remove unused code
This commit is contained in:
parent
d568f5780a
commit
9b3b85cddc
1 changed files with 1 additions and 61 deletions
|
|
@ -66,66 +66,6 @@ module.exports = (
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
const parseJSON = data => {
|
|
||||||
try {
|
|
||||||
if (typeof data === 'string') {
|
|
||||||
return JSON.parse(data)
|
|
||||||
}
|
|
||||||
|
|
||||||
return data
|
|
||||||
} catch (err) {
|
|
||||||
return data
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const decryptEvent = ({ eventName, data, socket }) => {
|
|
||||||
try {
|
|
||||||
const deviceId = socket.handshake.query['x-shockwallet-device-id']
|
|
||||||
if (Encryption.isNonEncrypted(eventName)) {
|
|
||||||
return data
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!data) {
|
|
||||||
return data
|
|
||||||
}
|
|
||||||
|
|
||||||
const parsedData = parseJSON(data)
|
|
||||||
|
|
||||||
if (!deviceId) {
|
|
||||||
throw {
|
|
||||||
field: 'deviceId',
|
|
||||||
message: 'Please specify a device ID'
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!Encryption.isAuthorizedDevice({ deviceId })) {
|
|
||||||
throw {
|
|
||||||
field: 'deviceId',
|
|
||||||
message: 'Please exchange keys with the API before using the socket'
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const decryptedKey = Encryption.decryptKey({
|
|
||||||
deviceId,
|
|
||||||
message: parsedData.encryptedKey
|
|
||||||
})
|
|
||||||
const decryptedMessage = Encryption.decryptMessage({
|
|
||||||
message: parsedData.encryptedData,
|
|
||||||
key: decryptedKey,
|
|
||||||
iv: parsedData.iv
|
|
||||||
})
|
|
||||||
const decryptedData = JSON.parse(decryptedMessage)
|
|
||||||
return decryptedData
|
|
||||||
} catch (err) {
|
|
||||||
logger.error(
|
|
||||||
`[SOCKET] An error has occurred while decrypting an event (${eventName}):`,
|
|
||||||
err
|
|
||||||
)
|
|
||||||
|
|
||||||
return socket.emit('encryption:error', err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const onNewInvoice = (socket, subID) => {
|
const onNewInvoice = (socket, subID) => {
|
||||||
const { lightning } = LightningServices.services
|
const { lightning } = LightningServices.services
|
||||||
logger.warn('Subscribing to invoices socket...' + subID)
|
logger.warn('Subscribing to invoices socket...' + subID)
|
||||||
|
|
@ -677,7 +617,7 @@ module.exports = (
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param {Common.Schema.SimpleReceivedRequest[]} receivedReqs
|
* @param {ReadonlyArray<Common.SimpleReceivedRequest>} receivedReqs
|
||||||
*/
|
*/
|
||||||
const onReceivedReqs = receivedReqs => {
|
const onReceivedReqs = receivedReqs => {
|
||||||
const processed = receivedReqs.map(({ id, requestorPK, timestamp }) => {
|
const processed = receivedReqs.map(({ id, requestorPK, timestamp }) => {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue