ws

type AckPayload struct {
	// ClientSeq echoes the seq from the client message being acknowledged.
	ClientSeq uint64 `json:"client_seq"`

	// Error is non-empty when the acknowledged request failed.
	// Clients should treat a non-empty Error as equivalent to [TypeError] for
	// the specific operation.
	Error string `json:"error,omitempty"`
}

type DiagEvent struct {
	Component string // "server" or "worker:<id>"
	Level     string // DEBUG|INFO|WARN|ERROR
	Msg       string
	Attrs     map[string]string
	At        time.Time
}

type DiagnosticsPush struct {
	Component string            `json:"component"`
	Level     string            `json:"level"`
	Msg       string            `json:"msg"`
	Attrs     map[string]string `json:"attrs,omitempty"`
	At        time.Time         `json:"at"`
}

type Envelope struct {
	// Type is the message discriminator. Required.
	Type MessageType `json:"type"`

	// Subject identifies the resource or stream the message concerns.
	//
	// For client subscribe/unsubscribe: the subscription target
	// (e.g. "jobs/abc123/tasks").
	//
	// For server push: the subject that generated the event.
	//
	// Omitted for ping/pong, ack, and error messages not tied to a subject.
	Subject string `json:"subject,omitempty"`

	// Payload carries message-specific data as a raw JSON value.
	//
	//   TypeSubscribe   → [SubscribePayload]
	//   TypePush        → subject-specific event struct
	//   TypeAck         → [AckPayload]
	//   TypeError       → [ErrorPayload]
	//   TypeUnsubscribe, TypePing, TypePong → nil
	Payload json.RawMessage `json:"payload,omitempty"`

	// Seq is the monotonically increasing sequence number.
	//
	//   TypePush (server → client): a per-subject hub-level counter assigned by
	//   [Hub]. Starts at 1 and increases globally (not per-connection) so
	//   clients can pass the last received Seq as since_seq when reconnecting.
	//
	//   TypeAck (server → client): 0; the acknowledged client seq is carried in
	//   [AckPayload.ClientSeq] instead.
	//
	//   Client messages (TypeSubscribe, TypeUnsubscribe): a client-chosen
	//   counter echoed back in the corresponding TypeAck so the client can
	//   correlate responses.
	//
	//   TypePing / TypePong / TypeError: always 0.
	Seq uint64 `json:"seq"`
}

type ErrorPayload struct {
	// Code is a machine-readable error identifier, e.g. "invalid_subject".
	Code string `json:"code"`

	// Message is a human-readable description of the error.
	Message string `json:"message"`
}

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

type JobEvent struct {
	JobID     string
	Name      string
	Owner     string
	QueueID   string
	Status    string // store.JobStatus value
	UpdatedAt time.Time
}

type JobSummaryPush struct {
	JobID     string    `json:"job_id"`
	TaskID    string    `json:"task_id,omitempty"`
	Name      string    `json:"name,omitempty"`
	Owner     string    `json:"owner,omitempty"`
	QueueID   string    `json:"queue_id,omitempty"`
	Status    string    `json:"status"`
	UpdatedAt time.Time `json:"updated_at"`
}

type LogEvent struct {
	TaskID    string
	AttemptID string
	SeqNum    int64
	Stream    string // "stdout" or "stderr"
	Data      string
	At        time.Time
}

type MessageType string

type NoopNotifier struct{}

type Notifier interface {
	NotifyTask(e TaskEvent)
	NotifyWorker(e WorkerEvent)
	NotifyLog(e LogEvent)
	NotifyJob(e JobEvent)
	NotifyDiag(e DiagEvent)
}

type SubscribePayload struct {
	// SinceSeq instructs the server to replay any buffered push messages with
	// seq strictly greater than SinceSeq before streaming live events.
	// A value of 0 (the default) replays all buffered messages for the subject
	// (hub sequences start at 1, so every buffered entry satisfies seq > 0).
	// Pass the last received Seq to resume without replay.
	SinceSeq uint64 `json:"since_seq,omitempty"`
}

type TaskEvent struct {
	JobID     string
	TaskID    string
	Name      string
	Status    string // store.TaskStatus value
	WorkerID  string // empty when unassigned
	UpdatedAt time.Time
}

type TaskLogPush struct {
	TaskID    string    `json:"task_id"`
	AttemptID string    `json:"attempt_id,omitempty"`
	SeqNum    int64     `json:"seq_num"`
	Stream    string    `json:"stream"`
	Data      string    `json:"data"`
	At        time.Time `json:"at"`
}

type TaskUpdatePush struct {
	JobID     string    `json:"job_id"`
	TaskID    string    `json:"task_id"`
	Name      string    `json:"name,omitempty"`
	Status    string    `json:"status"`
	WorkerID  string    `json:"worker_id,omitempty"`
	UpdatedAt time.Time `json:"updated_at"`
}

type WorkerEvent struct {
	WorkerID string
	Name     string
	Hostname string
	FarmID   string
	Status   string // store.WorkerStatus value
}

type WorkerStatusPush struct {
	WorkerID string `json:"worker_id"`
	Name     string `json:"name,omitempty"`
	Hostname string `json:"hostname,omitempty"`
	FarmID   string `json:"farm_id,omitempty"`
	Status   string `json:"status"`
}