-
Notifications
You must be signed in to change notification settings - Fork 0
/
sendqueries.ts
executable file
·39 lines (30 loc) · 1.12 KB
/
sendqueries.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
let path = require("path");
require('app-module-path').addPath(__dirname);
require('app-module-path').addPath(path.resolve(__dirname, "../generated"));
import * as messages from "rc/messages";
import { WebsocketService, IWebsocket } from "./socketservice";
import * as WebSocket from "ws";
const url = "ws://localhost:8081";
let ws = new WebSocket(url);
console.log(`Connecting to ${url}`)
ws.on('open', () => {
console.log(`Opened connection to ${url}`)
let sh = new WebsocketService(ws, { verbose: true });
let message1 = messages.GetUserByLogin.create({
login: "foobie"
});
let m2 = messages.GetLoginByName.create({
first: "Jack",
});
sh.observe(message1).subscribe((val: any) => console.log(val));
sh.observe(m2).subscribe((val: any) => console.log(val));
sh.query(m2).then(v => console.log(`got promise`, v));
sh.query(message1).then(v => console.log(`got promise`, v));
sh.execute(messages.AddUser.create({
binds: [messages.AddUserBinds.create({
login: "New Login",
passhash: "Sucker",
email: "yep@nope.com"
})]
}));
})