cliproto

type AuthExchangeReply struct {
	JWT         string    `json:"jwt"`
	NATSURL     string    `json:"nats_url"`
	AccountID   string    `json:"account_id"`
	AccountName string    `json:"account_name"`
	ExpiresAt   time.Time `json:"expires_at"`

	// Auth V2 Phase 3 — short-lived NATS user credentials. The daemon
	// uses NATSUserJWT + NATSUserSeed in nats.UserJWT(...) when
	// connecting to the NATS server URL. Re-fetch before ExpiresAt
	// (currently 5min) by re-running /auth/exchange with the same
	// bearer.
	NATSUserJWT  string `json:"nats_user_jwt"`
	NATSUserSeed string `json:"nats_user_seed"`
}

type AuthExchangeRequest struct {
	APIKey string `json:"api_key"`
	// AccountID (Phase 3.5): which org's account to mint a User JWT in.
	// Optional — server defaults to the bearer's primary org (first
	// owned, or first member). Multi-org users specify it explicitly
	// to switch which org their daemon talks to.
	AccountID string `json:"account_id,omitempty"`
}

type Code string

type ConnectReply struct {
	Handle string `json:"handle"`
}

type ConnectRequest struct {
	Handle  string `json:"handle"`
	Session string `json:"session,omitempty"`
}

type CreateInviteReply struct {
	Invite Invite `json:"invite"`
}

type CreateInviteRequest struct {
	Username string `json:"username"`
}

type CreateReply struct {
	Handle   string   `json:"handle"`
	Manifold string   `json:"manifold,omitempty"` // Phase 1.5.1
	Subject  string   `json:"subject"`
	Pipes    []string `json:"pipes,omitempty"` // pipe names provisioned for this source
}

type CreateRequest struct {
	Handle   string `json:"handle"`
	Kind     string `json:"kind,omitempty"`     // "message" (default) or "pty"
	Manifold string `json:"manifold,omitempty"` // Phase 1.5.1: namespace-aware source create
	Session  string `json:"session,omitempty"`  // sets per-session current after create
}

type CreateSourceReply struct {
	ID        string    `json:"id"`
	Handle    string    `json:"handle"`
	Manifold  string    `json:"manifold,omitempty"` // Phase 1.5.1
	Kind      string    `json:"kind"`
	Subject   string    `json:"subject"`
	CreatedAt time.Time `json:"created_at"`
}

type CreateSourceRequest struct {
	Handle   string `json:"handle"`
	Kind     string `json:"kind,omitempty"`     // "message" (default) or "pty"
	Manifold string `json:"manifold,omitempty"` // Phase 1.5.1: source lives at this manifold
}

type DiagEvent struct {
	Type   string    `json:"type"`
	At     time.Time `json:"at"`
	Reason string    `json:"reason,omitempty"`
}

type DiagReply struct {
	NATSState         string      `json:"nats_state,omitempty"`
	NATSDropsLastHour int         `json:"nats_drops_last_hour,omitempty"`
	NATSEvents        []DiagEvent `json:"nats_events"`
}

type DiagRequest struct{}

type DisconnectReply struct{}

type DisconnectRequest struct {
	Session string `json:"session,omitempty"`
}

type Error struct {
	Code    Code   `json:"code"`
	Message string `json:"message"`
}

type HTTPError struct {
	Error Error `json:"error"`
}

type Invite struct {
	ID              string `json:"id"`
	AccountID       string `json:"account_id"`
	AccountName     string `json:"account_name,omitempty"`
	InviteeUsername string `json:"invitee_username"`
	InviterUserID   string `json:"inviter_user_id"`
	Status          string `json:"status"`
	CreatedAt       string `json:"created_at"`
	DecidedAt       string `json:"decided_at,omitempty"`
}

type ListInvitesReply struct {
	Invites []Invite `json:"invites"`
}

type ListReply struct {
	Sources []Source `json:"sources"`
	// Phase 1.5: uncollared (sourceless) pipes — pipes with source_id IS
	// NULL. Walking sources alone misses them. The daemon enriches each
	// row with JetStream stats the same way it does PipeInfos.
	UncollaredPipes []UncollaredPipe `json:"uncollared_pipes,omitempty"`
}

type ListRequest struct {
	Session string `json:"session,omitempty"` // cursor key
}

type ListSourcesReply struct {
	Sources []Source `json:"sources"`
}

type ListUncollaredPipesReply struct {
	Pipes []UncollaredPipeListEntry `json:"pipes"`
}

type ListWatchRequest struct {
	Session  string   `json:"session,omitempty"`
	Patterns []string `json:"patterns,omitempty"`
}

type LoginReply struct {
	URL       string `json:"url"`
	KeyPrefix string `json:"key_prefix"`
	AccountID string `json:"account_id"`
}

type LoginRequest struct {
	URL    string `json:"url"`
	APIKey string `json:"api_key"`
}

type PipeCreateReply struct {
	Handle     string `json:"handle"`
	Manifold   string `json:"manifold,omitempty"` // Phase 1.5
	Name       string `json:"name"`
	StreamName string `json:"stream_name"`
	TTLSeconds int    `json:"ttl_seconds"`
	MaxMsgs    int    `json:"max_msgs"`
	MaxBytes   int64  `json:"max_bytes"`
}

type PipeCreateRequest struct {
	Handle       string  `json:"handle"`
	Manifold     string  `json:"manifold,omitempty"`
	SourceHandle *string `json:"source_handle,omitempty"`
	Name         string  `json:"name"`
	TTLSeconds   *int    `json:"ttl_seconds,omitempty"`
	MaxMsgs      *int    `json:"max_msgs,omitempty"`
	MaxBytes     *int64  `json:"max_bytes,omitempty"`

	// Session is set by the CLI for daemon-side manifold lookup; the IPC
	// transport drops it before forwarding to the server. Phase 1.5.
	Session string `json:"session,omitempty"`
}

type PipeDestroyReply struct {
	Handle   string `json:"handle"`
	Manifold string `json:"manifold,omitempty"` // Phase 1.5: present for uncollared destroys
	Name     string `json:"name"`
}

type PipeDestroyRequest struct {
	Handle string `json:"handle"`
	Name   string `json:"name"`
	// Phase 1.5: BareTarget set by the CLI when the user typed
	// `ppz pipe destroy LEAF` without a dot. Daemon resolves as an
	// uncollared pipe at the session's current namespace.
	BareTarget string `json:"bare_target,omitempty"`
	Session    string `json:"session,omitempty"`
	// Manifold is set by callers that already know the target pipe's
	// manifold (e.g. the glob path needs to destroy uncollared pipes
	// across manifolds, not just the session's). When empty, the
	// daemon falls back to the session's current_namespace.
	Manifold string `json:"manifold,omitempty"`
}

type PipeInfo struct {
	Pipe      string     `json:"pipe"`
	Total     uint64     `json:"total"`
	Unread    uint64     `json:"unread"`
	LastSeq   uint64     `json:"last_seq,omitempty"`
	LastAt    *time.Time `json:"last_at,omitempty"`
	Preview   string     `json:"preview,omitempty"`    // truncated to 60 bytes for table view
	Payload   string     `json:"payload,omitempty"`    // full untruncated payload for `ls --json`
	CreatedBy string     `json:"created_by,omitempty"` // username; empty → inherit Source.CreatedBy
}

type ReadEvent struct {
	Message *ReadMessage `json:"msg,omitempty"`
	Error   *Error       `json:"error,omitempty"`
	// Meta is an optional leading event (sent before any Message events)
	// carrying out-of-band stream metadata — currently the source pty's
	// dimensions for `<h>.stdout` reads, sourced from the latest
	// `<h>.stdctrl` resize. Lets the CLI configure its --tty renderer
	// to match the source size before consuming bytes.
	Meta *ReadMeta `json:"meta,omitempty"`
}

type ReadMessage struct {
	ID           string `json:"id"`
	Sender       string `json:"sender"`
	Subject      string `json:"subject"`
	Payload      string `json:"payload"`
	CreatedAt    string `json:"created_at"`
	InReplyTo    string `json:"in_reply_to"`
	AckRequested bool   `json:"ack_requested"`
}

type ReadMeta struct {
	Cols int `json:"cols,omitempty"`
	Rows int `json:"rows,omitempty"`
}

type ReadRequest struct {
	Handle    string `json:"handle"`
	Channel   string `json:"channel"`            // pipe name: broadcast / stdin / stdout
	Limit     int    `json:"limit,omitempty"`    // 0 = unlimited; non-zero = tail-N (reread only)
	Skip      int    `json:"skip,omitempty"`     // drop the first N retained messages (reread only)
	SinceMS   int64  `json:"since_ms,omitempty"` // 0 = no time filter; >0 = only msgs newer than (now − this many ms) (reread only)
	JSON      bool   `json:"json,omitempty"`     // emit envelope as JSON instead of payload text
	Follow    bool   `json:"follow,omitempty"`
	Session   string `json:"session,omitempty"`    // cursor key — defaults to "default" daemon-side
	NoAdvance bool   `json:"no_advance,omitempty"` // observational reads (terminal view) skip cursor advance
	All       bool   `json:"all,omitempty"`        // forensic mode (`reread`): ignore the cursor (deliver everything) and don't advance it. Implies NoAdvance.

	// Phase 1.5: BareTarget carries the raw user input when `ppz
	// read/reread LEAF` was bare. The daemon resolves it as an
	// uncollared pipe at the session's current_namespace. Handle and
	// Channel are empty in this case.
	BareTarget string `json:"bare_target,omitempty"`
}

type SendBatchReply struct {
	IDs     []string `json:"ids"`
	Subject string   `json:"subject"`
	Bytes   []int    `json:"bytes"`
}

type SendBatchRequest struct {
	Handle     string   `json:"handle,omitempty"`
	Channel    string   `json:"channel,omitempty"`
	BareTarget string   `json:"bare_target,omitempty"` // Phase 1.5: see SendRequest.BareTarget
	Payloads   []string `json:"payloads"`
	Session    string   `json:"session,omitempty"`
}

type SendReply struct {
	ID      string `json:"id"`
	Subject string `json:"subject"`
	Bytes   int    `json:"bytes"`
}

type SendRequest struct {
	// Optional explicit target. If both empty, daemon publishes to its
	// current source on .broadcast. If Handle is set, publishes to
	// <Handle>.<Channel|"broadcast">. Used by `ppz send` and by
	// `ppz broadcast` when PPZ_CURRENT_HANDLE is exported (e.g. inside
	// a `ppz terminal` child).
	//
	// `channel` JSON tag preserved for IPC backward-compat within Phase A;
	// it carries a pipe name. Phase B reorganises.
	Handle  string `json:"handle,omitempty"`
	Channel string `json:"channel,omitempty"`
	Payload string `json:"payload"`
	// MsgSubject is an optional envelope-level subject (header-line). Free-
	// form for users (set via `ppz send --subject`); subjects starting with
	// `ack:` are reserved for daemon-internal protocol messages (ack
	// emission) and rejected at the IPC trust boundary in handleSend.
	MsgSubject string `json:"msg_subject,omitempty"`
	// InReplyTo / AckRequested mirror the new envelope fields (v0.25.0).
	// JSON tags align with the envelope (`in_reply_to`, `ack_requested`)
	// rather than the older `msg_subject` precedent — these are 1:1 with
	// envelope fields.
	InReplyTo    string `json:"in_reply_to,omitempty"`
	AckRequested bool   `json:"ack_requested,omitempty"`
	// Session keys the per-session current-source fallback when neither
	// Handle nor PPZ_CURRENT_HANDLE is set.
	Session string `json:"session,omitempty"`

	// Phase 1.5: BareTarget carries the raw target string when the user
	// typed `ppz send LEAF` without a dot. The CLI mangles the bare form
	// to {Handle: LEAF, Channel: "inbox"} for backward compat with the
	// collared recipient.inbox shorthand; BareTarget lets the daemon
	// recognise the original bare form and fall back to uncollared pipe
	// resolution if the source handle lookup misses. Empty when the user
	// typed an explicit `<H>.<P>` form.
	BareTarget string `json:"bare_target,omitempty"`
}

type SetNamespaceReply struct {
	Namespace string `json:"namespace"`
}

type SetNamespaceRequest struct {
	Namespace string `json:"namespace"` // dot-separated path; ” = root (clear)
	Session   string `json:"session,omitempty"`
}

type Source struct {
	Handle   string `json:"handle"`
	Manifold string `json:"manifold,omitempty"` // Phase 1.5.1
	Kind     string `json:"kind,omitempty"`
	// Pipes is the list of user-created pipe names on this source (NOT the
	// auto-provisioned set — derive those from Kind). Set by the server's
	// /api/v1/sources response.
	Pipes     []string   `json:"pipes,omitempty"`
	PipeInfos []PipeInfo `json:"pipe_infos,omitempty"`
	CreatedBy string     `json:"created_by,omitempty"`
	// Legacy broadcast-only summary; kept for the GUI handlers that still
	// read these directly from the postgres-backed sources table.
	LastBroadcastAt      *time.Time `json:"last_broadcast_at,omitempty"`
	LastBroadcastPayload *string    `json:"last_broadcast_payload,omitempty"`
}

type SourceDestroyReply struct {
	Handle   string `json:"handle"`
	Manifold string `json:"manifold,omitempty"` // Phase 1.5.2: render manifold.handle in display
}

type SourceDestroyRequest struct {
	Handle string `json:"handle"`
}

type SourceKind string

type StatusReply struct {
	DaemonPID          int        `json:"daemon_pid"`
	DaemonVersion      string     `json:"daemon_version,omitempty"`
	LoggedIn           bool       `json:"logged_in"`
	URL                string     `json:"url,omitempty"`
	KeyPrefix          string     `json:"key_prefix,omitempty"`
	AccountID          string     `json:"account_id,omitempty"`
	AccountName        string     `json:"account_name,omitempty"`
	LastTokenRefreshAt *time.Time `json:"last_token_refresh_at,omitempty"`
	// LoginCheck is the daemon's last verification result against the
	// server. "ok" means a recent server-touching call succeeded;
	// "invalid" means the server returned E_INVALID_API_KEY (key
	// revoked / rotated since login). Empty / "unknown" means we
	// haven't observed yet — status performs an active probe in that
	// case so the user always sees the truth.
	LoginCheck string `json:"login_check,omitempty"`
	Current    string `json:"current,omitempty"`
	// CurrentNamespace is the per-session manifold (Phase 1.5). Empty
	// when unset = root namespace. Rendered as a `namespace: …` line by
	// `ppz status`.
	CurrentNamespace string `json:"current_namespace,omitempty"`
	// CurrentPath is the daemon-side path to current.json — surfaced so
	// `ppz status`'s env/daemon-disagree warning can point users at the
	// actual file (which lives in the daemon's home, not the CLI's, when
	// they're separate processes).
	CurrentPath string `json:"current_path,omitempty"`
	// NATSState is one of "connected", "disconnected", "connecting" —
	// the daemon's current NATS connection state. Empty means
	// unobserved (no connection ever attempted, e.g. fresh daemon
	// pre-login). Drives the `nats:` line in `ppz status` output;
	// underlying event log is available via `ppz diagnostics`. (Phase 0 of
	// agent hardening, docs/WIRE.md §8.)
	NATSState string `json:"nats_state,omitempty"`
}

type StatusRequest struct {
	Session string `json:"session,omitempty"`
}

type SwitchReply struct {
	Handle string `json:"handle"`
}

type SwitchRequest struct {
	Handle  string `json:"handle"`
	Session string `json:"session,omitempty"`
}

type UncollaredPipe struct {
	Manifold string   `json:"manifold,omitempty"` // ” = root namespace
	Name     string   `json:"name"`
	Info     PipeInfo `json:"info"`
}

type UncollaredPipeListEntry struct {
	Manifold  string `json:"manifold,omitempty"`
	Name      string `json:"name"`
	CreatedBy string `json:"created_by,omitempty"`
}

type UnsetNamespaceReply struct{}

type UnsetNamespaceRequest struct {
	Session string `json:"session,omitempty"`
}

type WhoEntry struct {
	Handle    string    `json:"handle"`
	Owner     string    `json:"owner,omitempty"`
	Payload   string    `json:"payload"`
	ArrivedAt time.Time `json:"arrived_at"`
}

type WhoReply struct {
	Entries []WhoEntry `json:"entries"`
}

type WhoRequest struct{}