client

Documentation

Overview

Package client is the reference client for the dcode protocol.

It is the first consumer of the contract. If the API feels awkward here, the protocol is what needs fixing, not this package.

It holds no session state: only a read position, which is what lets a client die and rejoin without the session noticing.

Index

• type Client
  • func New(socketPath string) *Client
  • func (c *Client) CommitDone(ctx context.Context, id string) (protocol.CommitDoneResponse, error)
  • func (c *Client) CreateSession(ctx context.Context, req protocol.CreateSessionRequest) (protocol.Session, error)
  • func (c *Client) DeleteSession(ctx context.Context, id string) error
  • func (c *Client) Exec(ctx context.Context, id, command string) error
  • func (c *Client) GetSession(ctx context.Context, id string) (protocol.Session, error)
  • func (c *Client) Health(ctx context.Context) error
  • func (c *Client) Interrupt(ctx context.Context, id string) error
  • func (c *Client) ListSessions(ctx context.Context) ([]protocol.Session, error)
  • func (c *Client) ListSpecs(ctx context.Context, workspace string, measure bool) ([]protocol.SpecFolder, error)
  • func (c *Client) RenameSession(ctx context.Context, id, name string) error
  • func (c *Client) Resolve(ctx context.Context, id, approvalID string, d protocol.ApprovalDecision) error
  • func (c *Client) SetMode(ctx context.Context, id, mode string) error
  • func (c *Client) Steer(ctx context.Context, id, text string) error
  • func (c *Client) Submit(ctx context.Context, id, text string, images ...protocol.TurnImage) error
  • func (c *Client) Subscribe(ctx context.Context, id string, from uint64) (<-chan protocol.Event, <-chan error)
  • func (c *Client) Undo(ctx context.Context, id string) (protocol.UndoResult, error)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client talks to a dcode daemon over a Unix socket.

func New

func New(socketPath string) *Client

New builds a client for a socket path.

func (*Client) CommitDone

func (c *Client) CommitDone(ctx context.Context, id string) (protocol.CommitDoneResponse, error)

ListSessions returns live sessions. CommitDone writes the definition of done a qualifying session proposed.

A call the loop makes after the turn ends, because the turn runs in plan mode and cannot write — and because measuring inside it would run the criteria under a boundary they were never meant to run under.

func (*Client) CreateSession

func (c *Client) CreateSession(ctx context.Context, req protocol.CreateSessionRequest) (protocol.Session, error)

CreateSession opens a session.

func (*Client) DeleteSession

func (c *Client) DeleteSession(ctx context.Context, id string) error

DeleteSession closes a session.

func (*Client) Exec

func (c *Client) Exec(ctx context.Context, id, command string) error

Exec runs a command the person typed, outside a turn.

It blocks until the command finishes. The output arrives on the event stream, not in the response: a client that disconnected mid-command and came back sees exactly what one that stayed sees.

func (*Client) GetSession

func (c *Client) GetSession(ctx context.Context, id string) (protocol.Session, error)

GetSession returns one session.

func (*Client) Health

func (c *Client) Health(ctx context.Context) error

Health reports whether a daemon is answering.

func (*Client) Interrupt

func (c *Client) Interrupt(ctx context.Context, id string) error

Interrupt cancels the running turn.

func (*Client) ListSessions

func (c *Client) ListSessions(ctx context.Context) ([]protocol.Session, error)

func (*Client) ListSpecs

func (c *Client) ListSpecs(ctx context.Context, workspace string, measure bool) ([]protocol.SpecFolder, error)

ListSpecs asks which spec folders a workspace has and which are pending.

The daemon decides "pending" because deciding it means running the folder's criteria, and the daemon is the one with the disk and the sandbox.

func (*Client) RenameSession

func (c *Client) RenameSession(ctx context.Context, id, name string) error

RenameSession names a conversation, live or not.

An empty name restores the title derived from the first question. That is the way back rather than a second call for undoing: one operation with a meaningful zero value is one thing to get right.

func (*Client) Resolve

func (c *Client) Resolve(ctx context.Context, id, approvalID string, d protocol.ApprovalDecision) error

func (*Client) SetMode

func (c *Client) SetMode(ctx context.Context, id, mode string) error

SetMode switches the session behavioural mode: plan, assist or auto.

The change is not in the response. It arrives on the event stream as session.mode_changed, so a client that was not attached when it happened still learns the mode from the log rather than from a call it missed.

func (*Client) Steer

func (c *Client) Steer(ctx context.Context, id, text string) error

Steer hands a running turn something the person said, without ending it.

Refused when no turn is running: a correction to a turn that already finished is a new message, and quietly turning it into one would let the person believe an urgent instruction landed when it never did.

func (*Client) Submit

func (c *Client) Submit(ctx context.Context, id, text string, images ...protocol.TurnImage) error

Submit sends user input. Submit sends a turn, optionally with pictures.

func (*Client) Subscribe

func (c *Client) Subscribe(ctx context.Context, id string, from uint64) (<-chan protocol.Event, <-chan error)

Subscribe streams events from `from`, reconnecting on its own.

Reconnection resumes at the last sequence seen plus one, which is why the read position is the only state a client keeps. Reconnecting therefore behaves exactly like connecting for the first time.

func (*Client) Undo

func (c *Client) Undo(ctx context.Context, id string) (protocol.UndoResult, error)

Resolve answers a pending approval. Undo puts back what the last turn changed.