service

Documentation

Index

• func MarshalPendingOrders(order models.Order) ([]byte, error)
• func UnmarshalPendingOrders(marshalled string) (*pendingOrders, error)
• type CategoriesService
  • func NewCategoriesService(persistence persistence.CategoriesRepository, log kitlog.Logger) CategoriesService
• type OrdersService
  • func NewOrdersService(repo persistence.OrdersRepository, prodSvc ProductsService, ...) OrdersService
• type PaymentsService
  • func NewPaymentsService(repo persistence.PaymentRepository, api paymentapi.PaymentAPI, ...) PaymentsService
• type ProductsService
  • func NewProductsService(repo persistence.ProductsRepository, log kitlog.Logger) ProductsService

Functions

func MarshalPendingOrders

func MarshalPendingOrders(order models.Order) ([]byte, error)

func UnmarshalPendingOrders

func UnmarshalPendingOrders(marshalled string) (*pendingOrders, error)

Types

type CategoriesService

type CategoriesService interface {
	GetCategory(ctx context.Context, id uuid.UUID) (*models.Category, error)
	InsertCategory(ctx context.Context, in *models.Category) (*models.Category, error)
	DeleteCategory(ctx context.Context, id uuid.UUID) error
	ListCategories(ctx context.Context, limit, offset int) (*models.CategoryList, error)
}

func NewCategoriesService

func NewCategoriesService(persistence persistence.CategoriesRepository, log kitlog.Logger) CategoriesService

type OrdersService

type OrdersService interface {
	GetOrder(ctx context.Context, orderID uuid.UUID) (*models.Order, error)
	GetOrderByPaymentID(ctx context.Context, paymentID uuid.UUID) (*models.Order, error)
	CreateOrder(ctx context.Context, products []models.Product, userID uuid.UUID) (*models.Order, error)
	UpdateOrderItems(ctx context.Context, orderID uuid.UUID, products []models.Product) (*models.Order, error)
	DeleteOrder(ctx context.Context, orderID uuid.UUID) error
	ListOrders(ctx context.Context, limit, offset int) (*models.OrderList, error)
	Checkout(ctx context.Context, paymentID uuid.UUID) (*models.Order, error)
	UpdateOrderStatus(ctx context.Context, orderID uuid.UUID, status models.OrderStatus) (*models.Order, error)
	ProcessPayment()
}

func NewOrdersService

func NewOrdersService(
	repo persistence.OrdersRepository,
	prodSvc ProductsService,
	paySvc PaymentsService,
	log kitlog.Logger,
	cache datastore.RedisStore,
	paymentAPI payments.PaymentAPI,
	productionAPI production.ProductionAPI,
) OrdersService

type PaymentsService

type PaymentsService interface {
	GetPayment(ctx context.Context, paymentID uuid.UUID) (*models.Payment, error)
	CreatePayment(ctx context.Context, orderID *models.Order) (*models.Payment, error)
	UpdatePayment(ctx context.Context, paymentID uuid.UUID, status models.PaymentStatus) (*models.Payment, error)
}

func NewPaymentsService

func NewPaymentsService(repo persistence.PaymentRepository, api paymentapi.PaymentAPI, log kitlog.Logger) PaymentsService

type ProductsService

type ProductsService interface {
	GetProduct(ctx context.Context, id uuid.UUID) (*models.Product, error)
	InsertProduct(ctx context.Context, product *models.Product) (*models.Product, error)
	UpdateProduct(ctx context.Context, product *models.Product) (*models.Product, error)
	DeleteProduct(ctx context.Context, uuid uuid.UUID) error
	ListProductsByCategory(ctx context.Context, categoryID uuid.UUID, limit, offset int) (*models.ProductList, error)
	GetProductsPriceSumByID(ctx context.Context, products []uuid.UUID) (*models.ProductsSum, error)
}

func NewProductsService

func NewProductsService(repo persistence.ProductsRepository, log kitlog.Logger) ProductsService