for go

.editorconfig

@@ -6,6 +6,10 @@ end_of_line = lf
 indent_style = space
 indent_size = 2
 
+[*.go]
+indent_style = tab
+indent_size = 2
+
 [*.nix]
 indent_style = space
 indent_size = 2

app/lib/prymn_web/channels/agent_channel.ex

@@ -9,15 +9,21 @@ defmodule PrymnWeb.AgentChannel do
     {:ok, socket}
   end
 
-  # Channels can be used in a request/response fashion
-  # by sending replies to requests from the client
   @impl true
-  def handle_in("ping", payload, socket) do
-    {:reply, {:ok, payload}, socket}
-  end
-
-  def handle_in("binary", {:binary, data}, socket) do
-    dbg(data)
+  def handle_in(event, _payload, socket) do
+    dbg(event)
     {:noreply, socket}
   end
+
+  # Channels can be used in a request/response fashion
+  # by sending replies to requests from the client
+  # @impl true
+  # def handle_in("ping", payload, socket) do
+  #   {:reply, {:ok, payload}, socket}
+  # end
+
+  # def handle_in("binary", {:binary, data}, socket) do
+  #   dbg(data)
+  #   {:noreply, socket}
+  # end
 end

flake.nix

@@ -42,7 +42,7 @@
                 pkgs.elixir
                 pkgs.elixir-ls
                 pkgs.rustToolchain
-                pkgs.natscli
+                pkgs.go
               ] ++ pkgs.lib.optionals pkgs.stdenv.isLinux [ pkgs.inotify-tools ];
 
               services.postgres = {
@@ -52,8 +52,6 @@
                 initialScript = "CREATE USER postgres SUPERUSER;";
               };
 
-              processes.nats-server.exec = "${pkgs.nats-server}/bin/nats-server -c ./agent/server.conf";
-
               enterShell = ''
                 echo happy deving
               '';

goagent/cmd/agent/main.go

@@ -0,0 +1,14 @@
+package main
+
+import (
+	"fmt"
+
+	"git.nikos.gg/prymn/prymn/goagent/pkg/gophx"
+)
+
+func main() {
+	err := gophx.Connect()
+	if err != nil {
+		fmt.Println(err)
+	}
+}

goagent/go.mod

@@ -0,0 +1,5 @@
+module git.nikos.gg/prymn/prymn/goagent
+
+go 1.21.5
+
+require nhooyr.io/websocket v1.8.10 // indirect

goagent/go.sum

@@ -0,0 +1,2 @@
+nhooyr.io/websocket v1.8.10 h1:mv4p+MnGrLDcPlBoWsvPP7XCzTYMXP9F9eIGoKbgx7Q=
+nhooyr.io/websocket v1.8.10/go.mod h1:rN9OFWIUwuxg4fR5tELlYC04bXYowCP9GX47ivo2l+c=

goagent/pkg/gophx/channel.go

@@ -0,0 +1,22 @@
+package gophx
+
+import (
+	"context"
+	"time"
+
+	"nhooyr.io/websocket"
+)
+
+func Connect() error {
+	ctx, cancel := context.WithTimeout(context.Background(), time.Minute)
+	defer cancel()
+
+	c, _, err := websocket.Dial(ctx, "ws://localhost:4000/agent/websocket?vsn=2.0.0", nil)
+	if err != nil {
+		return err
+	}
+
+	c.Ping(ctx)
+
+	return nil
+}