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

respect NOT_AUTH constnat

Browse source
This commit is contained in:
Daniel Lugo 2020-08-27 15:57:54 -04:00
parent 940fbfc96c
commit 90755ae0a1
4 changed files with 31 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -246,7 +246,7 @@ const getGun = () => {
const getUser = () => { const getUser = () => {
if (!user.is) { if (!user.is) {
logger.warn('called getUser() without being authed') logger.warn('called getUser() without being authed')
throw new Error('NOT_AUTH') throw new Error(Constants.ErrorCode.NOT_AUTH)
} }
return user return user
} }

3
services/gunDB/contact-api/streams/lastSentReqID.js
View file

@ -1,5 +1,6 @@
/** @format */ /** @format */
const logger = require('winston') const logger = require('winston')
const { Constants } = require('shock-common')
const Key = require('../key') const Key = require('../key')
@ -23,7 +24,7 @@ const onLastSentReqIDs = cb => {
const user = require('../../Mediator').getUser() const user = require('../../Mediator').getUser()
if (!user.is) { if (!user.is) {
logger.warn('lastSentReqID() -> tried to sub without authing') logger.warn('lastSentReqID() -> tried to sub without authing')
throw new Error('NOT_AUTH') throw new Error(Constants.ErrorCode.NOT_AUTH)
} }
user.get(Key.USER_TO_LAST_REQUEST_SENT).open(data => { user.get(Key.USER_TO_LAST_REQUEST_SENT).open(data => {

6
services/gunDB/contact-api/utils/index.js
View file

@ -129,7 +129,7 @@ const tryAndWait = async (promGen, shouldRetry = () => false) => {
} catch (e) { } catch (e) {
logger.error(e) logger.error(e)
logger.info(JSON.stringify(e)) logger.info(JSON.stringify(e))
if (e.message === 'NOT_AUTH') { if (e.message === Constants.ErrorCode.NOT_AUTH) {
throw e throw e
} }
} }
@ -159,7 +159,7 @@ const tryAndWait = async (promGen, shouldRetry = () => false) => {
} }
} catch (e) { } catch (e) {
logger.error(e) logger.error(e)
if (e.message === 'NOT_AUTH') { if (e.message === Constants.ErrorCode.NOT_AUTH) {
throw e throw e
} }
} }
@ -189,7 +189,7 @@ const tryAndWait = async (promGen, shouldRetry = () => false) => {
} }
} catch (e) { } catch (e) {
logger.error(e) logger.error(e)
if (e.message === 'NOT_AUTH') { if (e.message === Constants.ErrorCode.NOT_AUTH) {
throw e throw e
} }
} }

40
src/routes.js
View file

@ -1944,9 +1944,11 @@ module.exports = async (
} catch (err) { } catch (err) {
logger.info('Error in Chats poll:') logger.info('Error in Chats poll:')
logger.error(err) logger.error(err)
res.status(err.message === 'NON_AUTH' ? 401 : 500).json({ res
errorMessage: typeof err === 'string' ? err : err.message .status(err.message === Common.Constants.ErrorCode.NOT_AUTH ? 401 : 500)
}) .json({
errorMessage: typeof err === 'string' ? err : err.message
})
} }
}) })
@ -1966,9 +1968,11 @@ module.exports = async (
} catch (err) { } catch (err) {
logger.info('Error in Avatar poll:') logger.info('Error in Avatar poll:')
logger.error(err) logger.error(err)
res.status(err.message === 'NON_AUTH' ? 401 : 500).json({ res
errorMessage: typeof err === 'string' ? err : err.message .status(err.message === Common.Constants.ErrorCode.NOT_AUTH ? 401 : 500)
}) .json({
errorMessage: typeof err === 'string' ? err : err.message
})
} }
}) })
@ -1988,9 +1992,11 @@ module.exports = async (
} catch (err) { } catch (err) {
logger.info('Error in Display Name poll:') logger.info('Error in Display Name poll:')
logger.error(err) logger.error(err)
res.status(err.message === 'NON_AUTH' ? 401 : 500).json({ res
errorMessage: typeof err === 'string' ? err : err.message .status(err.message === Common.Constants.ErrorCode.NOT_AUTH ? 401 : 500)
}) .json({
errorMessage: typeof err === 'string' ? err : err.message
})
} }
}) })
@ -2007,9 +2013,11 @@ module.exports = async (
} catch (err) { } catch (err) {
logger.info('Error in Handshake Address poll:') logger.info('Error in Handshake Address poll:')
logger.error(err) logger.error(err)
res.status(err.message === 'NON_AUTH' ? 401 : 500).json({ res
errorMessage: typeof err === 'string' ? err : err.message .status(err.message === Common.Constants.ErrorCode.NOT_AUTH ? 401 : 500)
}) .json({
errorMessage: typeof err === 'string' ? err : err.message
})
} }
}) })
@ -2024,9 +2032,11 @@ module.exports = async (
} catch (err) { } catch (err) {
logger.info('Error in BIO poll:') logger.info('Error in BIO poll:')
logger.error(err) logger.error(err)
res.status(err.message === 'NON_AUTH' ? 401 : 500).json({ res
errorMessage: typeof err === 'string' ? err : err.message .status(err.message === Common.Constants.ErrorCode.NOT_AUTH ? 401 : 500)
}) .json({
errorMessage: typeof err === 'string' ? err : err.message
})
} }
}) })
//////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////////////