events

type BucketCreatedEvent struct {
	BucketName string
}

type BucketDeletedEvent struct {
	BucketName string
}

type Event interface {
	EventType() string
}

type EventEmitter[T Event] interface {
	Emit(ctx context.Context, event T) error
	Subscribe(listener EventListener[T]) func()
	ListenerCount() int
}

type EventListener[T Event] func(ctx context.Context, event T) error

type InMemoryEmitter[T Event] struct {
	// contains filtered or unexported fields
}

type ItemCreatedEvent struct {
	Key   map[string]any
	Table string
}

type ItemDeletedEvent struct {
	Key   map[string]any
	Table string
}

type ItemUpdatedEvent struct {
	Key   map[string]any
	Table string
}

type ObjectCreatedEvent struct {
	BucketName string
	Key        string
	Size       int64
}

type ObjectDeletedEvent struct {
	BucketName string
	Key        string
}

type S3NotificationEvent struct {
	// Payload is the JSON-encoded S3 event notification body (Records array).
	Payload string
	// TargetARN is the destination ARN (SQS queue ARN, SNS topic ARN, Lambda function ARN).
	TargetARN string
	// TargetType is the notification target type: "sqs", "sns", or "lambda".
	TargetType string
}

type SNSMessageAttributeSnapshot struct {
	// DataType is the attribute data type (String, Number, Binary, …).
	DataType string
	// StringValue is the string value (set when DataType is String/Number).
	StringValue string
}

type SNSPublishedEvent struct {
	Attributes map[string]SNSMessageAttributeSnapshot
	TopicARN   string
	MessageID  string
	Message    string
	Subject    string
	Timestamp  string // RFC3339 timestamp fixed at publish time (used for signing)
	Signature  string // base64 RSA signature of canonical notification string
	// SignatureVersion is the AWS SNS SignatureVersion used to produce Signature:
	// "1" (SHA1withRSA, the AWS default) or "2" (SHA256withRSA). Consumers that
	// re-embed Signature in their own delivery envelope (e.g. SQS) must report
	// this same value so the two fields stay consistent.
	SignatureVersion string
	SigningCertURL   string // URL where the signing certificate PEM can be retrieved
	Subscriptions    []SNSSubscriptionSnapshot
}

type SNSSubscriptionSnapshot struct {
	SubscriptionARN    string
	Protocol           string
	Endpoint           string
	FilterPolicy       string
	RedrivePolicy      string
	DeliveryPolicy     string
	RawMessageDelivery bool
}

type TableCreatedEvent struct {
	Table string
}

type TableDeletedEvent struct {
	Table string
}