重新整理api结构。

arbitrage/api/api_blockchain.go

@@ -1,32 +0,0 @@
-package api
-
-import (
-	"bytes"
-	"io/ioutil"
-	"net/http"
-)
-
-func HttpTest() (string, error) {
-	jsonDataStr := `
-{
-	"auth": {
-		"auth": "9d8b7074bf189dcad17189c8f264c0cb",
-		"timestamp": "123123"
-	}
-}
-`
-	jsonData := []byte(jsonDataStr)
-
-	resp, err := http.Post("http://web.410eth.com:8888", "application/json", bytes.NewBuffer(jsonData))
-	if err != nil {
-		return "", err
-	}
-	defer resp.Body.Close()
-
-	body, err := ioutil.ReadAll(resp.Body)
-	if err != nil {
-		return "", err
-	}
-
-	return string(body), nil
-}

arbitrage/api/api_blockchain_test.go

@@ -1,15 +0,0 @@
-package api
-
-import (
-	"testing"
-)
-
-func TestApi(t *testing.T) {
-	rst, err := HttpTest()
-
-	if err != nil {
-		t.Fatalf("err, %v.\n", err)
-	}
-
-	t.Logf(rst)
-}

arbitrage/api/blockchain_api.go

@@ -0,0 +1,64 @@
+package api
+
+import (
+	"bytes"
+	"fmt"
+	"io"
+	"net/http"
+)
+
+type BlockchainApi struct {
+	baseUrl string
+}
+
+func NewBlockchainApi() *BlockchainApi {
+	return &BlockchainApi{
+		baseUrl: "http://web.410eth.com:8888",
+	}
+}
+
+func HttpPost(url string, jsonDataStr string) (string, error) {
+	jsonData := []byte(jsonDataStr)
+
+	resp, err := http.Post(url, "application/json", bytes.NewBuffer(jsonData))
+	if err != nil {
+		return "", err
+	}
+	defer resp.Body.Close()
+
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return "", err
+	}
+
+	return string(body), nil
+}
+
+func (a *BlockchainApi) HelloWorld() (string, error) {
+	url := a.baseUrl
+	jsonDataStr := `
+{
+	"auth": {
+		"auth": "9d8b7074bf189dcad17189c8f264c0cb",
+		"timestamp": "123123"
+	}
+}
+`
+	return HttpPost(url, jsonDataStr)
+}
+
+func (a *BlockchainApi) V2LpCountByChainId(chainId int64) (string, error) {
+	url := a.baseUrl + "/v2-lp/countByChainId"
+	jsonDataStr := `
+{
+	"chainId": %d,
+	"auth": {
+		"auth": "9d8b7074bf189dcad17189c8f264c0cb",
+		"timestamp": "123123"
+	}
+}
+`
+	jsonDataStr = fmt.Sprintf(jsonDataStr, chainId)
+
+	return HttpPost(url, jsonDataStr)
+}

arbitrage/api/blockchain_api_test.go

@@ -0,0 +1,27 @@
+package api
+
+import (
+	"testing"
+)
+
+var api = NewBlockchainApi()
+
+func TestHelloWorld(t *testing.T) {
+	rst, err := api.HelloWorld()
+
+	if err != nil {
+		t.Fatalf("err, %v.\n", err)
+	}
+
+	t.Logf(rst)
+}
+
+func TestV2LpCountByChainId(t *testing.T) {
+	rst, err := api.V2LpCountByChainId(1116)
+
+	if err != nil {
+		t.Fatalf("err, %v.\n", err)
+	}
+
+	t.Logf(rst)
+}