Skip to content

Commit

Permalink
Version 0.4.0
Browse files Browse the repository at this point in the history
  • Loading branch information
cryptocoins committed Mar 9, 2017
1 parent e8e26e4 commit 2536397
Show file tree
Hide file tree
Showing 25 changed files with 1,266 additions and 744 deletions.
37 changes: 27 additions & 10 deletions bv.js
View file
@@ -1,12 +1,13 @@
'use strict'

const blockchain = require('./lib/Blockchain')
const Block = require('./lib/Block')
const blockchain = require('./lib/Blockchain')
const Block = require('./lib/Block')
const Tx = require('./lib/Tx')

const action = process.argv[2] || process.exit(0)
var id = process.argv[2] || process.exit(0)
var toId = null

if (action === 'e') {
if (id === 'e') {
let maxId
if (maxId = process.argv[3]) {
blockchain.eachTo(maxId, (block) => {
Expand All @@ -17,14 +18,30 @@ if (action === 'e') {
console.log(block.id, block.hash.toString('hex'))
})
}
} else if (action === 'v') {
let id
if (id = process.argv[3]) {
const block = blockchain.get(parseInt(id))
block && console.log(block.hash.toString('hex'), block.data.length)
} else if (id === 'r') {
blockchain.removeLast(null, 5)
} else if (id === '--repair') {
let hasErrors = true
while (hasErrors) {
console.log('Checking blockchain...')
const len = blockchain.getLength()
console.log('Length:', len)
const {hash, data} = blockchain.get(len - 1)
console.log('Hash of last block:', hash.toString('hex'))
if (hash.equals(Buffer.from('0000000000000000000000000000000000000000000000000000000000000000', 'hex'))) {
console.log('Error in blockchain')
console.log('Repairing blockchain...')
blockchain.removeLast(null, 1)
} else if (data[0] === 0) {
console.log('Error in blockchain')
console.log('Repairing blockchain...')
blockchain.removeLast(null, 1)
} else {
hasErrors = false
}
}
console.log('No errors in blockchain')
}

console.log('Blockchain length:', blockchain.getLength())
setTimeout(() => {
process.exit()
Expand Down
280 changes: 2 additions & 278 deletions core.js
View file
@@ -1,280 +1,4 @@
'use strict'

const application = require('./package')
console.log('XHD Core ' + application.version + ' loading...')

const fs = require('fs')
const configPath = __dirname + '/config.js'
const configPathInit = __dirname + '/init-config.js'
if (!fs.existsSync(configPath)) {
console.log('Creating configuration file...')
fs.writeFileSync(configPath, fs.readFileSync(configPathInit))
}
const config = require('./config')

console.log('Checking configuration...')
if (config.minerMinimalFee >= 100000000) {
console.log('\x1b[31mconfig.minerMinimalFee is too big. Recommended value is 1000000.\x1b[0m')
}

const storage = require('./lib/Storage')
storage.config = config
storage.session.version = application.version
console.log(config)

const R = require('ramda')

require('./lib/Debugger')
const helper = require('./lib/helper')
const hours = require('./lib/Hours')
const Address = require('./lib/Address')
const blockchain = require('./lib/Blockchain')
const Block = require('./lib/Block')
const net = require('./lib/Net')
const miner = require('./lib/Miner')
const synchronizer = require('./lib/Synchronizer')
const ifc = require('./lib/Interface')

if (!storage.config.rpcHost) {
storage.config.rpcHost = '127.0.0.1'
}
if (!storage.config.rpcPort) {
storage.config.rpcPort = 5839
}
const rpcServer = require('./lib/RpcServer')

function log(...data) {
storage.trigger('log', ...data) || console.log(...data)
}

storage.logIgnoreModules = ['P2P']

if (process.argv[2] === '--clear-storage') {
storage.freeTxs = {}
storage.flush()
process.exit()
}

setInterval(() => {
storage.flush()
}, 60000)

storage.on('fatalError', (msg) => {
ifc.close()
console.log('Fatal error: ' + msg)
process.exit(0)
})

net.once('error', (msg) => {
ifc.close()
console.log(msg)
process.exit(0)
})

net.once('online', () => {
log('CORE: Synchronizing blockchain...')
synchronizer.remote(() => {
log('CORE: Blockchain synchronized')
if (config.minerMode) {
miner.run(R.map(i => Address.hashToRaw(i), config.minerAddresses))
}
})
})

net.on('offline', () => {
})

var onNewBlock = (hash, block, unpacked) => {
let deleted = 0
for (let i in unpacked.txHashList) {
if (Tx.freeTxDelete(unpacked.txHashList[i])) {
deleted++
}
}

miner.restart()
}

synchronizer.on('blockAfterAccept', (afterHash, hash, block, unpacked) => {
onNewBlock(hash, block, unpacked)
})

synchronizer.on('blockFoundAccept', (hash, block, unpacked) => {
onNewBlock(hash, block, unpacked)
})

synchronizer.on('txInfoAccept', (hash, tx, fee) => {
if (fee >= config.minerMinimalFee) {
log('CORE: Free tx accepted')
Tx.freeTxAdd(hash, tx, fee)
synchronizer.broadcastTx(hash, tx)

miner.restart()
}
})

hours.sync()
setTimeout(() => {
setTimeout(() => {
log('CORE: blockchain caching...')
synchronizer.cache()
log('CORE: blockchain cached')
log('CORE: connection may take some time')
ifc.open()

ifc.key('f5', () => {
if (storage.session.syncSpeed > 1) {
storage.session.syncSpeed--
}
storage.session.stat.snc = storage.session.syncSpeed
})

ifc.key('f6', () => {
if (storage.session.syncSpeed < 9) {
storage.session.syncSpeed++
}
storage.session.stat.snc = storage.session.syncSpeed
})

ifc.key('f7', () => {
if (synchronizer.isPromiscuous()) {
synchronizer.setPromiscuous(false)
log('CORE: {red-fg}promiscuous mode OFF{/red-fg}')
} else {
synchronizer.setPromiscuous(true)
log('CORE: {green-fg}promiscuous mode ON{/green-fg}')
}
})

ifc.key('f8', () => {
log(storage.servers)
})

ifc.key('f10', () => {
storage.flush()
process.exit(0)
})
net.connect(config)
}, 1000)
}, 2000)

/* Wallet */
const express = require('express')
const bodyParser = require('body-parser')

const login = process.argv[2] || 'wallet'
const base = __dirname + '/templates/'

const Tx = require('./lib/Tx')
const Wallet = require('./lib/Wallet')
storage.session.wallet = Wallet(login)
const {wallet} = storage.session
var opened = false

const def = (value) => {
return value !== undefined
}

const updateData = () => {
log('WLT', '<UpdateData> Balances ready in ' + helper.stopwatch(() => {
wallet.updateData()
}) + 'ms')
return wallet.getContent().length
}

const sendData = (socket) => {
const walletData = wallet.getData()
socket.json.send({
balances: walletData.balances,
balancesSoft: walletData.balancesSoft,
balancesUnconfirmed: walletData.balancesUnconfirmed,
txs: walletData.txs,
txsSoft: walletData.txsSoft,
allAmount: (walletData.allAmount / 100000000).toFixed(8),
allAmountSoft: (walletData.allAmountSoft / 100000000).toFixed(8),
allAmountUnconfirmed: (walletData.allAmountUnconfirmed / 100000000).toFixed(8)
})
}

const sendCoins = (data, callback) => {
wallet.sendCoins(data, callback)
}

const app = express()
app.use(bodyParser.urlencoded({extended: false}))
const server = app.listen(config.walletPort, config.walletHost)
const io = require('socket.io').listen(server)
var walletTimer = null

var freeTxChanged = false
storage.on('freeTxAdd', () => {
freeTxChanged = true
})
storage.on('freeTxDelete', () => {
freeTxChanged = true
})

io.sockets.on('connection', (socket) => {
if (walletTimer) {
clearInterval(walletTimer)
}
walletTimer = setInterval(() => {
if (freeTxChanged || wallet.isBlockchainChanged()) {
freeTxChanged = false
updateData()
sendData(socket)
}
}, 10000)
socket.on('message', (data) => {
if (!opened) {
socket.json.send({reload: true})
} else if (data.get === 'balances') {
sendData(socket)
} else if (data.post === 'address') {
wallet.attachAddress(Address.create())
updateData()
sendData(socket)
} else if (data.post === 'coins') {
sendCoins(data, (result) => {
socket.json.send({noty: result})
// updateData()
sendData(socket)
})
}
})
})
app.get('/', (req, res) => {
if (synchronizer.isReady()) {
res.send(fs.readFileSync(base + 'index.html', 'utf8').replace('%LOGIN%', login))
} else {
res.send(fs.readFileSync(base + 'sync.html', 'utf8'))
}
})
app.get('/assets/*', (req, res) => {
let url = req.params[0]
if (R.contains(url, ['bootstrap.min.css'])) {
res.set('Content-type', 'text/css')
res.send(fs.readFileSync(base + url, 'utf8'))
} else if (R.contains(url, ['jquery.min.js', 'bootstrap.min.js', 'jquery.noty.packaged.min.js'])) {
res.set('Content-type', 'application/javascript')
res.send(fs.readFileSync(base + url, 'utf8'))
}
})
app.post('/', (req, res) => {
let created = wallet.create(req.body.password)
if (created) {
wallet.attachAddress(Address.create())
} else {
wallet.open(req.body.password)
}
if (updateData()) {
opened = true
let errors = ''
if (config.minerMinimalFee >= 100000000) {
errors += '<div class="alert alert-danger">config.minerMinimalFee is too big. Recommended value is 1000000. You will be charged an extra fee if you do not change this setting.</div>'
}
res.send(fs.readFileSync(base + 'wallet.html', 'utf8').replace('%ERRORS%', errors))
} else {
res.redirect('/')
}
})
const cluster = require('cluster')
require('./lib/' + (cluster.isMaster ? 'master' : 'worker'))

0 comments on commit 2536397

Please sign in to comment.