query

type AreaQuery interface {
	FindByID(areaUID uuid.UUID) <-chan QueryResult
}

type CropQuery interface {
	FindCropByID(cropUID uuid.UUID) <-chan QueryResult
}

type EventWrapper struct {
	EventName string
	EventData interface{}
}

type MaterialQuery interface {
	FindMaterialByID(materialID uuid.UUID) <-chan QueryResult
}

type QueryResult struct {
	Result interface{}
	Error  error
}

type ReservoirQuery interface {
	FindReservoirByID(reservoirUID uuid.UUID) <-chan QueryResult
}

type TaskAreaQueryResult struct {
	UID  uuid.UUID `json:"uid"`
	Name string    `json:"name"`
}

type TaskCropQueryResult struct {
	UID     uuid.UUID `json:"uid"`
	BatchID string    `json:"batch_id"`
}

type TaskEventQuery interface {
	FindAllByTaskID(uid uuid.UUID) <-chan QueryResult
}

type TaskMaterialQueryResult struct {
	UID              uuid.UUID `json:"uid"`
	TypeCode         string    `json:"type"`
	DetailedTypeCode string    `json:"detailed_type"`
	Name             string    `json:"name"`
}

type TaskReadQuery interface {
	FindAll(page, limit int) <-chan QueryResult
	FindByID(taskUID uuid.UUID) <-chan QueryResult
	FindTasksWithFilter(params map[string]string, page, limit int) <-chan QueryResult
	CountAll() <-chan QueryResult
	CountTasksWithFilter(params map[string]string) <-chan QueryResult
}

type TaskReservoirQueryResult struct {
	UID  uuid.UUID `json:"uid"`
	Name string    `json:"name"`
}