iceshrimp/packages/client/src/pages/messaging/index.vue

<template>
	<MkStickyContainer>
		<template #header>
			<MkPageHeader v-model:tab="tab" :actions="headerActions" :tabs="headerTabs" />
		</template>
		<div>
			<MkSpacer :content-max="800">
				<swiper :modules="[Virtual]" :space-between="20" :virtual="true"
					:allow-touch-move="!(deviceKind === 'desktop' && !defaultStore.state.swipeOnDesktop)" @swiper="setSwiperRef"
					@slide-change="onSlideChange">
					<swiper-slide>
						<div class="_content yweeujhr dms">
							<MkButton primary class="start" @click="startUser"><i class="ph-plus-bold ph-lg"></i> {{
								i18n.ts.startMessaging
							}}</MkButton>
							<MkPagination v-slot="{ items }" ref="paginationComponentUser" :pagination="dmsPagination">
								<MkChatPreview v-for="message in items" :key="message.id" class="yweeujhr message _block"
									:message="message" />
							</MkPagination>
						</div>
					</swiper-slide>
					<swiper-slide>
						<div class="_content yweeujhr groups">
							<div class="groupsbuttons">
								<MkButton primary class="start" :link="true" to="/my/groups"><i
										class="ph-user-circle-gear-bold ph-lg"></i> {{ i18n.ts.manageGroups }}</MkButton>
								<MkButton primary class="start" @click="startGroup"><i class="ph-plus-bold ph-lg"></i> {{
									i18n.ts.startMessaging
								}}</MkButton>
							</div>
							<MkPagination v-slot="{ items }" ref="paginationComponentGroup" :pagination="groupsPagination">
								<MkChatPreview v-for="message in items" :key="message.id" class="yweeujhr message _block"
									:message="message" />
							</MkPagination>
						</div>
					</swiper-slide>
				</swiper>
			</MkSpacer>
		</div>
	</MkStickyContainer>
</template>

<script lang="ts" setup>
import { markRaw, onMounted, onUnmounted, watch, computed, onActivated } from 'vue';
import * as Acct from 'calckey-js/built/acct';
import { Virtual } from 'swiper';
import { Swiper, SwiperSlide } from 'swiper/vue';
import MkButton from '@/components/MkButton.vue';
import MkChatPreview from '@/components/MkChatPreview.vue';
import MkPagination from '@/components/MkPagination.vue';
import * as os from '@/os';
import { stream } from '@/stream';
import { useRouter } from '@/router';
import { i18n } from '@/i18n';
import { definePageMetadata } from '@/scripts/page-metadata';
import { $i } from '@/account';
import { deviceKind } from '@/scripts/device-kind';
import { defaultStore } from '@/store';
import 'swiper/scss';
import 'swiper/scss/virtual';

const router = useRouter();

let messages = $ref([]);
let groupMessages = $ref([]);
let connection = $ref(null);
let paginationComponentUser = $ref<InstanceType<typeof MkPagination>>();
let paginationComponentGroup = $ref<InstanceType<typeof MkPagination>>();

const tabs = ['dms', 'groups'];
let tab = $ref(tabs[0]);
watch($$(tab), () => (syncSlide(tabs.indexOf(tab))));

const headerActions = $computed(() => [{
	asFullButton: true,
	icon: 'ph-plus-bold ph-lg',
	text: i18n.ts.addUser,
	handler: startMenu,
}]);

const headerTabs = $computed(() => [{
	key: 'dms',
	title: i18n.ts._messaging.dms,
	icon: 'ph-user-bold ph-lg',
}, {
	key: 'groups',
	title: i18n.ts._messaging.groups,
	icon: 'ph-users-three-bold ph-lg',
}]);

definePageMetadata({
	title: i18n.ts.messaging,
	icon: 'ph-chats-teardrop-bold ph-lg',
});

const dmsPagination = {
	endpoint: 'messaging/history' as const,
	limit: 20,
	params: computed(() => ({
		group: false,
	})),
	offsetMode: true,
};
const groupsPagination = {
	endpoint: 'messaging/history' as const,
	limit: 10,
	params: computed(() => ({
		group: true,
	})),
	offsetMode: true,
};

function onMessage(message): void {
	if (message.recipientId) {
		messages = messages.filter(m => !(
			(m.recipientId === message.recipientId && m.userId === message.userId) ||
			(m.recipientId === message.userId && m.userId === message.recipientId)));

		messages.unshift(message);
	} else if (message.groupId) {
		groupMessages = groupMessages.filter(m => m.groupId !== message.groupId);
		groupMessages.unshift(message);
	}
}

function onRead(ids): void {
	for (const id of ids) {
		const found = messages.find(m => m.id === id);
		if (found) {
			if (found.recipientId) {
				found.isRead = true;
			} else if (found.groupId) {
				found.reads.push($i.id);
			}
		}
	}
}

function startMenu(ev) {
	os.popupMenu([{
		text: i18n.ts.messagingWithUser,
		icon: 'ph-user-bold ph-lg',
		action: () => { startUser(); },
	}, {
		text: i18n.ts.messagingWithGroup,
		icon: 'ph-users-three-bold ph-lg',
		action: () => { startGroup(); },
	}], ev.currentTarget ?? ev.target);
}


async function startUser(): void {
	os.selectUser().then(user => {
		router.push(`/my/messaging/${Acct.toString(user)}`);
	});
}

async function startGroup(): void {
	const groups1 = await os.api('users/groups/owned');
	const groups2 = await os.api('users/groups/joined');
	if (groups1.length === 0 && groups2.length === 0) {
		os.alert({
			type: 'warning',
			title: i18n.ts.youHaveNoGroups,
			text: i18n.ts.joinOrCreateGroup,
		});
		return;
	}
	const { canceled, result: group } = await os.select({
		title: i18n.ts.group,
		items: groups1.concat(groups2).map(group => ({
			value: group, text: group.name,
		})),
	});
	if (canceled) return;
	router.push(`/my/messaging/group/${group.id}`);
}

let swiperRef = null;

function setSwiperRef(swiper) {
	swiperRef = swiper;
	syncSlide(tabs.indexOf(tab));
}

function onSlideChange() {
	tab = tabs[swiperRef.activeIndex];
}

function syncSlide(index) {
	swiperRef.slideTo(index);
}

onMounted(() => {
	syncSlide(tabs.indexOf(swiperRef?.activeIndex));

	connection = markRaw(stream.useChannel('messagingIndex'));

	connection.on('message', onMessage);
	connection.on('messagingMessage', onMessage);
	connection.on('read', onRead);

	os.api('messaging/history', { group: false, limit: 5 }).then(userMessages => {
		os.api('messaging/history', { group: true, limit: 5 }).then(groupMessages => {
			const _messages = userMessages.concat(groupMessages);
			_messages.sort((a, b) => new Date(b.createdAt).getTime() - new Date(a.createdAt).getTime());
			messages = _messages;
		});
	});
});

onUnmounted(() => {
	if (connection) connection.dispose();
});

/*
onActivated(() => {
	paginationComponentUser.reload();
	paginationComponentGroup.reload();
});*/
</script>

<style lang="scss" scoped>
.yweeujhr {
	>.start {
		margin: 0 auto var(--margin) auto;
	}

	>.groupsbuttons {
		max-width: 100%;
		display: flex;
		justify-content: center;
		margin-bottom: 1rem;
	}
}
</style>