feat(multisig): build multi-sig action indexer and pending approvals REST API (#1085)

prisma/schema/multisig.prisma

@@ -35,4 +35,44 @@ model MultisigSignature {
   @@unique([proposalId, signer])
   @@index([signer])
   @@map("multisig_signatures")
-}
+}
+
+model MultisigAction {
+  id           String   @id @default(cuid())
+  actionId     String   @unique
+  changeType   String?
+  payload      Json?
+  status       String   @default("pending") // pending | executed | expired | rejected
+  threshold    Int      @default(2)
+  totalSigners Int      @default(3)
+  proposedBy   String
+  proposedAt   DateTime @default(now())
+  executedAt   DateTime?
+  expiredAt    DateTime?
+  ledger       Int?
+  txHash       String?
+  createdAt    DateTime @default(now())
+  updatedAt    DateTime @updatedAt
+
+  signatures   Signature[]
+
+  @@index([status])
+  @@index([proposedBy])
+  @@map("multisig_actions")
+}
+
+model Signature {
+  id        String   @id @default(cuid())
+  actionId  String
+  signer    String
+  signedAt  DateTime @default(now())
+  ledger    Int?
+  txHash    String?
+
+  action    MultisigAction @relation(fields: [actionId], references: [actionId], onDelete: Cascade)
+
+  @@unique([actionId, signer])
+  @@index([signer])
+  @@index([actionId])
+  @@map("signatures")
+}

src/modules/index.ts

@@ -52,15 +52,7 @@ import factoryRouter from './factory/factory.routes';
 import lpRouter from './lp/lp.routes';
 import auctionRouter from './auctions/auction.routes';
 import holdersRouter from './dividends/holders.routes';
-import discoveryRouter from './keys/discovery.routes';
-import tradesRouter from './trades/trades.routes';
-import tradersRouter from './traders/traders.routes';
-import nonceRouter from './nonce/nonce.routes';
-import swapsRouter from './swaps/swaps.routes';
-import eventsRouter from './events/events.routes';
-import milestonesRouter from './keys/milestones.routes';
-import autoInvestRouter from './auto-invest/auto-invest.routes';
-
+import multisigRouter from './multisig/multisig.routes';
 import { BASE as CREATORS_BASE } from '../constants/creator.constants';
 
 const router = Router();
@@ -140,14 +132,6 @@ router.use('/factory', routeBodySizeLimit('default'), factoryRouter);
 router.use('/lp', routeBodySizeLimit('default'), lpRouter);
 router.use('/auctions', routeBodySizeLimit('default'), auctionRouter);
 router.use('/holders', routeBodySizeLimit('default'), holdersRouter);
-router.use('/events', routeBodySizeLimit('default'), eventsRouter);
-
-router.use('/discovery', routeBodySizeLimit('default'), discoveryRouter);
-router.use('/trades', routeBodySizeLimit('default'), tradesRouter);
-router.use('/traders', routeBodySizeLimit('default'), tradersRouter);
-router.use('/nonce', routeBodySizeLimit('default'), nonceRouter);
-router.use('/swaps', routeBodySizeLimit('default'), swapsRouter);
-router.use('/milestones', routeBodySizeLimit('default'), milestonesRouter);
-router.use('/auto-invest', routeBodySizeLimit('default'), autoInvestRouter);
+router.use('/multisig', routeBodySizeLimit('default'), multisigRouter);
 
 export default router;

src/modules/indexer/multisig-action-indexer.service.test.ts

@@ -0,0 +1,138 @@
+// src/modules/indexer/multisig-action-indexer.service.test.ts
+
+jest.mock('../../utils/prisma.utils', () => ({
+   prisma: {
+      multisigAction: {
+         upsert: jest.fn(),
+         updateMany: jest.fn(),
+      },
+      signature: {
+         create: jest.fn(),
+      },
+   },
+}));
+
+jest.mock('../../utils/logger.utils', () => ({
+   logger: {
+      info: jest.fn(),
+      warn: jest.fn(),
+      error: jest.fn(),
+      debug: jest.fn(),
+   },
+}));
+
+import { prisma } from '../../utils/prisma.utils';
+import { processMultisigActionEvents } from './multisig-action-indexer.service';
+
+const mockPrisma = prisma as unknown as {
+   multisigAction: {
+      upsert: jest.Mock;
+      updateMany: jest.Mock;
+   };
+   signature: {
+      create: jest.Mock;
+   };
+};
+
+const VALID_STELLAR_ADDR = 'GA37PRKUOWJN5DWJWBCBLAH4WWHWEQQKSKFQGSIEPKT3VJUE5DVQHSXT';
+
+beforeEach(() => {
+   jest.clearAllMocks();
+   mockPrisma.multisigAction.upsert.mockResolvedValue({ id: 'action-1' });
+   mockPrisma.signature.create.mockResolvedValue({ id: 'sig-1' });
+   mockPrisma.multisigAction.updateMany.mockResolvedValue({ count: 1 });
+});
+
+describe('processMultisigActionEvents', () => {
+   it('indexes ActionProposed event correctly', async () => {
+      const event = {
+         eventType: 'ActionProposed',
+         actionId: 'act-101',
+         changeType: 'upgrade',
+         payload: { version: '2.0' },
+         threshold: 2,
+         totalSigners: 3,
+         proposedBy: VALID_STELLAR_ADDR,
+         ledger: 1000,
+         txHash: 'tx-prop-1',
+         eventIndex: 0,
+         occurredAt: '2026-10-20T10:00:00.000Z',
+      };
+
+      await processMultisigActionEvents([event]);
+
+      expect(mockPrisma.multisigAction.upsert).toHaveBeenCalledWith({
+         where: { actionId: 'act-101' },
+         create: expect.objectContaining({
+            actionId: 'act-101',
+            changeType: 'upgrade',
+            threshold: 2,
+            totalSigners: 3,
+            status: 'pending',
+            proposedBy: VALID_STELLAR_ADDR,
+            ledger: 1000,
+            txHash: 'tx-prop-1',
+         }),
+         update: expect.any(Object),
+      });
+   });
+
+   it('indexes ActionSigned event correctly', async () => {
+      const event = {
+         eventType: 'ActionSigned',
+         actionId: 'act-101',
+         signer: VALID_STELLAR_ADDR,
+         ledger: 1001,
+         txHash: 'tx-sig-1',
+         eventIndex: 1,
+         occurredAt: '2026-10-20T10:05:00.000Z',
+      };
+
+      await processMultisigActionEvents([event]);
+
+      expect(mockPrisma.signature.create).toHaveBeenCalledWith({
+         data: expect.objectContaining({
+            actionId: 'act-101',
+            signer: VALID_STELLAR_ADDR,
+            ledger: 1001,
+            txHash: 'tx-sig-1',
+         }),
+      });
+   });
+
+   it('indexes ActionExecuted event correctly', async () => {
+      const event = {
+         eventType: 'ActionExecuted',
+         actionId: 'act-101',
+         status: 'executed',
+         ledger: 1002,
+         txHash: 'tx-exec-1',
+         eventIndex: 2,
+         occurredAt: '2026-10-20T10:10:00.000Z',
+      };
+
+      await processMultisigActionEvents([event]);
+
+      expect(mockPrisma.multisigAction.updateMany).toHaveBeenCalledWith({
+         where: { actionId: 'act-101' },
+         data: expect.objectContaining({
+            status: 'executed',
+         }),
+      });
+   });
+
+   it('ignores duplicate events in the same batch', async () => {
+      const event = {
+         eventType: 'ActionProposed',
+         actionId: 'act-102',
+         proposedBy: VALID_STELLAR_ADDR,
+         ledger: 1000,
+         txHash: 'tx-prop-2',
+         eventIndex: 0,
+      };
+
+      await processMultisigActionEvents([event, event]);
+
+      expect(mockPrisma.multisigAction.upsert).toHaveBeenCalledTimes(1);
+   });
+});