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

Ingore empty object "{}" error acks from gun

Browse source
This commit is contained in:
Daniel Lugo 2021-09-19 12:01:36 -04:00
parent 350ae42e33
commit bdcc4a06f3
6 changed files with 183 additions and 39 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -58,7 +58,11 @@ const authenticate = (user, pass, userNode) =>
} }
userNode.auth(user, pass, ack => { userNode.auth(user, pass, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
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'))
@ -81,7 +85,11 @@ const blacklist = (publicKey, user) =>
} }
user.get(Key.BLACKLIST).set(publicKey, ack => { user.get(Key.BLACKLIST).set(publicKey, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -100,7 +108,11 @@ const generateHandshakeAddress = async () => {
await /** @type {Promise<void>} */ (new Promise((res, rej) => { await /** @type {Promise<void>} */ (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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -113,7 +125,11 @@ 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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -150,7 +166,11 @@ const setAvatar = (avatar, user) =>
.get(Key.PROFILE_BINARY) .get(Key.PROFILE_BINARY)
.get(Key.AVATAR) .get(Key.AVATAR)
.put(avatar, ack => { .put(avatar, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -183,7 +203,11 @@ 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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -210,7 +234,11 @@ const setDefaultSeedProvider = (encryptedSeedProvider, user) =>
user user
.get('preferencesSeedServiceProvider') .get('preferencesSeedServiceProvider')
.put(encryptedSeedProvider, ack => { .put(encryptedSeedProvider, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -235,7 +263,11 @@ const setSeedServiceData = (encryptedSeedServiceData, user) =>
user user
.get('preferencesSeedServiceData') .get('preferencesSeedServiceData')
.put(encryptedSeedServiceData, ack => { .put(encryptedSeedServiceData, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -258,7 +290,11 @@ const setCurrentStreamInfo = (encryptedCurrentStreamInfo, user) =>
throw new TypeError() throw new TypeError()
} }
user.get('currentStreamInfo').put(encryptedCurrentStreamInfo, ack => { user.get('currentStreamInfo').put(encryptedCurrentStreamInfo, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -368,7 +404,11 @@ const sendSpontaneousPayment = async (
.get(currOrderAddress) .get(currOrderAddress)
//@ts-ignore //@ts-ignore
.set(order, ack => { .set(order, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
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}`
@ -589,7 +629,11 @@ 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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -622,7 +666,11 @@ const setBio = (bio, user) =>
} }
user.get(Key.BIO).put(bio, ack => { user.get(Key.BIO).put(bio, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -635,7 +683,11 @@ 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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
reject(new Error(ack.err)) reject(new Error(ack.err))
} else { } else {
resolve() resolve()
@ -664,7 +716,11 @@ 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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -687,7 +743,11 @@ 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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -705,7 +765,11 @@ 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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -719,7 +783,11 @@ 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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -771,7 +839,11 @@ const createPostNew = async (tags, title, content) => {
// @ts-expect-error // @ts-expect-error
newPost, newPost,
ack => { ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res(_n._.get) res(_n._.get)
@ -798,7 +870,11 @@ const deletePost = async (postId, page) => {
.get(Key.POSTS) .get(Key.POSTS)
.get(postId) .get(postId)
.put(null, ack => { .put(null, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -827,7 +903,11 @@ const follow = async (publicKey, isPrivate) => {
.get(publicKey) .get(publicKey)
// @ts-ignore // @ts-ignore
.put(newFollow, ack => { .put(newFollow, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -847,7 +927,11 @@ const unfollow = publicKey =>
.get(Key.FOLLOWS) .get(Key.FOLLOWS)
.get(publicKey) .get(publicKey)
.put(null, ack => { .put(null, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -870,7 +954,11 @@ 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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -891,7 +979,11 @@ const initWall = async () => {
unused: null unused: null
}, },
ack => { ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -909,7 +1001,11 @@ const initWall = async () => {
.get('0') .get('0')
.get(Key.COUNT) .get(Key.COUNT)
.put(0, ack => { .put(0, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()

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

@ -42,7 +42,11 @@ const lastSeenNode = user => {
} }
gotLatestUserAck = false gotLatestUserAck = false
user.get(Key.LAST_SEEN_NODE).put(Date.now(), ack => { user.get(Key.LAST_SEEN_NODE).put(Date.now(), ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
logger.error(`Error inside lastSeenNode user job: ${ack.err}`) logger.error(`Error inside lastSeenNode user job: ${ack.err}`)
} }
gotLatestUserAck = true gotLatestUserAck = true
@ -61,7 +65,11 @@ 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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
logger.error(`Error inside lastSeenNode profile job: ${ack.err}`) logger.error(`Error inside lastSeenNode profile job: ${ack.err}`)
} }
gotLatestProfileAck = true gotLatestProfileAck = true

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

@ -229,7 +229,11 @@ const listenerForAddr = (addr, SEA) => async (order, orderID) => {
.get(orderID) .get(orderID)
// @ts-expect-error // @ts-expect-error
.put(orderResponse, ack => { .put(orderResponse, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
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}`
@ -290,7 +294,11 @@ const listenerForAddr = (addr, SEA) => async (order, orderID) => {
.get(Key.ORDER_TO_RESPONSE) .get(Key.ORDER_TO_RESPONSE)
.get(ackNode) .get(ackNode)
.put(ordResponse, ack => { .put(ordResponse, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej( rej(
new Error( new Error(
`Error saving encrypted orderAck to order to response usergraph: ${ack}` `Error saving encrypted orderAck to order to response usergraph: ${ack}`
@ -378,7 +386,11 @@ const listenerForAddr = (addr, SEA) => async (order, orderID) => {
.get(Key.ORDER_TO_RESPONSE) .get(Key.ORDER_TO_RESPONSE)
.get(ackNode) .get(ackNode)
.put(ordResponse, ack => { .put(ordResponse, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej( rej(
new Error( new Error(
`Error saving encrypted orderAck to order to response usergraph: ${ack}` `Error saving encrypted orderAck to order to response usergraph: ${ack}`
@ -425,7 +437,11 @@ const listenerForAddr = (addr, SEA) => async (order, orderID) => {
.get(Key.ORDER_TO_RESPONSE) .get(Key.ORDER_TO_RESPONSE)
.get(ackNode) .get(ackNode)
.put(serviceResponse, ack => { .put(serviceResponse, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej( rej(
new Error( new Error(
`Error saving encrypted orderAck to order to response usergraph: ${ack}` `Error saving encrypted orderAck to order to response usergraph: ${ack}`
@ -489,7 +505,11 @@ const listenerForAddr = (addr, SEA) => async (order, orderID) => {
.get(orderID) .get(orderID)
// @ts-expect-error // @ts-expect-error
.put(orderResponse, ack => { .put(orderResponse, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
logger.error( logger.error(
`Error saving encrypted invoice to order to response usergraph: ${ack}` `Error saving encrypted invoice to order to response usergraph: ${ack}`
) )
@ -516,7 +536,11 @@ const listenerForAddr = (addr, SEA) => async (order, orderID) => {
.get(orderID) .get(orderID)
// @ts-expect-error // @ts-expect-error
.put(orderResponse, ack => { .put(orderResponse, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
logger.error( logger.error(
`Error saving encrypted invoice to order to response usergraph: ${ack}` `Error saving encrypted invoice to order to response usergraph: ${ack}`
) )

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

@ -20,7 +20,11 @@ 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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
@ -31,7 +35,11 @@ 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 && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()

12
services/gunDB/rpc/index.js
View file

@ -205,7 +205,11 @@ const put = async (rawPath, value) => {
} /* is primitive */ else { } /* is primitive */ else {
await makePromise((res, rej) => { await makePromise((res, rej) => {
node.put(/** @type {ValidDataValue} */ (theValue), ack => { node.put(/** @type {ValidDataValue} */ (theValue), ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
if (typeof ack.err === 'string') { if (typeof ack.err === 'string') {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
@ -290,7 +294,11 @@ async function set(rawPath, value) {
const id = await makePromise((res, rej) => { const id = await makePromise((res, rej) => {
const subNode = node.set(theValue, ack => { const subNode = node.set(theValue, ack => {
if (ack.err && typeof ack.err !== 'number') { if (
ack.err &&
typeof ack.err !== 'number' &&
typeof ack.err !== 'object'
) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res(subNode._.get) res(subNode._.get)

6
services/schema/index.js
View file

@ -201,7 +201,7 @@ const AddTmpChainOrder = async (address, orderInfo) => {
.get(Key.TMP_CHAIN_COORDINATE) .get(Key.TMP_CHAIN_COORDINATE)
.get(addressSHA256) .get(addressSHA256)
.put(encryptedOrderString, ack => { .put(encryptedOrderString, ack => {
if (ack.err && typeof ack.err !== 'number') { if (ack.err && typeof ack.err !== 'number' && typeof ack.err !== 'object') {
rej( rej(
new Error( new Error(
`Error saving tmp chain coordinate order to user-graph: ${ack}` `Error saving tmp chain coordinate order to user-graph: ${ack}`
@ -268,7 +268,7 @@ const clearTmpChainOrder = async (address) => {
.get(Key.TMP_CHAIN_COORDINATE) .get(Key.TMP_CHAIN_COORDINATE)
.get(addressSHA256) .get(addressSHA256)
.put(null, ack => { .put(null, ack => {
if (ack.err && typeof ack.err !== 'number') { if (ack.err && typeof ack.err !== 'number' && typeof ack.err !== 'object') {
rej( rej(
new Error( new Error(
`Error nulling tmp chain coordinate order to user-graph: ${ack}` `Error nulling tmp chain coordinate order to user-graph: ${ack}`
@ -370,7 +370,7 @@ class SchemaManager {
.get(Key.COORDINATES) .get(Key.COORDINATES)
.get(coordinateSHA256) .get(coordinateSHA256)
.put(encryptedOrderString, ack => { .put(encryptedOrderString, ack => {
if (ack.err && typeof ack.err !== 'number') { if (ack.err && typeof ack.err !== 'number' && typeof ack.err !== 'object') {
logger.info(ack) logger.info(ack)
rej( rej(
new Error( new Error(