feat: expose connection options and connector in AbstractPowerSyncDatabase

Author: khawarizmus

packages/common/src/client/AbstractPowerSyncDatabase.ts

@@ -181,7 +181,6 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
    * Current connection status.
    */
   currentStatus: SyncStatus;
-  connectionOptions: PowerSyncConnectionOptions;
 
   sdkVersion: string;
 
@@ -194,6 +193,14 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
     return this.connectionManager.syncStreamImplementation;
   }
 
+  get connector() {
+    return this.connectionManager.connector;
+  }
+
+  get connectionOptions() {
+    return this.connectionManager.connectionOptions;
+  }
+
   protected _schema: Schema;
 
   private _database: DBAdapter;
@@ -515,7 +522,6 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
    */
   async connect(connector: PowerSyncBackendConnector, options?: PowerSyncConnectionOptions) {
     const resolvedOptions: InternalConnectionOptions = options ?? {};
-    this.connectionOptions = resolvedOptions;
     resolvedOptions.serializedSchema = this.schema.toJSON();
 
     return this.connectionManager.connect(connector, resolvedOptions);
@@ -594,15 +600,6 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
     await this.iterateAsyncListeners(async (cb) => cb.closed?.());
   }
 
-  /**
-   * Get the connection options used to connect to the PowerSync backend instance.
-   *
-   * @returns The connection options used to connect to the PowerSync backend instance.
-   */
-  getConnectionOptions(): PowerSyncConnectionOptions | null {
-    return this.connectionOptions ?? null;
-  }
-
   /**
    * Get upload queue size estimate and count.
    */

packages/common/src/client/ConnectionManager.ts

@@ -118,6 +118,14 @@ export class ConnectionManager extends BaseObserver<ConnectionManagerListener> {
     this.syncDisposer = null;
   }
 
+  get connector() {
+    return this.pendingConnectionOptions?.connector ?? null;
+  }
+
+  get connectionOptions() {
+    return this.pendingConnectionOptions?.options ?? null;
+  }
+
   get logger() {
     return this.options.logger;
   }