progress callback for treeWrite

package-lock.json

 {
   "name": "xrpio",
-  "version": "0.2.3",
+  "version": "0.3.0",
   "lockfileVersion": 2,
   "requires": true,
   "packages": {
     "": {
       "name": "xrpio",
-      "version": "0.2.3",
+      "version": "0.3.0",
       "license": "MIT",
       "dependencies": {
         "axios": "^1.7.7",

src/xrpIO/xrpl-binding.ts

     this.dbg("Sending payment", wallet.address, '->', to)
 
     const _api = await this.cloneApi()
+    
     const payment: Payment = await _api.autofill({
       TransactionType: 'Payment',
       Account: wallet.address,
       Memos: [{
         Memo: {
           MemoData: hexEncode(data.data || ""),
-          MemoFormat: hexEncode(data.format || ""),
+          MemoFormat: hexEncode(data.format || "0"),
           MemoType: hexEncode(data.type || "")
         }
       }]
     }
     const tx = await this.getTransaction(hash)
 
-    
-
     if(verifyOwner && tx.result.tx_json.Account != verifyOwner){
       throw new CannotVerifyOwnerError(hash, tx.result.tx_json.Account, verifyOwner)
     }
     return memoParsed
   }
 
-  public async treeWrite(data: string, to: string, secret: string, format: 'L' | 'N' = 'L'): Promise<string> {
+  public async treeWrite(data: string, to: string, secret: string, format: string = "0"): Promise<string> {
     const wallet = Wallet.fromSecret(secret)
     data = await compressB64(data)
     const chunks = chunkString(data, PAYLOAD_SIZE)
       return hashes[0]
     }
 
-    return await this.treeWrite(JSON.stringify(hashes), to, secret, 'N')
+    return await this.treeWrite(JSON.stringify(hashes), to, secret, `${hashes.length}`)
   }
 
-  public async treeRead(hashes: string[], verifyOwner?:string): Promise<string> {
+  private maxMemos = 0
+
+  public async treeRead(hashes: string[], verifyOwner?:string, progressCallback:(max:number,finished:number)=>void = ()=>{}): Promise<string> {
     const bad_hash = hashes.find(hash => !NON_ZERO_TX_HASH.test(hash))
     if (bad_hash)
       throw new BadTxHashError(bad_hash)
 
-    const memos = await Promise.all(hashes.map(hash => this.readRaw(hash, verifyOwner)))
+    let count = 0;
+
+    const memos = await Promise.all(hashes.map(async hash => {
+      const memo = await this.readRaw(hash, verifyOwner)
+      if(String(memo.format) === '0'){
+        count += 1;
+        progressCallback(count, this.maxMemos)
+        if(count === this.maxMemos){
+          this.maxMemos = 0;
+        }
+      }else{
+        this.maxMemos = Math.max(this.maxMemos, Number(memo.format))
+        progressCallback(-1, this.maxMemos)
+      }
+      return memo
+    }))
     const payload: string = await decompressB64(memos.map(memo => memo.data).join(''))
 
-    if (memos.some(memo => memo.format === 'N')) {
-      return await this.treeRead(JSON.parse(payload), verifyOwner)
+    if (memos.some(memo => memo.format !== '0')) {
+      return await this.treeRead(JSON.parse(payload), verifyOwner, progressCallback)
     }
 
     return payload