Function revCacheLoaderForDocumentCV

db/revision_cache_interface.go:474–494

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

(ctx context.Context, backingStore RevisionCacheBackingStore, doc *Document, cv Version, loadBackup bool)

// revCacheLoaderForDocumentCV used either during cache miss (from revCacheLoaderForCv), or used directly when getting current active CV from cache
// nolint:staticcheck
func revCacheLoaderForDocumentCV(ctx context.Context, backingStore RevisionCacheBackingStore, doc *Document, cv Version, loadBackup bool) (bodyBytes []byte, history Revisions, channels base.Set, removed bool, attachments AttachmentsMeta, deleted bool, expiry *time.Time, revid string, hlv *HybridLogicalVector, err error) {
	if bodyBytes, attachments, channels, deleted, err = backingStore.getCurrentVersion(ctx, doc, cv, loadBackup); err != nil {
		return nil, nil, nil, false, nil, false, nil, "", nil, err
	}

	// if we have request current version on the doc we can add revision ID too. If not we cannot know what the
	// corresponding revID is to pair with the request CV
	if doc.HLV.ExtractCurrentVersionFromHLV().Equal(cv) {
		revid = doc.GetRevTreeID()
		deleted = doc.Deleted
		hlv = doc.HLV
	}

	validatedHistory, getHistoryErr := doc.History.getHistory(revid)
	if getHistoryErr != nil {
		return bodyBytes, history, channels, removed, attachments, deleted, doc.Expiry, revid, hlv, err
	}
	history = encodeRevisions(ctx, doc.ID, validatedHistory)

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

func (c *DatabaseCollection) getCurrentVersion(ctx context.Context, doc *Document, cv Version, loadBackup bool) (bodyBytes []byte, attachments AttachmentsMeta, channels base.Set, deleted bool, err error) {
	if err = doc.HasCurrentVersion(ctx, cv); err != nil {