Browse Source

zen: remove unnecessary transactions

Frank 4 tháng trước cách đây
mục cha
commit
dc32705bc9

+ 1 - 1
packages/console/app/src/routes/workspace-picker.tsx

@@ -14,7 +14,7 @@ import "./workspace-picker.css"
 const getWorkspaces = query(async () => {
   "use server"
   return withActor(async () => {
-    return Database.transaction((tx) =>
+    return Database.use((tx) =>
       tx
         .select({
           id: WorkspaceTable.id,

+ 5 - 6
packages/console/core/src/account.ts

@@ -11,7 +11,7 @@ export namespace Account {
       id: z.string().optional(),
     }),
     async (input) =>
-      Database.transaction(async (tx) => {
+      Database.use(async (tx) => {
         const id = input.id ?? Identifier.create("account")
         await tx.insert(AccountTable).values({
           id,
@@ -21,13 +21,12 @@ export namespace Account {
   )
 
   export const fromID = fn(z.string(), async (id) =>
-    Database.transaction(async (tx) => {
-      return tx
+    Database.use((tx) =>
+      tx
         .select()
         .from(AccountTable)
         .where(eq(AccountTable.id, id))
-        .execute()
-        .then((rows) => rows[0])
-    }),
+        .then((rows) => rows[0]),
+    ),
   )
 }

+ 1 - 1
packages/console/core/src/provider.ts

@@ -47,7 +47,7 @@ export namespace Provider {
     }),
     async ({ provider }) => {
       Actor.assertAdmin()
-      return Database.transaction((tx) =>
+      Database.use((tx) =>
         tx
           .delete(ProviderTable)
           .where(and(eq(ProviderTable.provider, provider), eq(ProviderTable.workspaceID, Actor.workspace()))),

+ 1 - 1
packages/console/function/src/auth.ts

@@ -194,7 +194,7 @@ export default {
         // Get workspace
         await Actor.provide("account", { accountID, email }, async () => {
           await User.joinInvitedWorkspaces()
-          const workspaces = await Database.transaction(async (tx) =>
+          const workspaces = await Database.use((tx) =>
             tx
               .select({ id: WorkspaceTable.id })
               .from(WorkspaceTable)