natty
/
calckey
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'develop' of codeberg.org:thatonecalculator/calckey into develop

This commit is contained in:
ThatOneCalculator 2022-12-12 12:08:06 -08:00
parent c050ff5580 a9058697be
commit 0a9208ddea
No known key found for this signature in database
GPG Key ID: 8703CACD01000000
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
packages/backend/src/server/api/endpoints/i/move.ts
View File

@ -7,8 +7,10 @@ import { genId } from '@/misc/gen-id.js';
import define from '../../define.js'; import define from '../../define.js';
import { ApiError } from '../../error.js'; import { ApiError } from '../../error.js';
import { apiLogger } from '../../logger.js'; import { apiLogger } from '../../logger.js';
import { Users } from '@/models/index.js';
import { UserProfiles } from '@/models/index.js'; import { UserProfiles } from '@/models/index.js';
import config from '@/config/index.js'; import config from '@/config/index.js';
import { publishMainStream } from '@/services/stream.js';
export const meta = { export const meta = {
tags: ['users'], tags: ['users'],
@ -100,10 +102,24 @@ export default define(meta, paramDef, async (ps, user) => {
if (!allowed || !toUrl || !fromUrl) throw new ApiError(meta.errors.remoteAccountForbids); if (!allowed || !toUrl || !fromUrl) throw new ApiError(meta.errors.remoteAccountForbids);
const updates = {} as Partial<User>;
if (!toUrl) toUrl = '';
updates.movedToUri = toUrl;
await Users.update(user.id, updates);
const iObj = await Users.pack<true, true>(user.id, user, {
detail: true,
includeSecrets: true,
});
const moveAct = moveActivity(toUrl, fromUrl); const moveAct = moveActivity(toUrl, fromUrl);
const dm = new DeliverManager(user, moveAct); const dm = new DeliverManager(user, moveAct);
dm.addFollowersRecipe(); dm.addFollowersRecipe();
dm.execute(); dm.execute();
return true; // Publish meUpdated event
publishMainStream(user.id, 'meUpdated', iObj);
return iObj;
}); });