(veggie) refactor lib/agent/runtime/handlers over several sessions

Author: verdverm

AGENTS.md

@@ -32,6 +32,7 @@ This is all we are working on currently.
 
 - **ADK + VS Code Coding Agent**
   - lib/agent/... (core runtime in Go using ADK)
+  - lib/agent/config/... (CUE-based configuration for agents, tools, and environments)
   - extensions/vscode/
     - extension/... (core extension)
     - webviews/...  (webview components)

lib/agent/cmd/chat_subops.go

@@ -8,6 +8,7 @@ import (
 
 	"github.com/hofstadter-io/hof/cmd/hof/flags"
 	"github.com/hofstadter-io/hof/lib/agent/runtime/handlers/common"
+	"github.com/hofstadter-io/hof/lib/consts"
 	"github.com/hofstadter-io/hof/lib/yagu"
 	"github.com/olekukonko/tablewriter"
 )
@@ -33,7 +34,7 @@ func ChatList(args []string, rflags flags.RootPflagpole, aflags flags.AgentPflag
 
 	// these loops need to be switched
 	// REALLY, we need a third list to calc intermediate rows with comparable data
-	sessions, err := common.SessionList(R, AR)
+	sessions, err := common.SessionList(R.Ctx, AR, consts.VEG_DEFAULT_USER)
 	rows := make([][]string, 0, len(sessions))
 	for _, s := range sessions {
 		id := s.ID()

lib/agent/cmd/runtime.go

@@ -47,11 +47,7 @@ func prepRuntime(args []string, rflags flags.RootPflagpole) (*runtime.Runtime, *
 		return nil, nil, err
 	}
 
-	ar, err := aruntime.NewRuntime(
-		r.DB,
-		r.Envs,
-		r.Agentics,
-	)
+	ar, err := aruntime.NewRuntime(r)
 	if err != nil {
 		return nil, nil, fmt.Errorf("failed to create agent runtime: %v", err)
 	}

lib/agent/cmd/tui/list.go

@@ -13,6 +13,7 @@ import (
 	tea "github.com/charmbracelet/bubbletea"
 	"github.com/charmbracelet/lipgloss"
 	"github.com/hofstadter-io/hof/lib/agent/runtime/handlers/common"
+	"github.com/hofstadter-io/hof/lib/consts"
 	"google.golang.org/adk/session"
 )
 
@@ -287,7 +288,7 @@ func (m *listModel) updateRows() {
 }
 
 func (m *listModel) updateSessions() error {
-	sessions, err := common.SessionList(m.root.R, m.root.AR)
+	sessions, err := common.SessionList(m.root.R.Ctx, m.root.AR, consts.VEG_DEFAULT_USER)
 	if err != nil {
 		return err
 	}

lib/agent/cmd/tui/root.go

@@ -62,7 +62,7 @@ type Model struct {
 	currSid       string
 	currSessTitle string
 	session       session.Session
-	asession      *aruntime.Session
+	asession      *common.Session
 }
 
 var views = []string{"list", "chat", "info"}
@@ -331,7 +331,7 @@ func (m *Model) currDims() {
 func (m *Model) createSession() error {
 	m.clearSession()
 
-	session, err := common.SessionCreate(m.R, m.AR, common.CreatePayload{
+	session, err := common.SessionCreate(m.R.Ctx, m.AR, common.CreatePayload{
 		User:  consts.VEG_DEFAULT_USER,
 		Agent: "veggie",
 		Model: "gemini-3-flash",
@@ -346,7 +346,7 @@ func (m *Model) createSession() error {
 }
 
 func (m *Model) loadSession(sid string) error {
-	session, err := common.SessionGet(m.R, m.AR, sid)
+	session, err := common.SessionGet(m.R.Ctx, m.AR, consts.VEG_DEFAULT_USER, sid)
 	if err != nil {
 		m.err = err
 		return err
@@ -372,7 +372,7 @@ func (m *Model) sendMessage(text string) error {
 }
 
 func (m *Model) delSession(sid string) error {
-	err := common.SessionDel(m.R, m.AR, sid)
+	err := common.SessionDel(m.R.Ctx, m.AR, consts.VEG_DEFAULT_USER, sid)
 	if err != nil {
 		m.err = err
 		return err

lib/agent/runtime/handlers/api/env.go

@@ -3,12 +3,12 @@ package api
 import (
 	"net/http"
 
-	"github.com/hofstadter-io/hof/lib/agent/services/environ"
+	"github.com/hofstadter-io/hof/lib/agent/runtime/handlers/common"
 	"github.com/labstack/echo/v4"
 )
 
 func envList(c echo.Context) error {
-	envs, err := environ.Client().ListEnvirons()
+	envs, err := common.ListEnvirons()
 	if err != nil {
 		// fmt.Println("error:", err)
 		return c.String(http.StatusBadRequest, err.Error())

lib/agent/runtime/handlers/api/runtime.go

@@ -1,10 +1,15 @@
 package api
 
 import (
+	"fmt"
+
 	"github.com/labstack/echo/v4"
+	"google.golang.org/adk/artifact"
+	"google.golang.org/adk/model"
 	"google.golang.org/adk/session"
 
 	"github.com/hofstadter-io/hof/lib/agent/config"
+	"github.com/hofstadter-io/hof/lib/agent/runtime/handlers/common"
 )
 
 type Runtime struct {
@@ -13,6 +18,34 @@ type Runtime struct {
 	Agentic *config.Config
 }
 
+func (r *Runtime) GetAppName() string {
+	return r.AppName
+}
+
+func (r *Runtime) GetSessionService() session.Service {
+	return r.S
+}
+
+func (r *Runtime) GetAgenticConfig() *config.Config {
+	return r.Agentic
+}
+
+func (r *Runtime) GetArtifactService() artifact.Service {
+	return nil
+}
+
+func (r *Runtime) GetModels() map[string]model.LLM {
+	return nil
+}
+
+func (r *Runtime) ReadEnvConfig() error {
+	return fmt.Errorf("ReadEnvConfig not implemented for api.Runtime")
+}
+
+func (r *Runtime) SetSession(s *common.Session) {
+	// api doesn't track active sessions this way
+}
+
 func Setup(appName string, e *echo.Echo, s session.Service, a *config.Config) (*Runtime, error) {
 	r := &Runtime{
 		AppName: appName,
@@ -36,8 +69,15 @@ func Setup(appName string, e *echo.Echo, s session.Service, a *config.Config) (*
 	e.POST("/env/list", envList)
 	e.POST("/prompt/render", r.promptRender)
 
+	e.POST("/session/list", r.sessionList)
+	e.POST("/session/get", r.sessionGet)
+	e.POST("/session/create", r.sessionCreate)
+	e.POST("/session/delete", r.sessionDelete)
 	e.POST("/session/clone", r.sessionClone)
 	e.POST("/session/splice", r.sessionSplice)
+	e.POST("/session/state/get", r.sessionStateGet)
+	e.POST("/session/state/put", r.sessionStatePut)
+	e.POST("/session/state/del", r.sessionStateDel)
 
 	return r, nil
 }