Add nodeid and signature to ledgers

internal/transform/ledger.go

@@ -1,13 +1,15 @@
 package transform
 
 import (
+	"encoding/base64"
 	"fmt"
 	"strconv"
 
 	"github.com/stellar/stellar-etl/internal/toid"
 	"github.com/stellar/stellar-etl/internal/utils"
 
 	"github.com/stellar/go/historyarchive"
+	"github.com/stellar/go/strkey"
 	"github.com/stellar/go/xdr"
 )
 
@@ -64,6 +66,17 @@ func TransformLedger(inputLedger historyarchive.Ledger, lcm xdr.LedgerCloseMeta)
 		}
 	}
 
+	var outputNodeID string
+	var outputSignature string
+	LedgerCloseValueSignature, ok := ledgerHeader.ScpValue.Ext.GetLcValueSignature()
+	if ok {
+		outputNodeID, err = getAddress(LedgerCloseValueSignature.NodeId)
+		if err != nil {
+			return LedgerOutput{}, err
+		}
+		outputSignature = base64.StdEncoding.EncodeToString(LedgerCloseValueSignature.Signature)
+	}
+
 	transformedLedger := LedgerOutput{
 		Sequence:                   outputSequence,
 		LedgerID:                   outputLedgerID,
@@ -83,6 +96,8 @@ func TransformLedger(inputLedger historyarchive.Ledger, lcm xdr.LedgerCloseMeta)
 		MaxTxSetSize:               outputMaxTxSetSize,
 		ProtocolVersion:            outputProtocolVersion,
 		SorobanFeeWrite1Kb:         outputSorobanFeeWrite1Kb,
+		NodeID:                     outputNodeID,
+		Signature:                  outputSignature,
 	}
 	return transformedLedger, nil
 }
@@ -167,3 +182,20 @@ func getTransactionPhase(transactionPhase []xdr.TransactionPhase) (transactionEn
 	return transactionSlice
 
 }
+
+// TODO: This should be moved into the go monorepo xdr functions
+// Or nodeID should just be an xdr.AccountId but the error message would be incorrect
+func getAddress(nodeID xdr.NodeId) (string, error) {
+	switch nodeID.Type {
+	case xdr.PublicKeyTypePublicKeyTypeEd25519:
+		ed, ok := nodeID.GetEd25519()
+		if !ok {
+			return "", fmt.Errorf("Could not get Ed25519")
+		}
+		raw := make([]byte, 32)
+		copy(raw, ed[:])
+		return strkey.Encode(strkey.VersionByteAccountID, raw)
+	default:
+		return "", fmt.Errorf("Unknown node id type: %v", nodeID.Type)
+	}
+}

internal/transform/schema.go

@@ -29,6 +29,8 @@ type LedgerOutput struct {
 	ProtocolVersion            uint32    `json:"protocol_version"`
 	LedgerID                   int64     `json:"id"`
 	SorobanFeeWrite1Kb         int64     `json:"soroban_fee_write_1kb"`
+	NodeID                     string    `json:"node_id"`
+	Signature                  string    `json:"signature"`
 }
 
 // TransactionOutput is a representation of a transaction that aligns with the BigQuery table history_transactions