mirror of
https://github.com/openziti/zrok.git
synced 2025-04-02 02:26:08 +02:00
working copyto (#893)
This commit is contained in:
parent
16dc9feb3c
commit
56b8d1e92c
@ -6,7 +6,7 @@ import {
|
|||||||
init,
|
init,
|
||||||
listener,
|
listener,
|
||||||
loadRoot,
|
loadRoot,
|
||||||
PRIVATE_SHARE_MODE, setLogLevel,
|
PRIVATE_SHARE_MODE,
|
||||||
ShareRequest,
|
ShareRequest,
|
||||||
TCP_TUNNEL_BACKEND_MODE,
|
TCP_TUNNEL_BACKEND_MODE,
|
||||||
write
|
write
|
||||||
@ -24,14 +24,14 @@ const copyto = async () => {
|
|||||||
return process.exit(1);
|
return process.exit(1);
|
||||||
});
|
});
|
||||||
let shr = await createShare(root, new ShareRequest(PRIVATE_SHARE_MODE, TCP_TUNNEL_BACKEND_MODE, "copyto"));
|
let shr = await createShare(root, new ShareRequest(PRIVATE_SHARE_MODE, TCP_TUNNEL_BACKEND_MODE, "copyto"));
|
||||||
console.log("connect with 'copyto " + shr.shareToken + "'");
|
|
||||||
listener(shr, {clientConnectCallback: (data: any) => {
|
console.log("connect with 'pastefrom " + shr.shareToken + "'");
|
||||||
console.log("data", data);
|
|
||||||
write(data.client, text) ;
|
listener(shr, (data: any) => {
|
||||||
}});
|
write(data.client, new TextEncoder().encode(text + "\n"));
|
||||||
|
});
|
||||||
|
|
||||||
process.on("SIGINT", async () => {
|
process.on("SIGINT", async () => {
|
||||||
console.log("cleaning up");
|
|
||||||
deleteShare(root, shr);
|
deleteShare(root, shr);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
@ -12,17 +12,10 @@ export const setLogLevel = (level: number) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export const listener = (shr: Share,
|
export const listener = (shr: Share,
|
||||||
callbacks?: {
|
clientConnectCallback: any,
|
||||||
listenCallback?: any,
|
clientDataCallback: any = (data: any) => {},
|
||||||
listenClientCallback?: any,
|
listenCallback: any = (data: any) => {},
|
||||||
clientConnectCallback: any,
|
listenClientCallback: any = (data: any) => {}): ziti.listener => {
|
||||||
clientDataCallback?: any
|
|
||||||
}): ziti.listener => {
|
|
||||||
let listenCallback = callbacks?.listenCallback ? callbacks.listenClientCallback : (data: any) => {};
|
|
||||||
let listenClientCallback = callbacks?.listenClientCallback ? callbacks.listenClientCallback : (data: any) => {};
|
|
||||||
let clientConnectCallback = callbacks?.clientConnectCallback ? callbacks.clientConnectCallback : (data: any) => {};
|
|
||||||
let clientDataCallback = callbacks?.clientDataCallback ? callbacks.clientDataCallback : (data: any) => {};
|
|
||||||
console.log("client connect callback", clientConnectCallback);
|
|
||||||
ziti.listen(shr.shareToken, 0, listenCallback, listenClientCallback, clientConnectCallback, clientDataCallback);
|
ziti.listen(shr.shareToken, 0, listenCallback, listenClientCallback, clientConnectCallback, clientDataCallback);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user