core

type FilterMessage struct {
	TopicId       []uuid.UUID
	Status        []MessageStatus
	SortBy        string
	SortDirection string
	Offset        int
	Limit         int
}

type FilterSubscriber struct {
	TopicId     []uuid.UUID
	Name        []string
	WithDeleted bool
}

type FilterTopic struct {
	Name        []string
	WithDeleted bool
}

type Message struct {
	Id        uuid.UUID     `db:"id"`
	TopicId   uuid.UUID     `db:"topic_id"`
	Message   string        `db:"message"`
	Status    MessageStatus `db:"status"`
	CreatedAt string        `db:"created_at"`
}

type MessageStatus string

type Messages []Message

type Subscriber struct {
	Id        uuid.UUID       `db:"id"`
	TopicId   uuid.UUID       `db:"topic_id"`
	TopicName string          `db:"topic_name"`
	Name      string          `db:"name"`
	Option    json.RawMessage `db:"option"`
	CreatedAt string          `db:"created_at"`
	DeletedAt null.String     `db:"deleted_at"`
}

type SubscriberOpt struct {
	MaxAttempts        int    `json:"max_attempts"`
	VisibilityDuration string `json:"visibility_duration"`
}

type Subscribers []Subscriber

type Topic struct {
	Id        uuid.UUID   `db:"id"`
	Name      string      `db:"name"`
	CreatedAt string      `db:"created_at"`
	DeletedAt null.String `db:"deleted_at"`
}

type Topics []Topic