extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2025-02-23 05:31:10 +01:00
Code Issues Packages Projects Releases Wiki Activity

adjust sdk example: tcpTunnel must be private

Browse Source
This commit is contained in:
Curt Tudor 2024-03-25 12:37:49 -06:00
parent c4842a5a81
commit 831c6cb4b7
No known key found for this signature in database
GPG Key ID: B3CD225AF4EC8E96
1 changed files with 35 additions and 70 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

105
sdk/nodejs/examples/pastebin/src/index.ts
View File

@ -1,9 +1,7 @@
const { Command } = require("commander"); const { Command } = require("commander");
const zrok = require("zrok") const zrok = require("zrok")
const ziti = require('@openziti/ziti-sdk-nodejs') const ziti = require('@openziti/ziti-sdk-nodejs')
const express = require('express')
var readlineSync = require('readline-sync'); var readlineSync = require('readline-sync');
import fs from "node:fs"
const program = new Command(); const program = new Command();
@ -17,34 +15,26 @@ program
console.log("data is: ", data) console.log("data is: ", data)
let root = zrok.Load() let root = zrok.Load()
await zrok.init(root); await zrok.init( root ).catch(( err: Error ) => { console.error(err); return process.exit(1) });
//await ziti.init( root.env.ZitiIdentity ).catch(( err: Error ) => { console.error(err); return process.exit(1) }); zrok.setLogLevel(0)
ziti.setLogLevel(0)
console.log("setting up zrok.CreateShare...") console.log("setting up zrok.CreateShare...")
let shr = await zrok.CreateShare(root, new zrok.ShareRequest(zrok.TCP_TUNNEL_BACKEND_MODE, zrok.PUBLIC_SHARE_MODE, "pastebin", ["public"])); let shr = await zrok.CreateShare(root, new zrok.ShareRequest(zrok.TCP_TUNNEL_BACKEND_MODE, zrok.PRIVATE_SHARE_MODE, "pastebin", ["private"]));
// console.log("zrok share is: ",shr)
// console.log("setting up app")
// let service = "ns5ix2brb61f"
// console.log("attempting to bind to service: "+ shr.Token)
console.log("access your pastebin using 'pastefrom ", shr.Token) console.log("access your pastebin using 'pastefrom ", shr.Token)
let app = zrok.express( shr.Token );
// let listener = await zrok.NewListener(shr.Token, root)
// console.log("zrok listener is: ", listener)
let app = ziti.express( express, shr.Token );
// console.log("after setting up app")
app.get('/',function(_: Request,res: any){ app.get('/',function(_: Request,res: any){
// console.log("received a GET request")
res.write(data) res.write(data)
res.end() res.end()
}); });
// console.log("after setting up get")
app.listen(undefined, () => { app.listen(undefined, () => {
// console.log(`Example app listening!`)
}) })
// console.log("after listen")
// zrok.DeleteShare(root, shr); // Delete the private share upon CTRL-C
process.on('SIGINT', async () => {
console.log("Now deleting your private zrok share...")
await zrok.DeleteShare(root, shr)
process.exit(15);
});
}); });
program program
@ -53,64 +43,39 @@ program
.description("command to paste content from coptyo") .description("command to paste content from coptyo")
.action(async (shrToken: string) => { .action(async (shrToken: string) => {
// ziti.setLogLevel(99)
let root = zrok.Load(); let root = zrok.Load();
await zrok.init(root).catch((err: any) => { await zrok.init(root).catch((err: any) => {
console.log(err) console.log(err)
}); });
let acc = await zrok.CreateAccess(root, new zrok.AccessRequest(shrToken)) let acc = await zrok.CreateAccess(root, new zrok.AccessRequest(shrToken))
// console.log("zrok.CreateAccess returned: ", acc)
// console.log("about to ziti.httpRequest: ", shrToken) ziti.httpRequest(
shrToken,
undefined,
'GET',
'/',
[],
(data: any) => { // on_req_cb
console.log("in on_req_cb")
console.log("data is: ", data)
},
(data: any) => { // on_resp_cb
console.log("in on_resp_cb")
console.log("data is: ", data)
},
async (data: any) => { // on_resp_data_cb
console.log("in on_resp_data_cb")
console.log("data is: ", data)
if (data.body) {
console.log('----------- pastefrom is: ', data.body.toString());
// setTimeout(function() { await zrok.DeleteAccess(root, acc)
ziti.httpRequest(
shrToken,
undefined,
'GET',
'/',
[],
(data: any) => { // on_req_cb
console.log("in on_req_cb")
console.log("data is: ", data)
},
(data: any) => { // on_resp_cb
console.log("in on_resp_cb")
console.log("data is: ", data)
},
async (data: any) => { // on_resp_data_cb
console.log("in on_resp_data_cb")
console.log("data is: ", data)
if (data.body) {
console.log('----------- pastefrom is: ', data.body.toString());
await zrok.DeleteAccess(root, acc)
process.exit(0);
}
process.exit(0);
} }
);
// }, 5000); }
);
// zrok.dialer(
// root,
// shrToken,
// (conn: any) => {
// console.log("in connectCallback")
// console.log("conn is: ", conn)
// },
// (dataData: any) => {
// console.log("in dataCallback")
// console.log(dataData.toString())
// }
// );
}); });
program.parse(process.argv) program.parse(process.argv)