init

Author: outprog

.gitignore

@@ -0,0 +1,2 @@
+main.go
+test-keyfile.json

README.md

@@ -0,0 +1,76 @@
+# goar
+
+### Install
+
+```
+go get github.com/everFinance/goar
+```
+
+### Example
+
+Send winston
+
+```golang
+package main
+
+import (
+	"fmt"
+	"math/big"
+
+	"github.com/everFinance/goar/types"
+	"github.com/everFinance/goar/wallet"
+)
+
+func main() {
+	wallet, err := wallet.NewFromPath("./test-keyfile.json")
+	if err != nil {
+		panic(err)
+	}
+
+	id, stat, err := wallet.SendWinston(
+		big.NewInt(1),
+		{{target}}, // target address
+		[]types.Tag{
+			types.Tag{
+				Name:  "testSendWinston",
+				Value: "1",
+			},
+		},
+	)
+
+	fmt.Println(id, stat, err) // {{id}}, Pending, nil
+}
+
+```
+
+Send Data
+
+```golang
+package main
+
+import (
+	"fmt"
+
+	"github.com/everFinance/goar/types"
+	"github.com/everFinance/goar/wallet"
+)
+
+func main() {
+	wallet, err := wallet.NewFromPath("./test-keyfile.json")
+	if err != nil {
+		panic(err)
+	}
+
+	id, stat, err := wallet.SendData(
+		[]byte("123"),
+		[]types.Tag{
+			types.Tag{
+				Name:  "testSendData",
+				Value: "123",
+			},
+		},
+	)
+
+	fmt.Println(id, stat, err) // {{id}}, Pending, nil
+}
+```

client/client.go

@@ -0,0 +1,189 @@
+package client
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"net/http"
+	"net/url"
+	"path"
+	"strconv"
+
+	"github.com/everFinance/goar/types"
+)
+
+type Client struct {
+	client *http.Client
+	url    string
+}
+
+func New(url string) *Client {
+	return &Client{client: http.DefaultClient, url: url}
+}
+
+func (c *Client) GetInfo() (info *types.NetworkInfo, err error) {
+	body, _, err := c.httpGet("info")
+	if err != nil {
+		return
+	}
+
+	info = &types.NetworkInfo{}
+	err = json.Unmarshal(body, info)
+	return
+}
+
+// Transaction
+// status: Pending/Invalid hash/overspend
+func (c *Client) GetTransactionByID(id string) (tx *types.Transaction, status string, err error) {
+	body, statusCode, err := c.httpGet(fmt.Sprintf("tx/%s", id))
+	if err != nil {
+		return
+	}
+
+	if statusCode != 200 {
+		status = string(body)
+		return
+	}
+
+	tx = &types.Transaction{}
+	err = json.Unmarshal(body, tx)
+	return
+}
+
+func (c *Client) GetTransactionField(id string, field string) (f string, err error) {
+	// TODO
+	return
+}
+
+func (c *Client) GetTransactionData(id string, extension string) (body []byte, err error) {
+	url := fmt.Sprintf("tx/%v/%v", id, "data")
+	if extension != "" {
+		url = url + "." + extension
+	}
+
+	body, statusCode, err := c.httpGet(url)
+	if statusCode != 200 {
+		err = fmt.Errorf("not found data")
+	}
+
+	return
+}
+
+func (c *Client) GetTransactionPrice(data []byte, target *string) (reward int64, err error) {
+	url := fmt.Sprintf("price/%d", len(data))
+	if target != nil {
+		url = fmt.Sprintf("%v/%v", url, *target)
+	}
+
+	body, _, err := c.httpGet(url)
+	if err != nil {
+		return
+	}
+
+	return strconv.ParseInt(string(body), 10, 64)
+}
+
+func (c *Client) GetTransactionAnchor() (anchor string, err error) {
+	body, _, err := c.httpGet("tx_anchor")
+	if err != nil {
+		return
+	}
+
+	anchor = string(body)
+	return
+}
+
+func (c *Client) SubmitTransaction(tx *types.Transaction) (status string, err error) {
+	by, err := json.Marshal(tx)
+	if err != nil {
+		return
+	}
+
+	body, _, err := c.httpPost("tx", by)
+	status = string(body)
+	return
+}
+
+func (c *Client) Arql(arql string) (ids []string, err error) {
+	body, _, err := c.httpPost("arql", []byte(arql))
+	err = json.Unmarshal(body, &ids)
+	return
+}
+
+// Wallet
+func (c *Client) GetWalletBalance(address string) (amount string, err error) {
+	// TODO
+	return
+}
+
+func (c *Client) GetLastTransactionID(address string) (id string, err error) {
+	body, _, err := c.httpGet(fmt.Sprintf("wallet/%s/last_tx", address))
+	if err != nil {
+		return
+	}
+
+	id = string(body)
+	return
+}
+
+// Block
+func (c *Client) GetBlockByID(id string) (block *types.Block, err error) {
+	body, _, err := c.httpGet(fmt.Sprintf("block/hash/%s", id))
+	if err != nil {
+		return
+	}
+
+	block = &types.Block{}
+	err = json.Unmarshal(body, block)
+	return
+}
+
+func (c *Client) GetBlockByHeight(height int64) (block *types.Block, err error) {
+	body, _, err := c.httpGet(fmt.Sprintf("block/height/%d", height))
+	if err != nil {
+		return
+	}
+
+	block = &types.Block{}
+	err = json.Unmarshal(body, block)
+	return
+}
+
+func (c *Client) httpGet(_path string) (body []byte, statusCode int, err error) {
+	u, err := url.Parse(c.url)
+	if err != nil {
+		return
+	}
+
+	u.Path = path.Join(u.Path, _path)
+
+	resp, err := c.client.Get(u.String())
+	if err != nil {
+		return
+	}
+	defer resp.Body.Close()
+
+	statusCode = resp.StatusCode
+	body, err = ioutil.ReadAll(resp.Body)
+	return
+}
+
+func (c *Client) httpPost(_path string, payload []byte) (body []byte, statusCode int, err error) {
+	u, err := url.Parse(c.url)
+	if err != nil {
+		return
+	}
+
+	u.Path = path.Join(u.Path, _path)
+
+	resp, err := c.client.Post(u.String(), "application/json", bytes.NewReader(payload))
+	if err != nil {
+		return
+	}
+	defer resp.Body.Close()
+
+	statusCode = resp.StatusCode
+	body, err = ioutil.ReadAll(resp.Body)
+	return
+}

client/client_test.go

@@ -0,0 +1,64 @@
+package client
+
+// import (
+// 	"fmt"
+// 	"testing"
+
+// 	"github.com/everFinance/goar/types"
+// 	"github.com/stretchr/testify/assert"
+// )
+
+// func TestGetTransactionByID(t *testing.T) {
+// 	client := New("https://arweave.net")
+// 	fmt.Println(client.GetTransactionByID("FgcKlptyDXSgEonYfy5cNBimq7GJ4h8h6L6pxuuYOBc"))
+// }
+
+// func TestGetTransactionPrice(t *testing.T) {
+// 	client := New("https://arweave.net")
+// 	target := ""
+// 	reward, err := client.GetTransactionPrice([]byte("123"), &target)
+// 	assert.NoError(t, err)
+// 	fmt.Println(reward)
+// }
+
+// func TestGetLastTransactionID(t *testing.T) {
+// 	client := New("https://arweave.net")
+// 	lastTx, err := client.GetLastTransactionID("dQzTM9hXV5MD1fRniOKI3MvPF_-8b2XDLmpfcMN9hi8")
+// 	assert.NoError(t, err)
+// 	fmt.Println(lastTx)
+// }
+
+// func TestGetTransactionAnchor(t *testing.T) {
+// 	client := New("https://arweave.net")
+// 	fmt.Println(client.GetTransactionAnchor())
+// }
+
+// func TestSubmitTransaction(t *testing.T) {
+// 	client := New("https://arweave.net")
+// 	fmt.Println(
+// 		client.SubmitTransaction(&types.Transaction{
+// 			ID: "n1iKT3trKn6Uvd1d8XyOqKBy8r-8SSBtGA62m3puK5k",
+// 		}),
+// 	)
+// }
+
+// func TestArql(t *testing.T) {
+// 	client := New("https://arweave.net")
+// 	fmt.Println(
+// 		client.Arql(`
+// 		{
+// 			"op": "and",
+// 			"expr1": {
+// 				"op": "equals",
+// 				"expr1": "TokenSymbol",
+// 				"expr2": "ROL"
+// 			},
+// 			"expr2": {
+// 				"op": "equals",
+// 				"expr1": "CreatedBy",
+// 				"expr2": "dQzTM9hXV5MD1fRniOKI3MvPF_-8b2XDLmpfcMN9hi8"
+// 			}
+// 		}
+// 		`),
+// 	)
+// }

go.mod

@@ -0,0 +1,6 @@
+module github.com/everFinance/goar
+
+go 1.14
+
+require github.com/stretchr/testify v1.6.1
+require github.com/everFinance/gojwk v1.0.0

go.sum

@@ -0,0 +1,12 @@
+github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/everFinance/gojwk v1.0.0 h1:le/oI2NgXlrqg3MHU6ka+V30EWcD7TD6+Ilh+go7924=
+github.com/everFinance/gojwk v1.0.0/go.mod h1:icXSXsIdpAczlpAtSljQlmABkMTRZENr73KHmo0GOGc=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=
+github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=