awssqsevents

type CloudTrailEvent struct {
	Version    string                `json:"version"`
	ID         string                `json:"id"`
	DetailType string                `json:"detail-type"` //nolint:tagliatelle
	Source     string                `json:"source"`
	Account    string                `json:"account"`
	Time       string                `json:"time"`
	Region     string                `json:"region"`
	Detail     CloudTrailEventDetail `json:"detail"`
}

type CloudTrailEventBuilder[T IEvent] struct{}

type CloudTrailEventDetail struct {
	EventVersion string `json:"eventVersion"`
	UserIdentity struct {
		Type           string `json:"type"`
		PrincipalID    string `json:"principalId"`
		ARN            string `json:"arn"`
		AccountID      string `json:"accountId"`
		AccessKeyID    string `json:"accessKeyId"`
		SessionContext struct {
			Attributes    map[string]any `json:"attributes"`
			SessionIssuer map[string]any `json:"sessionIssuer"`
		}
	}
	EventTime          string         `json:"eventTime"`
	EventSource        string         `json:"eventSource"`
	EventName          string         `json:"eventName"`
	AWSRegion          string         `json:"awsRegion"`
	SourceIPAddress    string         `json:"sourceIPAddress"` //nolint:tagliatelle
	UserAgent          string         `json:"userAgent"`
	ErrorCode          string         `json:"errorCode"`
	ErrorMessage       string         `json:"errorMessage"`
	RequestParameters  map[string]any `json:"requestParameters"`
	ResponseElements   map[string]any `json:"responseElements"`
	RequestID          string         `json:"requestID"` //nolint:tagliatelle
	EventID            string         `json:"eventID"`   //nolint:tagliatelle
	ReadOnly           bool           `json:"readOnly"`
	EventType          string         `json:"eventType"`
	ManagementEvent    bool           `json:"managementEvent"`
	RecipientAccountID string         `json:"recipientAccountId"`
	EventCategory      string         `json:"eventCategory"`
	TLSDetails         struct {
		CipherSuite              string `json:"cipherSuite"`
		TLSVersion               string `json:"tlsVersion"`
		ClientProvidedHostHeader string `json:"clientProvidedHostHeader"`
	} `json:"tlsDetails"`
	SessionCredentialFromConsole string `json:"sessionCredentialFromConsole"`
}

type CloudTrailImportEvent struct {
	Name    string `json:"name"`
	Source  string `json:"source"`
	Region  string `json:"region"`
	Account string `json:"account"`
}

type EventBuilderMock struct {
	GetPipelineEventFunc func(ctx context.Context, data []byte) (entities.PipelineEvent, error)

	AssertData    func(data []byte)
	ReturnedEvent *entities.Event
	ReturnedErr   error
}

type IEvent interface {
	ResourceName() (string, error)
	EventSource() string
	GetRegion() string
	AccountID() string
	Operation() (entities.Operation, error)
	EventType() string
}

type PipelineGroupMock struct {
	AddMessageInvoked bool
	StartInvoked      bool
	CloseInvoked      bool

	AssertAddMessage func(data entities.PipelineEvent)
	CloseErr         error
}