testkit

type AppSyncEventOptions struct {
	FieldName      string
	ParentTypeName string
	Arguments      map[string]any
	Identity       map[string]any
	Source         map[string]any
	Headers        map[string]string
	Variables      map[string]any
	Prev           any
	Stash          map[string]any
}

type CloudWatchLogsSubscriptionOptions struct {
	MessageType         string
	Owner               string
	LogGroup            string
	LogStream           string
	SubscriptionFilters []string
	LogEvents           []apptheory.CloudWatchLogsSubscriptionLogEvent
}

type DynamoDBStreamEventOptions struct {
	StreamARN string
	Records   []DynamoDBStreamRecordOptions
}

type DynamoDBStreamRecordOptions struct {
	EventID   string
	EventName string
}

type Env struct {
	Clock *ManualClock
	IDs   *ManualIDGenerator
}

type EventBridgeEventOptions struct {
	ID         string
	Source     string
	DetailType string
	Resources  []string
	Detail     any
	Time       time.Time
	Region     string
	AccountID  string
}

type FakeSNSClient struct {
	Calls []SNSPublishCall

	PublishErr error
	// contains filtered or unexported fields
}

type FakeStreamerClient struct {
	Endpoint string
	Calls    []StreamerCall

	Connections map[string]streamer.Connection

	PostErr   error
	GetErr    error
	DeleteErr error
	// contains filtered or unexported fields
}

type HTTPEventOptions struct {
	Query        map[string][]string
	Headers      map[string]string
	MultiHeaders map[string][]string
	Cookies      []string
	Body         []byte
	IsBase64     bool
	SourceIP     string
}

type KinesisCloudWatchLogsSubscriptionRecordOptions struct {
	EventID        string
	EventSourceARN string
	PartitionKey   string
	Subscription   CloudWatchLogsSubscriptionOptions
}

type KinesisEventOptions struct {
	StreamARN string
	Records   []KinesisRecordOptions
}

type KinesisRecordOptions struct {
	EventID        string
	EventSourceARN string
	PartitionKey   string
	Data           []byte
}

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

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

type SNSEventOptions struct {
	TopicARN string
	Records  []SNSRecordOptions
}

type SNSPublishCall struct {
	TopicARN string
	Subject  string
	Message  string
}

type SNSRecordOptions struct {
	MessageID string
	TopicArn  string
	Subject   string
	Message   string
}

type SQSEventOptions struct {
	QueueARN string
	Records  []SQSMessageOptions
}

type SQSMessageOptions struct {
	MessageID         string
	Body              string
	EventSourceARN    string
	MessageAttributes map[string]events.SQSMessageAttribute
}

type StepFunctionsTaskTokenEventOptions struct {
	TaskToken string
	Payload   map[string]any
}

type StreamResult struct {
	Status          int
	Headers         map[string][]string
	Cookies         []string
	Chunks          [][]byte
	Body            []byte
	IsBase64        bool
	StreamErrorCode string
}

type StreamerCall struct {
	Op           string
	ConnectionID string
	Data         []byte
}

type WebSocketEventOptions struct {
	RouteKey     string
	EventType    string
	ConnectionID string
	DomainName   string
	Stage        string
	RequestID    string
	Body         string
	IsBase64     bool

	Headers               map[string]string
	MultiValueHeaders     map[string][]string
	QueryStringParameters map[string]string
	MultiValueQueryString map[string][]string
}