Compare commits

..

No commits in common. "da4bda03ee6860147b176199f3ab41965a17fff3" and "1bb963caa556f105f043cf12f1d9d088c9633b1d" have entirely different histories.

5 changed files with 16 additions and 39 deletions

2
dist/index.d.ts vendored
View File

@ -1,7 +1,5 @@
/// <reference types="node" />
import ProtomuxRPC from "protomux-rpc"; import ProtomuxRPC from "protomux-rpc";
export default class RPC extends ProtomuxRPC { export default class RPC extends ProtomuxRPC {
constructor(stream: any, options?: {}); constructor(stream: any, options?: {});
request(method: any, value?: Buffer | Uint8Array | string, options?: {}): Promise<any>;
} }
//# sourceMappingURL=index.d.ts.map //# sourceMappingURL=index.d.ts.map

2
dist/index.d.ts.map vendored
View File

@ -1 +1 @@
{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";AACA,OAAO,WAAW,MAAM,cAAc,CAAC;AAOvC,MAAM,CAAC,OAAO,OAAO,GAAI,SAAQ,WAAW;gBAC9B,MAAM,EAAE,GAAG,EAAE,OAAO,KAAK;IAW/B,OAAO,CACX,MAAM,EAAE,GAAG,EACX,KAAK,GAAE,MAAM,GAAG,UAAU,GAAG,MAAqB,EAClD,OAAO,KAAK;CAQf"} {"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AACA,OAAO,WAAW,MAAM,cAAc,CAAA;AAOtC,MAAM,CAAC,OAAO,OAAO,GAAI,SAAQ,WAAW;gBAC5B,MAAM,EAAE,GAAG,EAAE,OAAO,KAAK;CASxC"}

11
dist/index.js vendored
View File

@ -9,16 +9,9 @@ export default class RPC extends ProtomuxRPC {
options = { options = {
...{ ...{
id: ID, id: ID,
valueEncoding: c.json, valueEncoding: c.json
}, }, ...options
...options,
}; };
super(stream, options); super(stream, options);
} }
async request(method, value = b4a.from(""), options = {}) {
if (!b4a.isBuffer(value)) {
value = b4a.from(value);
}
return super.request(method, value, options);
}
} }

View File

@ -8,7 +8,6 @@
"protomux-rpc": "^1.3.0" "protomux-rpc": "^1.3.0"
}, },
"devDependencies": { "devDependencies": {
"@types/b4a": "^1.6.0", "@types/b4a": "^1.6.0"
"prettier": "^2.8.0"
} }
} }

View File

@ -1,32 +1,19 @@
// @ts-ignore // @ts-ignore
import ProtomuxRPC from "protomux-rpc"; import ProtomuxRPC from "protomux-rpc"
// @ts-ignore // @ts-ignore
import c from "compact-encoding"; import c from "compact-encoding"
import b4a from "b4a"; import b4a from "b4a"
const ID = b4a.from("lumeweb"); const ID = b4a.from("lumeweb")
export default class RPC extends ProtomuxRPC { export default class RPC extends ProtomuxRPC {
constructor(stream: any, options = {}) { constructor(stream: any, options = {}) {
options = { options = {
...{ ...{
id: ID, id: ID,
valueEncoding: c.json, valueEncoding: c.json
}, }, ...options
...options,
}; };
super(stream, options); super(stream, options);
} }
async request(
method: any,
value: Buffer | Uint8Array | string = b4a.from(""),
options = {}
) {
if (!b4a.isBuffer(value)) {
value = b4a.from(value);
}
return super.request(method, value, options);
}
} }