Compare commits

...

2 Commits

2 changed files with 17 additions and 1 deletions

View File

@ -45,6 +45,14 @@ const writeSocketEncoding = {
}, },
}; };
const errorSocketEncoding = { const errorSocketEncoding = {
preencode(state, m) {
socketEncoding.preencode(state, m);
compact_encoding_1.json.preencode(state, (0, serialize_error_1.serializeError)(m.err));
},
encode(state, m) {
socketEncoding.encode(state, m);
compact_encoding_1.json.encode(state, (0, serialize_error_1.serializeError)(m.err));
},
decode(state, m) { decode(state, m) {
const socket = socketEncoding.decode(state, m); const socket = socketEncoding.decode(state, m);
return { return {

View File

@ -1,7 +1,7 @@
import Proxy, { ProxyOptions } from "../proxy.js"; import Proxy, { ProxyOptions } from "../proxy.js";
import TcpSocket from "./multiSocket/tcpSocket.js"; import TcpSocket from "./multiSocket/tcpSocket.js";
import { json, raw, uint } from "compact-encoding"; import { json, raw, uint } from "compact-encoding";
import { deserializeError } from "serialize-error"; import { deserializeError, serializeError } from "serialize-error";
import b4a from "b4a"; import b4a from "b4a";
import type { TcpSocketConnectOpts } from "net"; import type { TcpSocketConnectOpts } from "net";
import { DataSocketOptions, PeerOptions } from "../peer.js"; import { DataSocketOptions, PeerOptions } from "../peer.js";
@ -62,6 +62,14 @@ const writeSocketEncoding = {
}; };
const errorSocketEncoding = { const errorSocketEncoding = {
preencode(state: any, m: ErrorSocketRequest) {
socketEncoding.preencode(state, m);
json.preencode(state, serializeError(m.err));
},
encode(state: any, m: ErrorSocketRequest) {
socketEncoding.encode(state, m);
json.encode(state, serializeError(m.err));
},
decode(state: any, m: any): ErrorSocketRequest { decode(state: any, m: any): ErrorSocketRequest {
const socket = socketEncoding.decode(state, m); const socket = socketEncoding.decode(state, m);
return { return {