5551/xdrill operations

go.mod

@@ -62,6 +62,7 @@ require (
 	github.com/docker/docker v27.3.1+incompatible
 	github.com/docker/go-connections v0.5.0
 	github.com/fsouza/fake-gcs-server v1.49.2
+	github.com/stellar/go-stellar-xdr-json v0.0.0-20250203230501-c6fa0788fe99
 )
 
 require (

go.sum

@@ -469,6 +469,8 @@ github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
 github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
 github.com/spf13/viper v1.17.0 h1:I5txKw7MJasPL/BrfkbA0Jyo/oELqVmux4pR/UxOMfI=
 github.com/spf13/viper v1.17.0/go.mod h1:BmMMMLQXSbcHK6KAOiFLz0l5JHrU89OdIRHvsk0+yVI=
+github.com/stellar/go-stellar-xdr-json v0.0.0-20250203230501-c6fa0788fe99 h1:m6P+35IPHoxYjAnEgZOgSiDXwEnFCIOpXdwNt8tZ/cw=
+github.com/stellar/go-stellar-xdr-json v0.0.0-20250203230501-c6fa0788fe99/go.mod h1:BQ9LWqVJ14qa7ctsyLmjEHSx3Pi7r/8A0mbKzib4cgs=
 github.com/stellar/go-xdr v0.0.0-20231122183749-b53fb00bcac2 h1:OzCVd0SV5qE3ZcDeSFCmOWLZfEWZ3Oe8KtmSOYKEVWE=
 github.com/stellar/go-xdr v0.0.0-20231122183749-b53fb00bcac2/go.mod h1:yoxyU/M8nl9LKeWIoBrbDPQ7Cy+4jxRcWcOayZ4BMps=
 github.com/stellar/throttled v2.2.3-0.20190823235211-89d75816f59d+incompatible h1:jMXXAcz6xTarGDQ4VtVbtERogcmDQw4RaE85Cr9CgoQ=

ingest/account_merge_details.go

@@ -0,0 +1,47 @@
+package ingest
+
+import "fmt"
+
+type AccountMergeDetail struct {
+	Account        string `json:"account"`
+	AccountMuxed   string `json:"account_muxed"`
+	AccountMuxedID uint64 `json:"account_muxed_id,string"`
+	Into           string `json:"into"`
+	IntoMuxed      string `json:"into_muxed"`
+	IntoMuxedID    uint64 `json:"into_muxed_id,string"`
+}
+
+func (o *LedgerOperation) AccountMergeDetails() (AccountMergeDetail, error) {
+	destinationAccount, ok := o.Operation.Body.GetDestination()
+	if !ok {
+		return AccountMergeDetail{}, fmt.Errorf("could not access Destination info for this operation (index %d)", o.OperationIndex)
+	}
+
+	accountMergeDetail := AccountMergeDetail{
+		Account: o.SourceAccount(),
+		Into:    destinationAccount.Address(),
+	}
+
+	var err error
+	var accountMuxed string
+	var accountMuxedID uint64
+	accountMuxed, accountMuxedID, err = getMuxedAccountDetails(o.sourceAccountXDR())
+	if err != nil {
+		return AccountMergeDetail{}, err
+	}
+
+	accountMergeDetail.AccountMuxed = accountMuxed
+	accountMergeDetail.AccountMuxedID = accountMuxedID
+
+	var intoMuxed string
+	var intoMuxedID uint64
+	intoMuxed, intoMuxedID, err = getMuxedAccountDetails(destinationAccount)
+	if err != nil {
+		return AccountMergeDetail{}, err
+	}
+
+	accountMergeDetail.IntoMuxed = intoMuxed
+	accountMergeDetail.IntoMuxedID = intoMuxedID
+
+	return accountMergeDetail, nil
+}

ingest/allow_trust_details.go

@@ -0,0 +1,58 @@
+package ingest
+
+import (
+	"fmt"
+
+	"github.com/stellar/go/xdr"
+)
+
+type AllowTrustDetail struct {
+	AssetCode                      string `json:"asset_code"`
+	AssetIssuer                    string `json:"asset_issuer"`
+	AssetType                      string `json:"asset_type"`
+	Trustor                        string `json:"trustor"`
+	Trustee                        string `json:"trustee"`
+	TrusteeMuxed                   string `json:"trustee_muxed"`
+	TrusteeMuxedID                 uint64 `json:"trustee_muxed_id,string"`
+	Authorize                      bool   `json:"authorize"`
+	AuthorizeToMaintainLiabilities bool   `json:"authorize_to_maintain_liabilities"`
+	ClawbackEnabled                bool   `json:"clawback_enabled"`
+}
+
+func (o *LedgerOperation) AllowTrustDetails() (AllowTrustDetail, error) {
+	op, ok := o.Operation.Body.GetAllowTrustOp()
+	if !ok {
+		return AllowTrustDetail{}, fmt.Errorf("could not access AllowTrust info for this operation (index %d)", o.OperationIndex)
+	}
+
+	allowTrustDetail := AllowTrustDetail{
+		Trustor:                        op.Trustor.Address(),
+		Trustee:                        o.SourceAccount(),
+		Authorize:                      xdr.TrustLineFlags(op.Authorize).IsAuthorized(),
+		AuthorizeToMaintainLiabilities: xdr.TrustLineFlags(op.Authorize).IsAuthorizedToMaintainLiabilitiesFlag(),
+		ClawbackEnabled:                xdr.TrustLineFlags(op.Authorize).IsClawbackEnabledFlag(),
+	}
+
+	var err error
+	var assetCode, assetIssuer, assetType string
+	err = op.Asset.ToAsset(o.sourceAccountXDR().ToAccountId()).Extract(&assetType, &assetCode, &assetIssuer)
+	if err != nil {
+		return AllowTrustDetail{}, err
+	}
+
+	allowTrustDetail.AssetCode = assetCode
+	allowTrustDetail.AssetIssuer = assetIssuer
+	allowTrustDetail.AssetType = assetType
+
+	var trusteeMuxed string
+	var trusteeMuxedID uint64
+	trusteeMuxed, trusteeMuxedID, err = getMuxedAccountDetails(o.sourceAccountXDR())
+	if err != nil {
+		return AllowTrustDetail{}, err
+	}
+
+	allowTrustDetail.TrusteeMuxed = trusteeMuxed
+	allowTrustDetail.TrusteeMuxedID = trusteeMuxedID
+
+	return allowTrustDetail, nil
+}

ingest/begin_sponsoring_future_reserve_details.go

@@ -0,0 +1,18 @@
+package ingest
+
+import "fmt"
+
+type BeginSponsoringFutureReservesDetail struct {
+	SponsoredID string `json:"sponsored_id"`
+}
+
+func (o *LedgerOperation) BeginSponsoringFutureReservesDetails() (BeginSponsoringFutureReservesDetail, error) {
+	op, ok := o.Operation.Body.GetBeginSponsoringFutureReservesOp()
+	if !ok {
+		return BeginSponsoringFutureReservesDetail{}, fmt.Errorf("could not access BeginSponsoringFutureReserves info for this operation (index %d)", o.OperationIndex)
+	}
+
+	return BeginSponsoringFutureReservesDetail{
+		SponsoredID: op.SponsoredId.Address(),
+	}, nil
+}

ingest/bump_sequence_details.go

@@ -0,0 +1,18 @@
+package ingest
+
+import "fmt"
+
+type BumpSequenceDetails struct {
+	BumpTo int64 `json:"bump_to,string"`
+}
+
+func (o *LedgerOperation) BumpSequenceDetails() (BumpSequenceDetails, error) {
+	op, ok := o.Operation.Body.GetBumpSequenceOp()
+	if !ok {
+		return BumpSequenceDetails{}, fmt.Errorf("could not access BumpSequence info for this operation (index %d)", o.OperationIndex)
+	}
+
+	return BumpSequenceDetails{
+		BumpTo: int64(op.BumpTo),
+	}, nil
+}

ingest/change_trust_details.go

@@ -0,0 +1,85 @@
+package ingest
+
+import (
+	"fmt"
+
+	"github.com/stellar/go/xdr"
+)
+
+type ChangeTrustDetail struct {
+	AssetCode       string `json:"asset_code"`
+	AssetIssuer     string `json:"asset_issuer"`
+	AssetType       string `json:"asset_type"`
+	LiquidityPoolID string `json:"liquidity_pool_id"`
+	Limit           int64  `json:"limit,string"`
+	Trustee         string `json:"trustee"`
+	Trustor         string `json:"trustor"`
+	TrustorMuxed    string `json:"trustor_muxed"`
+	TrustorMuxedID  uint64 `json:"trustor_muxed_id,string"`
+}
+
+func (o *LedgerOperation) ChangeTrustDetails() (ChangeTrustDetail, error) {
+	op, ok := o.Operation.Body.GetChangeTrustOp()
+	if !ok {
+		return ChangeTrustDetail{}, fmt.Errorf("could not access GetChangeTrust info for this operation (index %d)", o.OperationIndex)
+	}
+
+	var err error
+	changeTrustDetail := ChangeTrustDetail{
+		Trustor: o.SourceAccount(),
+		Limit:   int64(op.Limit),
+	}
+
+	if op.Line.Type == xdr.AssetTypeAssetTypePoolShare {
+		changeTrustDetail.AssetType, changeTrustDetail.LiquidityPoolID, err = getLiquidityPoolAssetDetails(*op.Line.LiquidityPool)
+		if err != nil {
+			return ChangeTrustDetail{}, err
+		}
+	} else {
+		var assetCode, assetIssuer, assetType string
+		err = op.Line.ToAsset().Extract(&assetType, &assetCode, &assetIssuer)
+		if err != nil {
+			return ChangeTrustDetail{}, err
+		}
+
+		changeTrustDetail.AssetCode = assetCode
+		changeTrustDetail.AssetIssuer = assetIssuer
+		changeTrustDetail.AssetType = assetType
+		changeTrustDetail.Trustee = assetIssuer
+	}
+
+	var trustorMuxed string
+	var trustorMuxedID uint64
+	trustorMuxed, trustorMuxedID, err = getMuxedAccountDetails(o.sourceAccountXDR())
+	if err != nil {
+		return ChangeTrustDetail{}, err
+	}
+
+	changeTrustDetail.TrustorMuxed = trustorMuxed
+	changeTrustDetail.TrustorMuxedID = trustorMuxedID
+
+	return changeTrustDetail, nil
+}
+
+func getLiquidityPoolAssetDetails(lpp xdr.LiquidityPoolParameters) (string, string, error) {
+	if lpp.Type != xdr.LiquidityPoolTypeLiquidityPoolConstantProduct {
+		return "", "", fmt.Errorf("unknown liquidity pool type %d", lpp.Type)
+	}
+
+	cp := lpp.ConstantProduct
+
+	var err error
+	var poolID xdr.PoolId
+	var poolIDString string
+	poolID, err = xdr.NewPoolId(cp.AssetA, cp.AssetB, cp.Fee)
+	if err != nil {
+		return "", "", err
+	}
+
+	poolIDString, err = PoolIDToString(poolID)
+	if err != nil {
+		return "", "", err
+	}
+
+	return "liquidity_pool_shares", poolIDString, nil
+}

ingest/claim_claimable_balance_details.go

@@ -0,0 +1,46 @@
+package ingest
+
+import (
+	"fmt"
+
+	"github.com/stellar/go/xdr"
+)
+
+type ClaimClaimableBalanceDetail struct {
+	BalanceID       string `json:"balance_id"`
+	Claimant        string `json:"claimant"`
+	ClaimantMuxed   string `json:"claimant_muxed"`
+	ClaimantMuxedID uint64 `json:"claimant_muxed_id,string"`
+}
+
+func (o *LedgerOperation) ClaimClaimableBalanceDetails() (ClaimClaimableBalanceDetail, error) {
+	op, ok := o.Operation.Body.GetClaimClaimableBalanceOp()
+	if !ok {
+		return ClaimClaimableBalanceDetail{}, fmt.Errorf("could not access ClaimClaimableBalance info for this operation (index %d)", o.OperationIndex)
+	}
+
+	claimClaimableBalanceDetail := ClaimClaimableBalanceDetail{
+		Claimant: o.SourceAccount(),
+	}
+
+	var err error
+	var balanceID string
+	balanceID, err = xdr.MarshalBase64(op.BalanceId)
+	if err != nil {
+		return ClaimClaimableBalanceDetail{}, err
+	}
+
+	claimClaimableBalanceDetail.BalanceID = balanceID
+
+	var claimantMuxed string
+	var claimantMuxedID uint64
+	claimantMuxed, claimantMuxedID, err = getMuxedAccountDetails(o.sourceAccountXDR())
+	if err != nil {
+		return ClaimClaimableBalanceDetail{}, err
+	}
+
+	claimClaimableBalanceDetail.ClaimantMuxed = claimantMuxed
+	claimClaimableBalanceDetail.ClaimantMuxedID = claimantMuxedID
+
+	return claimClaimableBalanceDetail, nil
+}

ingest/clawback_claimable_balance_details.go

@@ -0,0 +1,25 @@
+package ingest
+
+import (
+	"fmt"
+
+	"github.com/stellar/go/xdr"
+)
+
+type ClawbackClaimableBalanceDetail struct {
+	BalanceID string `json:"balance_id"`
+}
+
+func (o *LedgerOperation) ClawbackClaimableBalanceDetails() (ClawbackClaimableBalanceDetail, error) {
+	op, ok := o.Operation.Body.GetClawbackClaimableBalanceOp()
+	if !ok {
+		return ClawbackClaimableBalanceDetail{}, fmt.Errorf("could not access ClawbackClaimableBalance info for this operation (index %d)", o.OperationIndex)
+	}
+
+	balanceID, err := xdr.MarshalBase64(op.BalanceId)
+	if err != nil {
+		return ClawbackClaimableBalanceDetail{}, err
+	}
+
+	return ClawbackClaimableBalanceDetail{BalanceID: balanceID}, nil
+}

ingest/clawback_details.go

@@ -0,0 +1,48 @@
+package ingest
+
+import "fmt"
+
+type ClawbackDetail struct {
+	AssetCode   string `json:"asset_code"`
+	AssetIssuer string `json:"asset_issuer"`
+	AssetType   string `json:"asset_type"`
+	From        string `json:"from"`
+	FromMuxed   string `json:"from_muxed"`
+	FromMuxedID uint64 `json:"from_muxed_id,string"`
+	Amount      int64  `json:"amount,string"`
+}
+
+func (o *LedgerOperation) ClawbackDetails() (ClawbackDetail, error) {
+	op, ok := o.Operation.Body.GetClawbackOp()
+	if !ok {
+		return ClawbackDetail{}, fmt.Errorf("could not access Clawback info for this operation (index %d)", o.OperationIndex)
+	}
+
+	clawbackDetail := ClawbackDetail{
+		Amount: int64(op.Amount),
+		From:   op.From.Address(),
+	}
+
+	var err error
+	var assetCode, assetIssuer, assetType string
+	err = op.Asset.Extract(&assetType, &assetCode, &assetIssuer)
+	if err != nil {
+		return ClawbackDetail{}, err
+	}
+
+	clawbackDetail.AssetCode = assetCode
+	clawbackDetail.AssetIssuer = assetIssuer
+	clawbackDetail.AssetType = assetType
+
+	var fromMuxed string
+	var fromMuxedID uint64
+	fromMuxed, fromMuxedID, err = getMuxedAccountDetails(op.From)
+	if err != nil {
+		return ClawbackDetail{}, err
+	}
+
+	clawbackDetail.FromMuxed = fromMuxed
+	clawbackDetail.FromMuxedID = fromMuxedID
+
+	return clawbackDetail, nil
+}