planet

type CreatePlanetCommand struct {
	Name    string `json:"name"`
	Climate string `json:"climate"`
	Terrain string `json:"terrain"`
}

type CreatePlanetEvent struct {
	PlanetID   ID  `json:"planet_id"`
	RetryCount int `json:"retry_count"`
}

type Deleter interface {
	Delete(id ID) error
}

type Error struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type EventProcessor interface {
	Process(data interface{}) error
}

type EventType int

type EventsProcessor map[string]EventProcessor

type Film struct {
	Title       string    `bson:"title" json:"title"`
	ReleaseDate time.Time `bson:"release_date" json:"release_date"`
}

type Films []Film

type HttpHandler interface {
	Handle(c *gin.Context)
}

type ID string

type KafkaRead interface {
	Read()
}

type KafkaWriter interface {
	Write(topic string, eventType EventType, msg []byte) error
}

type Metadata struct {
	Page       int `json:"page"`
	PerPage    int `json:"per_page"`
	PageCount  int `json:"page_count"`
	TotalCount int `json:"total_count"`
}

type PageFilterRequest struct {
	Name    string `form:"name"`
	Page    int    `form:"page"`
	PerPage int    `form:"per_page"`
}

type Pagination struct {
	Meta    Metadata    `json:"_metadata"`
	Results interface{} `json:"results"`
}

type PlanetDocument struct {
	PlanetID       ID       `bson:"planetID" json:"planet_id"`
	Name           string   `bson:"name" json:"name"`
	Climate        []string `bson:"climate" json:"climate"`
	Terrain        []string `bson:"terrain" json:"terrain"`
	Films          Films    `bson:"films" json:"films"`
	Status         string   `bson:"status" json:"status"`
	mgm.IDField    `bson:" ,inline" json:"-"`
	mgm.DateFields `bson:" ,inline"`
}

type ReadUpdater interface {
	Reader
	Updater
}

type Reader interface {
	ReadByPlanetId(id ID) (PlanetDocument, error)
	ReadAll(filter PageFilterRequest) ([]PlanetDocument, error)
	Count() (int, error)
}

type StateResponse struct {
	PlanetID ID     `json:"planet_id"`
	Status   string `json:"status"`
}

type Status int

type Updater interface {
	Update(planet PlanetDocument) error
}

type Writer interface {
	Write(createPlanet CreatePlanetCommand) (PlanetDocument, error)
}