Method Query

pkg/search/query.go:977–1203

(ctx context.Context, rawq *SearchQuery)

var debugQuerySpeed, _ = strconv.ParseBool(os.Getenv("CAMLI_DEBUG_QUERY_SPEED"))

func (h *Handler) Query(ctx context.Context, rawq *SearchQuery) (ret_ *SearchResult, _ error) {
	if debugQuerySpeed {
		t0 := time.Now()
		jq, _ := json.Marshal(rawq)
		log.Printf("[search=%p] Start %v, Doing search %s... ", rawq, t0.Format(time.RFC3339), jq)
		defer func() {
			d := time.Since(t0)
			if ret_ != nil {
				log.Printf("[search=%p] Start %v + %v = %v results", rawq, t0.Format(time.RFC3339), d, len(ret_.Blobs))
			} else {
				log.Printf("[search=%p] Start %v + %v = error", rawq, t0.Format(time.RFC3339), d)
			}
		}()
	}
	exprResult, err := rawq.checkValid(ctx)
	if err != nil {
		return nil, fmt.Errorf("Invalid SearchQuery: %v", err)
	}
	q := rawq.plannedQuery(exprResult)
	res := new(SearchResult)
	s := &search{
		h:   h,
		q:   q,
		res: res,
		loc: make(map[blob.Ref]camtypes.Location),
	}

	h.index.RLock()
	defer h.index.RUnlock()

	ctx, cancelSearch := context.WithCancel(context.TODO())
	defer cancelSearch()

	corpus := h.corpus

	cands := q.pickCandidateSource(s)
	if candSourceHook != nil {
		candSourceHook(cands.name)
	}
	if debugQuerySpeed {
		log.Printf("[search=%p] using candidate source set %q", rawq, cands.name)
	}

	wantAround, foundAround := false, false
	if q.Around.Valid() {
		// TODO(mpl): fail somewhere if MapSorted and wantAround at the same time.
		wantAround = true
	}
	blobMatches := q.Constraint.matcher()

	var enumErr error
	cands.send(ctx, s, func(meta camtypes.BlobMeta) bool {
		match, err := blobMatches(ctx, s, meta.Ref, meta)
		if err != nil {
			enumErr = err
			return false
		}
		if match {