Skip to content

Add transaction manager #138

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
jannikluhn wants to merge 6 commits into
base: main
Choose a base branch
from
Open

Add transaction manager #138

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
42e8345
metrics: use counters instead of gauges for monotonic totals
jannikluhn Aug 12, 2026
adc5105
metrics: rename counters to the _total suffix convention
jannikluhn Aug 14, 2026
c9096d5
metrics: add a gauge for the signer's balance
jannikluhn Aug 16, 2026
8c6faef
metrics: add metrics for the transaction lifecycle
jannikluhn Aug 24, 2026
f33e3b0
txmgr: serialize transaction submission for the signing key
jannikluhn Aug 24, 2026
e15d863
usecase: submit registrations through the transaction manager
jannikluhn Aug 24, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -102,6 +102,7 @@ require (
github.com/koron/go-ssdp v0.0.5 // indirect
github.com/kr/pretty v0.3.1 // indirect
github.com/kr/text v0.2.0 // indirect
github.com/kylelemons/godebug v1.1.0 // indirect
github.com/libp2p/go-buffer-pool v0.1.0 // indirect
github.com/libp2p/go-cidranger v1.1.0 // indirect
github.com/libp2p/go-flow-metrics v0.2.0 // indirect
Expand Down
4 changes: 3 additions & 1 deletion internal/router/router.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ import (
"github.com/shutter-network/shutter-api/docs"
"github.com/shutter-network/shutter-api/internal/middleware"
"github.com/shutter-network/shutter-api/internal/service"
"github.com/shutter-network/shutter-api/internal/usecase"
swaggerFiles "github.com/swaggo/files"
ginSwagger "github.com/swaggo/gin-swagger"
)
Expand All @@ -22,6 +23,7 @@ func NewRouter(
db *pgxpool.Pool,
contract *common.Contract,
ethClient *ethclient.Client,
txManager usecase.TxManagerInterface,
config *common.Config,
) *gin.Engine {
router := gin.New()
Expand All @@ -30,7 +32,7 @@ func NewRouter(
router.Use(cors.Default())
router.Use(middleware.ErrorHandler())

cryptoService := service.NewCryptoService(db, contract, ethClient, config)
cryptoService := service.NewCryptoService(db, contract, ethClient, txManager, config)
docs.SwaggerInfo.BasePath = "/api"
api := router.Group("/api")
{
Expand Down
5 changes: 4 additions & 1 deletion internal/service/crypto.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,10 +32,11 @@ func NewCryptoService(
db *pgxpool.Pool,
contract *common.Contract,
ethClient *ethclient.Client,
txManager usecase.TxManagerInterface,
config *common.Config,
) *CryptoService {
return &CryptoService{
CryptoUsecase: usecase.NewCryptoUsecase(db, contract.ShutterRegistryContract, contract.ShutterEventRegistryContract, contract.KeyperSetManagerContract, contract.KeyBroadcastContract, ethClient, config),
CryptoUsecase: usecase.NewCryptoUsecase(db, contract.ShutterRegistryContract, contract.ShutterEventRegistryContract, contract.KeyperSetManagerContract, contract.KeyBroadcastContract, ethClient, txManager, config),
}
}

Expand Down Expand Up @@ -233,6 +234,7 @@ func (svc *CryptoService) GetDataForEncryptionEvent(ctx *gin.Context) {
// @Failure 400 {object} error.Http "Invalid Register identity request."
// @Failure 429 {object} error.Http "Too many requests. Rate limited."
// @Failure 500 {object} error.Http "Internal server error."
// @Failure 503 {object} error.Http "Too many registrations in flight. Retry."
// @Security BearerAuth
// @Router /time/register_identity [post]
func (svc *CryptoService) RegisterIdentity(ctx *gin.Context) {
Expand Down Expand Up @@ -405,6 +407,7 @@ func CompileEventTriggerDefinition(ctx *gin.Context) {
// @Failure 429 {object} error.Http "Too many requests. Rate limited."
// @Failure 500 {object} error.Http "Internal server error."
// @Failure 501 {object} error.Http "Event API is disabled on this deployment."
// @Failure 503 {object} error.Http "Too many registrations in flight. Retry."
// @Security BearerAuth
// @Router /event/register_identity [post]
func (svc *CryptoService) RegisterEventIdentity(ctx *gin.Context) {
Expand Down
Loading