gun/test/tmp/mitra/gun_https2.js
Dimitris Apostolou 9e616ea3a9
Fix typos (#1299)
2023-02-25 17:09:54 -08:00

104 lines
4.0 KiB
JavaScript

//var port = process.env.OPENSHIFT_NODEJS_PORT || process.env.VCAP_APP_PORT || process.env.PORT || process.argv[2] || 8080;
const port = 4246;
const https = require('https');
const http = require('http');
const fs = require('fs');
process.env.GUN_ENV = "false";
const Gun = require('gun');
const path = require('path');
const usehttps = false;
const options =
usehttps ? {
key: fs.readFileSync('/etc/letsencrypt/live/dweb.me/privkey.pem'),
cert: fs.readFileSync('/etc/letsencrypt/live/dweb.me/fullchain.pem'),
} : {};
var h = usehttps ? https : http
//var server = h.createServer(options, (req, res) => {
var server = h.createServer((req, res) => {
if(Gun.serve(req, res)){ return } // filters gun requests!
res.writeHead(200);
res.end('go away - nothing for browsers here\n');
/*
fs.createReadStream(path.join(__dirname, req.url))
.on('error',function(){ // static files!
res.writeHead(200, {'Content-Type': 'text/html'});
res.end(fs.readFileSync(path.join(__dirname, 'index.html'))); // or default to index
})
.pipe(res); // stream
*/
});
//TODO-GUN put this into a separate require
function hijack(cb) {
/* Intercept outgoing message and replace result with
result from cb({soul, key, msg, original})
*/
Gun.on('opt', function (root) {
console.log("GUN: Hikacking loading trap");
if (root.once) {
return
}
root.on('out', function (msg) {
console.log("GUN: Hikacking starting outgoing message=", msg);
let to = this.to;
// TODO-GUN - this wont work when running locally in a script ONLY when running in server
if(msg['@'] && !msg.put) {
console.log("GUN: Hikacking outgoing message", msg);
setTimeout(function(){ // TODO-GUN its unclear why this timeout is here, other than for testing
let tmp = root.dup.s[msg['@']];
let original = tmp && tmp.it && tmp.it.get;
console.log("GUN: Hikacking outgoing message original=", original);
if (original) {
let soul = original['#'];
let key = original['.'];
console.log("GUN.hijack: soul=",soul,"key=", key);
let res;
try {
//TODO - this res now has to be async
res = cb({soul, key, msg, original}); // Note response can be undefined if error
} catch(err) {
console.warn("Gun.hijack callback error",err);
res = undefined;
}
msg.put = {
[soul]: {
_: {
'#': soul,
'>': {[key]: Gun.state()}
},
[key]: res // Note undefined should (hopefully) be a valid response
} };
console.log("GUN.hijack updated msg =", msg);
// NOTE: this doesn't necessarily save it back to
// this peers GUN data, (I (Mitra) thinks that may depend on other processes and order of Gun.on)
}
to.next(msg);
}, 100); //Just for testing and note that its async
} else {
to.next(msg); // pass to next middleware
}
});
this.to.next(root); // This is next for the Gun.on('opt'), not for the root.on('out')
});
}
hijack(function({soul=undefined, key=undefined, msg=undefined, original=undefined}={}) {
console.log("GUN: hijack testing", soul, key, msg, original);
return ("GUN: This is a test result");
});
var gun = new Gun({
web: server
});
server.listen(port);
console.log(usehttps ? "HTTPS" : "HTTP", 'Server started on port ' + port + ' with /gun');