126 lines
3.6 KiB
JavaScript
126 lines
3.6 KiB
JavaScript
import React from 'react';
|
|
import Window from "./Window";
|
|
|
|
async function awaitReducer(prev, c) {
|
|
return {...await prev, ...await c}
|
|
}
|
|
|
|
class ConnMgr extends React.Component {
|
|
constructor(props) {
|
|
super(props)
|
|
|
|
this.connect = this.connect.bind(this)
|
|
this.connectAll = this.connectAll.bind(this)
|
|
this.connect1 = this.connect1.bind(this)
|
|
this.connectChain = this.connectChain.bind(this)
|
|
this.getActualState = this.getActualState.bind(this)
|
|
|
|
this.state = {conns: {}, lock: true}
|
|
|
|
this.getActualState()
|
|
setInterval(this.getActualState, 500)
|
|
}
|
|
|
|
async getActualState() {
|
|
const nodes = this.props.nodes
|
|
let keys = Object.keys(nodes)
|
|
|
|
const newConns = await keys.filter((_, i) => i > 0).filter(kfrom => this.props.nodes[kfrom].conn !== undefined).map(async (kfrom, i) => {
|
|
return keys.filter((_, j) => i >= j).filter(kto => this.props.nodes[kto].conn !== undefined).map(async kto => {
|
|
|
|
const fromNd = this.props.nodes[kfrom]
|
|
const toNd = this.props.nodes[kto]
|
|
|
|
const connectedness = await fromNd.conn.call('Filecoin.NetConnectedness', [toNd.peerid])
|
|
|
|
return {[`${kfrom},${kto}`]: connectedness === 1}
|
|
}).reduce(awaitReducer, Promise.resolve({}))
|
|
}).reduce(awaitReducer, Promise.resolve({}))
|
|
|
|
this.setState({conns: newConns, lock: false})
|
|
}
|
|
|
|
async connect(action, from, to, noupdate) {
|
|
const fromNd = this.props.nodes[from]
|
|
const toNd = this.props.nodes[to]
|
|
|
|
if (action) {
|
|
const toPeerInfo = await toNd.conn.call('Filecoin.NetAddrsListen', [])
|
|
|
|
await fromNd.conn.call('Filecoin.NetConnect', [toPeerInfo])
|
|
} else {
|
|
await fromNd.conn.call('Filecoin.NetDisconnect', [toNd.peerid])
|
|
}
|
|
|
|
if (!noupdate)
|
|
this.setState(prev => ({conns: {...prev.conns, [`${from},${to}`]: action}}))
|
|
}
|
|
|
|
connectAll(discon) {
|
|
return () => {
|
|
const nodes = this.props.nodes
|
|
let keys = Object.keys(nodes)
|
|
|
|
keys.filter((_, i) => i > 0).forEach((kfrom, i) => {
|
|
keys.filter((_, j) => i >= j).forEach((kto, i) => {
|
|
this.connect(!discon, kfrom, kto, true)
|
|
})
|
|
})
|
|
}
|
|
}
|
|
|
|
connect1() {
|
|
const nodes = this.props.nodes
|
|
let keys = Object.keys(nodes)
|
|
|
|
keys.filter((_, i) => i > 0).forEach((k, i) => {
|
|
this.connect(true, k, keys[0])
|
|
})
|
|
}
|
|
|
|
connectChain() {
|
|
const nodes = this.props.nodes
|
|
let keys = Object.keys(nodes)
|
|
|
|
keys.filter((_, i) => i > 0).forEach((k, i) => {
|
|
this.connect(true, k, keys[i])
|
|
})
|
|
}
|
|
|
|
render() {
|
|
const nodes = this.props.nodes
|
|
let keys = Object.keys(nodes)
|
|
|
|
const rows = keys.filter((_, i) => i > 0).map((k, i) => {
|
|
const cols = keys.filter((_, j) => i >= j).map((kt, i) => {
|
|
const checked = this.state.conns[`${k},${kt}`] === true
|
|
|
|
return (
|
|
<td key={k + "," + kt}>
|
|
<input checked={checked} disabled={this.state.lock} type="checkbox" onChange={e => this.connect(e.target.checked, k, kt)}/>
|
|
</td>
|
|
)
|
|
})
|
|
return (
|
|
<tr key={k}><td>{k}</td>{cols}</tr>
|
|
)
|
|
})
|
|
|
|
return(
|
|
<Window title={`Connection Manager${this.state.lock ? ' (syncing)' : ''}`}>
|
|
<table>
|
|
<thead><tr><td></td>{keys.slice(0, -1).map((i) => (<td key={i}>{i}</td>))}</tr></thead>
|
|
<tbody>{rows}</tbody>
|
|
</table>
|
|
<div>
|
|
<button onClick={this.connectAll(true)}>DisonnAll</button>
|
|
<button onClick={this.connectAll(false)}>ConnAll</button>
|
|
<button onClick={this.connect1}>Conn1</button>
|
|
<button onClick={this.connectChain}>ConnChain</button>
|
|
</div>
|
|
</Window>
|
|
)
|
|
}
|
|
}
|
|
|
|
export default ConnMgr |