[connector] Connect/disconnect

Author: jamesgpearce

src/@types/index.d.ts

@@ -68,8 +68,8 @@ export function createSynclet(
 export interface Connector {
   __brand: 'Connector';
   log(message: string, level?: LogLevel): void;
-  start(): Promise<void>;
-  stop(): Promise<void>;
+  connect(): Promise<void>;
+  disconnect(): Promise<void>;
   setAtom: (
     address: Address,
     atom: Atom,

src/core/connector.ts

@@ -40,7 +40,7 @@ export const createConnector: typeof createConnectorDecl = async (
   }: ConnectorImplementations,
   options: ConnectorOptions = {},
 ): Promise<ProtectedConnector> => {
-  let started = false;
+  let connected = false;
   let attachedSynclet: Synclet | undefined;
 
   const id = options.id ?? getUniqueId();
@@ -60,19 +60,19 @@ export const createConnector: typeof createConnectorDecl = async (
 
     log,
 
-    start: async () => {
-      if (!started) {
-        log('start');
+    connect: async () => {
+      if (!connected) {
+        log('connect');
         await connect?.();
-        started = true;
+        connected = true;
       }
     },
 
-    stop: async () => {
-      if (started) {
-        log('stop');
+    disconnect: async () => {
+      if (connected) {
+        log('disconnect');
         await disconnect?.();
-        started = false;
+        connected = false;
       }
     },
 
@@ -143,8 +143,6 @@ export const createConnector: typeof createConnectorDecl = async (
       attachedSynclet = synclet;
     },
 
-    connect,
-    disconnect,
     readAtom,
     readTimestamp,
     readHash,

src/core/protected.d.ts

@@ -22,8 +22,6 @@ export type Message = [
 export type ReceiveMessage = (message: Message, from: string) => Promise<void>;
 
 export interface ProtectedConnector extends Connector {
-  connect?: () => Promise<void>;
-  disconnect?: () => Promise<void>;
   attachToSynclet(synclet: Synclet): void;
   readAtom(address: Address, context: Context): Promise<Atom | undefined>;
   readTimestamp(

src/core/synclet.ts

@@ -294,7 +294,7 @@ export const createSynclet: typeof createSyncletDecl = (async (
     start: async () => {
       if (!started) {
         log('start');
-        await connector.start();
+        await connector.connect();
         await transport.connect?.(receiveMessage);
         started = true;
         await sync([]);