From 4aa39018d8f2911b864429f326539f264a5ed65b Mon Sep 17 00:00:00 2001
From: Derrick Hammer <derrick@derrickhammer.com>
Date: Sat, 8 Apr 2023 21:04:52 -0400
Subject: [PATCH] *Moved protomux client to its own package

---
 package.json    |   2 +-
 src/protomux.ts | 263 ------------------------------------------------
 2 files changed, 1 insertion(+), 264 deletions(-)
 delete mode 100644 src/protomux.ts

diff --git a/package.json b/package.json
index 0af7318..ff05cff 100644
--- a/package.json
+++ b/package.json
@@ -10,6 +10,7 @@
     },
     "dependencies": {
         "@lumeweb/interface-relay": "git+https://git.lumeweb.com/LumeWeb/interface-relay.git",
+        "protomux": "git+https://git.lumeweb.com/LumeWeb/kernel-protomux-client.git",
         "@lumeweb/kernel-swarm-client": "git+https://git.lumeweb.com/LumeWeb/kernel-swarm-client.git",
         "@lumeweb/libkernel-universal": "git+https://git.lumeweb.com/LumeWeb/libkernel-universal.git",
         "@lumeweb/protomux-rpc-web": "git+https://git.lumeweb.com/LumeWeb/protomux-rpc-web.git",
@@ -32,7 +33,6 @@
     },
     "browser": {
         "timers": "timers-browserify",
-        "protomux": "./src/protomux.ts",
         "protomux-rpc": "@lumeweb/protomux-rpc-web"
     }
 }
diff --git a/src/protomux.ts b/src/protomux.ts
deleted file mode 100644
index 9cbdf6b..0000000
--- a/src/protomux.ts
+++ /dev/null
@@ -1,263 +0,0 @@
-import { Client, factory } from "@lumeweb/libkernel-universal";
-const MODULE = "_AXYJDzn2fjd-YfuchEegna7iErhun6QwQK7gSa3UNjHvw";
-
-import defer from "p-defer";
-import b4a from "b4a";
-
-class Protomux {
-  private isProtomux = true;
-
-  constructor(stream: any) {
-    this._stream = stream;
-    if (!stream.userData) {
-      stream.userData = this;
-    }
-  }
-
-  private _stream: any;
-
-  get stream(): any {
-    return this._stream;
-  }
-
-  static from(stream: any) {
-    if (stream.userData && stream.userData.isProtomux) return stream.userData;
-    if (stream.isProtomux) return stream;
-    return new this(stream);
-  }
-
-  public async createChannel({
-    protocol,
-    id = null,
-    handshake = null,
-    onopen = undefined,
-    onclose = undefined,
-    ondestroy = undefined,
-  }: {
-    protocol: string;
-    id: any;
-    handshake: any;
-    onopen?: Function;
-    onclose?: Function;
-    ondestroy?: Function;
-  }) {
-    return createChannel(
-      this,
-      protocol,
-      id,
-      handshake,
-      onopen,
-      onclose,
-      ondestroy
-    );
-  }
-}
-
-class Channel extends Client {
-  private protocol: string;
-  private id: any;
-  private handshake: any;
-  private onopen?: Function;
-  private onclose?: Function;
-  private ondestroy?: Function;
-  private _created = defer();
-  private _send?: (data?: any) => void;
-  private _queue: Message[] = [];
-  private _inited = false;
-
-  constructor(
-    mux: Protomux,
-    protocol: string,
-    id: any,
-    handshake: any,
-    onopen?: Function,
-    onclose?: Function,
-    ondestroy?: Function
-  ) {
-    super();
-    this._mux = mux;
-    this.protocol = protocol;
-    this.id = id;
-    this.handshake = handshake;
-    this.onopen = onopen;
-    this.onclose = onclose;
-    this.ondestroy = ondestroy;
-  }
-
-  private _ready = defer();
-
-  get ready(): Promise<void> {
-    return this._ready.promise as Promise<void>;
-  }
-
-  private _mux: Protomux;
-
-  get mux(): Protomux {
-    return this._mux;
-  }
-
-  private _channelId = -1;
-
-  get channelId(): number {
-    return this._channelId;
-  }
-
-  async open(): Promise<void> {
-    await this.init();
-    await this._created;
-
-    while (this._queue.length) {
-      await this._queue.shift()?.init();
-    }
-
-    this._ready.resolve();
-  }
-
-  public addMessage({
-    encoding = undefined,
-    onmessage,
-  }: {
-    encoding?: any;
-    onmessage: Function;
-  }) {
-    return createMessage({ channel: this, encoding, onmessage });
-  }
-
-  public async queueMessage(message: Message) {
-    this._queue.push(message);
-  }
-
-  private async init(): Promise<void> {
-    if (this._inited) {
-      return;
-    }
-
-    this._inited = true;
-
-    const [update, ret] = this.connectModule(
-      "createProtomuxChannel",
-      {
-        id: this._mux.stream.id,
-        data: {
-          protocol: this.protocol,
-          id: this.id,
-          handshake: this.handshake,
-          onopen: !!this.onopen,
-          onclose: !!this.onclose,
-          ondestroy: !!this.ondestroy,
-        },
-      },
-      (data: any) => {
-        switch (data.action) {
-          case "onopen":
-            this.onopen?.(...data.args);
-            break;
-          case "onclose":
-            this.onclose?.(...data.args);
-            break;
-          case "ondestroy":
-            this.ondestroy?.(...data.args);
-            break;
-          default:
-            this._channelId = data;
-            this._created.resolve();
-        }
-      }
-    );
-    this._send = update;
-
-    ret.catch((e) => this._created.reject(e));
-
-    return this._created.promise as Promise<void>;
-  }
-}
-
-class Message extends Client {
-  private encoding: any;
-  private onmessage: Function;
-  private channel: Channel;
-
-  private _send?: (data?: any) => void;
-
-  constructor({
-    channel,
-    encoding = undefined,
-    onmessage = () => {},
-  }: {
-    channel: Channel;
-    encoding?: any;
-    onmessage: Function;
-  }) {
-    super();
-    this.channel = channel;
-    this.encoding = encoding;
-    this.onmessage = onmessage;
-    this.channel.queueMessage(this);
-  }
-
-  async init(): Promise<void> {
-    const created = defer();
-
-    await this.loadLibs(MODULE);
-
-    const [update] = this.connectModule(
-      "createProtomuxMessage",
-      {
-        id: this.channel.mux.stream.id,
-        channelId: this.channel.channelId,
-        data: {
-          encoding: !!this.encoding,
-          onmessage: !!this.onmessage,
-        },
-      },
-      async (data: any) => {
-        if (data?.args && data?.args[0] instanceof Uint8Array) {
-          data.args[0] = b4a.from(data.args[0]);
-        }
-        switch (data.action) {
-          case "encode":
-            update({
-              action: "encode",
-              args: [await this.encoding.encode?.(...data.args), data.args[0]],
-            });
-            break;
-          case "decode":
-            update({
-              action: "decode",
-              args: [await this.encoding.decode?.(...data.args), data.args[0]],
-            });
-            break;
-          case "preencode":
-            update({
-              action: "preencode",
-              args: [
-                await this.encoding.preencode?.(...data.args),
-                data.args[0],
-              ],
-            });
-            break;
-          case "onmessage":
-            this.onmessage?.(...data.args);
-            break;
-          case "created":
-            created.resolve();
-            break;
-        }
-      }
-    );
-
-    this._send = update;
-
-    return created.promise as Promise<void>;
-  }
-
-  public send(data: any) {
-    this._send?.({ action: "send", args: [data] });
-  }
-}
-
-const createChannel = factory<Channel>(Channel, MODULE);
-const createMessage = factory<Message>(Message, MODULE);
-
-// @ts-ignore
-export = Protomux;