30 lines
1.5 KiB
JavaScript
30 lines
1.5 KiB
JavaScript
import config from "../../config/index.js";
|
|
import { MessagingMessages, Users } from "../../models/index.js";
|
|
import { publishGroupMessagingStream, publishMessagingStream } from "../stream.js";
|
|
import { renderActivity } from "../../remote/activitypub/renderer/index.js";
|
|
import renderDelete from "../../remote/activitypub/renderer/delete.js";
|
|
import renderTombstone from "../../remote/activitypub/renderer/tombstone.js";
|
|
import { deliver } from "../../queue/index.js";
|
|
export async function deleteMessage(message) {
|
|
await MessagingMessages.delete(message.id);
|
|
postDeleteMessage(message);
|
|
}
|
|
async function postDeleteMessage(message) {
|
|
if (message.recipientId) {
|
|
const user = await Users.findOneByOrFail({
|
|
id: message.userId
|
|
});
|
|
const recipient = await Users.findOneByOrFail({
|
|
id: message.recipientId
|
|
});
|
|
if (Users.isLocalUser(user)) publishMessagingStream(message.userId, message.recipientId, "deleted", message.id);
|
|
if (Users.isLocalUser(recipient)) publishMessagingStream(message.recipientId, message.userId, "deleted", message.id);
|
|
if (Users.isLocalUser(user) && Users.isRemoteUser(recipient)) {
|
|
const activity = renderActivity(renderDelete(renderTombstone(`${config.url}/notes/${message.id}`), user));
|
|
deliver(user, activity, recipient.inbox);
|
|
}
|
|
} else if (message.groupId) {
|
|
publishGroupMessagingStream(message.groupId, "deleted", message.id);
|
|
}
|
|
}
|