Add basic tests

Author: stevensJourney

packages/lite-sdk/src/client/sync/SyncClient.ts

@@ -1,3 +1,4 @@
+import type { BucketRequest, StreamingSyncLine } from '@powersync/service-core';
 import { BaseListener, BaseObserverInterface, Disposable } from '../../utils/BaseObserver.js';
 import type { BucketStorage } from '../storage/BucketStorage.js';
 import type { SystemDependencies } from '../system/SystemDependencies.js';
@@ -79,6 +80,20 @@ export interface SyncClient extends BaseObserverInterface<SyncClientListener>, D
   disconnect: () => void;
 }
 
+export type StreamOptions = {
+  endpoint: string;
+  token: string;
+  clientId: string | undefined;
+  signal: AbortSignal | undefined;
+  bucketPositions: BucketRequest[];
+  systemDependencies: SystemDependencies;
+};
+
+/**
+ * Function type for opening a sync stream. Can be overridden in tests.
+ */
+export type StreamOpener = (options: StreamOptions) => Promise<ReadableStream<StreamingSyncLine>>;
+
 /**
  * Configuration options for creating a SyncClient instance.
  */
@@ -93,4 +108,6 @@ export type SyncClientOptions = {
   storage: BucketStorage;
   /** System-level dependencies (HTTP client, timers, etc.) required for sync operations. */
   systemDependencies: SystemDependencies;
+  /** Optional function to open a sync stream. Defaults to openHttpStream. Used for testing. */
+  streamOpener?: StreamOpener;
 };

packages/lite-sdk/src/client/sync/SyncClientImpl.ts

@@ -4,6 +4,7 @@ import type { BucketStorage } from '../storage/BucketStorage.js';
 import type {
   Connector,
   PowerSyncCredentials,
+  StreamOpener,
   SyncClient,
   SyncClientListener,
   SyncClientOptions,
@@ -34,6 +35,7 @@ export class SyncClientImpl extends BaseObserver<SyncClientListener> implements
 
   protected cachedCredentials: PowerSyncCredentials | null;
   protected abortController: AbortController;
+  protected openStreamFn: StreamOpener;
 
   constructor(protected options: SyncClientOptions) {
     super();
@@ -47,6 +49,7 @@ export class SyncClientImpl extends BaseObserver<SyncClientListener> implements
       downloading: false,
       downloadError: null
     };
+    this.openStreamFn = options.streamOpener ?? openHttpStream;
   }
 
   protected get bucketStorage(): BucketStorage {
@@ -129,7 +132,7 @@ export class SyncClientImpl extends BaseObserver<SyncClientListener> implements
 
     const [bucketRequests, initBucketMap] = await this.collectLocalBucketState();
 
-    const stream = await openHttpStream({
+    const stream = await this.openStreamFn({
       endpoint: credentials.endpoint,
       token: credentials.token,
       signal: signal,

packages/lite-sdk/src/client/sync/open-stream.ts

@@ -1,5 +1,5 @@
 import type { StreamingSyncLine, StreamingSyncRequest } from '@powersync/service-core';
-import type { SystemDependencies } from '../system/SystemDependencies.js';
+import type { StreamOptions } from './SyncClient.js';
 import { ndjsonStream } from './ndjson.js';
 
 export class AuthorizationError extends Error {
@@ -24,17 +24,8 @@ export interface BucketRequest {
   after: string;
 }
 
-export type SyncOptions = {
-  endpoint: string;
-  token: string;
-  clientId: string | undefined;
-  signal: AbortSignal | undefined;
-  bucketPositions: BucketRequest[];
-  systemDependencies: SystemDependencies;
-};
-
 // TODO This currently uses NDJSON streaming. We should add binary streaming also
-export async function openHttpStream(options: SyncOptions): Promise<ReadableStream<StreamingSyncLine>> {
+export async function openHttpStream(options: StreamOptions): Promise<ReadableStream<StreamingSyncLine>> {
   const streamRequest: StreamingSyncRequest = {
     raw_data: true,
     client_id: options.clientId,

packages/lite-sdk/tests/powersync-lite.test.ts

@@ -7,7 +7,7 @@ import { DEFAULT_SYSTEM_DEPENDENCIES } from '../src/client/system/SystemDependen
 
 describe(`PowerSync Lite`, { timeout: Infinity }, () => {
   describe(`Connection`, () => {
-    it(`should connect to a PowerSync server`, async () => {
+    it.skip(`should connect to a PowerSync server`, async () => {
       const connector = {
         fetchCredentials: async () => {
           const tokenResponse = await fetch(`http://localhost:6060/api/auth/token`, {