sendMessageNew(), returns the created RES
This commit is contained in:
parent
2a68ff8743
commit
0088b7d8cf
2 changed files with 21 additions and 5 deletions
|
|
@ -631,9 +631,9 @@ const sendHandshakeRequest = async (recipientPublicKey, gun, user, SEA) => {
|
||||||
* @param {string} body
|
* @param {string} body
|
||||||
* @param {UserGUNNode} user
|
* @param {UserGUNNode} user
|
||||||
* @param {ISEA} SEA
|
* @param {ISEA} SEA
|
||||||
* @returns {Promise<string>} The message id.
|
* @returns {Promise<import('shock-common').Schema.ChatMessage>} The message id.
|
||||||
*/
|
*/
|
||||||
const sendMessage = async (recipientPublicKey, body, user, SEA) => {
|
const sendMessageNew = async (recipientPublicKey, body, user, SEA) => {
|
||||||
if (!user.is) {
|
if (!user.is) {
|
||||||
throw new Error(ErrorCode.NOT_AUTH)
|
throw new Error(ErrorCode.NOT_AUTH)
|
||||||
}
|
}
|
||||||
|
|
@ -691,12 +691,28 @@ const sendMessage = async (recipientPublicKey, body, user, SEA) => {
|
||||||
if (ack.err) {
|
if (ack.err) {
|
||||||
rej(new Error(ack.err))
|
rej(new Error(ack.err))
|
||||||
} else {
|
} else {
|
||||||
res(msgNode._.get)
|
res({
|
||||||
|
body,
|
||||||
|
id: msgNode._.get,
|
||||||
|
outgoing: true,
|
||||||
|
timestamp: newMessage.timestamp
|
||||||
|
})
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns the message id.
|
||||||
|
* @param {string} recipientPublicKey
|
||||||
|
* @param {string} body
|
||||||
|
* @param {UserGUNNode} user
|
||||||
|
* @param {ISEA} SEA
|
||||||
|
* @returns {Promise<string>} The message id.
|
||||||
|
*/
|
||||||
|
const sendMessage = async (recipientPublicKey, body, user, SEA) =>
|
||||||
|
(await sendMessageNew(recipientPublicKey, body, user, SEA)).id
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param {string} recipientPub
|
* @param {string} recipientPub
|
||||||
* @param {string} msgID
|
* @param {string} msgID
|
||||||
|
|
@ -1589,5 +1605,6 @@ module.exports = {
|
||||||
deletePost,
|
deletePost,
|
||||||
follow,
|
follow,
|
||||||
unfollow,
|
unfollow,
|
||||||
initWall
|
initWall,
|
||||||
|
sendMessageNew
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -98,7 +98,6 @@ const listenerForAddr = addr => data => {
|
||||||
}
|
}
|
||||||
|
|
||||||
logger.info('data for address length: ' + size(addr))
|
logger.info('data for address length: ' + size(addr))
|
||||||
logger.info(JSON.stringify(data, null, 4))
|
|
||||||
|
|
||||||
react()
|
react()
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue