Chore/refactor hypersync

Dockerfile.hypersync-indexer

@@ -0,0 +1,28 @@
+FROM node:20-slim AS base
+
+FROM base AS builder
+WORKDIR /app
+COPY . .
+RUN npx turbo@2.3.1 prune @anticapture/hypersync-indexer --docker
+
+FROM base AS installer
+RUN apt-get update && apt-get install -y curl && npm install -g pnpm ts-node
+WORKDIR /app
+COPY package.json package.json
+COPY pnpm-lock.yaml pnpm-lock.yaml
+COPY --from=builder /app/out/json/ .
+RUN pnpm install
+COPY --from=builder /app/out/full/ .
+COPY --from=builder /app/turbo.json turbo.json
+WORKDIR /app/apps/hypersync-indexer
+RUN npm install --prefix generated --legacy-peer-deps
+RUN pnpm envio codegen
+
+FROM base AS runner
+ENV NODE_ENV=production
+RUN apt-get update && apt-get install -y curl && npm install -g ts-node
+WORKDIR /app
+COPY --from=installer /app .
+WORKDIR /app/apps/hypersync-indexer
+
+ENTRYPOINT ["npm", "run", "start"]

apps/api/cmd/aave.ts

@@ -105,7 +105,7 @@ if (!daoClient) {
   throw new Error(`Client not found for DAO ${env.DAO_ID}`);
 }
 
-const pgClient = drizzle(env.DATABASE_URL, { schema, casing: "snake_case" });
+const pgClient = drizzle(env.DATABASE_URL, { schema });
 
 health(app, pgClient);
 

apps/api/cmd/index.ts

@@ -174,7 +174,7 @@ if (!daoClient) {
   throw new Error(`Client not found for DAO ${env.DAO_ID}`);
 }
 
-const pgClient = drizzle(env.DATABASE_URL, { schema, casing: "snake_case" });
+const pgClient = drizzle(env.DATABASE_URL, { schema });
 
 health(app, pgClient);
 
@@ -351,7 +351,6 @@ tokenMetrics(app, tokenMetricsService);
 if (daoClient.supportOffchainData()) {
   const pgUnifiedClient = drizzle(env.DATABASE_URL, {
     schema: { ...schema, ...offchainSchema },
-    casing: "snake_case",
   });
 
   const offchainProposalsRepo = wrapWithTracing(

apps/api/src/controllers/account-balance/historical.integration.test.ts

@@ -24,6 +24,7 @@
 const createHistoryRow = (
   overrides: Partial<BalanceHistoryInsert> = {},
 ): BalanceHistoryInsert => ({
+  id: "test-id",
   transactionHash: TX_HASH,
   daoId: DAO_ID,
   accountId: VALID_ADDRESS,
@@ -38,6 +39,7 @@
 const createTransferRow = (
   overrides: Partial<TransferInsert> = {},
 ): TransferInsert => ({
+  id: "test-id",
   transactionHash: TX_HASH,
   daoId: DAO_ID,
   tokenId: TOKEN_ID,
@@ -144,7 +146,7 @@
 
     it("should accept orderBy=delta", async () => {
       // Insert 2 rows with different delta/deltaMod values
       await db.insert(balanceHistory).values([
         createHistoryRow({
           transactionHash: TX_1,
           delta: 100n,
@@ -207,7 +209,7 @@
 
     it("should accept orderDirection=asc", async () => {
       // Insert 2 rows with different timestamps
       await db.insert(balanceHistory).values([
         createHistoryRow({
           transactionHash: TX_1,
           timestamp: 1700000000n,
@@ -248,7 +250,7 @@
 
     it("should accept fromValue and toValue parameters", async () => {
       // deltaMod=100n is within range [50, 200], deltaMod=10000n is outside
       await db.insert(balanceHistory).values([
         createHistoryRow({
           transactionHash: TX_1,
           deltaMod: 100n,
@@ -282,7 +284,7 @@
 
     it("should accept fromDate and toDate parameters", async () => {
       // timestamp=1700000000 is within [1699000000, 1701000000], timestamp=1695000000 is not
       await db.insert(balanceHistory).values([
         createHistoryRow({
           transactionHash: TX_1,
           timestamp: 1700000000n,

apps/api/src/controllers/account-balance/interactions.integration.test.ts

@@ -25,6 +25,7 @@
 const createAccountBalanceRow = (
   overrides: Partial<AccountBalanceInsert> = {},
 ): AccountBalanceInsert => ({
+  id: "test-id",
   accountId: COUNTERPART,
   tokenId: TOKEN_ID,
   balance: 200000000000000000n,
@@ -35,6 +36,7 @@
 const createTransferRow = (
   overrides: Partial<TransferInsert> = {},
 ): TransferInsert => ({
+  id: "test-id",
   transactionHash: TX_HASH,
   daoId: DAO_ID,
   tokenId: TOKEN_ID,
@@ -139,7 +141,7 @@
     });
 
     it("should accept orderBy and orderDirection parameters", async () => {
       await db.insert(accountBalance).values([
         createAccountBalanceRow({ accountId: COUNTERPART, balance: 100n }),
         createAccountBalanceRow({
           accountId: COUNTERPART_2,

apps/api/src/controllers/account-balance/listing.integration.test.ts

@@ -34,6 +34,7 @@
 const createAccountBalanceRow = (
   overrides: Partial<AccountBalanceInsert> = {},
 ): AccountBalanceInsert => ({
+  id: "test-id",
   accountId: VALID_ADDRESS,
   tokenId: TOKEN_ID,
   balance: 1200000000000000000n,
@@ -44,6 +45,7 @@
 const createTransferRow = (
   overrides: Partial<TransferInsert> = {},
 ): TransferInsert => ({
+  id: "test-id",
   transactionHash:
     "0xabc1230000000000000000000000000000000000000000000000000000000001",
   daoId: "ENS",
@@ -153,7 +155,7 @@
     });
 
     it("should accept orderBy=variation", async () => {
       await db.insert(accountBalance).values([
         createAccountBalanceRow({ accountId: VALID_ADDRESS, balance: 1000n }),
         createAccountBalanceRow({
           accountId: SECOND_ADDRESS,
@@ -219,7 +221,7 @@
     });
 
     it("should accept orderDirection=asc", async () => {
       await db.insert(accountBalance).values([
         createAccountBalanceRow({ accountId: VALID_ADDRESS, balance: 1000n }),
         createAccountBalanceRow({
           accountId: SECOND_ADDRESS,
@@ -268,7 +270,7 @@
     });
 
     it("should accept addresses filter", async () => {
       await db.insert(accountBalance).values([
         createAccountBalanceRow({ accountId: VALID_ADDRESS }),
         createAccountBalanceRow({
           accountId: SECOND_ADDRESS,

apps/api/src/controllers/account-balance/variations.integration.test.ts

@@ -29,6 +29,7 @@
 const createAccountBalanceRow = (
   overrides: Partial<AccountBalanceInsert> = {},
 ): AccountBalanceInsert => ({
+  id: "test-id",
   accountId: VALID_ADDRESS,
   tokenId: TOKEN_ID,
   balance: 1200000000000000000n,
@@ -39,6 +40,7 @@
 const createTransferRow = (
   overrides: Partial<TransferInsert> = {},
 ): TransferInsert => ({
+  id: "test-id",
   transactionHash: TX_HASH,
   daoId: DAO_ID,
   tokenId: TOKEN_ID,
@@ -128,7 +130,7 @@
     });
 
     it("should accept pagination parameters", async () => {
       await db.insert(accountBalance).values([
         createAccountBalanceRow({ accountId: VALID_ADDRESS, balance: 1000n }),
         createAccountBalanceRow({
           accountId: SECOND_ADDRESS,

apps/api/src/controllers/delegation-percentage/index.integration.test.ts

@@ -15,6 +15,7 @@ type MetricInsert = typeof daoMetricsDayBucket.$inferInsert;
 const TEST_DATE = 1699920000n;
 
 const createMetric = (overrides: Partial<MetricInsert> = {}): MetricInsert => ({
+  id: "test-id",
   date: TEST_DATE,
   daoId: "UNI",
   tokenId: "uni",

apps/api/src/controllers/delegations/delegations.integration.test.ts

@@ -27,6 +27,7 @@ const TX_HASH =
 const createAccountBalanceRow = (
   overrides: Partial<AccountBalanceInsert> = {},
 ): AccountBalanceInsert => ({
+  id: "test-id",
   accountId: VALID_ADDRESS,
   tokenId: "uni",
   balance: 1000000000000000000n,
@@ -37,6 +38,7 @@ const createAccountBalanceRow = (
 const createDelegationRow = (
   overrides: Partial<DelegationInsert> = {},
 ): DelegationInsert => ({
+  id: "test-id",
   transactionHash: TX_HASH,
   daoId: DAO_ID,
   delegateAccountId: VALID_ADDRESS,

apps/api/src/controllers/delegations/delegators.integration.test.ts

@@ -29,6 +29,7 @@ const DAO_ID = "uni";
 const createDelegationRow = (
   overrides: Partial<DelegationInsert> = {},
 ): DelegationInsert => ({
+  id: "test-id",
   transactionHash:
     "0xaabbccddaabbccddaabbccddaabbccddaabbccddaabbccddaabbccddaabbccdd",
   daoId: DAO_ID,
@@ -48,6 +49,7 @@ const createDelegationRow = (
 const createAccountBalanceRow = (
   overrides: Partial<AccountBalanceInsert> = {},
 ): AccountBalanceInsert => ({
+  id: "test-id",
   accountId: DELEGATOR_1,
   tokenId: "uni",
   balance: 1000000000000000000n,

apps/api/src/controllers/delegations/historical.delegations.integration.test.ts

@@ -32,6 +32,7 @@ const TX_HASH_2 =
 const createDelegationRow = (
   overrides: Partial<DelegationInsert> = {},
 ): DelegationInsert => ({
+  id: "test-id",
   transactionHash: TX_HASH,
   daoId: DAO_ID,
   delegatorAccountId: VALID_ADDRESS,

apps/api/src/controllers/feed/feed.integration.test.ts

@@ -17,16 +17,18 @@ type FeedEventInsert = typeof feedEvent.$inferInsert;
 const nounsThresholds = getDaoRelevanceThreshold(DaoIdEnum.NOUNS);
 
 const createEvent = (
-  overrides: Partial<FeedEventInsert> = {},
-): FeedEventInsert => ({
-  txHash: "0xabc123def456abc1",
-  logIndex: 0,
-  type: "VOTE" as const,
-  value: nounsThresholds[FeedEventType.VOTE][FeedRelevance.MEDIUM],
-  timestamp: 1700000000,
-  metadata: null,
-  ...overrides,
-});
+  overrides: Partial<Omit<FeedEventInsert, "type"> & { type: string }> = {},
+): FeedEventInsert =>
+  ({
+    id: "test-id",
+    txHash: "0xabc123def456abc1",
+    logIndex: 0,
+    type: "VOTE",
+    value: nounsThresholds[FeedEventType.VOTE][FeedRelevance.MEDIUM],
+    timestamp: 1700000000,
+    metadata: null,
+    ...overrides,
+  }) as FeedEventInsert;
 
 let client: PGlite;
 let db: Drizzle;

apps/api/src/controllers/governance-activity/controller.integration.test.ts

@@ -100,6 +100,7 @@ describe("GovernanceActivity Controller", () => {
 
     it("should return 200 with activeSupply when recent voters exist", async () => {
       await db.insert(accountPower).values({
+        id: "test-id-1",
         accountId: "0x1111111111111111111111111111111111111111",
         daoId: "TEST",
         votingPower: 1000000000000000000n,
@@ -121,6 +122,7 @@ describe("GovernanceActivity Controller", () => {
 
     it("should use default days=90d when not provided", async () => {
       await db.insert(accountPower).values({
+        id: "test-id-2",
         accountId: "0x1111111111111111111111111111111111111111",
         daoId: "TEST",
         votingPower: 500n,
@@ -203,6 +205,7 @@ describe("GovernanceActivity Controller", () => {
     it("should return 200 with data and calculated changeRate", async () => {
       await db.insert(votesOnchain).values([
         {
+          id: "vote-1",
           txHash: "0xv1",
           daoId: "TEST",
           voterAccountId: "0x1111111111111111111111111111111111111111",
@@ -212,6 +215,7 @@ describe("GovernanceActivity Controller", () => {
           timestamp: RECENT_TS,
         },
         {
+          id: "vote-2",
           txHash: "0xv2",
           daoId: "TEST",
           voterAccountId: "0x2222222222222222222222222222222222222222",
@@ -221,6 +225,7 @@ describe("GovernanceActivity Controller", () => {
           timestamp: RECENT_TS,
         },
         {
+          id: "vote-3",
           txHash: "0xv3",
           daoId: "TEST",
           voterAccountId: "0x3333333333333333333333333333333333333333",

apps/api/src/controllers/last-update/index.integration.test.ts

@@ -13,6 +13,7 @@ import { lastUpdate } from "./index";
 type MetricInsert = typeof daoMetricsDayBucket.$inferInsert;
 
 const createMetric = (overrides: Partial<MetricInsert> = {}): MetricInsert => ({
+  id: "test-id",
   date: 1700000000n,
   daoId: "UNI",
   tokenId: "uni",

apps/api/src/controllers/proposals/proposals-activity.integration.test.ts

@@ -84,6 +84,7 @@ const createProposal = (
 });
 
 const createVote = (overrides: Partial<VoteInsert> = {}): VoteInsert => ({
+  id: "0xvote123",
   txHash: "0xvote123",
   daoId: "ENS",
   voterAccountId: VALID_ADDRESS,

apps/api/src/controllers/token-metrics/index.integration.test.ts

@@ -15,6 +15,7 @@ import { tokenMetrics } from "./index";
 type MetricInsert = typeof daoMetricsDayBucket.$inferInsert;
 
 const createMetric = (overrides: Partial<MetricInsert> = {}): MetricInsert => ({
+  id: "test-id",
   date: 1700000000n,
   daoId: "UNI",
   tokenId: "uni",

apps/api/src/controllers/token/token-distribution.integration.test.ts

@@ -28,6 +28,7 @@ let repo: DrizzleRepository;
 let app: Hono;
 
 const createMetric = (overrides: Partial<MetricInsert> = {}): MetricInsert => ({
+  id: "test-id",
   date: BigInt(NOW - 10),
   daoId: "ENS",
   tokenId: "ens",

apps/api/src/controllers/transactions/index.integration.test.ts

@@ -19,6 +19,7 @@ type DelegationInsert = typeof delegation.$inferInsert;
 const createTransaction = (
   overrides: Partial<TransactionInsert> = {},
 ): TransactionInsert => ({
+  id: "test-id",
   transactionHash: TX_HASH,
   fromAddress: getAddress("0x1111111111111111111111111111111111111111"),
   toAddress: getAddress("0x2222222222222222222222222222222222222222"),
@@ -33,6 +34,7 @@ const createTransaction = (
 const createTransfer = (
   overrides: Partial<TransferInsert> = {},
 ): TransferInsert => ({
+  id: "test-id",
   transactionHash: TX_HASH,
   daoId: "UNI",
   tokenId: "uni",
@@ -51,6 +53,7 @@ const createTransfer = (
 const createDelegation = (
   overrides: Partial<DelegationInsert> = {},
 ): DelegationInsert => ({
+  id: "test-id",
   transactionHash: TX_HASH,
   daoId: "UNI",
   delegateAccountId: getAddress("0x3333333333333333333333333333333333333333"),

apps/api/src/controllers/transfers/index.integration.test.ts

@@ -20,6 +20,7 @@ type TransferInsert = typeof transfer.$inferInsert;
 const createTransfer = (
   overrides: Partial<TransferInsert> = {},
 ): TransferInsert => ({
+  id: "test-id",
   transactionHash: "0xabc",
   daoId: "UNI",
   tokenId: "uni",

apps/api/src/controllers/votes/onchainVotes.integration.test.ts

@@ -49,6 +49,7 @@ const createProposal = (
 });
 
 const createVote = (overrides: Partial<VoteInsert> = {}): VoteInsert => ({
+  id: "test-id",
   txHash: "0xabc123",
   daoId: "ENS",
   voterAccountId: VOTER_ADDRESS,
@@ -63,6 +64,7 @@ const createVote = (overrides: Partial<VoteInsert> = {}): VoteInsert => ({
 const createAccountPower = (
   overrides: Partial<AccountPowerInsert> = {},
 ): AccountPowerInsert => ({
+  id: "test-id",
   accountId: VOTER_ADDRESS,
   daoId: "ENS",
   votingPower: 1000000000000000000n,

apps/api/src/controllers/voting-power/historical.integration.test.ts

@@ -29,6 +29,7 @@ const DAO_ID = "ENS";
 const createHistoryRow = (
   overrides: Partial<VotingPowerHistoryInsert> = {},
 ): VotingPowerHistoryInsert => ({
+  id: "test-id",
   transactionHash: TX_HASH,
   daoId: DAO_ID,
   accountId: VALID_ADDRESS,
@@ -43,6 +44,7 @@ const createHistoryRow = (
 const createDelegationRow = (
   overrides: Partial<DelegationInsert> = {},
 ): DelegationInsert => ({
+  id: "test-id",
   transactionHash: TX_HASH,
   daoId: DAO_ID,
   delegateAccountId: VALID_ADDRESS,

apps/api/src/controllers/voting-power/listing.integration.test.ts

@@ -25,6 +25,7 @@ const DAO_ID = "test-dao";
 const createAccountPowerRow = (
   overrides: Partial<AccountPowerInsert> = {},
 ): AccountPowerInsert => ({
+  id: "test-id",
   accountId: TEST_ACCOUNT_1,
   daoId: DAO_ID,
   votingPower: 1000n,
@@ -38,6 +39,7 @@ const createAccountPowerRow = (
 const createHistoryRow = (
   overrides: Partial<VotingPowerHistoryInsert> = {},
 ): VotingPowerHistoryInsert => ({
+  id: "test-id",
   transactionHash:
     "0xabc1230000000000000000000000000000000000000000000000000000000000",
   daoId: DAO_ID,

apps/api/src/controllers/voting-power/variations.integration.test.ts

@@ -30,6 +30,7 @@ const TX_4 =
 const createHistoryRow = (
   overrides: Partial<VotingPowerHistoryInsert> = {},
 ): VotingPowerHistoryInsert => ({
+  id: "test-id",
   transactionHash:
     "0xabc1230000000000000000000000000000000000000000000000000000000000",
   daoId: DAO_ID,
@@ -45,6 +46,7 @@ const createHistoryRow = (
 const createAccountPowerRow = (
   overrides: Partial<AccountPowerInsert> = {},
 ): AccountPowerInsert => ({
+  id: "test-id",
   accountId: VALID_ADDRESS,
   daoId: DAO_ID,
   votingPower: 1200000000000000000n,