Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
var http = require('http')
// http.globalAgent.maxSockets = 100
var path = require('path')
var test = require('tape')
var find = require('array-find')
var typeforce = require('typeforce')
var extend = require('xtend')
var rimraf = require('rimraf')
var clone = require('clone')
var Q = require('q')
var express = require('express')
var leveldown = require('leveldown')
var helpers = require('@tradle/test-helpers')
var constants = require('@tradle/constants')
var ROOT_HASH = constants.ROOT_HASH
var Identity = require('@tradle/identity').Identity
var FakeKeeper = helpers.fakeKeeper
var fakeWallet = helpers.fakeWallet
var Transport = require('@tradle/transport-http')
var Tim = require('../')
var DAY_MILLIS = 24 * 3600 * 1000
Tim.CATCH_UP_INTERVAL = DAY_MILLIS
Tim.enableOptimizations()
var NONCE = 0
var BASE_PORT = 22222
var networkName = 'testnet'
var users = require('./users')
var bitcoin = require('@tradle/bitcoinjs-lib')
var kiki = require('@tradle/kiki')
// pre-cache key-parsing
var Q = require('q')
var extend = require('xtend')
var typeforce = require('typeforce')
var find = require('array-find')
var map = require('map-stream')
var constants = require('@tradle/constants')
var tutils = require('@tradle/utils')
var bitcoin = require('@tradle/bitcoinjs-lib')
var hrtime = require('monotonic-timestamp')
var Errors = require('./errors')
var Builder = require('@tradle/chained-obj').Builder
var Entry = require('logbase').Entry
var debug = require('debug')('tim-utils')
var NONCE = constants.NONCE
var CUR_HASH = constants.CUR_HASH
var ROOT_HASH = constants.ROOT_HASH
var PREV_HASH = constants.PREV_HASH
var TxData = require('@tradle/tx-data').TxData
var Entry = require('logbase').Entry
var MAX_ERRORS = 10
var PRIVATE_MSG_SCHEMA = {
txType: 'Number',
encryptedPermission: 'Buffer',
encryptedData: 'Buffer',
// txData: '?Buffer',
v: '?String'
}
var PUBLIC_MSG_SCHEMA = {
txType: 'Number',
data: 'Buffer',
var typeforce = require('typeforce')
// var lexint = require('lexicographic-integer')
var collect = require('stream-collector')
var pump = require('pump')
var levelup = require('levelup')
var Q = require('q')
var Promise = Q.Promise
// var levelQuery = require('level-queryengine')
// var jsonQueryEngine = require('jsonquery-engine')
var safe = require('safecb')
var constants = require('@tradle/constants')
// var TxData = require('tradle-tx-data').TxData
var levelErrs = require('level-errors')
var LiveStream = require('level-live-stream')
var CUR_HASH = constants.CUR_HASH
var ROOT_HASH = constants.ROOT_HASH
var TYPE = constants.TYPE
var TYPES = constants.TYPES
var lb = require('logbase')
var Entry = lb.Entry
var LogBase = lb.Simple
var EventType = require('./eventType')
var rebuf = require('./rebufEncoding')
var DEBUG = require('./debug')
var utils = require('./utils')
var Errors = require('./errors')
var now = utils.now
var ENTRY_TIMEOUT = DEBUG ? false : 5000
var MAIN_PREFIX = 'm!'
var TIMESTAMP_PREFIX = 't'
var CHAIN_TIMESTAMP_PREFIX = TIMESTAMP_PREFIX + 'c!'
var SEND_TIMESTAMP_PREFIX = TIMESTAMP_PREFIX + 's!'
var createMiscDB = require('./lib/miscDB')
var Errors = require('./lib/errors')
var utils = require('./lib/utils')
var getViaCache = require('./lib/getViaCache')
var RETRY_UNCHAIN_ERRORS = [
ChainLoader.Errors.ParticipantsNotFound,
ChainLoader.Errors.FileNotFound
].map(function (ErrType) {
return ErrType.type
})
var DEV = process.env.NODE_ENV !== 'production'
var TYPE = constants.TYPE
var TYPES = constants.TYPES
var SIGNEE = constants.SIGNEE
var ROOT_HASH = constants.ROOT_HASH
var PREV_HASH = constants.PREV_HASH
var CUR_HASH = constants.CUR_HASH
var NONCE = constants.NONCE
var CONFIRMATIONS_BEFORE_CONFIRMED = 10
Driver.BLOCKCHAIN_KEY_PURPOSE = 'messaging'
Driver.MIN_BALANCE = 10000
Driver.CHAIN_WRITE_THROTTLE = 60000
Driver.CHAIN_READ_THROTTLE = 300000
Driver.SEND_THROTTLE = 10000
Driver.CATCH_UP_INTERVAL = 2000
Driver.UNCHAIN_THROTTLE = 20000
// Driver.Zlorp = Zlorp
Driver.Kiki = kiki
Driver.Identity = Identity
Driver.Wallet = Wallet
Driver.EventType = EventType
var typeforce = require('typeforce')
// var lexint = require('lexicographic-integer')
var collect = require('stream-collector')
var levelup = require('levelup')
var Q = require('q')
var pump = require('pump')
var map = require('map-stream')
// var levelQuery = require('level-queryengine')
// var jsonQueryEngine = require('jsonquery-engine')
var safe = require('safecb')
var constants = require('@tradle/constants')
// var TxData = require('tradle-tx-data').TxData
var levelErrs = require('level-errors')
var LiveStream = require('level-live-stream')
var CUR_HASH = constants.CUR_HASH
var ROOT_HASH = constants.ROOT_HASH
var TYPE = constants.TYPE
var TYPES = constants.TYPES
var lb = require('logbase')
var Entry = lb.Entry
var LogBase = lb.Simple
var EventType = require('./eventType')
var rebuf = require('./rebufEncoding')
var DEBUG = require('./debug')
var utils = require('./utils')
var Errors = require('./errors')
var SEPARATOR = '!'
var now = utils.now
var ENTRY_TIMEOUT = DEBUG ? false : 5000
module.exports = function createMsgDB (path, options) {
typeforce('String', path)
var http = require('http')
var test = require('tape')
var Q = require('q')
var collect = require('stream-collector')
var ROOT_HASH = require('@tradle/constants').ROOT_HASH
var Messengers = require('../lib/messengers')
var utils = require('./helpers/utils')
var billPub = require('./fixtures/bill-pub')
var billPriv = require('./fixtures/bill-priv')
var tedPub = require('./fixtures/ted-pub')
var tedPriv = require('./fixtures/ted-priv')
test('p2p', function (t) {
var received
var identityInfos = [
{
pub: billPub,
priv: billPriv
},
{
pub: tedPub,
process.exit(1)
}
var cachePath = argv['cache-path']
if (!cachePath) {
throw new Error('expected "cache-path"')
}
cachePath = path.resolve(cachePath)
var bitcoin = require('@tradle/bitcoinjs-lib')
var helpers = require('@tradle/test-helpers')
var constants = require('@tradle/constants')
var utils = require('../lib/utils')
var tradleUtils = require('@tradle/utils')
var ROOT_HASH = constants.ROOT_HASH
var Identity = require('@tradle/identity').Identity
var FakeKeeper = helpers.fakeKeeper
var fakeWallet = helpers.fakeWallet
var Transport = require('@tradle/transport-http')
var Tim = require('../')
Tim.enableOptimizations()
var NONCE = 0
var BASE_PORT = 22222
var networkName = 'testnet'
var users = require('./users')
var ONE
var MANY
var STORAGE_PATH = './storage'
var sharedKeeper = FakeKeeper.empty()
var DAY_MILLIS = 24 * 60 * 1000 * 1000
var util = require('util')
var EventEmitter = require('events').EventEmitter
var debug = require('debug')('http-messenger-client')
var Q = require('q')
var typeforce = require('typeforce')
var nets = require('nets')
var debug = require('debug')('http-messenger')
var constants = require('@tradle/constants')
var Messenger = require('./base')
try {
var putString = !!require('react-native')
} catch (err) {}
var ROOT_HASH = constants.ROOT_HASH
module.exports = HttpMessengerClient
util.inherits(HttpMessengerClient, Messenger)
function HttpMessengerClient (opts) {
Messenger.call(this)
this._recipients = {}
if (opts && opts.rootHash) {
this.setRootHash(opts.rootHash)
}
}
HttpMessengerClient.prototype.addEndpoint =
HttpMessengerClient.prototype.addRecipient = function (rootHash, url) {
typeforce('String', rootHash)
typeforce('String', url)
var Dir = require('./dir')
var createIdentityDB = require('./identityDB')
var createMsgDB = require('./msgDB')
var createTxDB = require('./txDB')
var Errors = require('./errors')
var utils = require('./utils')
var RETRY_UNCHAIN_ERRORS = [
ChainLoader.Errors.ParticipantsNotFound,
ChainLoader.Errors.FileNotFound
].map(function (ErrType) {
return ErrType.type
})
var TYPE = constants.TYPE
var SIGNEE = constants.SIGNEE
var ROOT_HASH = constants.ROOT_HASH
var PREV_HASH = constants.PREV_HASH
var CUR_HASH = constants.CUR_HASH
var PREFIX = constants.OP_RETURN_PREFIX
var NONCE = constants.NONCE
var CONFIRMATIONS_BEFORE_CONFIRMED = 10
var KEY_PURPOSE = 'messaging'
Driver.MIN_BALANCE = 10000
Driver.CHAIN_WRITE_THROTTLE = 60000
Driver.CHAIN_READ_THROTTLE = 60000
Driver.SEND_THROTTLE = 10000
Driver.CATCH_UP_INTERVAL = 2000
Driver.Zlorp = Zlorp
Driver.Kiki = kiki
Driver.Identity = Identity
Driver.Wallet = Wallet
Driver.Messengers = Messengers
var debug = require('debug')('identityDB')
var typeforce = require('typeforce')
var extend = require('xtend')
var map = require('map-stream')
var levelup = require('levelup')
var Identity = require('@tradle/identity').Identity
var constants = require('@tradle/constants')
var TYPE = constants.TYPE
var ROOT_HASH = constants.ROOT_HASH
var CUR_HASH = constants.CUR_HASH
var Simple = require('logbase').Simple
var rebuf = require('./rebufEncoding')
var EventType = require('./eventType')
var DEBUG = require('./debug')
var ENTRY_TIMEOUT = DEBUG ? false : 5000
var prefixes = {
fingerprint: 'f'
}
prefixes[CUR_HASH] = CUR_HASH
prefixes[ROOT_HASH] = ROOT_HASH
module.exports = function mkIdentityDB (path, options) {
typeforce('String', path)
typeforce({