feat: dialog box

packages/shared/package.json

@@ -12,7 +12,7 @@
     "drizzle-zero": "^0.14.3"
   },
   "scripts": {
-    "generate:zero": "drizzle-zero generate -s ./src/db/schema/public.ts -o ./src/zero-schema.gen.ts -f && sed -i 's/enableLegacyQueries: true,/enableLegacyQueries: false,/g' src/zero-schema.gen.ts && sed -i 's/enableLegacyMutators: true,/enableLegacyMutators: false,/g' src/zero-schema.gen.ts",
+    "db:gen": "drizzle-zero generate -s ./src/db/schema/public.ts -o ./src/zero-schema.gen.ts -f && sed -i 's/enableLegacyQueries: true,/enableLegacyQueries: false,/g' src/zero-schema.gen.ts && sed -i 's/enableLegacyMutators: true,/enableLegacyMutators: false,/g' src/zero-schema.gen.ts",
     "db:migrate": "drizzle-kit push"
   }
 }

packages/shared/src/db/schema/public.ts

@@ -43,6 +43,7 @@ export const balance = pgTable("balance", {
   avaliable: decimal("avaliable").notNull(),
   current: decimal("current").notNull(),
   name: text("name").notNull(),
+  tokenId: text("tokenId").notNull(),
   createdAt: timestamp("created_at").notNull().defaultNow(),
   updatedAt: timestamp("updated_at").notNull().defaultNow(),
 });

packages/shared/src/mutators.ts

@@ -1,6 +1,6 @@
 import type { Transaction } from "@rocicorp/zero";
 import type { AuthData } from "./auth";
-import type { Schema } from ".";
+import { isLoggedIn, type Schema } from ".";
 
 type Tx = Transaction<Schema>;
 
@@ -11,6 +11,31 @@ export function createMutators(authData: AuthData | null) {
       async get(tx: Tx, { link_token }: { link_token: string }) {},
       async updateTransactions() {},
       async updateBalences() {},
+      async deleteAccounts(tx: Tx, { accountIds }: { accountIds: string[]  }) {
+        isLoggedIn(authData);
+        for (const id of accountIds) {
+          const token = await tx.query.plaidAccessTokens.where("userId", '=', authData.user.id).one();
+          if (!token) continue;
+          await tx.mutate.plaidAccessTokens.delete({ id });
+
+          const balances = await tx.query.balance
+            .where('user_id', '=', authData.user.id)
+            .where("tokenId", '=', token.id)
+            .run();
+
+          for (const bal of balances) {
+            await tx.mutate.balance.delete({ id: bal.id });
+            const txs = await tx.query.transaction
+              .where('user_id', '=', authData.user.id)
+              .where('account_id', '=', bal.tokenId)
+              .run();
+            for (const transaction of txs) {
+              await tx.mutate.transaction.delete({ id: transaction.id });
+            }
+          }
+
+        }
+      },
     }
   } as const;
 }

packages/shared/src/queries.ts

@@ -22,6 +22,7 @@ export const queries = {
     isLoggedIn(authData);
     return builder.plaidLink
       .where('user_id', '=', authData.user.id)
+      .where('createdAt', '<', new Date().getTime() + (1000 * 60 * 60 * 4))
       .orderBy('createdAt', 'desc')
       .one();
   }),

packages/shared/src/zero-schema.gen.ts

@@ -80,6 +80,15 @@ export const schema = {
             "name"
           >,
         },
+        tokenId: {
+          type: "string",
+          optional: false,
+          customType: null as unknown as ZeroCustomType<
+            ZeroSchema,
+            "balance",
+            "tokenId"
+          >,
+        },
         createdAt: {
           type: "number",
           optional: true,