2025-04-16 09:27:54 +02:00
|
|
|
package network_map
|
|
|
|
|
|
2025-05-28 23:05:52 +02:00
|
|
|
import (
|
|
|
|
|
"fmt"
|
|
|
|
|
|
|
|
|
|
log "github.com/sirupsen/logrus"
|
|
|
|
|
|
|
|
|
|
"management/internal/shared/db"
|
|
|
|
|
appmetrics "management/internal/shared/metrics"
|
|
|
|
|
)
|
|
|
|
|
|
2025-04-16 09:27:54 +02:00
|
|
|
type Controller struct {
|
2025-05-28 23:05:52 +02:00
|
|
|
repo Repository
|
|
|
|
|
metrics *metrics
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func NewController(store *db.Store, metrics *appmetrics.AppMetrics) *Controller {
|
|
|
|
|
cMetrics, err := appmetrics.RegisterMetrics(metrics, newMetrics)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Fatalf("Failed to register app metrics: %v", err)
|
|
|
|
|
}
|
|
|
|
|
return &Controller{
|
|
|
|
|
repo: newRepository(store, cMetrics),
|
|
|
|
|
metrics: cMetrics,
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (c *Controller) UpdatePeers(accountID string) error {
|
|
|
|
|
data, err := c.repo.GetNetworkMapData(accountID)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return fmt.Errorf("get network map data: %w", err)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return nil
|
2025-04-16 09:27:54 +02:00
|
|
|
}
|