feat: enhance XRP and Stellar indexers

- Added Conflux mainnet and testnet configurations to the indexer.
- Updated XRP indexer to handle new transaction types including clawback and claimable balance operations.
- Enhanced Stellar indexer to support claimable balance operations and improved transaction metadata handling.
- Removed outdated test files for Stellar and XRP indexers.

Author: vietddude

configs/config.example.yaml

@@ -82,6 +82,27 @@ chains:
       - url: "https://bsc.blockrazor.xyz"
       - url: "https://bnb.rpc.subquery.network/public"
 
+  conflux_mainnet:
+    network_id: "conflux_mainnet"
+    internal_code: "CONFLUX_MAINNET"
+    type: "evm"
+    start_block: 0
+    poll_interval: "3s"
+    nodes:
+      - url: "https://evm.confluxrpc.com"
+      - url: "https://conflux-espace-public.unifra.io"
+      - url: "https://1rpc.io/cfx"
+
+  conflux_testnet:
+    network_id: "conflux_testnet"
+    internal_code: "CONFLUX_TESTNET"
+    type: "evm"
+    start_block: 0
+    poll_interval: "3s"
+    nodes:
+      - url: "https://evmtestnet.confluxrpc.com"
+      - url: "https://conflux-espace-testnet.public.blastapi.io"
+
   bitcoin_testnet:
     network_id: "bitcoin_testnet"
     internal_code: "BTC_TESTNET"
@@ -322,6 +343,86 @@ chains:
       batch_size: 20
       concurrency: 4
 
+  xrp_mainnet:
+    network_id: "xrp_mainnet"
+    internal_code: "XRP_MAINNET"
+    type: "xrp"
+    start_block: 0
+    poll_interval: "2s"
+    nodes:
+      - url: "https://xrplcluster.com"
+      - url: "https://s1.ripple.com:51234"
+    client:
+      timeout: "15s"
+      max_retries: 3
+      retry_delay: "1s"
+    throttle:
+      rps: 40
+      burst: 80
+      batch_size: 20
+      concurrency: 6
+      parallel: true
+
+  xrp_testnet:
+    network_id: "xrp_testnet"
+    internal_code: "XRP_TESTNET"
+    type: "xrp"
+    start_block: 0
+    poll_interval: "2s"
+    nodes:
+      - url: "https://s.altnet.rippletest.net:51234"
+      - url: "https://testnet.xrpl-labs.com"
+    client:
+      timeout: "15s"
+      max_retries: 3
+      retry_delay: "1s"
+    throttle:
+      rps: 40
+      burst: 80
+      batch_size: 20
+      concurrency: 6
+      parallel: true
+
+  stellar_mainnet:
+    network_id: "stellar_mainnet"
+    internal_code: "STELLAR_MAINNET"
+    type: "stellar"
+    start_block: 0
+    poll_interval: "2s"
+    nodes:
+      - url: "https://horizon.stellar.org"
+      - url: "https://horizon.publicnode.com"
+    client:
+      timeout: "15s"
+      max_retries: 3
+      retry_delay: "1s"
+    throttle:
+      rps: 40
+      burst: 80
+      batch_size: 20
+      concurrency: 6
+      parallel: true
+
+  stellar_testnet:
+    network_id: "stellar_testnet"
+    internal_code: "STELLAR_TESTNET"
+    type: "stellar"
+    start_block: 0
+    poll_interval: "2s"
+    nodes:
+      - url: "https://horizon-testnet.stellar.org"
+      - url: "https://horizon-testnet.publicnode.com"
+    client:
+      timeout: "15s"
+      max_retries: 3
+      retry_delay: "1s"
+    throttle:
+      rps: 40
+      burst: 80
+      batch_size: 20
+      concurrency: 6
+      parallel: true
+
   ton_mainnet:
     network_id: "ton"
     internal_code: "TON_MAINNET"

internal/indexer/stellar.go

@@ -237,7 +237,7 @@ func (s *StellarIndexer) convertLedger(
 		}
 
 		var effects []stellar.Effect
-		if strings.EqualFold(strings.TrimSpace(operation.Type), "create_claimable_balance") {
+		if stellarOperationNeedsEffects(operation.Type) {
 			effects, err = s.getCachedOperationEffects(ctx, effectsByOperation, effectsFetched, operation.ID)
 			if err != nil {
 				return nil, err
@@ -316,6 +316,15 @@ func (s *StellarIndexer) shouldProcessOperation(operation stellar.Operation) boo
 	}
 }
 
+func stellarOperationNeedsEffects(operationType string) bool {
+	switch strings.ToLower(strings.TrimSpace(operationType)) {
+	case "create_claimable_balance", "claim_claimable_balance":
+		return true
+	default:
+		return false
+	}
+}
+
 func (s *StellarIndexer) getCachedTransactionDetail(
 	ctx context.Context,
 	cache map[string]*stellar.Transaction,
@@ -512,9 +521,9 @@ func (s *StellarIndexer) convertOperation(
 	case "create_claimable_balance":
 		return s.convertCreateClaimableBalanceOperation(operation, effects, txDetail, ledgerSequence, blockHash, transferIndex, ledgerTimestamp)
 	case "claim_claimable_balance":
-		return s.convertClaimClaimableBalanceOperation(operation, txDetail, ledgerSequence, blockHash, transferIndex, ledgerTimestamp)
+		return s.convertClaimClaimableBalanceOperation(operation, effects, txDetail, ledgerSequence, blockHash, transferIndex, ledgerTimestamp)
 	case "clawback_claimable_balance":
-		return s.convertClawbackClaimableBalanceOperation(operation, txDetail, ledgerSequence, blockHash, transferIndex, ledgerTimestamp)
+		return s.convertClawbackClaimableBalanceOperation(operation, effects, txDetail, ledgerSequence, blockHash, transferIndex, ledgerTimestamp)
 	default:
 		return types.Transaction{}, false, nil
 	}
@@ -595,14 +604,13 @@ func (s *StellarIndexer) convertCreateClaimableBalanceOperation(
 		return types.Transaction{}, false, err
 	}
 
-	shouldEmit := s.anyMonitoredAddress(claimants) || (s.config.TwoWayIndexing && s.isMonitoredAddress(sourceAccount))
+	shouldEmit := s.config.TwoWayIndexing && s.isMonitoredAddress(sourceAccount)
 	if !shouldEmit {
 		return types.Transaction{}, false, nil
 	}
 
 	tx := s.newOperationTransaction(operation, txDetail, ledgerSequence, blockHash, transferIndex, ledgerTimestamp)
 	tx.FromAddress = sourceAccount
-	tx.ToAddress = stellarClaimableBalanceAddress(balanceID)
 	tx.AssetAddress = assetAddress
 	tx.Amount = amount
 	tx.Type = txType
@@ -616,6 +624,7 @@ func (s *StellarIndexer) convertCreateClaimableBalanceOperation(
 
 func (s *StellarIndexer) convertClaimClaimableBalanceOperation(
 	operation stellar.Operation,
+	effects []stellar.Effect,
 	txDetail *stellar.Transaction,
 	ledgerSequence uint64,
 	blockHash string,
@@ -627,14 +636,25 @@ func (s *StellarIndexer) convertClaimClaimableBalanceOperation(
 		return types.Transaction{}, false, nil
 	}
 	state, found, err := s.loadClaimableBalanceState(balanceID)
-	if err != nil || !found {
+	if err != nil {
 		return types.Transaction{}, false, err
 	}
-	if err := s.deleteClaimableBalanceState(balanceID); err != nil {
-		return types.Transaction{}, false, err
+	if found {
+		if err := s.deleteClaimableBalanceState(balanceID); err != nil {
+			return types.Transaction{}, false, err
+		}
+	} else {
+		state, found = stellarClaimableBalanceStateFromEffect(findStellarEffect(effects, "claimable_balance_claimed"))
+		if !found {
+			return types.Transaction{}, false, nil
+		}
 	}
 
 	claimant := normalizeStellarAddress(operation.Claimant)
+	if claimant != "" {
+		state.Claimants = []string{claimant}
+	}
+
 	if claimant == "" || !s.isMonitoredAddress(claimant) {
 		return types.Transaction{}, false, nil
 	}
@@ -645,7 +665,6 @@ func (s *StellarIndexer) convertClaimClaimableBalanceOperation(
 	}
 
 	tx := s.newOperationTransaction(operation, txDetail, ledgerSequence, blockHash, transferIndex, ledgerTimestamp)
-	tx.FromAddress = stellarClaimableBalanceAddress(balanceID)
 	tx.ToAddress = claimant
 	tx.AssetAddress = assetAddress
 	tx.Amount = strings.TrimSpace(state.Amount)
@@ -657,6 +676,7 @@ func (s *StellarIndexer) convertClaimClaimableBalanceOperation(
 
 func (s *StellarIndexer) convertClawbackClaimableBalanceOperation(
 	operation stellar.Operation,
+	effects []stellar.Effect,
 	txDetail *stellar.Transaction,
 	ledgerSequence uint64,
 	blockHash string,
@@ -667,32 +687,16 @@ func (s *StellarIndexer) convertClawbackClaimableBalanceOperation(
 	if balanceID == "" {
 		return types.Transaction{}, false, nil
 	}
-	state, found, err := s.loadClaimableBalanceState(balanceID)
-	if err != nil || !found {
-		return types.Transaction{}, false, err
-	}
-	if err := s.deleteClaimableBalanceState(balanceID); err != nil {
+	_, found, err := s.loadClaimableBalanceState(balanceID)
+	if err != nil {
 		return types.Transaction{}, false, err
 	}
-
-	if !s.anyMonitoredAddress(state.Claimants) {
-		return types.Transaction{}, false, nil
-	}
-
-	txType, assetAddress, ok := stellarAssetFromOperation(state.Asset)
-	if !ok || strings.TrimSpace(state.Amount) == "" {
-		return types.Transaction{}, false, nil
+	if found {
+		if err := s.deleteClaimableBalanceState(balanceID); err != nil {
+			return types.Transaction{}, false, err
+		}
 	}
-
-	tx := s.newOperationTransaction(operation, txDetail, ledgerSequence, blockHash, transferIndex, ledgerTimestamp)
-	tx.FromAddress = stellarClaimableBalanceAddress(balanceID)
-	tx.ToAddress = stellarBurnAddress
-	tx.AssetAddress = assetAddress
-	tx.Amount = strings.TrimSpace(state.Amount)
-	tx.Type = txType
-	tx.SetMetadata(types.MetadataKeySubtype, "clawback_claimable_balance")
-	tx.SetMetadata(types.MetadataKeyClaimableID, balanceID)
-	return tx, true, nil
+	return types.Transaction{}, false, nil
 }
 
 func (s *StellarIndexer) newOperationTransaction(
@@ -746,7 +750,7 @@ func (s *StellarIndexer) newOperationTransaction(
 func (s *StellarIndexer) fetchEffectsForOperations(ctx context.Context, operations []stellar.Operation) (map[string][]stellar.Effect, error) {
 	effectsByOperation := make(map[string][]stellar.Effect)
 	for _, operation := range operations {
-		if !strings.EqualFold(strings.TrimSpace(operation.Type), "create_claimable_balance") {
+		if !stellarOperationNeedsEffects(operation.Type) {
 			continue
 		}
 		operationID := strings.TrimSpace(operation.ID)
@@ -859,6 +863,24 @@ func findStellarEffect(effects []stellar.Effect, effectType string) *stellar.Eff
 	return nil
 }
 
+func stellarClaimableBalanceStateFromEffect(effect *stellar.Effect) (stellarClaimableBalanceState, bool) {
+	if effect == nil {
+		return stellarClaimableBalanceState{}, false
+	}
+
+	state := stellarClaimableBalanceState{
+		Asset:  strings.TrimSpace(effect.Asset),
+		Amount: strings.TrimSpace(effect.Amount),
+	}
+	if claimant := normalizeStellarAddress(effect.Account); claimant != "" {
+		state.Claimants = []string{claimant}
+	}
+	if state.Asset == "" || state.Amount == "" {
+		return stellarClaimableBalanceState{}, false
+	}
+	return state, true
+}
+
 func stellarTransferIndex(payment stellar.Payment, paymentIndex int) string {
 	if pagingToken := strings.TrimSpace(payment.PagingToken); pagingToken != "" {
 		return pagingToken