Handle typo in powersync_url env variable

Author: HeinrichvonStein

.changeset/fuzzy-bears-nail.md

@@ -0,0 +1,6 @@
+---
+'@powersync/common': patch
+'@powersync/web': patch
+---
+
+Handle additional forward slash in the POWERSYNC_URL environment variable

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

@@ -14,6 +14,7 @@ import { version as POWERSYNC_JS_VERSION } from '../../../../package.json';
 
 export type BSONImplementation = typeof BSON;
 
+const POWERSYNC_TRAILING_SLASH_MATCH =/\/+$/;
 export type RemoteConnector = {
   fetchCredentials: () => Promise<PowerSyncCredentials | null>;
 };
@@ -117,18 +118,23 @@ export abstract class AbstractRemote {
 
   protected async buildRequest(path: string) {
     const credentials = await this.getCredentials();
+    let endPoint = credentials?.endpoint;
     if (credentials != null && (credentials.endpoint == null || credentials.endpoint == '')) {
       throw new Error('PowerSync endpoint not configured');
     } else if (credentials?.token == null || credentials?.token == '') {
       const error: any = new Error(`Not signed in`);
       error.status = 401;
       throw error;
+    } else if (credentials?.endpoint.match(POWERSYNC_TRAILING_SLASH_MATCH)) {
+      this.logger.warn('A trailing forward slash "/" was entered after the POWERSYNC_URL environment variable. ' +
+        'Remove the trailing "/" from the variable to get rid of this warning.');
+      endPoint = credentials?.endpoint.replace(POWERSYNC_TRAILING_SLASH_MATCH, "");
     }
 
     const userAgent = this.getUserAgent();
 
     return {
-      url: credentials.endpoint + path,
+      url: endPoint + path,
       headers: {
         'content-type': 'application/json',
         Authorization: `Token ${credentials.token}`,

packages/web/src/db/sync/SharedWebStreamingSyncImplementation.ts

@@ -13,6 +13,8 @@ import {
 } from './WebStreamingSyncImplementation';
 import { resolveWebSQLFlags } from '../adapters/web-sql-flags';
 
+const POWERSYNC_TRAILING_SLASH_MATCH =/\/+$/;
+
 /**
  * The shared worker will trigger methods on this side of the message port
  * via this client provider.
@@ -27,8 +29,13 @@ class SharedSyncClientProvider extends AbstractSharedSyncClientProvider {
 
   async fetchCredentials(): Promise<PowerSyncCredentials | null> {
     const credentials = await this.options.remote.getCredentials();
+    let endPoint = credentials?.endpoint;
     if (credentials == null) {
       return null;
+    } else if (credentials?.endpoint.match(POWERSYNC_TRAILING_SLASH_MATCH)) {
+      this.logger?.warn('A trailing forward slash "/" was entered after the POWERSYNC_URL environment variable. ' +
+        'Remove the trailing "/" from the variable to get rid of this warning.');
+      endPoint = credentials.endpoint.replace(POWERSYNC_TRAILING_SLASH_MATCH, "");
     }
     /**
      * The credentials need to be serializable.
@@ -37,7 +44,7 @@ class SharedSyncClientProvider extends AbstractSharedSyncClientProvider {
      * This returns only the essential fields.
      */
     return {
-      endpoint: credentials.endpoint,
+      endpoint: endPoint || '',
       token: credentials.token,
       expiresAt: credentials.expiresAt
     };