fluencelabs/dashboard
1
0
Fork 0
mirror of https://github.com/fluencelabs/dashboard synced 2024-12-04 15:20:21 +00:00
Code Issues Projects Releases Wiki Activity

enable logs

Browse Source
This commit is contained in:
Pavel Murygin 2021-10-29 18:10:01 +03:00
parent 6c20bbd407
commit 4498ad1c83
3 changed files with 108 additions and 99 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
aqua/app.aqua
View File

@ -23,7 +23,7 @@ func askAllAndSend(peer: PeerId, collectPeerInfo: PeerInfoCb, collectServiceInte
modules <- Dist.list_modules()
services <- Srv.list()
co collectPeerInfo(peer, ident, services, blueprints, modules)
collectServiceInterfaces(peer, services, collectServiceInterface, log)
co collectServiceInterfaces(peer, services, collectServiceInterface, log)
func findAndAskNeighboursSchema(relayPeerId: PeerId, clientId: PeerId, collectPeerInfo: PeerInfoCb, collectServiceInterface: ServiceInterfaceCb, log: Log):
on relayPeerId:

201
src/_aqua/app.js
View File

@ -192,47 +192,50 @@ export function askAllAndSend(...args) {
(seq
(seq
(seq
(seq
(seq
(call peer ("peer" "identify") [] ident)
(call peer ("dist" "list_blueprints") [] blueprints)
)
(call peer ("dist" "list_modules") [] modules)
)
(call peer ("srv" "list") [] services)
(call peer ("peer" "identify") [] ident)
(call peer ("dist" "list_blueprints") [] blueprints)
)
(par
(call peer ("dist" "list_modules") [] modules)
)
(call peer ("srv" "list") [] services)
)
(par
(seq
(call -relay- ("op" "noop") [])
(xor
(call %init_peer_id% ("callbackSrv" "collectPeerInfo") [peer ident services blueprints modules])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
(null)
)
)
(par
(seq
(seq
(xor
(fold services srv
(seq
(seq
(call peer ("srv" "get_interface") [srv.$.id!] iface)
(call peer ("op" "array") [srv.$.id! iface] $ifaces)
)
(next srv)
)
)
(seq
(call -relay- ("op" "noop") [])
(xor
(call %init_peer_id% ("callbackSrv" "collectPeerInfo") [peer ident services blueprints modules])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
(null)
)
(call -relay- ("op" "noop") [])
)
(xor
(fold services srv
(seq
(seq
(call peer ("srv" "get_interface") [srv.$.id!] iface)
(call peer ("op" "array") [srv.$.id! iface] $ifaces)
)
(next srv)
)
)
(seq
(call -relay- ("op" "noop") [])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
(call %init_peer_id% ("callbackSrv" "collectServiceInterface") [peer $ifaces])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
)
)
(call -relay- ("op" "noop") [])
)
(xor
(call %init_peer_id% ("callbackSrv" "collectServiceInterface") [peer $ifaces])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
(null)
)
)
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4])
@ -409,47 +412,50 @@ export function findAndAskNeighboursSchema(...args) {
(seq
(seq
(seq
(seq
(seq
(call n2 ("peer" "identify") [] ident)
(call n2 ("dist" "list_blueprints") [] blueprints)
)
(call n2 ("dist" "list_modules") [] modules)
)
(call n2 ("srv" "list") [] services)
(call n2 ("peer" "identify") [] ident)
(call n2 ("dist" "list_blueprints") [] blueprints)
)
(par
(call n2 ("dist" "list_modules") [] modules)
)
(call n2 ("srv" "list") [] services)
)
(par
(seq
(call -relay- ("op" "noop") [])
(xor
(call %init_peer_id% ("callbackSrv" "collectPeerInfo") [n2 ident services blueprints modules])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
(null)
)
)
(par
(seq
(seq
(xor
(fold services srv
(seq
(seq
(call n2 ("srv" "get_interface") [srv.$.id!] iface)
(call n2 ("op" "array") [srv.$.id! iface] $ifaces)
)
(next srv)
)
)
(seq
(call -relay- ("op" "noop") [])
(xor
(call %init_peer_id% ("callbackSrv" "collectPeerInfo") [n2 ident services blueprints modules])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
(null)
)
(call -relay- ("op" "noop") [])
)
(xor
(fold services srv
(seq
(seq
(call n2 ("srv" "get_interface") [srv.$.id!] iface)
(call n2 ("op" "array") [srv.$.id! iface] $ifaces)
)
(next srv)
)
)
(seq
(call -relay- ("op" "noop") [])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
(call %init_peer_id% ("callbackSrv" "collectServiceInterface") [n2 $ifaces])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
)
)
(call -relay- ("op" "noop") [])
)
(xor
(call %init_peer_id% ("callbackSrv" "collectServiceInterface") [n2 $ifaces])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
(null)
)
)
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4])
@ -624,47 +630,50 @@ export function getAll(...args) {
(seq
(seq
(seq
(seq
(seq
(call peer ("peer" "identify") [] ident)
(call peer ("dist" "list_blueprints") [] blueprints)
)
(call peer ("dist" "list_modules") [] modules)
)
(call peer ("srv" "list") [] services)
(call peer ("peer" "identify") [] ident)
(call peer ("dist" "list_blueprints") [] blueprints)
)
(par
(call peer ("dist" "list_modules") [] modules)
)
(call peer ("srv" "list") [] services)
)
(par
(seq
(call -relay- ("op" "noop") [])
(xor
(call %init_peer_id% ("callbackSrv" "collectPeerInfo") [peer ident services blueprints modules])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
(null)
)
)
(par
(seq
(seq
(xor
(fold services srv
(seq
(seq
(call peer ("srv" "get_interface") [srv.$.id!] iface)
(call peer ("op" "array") [srv.$.id! iface] $ifaces)
)
(next srv)
)
)
(seq
(call -relay- ("op" "noop") [])
(xor
(call %init_peer_id% ("callbackSrv" "collectPeerInfo") [peer ident services blueprints modules])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
(null)
)
(call -relay- ("op" "noop") [])
)
(xor
(fold services srv
(seq
(seq
(call peer ("srv" "get_interface") [srv.$.id!] iface)
(call peer ("op" "array") [srv.$.id! iface] $ifaces)
)
(next srv)
)
)
(seq
(call -relay- ("op" "noop") [])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
(call %init_peer_id% ("callbackSrv" "collectServiceInterface") [peer $ifaces])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
)
)
(call -relay- ("op" "noop") [])
)
(xor
(call %init_peer_id% ("callbackSrv" "collectServiceInterface") [peer $ifaces])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
(null)
)
)
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4])

4
src/index.js
View File

@ -131,7 +131,7 @@ function genFlags(peerId, relays, relayIdx) {
// alias ServiceInterfaceCb: PeerId, string, Interface -> ()
function collectServiceInterface(peer_id, ifaces) {
// console.count(`service interface from ${peer_id}`);
console.log(`service interface from ${peer_id}`);
try {
for (let srvIdAndInterfaceTuple of ifaces) {
const eventRaw = {
@ -148,7 +148,7 @@ function genFlags(peerId, relays, relayIdx) {
// alias PeerInfoCb: PeerId, Info, []Service, []Blueprint, []Module -> ()
function collectPeerInfo(peerId, identify, services, blueprints, modules, interfaces) {
// console.log('peer info from %s, %s services', peerId, services.length);
console.log('peer info from %s, %s services', peerId, services.length);
try {
const eventRaw = {
peerId,