notification

type NotificationCleanCommand struct {
	// MaxAge is the maximum age of notifications to keep (e.g., "720h" for 30 days)
	MaxAge libtime.Duration `json:"maxAge"`
	// Limit is the maximum number of notifications to delete in one run (default: 10000)
	Limit int `json:"limit"`
}

type NotificationCleanCommandSender interface {
	SendCleanNotificationCommand(
		ctx context.Context,
		command NotificationCleanCommand,
	) error
}

type NotificationCleanCommandSenderFunc func(ctx context.Context, command NotificationCleanCommand) error

type NotificationPublishCommand struct {
	// Type of the notification
	Type core.NotificationType `json:"type"`

	// Target of the notification (discord channelName, telegram room ...)
	Target *core.NotificationTarget `json:"target,omitempty"`

	// Message of the notification
	Message core.NotificationMessage `json:"message"`

	// Metadata carries source-specific fields as opaque key/value pairs
	// (e.g. trading producers pack brokerIdentifier/stage/accountIdentifier here).
	Metadata map[string]string `json:"metadata,omitempty"`
}

type NotificationPublishCommandSender interface {
	SendPublishNotificationCommand(
		ctx context.Context,
		command NotificationPublishCommand,
	) error
}

type NotificationPublishCommandSenderFunc func(ctx context.Context, command NotificationPublishCommand) error