senke/veza
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(commerce): wire TransferService in marketplace and webhook routes

Browse source
This commit is contained in:
senke 2026-02-23 22:55:39 +01:00
parent 31833c01f1
commit 6d1d861a52
2 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
veza-backend-api/internal/api/routes_marketplace.go
View file

@ -33,6 +33,11 @@ func (r *APIRouter) setupMarketplaceRoutes(router *gin.RouterGroup) {
marketplace.WithHyperswitchConfig(true, r.config.CheckoutSuccessURL),
)
}
var stripeConnectSvc *services.StripeConnectService
if r.config.StripeConnectEnabled && r.config.StripeConnectSecretKey != "" {
stripeConnectSvc = services.NewStripeConnectService(r.db.GormDB, r.config.StripeConnectSecretKey, r.logger)
opts = append(opts, marketplace.WithTransferService(stripeConnectSvc, r.config.PlatformFeeRate))
}
marketService := marketplace.NewService(r.db.GormDB, r.logger, storageService, opts...)
productPreviewDir := uploadDir
if productPreviewDir == "" {
@ -97,10 +102,6 @@ func (r *APIRouter) setupMarketplaceRoutes(router *gin.RouterGroup) {
sellProtected.GET("/stats/top-products", marketHandler.GetSellTopProducts)
sellProtected.GET("/sales", marketHandler.GetSellSales)
var stripeConnectSvc *services.StripeConnectService
if r.config.StripeConnectEnabled && r.config.StripeConnectSecretKey != "" {
stripeConnectSvc = services.NewStripeConnectService(r.db.GormDB, r.config.StripeConnectSecretKey, r.logger)
}
sellHandler := handlers.NewSellHandler(stripeConnectSvc, r.logger)
sellProtected.POST("/connect/onboard", sellHandler.ConnectOnboard)
sellProtected.GET("/connect/callback", sellHandler.ConnectCallback)

4
veza-backend-api/internal/api/routes_webhooks.go
View file

@ -98,5 +98,9 @@ func (r *APIRouter) getMarketplaceService() marketplace.MarketplaceService {
marketplace.WithHyperswitchConfig(true, r.config.CheckoutSuccessURL),
)
}
if r.config.StripeConnectEnabled && r.config.StripeConnectSecretKey != "" {
scs := services.NewStripeConnectService(r.db.GormDB, r.config.StripeConnectSecretKey, r.logger)
opts = append(opts, marketplace.WithTransferService(scs, r.config.PlatformFeeRate))
}
return marketplace.NewService(r.db.GormDB, r.logger, storageService, opts...)
}