wip

packages/backend/src/server/api/stream/Connection.ts

@@ -35,6 +35,7 @@ import { ChatUserChannel } from '@/server/api/stream/channels/chat-user.js';
 import { ChatRoomChannel } from '@/server/api/stream/channels/chat-room.js';
 import { ReversiChannel } from '@/server/api/stream/channels/reversi.js';
 import { ReversiGameChannel } from '@/server/api/stream/channels/reversi-game.js';
+import { WorldRoomChannel } from '@/server/api/stream/channels/world-room.js';
 import type { ChannelRequest } from './channel.js';
 import type { ChannelConstructor } from './channel.js';
 import type Channel from './channel.js';
@@ -338,6 +339,7 @@ export default class Connection {
 			case 'chatRoom': return ChatRoomChannel;
 			case 'reversi': return ReversiChannel;
 			case 'reversiGame': return ReversiGameChannel;
+			case 'worldRoom': return WorldRoomChannel;
 
 			default:
 				throw new Error(`no such channel: ${name}`);

packages/backend/src/server/api/stream/channels/world-room.ts

@@ -0,0 +1,97 @@
+/*
+ * SPDX-FileCopyrightText: syuilo and misskey-project
+ * SPDX-License-Identifier: AGPL-3.0-only
+ */
+
+import { Inject, Injectable, Scope } from '@nestjs/common';
+import { REQUEST } from '@nestjs/core';
+import { DI } from '@/di-symbols.js';
+import { bindThis } from '@/decorators.js';
+import type { GlobalEvents } from '@/core/GlobalEventService.js';
+import type { JsonObject } from '@/misc/json-value.js';
+import { WorldRoomService } from '@/core/WorldRoomService.js';
+import { WorldRoomMultiplayService } from '@/core/WorldRoomMultiplayService.js';
+import Channel, { type ChannelRequest } from '../channel.js';
+
+@Injectable({ scope: Scope.TRANSIENT })
+export class WorldRoomChannel extends Channel {
+	public readonly chName = 'worldRoom';
+	public static shouldShare = false;
+	public static requireCredential = true as const;
+	public static kind = 'read:worldRoom';
+	private roomId: string;
+	private intervalId: NodeJS.Timeout;
+	private isEntered = false;
+
+	constructor(
+		@Inject(REQUEST)
+		request: ChannelRequest,
+
+		private worldRoomService: WorldRoomService,
+		private worldRoomMultiplayService: WorldRoomMultiplayService,
+	) {
+		super(request);
+	}
+
+	@bindThis
+	public async init(params: JsonObject): Promise<boolean> {
+		if (typeof params.roomId !== 'string') return false;
+		if (!this.user) return false;
+
+		this.roomId = params.roomId;
+
+		const room = await this.worldRoomService.findRoomById(this.roomId);
+		if (room == null) return false;
+
+		try {
+			await this.enter();
+		} catch (err) {
+			return false;
+		}
+
+		//this.subscriber.on(`worldRoomStream:${this.roomId}`, this.onEvent);
+
+		return true;
+	}
+
+	@bindThis
+	private async enter() {
+		if (this.isEntered) return;
+
+		await this.worldRoomMultiplayService.enter(this.user!.id, this.roomId);
+
+		this.isEntered = true;
+
+		this.send('entered', {});
+
+		this.intervalId = setInterval(async () => {
+			const states = await this.worldRoomMultiplayService.getPlayerStatesAndHeatbeat(this.user!.id, this.roomId);
+			// TODO: 自分自身のstateは抜く
+			this.send('sync', states);
+		}, 1000);
+	}
+
+	//@bindThis
+	//private async onEvent(data: GlobalEvents['worldRoom']['payload']) {
+	//	this.send(data.type, data.body);
+	//}
+
+	@bindThis
+	public onMessage(type: string, body: any) {
+		switch (type) {
+			case 'update':
+				if (this.roomId && this.isEntered) {
+					this.worldRoomMultiplayService.updatePlayerState(this.user!.id, this.roomId, body);
+				}
+				break;
+		}
+	}
+
+	@bindThis
+	public dispose() {
+		//this.subscriber.off(`worldRoomStream:${this.roomId}`, this.onEvent);
+
+		clearInterval(this.intervalId);
+		this.worldRoomMultiplayService.leave(this.user!.id, this.roomId);
+	}
+}