hugo.go

package hugo

import (
	"encoding/json"
	"io/ioutil"
	"net/http"
	"strconv"
	"strings"
)

const (
	baseUrl = "https://api.hurriyet.com.tr/v1/"
)

// HurriyetAPI keeps apikey and baseUrl info.
type HurriyetAPI struct {
	apiKey  string
	client  *http.Client
	baseUrl string
}

// NewHurriyetAPI takes apiKey and returns new HurriyetAPI for communicating Hurriyet API.
func NewHurriyetAPI(apiKey string) *HurriyetAPI {
	return &HurriyetAPI{
		apiKey:  apiKey,
		baseUrl: baseUrl,
		client:  http.DefaultClient,
	}
}

// ListArticles returns articles.
func (h HurriyetAPI) ListArticles(query *Query) ([]Article, error) {
	data, err := h.request("articles", query)
	if err != nil {
		return nil, err
	}

	var articles []Article
	if jsonErr := json.Unmarshal(data, &articles); jsonErr != nil {
		// check response for error
		return nil, jsonErr
	}

	return articles, nil
}

// SingleArticle takes an id and returns an article .
func (h HurriyetAPI) SingleArticle(Id string, query *Query) (Article, error) {
	data, err := h.request("articles/"+Id, query)
	if err != nil {
		return Article{}, err
	}

	var article Article
	if jsonErr := json.Unmarshal(data, &article); jsonErr != nil {
		// check response for error
		return Article{}, jsonErr
	}

	return article, nil
}

// Search takes search keyword and returns search results.
func (h HurriyetAPI) Search(keyword string, query *Query) (Search, error) {
	data, err := h.request("search/"+keyword, query)
	if err != nil {
		return Search{}, err
	}

	var search Search
	if jsonErr := json.Unmarshal(data, &search); jsonErr != nil {
		// check response for error
		return Search{}, jsonErr
	}

	return search, nil
}

func (h HurriyetAPI) ListColumns(query *Query) ([]Column, error) {
	data, err := h.request("columns", query)
	if err != nil {
		return nil, err
	}

	var columns []Column
	if jsonErr := json.Unmarshal(data, &columns); jsonErr != nil {
		// check response for error
		return nil, jsonErr
	}

	return columns, nil
}

func (h HurriyetAPI) SingleColumn(Id string, query *Query) (Column, error) {
	data, err := h.request("columns/"+Id, query)
	if err != nil {
		return Column{}, err
	}

	var column Column
	if jsonErr := json.Unmarshal(data, &column); jsonErr != nil {
		// check response for error
		return Column{}, jsonErr
	}

	return column, nil
}

func (h HurriyetAPI) ListPages(query *Query) ([]Page, error) {
	data, err := h.request("pages", query)
	if err != nil {
		return nil, err
	}

	var pages []Page
	if jsonErr := json.Unmarshal(data, &pages); jsonErr != nil {
		// check response for error
		return nil, jsonErr
	}

	return pages, nil
}

func (h HurriyetAPI) SinglePage(Id string, query *Query) (Page, error) {
	data, err := h.request("pages/"+Id, query)
	if err != nil {
		return Page{}, err
	}

	var page Page
	if jsonErr := json.Unmarshal(data, &page); jsonErr != nil {
		// check response for error
		return Page{}, jsonErr
	}

	return page, nil
}

func (h HurriyetAPI) ListPhotoGalleries(query *Query) ([]Article, error) {
	data, err := h.request("newsphotogalleries", query)
	if err != nil {
		return nil, err
	}

	var galleries []Article
	if jsonErr := json.Unmarshal(data, &galleries); jsonErr != nil {
		// check response for error
		return nil, jsonErr
	}

	return galleries, nil
}

func (h HurriyetAPI) SinglePhotoGallery(Id string, query *Query) (Article, error) {
	data, err := h.request("newsphotogalleries/"+Id, query)
	if err != nil {
		return Article{}, err
	}

	var gallery Article
	if jsonErr := json.Unmarshal(data, &gallery); jsonErr != nil {
		// check response for error
		return Article{}, jsonErr
	}

	return gallery, nil
}

func (h HurriyetAPI) ListPaths(query *Query) ([]Path, error) {
	data, err := h.request("paths", query)
	if err != nil {
		return nil, err
	}

	var paths []Path
	if jsonErr := json.Unmarshal(data, &paths); jsonErr != nil {
		// check response for error
		return nil, jsonErr
	}

	return paths, nil
}

func (h HurriyetAPI) SinglePath(Id string, query *Query) (Path, error) {
	data, err := h.request("paths/"+Id, query)
	if err != nil {
		return Path{}, err
	}

	var path Path
	if jsonErr := json.Unmarshal(data, &path); jsonErr != nil {
		// check response for error
		return Path{}, jsonErr
	}

	return path, nil
}

func (h HurriyetAPI) ListWriters(query *Query) ([]Writer, error) {
	data, err := h.request("writers", query)
	if err != nil {
		return nil, err
	}

	var writers []Writer
	if jsonErr := json.Unmarshal(data, &writers); jsonErr != nil {
		// check response for error
		return nil, jsonErr
	}

	return writers, nil
}

func (h HurriyetAPI) SingleWriter(Id string, query *Query) (Writer, error) {
	data, err := h.request("writers/"+Id, query)
	if err != nil {
		return Writer{}, err
	}

	var writer Writer
	if jsonErr := json.Unmarshal(data, &writer); jsonErr != nil {
		// check response for error
		return Writer{}, jsonErr
	}

	return writer, nil
}

func (h HurriyetAPI) request(url string, query *Query) ([]byte, error) {
	req, err := http.NewRequest("GET", h.baseUrl+url, nil)
	req.Header.Add("apikey", h.apiKey)
	req.Header.Add("accept", "application/json")

	if query != nil {
		q := req.URL.Query()
		if len(query.Filter) > 0 {
			q.Add("$filter", query.Filter)
		}

		if len(query.Select) > 0 {
			q.Add("$select", strings.Join(query.Select, ","))
		}

		if query.Top > 0 {
			q.Add("$top", strconv.Itoa(query.Top))
		}

		if query.Skip > 0 {
			q.Add("$skip", strconv.Itoa(query.Skip))
		}

		if query.S != "" {
			q.Add("s", query.S)
		}

		req.URL.RawQuery = q.Encode()
	}

	resp, err := h.client.Do(req)

	if err != nil {
		return nil, err
	}

	defer resp.Body.Close()
	body, err := ioutil.ReadAll(resp.Body)

	if err != nil {
		return nil, err
	}

	return body, nil
}