Merge branch 'master' into ask-for-contacts-export

src/services/AbsurdSqlDatabaseService.ts

@@ -1,7 +1,9 @@
 // **WORKER-COMPATIBLE CRYPTO POLYFILL**: Must be at the very top
 // This prevents "crypto is not defined" errors when running in worker context
 if (typeof window === "undefined" && typeof crypto === "undefined") {
+  // eslint-disable-next-line @typescript-eslint/no-explicit-any
   (globalThis as any).crypto = {
+    // eslint-disable-next-line @typescript-eslint/no-explicit-any
     getRandomValues: (array: any) => {
       // Simple fallback for worker context
       for (let i = 0; i < array.length; i++) {
@@ -134,7 +136,11 @@ class AbsurdSqlDatabaseService implements DatabaseService {
 
     // An error is thrown without this pragma: "File has invalid page size. (the first block of a new file must be written first)"
     await this.db.exec(`PRAGMA journal_mode=MEMORY;`);
-    const sqlExec = this.db.run.bind(this.db);
+
+    // Create wrapper functions that match the expected signatures
+    const sqlExec = async (sql: string, params?: unknown[]): Promise<void> => {
+      await this.db!.run(sql, params);
+    };
     const sqlQuery = this.db.exec.bind(this.db);
 
     // Extract the migration names for the absurd-sql format
@@ -178,14 +184,6 @@ class AbsurdSqlDatabaseService implements DatabaseService {
         }
         operation.resolve(result);
       } catch (error) {
-        // logger.error( // DISABLED
-        //   "Error while processing SQL queue:",
-        //   error,
-        //   " ... for sql:",
-        //   operation.sql,
-        //   " ... with params:",
-        //   operation.params,
-        // );
         logger.error(
           "Error while processing SQL queue:",
           error,
@@ -238,9 +236,6 @@ class AbsurdSqlDatabaseService implements DatabaseService {
 
     // If initialized but no db, something went wrong
     if (!this.db) {
-      // logger.error( // DISABLED
-      //   `Database not properly initialized after await waitForInitialization() - initialized flag is true but db is null`,
-      // );
       logger.error(
         `Database not properly initialized after await waitForInitialization() - initialized flag is true but db is null`,
       );

src/services/ProfileService.ts

@@ -103,9 +103,10 @@ export class ProfileService {
         { headers },
       );
 
-      if (response.status === 200) {
+      if (response.status === 201) {
         return true;
       } else {
+        logger.error("Error saving profile:", response);
         throw new Error(ACCOUNT_VIEW_CONSTANTS.ERRORS.PROFILE_NOT_SAVED);
       }
     } catch (error) {

src/services/deepLinks.ts

@@ -53,6 +53,7 @@ import {
   DeepLinkRoute,
 } from "../interfaces/deepLinks";
 import type { DeepLinkError } from "../interfaces/deepLinks";
+import { logger } from "../utils/logger";
 
 // Helper function to extract the first key from a Zod object schema
 function getFirstKeyFromZodObject(
@@ -149,6 +150,10 @@ export class DeepLinkHandler {
       params[routeConfig.paramKey ?? "id"] = pathParams.join("/");
     }
 
+    // logConsoleAndDb(
+    //   `[DeepLink] Debug: Route Path: ${routePath} Path Params: ${JSON.stringify(params)} Query String: ${JSON.stringify(query)}`,
+    //   false,
+    // );
     return { path: routePath, params, query };
   }
 
@@ -174,7 +179,7 @@ export class DeepLinkHandler {
       const validRoute = routeSchema.parse(path) as DeepLinkRoute;
       routeName = ROUTE_MAP[validRoute].name;
     } catch (error) {
-      console.error(`[DeepLink] Invalid route path: ${path}`);
+      logger.error(`[DeepLink] Invalid route path: ${path}`);
 
       // Redirect to error page with information about the invalid link
       await this.router.replace({
@@ -195,13 +200,12 @@ export class DeepLinkHandler {
     // Continue with parameter validation as before...
     const schema = deepLinkSchemas[path as keyof typeof deepLinkSchemas];
 
-    let validatedParams, validatedQuery;
+    let validatedParams;
     try {
       validatedParams = await schema.parseAsync(params);
-      validatedQuery = await schema.parseAsync(query);
     } catch (error) {
       // For parameter validation errors, provide specific error feedback
-      console.error(
+      logger.error(
         `[DeepLink] Invalid parameters for route name ${routeName} for path: ${path}: ${JSON.stringify(error)} ... with params: ${JSON.stringify(params)} ... and query: ${JSON.stringify(query)}`,
       );
       await this.router.replace({
@@ -223,11 +227,10 @@ export class DeepLinkHandler {
       await this.router.replace({
         name: routeName,
         params: validatedParams,
-        query: validatedQuery,
       });
     } catch (error) {
-      console.error(
-        `[DeepLink] Error routing to route name ${routeName} for path: ${path}: ${JSON.stringify(error)} ... with validated params: ${JSON.stringify(validatedParams)} ... and validated query: ${JSON.stringify(validatedQuery)}`,
+      logger.error(
+        `[DeepLink] Error routing to route name ${routeName} for path: ${path}: ${JSON.stringify(error)} ... with validated params: ${JSON.stringify(validatedParams)}`,
       );
       // For parameter validation errors, provide specific error feedback
       await this.router.replace({
@@ -237,7 +240,6 @@ export class DeepLinkHandler {
           originalPath: path,
           errorCode: "ROUTING_ERROR",
           errorMessage: `Error routing to ${routeName}: ${JSON.stringify(error)}`,
-          ...validatedQuery,
         },
       });
     }
@@ -260,7 +262,7 @@ export class DeepLinkHandler {
       await this.validateAndRoute(path, sanitizedParams, query);
     } catch (error) {
       const deepLinkError = error as DeepLinkError;
-      console.error(
+      logger.error(
         `[DeepLink] Error (${deepLinkError.code}): ${deepLinkError.details}`,
       );
 

src/services/platforms/CapacitorPlatformService.ts

@@ -11,7 +11,6 @@ import {
   SQLiteConnection,
   SQLiteDBConnection,
   CapacitorSQLite,
-  capSQLiteChanges,
   DBSQLiteValues,
 } from "@capacitor-community/sqlite";
 
@@ -493,22 +492,17 @@ export class CapacitorPlatformService implements PlatformService {
      * @param params - Optional parameters for prepared statements
      * @returns Promise resolving to execution results
      */
-    const sqlExec = async (
-      sql: string,
-      params?: unknown[],
-    ): Promise<capSQLiteChanges> => {
+    const sqlExec = async (sql: string, params?: unknown[]): Promise<void> => {
       logger.debug(`🔧 [CapacitorMigration] Executing SQL:`, sql);
 
       if (params && params.length > 0) {
         // Use run method for parameterized queries (prepared statements)
         // This is essential for proper parameter binding and SQL injection prevention
-        const result = await this.db!.run(sql, params);
-        return result;
+        await this.db!.run(sql, params);
       } else {
         // Use execute method for non-parameterized queries
         // This is more efficient for simple DDL statements
-        const result = await this.db!.execute(sql);
-        return result;
+        await this.db!.execute(sql);
       }
     };
 

src/services/platforms/WebPlatformService.ts

@@ -693,7 +693,8 @@ export class WebPlatformService implements PlatformService {
     const setClause = keys.map((key) => `${key} = ?`).join(", ");
     const sql = `UPDATE settings SET ${setClause} WHERE accountDid = ?`;
     const params = [...keys.map((key) => settings[key]), did];
-    console.log(
+    // Log update operation for debugging
+    logger.debug(
       "[WebPlatformService] updateDidSpecificSettings",
       sql,
       JSON.stringify(params, null, 2),