2023-07-27 00:31:52 -05:00
|
|
|
|
/*
|
|
|
|
|
* SPDX-FileCopyrightText: syuilo and other misskey contributors
|
|
|
|
|
* SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
|
*/
|
|
|
|
|
|
2022-01-13 19:25:51 -06:00
|
|
|
|
import { onUnmounted, Ref } from 'vue';
|
|
|
|
|
import * as misskey from 'misskey-js';
|
2023-05-15 05:08:46 -05:00
|
|
|
|
import { useStream } from '@/stream';
|
2022-01-13 19:25:51 -06:00
|
|
|
|
import { $i } from '@/account';
|
|
|
|
|
|
|
|
|
|
export function useNoteCapture(props: {
|
|
|
|
|
rootEl: Ref<HTMLElement>;
|
2022-02-11 06:35:28 -06:00
|
|
|
|
note: Ref<misskey.entities.Note>;
|
|
|
|
|
isDeletedRef: Ref<boolean>;
|
2022-01-13 19:25:51 -06:00
|
|
|
|
}) {
|
2022-02-11 06:35:28 -06:00
|
|
|
|
const note = props.note;
|
2023-05-15 05:08:46 -05:00
|
|
|
|
const connection = $i ? useStream() : null;
|
2022-01-13 19:25:51 -06:00
|
|
|
|
|
2022-05-07 00:19:15 -05:00
|
|
|
|
function onStreamNoteUpdated(noteData): void {
|
|
|
|
|
const { type, id, body } = noteData;
|
2022-01-13 19:25:51 -06:00
|
|
|
|
|
2022-02-11 06:35:28 -06:00
|
|
|
|
if (id !== note.value.id) return;
|
2022-01-13 19:25:51 -06:00
|
|
|
|
|
|
|
|
|
switch (type) {
|
|
|
|
|
case 'reacted': {
|
|
|
|
|
const reaction = body.reaction;
|
|
|
|
|
|
2023-01-26 02:46:21 -06:00
|
|
|
|
if (body.emoji && !(body.emoji.name in note.value.reactionEmojis)) {
|
|
|
|
|
note.value.reactionEmojis[body.emoji.name] = body.emoji.url;
|
2022-01-13 19:25:51 -06:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// TODO: reactionsプロパティがない場合ってあったっけ? なければ || {} は消せる
|
2022-02-11 06:35:28 -06:00
|
|
|
|
const currentCount = (note.value.reactions || {})[reaction] || 0;
|
2022-01-13 19:25:51 -06:00
|
|
|
|
|
2022-02-11 06:35:28 -06:00
|
|
|
|
note.value.reactions[reaction] = currentCount + 1;
|
2022-01-13 19:25:51 -06:00
|
|
|
|
|
|
|
|
|
if ($i && (body.userId === $i.id)) {
|
2022-02-11 06:35:28 -06:00
|
|
|
|
note.value.myReaction = reaction;
|
2022-01-13 19:25:51 -06:00
|
|
|
|
}
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
case 'unreacted': {
|
|
|
|
|
const reaction = body.reaction;
|
|
|
|
|
|
|
|
|
|
// TODO: reactionsプロパティがない場合ってあったっけ? なければ || {} は消せる
|
2022-02-11 06:35:28 -06:00
|
|
|
|
const currentCount = (note.value.reactions || {})[reaction] || 0;
|
2022-01-13 19:25:51 -06:00
|
|
|
|
|
2022-02-11 06:35:28 -06:00
|
|
|
|
note.value.reactions[reaction] = Math.max(0, currentCount - 1);
|
2022-12-30 04:01:01 -06:00
|
|
|
|
if (note.value.reactions[reaction] === 0) delete note.value.reactions[reaction];
|
2022-01-13 19:25:51 -06:00
|
|
|
|
|
|
|
|
|
if ($i && (body.userId === $i.id)) {
|
2022-02-11 06:35:28 -06:00
|
|
|
|
note.value.myReaction = null;
|
2022-01-13 19:25:51 -06:00
|
|
|
|
}
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
case 'pollVoted': {
|
|
|
|
|
const choice = body.choice;
|
|
|
|
|
|
2022-02-11 06:35:28 -06:00
|
|
|
|
const choices = [...note.value.poll.choices];
|
2022-01-13 19:25:51 -06:00
|
|
|
|
choices[choice] = {
|
|
|
|
|
...choices[choice],
|
|
|
|
|
votes: choices[choice].votes + 1,
|
|
|
|
|
...($i && (body.userId === $i.id) ? {
|
2022-12-22 01:01:59 -06:00
|
|
|
|
isVoted: true,
|
|
|
|
|
} : {}),
|
2022-01-13 19:25:51 -06:00
|
|
|
|
};
|
|
|
|
|
|
2022-02-11 06:35:28 -06:00
|
|
|
|
note.value.poll.choices = choices;
|
2022-01-13 19:25:51 -06:00
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
case 'deleted': {
|
2022-02-11 06:35:28 -06:00
|
|
|
|
props.isDeletedRef.value = true;
|
2022-01-13 19:25:51 -06:00
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function capture(withHandler = false): void {
|
|
|
|
|
if (connection) {
|
|
|
|
|
// TODO: このノートがストリーミング経由で流れてきた場合のみ sr する
|
2022-02-11 06:35:28 -06:00
|
|
|
|
connection.send(document.body.contains(props.rootEl.value) ? 'sr' : 's', { id: note.value.id });
|
2022-01-13 19:25:51 -06:00
|
|
|
|
if (withHandler) connection.on('noteUpdated', onStreamNoteUpdated);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function decapture(withHandler = false): void {
|
|
|
|
|
if (connection) {
|
|
|
|
|
connection.send('un', {
|
2022-02-11 06:35:28 -06:00
|
|
|
|
id: note.value.id,
|
2022-01-13 19:25:51 -06:00
|
|
|
|
});
|
|
|
|
|
if (withHandler) connection.off('noteUpdated', onStreamNoteUpdated);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function onStreamConnected() {
|
|
|
|
|
capture(false);
|
|
|
|
|
}
|
2023-07-07 17:08:16 -05:00
|
|
|
|
|
2022-01-13 19:25:51 -06:00
|
|
|
|
capture(true);
|
|
|
|
|
if (connection) {
|
|
|
|
|
connection.on('_connected_', onStreamConnected);
|
|
|
|
|
}
|
2023-07-07 17:08:16 -05:00
|
|
|
|
|
2022-01-13 19:25:51 -06:00
|
|
|
|
onUnmounted(() => {
|
|
|
|
|
decapture(true);
|
|
|
|
|
if (connection) {
|
|
|
|
|
connection.off('_connected_', onStreamConnected);
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
}
|