From f96dac6d88388ec4e0feefe144ff1826d43b26a4 Mon Sep 17 00:00:00 2001
From: Steven Ontong <steven@journeyapps.com>
Date: Wed, 22 Nov 2023 13:43:04 -0700
Subject: [PATCH] type improvements

---
 .../src/client/AbstractPowerSyncOpenFactory.ts               | 2 +-
 .../sync/stream/AbstractStreamingSyncImplementation.ts       | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/packages/powersync-sdk-common/src/client/AbstractPowerSyncOpenFactory.ts b/packages/powersync-sdk-common/src/client/AbstractPowerSyncOpenFactory.ts
index 996f4c4c..a94a09ce 100644
--- a/packages/powersync-sdk-common/src/client/AbstractPowerSyncOpenFactory.ts
+++ b/packages/powersync-sdk-common/src/client/AbstractPowerSyncOpenFactory.ts
@@ -1,4 +1,4 @@
-import { DBAdapter } from 'src/db/DBAdapter';
+import { DBAdapter } from '../db/DBAdapter';
 import { Schema } from '../db/schema/Schema';
 import { AbstractPowerSyncDatabase, PowerSyncDatabaseOptions } from './AbstractPowerSyncDatabase';
 
diff --git a/packages/powersync-sdk-common/src/client/sync/stream/AbstractStreamingSyncImplementation.ts b/packages/powersync-sdk-common/src/client/sync/stream/AbstractStreamingSyncImplementation.ts
index 49623659..4bc49221 100644
--- a/packages/powersync-sdk-common/src/client/sync/stream/AbstractStreamingSyncImplementation.ts
+++ b/packages/powersync-sdk-common/src/client/sync/stream/AbstractStreamingSyncImplementation.ts
@@ -49,7 +49,7 @@ export const DEFAULT_STREAMING_SYNC_OPTIONS = {
 };
 
 export abstract class AbstractStreamingSyncImplementation extends BaseObserver<StreamingSyncImplementationListener> {
-  protected _lastSyncedAt: Date;
+  protected _lastSyncedAt: Date | null;
   protected options: AbstractStreamingSyncImplementationOptions;
 
   private isUploadingCrud: boolean;
@@ -61,6 +61,7 @@ export abstract class AbstractStreamingSyncImplementation extends BaseObserver<S
     this.options = { ...DEFAULT_STREAMING_SYNC_OPTIONS, ...options };
     this.isUploadingCrud = false;
     this._isConnected = false;
+    this._lastSyncedAt = null;
   }
 
   get lastSyncedAt() {
@@ -305,7 +306,7 @@ export abstract class AbstractStreamingSyncImplementation extends BaseObserver<S
     }
   }
 
-  private updateSyncStatus(connected: boolean, lastSyncedAt?: Date) {
+  protected updateSyncStatus(connected: boolean, lastSyncedAt?: Date) {
     const takeSnapShot = () => [this._isConnected, this._lastSyncedAt?.valueOf()];
 
     const previousValues = takeSnapShot();