LumeWeb
/
kernel-protomux-client
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: LumeWeb:47a0fed27eb3444486290f8914dc00a90cf0e068
Branches Tags
LumeWeb:master
LumeWeb:develop
LumeWeb:v0.0.2-develop.23
LumeWeb:v0.0.2-develop.22
LumeWeb:v0.0.2-develop.21
LumeWeb:v0.0.2-develop.20
LumeWeb:v0.0.2-develop.19
LumeWeb:v0.0.2-develop.18
LumeWeb:v0.0.2-develop.17
LumeWeb:v0.0.2-develop.16
LumeWeb:v0.0.2-develop.15
LumeWeb:v0.0.2-develop.14
LumeWeb:v0.0.2-develop.13
LumeWeb:v0.0.2-develop.12
LumeWeb:v0.0.2-develop.11
LumeWeb:v0.0.2-develop.10
LumeWeb:v0.0.2-develop.9
LumeWeb:v0.0.2-develop.8
LumeWeb:v0.0.2-develop.7
LumeWeb:v0.0.2-develop.6
LumeWeb:v0.0.2-develop.5
LumeWeb:v0.0.2-develop.4
LumeWeb:v0.0.2-develop.3
LumeWeb:v0.0.2-develop.2
LumeWeb:v0.0.2-develop.1
LumeWeb:v0.0.1
...
compare: LumeWeb:51eabd809d72b747de9af7e53f640885208a83dd
Branches Tags
LumeWeb:develop
LumeWeb:master
LumeWeb:v0.0.2-develop.23
LumeWeb:v0.0.2-develop.22
LumeWeb:v0.0.2-develop.21
LumeWeb:v0.0.2-develop.20
LumeWeb:v0.0.2-develop.19
LumeWeb:v0.0.2-develop.18
LumeWeb:v0.0.2-develop.17
LumeWeb:v0.0.2-develop.16
LumeWeb:v0.0.2-develop.15
LumeWeb:v0.0.2-develop.14
LumeWeb:v0.0.2-develop.13
LumeWeb:v0.0.2-develop.12
LumeWeb:v0.0.2-develop.11
LumeWeb:v0.0.2-develop.10
LumeWeb:v0.0.2-develop.9
LumeWeb:v0.0.2-develop.8
LumeWeb:v0.0.2-develop.7
LumeWeb:v0.0.2-develop.6
LumeWeb:v0.0.2-develop.5
LumeWeb:v0.0.2-develop.4
LumeWeb:v0.0.2-develop.3
LumeWeb:v0.0.2-develop.2
LumeWeb:v0.0.2-develop.1
LumeWeb:v0.0.1

2 Commits
47a0fed27e ... 51eabd809d

Author SHA1 Message Date
Derrick Hammer 51eabd809d
*Update dist 2023-04-09 00:35:45 -04:00
Derrick Hammer fbaf4314f3
* Refactor index.ts and package.json to use the Buffer module instead of b4a module for buffer operations. 2023-04-09 00:35:28 -04:00
3 changed files with 9 additions and 7 deletions
Show Stats Expand all files Collapse all files

6
dist/index.js vendored
View File

@ -1,7 +1,7 @@
import { Client, factory } from "@lumeweb/libkernel-universal"; import { Client, factory } from "@lumeweb/libkernel-universal";
import { MODULE } from "@lumeweb/kernel-swarm-client"; import { MODULE } from "@lumeweb/kernel-swarm-client";
import defer from "p-defer"; import defer from "p-defer";
import b4a from "b4a"; import { Buffer } from "buffer";
export default class Protomux { export default class Protomux {
isProtomux = true; isProtomux = true;
constructor(stream) { constructor(stream) {
@ -137,13 +137,13 @@ class Message extends Client {
if (data.args) { if (data.args) {
data.args = data.args.filter((arg) => { data.args = data.args.filter((arg) => {
if (arg instanceof Uint8Array) { if (arg instanceof Uint8Array) {
return b4a.from(arg); return Buffer.from(arg);
} }
return arg; return arg;
}); });
} }
if (data?.args && data?.args[0]?.buffer instanceof Uint8Array) { if (data?.args && data?.args[0]?.buffer instanceof Uint8Array) {
data.args[0].buffer = b4a.from(data.args[0].buffer); data.args[0].buffer = Buffer.from(data.args[0].buffer);
} }
switch (data.action) { switch (data.action) {
case "encode": case "encode":

1
package.json
View File

@ -6,6 +6,7 @@
"@lumeweb/kernel-swarm-client": "git+https://git.lumeweb.com/LumeWeb/kernel-swarm-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/libkernel-universal": "git+https://git.lumeweb.com/LumeWeb/libkernel-universal.git",
"b4a": "^1.6.3", "b4a": "^1.6.3",
"buffer": "^6.0.3",
"p-defer": "^4.0.0" "p-defer": "^4.0.0"
}, },
"devDependencies": { "devDependencies": {

5
src/index.ts
View File

@ -4,6 +4,7 @@ import { MODULE } from "@lumeweb/kernel-swarm-client";
import defer from "p-defer"; import defer from "p-defer";
import b4a from "b4a"; import b4a from "b4a";
import { Buffer } from "buffer";
export default class Protomux { export default class Protomux {
private isProtomux = true; private isProtomux = true;
@ -219,7 +220,7 @@ class Message extends Client {
if (data.args) { if (data.args) {
data.args = data.args.filter((arg: any) => { data.args = data.args.filter((arg: any) => {
if (arg instanceof Uint8Array) { if (arg instanceof Uint8Array) {
return b4a.from(arg); return Buffer.from(arg);
} }
return arg; return arg;
@ -227,7 +228,7 @@ class Message extends Client {
} }
if (data?.args && data?.args[0]?.buffer instanceof Uint8Array) { if (data?.args && data?.args[0]?.buffer instanceof Uint8Array) {
data.args[0].buffer = b4a.from(data.args[0].buffer); data.args[0].buffer = Buffer.from(data.args[0].buffer);
} }
switch (data.action) { switch (data.action) {
case "encode": case "encode":