Merge branch 'main' of https://github.com/mminl-de/interscore

Author: MrMineDe

Makefile

@@ -6,7 +6,6 @@ b-fast:
 	${MAKE} --no-print-directory -C backend fast
 b-run:
 	${MAKE} --no-print-directory -C backend run
-
 js:
 	m4 -DTS MessageType.m4 > MessageType.ts
 	cp MessageType.ts frontend/MessageType.ts # TODO
@@ -21,6 +20,7 @@ f-freezed:
 
 f-run:
 	${MAKE} --no-print-directory -C rentnerend flutter
-
+e-run:
+	${MAKE} --no-print-directory -C echo run
 clean:
 	rm -f frontend/script.js MessageType.js MessageType.ts backend/interscore-backend

echo/src/MessageType.zig

@@ -0,0 +1,20 @@
+
+
+
+
+
+
+
+
+
+
+
+
+pub const MessageType = enum(u8) {
+
+DATA_META = 0, DATA_META_GAME = 1, DATA_META_TIME = 2, DATA_META_OBS = 3, DATA_META_WIDGETS = 4, DATA_GAMES = 5, DATA_GAME = 6, DATA_GAMEACTIONS = 7, DATA_GAMEACTION = 8, DATA_FORMATS = 9, DATA_FORMAT = 10, DATA_TEAMS = 11, DATA_TEAM = 12, DATA_GROUPS = 13, DATA_GROUP = 14, DATA_IM_BOSS = 15, DATA_TIMESTAMP = 16, DATA_JSON = 17, IM_THE_BOSS = 18, PLS_SEND_META = 19, PLS_SEND_META_GAME = 20, PLS_SEND_META_TIME = 21, PLS_SEND_META_OBS = 22, PLS_SEND_META_WIDGETS = 23, PLS_SEND_GAMES = 24, PLS_SEND_GAME = 25, PLS_SEND_GAMEACTIONS = 26, PLS_SEND_GAMEACTION = 27, PLS_SEND_FORMATS = 28, PLS_SEND_FORMAT = 29, PLS_SEND_TEAMS = 30, PLS_SEND_TEAM = 31, PLS_SEND_GROUPS = 32, PLS_SEND_GROUP = 33, PLS_SEND_IM_BOSS = 34, PLS_SEND_TIMESTAMP = 35, PLS_SEND_JSON
+ = 36,
+};
+
+
+

echo/src/main.zig

@@ -1,6 +1,7 @@
 const std = @import("std");
 const ws = @import("websocket");
 const AllocatorWrapper = @import("allocator.zig").AllocatorWrapper;
+const MessageType = @import("MessageType.zig").MessageType;
 
 const log = std.log.scoped(.interscore);
 const ziglog = std.log.scoped(.zig);
@@ -56,7 +57,48 @@ const Handler = struct {
 
 	// Callback running when client sends message
 	pub fn clientMessage(self: *Handler, data: []const u8) !void {
-		try self.conn.write(data);
+		const msg: MessageType = @enumFromInt(data[0]);
+		switch (msg) {
+			.PLS_SEND_SIDES_SWITCHED,
+			.PLS_SEND_GAMEPART,
+			.PLS_SEND_GAMEINDEX,
+			.PLS_SEND_IS_PAUSE,
+			.PLS_SEND_TIME,
+			.PLS_SEND_JSON,
+			.PLS_SEND_OBS_REPLAY_ON,
+			.PLS_SEND_OBS_STREAM_ON,
+			.PLS_SEND_WIDGET_AD_ON,
+			.PLS_SEND_WIDGET_GAMESTART_ON,
+			.PLS_SEND_WIDGET_GAMEPLAN_ON,
+			.PLS_SEND_WIDGET_LIVETABLE_ON,
+			.PLS_SEND_WIDGET_SCOREBOARD_ON,
+			.PLS_SEND_GAME_ACTION,
+			.PLS_SEND_TIMESTAMP,
+			.PLS_SEND_GAME => {
+				// Forwarding to frontend
+				try self.conn.write(data);
+			},
+			.PLS_SEND_IM_BOSS => {
+				const msg_byte: u8 = @intFromEnum(MessageType.DATA_IM_BOSS);
+				const is_boss: u8 = @intFromBool(self.conn == self.app.boss);
+				try self.conn.write(&.{msg_byte, is_boss});
+			},
+			.DATA_OBS_STREAM_ON => {
+				// TODO
+			},
+			.DATA_OBS_REPLAY_ON => {
+				// TODO
+			},
+			.IM_THE_BOSS => {
+				// TODO
+			},
+			.DATA_GAMEINDEX => {
+				// TODO
+			},
+			else => {
+				// TODO
+			}
+		}
 	}
 
 	// Callback running when connection is about to be terminated