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-SHA1 signature of canonical notification 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
}