|
|
@ -102,14 +102,14 @@ func (s *StandardSearchService) IsDisabled() bool { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func (s *StandardSearchService) Run(ctx context.Context) error { |
|
|
|
func (s *StandardSearchService) Run(ctx context.Context) error { |
|
|
|
orgQuery := &org.SearchOrgsQuery{} |
|
|
|
orgQuery := &models.SearchOrgsQuery{} |
|
|
|
result, err := s.orgService.Search(ctx, orgQuery) |
|
|
|
err := s.sql.SearchOrgs(ctx, orgQuery) |
|
|
|
if err != nil { |
|
|
|
if err != nil { |
|
|
|
return fmt.Errorf("can't get org list: %w", err) |
|
|
|
return fmt.Errorf("can't get org list: %w", err) |
|
|
|
} |
|
|
|
} |
|
|
|
orgIDs := make([]int64, 0, len(result)) |
|
|
|
orgIDs := make([]int64, 0, len(orgQuery.Result)) |
|
|
|
for _, org := range result { |
|
|
|
for _, org := range orgQuery.Result { |
|
|
|
orgIDs = append(orgIDs, org.ID) |
|
|
|
orgIDs = append(orgIDs, org.Id) |
|
|
|
} |
|
|
|
} |
|
|
|
return s.dashboardIndex.run(ctx, orgIDs, s.reIndexCh) |
|
|
|
return s.dashboardIndex.run(ctx, orgIDs, s.reIndexCh) |
|
|
|
} |
|
|
|
} |
|
|
|