Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/KaoutharAsma/nestjs-kafka-saga-pattern
/ functions
Functions
91 in github.com/KaoutharAsma/nestjs-kafka-saga-pattern
⨍
Functions
91
◇
Types & classes
67
↓ 3 callers
Method
findMany
(ids: string[])
inventory/src/repositories/product.repository.interface.ts:5
↓ 3 callers
Method
update
(order: Order)
order/src/repositories/order.repository.interface.ts:5
↓ 2 callers
Method
cancel
()
order/src/entities/order.ts:45
↓ 2 callers
Method
updateMany
(products: Partial<Product>[])
inventory/src/repositories/product.repository.interface.ts:6
↓ 1 callers
Method
authorizePayment
(request: { orderId: string; amount: number })
payment/src/services/payment.service.interface.ts:2
↓ 1 callers
Method
authroize
()
payment/src/entities/payment.ts:35
↓ 1 callers
Function
bootstrap
()
payment/src/main.ts:6
↓ 1 callers
Function
bootstrap
()
order/src/main.ts:6
↓ 1 callers
Function
bootstrap
()
inventory/src/main.ts:6
↓ 1 callers
Method
cancel
()
payment/src/entities/payment.ts:38
↓ 1 callers
Method
checkProductAvailibity
(request: { [id: string]: number })
inventory/src/services/product.service.interface.ts:4
↓ 1 callers
Method
confirm
()
order/src/entities/order.ts:41
↓ 1 callers
Method
createOrder
(body: CreateOrderDto)
order/src/services/order.service.interface.ts:5
↓ 1 callers
Method
execute
(order: Order)
order/src/usecases/create-order/saga/create-order.saga.ts:25
↓ 1 callers
Method
findByOrderId
(orderId: string)
payment/src/repositories/payment.repository.interface.ts:6
↓ 1 callers
Method
invoke
(order: Order)
order/src/usecases/create-order/saga/steps/place-order.step.ts:16
↓ 1 callers
Method
isStockSufficient
(demandedQuantity: number)
inventory/src/entities/product.ts:39
↓ 1 callers
Method
reduceStockQuantity
(request: { [id: string]: number })
inventory/src/services/product.service.interface.ts:5
↓ 1 callers
Method
refund
(request: { orderId: string; amount: number })
payment/src/services/payment.service.interface.ts:5
↓ 1 callers
Method
restockQuantity
(request: { [id: string]: number })
inventory/src/services/product.service.interface.ts:6
↓ 1 callers
Method
save
(payment: Payment)
payment/src/repositories/payment.repository.interface.ts:4
↓ 1 callers
Method
save
(order: Order)
order/src/repositories/order.repository.interface.ts:4
↓ 1 callers
Method
update
(payment: Payment)
payment/src/repositories/payment.repository.interface.ts:5
↓ 1 callers
Method
withCompenstation
(order: Order)
order/src/usecases/create-order/saga/steps/place-order.step.ts:21
Method
amount
()
payment/src/entities/payment.ts:23
Method
authorizePayment
(@Payload() message: AuthorizePaymentMessage)
payment/src/usecases/authorize-payment/authorize-payment.controller.ts:16
Method
authorizePayment
(request: { orderId: string; amount: number })
payment/src/services/payment.service.ts:11
Method
checkProductAvailibity
(@Payload() message: CheckProductsAvailibilityMessage)
inventory/src/usecases/fetch-availible-products/check-products-availiblity.controller.ts:22
Method
checkProductAvailibity
(request: { [id: string]: number })
inventory/src/services/product.service.ts:12
Method
constructor
( @Inject('payment-service') private paymentService: PaymentServiceInterface, )
payment/src/usecases/authorize-payment/authorize-payment.controller.ts:11
Method
constructor
( @Inject('payment-repository') private paymentRepository: PaymentRepositoryInterface, )
payment/src/services/payment.service.ts:7
Method
constructor
(private props: PaymentProps)
payment/src/entities/payment.ts:14
Method
constructor
( @Inject('order-service') private readonly service: OrderServiceInterface, )
order/src/usecases/create-order/create-order.controller.ts:17
Method
constructor
( @Inject('place-order-step') step1: PlaceOrderStep, @Inject('check-products-availibity') step2: Check
order/src/usecases/create-order/saga/create-order.saga.ts:15
Method
constructor
( @Inject(config().services.payment.name) private paymentClient: ClientKafka, )
order/src/usecases/create-order/saga/steps/authorize-payment.step.ts:11
Method
constructor
( @Inject(config().services.inventory.name) private inventoryClient: ClientKafka, )
order/src/usecases/create-order/saga/steps/update-stock.step.ts:10
Method
constructor
( @Inject('order-repository') private orderRepository: OrderRepositoryInterface, )
order/src/usecases/create-order/saga/steps/place-order.step.ts:8
Method
constructor
( @Inject(config().services.inventory.name) private inventoryClient: ClientKafka, )
order/src/usecases/create-order/saga/steps/check-product-availibilty.step.ts:11
Method
constructor
( @Inject('order-repository') private orderRepository: OrderRepositoryInterface, )
order/src/usecases/create-order/saga/steps/confirm-order.step.ts:8
Method
constructor
( objectOrError?: string | object | any, descriptionOrOptions: string | HttpExceptionOptions = 'Paymen
order/src/exceptions/http/payment_required_exception.ts:8
Method
constructor
(@Inject('create-order-saga') private saga: CreateOrderSaga)
order/src/services/order.service.ts:10
Method
constructor
(private props: OrderItemProps)
order/src/entities/order-item.ts:12
Method
constructor
(private props: OrderProps)
order/src/entities/order.ts:15
Method
constructor
( @Inject('product-service') private readonly service: ProductServiceInterface, )
inventory/src/usecases/update-stock/update-stock.controller.ts:16
Method
constructor
( @Inject('product-service') private readonly service: ProductServiceInterface, )
inventory/src/usecases/fetch-availible-products/check-products-availiblity.controller.ts:16
Method
constructor
( @Inject('product-repository') private productRepository: ProductRepositoryInterface, )
inventory/src/services/product.service.ts:7
Method
constructor
( private props: ProductProps, id?: string, )
inventory/src/entities/product.ts:12
Method
createOrder
(@Body() body: CreateOrderDto)
order/src/usecases/create-order/create-order.controller.ts:23
Method
createOrder
(body: CreateOrderDto)
order/src/services/order.service.ts:12
Method
customerId
()
order/src/entities/order.ts:25
Method
findByOrderId
(orderId: string)
payment/src/repositories/memory/payment.repository.ts:17
Method
findMany
(ids: string[])
inventory/src/repositories/memory/product.repository.ts:94
Method
id
()
payment/src/entities/payment.ts:19
Method
id
()
order/src/entities/order-item.ts:16
Method
id
()
order/src/entities/order.ts:21
Method
id
()
inventory/src/entities/product.ts:19
Method
invoke
(order: Order)
order/src/usecases/create-order/saga/steps/authorize-payment.step.ts:18
Method
invoke
(order: Order)
order/src/usecases/create-order/saga/steps/update-stock.step.ts:18
Method
invoke
(order: Order)
order/src/usecases/create-order/saga/steps/check-product-availibilty.step.ts:19
Method
invoke
(order: Order)
order/src/usecases/create-order/saga/steps/confirm-order.step.ts:16
Method
name
()
inventory/src/entities/product.ts:23
Method
onModuleInit
()
order/src/usecases/create-order/saga/steps/authorize-payment.step.ts:44
Method
onModuleInit
()
order/src/usecases/create-order/saga/steps/update-stock.step.ts:46
Method
onModuleInit
()
order/src/usecases/create-order/saga/steps/check-product-availibilty.step.ts:40
Method
orderDate
()
order/src/entities/order.ts:29
Method
orderId
()
payment/src/entities/payment.ts:27
Method
orderItems
()
order/src/entities/order.ts:37
Method
paymentDate
()
payment/src/entities/payment.ts:31
Method
price
()
inventory/src/entities/product.ts:27
Method
productId
()
order/src/entities/order-item.ts:20
Method
quantity
()
order/src/entities/order-item.ts:24
Method
quantity
()
inventory/src/entities/product.ts:31
Method
reduceStockQuantity
(@Payload() message: UpdateStockMessage)
inventory/src/usecases/update-stock/update-stock.controller.ts:22
Method
reduceStockQuantity
(request: { [id: string]: number })
inventory/src/services/product.service.ts:19
Method
refund
(@Payload() message: AuthorizePaymentMessage)
payment/src/usecases/authorize-payment/authorize-payment.controller.ts:23
Method
refund
(request: { orderId: string; amount: number })
payment/src/services/payment.service.ts:22
Method
restockQuantity
(@Payload() message: UpdateStockMessage)
inventory/src/usecases/update-stock/update-stock.controller.ts:37
Method
restockQuantity
(request: { [id: string]: number })
inventory/src/services/product.service.ts:27
Method
save
(payment: Payment)
payment/src/repositories/memory/payment.repository.ts:7
Method
save
(order: Order)
order/src/repositories/memory/order.repository.ts:7
Method
status
()
order/src/entities/order.ts:33
Method
totalPrice
()
order/src/entities/order-item.ts:28
Method
update
(payment: Payment)
payment/src/repositories/memory/payment.repository.ts:11
Method
update
(order: Order)
order/src/repositories/memory/order.repository.ts:11
Method
update
(product: Product)
inventory/src/repositories/product.repository.interface.ts:4
Method
update
(product: Product)
inventory/src/repositories/memory/product.repository.ts:88
Method
updateMany
(products: Partial<Product>[])
inventory/src/repositories/memory/product.repository.ts:102
Method
withCompenstation
(order: Order)
order/src/usecases/create-order/saga/steps/authorize-payment.step.ts:33
Method
withCompenstation
(order: Order)
order/src/usecases/create-order/saga/steps/update-stock.step.ts:32
Method
withCompenstation
(params: Order)
order/src/usecases/create-order/saga/steps/check-product-availibilty.step.ts:36
Method
withCompenstation
(order: Order)
order/src/usecases/create-order/saga/steps/confirm-order.step.ts:22