Files
hp-devkit/docker/code-templates/nodejs/npl-client/_projname_.js
2024-03-15 17:16:24 +05:30

78 lines
2.2 KiB
JavaScript

const readline = require('readline');
const HotPocket = require('hotpocket-js-client');
async function clientApp() {
const userKeyPair = await HotPocket.generateKeys();
const client = await HotPocket.createClient(['wss://localhost:8081'], userKeyPair);
// Establish HotPocket connection.
if (!await client.connect()) {
console.log('Connection failed.');
return;
}
console.log('HotPocket Connected.');
// start listening for stdin
const rl = readline.createInterface({
input: process.stdin,
output: process.stdout
});
// On ctrl + c we should close HP connection gracefully.
rl.on('SIGINT', () => {
console.log('SIGINT received...');
rl.close();
client.close();
});
// This will get fired if HP server disconnects unexpectedly.
client.on(HotPocket.events.disconnect, () => {
console.log('Disconnected');
rl.close();
});
// This will get fired when contract sends an output.
client.on(HotPocket.events.contractOutput, (r) => {
r.outputs.forEach(output => {
if (output.type == "rndResult") {
if (output.status == "ok")
console.log(`(ledger:${r.ledgerSeqNo})>> ${JSON.stringify(output)}`);
else
console.log(`(ledger:${r.ledgerSeqNo})>> Rnd failed. reason: ${output.error}`);
}
else {
console.log("Unknown contract output.");
}
});
});
console.log("Ready to accept inputs.");
const input_pump = () => {
rl.question('', async (inp) => {
let input;
if (inp.startsWith("rnd")) {
input = await client.submitContractInput(JSON.stringify({
type: "rnd"
}));
}
else {
console.log("Invalid command. [rnd] expected.")
}
if (input) {
const submission = await input.submissionStatus;
if (submission.status != "accepted")
console.log("Submission failed. reason: " + submission.reason);
}
input_pump();
})
}
input_pump();
}
clientApp();