Merge pull request #84 from xnoname79/main

support parse squad-multiig transaction

Author: anhthii

internal/indexer/solana.go

@@ -385,7 +385,7 @@ func solanaParseTokenTransfer(ix solana.Instruction, accountKeys []solana.Accoun
 					case uint64:
 						amt = v
 					}
-				case "transferChecked":
+				case "transferChecked", "transferCheckedWithFee":
 					// tokenAmount: { amount:"..", decimals:n, uiAmountString:".." }
 					if ta, _ := info["tokenAmount"].(map[string]any); ta != nil {
 						switch v := ta["amount"].(type) {
@@ -444,7 +444,7 @@ func solanaParseTokenTransfer(ix solana.Instruction, accountKeys []solana.Accoun
 			return "", "", "", 0, false
 		}
 		return accountKeys[srcIdx].Pubkey, accountKeys[dstIdx].Pubkey, "", amt, true
-	case 12:
+	case 12, 26: // 12 = transferChecked, 26 = transferCheckedWithFee (same account layout)
 		if len(accIdx) < 3 || len(data) < 9 {
 			return "", "", "", 0, false
 		}

internal/indexer/solana_test.go

@@ -244,3 +244,129 @@ func TestParseSPLTransferChecked(t *testing.T) {
 		tokenTransfer.FromAddress, tokenTransfer.ToAddress,
 		tokenTransfer.Amount, tokenTransfer.AssetAddress, tokenTransfer.TransferIndex)
 }
+
+// TestParseBatchSOLTransfer tests parsing of a batch transfer transaction containing
+// 20 native SOL transfers (1 lamport each) from a single sender to 20 different recipients.
+// Transaction: 5dKRr7cF6pNiuhKYY8RDF5rxTjbFWFGAzKgBXoYrPcg2uMx14uwfopiX1XiyZuu3aihMMRqzSSX9jQcWnamqw5DK
+func TestParseBatchSOLTransfer(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping integration test")
+	}
+
+	ctx := context.Background()
+	c := newTestSolanaClient()
+
+	txSig := "5dKRr7cF6pNiuhKYY8RDF5rxTjbFWFGAzKgBXoYrPcg2uMx14uwfopiX1XiyZuu3aihMMRqzSSX9jQcWnamqw5DK"
+	txResult, err := c.GetTransaction(ctx, txSig)
+	require.NoError(t, err)
+	require.NotNil(t, txResult, "transaction should exist on mainnet")
+
+	idx := newTestSolanaIndexer()
+	block := txToBlockResult(txResult)
+
+	ts := uint64(0)
+	if txResult.BlockTime != nil {
+		ts = uint64(*txResult.BlockTime)
+	}
+	transfers := idx.extractSolanaTransfers("solana-mainnet", txResult.Slot, ts, block)
+
+	// This transaction contains 20 native SOL transfers of 1 lamport each
+	expectedRecipients := []string{
+		"5P1E2RDvWWsQYtHgC9Ng3SejPq7tLdk697tNWfkxwx5g",
+		"JCxSuQwRa2Qbtxjrv9Csf2B8AtCMiLjfr24Bb27yheFL",
+		"4Y84ZayuVutuW2e1Lq8qfq5JYwYkTn8CtutmZs3jW8oM",
+		"9rRE1bEPcQxf3LSJphSd1jHbDVi4dLYWgY9g61YTCHdW",
+		"3dUBc9cLiF92uWCdZVGmB7iKPTHVioeE5UqA8PEjUYXs",
+		"FeAuJTC8wZypEuTQteys9PRdBPAL3ik8VuViDtQNm2tb",
+		"BMvWVyMFoDhfwvqDG4q2uGmnP4sr4FhqT1hDSPbrbGRX",
+		"3KSTPVNHmWvkwy3JcuKQH8sLogv1Gf9rauj8Z1TpPdbG",
+		"DHY4ANQod7Ff67ojZPgzWePwHNSBeJwbWmye2SwR6F3V",
+		"B9eWxGfXGsLhMPx65mdFiSayhqVAxWG4TGzaFpuTWQmH",
+		"Avr7d3kwUcV8cUhzDmpbVjzPDCni9FSJYyNaDjuFPLZt",
+		"HPDN6Ro6gPgYbNgnv7yhFCpyY3uYzT18epFxRFNZ985w",
+		"EYidortrJzJGkR3r2gFg2sJVM6WJQNE7yZdzvhndGPVQ",
+		"E4oy1PetbUo7UKww5Dmy9gHyNgrtQWPsC5DHBsVu3KQo",
+		"H6EJh7pyygR8ghgPxe1j4NE3FC7BuzC4S2Cybw5fJMcg",
+		"5E81HKzq7vXPgGcH3ZndGW56DtLBPC9rJD5RmAMdbE3Y",
+		"H1PQRtvSEH2HwwtZUnBfxEerwbhPHhUvTCtDF66NSCY4",
+		"9mSFaSJgQotHmL14xSMcRgNC9hnidNfGkyJ2fhvizKuj",
+		"GLvb7P4q7AkX1j7r4S2fr4uoLWqDLWRsPkJqMMcNR9CE",
+		"5XFz3x79Hi8zzQb8RuzNqzoqXkyxRCgDyvjK7BrfCKML",
+	}
+
+	const expectedSender = "AZWibhw2cmpVFt4b45XGhiB8vSmYc2LfMGyHE3Lb97cM"
+
+	// All transfers should be native
+	var nativeTransfers []types.Transaction
+	for _, tx := range transfers {
+		if tx.Type == constant.TxTypeNativeTransfer {
+			nativeTransfers = append(nativeTransfers, tx)
+		}
+	}
+
+	require.Len(t, nativeTransfers, 20, "should detect all 20 native SOL transfers in the batch")
+
+	// Verify each transfer
+	for i, tx := range nativeTransfers {
+		assert.Equal(t, txSig, tx.TxHash, "transfer %d: TxHash should match", i)
+		assert.Equal(t, expectedSender, tx.FromAddress, "transfer %d: sender should match", i)
+		assert.Equal(t, expectedRecipients[i], tx.ToAddress, "transfer %d: recipient should match", i)
+		assert.Equal(t, "1", tx.Amount, "transfer %d: amount should be 1 lamport", i)
+		assert.Empty(t, tx.AssetAddress, "transfer %d: AssetAddress should be empty for native SOL", i)
+	}
+
+	// Verify no token transfers were detected
+	for _, tx := range transfers {
+		assert.NotEqual(t, constant.TxTypeTokenTransfer, tx.Type, "should not detect any token transfers")
+	}
+
+	t.Logf("Batch transfer: %d native SOL transfers from %s (1 lamport each)", len(nativeTransfers), expectedSender)
+}
+
+// TestParseSquadsMultisigTransfer tests parsing of a Squads Multisig (SMPLecH534NA9acpos4G6x7uf3LWbCAwZQE9e8ZekMu)
+// transaction that CPI-calls Token-2022 with transferCheckedWithFee.
+// Transaction: 2Sqm2FwnSdTLQ5tfbpCKafWiQDwynmDZrkvGxCbpin3mwPHdmRKNDq6drv5rnosp9is86JwScQLnyWHbV9TfYTDj
+func TestParseSquadsMultisigTransfer(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping integration test")
+	}
+
+	ctx := context.Background()
+	c := newTestSolanaClient()
+
+	txSig := "2Sqm2FwnSdTLQ5tfbpCKafWiQDwynmDZrkvGxCbpin3mwPHdmRKNDq6drv5rnosp9is86JwScQLnyWHbV9TfYTDj"
+	txResult, err := c.GetTransaction(ctx, txSig)
+	require.NoError(t, err)
+	require.NotNil(t, txResult, "transaction should exist on mainnet")
+
+	idx := newTestSolanaIndexer()
+	block := txToBlockResult(txResult)
+
+	ts := uint64(0)
+	if txResult.BlockTime != nil {
+		ts = uint64(*txResult.BlockTime)
+	}
+	transfers := idx.extractSolanaTransfers("solana-mainnet", txResult.Slot, ts, block)
+
+	// This transaction contains a Token-2022 transferCheckedWithFee via Squads multisig CPI.
+	// Token: HeLp6NuQkmYB4pYWo2zYs22mESHXPQYzXbB8n4V98jwC, Amount: 13000000 (0.013 with 9 decimals)
+	var tokenTransfer *types.Transaction
+	for i := range transfers {
+		if transfers[i].Type == constant.TxTypeTokenTransfer {
+			tokenTransfer = &transfers[i]
+			break
+		}
+	}
+
+	require.NotNil(t, tokenTransfer, "should detect the Token-2022 transferCheckedWithFee from inner instructions")
+
+	assert.Equal(t, txSig, tokenTransfer.TxHash, "TxHash should match")
+	assert.Equal(t, "13000000", tokenTransfer.Amount, "Amount should be 13000000")
+	assert.Equal(t, "HeLp6NuQkmYB4pYWo2zYs22mESHXPQYzXbB8n4V98jwC", tokenTransfer.AssetAddress, "AssetAddress should be the token mint")
+	assert.Equal(t, "BfV1aVZTcN2R8fA9Asa49qsfYzX3rH3jVGkwWAA2muDs", tokenTransfer.FromAddress, "FromAddress should be the source owner")
+	assert.Equal(t, "CvySeQ1FR4CgKo4N1L6UhgCaJ8RWJbcXi32ZppCAnRF4", tokenTransfer.ToAddress, "ToAddress should be the destination owner")
+
+	t.Logf("Squads multisig transfer: from=%s to=%s amount=%s token=%s",
+		tokenTransfer.FromAddress, tokenTransfer.ToAddress,
+		tokenTransfer.Amount, tokenTransfer.AssetAddress)
+}