mirror of
https://github.com/fullstack-cash/bch-api.git
synced 2026-09-22 17:22:04 -07:00
Merge branch 'master' into 6-electrum-broadcast
This commit is contained in:
@@ -16,9 +16,10 @@ util.inspect.defaultOptions = { depth: 1 }
|
||||
|
||||
// const SERVER = `http://192.168.0.36:12400/v3/`
|
||||
const SERVER = 'http://localhost:3000/v3/'
|
||||
// const SERVER = 'https://api.fullstack.cash/v3/'
|
||||
|
||||
const TEST_JWT =
|
||||
'eyJhbGciOiJFUzI1NiIsInR5cCI6IkpXVCJ9.eyJpZCI6IjVlM2EwNDE1ZWIyOWE5NjJkYTI3MDhiNCIsImFwaUxldmVsIjowLCJyYXRlTGltaXQiOjEwLCJpYXQiOjE1ODA4NjA0NjcsImV4cCI6MTU4MzQ1MjQ2N30.fuY5S-YrF0J11h5uyMjPe7wiVkYRnIyXi4dL9-V-C6pLJm33p0dSq_pSheVVWw78n5kAvL_9kFHngbnmQiOJYQ'
|
||||
'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpZCI6IjVlODhhY2JmMDIyMWMxMDAxMmFkOTNmZiIsImVtYWlsIjoiY2hyaXMudHJvdXRuZXJAZ21haWwuY29tIiwiYXBpTGV2ZWwiOjQwLCJyYXRlTGltaXQiOjMsImlhdCI6MTYwMDYyODk1MSwiZXhwIjoxNjAzMjIwOTUxfQ.JPXDJQsxJFtCGZjHOd-hRfJuY41Ef_FQ4ET06CtYdNk'
|
||||
|
||||
describe('#rate limits', () => {
|
||||
it('should get control/getNetworkInfo() with no auth', async () => {
|
||||
@@ -35,7 +36,7 @@ describe('#rate limits', () => {
|
||||
assert.hasAnyKeys(result.data, ['version'])
|
||||
})
|
||||
|
||||
it('should trigger rate-limit handler if rate limits exceeds 30 request per minute', async () => {
|
||||
it('should trigger rate-limit handler if rate limits exceeds 5 request per minute', async () => {
|
||||
try {
|
||||
// Actual rate limit is 60 per minute X 4 nodes = 240 rpm.
|
||||
const options = {
|
||||
@@ -44,7 +45,7 @@ describe('#rate limits', () => {
|
||||
}
|
||||
|
||||
const promises = []
|
||||
for (let i = 0; i < 30; i++) {
|
||||
for (let i = 0; i < 5; i++) {
|
||||
const promise = axios(options)
|
||||
promises.push(promise)
|
||||
}
|
||||
@@ -60,79 +61,79 @@ describe('#rate limits', () => {
|
||||
}
|
||||
})
|
||||
|
||||
it('should not trigger rate-limit handler if correct pro-tier password is used', async () => {
|
||||
try {
|
||||
const username = 'BITBOX'
|
||||
// it('should not trigger rate-limit handler if correct pro-tier password is used', async () => {
|
||||
// try {
|
||||
// const username = 'BITBOX'
|
||||
//
|
||||
// // Pro-tier is accessed by using the right password.
|
||||
// const password = 'BITBOX'
|
||||
// // const password = "something"
|
||||
//
|
||||
// const combined = `${username}:${password}`
|
||||
// const base64Credential = Buffer.from(combined).toString('base64')
|
||||
// const readyCredential = `Basic ${base64Credential}`
|
||||
//
|
||||
// const options = {
|
||||
// method: 'GET',
|
||||
// url: `${SERVER}control/getNetworkInfo`,
|
||||
// headers: { Authorization: readyCredential }
|
||||
// }
|
||||
//
|
||||
// const promises = []
|
||||
// for (let i = 0; i < 30; i++) {
|
||||
// const promise = axios(options)
|
||||
// promises.push(promise)
|
||||
// }
|
||||
//
|
||||
// await Promise.all(promises)
|
||||
//
|
||||
// assert.equal(true, true, 'Not throwing an error is a pass!')
|
||||
// } catch (err) {
|
||||
// // console.log(`err.response: ${util.inspect(err.response)}`)
|
||||
//
|
||||
// assert.equal(
|
||||
// true,
|
||||
// false,
|
||||
// 'This error handler should not have been triggered. Is the password correct?'
|
||||
// )
|
||||
// }
|
||||
// })
|
||||
|
||||
// Pro-tier is accessed by using the right password.
|
||||
const password = 'BITBOX'
|
||||
// const password = "something"
|
||||
|
||||
const combined = `${username}:${password}`
|
||||
const base64Credential = Buffer.from(combined).toString('base64')
|
||||
const readyCredential = `Basic ${base64Credential}`
|
||||
|
||||
const options = {
|
||||
method: 'GET',
|
||||
url: `${SERVER}control/getNetworkInfo`,
|
||||
headers: { Authorization: readyCredential }
|
||||
}
|
||||
|
||||
const promises = []
|
||||
for (let i = 0; i < 30; i++) {
|
||||
const promise = axios(options)
|
||||
promises.push(promise)
|
||||
}
|
||||
|
||||
await Promise.all(promises)
|
||||
|
||||
assert.equal(true, true, 'Not throwing an error is a pass!')
|
||||
} catch (err) {
|
||||
// console.log(`err.response: ${util.inspect(err.response)}`)
|
||||
|
||||
assert.equal(
|
||||
true,
|
||||
false,
|
||||
'This error handler should not have been triggered. Is the password correct?'
|
||||
)
|
||||
}
|
||||
})
|
||||
|
||||
it('should trigger rate-limit handler if rate limits exceeds pro-tier limit', async () => {
|
||||
try {
|
||||
const username = 'BITBOX'
|
||||
|
||||
// Pro-tier is accessed by using the right password.
|
||||
const password = 'BITBOX'
|
||||
// const password = "something"
|
||||
|
||||
const combined = `${username}:${password}`
|
||||
const base64Credential = Buffer.from(combined).toString('base64')
|
||||
const readyCredential = `Basic ${base64Credential}`
|
||||
|
||||
// Actual rate limit is 60 per minute X 4 nodes = 240 rpm.
|
||||
const options = {
|
||||
method: 'GET',
|
||||
url: `${SERVER}control/getNetworkInfo`,
|
||||
headers: { Authorization: readyCredential }
|
||||
}
|
||||
|
||||
const promises = []
|
||||
for (let i = 0; i < 80; i++) {
|
||||
const promise = axios(options)
|
||||
promises.push(promise)
|
||||
}
|
||||
|
||||
await Promise.all(promises)
|
||||
|
||||
assert.equal(true, false, 'Unexpected result!')
|
||||
} catch (err) {
|
||||
// console.log(`err.response: ${util.inspect(err.response)}`)
|
||||
|
||||
assert.equal(err.response.status, 429)
|
||||
assert.include(err.response.data.error, 'Too many requests')
|
||||
}
|
||||
})
|
||||
// it('should trigger rate-limit handler if rate limits exceeds pro-tier limit', async () => {
|
||||
// try {
|
||||
// const username = 'BITBOX'
|
||||
//
|
||||
// // Pro-tier is accessed by using the right password.
|
||||
// const password = 'BITBOX'
|
||||
// // const password = "something"
|
||||
//
|
||||
// const combined = `${username}:${password}`
|
||||
// const base64Credential = Buffer.from(combined).toString('base64')
|
||||
// const readyCredential = `Basic ${base64Credential}`
|
||||
//
|
||||
// // Actual rate limit is 60 per minute X 4 nodes = 240 rpm.
|
||||
// const options = {
|
||||
// method: 'GET',
|
||||
// url: `${SERVER}control/getNetworkInfo`,
|
||||
// headers: { Authorization: readyCredential }
|
||||
// }
|
||||
//
|
||||
// const promises = []
|
||||
// for (let i = 0; i < 80; i++) {
|
||||
// const promise = axios(options)
|
||||
// promises.push(promise)
|
||||
// }
|
||||
//
|
||||
// await Promise.all(promises)
|
||||
//
|
||||
// assert.equal(true, false, 'Unexpected result!')
|
||||
// } catch (err) {
|
||||
// // console.log(`err.response: ${util.inspect(err.response)}`)
|
||||
//
|
||||
// assert.equal(err.response.status, 429)
|
||||
// assert.include(err.response.data.error, 'Too many requests')
|
||||
// }
|
||||
// })
|
||||
|
||||
it('should unlock pro-tier for a valid JWT token', async () => {
|
||||
try {
|
||||
|
||||
+35
-35
@@ -105,14 +105,14 @@ describe('#route-ratelimits & jwt-auth', () => {
|
||||
})
|
||||
|
||||
describe('#calcPoints', () => {
|
||||
it('should return 30 points for anonymous user', () => {
|
||||
it('should return 300 points for anonymous user', () => {
|
||||
const result = rateLimits.calcPoints()
|
||||
// console.log(`result: ${result}`)
|
||||
|
||||
assert.equal(result, 30)
|
||||
assert.equal(result, 300)
|
||||
})
|
||||
|
||||
it('should return 10 points for free tier requesting full node access', () => {
|
||||
it('should return 100 points for free tier requesting full node access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 10,
|
||||
resource: 'blockchain',
|
||||
@@ -120,10 +120,10 @@ describe('#route-ratelimits & jwt-auth', () => {
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 10)
|
||||
assert.equal(result, 100)
|
||||
})
|
||||
|
||||
it('should return 10 points for free tier requesting indexer access', () => {
|
||||
it('should return 100 points for free tier requesting indexer access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 10,
|
||||
resource: 'blockbook',
|
||||
@@ -131,10 +131,10 @@ describe('#route-ratelimits & jwt-auth', () => {
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 10)
|
||||
assert.equal(result, 100)
|
||||
})
|
||||
|
||||
it('should return 10 points for free tier requesting SLPDB access', () => {
|
||||
it('should return 100 points for free tier requesting SLPDB access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 10,
|
||||
resource: 'slp',
|
||||
@@ -142,10 +142,10 @@ describe('#route-ratelimits & jwt-auth', () => {
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 10)
|
||||
assert.equal(result, 100)
|
||||
})
|
||||
|
||||
it('should return 1 point for full node tier requesting full node access', () => {
|
||||
it('should return 10 points for full node tier requesting full node access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 20,
|
||||
resource: 'blockchain',
|
||||
@@ -153,10 +153,10 @@ describe('#route-ratelimits & jwt-auth', () => {
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 1)
|
||||
assert.equal(result, 10)
|
||||
})
|
||||
|
||||
it('should return 10 points for full-node tier requesting indexer access', () => {
|
||||
it('should return 100 points for full-node tier requesting indexer access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 20,
|
||||
resource: 'blockbook',
|
||||
@@ -164,10 +164,10 @@ describe('#route-ratelimits & jwt-auth', () => {
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 10)
|
||||
assert.equal(result, 100)
|
||||
})
|
||||
|
||||
it('should return 10 points for full node tier requesting SLPDB access', () => {
|
||||
it('should return 100 points for full node tier requesting SLPDB access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 20,
|
||||
resource: 'slp',
|
||||
@@ -175,10 +175,10 @@ describe('#route-ratelimits & jwt-auth', () => {
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 10)
|
||||
assert.equal(result, 100)
|
||||
})
|
||||
|
||||
it('should return 1 point for indexer tier requesting full node access', () => {
|
||||
it('should return 10 point for indexer tier requesting full node access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 30,
|
||||
resource: 'blockchain',
|
||||
@@ -186,32 +186,32 @@ describe('#route-ratelimits & jwt-auth', () => {
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 1)
|
||||
assert.equal(result, 10)
|
||||
})
|
||||
|
||||
it('should return 1 points for indexer tier requesting indexer access', () => {
|
||||
it('should return 10 points for indexer tier requesting indexer access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 30,
|
||||
resource: 'blockbook',
|
||||
id: '5e3a0415eb29a962da2708b4'
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 1)
|
||||
})
|
||||
|
||||
it('should return 10 points for indexer tier requesting SLPDB access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 30,
|
||||
resource: 'slp',
|
||||
id: '5e3a0415eb29a962da2708b4'
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 10)
|
||||
})
|
||||
|
||||
it('should return 1 point for SLP tier requesting full node access', () => {
|
||||
it('should return 100 points for indexer tier requesting SLPDB access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 30,
|
||||
resource: 'slp',
|
||||
id: '5e3a0415eb29a962da2708b4'
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 100)
|
||||
})
|
||||
|
||||
it('should return 10 point for SLP tier requesting full node access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 40,
|
||||
resource: 'blockchain',
|
||||
@@ -219,10 +219,10 @@ describe('#route-ratelimits & jwt-auth', () => {
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 1)
|
||||
assert.equal(result, 10)
|
||||
})
|
||||
|
||||
it('should return 1 points for SLP tier requesting indexer access', () => {
|
||||
it('should return 10 points for SLP tier requesting indexer access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 40,
|
||||
resource: 'blockbook',
|
||||
@@ -230,10 +230,10 @@ describe('#route-ratelimits & jwt-auth', () => {
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 1)
|
||||
assert.equal(result, 10)
|
||||
})
|
||||
|
||||
it('should return 1 points for SLP tier requesting SLPDB access', () => {
|
||||
it('should return 10 points for SLP tier requesting SLPDB access', () => {
|
||||
const jwtInfo = {
|
||||
apiLevel: 40,
|
||||
resource: 'slp',
|
||||
@@ -241,7 +241,7 @@ describe('#route-ratelimits & jwt-auth', () => {
|
||||
}
|
||||
|
||||
const result = rateLimits.calcPoints(jwtInfo)
|
||||
assert.equal(result, 1)
|
||||
assert.equal(result, 10)
|
||||
})
|
||||
})
|
||||
|
||||
@@ -442,7 +442,7 @@ describe('#route-ratelimits & jwt-auth', () => {
|
||||
|
||||
// Issues with token secret should treat incoming requests as anonymous
|
||||
// calls with 30 points or 3 RPM.
|
||||
assert.equal(res.locals.pointsToConsume, 30)
|
||||
assert.equal(res.locals.pointsToConsume, 300)
|
||||
})
|
||||
})
|
||||
})
|
||||
|
||||
Reference in New Issue
Block a user