close file and gzip writer when app finished (#16)

* close file and gzip writer when app finished

* update celestia event key

* update celestia event value

* bug fix query raw_commit

Author: sh-cha

client/client.go

@@ -509,7 +509,7 @@ func (c *baseRPCClient) RawCommit(ctx context.Context, height *int64) ([]byte, e
 	if height != nil {
 		params["height"] = height
 	}
-	_, err := c.caller.Call(ctx, "commit", params, result)
+	_, err := c.caller.Call(ctx, "raw_commit", params, result)
 	if err != nil {
 		return nil, err
 	}

executor/batch/batch.go

@@ -119,7 +119,12 @@ func (bs *BatchSubmitter) Initialize(ctx context.Context, startHeight uint64, ho
 		bs.DequeueBatchInfo()
 	}
 
-	fileFlag := os.O_CREATE | os.O_RDWR
+	fileFlag := os.O_CREATE | os.O_RDWR | os.O_APPEND
+	bs.batchFile, err = os.OpenFile(bs.homePath+"/batch", fileFlag, 0666)
+	if err != nil {
+		return err
+	}
+
 	if bs.node.HeightInitialized() {
 		bs.localBatchInfo.Start = bs.node.GetHeight()
 		bs.localBatchInfo.End = 0
@@ -129,14 +134,15 @@ func (bs *BatchSubmitter) Initialize(ctx context.Context, startHeight uint64, ho
 		if err != nil {
 			return err
 		}
-	} else {
-		// if the node has already processed blocks, append to the file
-		fileFlag |= os.O_APPEND
-	}
-
-	bs.batchFile, err = os.OpenFile(bs.homePath+"/batch", fileFlag, 0666)
-	if err != nil {
-		return err
+		// reset batch file
+		err := bs.batchFile.Truncate(0)
+		if err != nil {
+			return err
+		}
+		_, err = bs.batchFile.Seek(0, 0)
+		if err != nil {
+			return err
+		}
 	}
 	// linux command gzip use level 6 as default
 	bs.batchWriter, err = gzip.NewWriterLevel(bs.batchFile, 6)
@@ -162,6 +168,15 @@ func (bs *BatchSubmitter) Start(ctx context.Context) {
 	bs.node.Start(ctx)
 }
 
+func (bs *BatchSubmitter) Close() {
+	if bs.batchWriter != nil {
+		bs.batchWriter.Close()
+	}
+	if bs.batchFile != nil {
+		bs.batchFile.Close()
+	}
+}
+
 func (bs *BatchSubmitter) SetBridgeInfo(bridgeInfo opchildtypes.BridgeInfo) {
 	bs.bridgeInfo = bridgeInfo
 }

executor/celestia/handler.go

@@ -2,6 +2,7 @@ package celestia
 
 import (
 	"context"
+	"encoding/base64"
 
 	nodetypes "github.com/initia-labs/opinit-bots/node/types"
 	"go.uber.org/zap"
@@ -14,13 +15,24 @@ func (c *Celestia) payForBlobsHandler(_ context.Context, args nodetypes.EventHan
 
 	for _, attr := range args.EventAttributes {
 		switch attr.Key {
-		// signer
-		case "signer":
-			signer = attr.Value
-		case "blob_sizes":
-			blobSizes = attr.Value
-		case "namespaces":
-			namespaces = attr.Value
+		case "c2lnbmVy": // signer
+			value, err := base64.StdEncoding.DecodeString(attr.Value)
+			if err != nil {
+				return err
+			}
+			signer = string(value)
+		case "YmxvYl9zaXplcw==": // blob_sizes
+			value, err := base64.StdEncoding.DecodeString(attr.Value)
+			if err != nil {
+				return err
+			}
+			blobSizes = string(value)
+		case "bmFtZXNwYWNlcw==": // namespaces
+			value, err := base64.StdEncoding.DecodeString(attr.Value)
+			if err != nil {
+				return err
+			}
+			namespaces = string(value)
 		}
 	}
 	c.logger.Info("record batch",

executor/executor.go

@@ -143,6 +143,7 @@ func (ex *Executor) Start(ctx context.Context) error {
 }
 
 func (ex *Executor) Close() {
+	ex.batch.Close()
 	ex.db.Close()
 }