Compare commits
No commits in common. "51eabd809d72b747de9af7e53f640885208a83dd" and "47a0fed27eb3444486290f8914dc00a90cf0e068" have entirely different histories.
51eabd809d
...
47a0fed27e
|
@ -1,7 +1,7 @@
|
|||
import { Client, factory } from "@lumeweb/libkernel-universal";
|
||||
import { MODULE } from "@lumeweb/kernel-swarm-client";
|
||||
import defer from "p-defer";
|
||||
import { Buffer } from "buffer";
|
||||
import b4a from "b4a";
|
||||
export default class Protomux {
|
||||
isProtomux = true;
|
||||
constructor(stream) {
|
||||
|
@ -137,13 +137,13 @@ class Message extends Client {
|
|||
if (data.args) {
|
||||
data.args = data.args.filter((arg) => {
|
||||
if (arg instanceof Uint8Array) {
|
||||
return Buffer.from(arg);
|
||||
return b4a.from(arg);
|
||||
}
|
||||
return arg;
|
||||
});
|
||||
}
|
||||
if (data?.args && data?.args[0]?.buffer instanceof Uint8Array) {
|
||||
data.args[0].buffer = Buffer.from(data.args[0].buffer);
|
||||
data.args[0].buffer = b4a.from(data.args[0].buffer);
|
||||
}
|
||||
switch (data.action) {
|
||||
case "encode":
|
||||
|
|
|
@ -6,7 +6,6 @@
|
|||
"@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",
|
||||
"b4a": "^1.6.3",
|
||||
"buffer": "^6.0.3",
|
||||
"p-defer": "^4.0.0"
|
||||
},
|
||||
"devDependencies": {
|
||||
|
|
|
@ -4,7 +4,6 @@ import { MODULE } from "@lumeweb/kernel-swarm-client";
|
|||
|
||||
import defer from "p-defer";
|
||||
import b4a from "b4a";
|
||||
import { Buffer } from "buffer";
|
||||
|
||||
export default class Protomux {
|
||||
private isProtomux = true;
|
||||
|
@ -220,7 +219,7 @@ class Message extends Client {
|
|||
if (data.args) {
|
||||
data.args = data.args.filter((arg: any) => {
|
||||
if (arg instanceof Uint8Array) {
|
||||
return Buffer.from(arg);
|
||||
return b4a.from(arg);
|
||||
}
|
||||
|
||||
return arg;
|
||||
|
@ -228,7 +227,7 @@ class Message extends Client {
|
|||
}
|
||||
|
||||
if (data?.args && data?.args[0]?.buffer instanceof Uint8Array) {
|
||||
data.args[0].buffer = Buffer.from(data.args[0].buffer);
|
||||
data.args[0].buffer = b4a.from(data.args[0].buffer);
|
||||
}
|
||||
switch (data.action) {
|
||||
case "encode":
|
||||
|
|
Loading…
Reference in New Issue