domain

type CloudFunction string

type CloudFunctionConfiguration struct {
	Events        []string `xml:"Event"`
	Filter        Filter
	Id            string
	CloudFunction CloudFunction
}

type CloudFunctionInvoker interface {
	Invoke(string) func(interface{})
}

type EventFunction func(string, interface{})

type Filter struct {
	S3Key S3Key
}

type FilterRule struct {
	Name  string
	Value string
}

type JsonTime time.Time

type LambdaRecord struct {
	EventVersion      string                  `json:"eventVersion"`
	EventSource       string                  `json:"eventSource"`
	AwsRegion         string                  `json:"awsRegion"`
	EventTime         JsonTime                `json:"eventTime"`
	EventName         string                  `json:"eventName"`
	UserIdentity      LambdaUserIdentity      `json:"userIdentity"`
	RequestParameters LambdaRequestParameters `json:"requestParameters"`
	ResponseElements  LambdaResponseElements  `json:"responseElements"`
	S3                S3Record                `json:"s3"`
}

type LambdaRequestParameters struct {
	SourceIPAddress string `json:"sourceIPAddress"`
}

type LambdaResponseElements struct {
	RequestId string `json:"x-amz-request-id"`
	Id2       string `json:"x-amz-id-2"`
}

type LambdaUserIdentity struct {
	PrincipalId string `json:"principalId"`
}

type NotificationConfiguration struct {
	CloudFunctionConfigurations []CloudFunctionConfiguration `xml:"CloudFunctionConfiguration"`
}

type NotificationEvent struct {
	Bucket   string
	Key      string // S3 Object key
	Event    string // S3 event (i.e. s3:ObjectCreated", "s3:ObjectRemoved", etc.)
	SourceIp string
	Size     int64
}

type S3Bucket struct {
	Name          string                `json:"name"`
	OwnerIdentity S3BucketOwnerIdentity `json:"ownerIdentity"`
	Arn           string                `json:"arn"`
}

type S3BucketOwnerIdentity struct {
	PrincipalId string `json:"principalId"`
}

type S3Key struct {
	FilterRules []FilterRule `xml:"FilterRule"`
}

type S3Object struct {
	Key       string `json:"key"`
	Size      int64  `json:"size"`
	ETag      string `json:"eTag"`
	Sequencer string `json:"sequencer"`
}

type S3Record struct {
	S3SchemaVersion string   `json:"s3SchemaVersion"`
	ConfigurationId string   `json:"configurationId"`
	Bucket          S3Bucket `json:"bucket"`
	Object          S3Object `json:"object"`
}