Run prettier

Author: simolus3

packages/common/src/client/AbstractPowerSyncDatabase.ts

@@ -364,14 +364,13 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
         priorityStatuses.push({ priority, hasSynced: true, lastSyncedAt: parsedDate });
       }
     }
-    
 
     const hasSynced = lastCompleteSync != null;
     const updatedStatus = new SyncStatus({
       ...this.currentStatus.toJSON(),
       hasSynced,
       priorityStatuses,
-      lastSyncedAt: lastCompleteSync,
+      lastSyncedAt: lastCompleteSync
     });
 
     if (!updatedStatus.isEqual(this.currentStatus)) {

packages/common/src/client/sync/bucket/SqliteBucketStorage.ts

@@ -207,7 +207,7 @@ export class SqliteBucketStorage extends BaseObserver<BucketStorageListener> imp
     if (priority !== undefined) {
       // Only validate the buckets within the priority we care about
       const newBuckets = checkpoint.buckets.filter((cs) => hasMatchingPriority(priority, cs));
-      checkpoint = {...checkpoint, buckets: newBuckets};
+      checkpoint = { ...checkpoint, buckets: newBuckets };
     }
 
     const rs = await this.db.execute('SELECT powersync_validate_checkpoint(?) as result', [

packages/common/src/client/sync/stream/AbstractStreamingSyncImplementation.ts

@@ -557,7 +557,10 @@ The next upload iteration will be delayed.`);
             const bucketsToDelete = new Set<string>(bucketMap.keys());
             const newBuckets = new Map<string, BucketDescription>();
             for (const checksum of line.checkpoint.buckets) {
-              newBuckets.set(checksum.bucket, { name: checksum.bucket, priority: checksum.priority ?? FALLBACK_PRIORITY });
+              newBuckets.set(checksum.bucket, {
+                name: checksum.bucket,
+                priority: checksum.priority ?? FALLBACK_PRIORITY
+              });
               bucketsToDelete.delete(checksum.bucket);
             }
             if (bucketsToDelete.size > 0) {

packages/web/bin/powersync.js

@@ -5,31 +5,27 @@ const program = new Command();
 const path = require('path');
 const fsPromise = require('fs/promises');
 const { version } = require('../package.json');
-  
-program
-  .name('powersync-web')
-  .description('CLI for PowerSync Web SDK utilities')
-  .version(version);
+
+program.name('powersync-web').description('CLI for PowerSync Web SDK utilities').version(version);
 
 program
   .command('copy-assets')
   .description('Copy assets to the specified output directory')
   .option('-o, --output <directory>', 'output directory for assets', 'public')
-  .action(async(options) => {
+  .action(async (options) => {
     const outputDir = options.output;
-    
+
     console.log(`Target directory: ${outputDir}`);
-    
+
     const cwd = process.cwd();
     const source = path.join(cwd, 'node_modules', '@powersync', 'web', 'dist');
     const destination = path.join(cwd, outputDir, '@powersync');
-    
+
     await fsPromise.rm(destination, { recursive: true, force: true }); // Clear old assets
 
-    await copyDirectory(source, destination)
+    await copyDirectory(source, destination);
   });
 
-
 program.parse(process.argv);
 
 async function copyDirectory(source, destination) {
@@ -40,4 +36,4 @@ async function copyDirectory(source, destination) {
     console.error(`Error copying assets: ${err.message}`);
     process.exit(1);
   }
-}
+}

packages/web/src/db/PowerSyncDatabase.ts

@@ -14,7 +14,7 @@ import {
   PowerSyncDatabaseOptionsWithOpenFactory,
   PowerSyncDatabaseOptionsWithSettings,
   SqliteBucketStorage,
-  StreamingSyncImplementation,
+  StreamingSyncImplementation
 } from '@powersync/common';
 import { Mutex } from 'async-mutex';
 import { getNavigatorLocks } from '../shared/navigator';

packages/web/src/shared/navigator.ts

@@ -3,5 +3,7 @@ export const getNavigatorLocks = (): LockManager => {
     return navigator.locks;
   }
 
-  throw new Error('Navigator locks are not available in an insecure context. Use a secure context such as HTTPS or http://localhost.');
-}
+  throw new Error(
+    'Navigator locks are not available in an insecure context. Use a secure context such as HTTPS or http://localhost.'
+  );
+};

packages/web/tests/crud.test.ts

@@ -79,9 +79,9 @@ describe('CRUD Tests', () => {
     expect(await powersync.get('SELECT count(*) AS count FROM assets')).deep.equals({ count: 1 });
 
     // Make sure uniqueness is enforced
-    await expect(powersync.execute('INSERT INTO assets(id, description) VALUES(?, ?)', [testId, 'test3'])).rejects.toThrow(
-      /UNIQUE constraint failed/
-    );
+    await expect(
+      powersync.execute('INSERT INTO assets(id, description) VALUES(?, ?)', [testId, 'test3'])
+    ).rejects.toThrow(/UNIQUE constraint failed/);
   });
 
   it('UPDATE', async () => {

packages/web/tests/shared/navigator.test.ts

@@ -9,7 +9,7 @@ describe('getNavigationLocks', () => {
   it('should return native navigator.locks if available', () => {
     const mockLocks = {
       request: vi.fn(),
-      query: vi.fn(),
+      query: vi.fn()
     };
 
     vi.spyOn(navigator, 'locks', 'get').mockReturnValue(mockLocks);
@@ -19,9 +19,10 @@ describe('getNavigationLocks', () => {
   });
 
   it('should throw an error if navigator.locks is unavailable', () => {
-
     vi.spyOn(navigator, 'locks', 'get').mockReturnValue(undefined!);
 
-    expect(() => getNavigatorLocks()).toThrowError('Navigator locks are not available in an insecure context. Use a secure context such as HTTPS or http://localhost.');;
+    expect(() => getNavigatorLocks()).toThrowError(
+      'Navigator locks are not available in an insecure context. Use a secure context such as HTTPS or http://localhost.'
+    );
   });
 });

packages/web/tests/src/db/AbstractPowerSyncDatabase.test.ts

@@ -1,29 +1,42 @@
 import { describe, it, expect, vi } from 'vitest';
-import { AbstractPowerSyncDatabase, DEFAULT_RETRY_DELAY_MS, DEFAULT_CRUD_UPLOAD_THROTTLE_MS, BucketStorageAdapter, DBAdapter, PowerSyncBackendConnector, PowerSyncDatabaseOptionsWithSettings, RequiredAdditionalConnectionOptions, StreamingSyncImplementation } from '@powersync/common';
+import {
+  AbstractPowerSyncDatabase,
+  DEFAULT_RETRY_DELAY_MS,
+  DEFAULT_CRUD_UPLOAD_THROTTLE_MS,
+  BucketStorageAdapter,
+  DBAdapter,
+  PowerSyncBackendConnector,
+  PowerSyncDatabaseOptionsWithSettings,
+  RequiredAdditionalConnectionOptions,
+  StreamingSyncImplementation
+} from '@powersync/common';
 import { testSchema } from '../../utils/testDb';
 
 class TestPowerSyncDatabase extends AbstractPowerSyncDatabase {
   protected openDBAdapter(options: PowerSyncDatabaseOptionsWithSettings): DBAdapter {
-    return {} as any
+    return {} as any;
   }
-  protected generateSyncStreamImplementation(connector: PowerSyncBackendConnector, options: RequiredAdditionalConnectionOptions): StreamingSyncImplementation {
+  protected generateSyncStreamImplementation(
+    connector: PowerSyncBackendConnector,
+    options: RequiredAdditionalConnectionOptions
+  ): StreamingSyncImplementation {
     return undefined as any;
   }
   protected generateBucketStorageAdapter(): BucketStorageAdapter {
     return {
       init: vi.fn()
-    } as any
+    } as any;
   }
   _initialize(): Promise<void> {
     return Promise.resolve();
   }
 
   get database() {
     return {
-      get: vi.fn().mockResolvedValue({ version: '0.3.0'}),
+      get: vi.fn().mockResolvedValue({ version: '0.3.0' }),
       execute: vi.fn(),
-      refreshSchema: vi.fn(),
-    } as any
+      refreshSchema: vi.fn()
+    } as any;
   }
   // Expose protected method for testing
   public testResolvedConnectionOptions(options?: any) {

packages/web/tests/src/db/PowersyncDatabase.test.ts

@@ -10,7 +10,7 @@ describe('PowerSyncDatabase', () => {
 
   beforeEach(() => {
     mockLogger = {
-      debug: vi.fn(),
+      debug: vi.fn()
     };
 
     // Initialize with minimal required options
@@ -24,8 +24,7 @@ describe('PowerSyncDatabase', () => {
 
     vi.spyOn(db as any, 'runExclusive').mockImplementation((cb: any) => cb());
 
-    vi.spyOn(AbstractPowerSyncDatabase.prototype, 'connect')
-      .mockResolvedValue(undefined);
+    vi.spyOn(AbstractPowerSyncDatabase.prototype, 'connect').mockResolvedValue(undefined);
   });
 
   afterEach(() => {
@@ -49,17 +48,14 @@ describe('PowerSyncDatabase', () => {
         connectionMethod: SyncStreamConnectionMethod.HTTP
       });
 
-      expect(AbstractPowerSyncDatabase.prototype.connect).toHaveBeenCalledWith(
-        mockConnector,
-        {
-          retryDelayMs: 1000,
-          crudUploadThrottleMs: 2000,
-          connectionMethod: "http",
-          params: {
-            param1: 1,
-          },
+      expect(AbstractPowerSyncDatabase.prototype.connect).toHaveBeenCalledWith(mockConnector, {
+        retryDelayMs: 1000,
+        crudUploadThrottleMs: 2000,
+        connectionMethod: 'http',
+        params: {
+          param1: 1
         }
-      );
+      });
     });
   });
 });