From bf04ca496992947faf2740edd77db0faa2f12451 Mon Sep 17 00:00:00 2001 From: cutestnekoaqua Date: Mon, 12 Dec 2022 20:44:11 +0100 Subject: [PATCH] POV: coding at 3am bad --- .../backend/src/server/api/endpoints/i/move.ts | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/packages/backend/src/server/api/endpoints/i/move.ts b/packages/backend/src/server/api/endpoints/i/move.ts index 4c03719797..8345ce0948 100644 --- a/packages/backend/src/server/api/endpoints/i/move.ts +++ b/packages/backend/src/server/api/endpoints/i/move.ts @@ -7,8 +7,10 @@ import { genId } from '@/misc/gen-id.js'; import define from '../../define.js'; import { ApiError } from '../../error.js'; import { apiLogger } from '../../logger.js'; +import { Users } from '@/models/index.js'; import { UserProfiles } from '@/models/index.js'; import config from '@/config/index.js'; +import { publishMainStream } from '@/services/stream.js'; export const meta = { tags: ['users'], @@ -100,10 +102,24 @@ export default define(meta, paramDef, async (ps, user) => { if (!allowed || !toUrl || !fromUrl) throw new ApiError(meta.errors.remoteAccountForbids); + const updates = {} as Partial; + + if (!toUrl) toUrl = ''; + updates.movedToUri = toUrl; + + await Users.update(user.id, updates); + const iObj = await Users.pack(user.id, user, { + detail: true, + includeSecrets: true, + }); + const moveAct = moveActivity(toUrl, fromUrl); const dm = new DeliverManager(user, moveAct); dm.addFollowersRecipe(); dm.execute(); + // Publish meUpdated event + publishMainStream(user.id, 'meUpdated', iObj); + return true; });