fix(): fix bundler tx

Author: zyjblockchain

README.md

@@ -324,7 +324,7 @@ bundle, err := utils.NewBundle(items...)
 #### Send Item to Bundler
 Bundler network provides guaranteed data seeding and instant data accessibility
 ```go
-resp, err := w.Client.BatchSendItemToBundler(items)
+resp, err := w.Client.BatchSendItemToBundler(items,"") // The second parameter is the bundler gateway url，"" means use default url
 ```
 
 #### Send Bundle Tx
@@ -343,4 +343,36 @@ for _, item := range bundle.Items {
   assert.NoError(t, err)
 }
 ```
+
+### notice
+if you call `w.Client.BatchSendItemToBundler(items,"")` 
+and return `panic: send to bundler request failed; http code: 402`        
+means that you have to pay ar to the bundler service address    
+must use item signature address to transfer funds   
+
+##### how to get bundler service address?
+```go
+curl --location --request GET 'https://node1.bundlr.network/info'
+
+response:
+{
+"uptime": 275690.552536824,
+"address": "OXcT1sVRSA5eGwt2k6Yuz8-3e3g9WJi5uSE99CWqsBs",
+"gateway": "arweave.net"
+}
+```
+This "address" is the bundler service receive ar address.    
+You need to transfer a certain amount of ar to this address    
+and wait for 25 blocks to confirm the transaction before you can use the bundler service.    
+
+You can also use the following api to query the balance in the bundler service.   
+```
+curl --location --request GET 'https://node1.bundlr.network/account/balance?address=Ii5wAMlLNz13n26nYY45mcZErwZLjICmYd46GZvn4ck'
+
+response:
+{
+    "balance": 1000000000
+}
+```
+
 ---

client_bundle.go

@@ -20,9 +20,12 @@ func (c *Client) GetBundle(arId string) (*types.Bundle, error) {
 }
 
 // SendItemToBundler send bundle bundleItem to bundler gateway
-func (c *Client) SendItemToBundler(itemBinary []byte) (*types.BundlerResp, error) {
+func (c *Client) SendItemToBundler(itemBinary []byte, gateway string) (*types.BundlerResp, error) {
+	if gateway == "" {
+		gateway = types.BUNDLER_HOST
+	}
 	// post to bundler
-	resp, err := http.DefaultClient.Post(types.BUNDLER_HOST+"/tx", "application/octet-stream", bytes.NewReader(itemBinary))
+	resp, err := http.DefaultClient.Post(gateway+"/tx", "application/octet-stream", bytes.NewReader(itemBinary))
 	if err != nil {
 		return nil, err
 	}
@@ -43,7 +46,7 @@ func (c *Client) SendItemToBundler(itemBinary []byte) (*types.BundlerResp, error
 	return br, nil
 }
 
-func (c *Client) BatchSendItemToBundler(bundleItems []types.BundleItem) ([]*types.BundlerResp, error) {
+func (c *Client) BatchSendItemToBundler(bundleItems []types.BundleItem, gateway string) ([]*types.BundlerResp, error) {
 	respList := make([]*types.BundlerResp, 0, len(bundleItems))
 	for _, item := range bundleItems {
 		itemBinary := item.ItemBinary
@@ -53,7 +56,7 @@ func (c *Client) BatchSendItemToBundler(bundleItems []types.BundleItem) ([]*type
 			}
 			itemBinary = item.ItemBinary
 		}
-		resp, err := c.SendItemToBundler(itemBinary)
+		resp, err := c.SendItemToBundler(itemBinary, gateway)
 		if err != nil {
 			return nil, err
 		}

example/bundle_test.go

@@ -47,11 +47,11 @@ func TestBundle_SendBundleTx(t *testing.T) {
 
 	// // send item to bundler gateway
 	// for _, item := range items {
-	// 	resp, err := w.Client.SendItemToBundler(item.ItemBinary)
+	// 	resp, err := w.Client.SendItemToBundler(item.ItemBinary,"")
 	// 	assert.NoError(t, err)
 	// 	t.Log(resp.Id)
 	// }
-	resp, err := w.Client.BatchSendItemToBundler(items)
+	resp, err := w.Client.BatchSendItemToBundler(items, "")
 	assert.NoError(t, err)
 	t.Log(resp)
 

types/const.go

@@ -45,6 +45,6 @@ var FATAL_CHUNK_UPLOAD_ERRORS = map[string]struct{}{
 
 // about bundle
 const (
-	BUNDLER_HOST           = "http://bundler.arweave.net:10000"
+	BUNDLER_HOST           = "https://node1.bundlr.network"
 	MIN_BUNDLE_BINARY_SIZE = 1044
 )