Method OnDemandImportForGet

db/crud.go:246–273

OnDemandImportForGet. Attempts to import the doc based on the provided id, contents and cas. ImportDocRaw does cas retry handling if the document gets updated after the initial retrieval attempt that triggered this.

(ctx context.Context, docid string, doc *Document, rawDoc []byte, xattrs map[string][]byte, cas uint64)

// OnDemandImportForGet. Attempts to import the doc based on the provided id, contents and cas. ImportDocRaw does cas retry handling
// if the document gets updated after the initial retrieval attempt that triggered this.
func (c *DatabaseCollection) OnDemandImportForGet(ctx context.Context, docid string, doc *Document, rawDoc []byte, xattrs map[string][]byte, cas uint64) (docOut *Document, err error) {
	isDelete := rawDoc == nil
	importDb := DatabaseCollectionWithUser{DatabaseCollection: c, user: nil}
	var importErr error

	if syncDataErr := doc.validateSyncDataForImport(ctx, c.dbCtx, docid); syncDataErr != nil {
		return nil, syncDataErr
	}

	importOpts := importDocOptions{
		isDelete: isDelete,
		mode:     ImportOnDemand,
		revSeqNo: doc.RevSeqNo,
		expiry:   nil,
	}

	docOut, importErr = importDb.ImportDocRaw(ctx, docid, rawDoc, xattrs, importOpts, cas)

	if importErr == base.ErrImportCancelledFilter {
		// If the import was cancelled due to filter, treat as 404 not imported
		return nil, base.HTTPErrorf(http.StatusNotFound, "Not imported")
	} else if importErr != nil {
		// Treat any other failure to perform an on-demand import as not found
		base.DebugfCtx(ctx, base.KeyImport, "Unable to import doc %q during on demand import for get - will be treated as not found.  Reason: %v", base.UD(docid), importErr)
		return nil, base.HTTPErrorf(http.StatusNotFound, "Not found")
	}
	return docOut, nil
}

// GetRev returns the revision for the given docID and revOrCV, or the current active revision if revOrCV is empty.
func (db *DatabaseCollectionWithUser) GetRev(ctx context.Context, docID, revOrCV string, history bool, attachmentsSince []string) (DocumentRevision, error) {