feat(): test

Author: zyjblockchain

client_test.go

@@ -1,10 +1,12 @@
 package goar
 
 import (
+	"github.com/everFinance/goar/types"
 	"github.com/everFinance/goar/utils"
 	"github.com/stretchr/testify/assert"
 	"io/ioutil"
 	"os"
+	"strconv"
 	"testing"
 )
 
@@ -348,3 +350,76 @@ func TestNewTempConn2(t *testing.T) {
 	err = utils.VerifyBundleItem(*item)
 	assert.NoError(t, err)
 }
+
+func TestNewClient2(t *testing.T) {
+	arTx := "b92IF6ZX0owPFcssPcs-qOBN2nuR0d3xLYOSovh1eck"
+	c := NewClient("https://arweave.net")
+	data, err := c.GetTransactionDataByGateway(arTx)
+
+	assert.NoError(t, err)
+	// data bundle binary
+	bundle, err := utils.DecodeBundle(data)
+	assert.NoError(t, err)
+
+	bundleItems := bundle.Items
+	for _, item := range bundleItems {
+		t.Log(item.Id)
+	}
+}
+
+func TestNewWallet2(t *testing.T) {
+	c := NewClient("https://arweave.net")
+	offsetResponse, err := c.getTransactionOffset("47KozLIAfVMKdxq1q3D1xFZmRpkahOOBQ8boOjSydnQ")
+	assert.NoError(t, err)
+	t.Log(offsetResponse.Offset)
+	t.Log(offsetResponse.Size)
+	size, err := strconv.ParseInt(offsetResponse.Size, 10, 64)
+	assert.NoError(t, err)
+	endOffset, err := strconv.ParseInt(offsetResponse.Offset, 10, 64)
+	assert.NoError(t, err)
+	startOffset := endOffset - size + 1
+	firstChunk, err := c.getChunkData(startOffset)
+	assert.NoError(t, err)
+
+	// 从 firstChunk 中获取 itemNum
+	itemsNum := utils.ByteArrayToLong(firstChunk[:32])
+	t.Log(itemsNum) // 739
+
+	// 解析出 item headers 并找到headers 的 offset
+	bundleItemStart := 32 + itemsNum*64
+	if len(firstChunk) < bundleItemStart {
+		// todo 需要拉取后面的多个 chunks
+	}
+	containHeadersChunks := firstChunk // todo
+	for i := 0; i < itemsNum; i++ {
+		headerBegin := 32 + i*64
+		end := headerBegin + 64
+		headerByte := containHeadersChunks[headerBegin:end]
+		itemBinaryLength := utils.ByteArrayToLong(headerByte[:32])
+		id := utils.Base64Encode(headerByte[32:64])
+
+		// --------- 1 ----2 ------
+		if id == "UCTEOaljmuutGJId-ktPY_q_Gbal8tyJuLfyR6BeaGw" {
+			t.Log("found item")
+			t.Log("item start offset", "offset", bundleItemStart, "length", itemBinaryLength)
+			startChunkNum := bundleItemStart / types.MAX_CHUNK_SIZE
+			startChunkOffset := bundleItemStart % types.MAX_CHUNK_SIZE
+			data := make([]byte, 0, itemBinaryLength)
+			for offset := startOffset + int64(startChunkNum*types.MAX_CHUNK_SIZE); offset <= startOffset+int64(bundleItemStart+itemBinaryLength); {
+				chunk, err := c.getChunkData(offset)
+				assert.NoError(t, err)
+				data = append(data, chunk...)
+				offset += int64(len(chunk))
+			}
+			itemData := data[startChunkOffset : startChunkOffset+itemBinaryLength]
+			item, err := utils.DecodeBundleItem(itemData)
+			assert.NoError(t, err)
+			dd, _ := utils.Base64Decode(item.Data)
+			t.Log(string(dd))
+			t.Log(item.Id)
+			t.Log(item.SignatureType)
+		}
+
+		bundleItemStart += itemBinaryLength // next itemBy start offset
+	}
+}

example/api_example_test.go

@@ -52,6 +52,14 @@ func Test_Client(t *testing.T) {
 
 }
 
+func Test_Arq1(t *testing.T) {
+	arNode := "https://arweave.net"
+	c := goar.NewClient(arNode)
+	dd, err := c.GetTransactionPrice(712, nil)
+	assert.NoError(t, err)
+	t.Log(dd)
+}
+
 func Test_Arq(t *testing.T) {
 	arqStr := `{
 			"op": "and",

example/bundle_test.go

@@ -1,6 +1,7 @@
 package example
 
 import (
+	"bytes"
 	"context"
 	"errors"
 	"io"
@@ -52,6 +53,18 @@ func init() {
 	}
 }
 
+func TestBundleToArweave4(t *testing.T) {
+	itemSigner01, err := goar.NewItemSigner(signer01)
+	assert.NoError(t, err)
+	data := []byte("aabbcc")
+	item01, err := itemSigner01.CreateAndSignItemStream(bytes.NewReader(data), "", "", []types.Tag{
+		{Name: "Content-Type", Value: "application/txt"},
+		{Name: "App-Version", Value: "2.0.0"},
+	})
+	assert.NoError(t, err)
+	t.Log(item01)
+}
+
 func TestBundleToArweave(t *testing.T) {
 	// sig item01 by ecc signer
 	itemSigner01, err := goar.NewItemSigner(signer01)

utils/crypto_test.go

@@ -1,6 +1,8 @@
 package utils
 
 import (
+	"crypto/sha256"
+	"github.com/ethereum/go-ethereum/common/hexutil"
 	"github.com/stretchr/testify/assert"
 	"testing"
 )
@@ -17,3 +19,17 @@ func TestSignAndVerify(t *testing.T) {
 	assert.NoError(t, Verify(msg, &rightKey.PublicKey, sig))
 	assert.Error(t, Verify(msg, &wrongKey.PublicKey, sig))
 }
+
+func TestVerify(t *testing.T) {
+	pub, err := OwnerToPubKey("5oZAXKfBfZ32JIKSIUksXO6K27T9gnbJCnndpGTvKf1HFUh5uh1y38Zcxwn8D5hhOfgWoonVmWcuxvNBw3LaW4q7NUEu72ukg0KpaipGOqVvzChsP4MuD79mXgQd_N-J18MT51mO3uGwiMLJUohkWT_XkhSDSsPyJoS9xhoRZN9OseDB-4cIkevfIyewrBpmX6wSZ7yBf6lml5btAi57Aha-DvhUSEKV0mtsx7C81jf1Aw8B639zPomT7eYYRWepkGwfQ7_JZMJ7ddAC0hEUpTDcmBe20k5i9XzlmqB1bFIu236BrswD-xVTGvWidrEVTUafL8jOpSML875iOKGgC_y6aCgwMgTxemneWNgsUjkSOvi24fPxpGoFFzcRPWnQ1Ru5Wuw6RqO5RlVpvEvztXEE5IprXWdP286lgLTzcduagT4dHouhDrMaIP68lq17u2p3RaU2Awgn4kOQA-p8_iVESj9hPlLwhbQ48I46Vh2Eq6SgJffvr-mYqOY6jJB3AttsftMk8zxhmMl20nDT0RbKNGkKicezjbxXi9Pp2j4s_H_ynvrNvFWj_JS3wHITuX_vKcYFxgmExcpTa4FQsuwBeZxI2Ls9g4kkIM-CcXDwfp-aQ4JIpfWLWt5MKKx5ouhOXBQa5GvNs3YR3imhUTv1FOpm9n_jscWxwZJMTls")
+	assert.NoError(t, err)
+	data := "0xeaa110e6abf9423481fa6d5a72a3d66118e05ea4759fd4a6d6344de83e18dd52"
+	dataBy, err := hexutil.Decode(data)
+	assert.NoError(t, err)
+
+	sig, err := Base64Decode("5fS8LHBda15AMKBH8QQUuDCk23RJdYhWFq_rNoyPusqEdFGeiawSGwypcIhTeP9cOXKVZjf9LT9rPcEpJm49EdDb5FcqV7xCBSVV0CpLwJKCoYUMk1tDWFBN2wUbRDUe2PI7ycUKrurXrQeT1WfjEc-Nh7nGCR9kKv9MJfBoo76GhbC_CKtrmGFUeok3t9uoVjEOGC-iXtvMjh6G3hIV2JFIiSUdBS3qMIRa7FZiJ2ZkJaS-4vTwh70esP6KGkLYW5nhJWZ9Y0jIndLAxnFz-vcJJDmaq4fPUcWDO49sH0u8ZZe6mAs3Kdj2B7rGmzozYi4-j_nivnbWUGM7yCw6w1bops8Cxwr0g9l16lBPkAHBgxE1CGS0_KbsJ_GkbNlEU-6znEuFJpDubhC12QNmEeH8TIIwJqz8aw8G6zOyTP2wXyP6TIoFAemMIbyzAoV99QQ-2RWjnoLG0srgfacfJlhHcSSAaXFWB1Mr-bCCMjetLLcRrK5wwa-h7NAT6feZIUni0bq-SGc9oIVNDFvOsNJnHVKx644wpmdmNkZSINUccuJDwzNYKrbqqDIIpe_vzaAgLbS940LS5UmYtbkZkMvLQBFzbEW9C1A4rpJoDy-nibD0cqP1gg0AIdueElKrA1Szuj5Kh3_uOz-Fh81SYNLye4pX1bYWuV_wPt7qd3E")
+	assert.NoError(t, err)
+	hashed := sha256.Sum256(dataBy)
+	err = Verify(hashed[:], pub, sig)
+	assert.NoError(t, err)
+}