[partykit] Fixed protocol handling

Author: jamesgpearce

src/persisters/persister-partykit-client.ts

@@ -15,17 +15,17 @@ import {jsonString} from '../common/json';
 type MessageListener = (event: MessageEvent) => void;
 
 const MESSAGE = 'message';
-const HTTPS = 'https:';
 
 export const createPartyKitPersister = ((
   store: Store,
   connection: PartySocket,
+  storeUrlProtocol: 'http' | 'https' = 'https',
   onIgnoredError?: (error: any) => void,
 ): Persister => {
   const {host, room} = connection.partySocketOptions;
   const storeUrl =
-    (location.protocol == HTTPS ? HTTPS : 'http:') +
-    '//' +
+    storeUrlProtocol +
+    '://' +
     host +
     '/parties/' +
     ((connection as any).name ?? 'main') +

src/types/docs/persisters/persister-partykit-client.js

@@ -47,6 +47,9 @@
  * @param store The Store to persist.
  * @param connection The PartySocket to use for participating in the PartyKit
  * room.
+ * @param storeUrlProtocol The HTTP protocol to use (in addition to the
+ * websocket channel). This defaults to 'https' but you may wish to use 'http'
+ * for local PartyKit development.
  * @param onIgnoredError An optional handler for the errors that the Persister
  * would otherwise ignore when trying to save or load data. This is suitable for
  * debugging persistence issues in a development environment.

src/types/persisters/persister-partykit-client.d.ts

@@ -8,5 +8,6 @@ import {Store} from '../store';
 export function createPartyKitPersister(
   store: Store,
   connection: PartySocket,
+  storeUrlProtocol?: 'http' | 'https',
   onIgnoredError?: (error: any) => void,
 ): Persister;

src/types/with-schemas/persisters/persister-partykit-client.d.ts

@@ -8,5 +8,6 @@ import {Persister} from '../persisters';
 export function createPartyKitPersister<Schemas extends OptionalSchemas>(
   store: Store<Schemas>,
   connection: PartySocket,
+  storeUrlProtocol?: 'http' | 'https',
   onIgnoredError?: (error: any) => void,
 ): Persister<Schemas>;