valerie
/
valnet
Archived
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

connect to main relay

stable
Marcus 2020-11-12 11:43:35 -05:00
parent 27c375ab82
commit cbf1efb688
4 changed files with 32 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/Identity.js
View File

@ -3,7 +3,7 @@ const { KeyvFile } = require('keyv-file');
const { hri } = require('human-readable-ids'); const { hri } = require('human-readable-ids');
const os = require('os'); const os = require('os');
const NodeRSA = require('node-rsa'); const NodeRSA = require('node-rsa');
let log = require('signale').scope('Identity'); let log = require('signale').scope('Identity(null)');
module.exports.Identity = class Identity { module.exports.Identity = class Identity {
kv; kv;
@ -17,7 +17,7 @@ module.exports.Identity = class Identity {
}) })
}); });
log = log.scope(`${module}/${id}`); log = log.scope(`Identity(${module}/${id})`);
this.key = new Promise(async (res) => { this.key = new Promise(async (res) => {
log.info(`Searching for identity`); log.info(`Searching for identity`);

8
lib/STP.js
View File

@ -29,11 +29,13 @@ class Client extends EventEmitter {
} }
connect(e) { connect(e) {
log.debug('connect', e); // log.debug('connect', e);
this.emit('connect');
} }
error(e) { error(e) {
log.debug('error', e); // log.debug('error', e);
this.emit('error');
} }
} }
@ -79,7 +81,7 @@ class Server extends EventEmitter {
} }
listen(...args) { listen(...args) {
log.success('STP Server created on port', args[0]); // log.success('STP Server created on port', args[0]);
this.tcpServer.listen(...args); this.tcpServer.listen(...args);
} }
} }

3
package.json
View File

@ -7,6 +7,9 @@
"ports": { "ports": {
"ns": 5500, "ns": 5500,
"relay": 5600 "relay": 5600
},
"addresses": {
"relay": "valnet.xyz"
} }
}, },
"scripts": { "scripts": {

23
relay/index.js
View File

@ -2,9 +2,13 @@ const { title } = require('../lib/title');
const net = require('net'); const net = require('net');
const log = require('signale').scope('relay'); const log = require('signale').scope('relay');
const { config } = require('./../package.json'); const { config } = require('./../package.json');
const { Identity } = require('../lib/Identity');
const stp = require('../lib/STP');
title('relay', false); title('relay', false);
const identity = new Identity('relay', 'default');
// let connection = null; // let connection = null;
// (function tryConnect() { // (function tryConnect() {
@ -21,6 +25,23 @@ title('relay', false);
// }) // })
// })(); // })();
(async () => {
await identity.key;
const server = stp.createServer({
publicKey: (await identity.key).exportKey('pkcs8-public-pem'),
privateKey: (await identity.key).exportKey('pkcs8-private-pem')
}, (client) => {
log.info(`incomming connection from ${client.remoteAddress}`);
});
server.listen(config.ports.relay);
log.success(`STP server listening on ${config.ports.relay}`);
stp.connect(config.ports.relay, config.addresses.relay);
})();
const express = require('express'); const express = require('express');
const app = express(); const app = express();