1. 1
2. 2
3. 3
4. 4
5. 5
6. 6
7. 7
8. 8
9. 9
10. 10
11. 11
12. 12
13. 13
14. 14
15. 15
16. 16
17. 17
18. 18
19. 19
20. 20
21. 21
22. 22
23. 23
24. 24
25. 25
26. 26
27. 27
28. 28
29. 29
30. 30
31. 31
32. 32
33. 33
34. 34
35. 35
36. 36
37. 37
38. 38
39. 39
40. 40
41. 41
42. 42
43. 43
44. 44
45. 45
46. 46
47. 47
48. 48
49. 49
50. 50
51. 51
52. 52
53. 53
54. 54
55. 55
56. 56
57. 57
58. 58
59. 59
60. 60
61. 61
62. 62
63. 63
64. 64
65. 65
66. 66
67. 67
68. 68
69. 69
70. 70
71. 71
72. 72
73. 73
74. 74
75. 75
76. 76
77. 77
78. 78
79. 79

// SPDX-FileCopyrightText: 2024 Shota FUJI <pockawoooh@gmail.com>
// SPDX-License-Identifier: AGPL-3.0-only

import { create, fromBinary, toBinary } from "@bufbuild/protobuf";
import { ListRequestSchema } from "@yamori/proto/yamori/workspace/v1/list_request_pb.js";
import { ListResponseSchema } from "@yamori/proto/yamori/workspace/v1/list_response_pb.js";

import { isValidMessage, type Message } from "./worker/message.ts";

const button = document.createElement("button");
button.textContent = "Send Message";
button.disabled = true;
document.body.appendChild(button);

const pre = document.createElement("pre");
const output = document.createElement("output");
pre.appendChild(output);
document.body.appendChild(pre);

const worker = new Worker(new URL("./worker/main.ts", import.meta.url), {
	type: "module",
});

worker.addEventListener(
	"message",
	(ev) => {
		if (ev.data === "ready") {
			button.disabled = false;

			button.addEventListener("click", (ev) => {
				ev.preventDefault();

				const req = toBinary(ListRequestSchema, create(ListRequestSchema, {}));

				worker.postMessage(
					{
						service: "yamori.workspace.v1.KeyValueStorageBasedWorkspaceService",
						method: "List",
						data: req,
					} satisfies Message,
					{
						transfer: [req.buffer],
					},
				);
			});

			worker.addEventListener("message", (ev) => {
				if (!isValidMessage(ev.data)) {
					console.warn("Invalid message sent from worker thread.");
					return;
				}

				switch (ev.data.service) {
					case "yamori.workspace.v1.KeyValueStorageBasedWorkspaceService": {
						switch (ev.data.method) {
							case "List": {
								const resp = fromBinary(ListResponseSchema, ev.data.data);

								output.textContent += "\n" + JSON.stringify(resp, null, 2);
								return;
							}
							default: {
								console.warn(
									`Unknown method name "${ev.data.method}" at ${ev.data.service}`,
								);
								return;
							}
						}
					}
					default: {
						console.warn(`Unknown service name "${ev.data.service}"`);
						return;
					}
				}
			});
		}
	},
	{ once: true },
);