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
80. 80
81. 81
82. 82
83. 83

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

import { isValidMessage, type Message } from "./worker/message.ts";
import { encode_list_request, decode_list_response } from "./app.gleam";

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",
});

interface RequestParameters {
	service: string;
	method: string;
	request: Uint8Array;
}

function request({ service, method, request }: RequestParameters): Promise<Uint8Array> {
	const id = crypto.randomUUID();

	return new Promise((resolve) => {
		const handler = (event: MessageEvent) => {
			if (!isValidMessage(event.data) || event.data.id !== id) {
				return;
			}

			worker.removeEventListener("message", handler);

			if (event.data.service !== service || event.data.method !== method) {
				throw new Error(
					`Received response with incorrect service/method: expected=${service}.${method}, received=${event.data.service}/${event.data.method}`,
				);
			}

			resolve(event.data.data);
		};

		worker.addEventListener("message", handler);

		worker.postMessage(
			{
				id,
				service,
				method,
				data: request,
			} satisfies Message,
			{
				transfer: [request.buffer],
			},
		);
	});
}

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

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

				const resp = await request({
					service: "yamori.workspace.v1.KeyValueStorageBasedWorkspaceService",
					method: "List",
					request: encode_list_request(),
				});

				output.textContent += "\n" + JSON.stringify(decode_list_response(resp), null, 2);
			});
		}
	},
	{ once: true },
);