nwaku/examples/nodejs/waku.js

79 lines
2.3 KiB
JavaScript

var express = require('express');
var app = express();
function create_random_string(length) {
let result = '';
const characters = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789';
const charactersLength = characters.length;
let counter = 0;
while (counter < length) {
result += characters.charAt(Math.floor(Math.random() * charactersLength));
counter += 1;
}
return result;
}
var wakuMod = require('bindings')('waku');
var cfg = `{
"host": "0.0.0.0",
"port": 60001,
"key": "364d111d729a6eb6d3e6113e163f017b5ef03a6f94c9b5b7bb1bb36fa5cb07a9",
"relay": true
"logLevel": "DEBUG"
}`
function event_handler(event) {
console.log("evento NodeJs: " + event)
}
wakuMod.wakuNew(cfg)
wakuMod.wakuVersion(function(msg){ console.log("Waku Version: " + msg) })
// Example on how to retrieve a value from the waku library
var defaultPubsubTopic = ""
wakuMod.wakuDefaultPubsubTopic(function(msg){ defaultPubsubTopic = msg })
console.log("Default pubsub topic: " + defaultPubsubTopic)
console.log("Setting callback event callback function")
wakuMod.wakuSetEventCallback(event_handler)
wakuMod.wakuStart()
wakuMod.wakuConnect("/ip4/127.0.0.1/tcp/60000/p2p/16Uiu2HAmVFXtAfSj4EiR7mL2KvL4EE2wztuQgUSBoj2Jx2KeXFLN",
10000,
function onErr(msg) {
console.log("Error connecting node: " + msg)
})
wakuMod.wakuRelaySubscribe(defaultPubsubTopic,
function onErr(msg) {
console.log("Error subscribing: " + msg)
})
app.post('/publish',
function (req, res) {
// First read existing users.
console.log("Publish event received")
wakuMod.wakuRelayPublish(defaultPubsubTopic,
"content_topic_name",
create_random_string(10),
10000,
function onError(msg) {
console.log("Error: " + msg)
process.exit(-1)
});
res.end( JSON.stringify("OK publish"))
})
var server = app.listen(8081, function () {
var host = server.address().address
var port = server.address().port
console.log("Example waku listening at http://%s:%s", host, port)
})