tck

type Adapter interface {
	TransportKey() string
	BrokerConfig() BrokerConfig
	StartService(t spectest.T, serviceName string, intents []spectest.SetupIntent) *spectest.ServiceHandle
}

type BrokerClient interface {
	QueryState(t spectest.T) spectest.BrokerState
	PublishRaw(t spectest.T, target spectest.ProbeTarget, payload json.RawMessage, headers map[string]string) error
	CreateProbeConsumer(t spectest.T, target spectest.ProbeTarget) *spectest.ProbeConsumer
	// GetQueueMessages drains and returns messages currently in a named queue
	// (used to assert dead-lettering into the managed DLQ). Currently implemented
	// for AMQP only; the NATS client returns nil (no DLQ scenario runs on NATS).
	GetQueueMessages(t spectest.T, queueName string) []spectest.RawMessage
	Cleanup(t spectest.T)
}

type BrokerConfig struct {
	AMQPURL       string // e.g. amqp://guest:guest@localhost:5672
	ManagementURL string // e.g. http://guest:guest@localhost:15672
	NATSURL       string // e.g. nats://localhost:4222
}

type CloseServiceParams struct {
	ServiceName string `json:"serviceName"`
}

type CoverageEntry struct {
	IntentKey
	Scenarios []string
}

type CoverageMatrix struct {
	Entries []CoverageEntry
	Missing []IntentKey
}

type HelloParams struct {
	ProtocolVersion int `json:"protocolVersion"`
}

type HelloResult struct {
	ProtocolVersion int          `json:"protocolVersion"`
	TransportKey    string       `json:"transportKey"`
	BrokerConfig    BrokerConfig `json:"brokerConfig"`
}

type IntentKey struct {
	Pattern   string
	Direction string
	Ephemeral bool
}

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

type PhaseResult struct {
	Name     string        `json:"name"`
	Passed   bool          `json:"passed"`
	Duration time.Duration `json:"duration"`
	Errors   []string      `json:"errors,omitempty"`
}

type ProbeMessage struct {
	Direction        string            `json:"direction"` // "outbound" or "inbound"
	PublishVia       string            `json:"publishVia,omitempty"`
	ExpectReceivedBy string            `json:"expectReceivedBy,omitempty"`
	RoutingKey       string            `json:"routingKey"`
	Payload          json.RawMessage   `json:"payload"`
	CEAttributes     map[string]string `json:"ceAttributes"`
	PayloadMatch     json.RawMessage   `json:"payloadMatch,omitempty"`
}

type PublishParams struct {
	ServiceName  string            `json:"serviceName"`
	PublisherKey string            `json:"publisherKey"`
	RoutingKey   string            `json:"routingKey"`
	Payload      json.RawMessage   `json:"payload"`
	Headers      map[string]string `json:"headers,omitempty"`
}

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

type ReceivedMessageWire struct {
	RoutingKey   string                 `json:"routingKey"`
	Payload      json.RawMessage        `json:"payload"`
	Metadata     messaging.Metadata     `json:"metadata"`
	DeliveryInfo messaging.DeliveryInfo `json:"deliveryInfo"`
}

type ReceivedParams struct {
	ServiceName string `json:"serviceName"`
}

type ReceivedResult struct {
	Messages []ReceivedMessageWire `json:"messages"`
}

type ReportSummary struct {
	Total  int `json:"total"`
	Passed int `json:"passed"`
	Failed int `json:"failed"`
}

type Request struct {
	ID     int             `json:"id"`
	Method string          `json:"method"`
	Params json.RawMessage `json:"params"`
}

type Response struct {
	ID     int             `json:"id"`
	Result json.RawMessage `json:"result,omitempty"`
	Error  *RPCError       `json:"error,omitempty"`
}

type Scenario struct {
	Name          string                            `json:"name"`
	Transports    []string                          `json:"transports,omitempty"`
	Services      map[string]spectest.ServiceConfig `json:"services"`
	Messages      []spectest.MessageSpec            `json:"messages"`
	ProbeMessages []ProbeMessage                    `json:"probeMessages,omitempty"`
}

type ScenarioReport struct {
	Name     string        `json:"name"`
	Passed   bool          `json:"passed"`
	Duration time.Duration `json:"duration"`
	Services []string      `json:"services"`
	Patterns []string      `json:"patterns"`
	Phases   []PhaseResult `json:"phases"`
}

type ShutdownParams struct{}

type StartServiceParams struct {
	ServiceName string                 `json:"serviceName"`
	Intents     []spectest.SetupIntent `json:"intents"`
}

type StartServiceResult struct {
	PublisherKeys []string           `json:"publisherKeys"`
	Topology      messaging.Topology `json:"topology"`
}

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

type TCKReport struct {
	TransportKey string           `json:"transportKey"`
	Timestamp    time.Time        `json:"timestamp"`
	Scenarios    []ScenarioReport `json:"scenarios"`
	Coverage     CoverageMatrix   `json:"coverage"`
	Summary      ReportSummary    `json:"summary"`
}