fluencelabs/dashboard
1
0
Fork 0
mirror of https://github.com/fluencelabs/dashboard synced 2025-05-12 15:47:11 +00:00
Code Issues Projects Releases Wiki Activity

Now It Works

Browse Source
This commit is contained in:
dmitry 2020-11-23 17:29:56 +03:00
parent 1adeb9afb9
commit 7863879122
2 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Route.elm
View File

@ -33,14 +33,17 @@ routeCommand m r =
air = air =
seq seq
(callBI "relayId" ( "dht", "neighborhood" ) [ "clientId" ] (Just "peers")) (callBI "relayId" ( "dht", "neighborhood" ) [ "clientId" ] (Just "peers"))
(par
(relayEvent "peers_discovered" [ "relayId", "peers" ])
(fold "peers" "p" <| (fold "peers" "p" <|
par par
(seq (seq
(callBI "p" ( "dht", "neighborhood" ) [ "clientId" ] (Just "morePeers")) (callBI "p" ( "dht", "neighborhood" ) [ "clientId" ] (Just "morePeers[]"))
(relayEvent "peersDiscovered" [ "p", "morePeers" ]) (relayEvent "peers_discovered" [ "p", "morePeers" ])
) )
(next "p") (next "p")
) )
)
in in
sendAir (relayId <| clientId <| air) sendAir (relayId <| clientId <| air)

8
src/index.ts
View File

@ -23,10 +23,12 @@ import {build} from "fluence/dist/particle";
import {registerService} from "fluence/dist/globalState"; import {registerService} from "fluence/dist/globalState";
import {Service, ServiceMultiple, ServiceOne} from "fluence/dist/service"; import {Service, ServiceMultiple, ServiceOne} from "fluence/dist/service";
let relayIdx = 1
function genFlags(peerId: string): any { function genFlags(peerId: string): any {
return { return {
peerId: peerId, peerId: peerId,
relayId: relays[0].peerId relayId: relays[relayIdx].peerId
} }
} }
@ -37,8 +39,8 @@ function genFlags(peerId: string): any {
let flags = genFlags(pid.toB58String()) let flags = genFlags(pid.toB58String())
// If the relay is ever changed, an event shall be sent to elm // If the relay is ever changed, an event shall be sent to elm
let client = await Fluence.connect(relays[1].multiaddr, pid) let client = await Fluence.connect(relays[relayIdx].multiaddr, pid)
Fluence.setLogLevel("debug")
let app = Elm.Main.init({ let app = Elm.Main.init({
node: document.getElementById('root'), node: document.getElementById('root'),
flags: flags flags: flags