removed awaits

Bossett · Sep 6, 2024 · d310d30 · d310d30
1 parent ef9e0a8
commit d310d30
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 7 deletions.
diff --git a/src/labelEmitter.ts b/src/labelEmitter.ts
@@ -165,9 +165,9 @@ export default async function labelEmitter() {
 
     if (completedEvents.size > 0) {
       logger.debug(`deleting ${completedEvents.size} completed events`)
-      await db
-        .delete(schema.label_actions)
-        .where(inArray(schema.label_actions.id, Array.from(completedEvents)))
+      db.delete(schema.label_actions).where(
+        inArray(schema.label_actions.id, Array.from(completedEvents)),
+      )
 
       let outputString = `emitted ${completedEvents.size} labels in ${
         Object.keys(groupedEvents).length

diff --git a/src/lib/insertListItemOperation.ts b/src/lib/insertListItemOperation.ts
@@ -54,7 +54,7 @@ async function syncListChangeToDb(did: string, currentLabels: Set<string>) {
     )
 
   if (!isValueMapAndExistingEqual) {
-    await db.transaction(async (tx) => {
+    db.transaction(async (tx) => {
       if (valueMap.length > 0) {
         const validIds = await tx
           .insert(schema.listItems)

diff --git a/src/lib/insertOperations.ts b/src/lib/insertOperations.ts
@@ -45,8 +45,7 @@ export async function insertOperations(
   }
 
   if (activeOps.length > 0) {
-    await db
-      .insert(schema.label_actions)
+    db.insert(schema.label_actions)
       .values(activeOps)
       .then(() => {
         logger.debug(`inserted ${activeOps.length} operations`)

diff --git a/src/lib/listManager.ts b/src/lib/listManager.ts
@@ -163,7 +163,7 @@ export async function updateListItemURLs(
 ) {
   if (items.length === 0) return 0
   const updatedIds: { updatedId: number }[] = []
-  await db.transaction(async (tx) => {
+  db.transaction(async (tx) => {
     updatedIds.push(
       ...(await tx
         .insert(schema.listItems)