add: filecoin getmessage method for rpc package

This commit is contained in:
bahadylbekov 2020-08-07 01:48:28 +03:00
parent 953e54a41c
commit 3c68e8fea3

View File

@ -2,6 +2,7 @@ package rpc
import ( import (
"bytes" "bytes"
"encoding/json"
"fmt" "fmt"
"net/http" "net/http"
@ -9,21 +10,54 @@ import (
) )
// client implements the `Client` interface. // client implements the `Client` interface.
type lotusClient struct { type LotusClient struct {
host string host string
jwt jwt.Token jwt jwt.Token
} }
type RequestBody struct {
Jsonrpc string
Method string
Params []string
ID int
}
func NewRequestBody(method string) *RequestBody {
return &RequestBody{
Jsonrpc: "2.0",
Method: method,
Params: []string{},
ID: 0,
}
}
// NewClient returns a new client. // NewClient returns a new client.
func NewLotusClient(host string, token jwt.Token) Client { func NewLotusClient(host string, token jwt.Token) Client {
return &lotusClient{ return &LotusClient{
host: host, host: host,
jwt: token, jwt: token,
} }
} }
func (c *LotusClient) GetMessage(r *http.Request, txHash string) (*http.Response, error) {
requestBody := NewRequestBody("Filecoin.GetMessage")
requestBody.Params = append(requestBody.Params, txHash)
body, err := json.Marshal(requestBody)
if err != nil {
return nil, fmt.Errorf("Failed to marshal request body %v", err)
}
client := http.Client{}
req, err := http.NewRequest("POST", c.host, bytes.NewBuffer(body))
req.Header.Set("Content-Type", "application/json")
req.Header.Set("Authentication", "Bearer "+c.jwt.Raw)
if err != nil {
return nil, fmt.Errorf("Failed to construct lotus node rpc request %v", err)
}
return client.Do(req)
}
// HandleRequest implements the `Client` interface. // HandleRequest implements the `Client` interface.
func (c *lotusClient) HandleRequest(r *http.Request, data []byte) (*http.Response, error) { func (c *LotusClient) HandleRequest(r *http.Request, data []byte) (*http.Response, error) {
client := http.Client{} client := http.Client{}
req, err := http.NewRequest("POST", c.host, bytes.NewBuffer(data)) req, err := http.NewRequest("POST", c.host, bytes.NewBuffer(data))
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")