testutil

type DualModeTest struct {
	// Name is the test name (will have mode suffix appended).
	Name string

	// Test is the test function. Mode indicates whether the daemon is running.
	// Test should use mode to determine how to execute the command.
	Test func(t *testing.T, mode Mode)

	// SkipDaemon skips daemon mode test if true.
	SkipDaemon bool

	// SkipDirect skips direct mode test if true.
	SkipDirect bool
}

type Fault = faultdaemon.Fault

type FaultConfig struct {
	// Fault is the failure mode to inject.
	Fault Fault

	// SlowResponseDelay is the delay for slow response faults.
	SlowResponseDelay time.Duration

	// DropEveryN drops every Nth connection for drop connection fault.
	DropEveryN int

	// FaultOnMessageType restricts the fault to a specific message type.
	// Other message types respond normally.
	FaultOnMessageType string

	// StatusResponse overrides the daemon's status response.
	StatusResponse *daemon.StatusData

	// DoctorResponse overrides the daemon's doctor response.
	DoctorResponse *daemon.DoctorResponse

	// CheckoutResponse overrides the daemon's checkout response.
	CheckoutResponse *daemon.CheckoutResult

	// SyncError is the error to return for sync requests.
	SyncError error
}

type MockService struct {
	// sync operations
	SyncFunc             func() error
	SyncWithProgressFunc func(progress *daemon.ProgressWriter) error
	TeamSyncFunc         func(progress *daemon.ProgressWriter) error
	SyncHistoryFunc      func() []daemon.SyncEvent

	// status / query operations
	StatusFunc     func() *daemon.StatusData
	GetErrorsFunc  func() []daemon.StoredError
	SessionsFunc   func() []daemon.AgentSession
	InstancesFunc  func() []daemon.InstanceInfo
	WhispersFunc   func(agentID string, attention whisperstore.Attention, topics []string) ([]whisperstore.WhisperEntry, error)
	CodeStatusFunc func() *daemon.CodeDBStats

	// mutation operations
	StopFunc              func()
	CheckoutFunc          func(payload daemon.CheckoutPayload, progress *daemon.ProgressWriter) (*daemon.CheckoutResult, error)
	MarkErrorsFunc        func(ids []string)
	TriggerGCFunc         func() *daemon.TriggerGCResponse
	CodeIndexFunc         func(payload daemon.CodeIndexPayload, progress *daemon.ProgressWriter) (*daemon.CodeIndexResult, error)
	DoctorFunc            func() *daemon.DoctorResponse
	SessionFinalizeFunc   func(payload daemon.SessionFinalizeIPCPayload)
	SessionWatchStartFunc func(payload daemon.SessionWatchStartPayload)
	SessionWatchStopFunc  func(payload daemon.SessionWatchStopPayload)

	// fire-and-forget operations
	ActivityFunc        func()
	HeartbeatFunc       func(callerID string, payload json.RawMessage)
	TelemetryFunc       func(payload json.RawMessage)
	FrictionFunc        func(payload daemon.FrictionPayload)
	PublishMurmurFunc   func(payload daemon.MurmurPayload)
	PauseMurmuringFunc  func(agentID string)
	ResumeMurmuringFunc func(agentID string)
}

type Mode string

type OxFaultConfig struct {
	// Embedded generic config
	faultdaemon.Config

	// StatusResponse is returned for status requests.
	StatusResponse *daemon.StatusData

	// DoctorResponse is returned for doctor requests.
	DoctorResponse *daemon.DoctorResponse

	// CheckoutResponse is returned for checkout requests.
	CheckoutResponse *daemon.CheckoutResult

	// SyncError is the error to return for sync requests (nil = success).
	SyncError error

	// CustomResponses maps message types to custom response data.
	// Value will be marshaled to JSON and wrapped in daemon.Response.
	CustomResponses map[string]any
}

type OxFaultDaemon struct {
	*faultdaemon.FaultDaemon
	// contains filtered or unexported fields
}

type RPCCall struct {
	Type      string
	Payload   json.RawMessage
	Timestamp time.Time
}

type TestEnvironment struct {
	TmpDir     string
	LedgerDir  string
	ProjectDir string
	// contains filtered or unexported fields
}