ref(transport): remove channel transport

cmd/main.go

@@ -1,12 +1,7 @@
 package main
 
 import (
-  "github.com/KristianJBorgwarth/dendrite.daemon/core"
-	_ "modernc.org/sqlite"
 )
 
 func main() {
-	server := core.NewServer()
-	server.Run()
 }
-

core/server.go

@@ -1,132 +0,0 @@
-// Package core contains core functionality for dendrite server
-package core 
-
-import (
-	"bufio"
-	"encoding/json"
-	"fmt"
-	"io"
-	"log/slog"
-	"os"
-	"strconv"
-	"strings"
-
-	"github.com/KristianJBorgwarth/dendrite.daemon/config"
-	"github.com/KristianJBorgwarth/dendrite.daemon/core/handlers"
-	"github.com/KristianJBorgwarth/dendrite.daemon/core/models"
-)
-
-type Server struct {
-	in     *bufio.Reader
-	out    io.Writer
-	log    *slog.Logger
-	config *config.Config
-}
-
-func NewServer() *Server {
-	return &Server{
-		in:  bufio.NewReader(os.Stdin),
-		out: os.Stdout,
-		log: slog.Default(),
-	}
-}
-
-func (s *Server) writeResponse(id int, result any, err error) {
-	resp := types.Response{
-		Jsonrpc: "2.0",
-		ID:      id,
-	}
-
-	if err != nil {
-		resp.Error = map[string]any{
-			"code":    -1,
-			"message": err.Error(),
-		}
-	} else {
-		resp.Result = result
-	}
-
-	data, marshalErr := json.Marshal(resp)
-	if marshalErr != nil {
-		s.log.Error("failed to marshal response", "error", marshalErr)
-		return
-	}
-
-	fmt.Fprintf(s.out, "Content-Length: %d\r\n\r\n", len(data))
-	s.out.Write(data)
-}
-
-// Run starts the server loop, continuously reading and processing incoming messages
-func (s *Server) Run() error {
-	for {
-		length, err := s.readContentLength()
-		if err != nil {
-			return err
-		}
-
-		body := make([]byte, length)
-		if _, err := io.ReadFull(s.in, body); err != nil {
-			return err
-		}
-
-		s.log.Debug("received", "body", string(body))
-
-		// Try request first
-		var req types.Request
-		if err := json.Unmarshal(body, &req); err == nil && req.Method != "" {
-			s.handleRequest(req)
-			continue
-		}
-
-		// fallback: notification
-		var notif types.Notification
-		if err := json.Unmarshal(body, &notif); err == nil {
-			s.handleNotification(notif)
-			continue
-		}
-	}
-}
-
-func (s *Server) readContentLength() (int, error) {
-	for {
-		line, err := s.in.ReadString('\n')
-		if err != nil {
-			return 0, err
-		}
-
-		line = strings.TrimSpace(line)
-		if line == "" {
-			break
-		}
-
-		if after, ok := strings.CutPrefix(line, "Content-Length:"); ok {
-			val := strings.TrimSpace(after)
-			return strconv.Atoi(val)
-		}
-	}
-	return 0, fmt.Errorf("missing Content Length")
-}
-
-func (s *Server) handleRequest(req types.Request) {
-	s.log.Info("handling request", "method", req.Method, "id", req.ID)
-
-	var (
-		result any
-		err    error
-	)
-
-	// move to handler package?
-	switch req.Method {
-	case "initialize":
-		s.config, err = handlers.Initialize(req.Params)
-		result = map[string]any{"status": "ok"}
-	default:
-		err = fmt.Errorf("unknown method: %s", req.Method)
-	}
-
-	s.writeResponse(req.ID, result, err)
-}
-
-func (s *Server) handleNotification(notif types.Notification) {
-	s.log.Info("handling notification", "method", notif.Method)
-}