Fix typo

Author: simolus3

packages/common/src/client/AbstractPowerSyncDatabase.ts

@@ -352,7 +352,7 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
       'SELECT priority, last_synced_at FROM ps_sync_state ORDER BY priority DESC'
     );
     let lastCompleteSync: Date | undefined;
-    const prioritStatuses: SyncPriorityStatus[] = [];
+    const priorityStatuses: SyncPriorityStatus[] = [];
 
     for (const { priority, last_synced_at } of result) {
       const parsedDate = new Date(last_synced_at + 'Z');
@@ -361,7 +361,7 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
         // This lowest-possible priority represents a complete sync.
         lastCompleteSync = parsedDate;
       } else {
-        prioritStatuses.push({ priority, hasSynced: true, lastSyncedAt: parsedDate });
+        priorityStatuses.push({ priority, hasSynced: true, lastSyncedAt: parsedDate });
       }
     }
 
@@ -370,7 +370,7 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
     const updatedStatus = new SyncStatus({
       ...this.currentStatus.toJSON(),
       hasSynced,
-      prioritStatuses,
+      priorityStatuses,
       lastSyncedAt: lastCompleteSync,
     });
 

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

@@ -601,7 +601,7 @@ The next upload iteration will be delayed.`);
               this.logger.debug('partial checkpoint validation succeeded');
 
               // All states with a higher priority can be deleted since this partial sync includes them.
-              const priorityStates = this.syncStatus.prioritStatuses.filter((s) => s.priority <= priority);
+              const priorityStates = this.syncStatus.priorityStatuses.filter((s) => s.priority <= priority);
               priorityStates.push({
                 priority,
                 lastSyncedAt: new Date(),
@@ -610,7 +610,7 @@ The next upload iteration will be delayed.`);
 
               this.updateSyncStatus({
                 connected: true,
-                prioritStatuses: priorityStates
+                priorityStatuses: priorityStates
               });
             }
           } else if (isStreamingSyncCheckpointDiff(line)) {
@@ -679,7 +679,7 @@ The next upload iteration will be delayed.`);
               this.updateSyncStatus({
                 connected: true,
                 lastSyncedAt: new Date(),
-                prioritStatuses: []
+                priorityStatuses: []
               });
             } else if (validatedCheckpoint === targetCheckpoint) {
               const result = await this.options.adapter.syncLocalDatabase(targetCheckpoint!);
@@ -696,7 +696,7 @@ The next upload iteration will be delayed.`);
                 this.updateSyncStatus({
                   connected: true,
                   lastSyncedAt: new Date(),
-                  prioritStatuses: [],
+                  priorityStatuses: [],
                   dataFlow: {
                     downloading: false
                   }
@@ -721,7 +721,7 @@ The next upload iteration will be delayed.`);
         ...this.syncStatus.dataFlowStatus,
         ...options.dataFlow
       },
-      prioritStatuses: options.prioritStatuses ?? this.syncStatus.prioritStatuses
+      priorityStatuses: options.priorityStatuses ?? this.syncStatus.priorityStatuses
     });
 
     if (!this.syncStatus.isEqual(updatedStatus)) {

packages/common/src/db/crud/SyncStatus.ts

@@ -15,7 +15,7 @@ export type SyncStatusOptions = {
   dataFlow?: SyncDataFlowStatus;
   lastSyncedAt?: Date;
   hasSynced?: boolean;
-  prioritStatuses?: SyncPriorityStatus[];
+  priorityStatuses?: SyncPriorityStatus[];
 };
 
 export class SyncStatus {
@@ -70,8 +70,8 @@ export class SyncStatus {
   /**
    * Partial sync status for involved bucket priorities.
    */
-  get prioritStatuses() {
-    return (this.options.prioritStatuses ?? []).toSorted(SyncStatus.comparePriorities);
+  get priorityStatuses() {
+    return (this.options.priorityStatuses ?? []).toSorted(SyncStatus.comparePriorities);
   }
 
   /**
@@ -90,8 +90,8 @@ export class SyncStatus {
    * @param priority The bucket priority for which the status should be reported.
    */
   statusForPriority(priority: number): SyncPriorityStatus {
-    // prioritStatuses are sorted by ascending priorities (so higher numbers to lower numbers).
-    for (const known of this.prioritStatuses) {
+    // priorityStatuses are sorted by ascending priorities (so higher numbers to lower numbers).
+    for (const known of this.priorityStatuses) {
       // We look for the first entry that doesn't have a higher priority.
       if (known.priority >= priority) {
         return known;
@@ -122,7 +122,7 @@ export class SyncStatus {
       dataFlow: this.dataFlowStatus,
       lastSyncedAt: this.lastSyncedAt,
       hasSynced: this.hasSynced,
-      prioritStatuses: this.prioritStatuses
+      priorityStatuses: this.priorityStatuses
     };
   }
 

packages/web/tests/stream.test.ts

@@ -247,7 +247,7 @@ describe(
       });
       await another.init();
 
-      expect(another.currentStatus.prioritStatuses).toHaveLength(1);
+      expect(another.currentStatus.priorityStatuses).toHaveLength(1);
       expect(another.currentStatus.statusForPriority(0).hasSynced).toBeTruthy();
       await another.waitForFirstSync({priority: 0});
     });