Function revCacheLoaderForDocument

db/revision_cache_interface.go:439–470

Common revCacheLoader functionality used either during a cache miss (from revCacheLoader), or directly when retrieving current rev from cache

(ctx context.Context, backingStore RevisionCacheBackingStore, doc *Document, revid string)

// Common revCacheLoader functionality used either during a cache miss (from revCacheLoader), or directly when retrieving current rev from cache

func revCacheLoaderForDocument(ctx context.Context, backingStore RevisionCacheBackingStore, doc *Document, revid string) (bodyBytes []byte, history Revisions, channels base.Set, removed bool, attachments AttachmentsMeta, deleted bool, expiry *time.Time, hlv *HybridLogicalVector, err error) {
	if bodyBytes, attachments, channels, err = backingStore.getRevision(ctx, doc, revid); err != nil {
		// If we can't find the revision (either as active or conflicted body from the document, or as old revision body backup), check whether
		// the revision was a channel removal. If so, we want to store as removal in the revision cache
		removalBodyBytes, removalHistory, activeChannels, isRemoval, isDelete, isRemovalErr := doc.IsChannelRemoval(ctx, revid)
		if isRemovalErr != nil {
			return bodyBytes, history, channels, isRemoval, nil, isDelete, nil, hlv, isRemovalErr
		}

		if isRemoval {
			return removalBodyBytes, removalHistory, activeChannels, isRemoval, nil, isDelete, nil, hlv, nil
		}

		// If this wasn't a removal, return the original error from getRevision
		return bodyBytes, history, channels, removed, nil, isDelete, nil, hlv, err
	}
	deleted = doc.History[revid].Deleted

	validatedHistory, getHistoryErr := doc.History.getHistory(revid)
	if getHistoryErr != nil {
		return bodyBytes, history, channels, removed, nil, deleted, nil, hlv, getHistoryErr
	}
	history = encodeRevisions(ctx, doc.ID, validatedHistory)
	// only add doc hlv if the revision we have fetched is current revision, otherwise we don't know whether hlv applies to that revision
	if doc.GetRevTreeID() == revid {
		if doc.HLV != nil {
			hlv = doc.HLV
		}
	}

	return bodyBytes, history, channels, removed, attachments, deleted, doc.Expiry, hlv, err
}

// revCacheLoaderForDocumentCV used either during cache miss (from revCacheLoaderForCv), or used directly when getting current active CV from cache
// nolint:staticcheck