RomanNum3ral
/
Cybersecurity-Projects
mirror of https://github.com/CarterPerez-dev/Cybersecurity-Projects.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

feat(monitor/main): wire coinbase BTC/ETH collector under errgroup

This commit is contained in:
CarterPerez-dev 2026-05-02 03:36:26 -04:00
parent 9c35e14ae8
commit 99f6e41845
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
PROJECTS/advanced/monitor-the-situation-dashboard/backend/cmd/api/main.go
View File

@ -21,6 +21,7 @@ import (
"github.com/carterperez-dev/monitor-the-situation/backend/internal/auth" "github.com/carterperez-dev/monitor-the-situation/backend/internal/auth"
"github.com/carterperez-dev/monitor-the-situation/backend/internal/bus" "github.com/carterperez-dev/monitor-the-situation/backend/internal/bus"
"github.com/carterperez-dev/monitor-the-situation/backend/internal/collectors/cfradar" "github.com/carterperez-dev/monitor-the-situation/backend/internal/collectors/cfradar"
"github.com/carterperez-dev/monitor-the-situation/backend/internal/collectors/coinbase"
"github.com/carterperez-dev/monitor-the-situation/backend/internal/collectors/cve" "github.com/carterperez-dev/monitor-the-situation/backend/internal/collectors/cve"
"github.com/carterperez-dev/monitor-the-situation/backend/internal/collectors/dshield" "github.com/carterperez-dev/monitor-the-situation/backend/internal/collectors/dshield"
"github.com/carterperez-dev/monitor-the-situation/backend/internal/collectors/heartbeat" "github.com/carterperez-dev/monitor-the-situation/backend/internal/collectors/heartbeat"
@ -221,6 +222,19 @@ func run(configPath string) error {
collectorGroup.Go(func() error { return coll.Run(collectorCtx) }) collectorGroup.Go(func() error { return coll.Run(collectorCtx) })
} }
if cfg.Collectors.Coinbase.Enabled {
coll := coinbase.NewCollector(coinbase.CollectorConfig{
URL: cfg.Collectors.Coinbase.URL,
ProductIDs: cfg.Collectors.Coinbase.ProductIDs,
Repo: coinbase.NewRepo(db.DB),
Emitter: eventBus,
State: collectorState,
Throttle: cfg.Collectors.Coinbase.Throttle,
Logger: logger.With("collector", "coinbase"),
})
collectorGroup.Go(func() error { return coll.Run(collectorCtx) })
}
logger.Info("collectors started", logger.Info("collectors started",
"heartbeat", true, "heartbeat", true,
"dshield", cfg.Collectors.DShield.Enabled, "dshield", cfg.Collectors.DShield.Enabled,
@ -228,6 +242,7 @@ func run(configPath string) error {
"cve", cfg.Collectors.CVE.Enabled, "cve", cfg.Collectors.CVE.Enabled,
"kev", cfg.Collectors.KEV.Enabled, "kev", cfg.Collectors.KEV.Enabled,
"ransomware", cfg.Collectors.Ransomware.Enabled, "ransomware", cfg.Collectors.Ransomware.Enabled,
"coinbase", cfg.Collectors.Coinbase.Enabled,
) )
srv := server.New(server.Config{ srv := server.New(server.Config{