add wallet when transfer to subaccount (#2519)

dydxprotocol · Oct 18, 2024 · 8a866a5 · 8a866a5
1 parent 301b438
commit 8a866a5
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 4 deletions.
diff --git a/indexer/services/ender/__tests__/handlers/transfer-handler.test.ts b/indexer/services/ender/__tests__/handlers/transfer-handler.test.ts
@@ -311,7 +311,7 @@ describe('transferHandler', () => {
     expect(wallet).toEqual(defaultWallet);
   });
 
-  it('creates new deposit for previously non-existent subaccount', async () => {
+  it('creates new deposit for previously non-existent subaccount (also non-existent recipient wallet)', async () => {
     const transactionIndex: number = 0;
 
     const depositEvent: TransferEventV1 = defaultDepositEvent;
@@ -348,16 +348,23 @@ describe('transferHandler', () => {
       newTransfer,
       asset,
     );
-    // Confirm the wallet was created
-    const wallet: WalletFromDatabase | undefined = await WalletTable.findById(
+    // Confirm the wallet was created for the sender and recipient
+    const walletSender: WalletFromDatabase | undefined = await WalletTable.findById(
       defaultWalletAddress,
     );
+    const walletRecipient: WalletFromDatabase | undefined = await WalletTable.findById(
+      defaultDepositEvent.recipient!.subaccountId!.owner,
+    );
     const newRecipientSubaccount: SubaccountFromDatabase | undefined = await
     SubaccountTable.findById(
       defaultRecipientSubaccountId,
     );
     expect(newRecipientSubaccount).toBeDefined();
-    expect(wallet).toEqual(defaultWallet);
+    expect(walletSender).toEqual(defaultWallet);
+    expect(walletRecipient).toEqual({
+      ...defaultWallet,
+      address: defaultDepositEvent.recipient!.subaccountId!.owner,
+    });
   });
 
   it('creates new withdrawal for existing subaccount', async () => {

diff --git a/indexer/services/ender/src/scripts/handlers/dydx_transfer_handler.sql b/indexer/services/ender/src/scripts/handlers/dydx_transfer_handler.sql
@@ -46,6 +46,11 @@ BEGIN
             SET
                 "updatedAtHeight" = recipient_subaccount_record."updatedAtHeight",
                 "updatedAt" = recipient_subaccount_record."updatedAt";
+
+        recipient_wallet_record."address" = event_data->'recipient'->'subaccountId'->>'owner';
+        recipient_wallet_record."totalTradingRewards" = '0';
+        recipient_wallet_record."totalVolume" = '0';
+        INSERT INTO wallets VALUES (recipient_wallet_record.*) ON CONFLICT DO NOTHING;
     END IF;
 
     IF event_data->'sender'->'subaccountId' IS NOT NULL THEN