update: impl spawnWorker func via unix protocolmain

1 files changed, 7 insertions, 7 deletions

diff --git a/internal/daemon.go b/internal/daemon.go
index cc202f5..62fdc5c 100644
--- a/internal/daemon.go
+++ b/internal/daemon.go
@@ -10,8 +10,6 @@ import (
 	"sync"
 	"sync/atomic"
 	"time"
-
-	"lurchers/internal/api"
 )
 
 type Daemon struct {
@@ -28,9 +26,9 @@ func (d *Daemon) HandleConn(ctx context.Context, conn net.Conn) {
 
 	scanner := bufio.NewScanner(conn)
 	for scanner.Scan() {
-		var msg api.LurchMsg
+		var msg LurchMsg
 
-		if err := api.Decode(&msg, scanner.Bytes()); err != nil {
+		if err := Decode(&msg, scanner.Bytes()); err != nil {
 			slog.Error("decode: failed to decode", "error", err)
 			fmt.Fprintln(conn, "error: invalid json")
 			continue
@@ -38,7 +36,7 @@ func (d *Daemon) HandleConn(ctx context.Context, conn net.Conn) {
 
 		slog.Info("received", "json", msg)
 
-		if err := api.Compute(ctx, &msg, conn); err != nil {
+		if err := Compute(ctx, &msg, conn); err != nil {
 			slog.Error("parse: failed to parse lurch logic", "error", err)
 			fmt.Fprintln(conn, "error: failed to parse")
 			continue
@@ -50,7 +48,8 @@ func (d *Daemon) HandleConn(ctx context.Context, conn net.Conn) {
 	}
 }
 
-func (d *Daemon) SpawnWorker(ev SysLurchEventT, timeout time.Duration) (uint64, error) {
+// TODO: add in custom command later
+func (d *Daemon) SpawnWorker(ev *SysLurchEventT, timeout time.Duration) (uint64, error) {
 	offset, slotIdx, err := d.Ring.ClaimSlot()
 	if err != nil {
 		return 0, err
@@ -64,7 +63,8 @@ func (d *Daemon) SpawnWorker(ev SysLurchEventT, timeout time.Duration) (uint64,
 	payloadOffset := offset + SlotHeaderSize
 
 	ctx, cancel := context.WithTimeout(d.Ctx, timeout)
-	cmd := exec.CommandContext(ctx, "jac", "howler,.py", fmt.Sprintf("%d", payloadOffset))
+	// custom executions; don't know yet with jaclang
+	cmd := exec.CommandContext(ctx, "jac", "howler.jac", fmt.Sprintf("%d", payloadOffset))
 
 	// explicit tracking of workers
 	d.WorkerWg.Add(1)