-
Notifications
You must be signed in to change notification settings - Fork 50
/
api.go
120 lines (98 loc) · 2.88 KB
/
api.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
/*
* Copyright 2018 The openwallet Authors
* This file is part of the openwallet library.
*
* The openwallet library is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* The openwallet library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Lesser General Public License for more details.
*/
package sia
import (
"encoding/base64"
"fmt"
"github.com/imroc/req"
"github.com/pkg/errors"
"github.com/tidwall/gjson"
"log"
"net/http"
)
// A Client is a Bitcoin RPC client. It performs RPCs over HTTP using JSON
// request and responses. A Client must be configured with a secret token
// to authenticate with other Cores on the network.
type Client struct {
BaseURL string
Auth string
Debug bool
//Client *req.Req
}
type Response struct {
Code int `json:"code,omitempty"`
Error interface{} `json:"error,omitempty"`
Result interface{} `json:"result,omitempty"`
Message string `json:"message,omitempty"`
Id string `json:"id,omitempty"`
}
// Call calls for batch address
func (c *Client) CallBatchAddress(path, method string, request interface{}) ([]byte, error) {
url := c.BaseURL + "/" + path
authHeader := req.Header{
"Accept": "application/json",
"User-Agent": "Sia-Agent",
"Authorization": "Basic " + basicAuth("", c.Auth),
}
r, err := req.Do(
method,
url,
request,
authHeader)
if err != nil {
return nil, err
}
return r.Bytes(), nil
}
func (c *Client) Call(path, method string, request interface{}) ([]byte, error) {
url := c.BaseURL + "/" + path
authHeader := req.Header{
"Accept": "application/json",
"User-Agent": "Sia-Agent",
"Authorization": "Basic " + basicAuth("", c.Auth),
}
if c.Debug {
log.Println("Start Request API...")
}
r, err := req.Do(
method,
url,
request,
authHeader)
if c.Debug {
log.Println("Request API Completed")
}
if c.Debug {
log.Printf("%+v\n", r)
}
if err != nil {
return nil, err
}
if r.Response().StatusCode != http.StatusOK {
message := gjson.GetBytes(r.Bytes(), "message").String()
message = fmt.Sprintf("[%s]%s", r.Response().Status, message)
return nil, errors.New(message)
}
return r.Bytes(), nil
}
// See 2 (end of page 4) http://www.ietf.org/rfc/rfc2617.txt
// "To receive authorization, the client sends the userid and password,
// separated by a single colon (":") character, within a base64
// encoded string in the credentials."
// It is not meant to be urlencoded.
func basicAuth(username, password string) string {
auth := username + ":" + password
return base64.StdEncoding.EncodeToString([]byte(auth))
}