store system chunk (#119)

* debug looking at system chunk

* send over the system chunk events

state.go

@@ -78,7 +78,7 @@ type OverflowBetaClient interface {
 	OverflowClient
 	GetTransactionById(ctx context.Context, id flow.Identifier) (*flow.Transaction, error)
 	GetOverflowTransactionById(ctx context.Context, id flow.Identifier) (*OverflowTransaction, error)
-	GetTransactions(ctx context.Context, id flow.Identifier) ([]OverflowTransaction, error)
+	GetTransactions(ctx context.Context, id flow.Identifier) ([]OverflowTransaction, OverflowEvents, error)
 	StreamTransactions(ctx context.Context, poll time.Duration, height uint64, logger *zap.Logger, channel chan<- BlockResult) error
 }
 

transaction.go

@@ -18,10 +18,11 @@ import (
 type FilterFunction func(OverflowTransaction) bool
 
 type BlockResult struct {
-	Transactions []OverflowTransaction
-	Block        flow.Block
-	Error        error
-	Logger       *zap.Logger
+	Transactions      []OverflowTransaction
+	SystemChunkEvents OverflowEvents
+	Block             flow.Block
+	Error             error
+	Logger            *zap.Logger
 }
 
 type Argument struct {
@@ -155,7 +156,8 @@ func (o *OverflowState) GetTransactionById(ctx context.Context, id flow.Identifi
 	return tx, nil
 }
 
-func (o *OverflowState) GetTransactions(ctx context.Context, id flow.Identifier) ([]OverflowTransaction, error) {
+// this is get from block, needs to return system chunk information
+func (o *OverflowState) GetTransactions(ctx context.Context, id flow.Identifier) ([]OverflowTransaction, OverflowEvents, error) {
 
 	//sometimes this will become too complex.
 
@@ -169,17 +171,18 @@ func (o *OverflowState) GetTransactions(ctx context.Context, id flow.Identifier)
 		time.Sleep(time.Millisecond * 200)
 		tx, txR, err = o.Flowkit.GetTransactionsByBlockID(ctx, id)
 		if err != nil {
-			return nil, errors.Wrap(err, "getting transaction results")
+			return nil, nil, errors.Wrap(err, "getting transaction results")
 		}
 	}
 
+	var systemChunkEvents OverflowEvents
 	result := lo.FlatMap(txR, func(rp *flow.TransactionResult, i int) []OverflowTransaction {
 		r := *rp
 
 		if r.TransactionID.String() == "f31815934bff124e332b3c8be5e1c7a949532707251a9f2f81def8cc9f3d1458" {
+			systemChunkEvents, _ = parseEvents(r.Events)
 			return []OverflowTransaction{}
 		}
-
 		t := *tx[i]
 
 		//for some reason we get epoch heartbeat
@@ -194,7 +197,7 @@ func (o *OverflowState) GetTransactions(ctx context.Context, id flow.Identifier)
 		return []OverflowTransaction{*ot}
 	})
 
-	return result, nil
+	return result, systemChunkEvents, nil
 
 }
 
@@ -245,13 +248,13 @@ func (o *OverflowState) StreamTransactions(ctx context.Context, poll time.Durati
 			} else {
 				block = latestKnownBlock
 			}
-			tx, err := o.GetTransactions(ctx, block.ID)
+			tx, systemChunkEvents, err := o.GetTransactions(ctx, block.ID)
 			if err != nil {
 				logg.Debug("getting transaction", zap.Error(err))
 				if strings.Contains(err.Error(), "could not retrieve collection: key not found") {
 					continue
 				}
-				channel <- BlockResult{Block: *block, Error: errors.Wrap(err, "getting transactions"), Logger: logg}
+				channel <- BlockResult{Block: *block, SystemChunkEvents: systemChunkEvents, Error: errors.Wrap(err, "getting transactions"), Logger: logg}
 				height = nextBlockToProcess
 				continue
 			}