From b0ebfa5f0513abdbb1eb49012c9d45488afc2609 Mon Sep 17 00:00:00 2001
From: Drew DeVault <sir@cmpwn.com>
Date: Tue, 6 Oct 2020 11:21:03 -0400
Subject: [PATCH] client: import from gql.sr.ht

---
 client/graphql.go | 79 +++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 79 insertions(+)
 create mode 100644 client/graphql.go

diff --git a/client/graphql.go b/client/graphql.go
new file mode 100644
index 0000000000000000000000000000000000000000..1e40127d0ed6f2da16e0c961b0f5e90337b66b2d
--- /dev/null
+++ b/client/graphql.go
@@ -0,0 +1,79 @@
+package client
+
+import (
+	"bytes"
+	"context"
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"net/http"
+
+	"git.sr.ht/~sircmpwn/gql.sr.ht/config"
+	"git.sr.ht/~sircmpwn/gql.sr.ht/crypto"
+)
+
+type GraphQLQuery struct {
+	Query     string                 `json:"query"`
+	Variables map[string]interface{} `json:"variables"`
+}
+
+type InternalAuth struct {
+	Name     string `json:"name"`
+	ClientID string `json:"client_id"`
+	NodeID   string `json:"node_id"`
+}
+
+func Execute(ctx context.Context, username string, svc string,
+	query GraphQLQuery, result interface{}) error {
+	body, err := json.Marshal(query)
+	if err != nil {
+		panic(err) // Programmer error
+	}
+
+	conf := config.ForContext(ctx)
+	origin, ok := conf.Get(svc, "origin")
+	if !ok {
+		panic(fmt.Errorf("No %s origin specified in config.ini", svc))
+	}
+
+	reader := bytes.NewBuffer(body)
+	req, err := http.NewRequestWithContext(ctx,
+		"POST", fmt.Sprintf("%s/query", origin), reader)
+	if err != nil {
+		return err
+	}
+	req.Header.Add("Content-Type", "application/json")
+	auth := InternalAuth{
+		Name: username,
+		// TODO: Populate these better
+		ClientID: "gql.sr.ht",
+		NodeID:   "gql.sr.ht",
+	}
+	authBlob, err := json.Marshal(&auth)
+	if err != nil {
+		panic(err) // Programmer error
+	}
+	req.Header.Add("Authorization", fmt.Sprintf("Internal %s",
+		crypto.Encrypt(authBlob)))
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return err
+	}
+
+	defer resp.Body.Close()
+	respBody, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != 200 {
+		return fmt.Errorf("%s returned status %d: %s",
+			svc, resp.StatusCode, string(respBody))
+	}
+
+	if err = json.Unmarshal(respBody, result); err != nil {
+		return err
+	}
+
+	return nil
+}