/
index.js
55 lines (39 loc) · 1.18 KB
/
index.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
const bodyParser = require("body-parser")
const express = require("express")
const request = require("request")
const Blockchain = require("./blockchain/")
const PubSub = require("./app/pubsub")
const app = express()
const blockchain = new Blockchain()
const pubsub = new PubSub({ blockchain })
const DEFAULT_PORT = 3000
const ROOT_NODE_ADDRESS = `http://localhost:${DEFAULT_PORT}`
app.use(bodyParser.json())
app.get("/api/blocks", (req, res) => {
res.json(blockchain.chain)
})
app.post("/api/mine", (req, res) => {
const { data } = req.body
blockchain.addBlock({ data })
pubsub.broadcastChain()
res.redirect("/api/blocks")
})
const syncChains = () => {
request({ url: `${ROOT_NODE_ADDRESS}/api/blocks` }, (error, response, body) => {
if (!error && response.statusCode === 200) {
const rootChain = JSON.parse(body)
blockchain.replaceChain(rootChain)
}
})
}
let PEER_PORT
if (process.env.GENERATE_PEER_PORT === 'true') {
PEER_PORT = DEFAULT_PORT + Math.ceil(Math.random() * 1000)
}
const PORT = PEER_PORT || DEFAULT_PORT
app.listen(PORT, () => {
console.log(`Listening at localhost:${PORT}`)
if (PORT !== DEFAULT_PORT) {
syncChains()
}
})