mirror of https://github.com/oxen-io/lokinet
remove unused cruft
Jeff Becker
4 years ago
parent
fcf6f7119f
commit
e8c5a62ee8
@ -1,6 +0,0 @@
|
||||
|
||||
int
|
||||
main(__attribute__((unused)) int argc, __attribute__((unused)) char* argv[])
|
||||
{
|
||||
return 0;
|
||||
}
|
||||
@ -1,3 +0,0 @@
|
||||
#!/bin/sh
|
||||
rm -fr loki*/tmp-nodes
|
||||
rm loki*/profile.dat
|
||||
@ -1,9 +0,0 @@
|
||||
#!/bin/sh
|
||||
# copy a lokinet binary into this cluster
|
||||
cp ../../lokinet .
|
||||
# generate default config file
|
||||
./lokinet -g -r lokinet.ini
|
||||
# make seed node
|
||||
./makenode.sh 1
|
||||
# establish bootstrap
|
||||
ln -s loki1/self.signed bootstrap.signed
|
||||
@ -1,7 +0,0 @@
|
||||
mkdir loki$1
|
||||
cd loki$1
|
||||
ln -s ../lokinet lokinet$1
|
||||
cp ../lokinet.ini .
|
||||
nano lokinet.ini
|
||||
cd ..
|
||||
echo "killall -9 lokinet$1" >> ../stop.sh
|
||||
@ -1,16 +0,0 @@
|
||||
#!/bin/bash
|
||||
set +x
|
||||
cd loki1
|
||||
nohup ./lokinet1 $PWD/lokinet.ini &
|
||||
# seed node needs some time to write RC to make sure it's not expired on load for the rest
|
||||
sleep 1
|
||||
cd ../loki2
|
||||
nohup ./lokinet2 $PWD/lokinet.ini &
|
||||
cd ../loki3
|
||||
nohup ./lokinet3 $PWD/lokinet.ini &
|
||||
cd ../loki4
|
||||
nohup ./lokinet4 $PWD/lokinet.ini &
|
||||
cd ../loki5
|
||||
nohup ./lokinet5 $PWD/lokinet.ini &
|
||||
cd ..
|
||||
tail -f loki*/nohup.out
|
||||
@ -1,7 +0,0 @@
|
||||
#!/bin/sh
|
||||
killall -9 lokinet1
|
||||
killall -9 lokinet2
|
||||
killall -9 lokinet3
|
||||
killall -9 lokinet4
|
||||
killall -9 lokinet5
|
||||
killall -9 lokinet6
|
||||
@ -1,80 +0,0 @@
|
||||
apiVersion: v1
|
||||
kind: Service
|
||||
metadata:
|
||||
name: loki-network
|
||||
labels:
|
||||
app: loki-network
|
||||
spec:
|
||||
type: NodePort
|
||||
ports:
|
||||
- protocol: UDP
|
||||
port: 1090
|
||||
name: udp-1
|
||||
targetPort: 1090
|
||||
- protocol: UDP
|
||||
port: 1190
|
||||
name: udp-2
|
||||
targetPort: 1190
|
||||
selector:
|
||||
app: loki-network
|
||||
---
|
||||
apiVersion: extensions/v1beta1
|
||||
kind: Deployment
|
||||
metadata:
|
||||
annotations:
|
||||
description: loki-network lokinet
|
||||
keel.sh/pollSchedule: "@every 1m"
|
||||
keel.sh/notify: deployments # chat channels to sent notification to
|
||||
generation: 1
|
||||
labels:
|
||||
app: loki-network
|
||||
keel.sh/policy: force # update policy (available: patch, minor, major, all, force)
|
||||
keel.sh/trigger: poll # enable active repository checking (webhooks and GCR would still work)
|
||||
keel.sh/approvals: "0" # required approvals to update
|
||||
keel.sh/match-tag: "true" # only makes a difference when used with 'force' policy, will only update if tag matches :dev->:dev, :prod->:prod
|
||||
name: loki-network
|
||||
spec:
|
||||
progressDeadlineSeconds: 600
|
||||
replicas: 3
|
||||
revisionHistoryLimit: 20
|
||||
selector:
|
||||
matchLabels:
|
||||
app: loki-network
|
||||
strategy:
|
||||
rollingUpdate:
|
||||
maxSurge: 25%
|
||||
maxUnavailable: 25%
|
||||
type: RollingUpdate
|
||||
template:
|
||||
metadata:
|
||||
annotations:
|
||||
description: loki-network lokinet
|
||||
creationTimestamp: null
|
||||
labels:
|
||||
app: loki-network
|
||||
name: loki-network
|
||||
spec:
|
||||
containers:
|
||||
- image: 092763672147.dkr.ecr.us-east-1.amazonaws.com/loki/loki-network:latest
|
||||
imagePullPolicy: Always
|
||||
name: loki-network
|
||||
securityContext:
|
||||
privileged: true
|
||||
terminationMessagePath: /dev/termination-log
|
||||
terminationMessagePolicy: File
|
||||
ports:
|
||||
- protocol: UDP
|
||||
containerPort: 1090
|
||||
name: udp-1
|
||||
- protocol: UDP
|
||||
containerPort: 1190
|
||||
name: udp-2
|
||||
dnsPolicy: "None"
|
||||
dnsConfig:
|
||||
nameservers:
|
||||
- 127.0.0.1
|
||||
- 1.1.1.1
|
||||
restartPolicy: Always
|
||||
schedulerName: default-scheduler
|
||||
terminationGracePeriodSeconds: 30
|
||||
status: {}
|
||||
@ -1,11 +0,0 @@
|
||||
apiVersion: apps/v1
|
||||
kind: DaemonSet
|
||||
metadata:
|
||||
name: lokid-lokinet
|
||||
namespace: kube-system
|
||||
labels:
|
||||
k8s-app: fluentd-logging
|
||||
spec:
|
||||
selector:
|
||||
matchLabels:
|
||||
name:
|
||||
@ -1,30 +0,0 @@
|
||||
apiVersion: apps/v1
|
||||
kind: Deployment
|
||||
metadata:
|
||||
name: loki-deployment
|
||||
labels:
|
||||
app: loki-svc-node
|
||||
spec:
|
||||
replicas: 2
|
||||
selector:
|
||||
matchLabels:
|
||||
app: loki-svc-node
|
||||
template:
|
||||
metadata:
|
||||
labels:
|
||||
app: loki-svc-node
|
||||
spec:
|
||||
containers:
|
||||
- name: loki-svc-node
|
||||
image: jaaff/loki-svc-kubernetes
|
||||
ports:
|
||||
- protocol: TCP
|
||||
port: 22022
|
||||
targetPort: 22022
|
||||
- protocol: TCP
|
||||
port: 22023
|
||||
targetPort: 22023
|
||||
- protocol: UDP
|
||||
port: 1090
|
||||
targetPort: 1090
|
||||
|
||||
@ -1,13 +0,0 @@
|
||||
kind: Service
|
||||
apiVersion: v1
|
||||
metadata:
|
||||
name: lokinet
|
||||
labels:
|
||||
app: lokinet
|
||||
spec:
|
||||
selector:
|
||||
app: lokinet
|
||||
ports:
|
||||
- protocol: UDP
|
||||
port: 1090
|
||||
targetPort: 1090
|
||||
@ -1,7 +0,0 @@
|
||||
# kuberentes cluster
|
||||
|
||||
this contains stuff for kuberenetes
|
||||
|
||||
usage:
|
||||
|
||||
$
|
||||
@ -1,26 +0,0 @@
|
||||
# Building / Running
|
||||
|
||||
after building lokinet
|
||||
|
||||
```
|
||||
cd contrib/node-monitor
|
||||
npm install
|
||||
sudo node monitor_client.js
|
||||
```
|
||||
|
||||
and wait 30 minutes for final score
|
||||
|
||||
# Scoring
|
||||
|
||||
Lokinet gets a point for everything it does correctly.
|
||||
|
||||
Currently:
|
||||
- succesful ping to snode (1 per second after a snode is discovered)
|
||||
- session with snode established
|
||||
- got a router from exploration
|
||||
- Handling DHT S or R message
|
||||
- a path is built
|
||||
- obtained an exit via
|
||||
- granted exit
|
||||
- IntroSet publish confirmed
|
||||
- utp.session.sendq. has a min zero count (no blocked buffers on routers)
|
||||
@ -1,61 +0,0 @@
|
||||
function iniToJSON(data) {
|
||||
const lines = data.split(/\n/)
|
||||
var section = 'unknown'
|
||||
var config = {}
|
||||
for (var i in lines) {
|
||||
var line = lines[i].trim()
|
||||
if (line.match(/#/)) {
|
||||
var parts = line.split(/#/)
|
||||
line = parts[0].trim()
|
||||
}
|
||||
// done reducing
|
||||
if (!line) continue
|
||||
|
||||
// check for section
|
||||
if (line[0] == '[' && line[line.length - 1] == ']') {
|
||||
section = line.substring(1, line.length - 1)
|
||||
//console.log('found section', section)
|
||||
continue
|
||||
}
|
||||
// key value pair
|
||||
if (line.match(/=/)) {
|
||||
var parts = line.split(/=/)
|
||||
var key = parts.shift().trim()
|
||||
var value = parts.join('=').trim()
|
||||
if (value === 'true') value = true
|
||||
if (value === 'false') value = false
|
||||
//console.log('key/pair ['+section+']', key, '=', value)
|
||||
if (config[section] === undefined) config[section] = {}
|
||||
config[section][key] = value
|
||||
continue
|
||||
}
|
||||
console.error('config [' + section + '] not section or key/value pair', line)
|
||||
}
|
||||
return config
|
||||
}
|
||||
|
||||
function jsonToINI(json) {
|
||||
var config = ''
|
||||
for (var section in json) {
|
||||
config += "\n" + '[' + section + ']' + "\n"
|
||||
var keys = json[section]
|
||||
for (var key in keys) {
|
||||
//console.log('key', key, 'value', keys[key])
|
||||
// if keys[key] is an array, then we need to send the same key each time
|
||||
if (keys[key] !== undefined && keys[key].constructor.name == 'Array') {
|
||||
for (var i in keys[key]) {
|
||||
var v = keys[key][i]
|
||||
config += key + '=' + v + "\n"
|
||||
}
|
||||
} else {
|
||||
config += key + '=' + keys[key] + "\n"
|
||||
}
|
||||
}
|
||||
}
|
||||
return config
|
||||
}
|
||||
|
||||
module.exports = {
|
||||
iniToJSON: iniToJSON,
|
||||
jsonToINI: jsonToINI,
|
||||
}
|
||||
File diff suppressed because it is too large
Load Diff
@ -1,323 +0,0 @@
|
||||
const lokinet = require('./lokinet') // currently using the 0.5 api
|
||||
const fs = require('fs')
|
||||
const ping = require("net-ping")
|
||||
// horrible library that shells out to use ping...
|
||||
//const ping = require('ping')
|
||||
|
||||
// score successful actions
|
||||
// while we monitor snode and loki addresses
|
||||
|
||||
var session = ping.createSession()
|
||||
|
||||
// probably should nuke profiles.dat each round to level the playing field
|
||||
if (fs.existsSync('profiles.dat')) {
|
||||
console.log('cleaning router profiles')
|
||||
fs.unlinkSync('profiles.dat')
|
||||
}
|
||||
|
||||
//
|
||||
// start config
|
||||
//
|
||||
|
||||
// FIXME: take in a binary_path as an option...
|
||||
var lokinet_config = {
|
||||
binary_path: '../../lokinet',
|
||||
// clients will default to i2p.rocks
|
||||
// bootstrap_url : 'http://206.81.100.174/n-st-1.signed',
|
||||
// rpc_ip : '127.0.0.1',
|
||||
// rpc_port : 28082,
|
||||
// auto_config_test_host: 'www.google.com',
|
||||
// auto_config_test_port: 80,
|
||||
// testnet : true,
|
||||
// verbose : true,
|
||||
}
|
||||
|
||||
score_time = null
|
||||
score_total = 0
|
||||
|
||||
var lokinet_version = 'unknown'
|
||||
|
||||
var known_snodes = []
|
||||
var snodes_stats = {}
|
||||
|
||||
function addSnode(snode) {
|
||||
var idx = known_snodes.indexOf(snode)
|
||||
if (idx == -1) {
|
||||
known_snodes.push(snode)
|
||||
|
||||
function lookupSnode(snode) {
|
||||
lokinet.lookup(snode, function (records) {
|
||||
console.log(snode, 'mapped to', records)
|
||||
// if no response or not found, retry
|
||||
if (records === undefined || records === null) {
|
||||
// failure retry
|
||||
setTimeout(function () {
|
||||
console.log('retry lookup for', snode)
|
||||
lookupSnode(snode)
|
||||
}, 5000)
|
||||
return
|
||||
}
|
||||
if (!records) {
|
||||
console.log('records is false', records)
|
||||
return
|
||||
}
|
||||
if (!records.length) {
|
||||
console.log('record is empty array')
|
||||
return
|
||||
}
|
||||
var ip = records[0]
|
||||
// reset stats
|
||||
snodes_stats[snode] = {
|
||||
onlines: 0,
|
||||
offlines: 0,
|
||||
}
|
||||
// trigger monitor update?
|
||||
setInterval(function () {
|
||||
/*
|
||||
ping.sys.probe(ip, function(isAlive){
|
||||
if (isAlive) {
|
||||
//console.log(snode, ip, 'is online')
|
||||
snodes_stats[snode].onlines++
|
||||
score_total++
|
||||
} else {
|
||||
console.log(snode, ip, 'is offline')
|
||||
snodes_stats[snode].offlines++
|
||||
}
|
||||
})
|
||||
*/
|
||||
session.pingHost(ip, function (err, target) {
|
||||
if (err) {
|
||||
console.warn(target, 'ping err', err);
|
||||
console.log(snode, ip, 'is offline')
|
||||
snodes_stats[snode].offlines++
|
||||
} else {
|
||||
//console.log (target + ": Alive")
|
||||
//console.log(snode, ip, 'is online')
|
||||
snodes_stats[snode].onlines++
|
||||
score_total++
|
||||
}
|
||||
})
|
||||
}, 1000)
|
||||
})
|
||||
}
|
||||
lookupSnode(snode)
|
||||
}
|
||||
}
|
||||
|
||||
setInterval(function () {
|
||||
// can be known but not mapped yet...
|
||||
console.log('snode score card,', known_snodes.length, 'known routers')
|
||||
for (var snode in snodes_stats) {
|
||||
var stats = snodes_stats[snode]
|
||||
var total = stats.onlines + stats.offlines
|
||||
var onlinePer = (stats.onlines / total) * 100
|
||||
console.log(snode, stats, onlinePer + '%')
|
||||
}
|
||||
}, 30 * 1000)
|
||||
|
||||
lokinet.onMessage = function (data) {
|
||||
console.log(`monitor: ${data}`)
|
||||
var lines = data.split(/\n/)
|
||||
for (var i in lines) {
|
||||
var tline = lines[i].trim()
|
||||
// lokinet-0.4.0-59e6a4bc (dev build)
|
||||
if (tline.match('lokinet-0.')) {
|
||||
var parts = tline.split('lokinet-0.')
|
||||
lokinet_version = parts[1]
|
||||
console.log('VERSION', parts[1])
|
||||
}
|
||||
if (tline.match('Using config file:')) {
|
||||
// get bootstrap info
|
||||
var parts = tline.split('Using config file: ')
|
||||
console.log('CONFIGFILE', parts[1])
|
||||
}
|
||||
if (tline.match('Added bootstrap node')) {
|
||||
// get bootstrap info
|
||||
var parts = tline.split('Added bootstrap node ')
|
||||
addSnode(parts[1])
|
||||
console.log('BOOTSTRAP', parts[1])
|
||||
}
|
||||
if (tline.match('Set Up networking for')) {
|
||||
// get interface info
|
||||
var parts = tline.split('Set Up networking for ')
|
||||
// default:9j4uido1ai7ucirbncbqii1395e8ccd6cjomo9cccp3ztx1ukwio.loki
|
||||
console.log('INTERFACE', parts[1])
|
||||
}
|
||||
//
|
||||
if (tline.match('session with ')) {
|
||||
// potential node
|
||||
var parts = tline.split('session with ')
|
||||
if (parts.length) {
|
||||
var one = parts[1].replace(' established', '')
|
||||
var two = one.split('.snode') // snode\u001b[0;0m
|
||||
var snode = two[0] + '.snode'
|
||||
addSnode(snode)
|
||||
console.log('SESSION', snode)
|
||||
score_total++
|
||||
} else {
|
||||
console.log('unknown session line', tline)
|
||||
}
|
||||
}
|
||||
if (tline.match(' routers from exploration')) {
|
||||
var parts = tline.split('\tgot ')
|
||||
if (parts.length > 1) {
|
||||
var routers = parts[1].replace(' routers from exploration', '')
|
||||
console.log('ROUTERS', routers)
|
||||
if (routers && routers != '0') {
|
||||
score_total++
|
||||
}
|
||||
} else {
|
||||
console.log('unknown exploration line', tline)
|
||||
}
|
||||
}
|
||||
// ?
|
||||
if (tline.match('Handle DHT message S relayed=0')) {
|
||||
score_total++
|
||||
}
|
||||
// relay DHT packet
|
||||
if (tline.match('Handle DHT message R relayed=0')) {
|
||||
score_total++
|
||||
}
|
||||
//
|
||||
if (tline.match(' is built, took ')) {
|
||||
// path TX=8826efd28bede66c59782af9894eed08 RX=a994770a8c6d61700b8ca65e4a3adea3 on OBContext:default:3y3ch3m6c8xgmutxwe8fger6n963hn3mkn6tk14j67w1zdxj1n1y.loki-icxqqcpd3sfkjbqifn53h7rmusqa1fyxwqyfrrcgkd37xcikwa7y.loki is built, took 2321 ms
|
||||
var parts = tline.split('path TX=')
|
||||
if (parts.length > 1) {
|
||||
var two = parts[1].split(' RX=')
|
||||
if (two.length > 1) {
|
||||
var tx = two[0]
|
||||
var three = two[1].split(' on OBContext:')
|
||||
if (three.length > 1) {
|
||||
var rx = three[0]
|
||||
var four = three[1].split(' is built, took ')
|
||||
if (four.length > 1) {
|
||||
var context = four[0]
|
||||
var ms = four[1]
|
||||
console.log('PATH BUILT', tx, rx, context, ms)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
score_total++
|
||||
}
|
||||
// happen right after the built, took
|
||||
//TX=53e833fcbad1395647f198201d4931e5 RX=b4768bc4b91b86b51b513319f443f538 on default:dnhi78pwrn6cd5yz83i83816nqudwym57s5x4bp3j4g5kbeigw5y.loki built latency=291
|
||||
if (tline.match(' is built latency ')) {
|
||||
// path latency info
|
||||
}
|
||||
//[WRN] (166) Tue Apr 30 15:26:25 2019 PDT path/pathbuilder.cpp:319 SNode::8ti485iig9q1wd6k9qr6dqmswrqp9hceohcrtwwa7pn6wcxx9wdy.snode failed to select hop 3
|
||||
// not a sure but snode extract
|
||||
if (tline.match('.snode failed to select hop')) {
|
||||
var parts = tline.split('SNode::')
|
||||
//console.log('failed to select hop parts', parts)
|
||||
if (parts.length > 1) {
|
||||
var two = parts[1].split(' failed to select hop ')
|
||||
if (two.length) {
|
||||
var hops = two[1]
|
||||
//console.log('hopSelectionFailure', snode, hops)
|
||||
}
|
||||
}
|
||||
}
|
||||
//obtained an exit via nc9y88xsr7cqmpytc6tbo5dbf5c9fa3is5dezmdwxwgfkuhemg3o.snode
|
||||
if (tline.match('obtained an exit via ')) {
|
||||
var parts = tline.split('obtained an exit via ')
|
||||
if (parts.length > 1) {
|
||||
var two = parts[1].split('.snode')
|
||||
var snode = two[0] + '.snode'
|
||||
addSnode(snode)
|
||||
}
|
||||
score_total++
|
||||
}
|
||||
//TX=219222f0f390e40ce47745af292001f2 RX=671c259dd9590173019694fc10433b63 on SNode::nc9y88xsr7cqmpytc6tbo5dbf5c9fa3is5dezmdwxwgfkuhemg3o.snode nc9y88xsr7cqmpytc6tbo5dbf5c9fa3is5dezmdwxwgfkuhemg3o.snode Granted exit
|
||||
if (tline.match('Granted exit')) {
|
||||
var one = tline.split('TX=')
|
||||
if (one.length > 1) {
|
||||
var two = one[1].split(' RX=')
|
||||
if (two.length > 1) {
|
||||
var three = two[1].split(' on SNode::')
|
||||
if (three.length > 1) {
|
||||
var tx = two[0]
|
||||
var rx = three[0]
|
||||
console.log('EXIT', tx, rx, 'rest', three[1])
|
||||
}
|
||||
}
|
||||
}
|
||||
score_total++
|
||||
}
|
||||
//service/endpoint.cpp:652 default:kzow69uftho8ukm8g4kf88y5zka84azfrmfx5okkmrg7ucdz5d1o.loki IntroSet publish confirmed
|
||||
if (tline.match('IntroSet publish confirmed')) {
|
||||
score_total++
|
||||
}
|
||||
}
|
||||
}
|
||||
lokinet.onError = function (data) {
|
||||
console.log(`monitorerr: ${data}`)
|
||||
// start on 2019-04-30T15:40:55.540314745-07:00 X Records
|
||||
// buffer until
|
||||
// end on \n\n
|
||||
var lines = data.toString().split(/\n/)
|
||||
for (var i in lines) {
|
||||
var tline = lines[i].trim()
|
||||
if (tline.match('utp.session.sendq.')) {
|
||||
//console.log('sendq')
|
||||
var one = tline.split('utp.session.sendq.')
|
||||
// parts[1] = 8ti485iig9q1wd6k9qr6dqmswrqp9hceohcrtwwa7pn6wcxx9wdy.snode [
|
||||
// count = 282, total = 3, min = 0, max = 1 ]
|
||||
if (one.length > 1) {
|
||||
var two = one[1].split(' [ ')
|
||||
if (two.length > 1) {
|
||||
var snode = two[0]
|
||||
var three = two[1].split(', ')
|
||||
if (three.length > 3) {
|
||||
var count = three[0]
|
||||
var total = three[1]
|
||||
var min = three[2]
|
||||
if (min == 'min = 0') {
|
||||
//console.log('no bloat')
|
||||
// not sure if this is related to our version or not...
|
||||
score_total++
|
||||
}
|
||||
var max = three[3]
|
||||
console.log('UTPSENDQ', snode, count, total, min, max)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
//
|
||||
// end config
|
||||
//
|
||||
|
||||
function checkIP(cb) {
|
||||
lokinet.getLokiNetIP(function (ip) {
|
||||
if (ip === undefined) {
|
||||
checkIP(cb)
|
||||
return
|
||||
}
|
||||
//console.log('lokinet interface ip', ip)
|
||||
cb(ip)
|
||||
})
|
||||
}
|
||||
|
||||
lokinet.startClient(lokinet_config, function () {
|
||||
// lokinet isn't necessarily running at this point
|
||||
console.log('Starting monitor')
|
||||
score_time = Date.now()
|
||||
checkIP(function (ip) {
|
||||
console.log('lokinet interface ip', ip)
|
||||
lokinet.findLokiNetDNS(function (servers) {
|
||||
console.log('monitor detected DNS Servers', servers)
|
||||
})
|
||||
setInterval(function () {
|
||||
console.log('score', score_total, 'time', ((Date.now() - score_time) / 1000))
|
||||
}, 30000)
|
||||
// maybe run until a specific time and quit for comparison
|
||||
// 1200s (two 10min sessions)
|
||||
setTimeout(function () {
|
||||
console.log(lokinet_config.binary_path, 'version', lokinet_version, 'final score', score_total)
|
||||
process.exit()
|
||||
}, 3 * 600 * 1000) // 3x 10m sessions worth
|
||||
})
|
||||
})
|
||||
@ -1,29 +0,0 @@
|
||||
{
|
||||
"name": "lokinet-monitor",
|
||||
"version": "0.0.1",
|
||||
"lockfileVersion": 1,
|
||||
"requires": true,
|
||||
"dependencies": {
|
||||
"nan": {
|
||||
"version": "2.10.0",
|
||||
"resolved": "https://registry.npmjs.org/nan/-/nan-2.10.0.tgz",
|
||||
"integrity": "sha512-bAdJv7fBLhWC+/Bls0Oza+mvTaNQtP+1RyhhhvD95pgUJz6XM5IzgmxOkItJ9tkoCiplvAnXI1tNmmUD/eScyA=="
|
||||
},
|
||||
"net-ping": {
|
||||
"version": "1.2.3",
|
||||
"resolved": "https://registry.npmjs.org/net-ping/-/net-ping-1.2.3.tgz",
|
||||
"integrity": "sha512-ZKxj/kVPKL2RIsV9nR6I8nMT8Pi3k6ciTBKxD/6gd5lga9qcNmlyqNv+dbXqYGBvHsmG9yIpsfajr8X054x2fQ==",
|
||||
"requires": {
|
||||
"raw-socket": "*"
|
||||
}
|
||||
},
|
||||
"raw-socket": {
|
||||
"version": "1.6.4",
|
||||
"resolved": "https://registry.npmjs.org/raw-socket/-/raw-socket-1.6.4.tgz",
|
||||
"integrity": "sha512-ab/By3tp0gTDzwEJxgKUv+uIma0JFVnJElNMKNAqNiET+GQ2VAfR6eUVfnm0yRG/vxGu8gO2BYWhR30sQOTebg==",
|
||||
"requires": {
|
||||
"nan": "2.10.*"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,25 +0,0 @@
|
||||
{
|
||||
"name": "lokinet-monitor",
|
||||
"version": "0.0.1",
|
||||
"description": "Lokinet monitor",
|
||||
"main": "monitor_client.js",
|
||||
"scripts": {
|
||||
"test": "echo \"Error: no test specified\" && exit 1"
|
||||
},
|
||||
"repository": {
|
||||
"type": "git",
|
||||
"url": "git+https://github.com/loki-project/loki-network.git"
|
||||
},
|
||||
"keywords": [
|
||||
"lokinet"
|
||||
],
|
||||
"author": "Ryan Tharp",
|
||||
"license": "ISC",
|
||||
"bugs": {
|
||||
"url": "https://github.com/loki-project/loki-network/issues"
|
||||
},
|
||||
"homepage": "https://github.com/loki-project/loki-network#readme",
|
||||
"dependencies": {
|
||||
"net-ping": "^1.2.3"
|
||||
}
|
||||
}
|
||||
@ -1,3 +0,0 @@
|
||||
node_modules
|
||||
build
|
||||
*.log
|
||||
@ -1,15 +0,0 @@
|
||||
|
||||
{
|
||||
"targets": [
|
||||
{
|
||||
"target_name": "lokinet",
|
||||
"cflags!": [ "-fno-exceptions" ],
|
||||
"cflags_cc!": [ "-fno-exceptions" ],
|
||||
"sources": [ "lokinet.cc" ],
|
||||
"include_dirs": [
|
||||
"<!@(node -p \"require('node-addon-api').include\")"
|
||||
],
|
||||
'defines': [ 'NAPI_DISABLE_CPP_EXCEPTIONS' ],
|
||||
}
|
||||
]
|
||||
}
|
||||
@ -1,62 +0,0 @@
|
||||
#include <napi.h>
|
||||
#include <llarp.hpp>
|
||||
|
||||
struct Lokinet : public Napi::ObjectWrap< Lokinet >
|
||||
{
|
||||
llarp::Context ctx;
|
||||
|
||||
static Napi::Object
|
||||
Init(Napi::Env env, Napi::Object exports)
|
||||
{
|
||||
Napi::HandleScope scope(env);
|
||||
|
||||
Napi::Function func =
|
||||
DefineClass(env, "Lokinet",
|
||||
{InstanceMethod("configure", &Lokinet::Configure),
|
||||
InstanceMethod("run", &Lokient::Run),
|
||||
InstanceMethod("kill", &Lokinet::Kill)});
|
||||
|
||||
constructor = Napi::Persistent(func);
|
||||
constructor.SuppressDestruct();
|
||||
|
||||
exports.Set("Lokinet", func);
|
||||
return exports;
|
||||
};
|
||||
|
||||
Napi::Value
|
||||
Configure(const Napi::CallbackInfo& info)
|
||||
{
|
||||
if(info.Length() != 1 || !info[0].IsString())
|
||||
{
|
||||
Napi::TypeError::New(env, "String expected").ThrowAsJavaScriptException();
|
||||
}
|
||||
bool result = ctx.LoadConfig(info[0].As< std::string >());
|
||||
if(result)
|
||||
{
|
||||
result &= ctx.Setup() == 0;
|
||||
}
|
||||
return Napi::Value(info.Env(), result);
|
||||
}
|
||||
|
||||
Napi::Value
|
||||
Run(const Napi::CallbackInfo& info)
|
||||
{
|
||||
bool result = ctx.Run() == 0;
|
||||
return Napi::Value(info.Env(), result);
|
||||
}
|
||||
|
||||
Napi::Value
|
||||
Kill(const Napi::CallbackInfo& info)
|
||||
{
|
||||
bool result = ctx.Stop();
|
||||
return Napi::Value(info.Env(), result);
|
||||
}
|
||||
};
|
||||
|
||||
Napi::Object
|
||||
InitAll(Napi::Env env, Napi::Object exports)
|
||||
{
|
||||
return Lokinet::Init(env, exports);
|
||||
}
|
||||
|
||||
NODE_API_MODULE(addon, InitAll)
|
||||
@ -1,2 +0,0 @@
|
||||
var lokinet = require("bindings")("lokinet");
|
||||
console.log(lokinet);
|
||||
Loading…
Reference in New Issue