Skip to content

refactor(lib): extract Conversation interface #172

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
johnstcn wants to merge 8 commits into
base: main
Choose a base branch
from
+585 −563
Open

refactor(lib): extract Conversation interface #172

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
e3bd936
chore(lib): extract Conversation interface
johnstcn Jan 22, 2026
e5f1bda
Merge branch 'main' into cj/refactor-conversation
35C4n0r Jan 26, 2026
b0147e6
chore(Conversation): rename String() to Text()
johnstcn Feb 3, 2026
ff1e36d
chore: use ErrXXX naming pattern
johnstcn Feb 3, 2026
c340cf3
Clarify conversation interface
johnstcn Feb 3, 2026
b49989c
clarify usage of Snapshot()
johnstcn Feb 3, 2026
0320e5c
Merge remote-tracking branch 'origin/main' into HEAD
johnstcn Feb 3, 2026
b0656fd
fix merge mistakes
johnstcn Feb 3, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion cmd/attach/attach.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,8 @@ import (

tea "github.com/charmbracelet/bubbletea"
"github.com/coder/agentapi/lib/httpapi"
"github.com/coder/agentapi/lib/util"
"github.com/coder/quartz"
"github.com/spf13/cobra"
sse "github.com/tmaxmax/go-sse"
"golang.org/x/term"
Expand Down Expand Up @@ -213,7 +215,7 @@ func runAttach(remoteUrl string) error {
p.Send(finishMsg{})
select {
case <-pErrCh:
case <-time.After(1 * time.Second):
case <-util.After(quartz.NewReal(), 1*time.Second):
}

return err
Expand Down
12 changes: 6 additions & 6 deletions lib/httpapi/server.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ type Server struct {
srv *http.Server
mu sync.RWMutex
logger *slog.Logger
conversation *st.Conversation
conversation *st.PTYConversation
Copy link
Collaborator

@35C4n0r 35C4n0r Jan 23, 2026 •
edited
Loading

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@johnstcn Shouldn't this be *st.Conversation ? (It's possible that I'm lacking the context/motive behind this refactor, If we have extracted an interface, shouldn't we be using it rather than coupling this to the concrete implementation ?)

Copy link
Member Author

@johnstcn johnstcn Jan 23, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It should, but there's some more coupling to be disentangled here before we can do that.

agentio *termexec.Process
agentType mf.AgentType
emitter *EventEmitter
Expand Down Expand Up @@ -244,7 +244,7 @@ func NewServer(ctx context.Context, config ServerConfig) (*Server, error) {
return mf.FormatToolCall(config.AgentType, message)
}

conversation := st.NewConversation(ctx, st.ConversationConfig{
conversation := st.NewPTY(ctx, st.PTYConversationConfig{
AgentType: config.AgentType,
AgentIO: config.Process,
Clock: config.Clock,
Expand Down Expand Up @@ -337,7 +337,7 @@ func sseMiddleware(ctx huma.Context, next func(huma.Context)) {
}

func (s *Server) StartSnapshotLoop(ctx context.Context) {
s.conversation.StartSnapshotLoop(ctx)
s.conversation.Start(ctx)
go func() {
ticker := s.clock.NewTicker(snapshotInterval)
defer ticker.Stop()
Expand All @@ -346,7 +346,7 @@ func (s *Server) StartSnapshotLoop(ctx context.Context) {

// Send initial prompt when agent becomes stable for the first time
if !s.conversation.InitialPromptSent && convertStatus(currentStatus) == AgentStatusStable {
if err := s.conversation.SendMessage(FormatMessage(s.agentType, s.conversation.InitialPrompt)...); err != nil {
if err := s.conversation.Send(FormatMessage(s.agentType, s.conversation.InitialPrompt)...); err != nil {
s.logger.Error("Failed to send initial prompt", "error", err)
} else {
s.conversation.InitialPromptSent = true
Expand All @@ -357,7 +357,7 @@ func (s *Server) StartSnapshotLoop(ctx context.Context) {
}
s.emitter.UpdateStatusAndEmitChanges(currentStatus, s.agentType)
s.emitter.UpdateMessagesAndEmitChanges(s.conversation.Messages())
s.emitter.UpdateScreenAndEmitChanges(s.conversation.Screen())
s.emitter.UpdateScreenAndEmitChanges(s.conversation.Text())

select {
case <-ctx.Done():
Expand Down Expand Up @@ -461,7 +461,7 @@ func (s *Server) createMessage(ctx context.Context, input *MessageRequest) (*Mes

switch input.Body.Type {
case MessageTypeUser:
if err := s.conversation.SendMessage(FormatMessage(s.agentType, input.Body.Content)...); err != nil {
if err := s.conversation.Send(FormatMessage(s.agentType, input.Body.Content)...); err != nil {
return nil, xerrors.Errorf("failed to send message: %w", err)
}
case MessageTypeRaw:
Expand Down
Loading