42 lines
1.0 KiB
Go
42 lines
1.0 KiB
Go
package app
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"gitea.dwysokinski.me/twhelp/corev3/internal/domain"
|
|
)
|
|
|
|
type DataSyncService struct {
|
|
versionSvc *VersionService
|
|
serverPub ServerPublisher
|
|
}
|
|
|
|
func NewDataSyncService(versionSvc *VersionService, serverPub ServerPublisher) *DataSyncService {
|
|
return &DataSyncService{versionSvc: versionSvc, serverPub: serverPub}
|
|
}
|
|
|
|
func (svc *DataSyncService) TriggerDataSync(ctx context.Context) error {
|
|
versions, err := svc.versionSvc.List(ctx, domain.NewListVersionsParams())
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
payloads := make([]domain.SyncServersCmdPayload, 0, len(versions))
|
|
|
|
for _, v := range versions {
|
|
p, payloadErr := domain.NewSyncServersCmdPayload(v.Code(), v.URL())
|
|
if payloadErr != nil {
|
|
return fmt.Errorf("%s: couldn't construct domain.SyncServersCmdPayload: %w", v.Code(), payloadErr)
|
|
}
|
|
|
|
payloads = append(payloads, p)
|
|
}
|
|
|
|
return svc.serverPub.CmdSync(ctx, payloads...)
|
|
}
|
|
|
|
func (svc *DataSyncService) TriggerEnnoblementSync(_ context.Context) error {
|
|
panic("unimplemented")
|
|
}
|