Compare commits
2 Commits
3a41474b26
...
3a1ea39a79
Author | SHA1 | Date |
---|---|---|
Derrick Hammer | 3a1ea39a79 | |
Derrick Hammer | e19e4c1744 |
|
@ -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 {
|
||||||
|
|
|
@ -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 {
|
||||||
|
|
Loading…
Reference in New Issue