Michael McGuinness
0df3d16976
Query Version Sync Runner * testing * queryversiosyncworking * update * tests * fixtests
72 lines
1.9 KiB
Go
72 lines
1.9 KiB
Go
package resultset
|
|
|
|
import (
|
|
"context"
|
|
"log/slog"
|
|
"queryorchestration/internal/database"
|
|
"queryorchestration/internal/database/repository"
|
|
"queryorchestration/internal/query/result"
|
|
|
|
"github.com/google/uuid"
|
|
)
|
|
|
|
type Set struct {
|
|
DocumentID uuid.UUID `json:"document_id" validate:"required,uuid"`
|
|
QueryID uuid.UUID `json:"query_id" validate:"required,uuid"`
|
|
}
|
|
|
|
func (s *Service) Set(ctx context.Context, params *Set) error {
|
|
dbid := database.MustToDBUUID(params.DocumentID)
|
|
cleanVersion, err := s.cfg.GetDBQueries().GetDocumentCleanEntry(ctx, dbid)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
textVersion, err := s.cfg.GetDBQueries().GetDocumentTextEntry(ctx, dbid)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
query, err := s.svc.Query.Get(ctx, params.QueryID)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
value, err := s.svc.Result.Process(ctx, &result.Process{
|
|
DocumentID: params.DocumentID,
|
|
QueryID: query.ID,
|
|
QueryVersion: query.ActiveVersion,
|
|
})
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
err = s.cfg.GetDBQueries().SetResult(ctx, &repository.SetResultParams{
|
|
Queryid: database.MustToDBUUID(params.QueryID),
|
|
Documentid: database.MustToDBUUID(params.DocumentID),
|
|
Value: value.GetStoreValue(),
|
|
Cleanversion: cleanVersion.Version,
|
|
Textversion: textVersion.Version,
|
|
Queryversion: query.ActiveVersion,
|
|
})
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
slog.Debug("set query result", "query_id", params.QueryID.String(), "document_id", params.DocumentID.String())
|
|
|
|
return s.informQueryDependents(ctx, params)
|
|
}
|
|
|
|
func (s *Service) informQueryDependents(ctx context.Context, params *Set) error {
|
|
ids, err := s.cfg.GetDBQueries().ListQueryDirectDependentsByDocumentID(ctx, &repository.ListQueryDirectDependentsByDocumentIDParams{
|
|
ID: database.MustToDBUUID(params.DocumentID),
|
|
Requiredids: database.MustToDBUUID(params.QueryID),
|
|
})
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return s.svc.Sync.TriggerMultiSync(ctx, params.DocumentID, database.MustToUUIDArray(ids))
|
|
}
|