Method getCurrentVersion

db/revision_cache_interface.go:496–525

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

}

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 {
		if !loadBackup {
			// do not attempt to fetch backup revision by CV unless specified
			return nil, nil, nil, false, ErrMissing
		}
		bodyBytes, channels, deleted, err = c.getOldRevisionJSON(ctx, doc.ID, base.Crc32cHashString([]byte(cv.String())))
		if err != nil || bodyBytes == nil {
			return nil, nil, nil, false, err
		}
	} else {
		bodyBytes, err = doc.BodyBytes(ctx)
		if err != nil {
			base.WarnfCtx(ctx, "Marshal error when retrieving active current version body: %v", err)
			return nil, nil, nil, false, err
		}
		channels = doc.SyncData.getCurrentChannels()
		attachments = doc.Attachments()
	}

	// handle backup revision inline attachments, or pre-2.5 meta
	if inlineAtts, cleanBodyBytes, _, err := extractInlineAttachments(bodyBytes); err != nil {
		return nil, nil, nil, false, err
	} else if len(inlineAtts) > 0 {
		// we found some inline attachments, so merge them with attachments, and update the bodies
		attachments = mergeAttachments(inlineAtts, attachments)
		bodyBytes = cleanBodyBytes
	}
	return bodyBytes, attachments, channels, deleted, err
}