diff --git a/bridge-history-api/internal/config/config.go b/bridge-history-api/internal/config/config.go index f6a44aa84d..1da4864252 100644 --- a/bridge-history-api/internal/config/config.go +++ b/bridge-history-api/internal/config/config.go @@ -38,6 +38,7 @@ type FetcherConfig struct { BeaconNodeAPIEndpoint string `json:"BeaconNodeAPIEndpoint"` BlobScanAPIEndpoint string `json:"BlobScanAPIEndpoint"` BlockNativeAPIEndpoint string `json:"BlockNativeAPIEndpoint"` + AwsS3Endpoint string `json:"AwsS3Endpoint"` } // RedisConfig redis config diff --git a/bridge-history-api/internal/controller/fetcher/l1_fetcher.go b/bridge-history-api/internal/controller/fetcher/l1_fetcher.go index 8efdce1302..35ada5d9f9 100644 --- a/bridge-history-api/internal/controller/fetcher/l1_fetcher.go +++ b/bridge-history-api/internal/controller/fetcher/l1_fetcher.go @@ -39,6 +39,9 @@ type L1MessageFetcher struct { // NewL1MessageFetcher creates a new L1MessageFetcher instance. func NewL1MessageFetcher(ctx context.Context, cfg *config.FetcherConfig, db *gorm.DB, client *ethclient.Client) (*L1MessageFetcher, error) { blobClient := blob_client.NewBlobClients() + if cfg.AwsS3Endpoint != "" { + blobClient.AddBlobClient(blob_client.NewAwsS3Client(cfg.AwsS3Endpoint)) + } if cfg.BeaconNodeAPIEndpoint != "" { beaconNodeClient, err := blob_client.NewBeaconNodeClient(cfg.BeaconNodeAPIEndpoint) if err != nil { diff --git a/common/version/version.go b/common/version/version.go index 05024d456a..f8087fa636 100644 --- a/common/version/version.go +++ b/common/version/version.go @@ -5,7 +5,7 @@ import ( "runtime/debug" ) -var tag = "v4.5.40" +var tag = "v4.5.41" var commit = func() string { if info, ok := debug.ReadBuildInfo(); ok {