server

package
v0.0.0-...-ae75a06 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 10, 2022 License: Apache-2.0 Imports: 41 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	Required      = "REQUIRED"
	Alphanumeric  = "ALPHANUMERIC"
	Alpha         = "ALPHA"
	Numeric       = "NUMERIC"
	Float         = "FLOAT"
	ParseFailed   = "PARSE_FAILED"
	InvalidOption = "INVALID_OPTION"
	NotFound      = "NOT_FOUND"
)

Variables

This section is empty.

Functions

func CropContainerHook 

func CropContainerHook() mapstructure.DecodeHookFunc

func Decode 

func Decode(f mapstructure.DecodeHookFunc, data *map[string]interface{}, e interface{}) (interface{}, error)

func Error 

func Error(c echo.Context, err error) error

Error wraps errors from application layer and domain layer to some format in JSON for response

func MapToCropRead 

func MapToCropRead(s *GrowthServer, crop domain.Crop) (storage.CropRead, error)

func Message 

func Message(errorCode string) string

Message translates error code to meaningful message

func TimeHook 

func TimeHook(layout string) mapstructure.DecodeHookFunc

func UIDHook 

func UIDHook() mapstructure.DecodeHookFunc

Types

type CropActivity 

type CropActivity storage.CropActivity

func MapToCropActivity 

func MapToCropActivity(activity storage.CropActivity) CropActivity

type CropListInArea 

type CropListInArea struct {
	UID              uuid.UUID       `json:"uid"`
	BatchID          string          `json:"batch_id"`
	DaysSinceSeeding int             `json:"days_since_seeding"`
	InitialQuantity  int             `json:"initial_quantity"`
	CurrentQuantity  int             `json:"current_quantity"`
	Container        query.Container `json:"container"`
	LastWatered      *time.Time      `json:"last_watered"`
	SeedingDate      time.Time       `json:"seeding_date"`
	MovingDate       time.Time       `json:"moving_date"`
	InitialArea      InitialArea     `json:"initial_area"`
	Inventory        query.Inventory `json:"inventory"`
}

func MapToCropListInArea 

func MapToCropListInArea(crop query.CropAreaByAreaQueryResult) (CropListInArea, error)

type DumpActivity 

type DumpActivity struct{ *storage.DumpActivity }

func (DumpActivity) MarshalJSON 

func (a DumpActivity) MarshalJSON() ([]byte, error)

type File 

type File interface {
	GetFile(src string) ([]byte, error)
	Upload(file *multipart.FileHeader, destPath string) error
}

File used to handle file path and file operation. We use interface so we can swap it to other file storage easily

type GrowthServer 

type GrowthServer struct {
	CropEventRepo     repository.CropEvent
	CropEventQuery    query.CropEventQuery
	CropReadRepo      repository.CropRead
	CropReadQuery     query.CropReadQuery
	CropActivityRepo  repository.CropActivity
	CropActivityQuery query.CropActivityQuery
	CropService       domain.CropService
	AreaReadQuery     query.AreaReadQuery
	MaterialReadQuery query.MaterialReadQuery
	FarmReadQuery     query.FarmReadQuery
	TaskReadQuery     query.TaskReadQuery
	EventBus          eventbus.TaniaEventBus
	File              File
}

GrowthServer ties the routes and handlers with injected dependencies

func NewGrowthServer 

func NewGrowthServer(
	db *sql.DB,
	bus eventbus.TaniaEventBus,
	cropEventStorage *storage.CropEventStorage,
	cropReadStorage *storage.CropReadStorage,
	cropActivityStorage *storage.CropActivityStorage,
	areaReadStorage *assetsstorage.AreaReadStorage,
	materialReadStorage *assetsstorage.MaterialReadStorage,
	farmReadStorage *assetsstorage.FarmReadStorage,
	taskReadStorage *taskstorage.TaskReadStorage,
) (*GrowthServer, error)

NewGrowthServer initializes GrowthServer's dependencies and create new GrowthServer struct

func (*GrowthServer) DumpCrop 

func (s *GrowthServer) DumpCrop(c echo.Context) error

func (*GrowthServer) FindAllCropArchives 

func (s *GrowthServer) FindAllCropArchives(c echo.Context) error

func (*GrowthServer) FindAllCrops 

func (s *GrowthServer) FindAllCrops(c echo.Context) error

func (*GrowthServer) FindAllCropsByArea 

func (s *GrowthServer) FindAllCropsByArea(c echo.Context) error

func (*GrowthServer) FindCropByID 

func (s *GrowthServer) FindCropByID(c echo.Context) error

func (*GrowthServer) GetBatchQuantity 

func (s *GrowthServer) GetBatchQuantity(c echo.Context) error

func (*GrowthServer) GetCropActivities 

func (s *GrowthServer) GetCropActivities(c echo.Context) error

func (*GrowthServer) GetCropPhotos 

func (s *GrowthServer) GetCropPhotos(c echo.Context) error

func (*GrowthServer) GetCropsInformation 

func (s *GrowthServer) GetCropsInformation(c echo.Context) error

func (*GrowthServer) HarvestCrop 

func (s *GrowthServer) HarvestCrop(c echo.Context) error

func (*GrowthServer) InitSubscriber 

func (s *GrowthServer) InitSubscriber()

InitSubscriber defines the mapping of which event this domain listen with their handler

func (*GrowthServer) Mount 

func (s *GrowthServer) Mount(g *echo.Group)

Mount defines the GrowthServer's endpoints with its handlers

func (*GrowthServer) MoveCrop 

func (s *GrowthServer) MoveCrop(c echo.Context) error

func (*GrowthServer) RemoveCropNotes 

func (s *GrowthServer) RemoveCropNotes(c echo.Context) error

func (*GrowthServer) SaveAreaCropBatch 

func (s *GrowthServer) SaveAreaCropBatch(c echo.Context) error

func (*GrowthServer) SaveCropNotes 

func (s *GrowthServer) SaveCropNotes(c echo.Context) error

func (*GrowthServer) SaveToCropActivityReadModel 

func (s *GrowthServer) SaveToCropActivityReadModel(event interface{}) error

func (*GrowthServer) SaveToCropReadModel 

func (s *GrowthServer) SaveToCropReadModel(event interface{}) error

func (*GrowthServer) UpdateCropBatch 

func (s *GrowthServer) UpdateCropBatch(c echo.Context) error

func (*GrowthServer) UploadCropPhotos 

func (s *GrowthServer) UploadCropPhotos(c echo.Context) error

func (*GrowthServer) WaterCrop 

func (s *GrowthServer) WaterCrop(c echo.Context) error

type HarvestActivity 

type HarvestActivity struct{ *storage.HarvestActivity }

func (HarvestActivity) MarshalJSON 

func (a HarvestActivity) MarshalJSON() ([]byte, error)

type InitialArea 

type InitialArea struct {
	AreaUID uuid.UUID `json:"area_id"`
	Name    string    `json:"name"`
}

type LocalFile 

type LocalFile struct{}

func (LocalFile) GetFile 

func (f LocalFile) GetFile(srcPath string) ([]byte, error)

func (LocalFile) Upload 

func (f LocalFile) Upload(file *multipart.FileHeader, destPath string) error

Upload saves uploaded file to the destined path

type MoveActivity 

type MoveActivity struct{ *storage.MoveActivity }

func (MoveActivity) MarshalJSON 

func (a MoveActivity) MarshalJSON() ([]byte, error)

type PhotoActivity 

type PhotoActivity struct{ *storage.PhotoActivity }

func (PhotoActivity) MarshalJSON 

func (a PhotoActivity) MarshalJSON() ([]byte, error)

type RequestValidation 

type RequestValidation struct{}

RequestValidation sanitizes request inputs and convert the input to its correct data type. This is mostly used to prevent issues like invalid data type or potential SQL Injection. So we can focus on processing data without converting data type after this sanitizing. This validation doesn't aim to validate business process. The business process validation will be handled in each entity's behaviour.

type RequestValidationError 

type RequestValidationError struct {
	FieldName    string `json:"field_name"`
	ErrorCode    string `json:"error_code"`
	ErrorMessage string `json:"error_message"`
}

RequestValidationError contains fields used for JSON error response

func NewRequestValidationError 

func NewRequestValidationError(errorCode, fieldName string) RequestValidationError

NewRequestValidationError initializes new RequestValidation struct

func (RequestValidationError) Error 

func (rve RequestValidationError) Error() string

type SeedActivity 

type SeedActivity struct{ *storage.SeedActivity }

func (SeedActivity) MarshalJSON 

func (a SeedActivity) MarshalJSON() ([]byte, error)

type SortedCropNotes 

type SortedCropNotes []domain.CropNote

func (SortedCropNotes) Len 

func (sn SortedCropNotes) Len() int

Len is part of sort.Interface.

func (SortedCropNotes) Less 

func (sn SortedCropNotes) Less(i, j int) bool

Less is part of sort.Interface.

func (SortedCropNotes) Swap 

func (sn SortedCropNotes) Swap(i, j int)

Swap is part of sort.Interface.

type TaskCropActivity 

type TaskCropActivity struct{ *storage.TaskCropActivity }

func (TaskCropActivity) MarshalJSON 

func (a TaskCropActivity) MarshalJSON() ([]byte, error)

type TaskNutrientActivity 

type TaskNutrientActivity struct{ *storage.TaskNutrientActivity }

func (TaskNutrientActivity) MarshalJSON 

func (a TaskNutrientActivity) MarshalJSON() ([]byte, error)

type TaskPestControlActivity 

type TaskPestControlActivity struct {
	*storage.TaskPestControlActivity
}

func (TaskPestControlActivity) MarshalJSON 

func (a TaskPestControlActivity) MarshalJSON() ([]byte, error)

type TaskSafetyActivity 

type TaskSafetyActivity struct{ *storage.TaskSafetyActivity }

func (TaskSafetyActivity) MarshalJSON 

func (a TaskSafetyActivity) MarshalJSON() ([]byte, error)

type TaskSanitationActivity 

type TaskSanitationActivity struct {
	*storage.TaskSanitationActivity
}

func (TaskSanitationActivity) MarshalJSON 

func (a TaskSanitationActivity) MarshalJSON() ([]byte, error)

type WaterActivity 

type WaterActivity struct{ *storage.WaterActivity }

func (WaterActivity) MarshalJSON 

func (a WaterActivity) MarshalJSON() ([]byte, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.