cleantextversion
This commit is contained in:
@@ -41,7 +41,8 @@ func (s *Service) Sync(ctx context.Context, doc Document) error {
|
||||
return err
|
||||
}
|
||||
|
||||
results, err := s.db.ListResultsByDocumentID(ctx, docID)
|
||||
// TODO grab only the results with the latest clean and text version
|
||||
results, err := s.db.ListResultsByDocumentID(ctx, docID, minCleanVersion, minTextVersion)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
@@ -49,10 +50,12 @@ func (s *Service) Sync(ctx context.Context, doc Document) error {
|
||||
for _, query := range queries {
|
||||
isSynced := false
|
||||
for _, result := range results {
|
||||
if result.Queryid != query.ID {
|
||||
if result.Queryid != query.ID && result.Queryversion != query.Queryversion {
|
||||
continue
|
||||
}
|
||||
isSynced = result.Cleanversion >= query.Mincleanversion && result.Textversion >= query.Mintextversion && result.Queryversion != query.Queryversion
|
||||
if result.Cleanversion > query.Mincleanversion && result.Textversion > query.Mintextversion {
|
||||
isSynced = true
|
||||
}
|
||||
break
|
||||
}
|
||||
if isSynced {
|
||||
|
||||
Reference in New Issue
Block a user