Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-01-10 01:23:04 +01:00
Code Issues Packages Projects Releases Wiki Activity

test: add await to send

Browse Source 
return promise from ap.send
This commit is contained in:
Barış Soner Uşaklı
2025-09-09 12:09:35 -04:00
parent 8d6a0f0298
commit 42ffec1250
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/activitypub/inbox.js
View File

@@ -21,7 +21,7 @@ const helpers = require('./helpers');
const inbox = module.exports;
function reject(type, object, target, senderType = 'uid', id = 0) {
activitypub.send(senderType, id, target, {
return activitypub.send(senderType, id, target, {
id: `${helpers.resolveActor(senderType, id)}#/activity/reject/${encodeURIComponent(object.id)}`,
type: 'Reject',
object: {
@@ -408,7 +408,7 @@ inbox.follow = async (req) => {
await user.setUserField(id, 'followerRemoteCount', followerRemoteCount);
await user.onFollow(actor, id);
activitypub.send('uid', id, actor, {
await activitypub.send('uid', id, actor, {
id: `${nconf.get('url')}/${type}/${id}#activity/accept:follow/${handle}/${Date.now()}`,
type: 'Accept',
object: {
@@ -435,7 +435,7 @@ inbox.follow = async (req) => {
await user.setCategoryWatchState(actor, id, categories.watchStates.tracking);
}
activitypub.send('cid', id, actor, {
await activitypub.send('cid', id, actor, {
id: `${nconf.get('url')}/${type}/${id}#activity/accept:follow/${handle}/${Date.now()}`,
type: 'Accept',
object: {

2
src/activitypub/index.js
View File

@@ -405,7 +405,7 @@ ActivityPub.send = async (type, id, targets, payload) => {
};
const oneMinute = 1000 * 60;
batch.processArray(inboxes, async (inboxBatch) => {
return batch.processArray(inboxes, async (inboxBatch) => {
const retryQueueAdd = [];
const retryQueuedSet = [];