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
84. 84
85. 85
86. 86
87. 87
88. 88
89. 89

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

import backend
import dom
import gleam/json
import gleam/string
import protobuf

fn encode_list_request() -> protobuf.Binary {
  json.object([])
  |> protobuf.encode(protobuf.list_request())
}

fn decode_list_response(
  binary: protobuf.Binary,
) -> protobuf.Message(protobuf.ListResponse) {
  binary
  |> protobuf.decode(protobuf.list_response())
}

pub fn main(container: dom.Node(dom.Element)) -> Nil {
  let loading =
    dom.html("p")
    |> dom.append_child(dom.text("Loading..."))

  container |> dom.append_child(loading)

  use worker_result <- backend.load_worker()

  dom.detach_node(loading)

  case worker_result {
    Ok(worker) -> {
      let button =
        dom.html("button")
        |> dom.append_child(dom.text("List Workspaces"))
        |> dom.set_attribute("type", "button")

      let pre = dom.html("pre")
      let output = dom.html("output")

      container
      |> dom.append_child(button)
      |> dom.append_child(dom.append_child(pre, output))

      {
        use _event <- dom.add_event_listener(button, "click")

        button |> dom.set_attribute("disabled", "")

        use response <- backend.request(
          worker,
          "yamori.workspace.v1.KeyValueStorageBasedWorkspaceService",
          "List",
          encode_list_request(),
        )

        button |> dom.remove_attribute("disabled")

        let text =
          decode_list_response(response)
          |> protobuf.to_json
          |> string.append("\n")

        output
        |> dom.append_child(dom.text(text))

        Nil
      }
    }
    Error(error) -> {
      let feedback =
        dom.html("p")
        |> dom.append_child(dom.text("Failed to load worker: "))
        |> dom.append_child(
          dom.text(case error {
            backend.DecodeError(_errors) ->
              "Detected broken inner system message."
            backend.WorkerInitializeError(text) -> text
          }),
        )

      container |> dom.append_child(feedback)

      Nil
    }
  }
}