follows-related actions
This commit is contained in:
parent
154f9e3a10
commit
924d2ce25e
1 changed files with 51 additions and 1 deletions
|
|
@ -1218,6 +1218,54 @@ const setLastSeenApp = () =>
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param {string} publicKey
|
||||||
|
* @param {boolean} isPrivate
|
||||||
|
* @returns {Promise<string>}
|
||||||
|
*/
|
||||||
|
const follow = (publicKey, isPrivate = false) => {
|
||||||
|
/** @type {import('shock-common').Schema.Follow} */
|
||||||
|
const newFollow = {
|
||||||
|
private: isPrivate,
|
||||||
|
status: 'ok',
|
||||||
|
user: publicKey
|
||||||
|
}
|
||||||
|
|
||||||
|
return new Promise((res, rej) => {
|
||||||
|
require('../Mediator')
|
||||||
|
.getUser()
|
||||||
|
.get(Key.FOLLOWS)
|
||||||
|
.get(publicKey)
|
||||||
|
// @ts-ignore
|
||||||
|
.put(newFollow, ack => {
|
||||||
|
if (ack.err) {
|
||||||
|
rej(ack.err)
|
||||||
|
} else {
|
||||||
|
res()
|
||||||
|
}
|
||||||
|
})
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param {string} publicKey
|
||||||
|
* @returns {Promise<void>}
|
||||||
|
*/
|
||||||
|
const unfollow = publicKey =>
|
||||||
|
new Promise((res, rej) => {
|
||||||
|
require('../Mediator')
|
||||||
|
.getUser()
|
||||||
|
.get(Key.FOLLOWS)
|
||||||
|
.get(publicKey)
|
||||||
|
.put(null, ack => {
|
||||||
|
if (ack.err) {
|
||||||
|
rej(new Error(ack.err))
|
||||||
|
} else {
|
||||||
|
res()
|
||||||
|
}
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
module.exports = {
|
module.exports = {
|
||||||
__createOutgoingFeed,
|
__createOutgoingFeed,
|
||||||
acceptRequest,
|
acceptRequest,
|
||||||
|
|
@ -1236,5 +1284,7 @@ module.exports = {
|
||||||
saveSeedBackup,
|
saveSeedBackup,
|
||||||
saveChannelsBackup,
|
saveChannelsBackup,
|
||||||
disconnect,
|
disconnect,
|
||||||
setLastSeenApp
|
setLastSeenApp,
|
||||||
|
follow,
|
||||||
|
unfollow
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue