refactor: fix typescript issues

GetStream · Nov 29, 2022 · 8eb7879 · 8eb7879
1 parent 89a12b1
commit 8eb7879
Show file tree

Hide file tree

Showing 7 changed files with 11 additions and 8 deletions.
diff --git a/package/src/store/QuickSqliteClient.ts b/package/src/store/QuickSqliteClient.ts
@@ -83,13 +83,12 @@ export class QuickSqliteClient {
   };
 
   static executeSql = (query: string, params?: string[]) => {
-    this.openDB();
-
     if (this.isQuickSqliteV4) {
       return QuickSqliteClient_v4.executeSql(query, params);
     }
 
     try {
+      this.openDB();
       const { rows } = sqlite.execute(DB_NAME, query, params);
       this.closeDB();
 

diff --git a/package/src/store/apis/getPendingTasks.ts b/package/src/store/apis/getPendingTasks.ts
@@ -1,6 +1,7 @@
 import { mapStorableToTask } from '../mappers/mapStorableToTask';
 import { QuickSqliteClient } from '../QuickSqliteClient';
 import { createSelectQuery } from '../sqlite-utils/createSelectQuery';
+import type { TableRowJoinedUser } from '../types';
 
 export const getPendingTasks = (conditions: { messageId?: string } = {}) => {
   const query = createSelectQuery('pendingTasks', ['*'], conditions, {
@@ -9,5 +10,5 @@ export const getPendingTasks = (conditions: { messageId?: string } = {}) => {
 
   const result = QuickSqliteClient.executeSql.apply(null, query);
 
-  return result.map((r) => mapStorableToTask(r));
+  return result.map((r: TableRowJoinedUser<'pendingTasks'>) => mapStorableToTask(r));
 };
diff --git a/package/src/store/apis/queries/selectChannels.ts b/package/src/store/apis/queries/selectChannels.ts
@@ -18,7 +18,10 @@ export const selectChannels = ({
   const result = QuickSqliteClient.executeSql.apply(null, query);
 
   if (channelIds) {
-    return result.sort((a, b) => channelIds.indexOf(a.cid) - channelIds.indexOf(b.cid));
+    return result.sort(
+      (a: { cid: string }, b: { cid: string }) =>
+        channelIds.indexOf(a.cid) - channelIds.indexOf(b.cid),
+    );
   } else {
     return result;
   }

diff --git a/package/src/store/apis/queries/selectMembersForChannels.ts b/package/src/store/apis/queries/selectMembersForChannels.ts
@@ -28,5 +28,5 @@ export const selectMembersForChannels = (cids: string[]): TableRowJoinedUser<'me
     cids,
   );
 
-  return result.map((r) => JSON.parse(r.value));
+  return result.map((r: { value: string }) => JSON.parse(r.value));
 };
diff --git a/package/src/store/apis/queries/selectMessagesForChannels.ts b/package/src/store/apis/queries/selectMessagesForChannels.ts
@@ -36,5 +36,5 @@ export const selectMessagesForChannels = (cids: string[]): TableRowJoinedUser<'m
     cids,
   );
 
-  return result.map((r) => JSON.parse(r.value));
+  return result.map((r: { value: string }) => JSON.parse(r.value));
 };
diff --git a/package/src/store/apis/queries/selectReactionsForMessages.ts b/package/src/store/apis/queries/selectReactionsForMessages.ts
@@ -29,5 +29,5 @@ export const selectReactionsForMessages = (
     messageIds,
   );
 
-  return result.map((r) => JSON.parse(r.value));
+  return result.map((r: { value: string }) => JSON.parse(r.value));
 };
diff --git a/package/src/store/apis/queries/selectReadsForChannels.ts b/package/src/store/apis/queries/selectReadsForChannels.ts
@@ -26,5 +26,5 @@ export const selectReadsForChannels = (cids: string[]): TableRowJoinedUser<'read
     cids,
   );
 
-  return result.map((r) => JSON.parse(r.value));
+  return result.map((r: { value: string }) => JSON.parse(r.value));
 };
-Original file line number
+Diff line change
@@ Expand Up @@
         cids,
       );
-      return result.map((r) => JSON.parse(r.value));
+      return result.map((r: { value: string }) => JSON.parse(r.value));
     };