Add Client & CreateSubscription.

Author: kaito2

Diff for: client.go

@@ -0,0 +1,70 @@
+package rssapi
+
+import (
+	"context"
+	"encoding/json"
+	"io"
+	"log"
+	"net/http"
+	"net/url"
+	"path"
+
+	"github.com/pkg/errors"
+)
+
+type Client struct {
+	url        *url.URL
+	apiKey     string
+	httpClient *http.Client
+
+	Logger *log.Logger
+}
+
+// NewClient returns new RSS API Client.
+func NewClient(urlStr, apiKey string, logger *log.Logger) (*Client, error) {
+	parsedURL, err := url.Parse(urlStr)
+	if err != nil {
+		return nil, errors.Wrap(err, "failed to parse url")
+	}
+
+	// TODO: Configure HTTP Client.
+	httpClient := &http.Client{}
+
+	var discardLogger = log.New(io.Discard, "", log.LstdFlags)
+	if logger == nil {
+		logger = discardLogger
+	}
+
+	return &Client{
+		url:        parsedURL,
+		apiKey:     apiKey,
+		httpClient: httpClient,
+		Logger:     logger,
+	}, nil
+}
+
+func (c *Client) newGETRequest(ctx context.Context, spath string, query map[string]string) (*http.Request, error) {
+	u := *c.url
+	u.Path = path.Join(c.url.Path, spath)
+
+	q := u.Query()
+	for k, v := range query {
+		q.Add(k, v)
+	}
+	u.RawQuery = q.Encode()
+
+	req, err := http.NewRequestWithContext(ctx, http.MethodGet, u.String(), nil)
+	if err != nil {
+		return nil, errors.Wrap(err, "failed to create new request")
+	}
+
+	req.Header.Add("X-API-KEY", c.apiKey)
+
+	return req, nil
+}
+
+func decodeBody(resp *http.Response, out interface{}) error {
+	defer resp.Body.Close()
+	decoder := json.NewDecoder(resp.Body)
+	return decoder.Decode(out)
+}

Diff for: create_subscription.go

@@ -0,0 +1,49 @@
+package rssapi
+
+import (
+	"context"
+	"fmt"
+	"github.com/pkg/errors"
+)
+
+type CreateSubscriptionResponse struct {
+	OK     bool `json:"ok"`
+	Result struct {
+		Status         string `json:"status"`          // e.g. "subscribed"
+		SubscriptionID string `json:"subscription_id"` // e.g. "22946
+		FeedType       string `json:"feed_type"`       // e.g. "rss"
+		WebhookURL     string `json:"webhook_url"`     // e.g. "https://example.org/webhook"
+		URL            string `json:"url"`             // e.g. "https://www.nasa.gov/rss/dyn/breaking_news.rss"
+		Info           string `json:"info"`
+	} `json:"result"`
+}
+
+// CreateSubscription Create a Subscription.
+// TODO: Make `info` to optional.
+func (c *Client) CreateSubscription(ctx context.Context, url, info string) (*CreateSubscriptionResponse, error) {
+	// TODO: Set header for authentication.
+	spath := fmt.Sprintf("/v1/header/subscribe")
+	q := map[string]string{
+		"url":  url,
+		"info": info,
+	}
+	req, err := c.newGETRequest(ctx, spath, q)
+	if err != nil {
+		// TODO: Define custom error type.
+		return nil, errors.Wrap(err, "failed to create GET request")
+	}
+
+	res, err := c.httpClient.Do(req)
+	if err != nil {
+		return nil, errors.Wrap(err, "failed to Do http request")
+	}
+
+	// TODO: Check status here...
+
+	var createSubscriptionResponse CreateSubscriptionResponse
+	if err := decodeBody(res, &createSubscriptionResponse); err != nil {
+		return nil, errors.Wrap(err, "failed to decode response body")
+	}
+
+	return &createSubscriptionResponse, nil
+}

Diff for: example/create_subscription/main.go

@@ -0,0 +1,33 @@
+package main
+
+import (
+	"context"
+	"github.com/kaito2/rssapi-go"
+	"log"
+	"os"
+)
+
+func main() {
+	apiKey := os.Getenv("RSS_API_API_KEY")
+	if apiKey == "" {
+		log.Fatal("Please set the environment variable named RSS_API_API_KEY.")
+	}
+
+	client, err := rssapi.NewClient(
+		"https://api.rssapi.net",
+		apiKey,
+		nil,
+	)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	ctx := context.Background()
+	res, err := client.CreateSubscription(
+		ctx, "https://www.nasa.gov/rss/dyn/breaking_news.rss", "test-info")
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	log.Println(*res)
+}

Diff for: go.mod

@@ -0,0 +1,5 @@
+module github.com/kaito2/rssapi-go
+
+go 1.18
+
+require github.com/pkg/errors v0.9.1

Diff for: go.sum

@@ -0,0 +1,2 @@
+github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
+github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=