aiolabs/lightning-pub
2
0
Fork 0
Code Issues 9 Pull requests 4 Projects Releases Packages Wiki Activity Actions

ignore clock skew errrs (numbers)

Browse source
This commit is contained in:
Daniel Lugo 2020-08-03 10:56:11 -04:00
parent 1fb7587374
commit ee5e2951cb
6 changed files with 49 additions and 49 deletions
Download patch file Download diff file Expand all files Collapse all files

6
services/gunDB/Mediator/index.js
View file

@ -280,7 +280,7 @@ const authenticate = async (alias, pass, __user) => {
unused: null unused: null
}, },
ack => { ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(`Error initializing follows: ${ack.err}`)) rej(new Error(`Error initializing follows: ${ack.err}`))
} else { } else {
res() res()
@ -311,7 +311,7 @@ const authenticate = async (alias, pass, __user) => {
unused: null unused: null
}, },
ack => { ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(`Error initializing follows: ${ack.err}`)) rej(new Error(`Error initializing follows: ${ack.err}`))
} else { } else {
res() res()
@ -371,7 +371,7 @@ const authenticate = async (alias, pass, __user) => {
unused: null unused: null
}, },
ack => { ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(`Error initializing follows: ${ack.err}`)) rej(new Error(`Error initializing follows: ${ack.err}`))
} else { } else {
res() res()

76
services/gunDB/contact-api/actions.js
View file

@ -71,7 +71,7 @@ const __createOutgoingFeed = async (withPublicKey, user, SEA) => {
const _outFeedNode = user const _outFeedNode = user
.get(Key.OUTGOINGS) .get(Key.OUTGOINGS)
.set(newPartialOutgoingFeed, ack => { .set(newPartialOutgoingFeed, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res(_outFeedNode._.get) res(_outFeedNode._.get)
@ -95,7 +95,7 @@ const __createOutgoingFeed = async (withPublicKey, user, SEA) => {
.get(newOutgoingFeedID) .get(newOutgoingFeedID)
.get(Key.MESSAGES) .get(Key.MESSAGES)
.set(initialMsg, ack => { .set(initialMsg, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -113,7 +113,7 @@ const __createOutgoingFeed = async (withPublicKey, user, SEA) => {
.get(Key.RECIPIENT_TO_OUTGOING) .get(Key.RECIPIENT_TO_OUTGOING)
.get(withPublicKey) .get(withPublicKey)
.put(encryptedForMeNewOutgoingFeedID, ack => { .put(encryptedForMeNewOutgoingFeedID, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(Error(ack.err)) rej(Error(ack.err))
} else { } else {
res() res()
@ -230,7 +230,7 @@ const acceptRequest = async (
.get(Key.USER_TO_INCOMING) .get(Key.USER_TO_INCOMING)
.get(senderPublicKey) .get(senderPublicKey)
.put(encryptedForMeIncomingID, ack => { .put(encryptedForMeIncomingID, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -259,7 +259,7 @@ const acceptRequest = async (
response: encryptedForUsOutgoingID response: encryptedForUsOutgoingID
}, },
ack => { ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -297,7 +297,7 @@ const authenticate = (user, pass, userNode) =>
} }
userNode.auth(user, pass, ack => { userNode.auth(user, pass, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else if (!userNode.is) { } else if (!userNode.is) {
reject(new Error('authentication failed')) reject(new Error('authentication failed'))
@ -320,7 +320,7 @@ const blacklist = (publicKey, user) =>
} }
user.get(Key.BLACKLIST).set(publicKey, ack => { user.get(Key.BLACKLIST).set(publicKey, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -339,7 +339,7 @@ const generateHandshakeAddress = async () => {
await new Promise((res, rej) => { await new Promise((res, rej) => {
user.get(Key.CURRENT_HANDSHAKE_ADDRESS).put(address, ack => { user.get(Key.CURRENT_HANDSHAKE_ADDRESS).put(address, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -352,7 +352,7 @@ const generateHandshakeAddress = async () => {
.get(Key.HANDSHAKE_NODES) .get(Key.HANDSHAKE_NODES)
.get(address) .get(address)
.put({ unused: 0 }, ack => { .put({ unused: 0 }, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -380,7 +380,7 @@ const cleanup = async pub => {
.get(Key.USER_TO_INCOMING) .get(Key.USER_TO_INCOMING)
.get(pub) .get(pub)
.put(null, ack => { .put(null, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -395,7 +395,7 @@ const cleanup = async pub => {
.get(Key.RECIPIENT_TO_OUTGOING) .get(Key.RECIPIENT_TO_OUTGOING)
.get(pub) .get(pub)
.put(null, ack => { .put(null, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -410,7 +410,7 @@ const cleanup = async pub => {
.get(Key.USER_TO_LAST_REQUEST_SENT) .get(Key.USER_TO_LAST_REQUEST_SENT)
.get(pub) .get(pub)
.put(null, ack => { .put(null, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -426,7 +426,7 @@ const cleanup = async pub => {
.get(Key.OUTGOINGS) .get(Key.OUTGOINGS)
.get(outGoingID) .get(outGoingID)
.put(null, ack => { .put(null, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -588,7 +588,7 @@ const sendHandshakeRequest = async (recipientPublicKey, gun, user, SEA) => {
.get(Key.HANDSHAKE_NODES) .get(Key.HANDSHAKE_NODES)
.get(currentHandshakeAddress) .get(currentHandshakeAddress)
.set(handshakeRequestData, ack => { .set(handshakeRequestData, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(`Error trying to create request: ${ack.err}`)) rej(new Error(`Error trying to create request: ${ack.err}`))
} else { } else {
res(hr._.get) res(hr._.get)
@ -601,7 +601,7 @@ const sendHandshakeRequest = async (recipientPublicKey, gun, user, SEA) => {
.get(Key.USER_TO_LAST_REQUEST_SENT) .get(Key.USER_TO_LAST_REQUEST_SENT)
.get(recipientPublicKey) .get(recipientPublicKey)
.put(newHandshakeRequestID, ack => { .put(newHandshakeRequestID, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -624,7 +624,7 @@ const sendHandshakeRequest = async (recipientPublicKey, gun, user, SEA) => {
await new Promise((res, rej) => { await new Promise((res, rej) => {
user.get(Key.STORED_REQS).set(storedReq, ack => { user.get(Key.STORED_REQS).set(storedReq, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej( rej(
new Error( new Error(
`Error saving newly created request to sent requests: ${ack.err}` `Error saving newly created request to sent requests: ${ack.err}`
@ -700,7 +700,7 @@ const sendMessageNew = async (recipientPublicKey, body, user, SEA) => {
.get(outgoingID) .get(outgoingID)
.get(Key.MESSAGES) .get(Key.MESSAGES)
.set(newMessage, ack => { .set(newMessage, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res({ res({
@ -773,7 +773,7 @@ const deleteMessage = async (recipientPub, msgID, user) => {
.get(Key.MESSAGES) .get(Key.MESSAGES)
.get(msgID) .get(msgID)
.put(null, ack => { .put(null, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -810,7 +810,7 @@ const setAvatar = (avatar, user) =>
.get(Key.PROFILE) .get(Key.PROFILE)
.get(Key.AVATAR) .get(Key.AVATAR)
.put(avatar, ack => { .put(avatar, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -843,7 +843,7 @@ const setDisplayName = (displayName, user) =>
.get(Key.PROFILE) .get(Key.PROFILE)
.get(Key.DISPLAY_NAME) .get(Key.DISPLAY_NAME)
.put(displayName, ack => { .put(displayName, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -955,7 +955,7 @@ const sendPayment = async (to, amount, memo) => {
.get(Key.ORDER_NODES) .get(Key.ORDER_NODES)
.get(currOrderAddress) .get(currOrderAddress)
.set(order, ack => { .set(order, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej( rej(
new Error( new Error(
`Error writing order to order node: ${currOrderAddress} for pub: ${to}: ${ack.err}` `Error writing order to order node: ${currOrderAddress} for pub: ${to}: ${ack.err}`
@ -1123,7 +1123,7 @@ const generateOrderAddress = user =>
const address = uuidv1() const address = uuidv1()
user.get(Key.CURRENT_ORDER_ADDRESS).put(address, ack => { user.get(Key.CURRENT_ORDER_ADDRESS).put(address, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -1156,7 +1156,7 @@ const setBio = (bio, user) =>
} }
user.get(Key.BIO).put(bio, ack => { user.get(Key.BIO).put(bio, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -1169,7 +1169,7 @@ const setBio = (bio, user) =>
.get(Key.PROFILE) .get(Key.PROFILE)
.get(Key.BIO) .get(Key.BIO)
.put(bio, ack => { .put(bio, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -1198,7 +1198,7 @@ const saveSeedBackup = async (mnemonicPhrase, user, SEA) => {
return new Promise((res, rej) => { return new Promise((res, rej) => {
user.get(Key.SEED_BACKUP).put(encryptedSeed, ack => { user.get(Key.SEED_BACKUP).put(encryptedSeed, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -1221,7 +1221,7 @@ const saveChannelsBackup = async (backups, user, SEA) => {
const encryptBackups = await SEA.encrypt(backups, mySecret) const encryptBackups = await SEA.encrypt(backups, mySecret)
return new Promise((res, rej) => { return new Promise((res, rej) => {
user.get(Key.CHANNELS_BACKUP).put(encryptBackups, ack => { user.get(Key.CHANNELS_BACKUP).put(encryptBackups, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -1251,7 +1251,7 @@ const setLastSeenApp = () =>
.getUser() .getUser()
.get(Key.LAST_SEEN_APP) .get(Key.LAST_SEEN_APP)
.put(Date.now(), ack => { .put(Date.now(), ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -1265,7 +1265,7 @@ const setLastSeenApp = () =>
.get(Key.PROFILE) .get(Key.PROFILE)
.get(Key.LAST_SEEN_APP) .get(Key.LAST_SEEN_APP)
.put(Date.now(), ack => { .put(Date.now(), ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -1348,7 +1348,7 @@ const createPost = async (tags, title, content) => {
} }
}, },
ack => { ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} }
@ -1373,7 +1373,7 @@ const createPost = async (tags, title, content) => {
title title
}, },
ack => { ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res(_n._.get) res(_n._.get)
@ -1389,7 +1389,7 @@ const createPost = async (tags, title, content) => {
.get(Key.WALL) .get(Key.WALL)
.get(Key.NUM_OF_PAGES) .get(Key.NUM_OF_PAGES)
.put(numOfPages + 1, ack => { .put(numOfPages + 1, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
throw new Error(ack.err) throw new Error(ack.err)
} }
@ -1414,7 +1414,7 @@ const createPost = async (tags, title, content) => {
new Promise(res => { new Promise(res => {
// @ts-ignore // @ts-ignore
contentItems.set(ci, ack => { contentItems.set(ci, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
throw new Error(ack.err) throw new Error(ack.err)
} }
@ -1433,7 +1433,7 @@ const createPost = async (tags, title, content) => {
.get(Key.POSTS) .get(Key.POSTS)
.get(postID) .get(postID)
.put(null, ack => { .put(null, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
throw new Error(ack.err) throw new Error(ack.err)
} }
@ -1508,7 +1508,7 @@ const follow = (publicKey, isPrivate) => {
.get(publicKey) .get(publicKey)
// @ts-ignore // @ts-ignore
.put(newFollow, ack => { .put(newFollow, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -1528,7 +1528,7 @@ const unfollow = publicKey =>
.get(Key.FOLLOWS) .get(Key.FOLLOWS)
.get(publicKey) .get(publicKey)
.put(null, ack => { .put(null, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -1551,7 +1551,7 @@ const initWall = async () => {
.get(Key.WALL) .get(Key.WALL)
.get(Key.NUM_OF_PAGES) .get(Key.NUM_OF_PAGES)
.put(0, ack => { .put(0, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -1572,7 +1572,7 @@ const initWall = async () => {
unused: null unused: null
}, },
ack => { ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -1590,7 +1590,7 @@ const initWall = async () => {
.get('0') .get('0')
.get(Key.COUNT) .get(Key.COUNT)
.put(0, ack => { .put(0, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()

4
services/gunDB/contact-api/jobs/lastSeenNode.js
View file

@ -33,7 +33,7 @@ const lastSeenNode = user => {
setInterval(() => { setInterval(() => {
if (user.is) { if (user.is) {
user.get(Key.LAST_SEEN_NODE).put(Date.now(), ack => { user.get(Key.LAST_SEEN_NODE).put(Date.now(), ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
logger.error(`Error inside lastSeenNode job: ${ack.err}`) logger.error(`Error inside lastSeenNode job: ${ack.err}`)
} }
}) })
@ -42,7 +42,7 @@ const lastSeenNode = user => {
.get(Key.PROFILE) .get(Key.PROFILE)
.get(Key.LAST_SEEN_NODE) .get(Key.LAST_SEEN_NODE)
.put(Date.now(), ack => { .put(Date.now(), ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
logger.error(`Error inside lastSeenNode job: ${ack.err}`) logger.error(`Error inside lastSeenNode job: ${ack.err}`)
} }
}) })

4
services/gunDB/contact-api/jobs/onAcceptedRequests.js
View file

@ -156,7 +156,7 @@ const onAcceptedRequests = (user, SEA) => {
.get(Key.USER_TO_INCOMING) .get(Key.USER_TO_INCOMING)
.get(recipientPub) .get(recipientPub)
.put(encryptedForMeIncomingID, ack => { .put(encryptedForMeIncomingID, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -169,7 +169,7 @@ const onAcceptedRequests = (user, SEA) => {
.get(Key.STORED_REQS) .get(Key.STORED_REQS)
.get(id) .get(id)
.put(null, ack => { .put(null, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()

4
services/gunDB/contact-api/jobs/onOrders.js
View file

@ -141,7 +141,7 @@ const listenerForAddr = (addr, SEA) => async (order, orderID) => {
.get(Key.ORDER_TO_RESPONSE) .get(Key.ORDER_TO_RESPONSE)
.get(orderID) .get(orderID)
.put(orderResponse, ack => { .put(orderResponse, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej( rej(
new Error( new Error(
`Error saving encrypted invoice to order to response usergraph: ${ack}` `Error saving encrypted invoice to order to response usergraph: ${ack}`
@ -170,7 +170,7 @@ const listenerForAddr = (addr, SEA) => async (order, orderID) => {
.get(Key.ORDER_TO_RESPONSE) .get(Key.ORDER_TO_RESPONSE)
.get(orderID) .get(orderID)
.put(orderResponse, ack => { .put(orderResponse, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
logger.error( logger.error(
`Error saving encrypted invoice to order to response usergraph: ${ack}` `Error saving encrypted invoice to order to response usergraph: ${ack}`
) )

4
services/gunDB/contact-api/utils/promisifygun.js
View file

@ -20,7 +20,7 @@ const promisify = node => {
pnode.put = data => pnode.put = data =>
new Promise((res, rej) => { new Promise((res, rej) => {
oldPut(data, ack => { oldPut(data, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -31,7 +31,7 @@ const promisify = node => {
pnode.set = data => pnode.set = data =>
new Promise((res, rej) => { new Promise((res, rej) => {
oldSet(data, ack => { oldSet(data, ack => {
if (ack.err) { if (ack.err && typeof ack.err !== 'number') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()