Method setOldRevisionJSON

db/revision.go:332–364

(ctx context.Context, docid string, rev string, body []byte, deletedDoc bool, expiry uint32, channels base.Set)

}

func (db *DatabaseCollectionWithUser) setOldRevisionJSON(ctx context.Context, docid string, rev string, body []byte, deletedDoc bool, expiry uint32, channels base.Set) error {
	// no channel information available (Note: this is different than an empty set of channels)
	if channels == nil {
		base.WarnfCtx(ctx, "setOldRevisionJSON called with nil channels for old revision %q / %q", base.UD(docid), rev)
		return db.setOldRevisionJSONBody(ctx, docid, rev, body, expiry)
	}

	// store channels as optional metadata in the backup
	// not stored as a real Couchbase Server xattr since we need to write this as a binary document
	channelsJSON, err := channels.MarshalJSON()
	if err != nil {
		return fmt.Errorf("error marshalling channels for old revision %q / %q: %v", base.UD(docid), rev, err)
	}
	deletedJSON, err := base.JSONMarshal(deletedDoc)
	if err != nil {
		return fmt.Errorf("error marshalling deleted flag for old revision %q / %q: %v", base.UD(docid), rev, err)
	}
	meta := []sgbucket.Xattr{
		{Name: backupRevisionChannelsMetaKey, Value: channelsJSON},
		{Name: backupRevisionBodyDeletedMetaKey, Value: deletedJSON},
	}
	bodyWithMeta := sgbucket.EncodeValueWithXattrs(body, meta...)
	nonJSONBytes := withNonJSONPrefix(nonJSONPrefixKindRevWithMeta, bodyWithMeta)

	err = db.dataStore.SetRaw(oldRevisionKey(docid, rev), expiry, nil, nonJSONBytes)
	if err != nil {
		base.WarnfCtx(ctx, "setOldRevisionJSONBodyWithMeta failed: doc=%q rev=%q err=%v", base.UD(docid), rev, err)
		return err
	}

	base.DebugfCtx(ctx, base.KeyCRUD, "Backed up revision body (with meta) %q/%q (%d bytes, ttl:%d)", base.UD(docid), rev, len(body), expiry)
	return nil
}

// Extends the expiry on a revision backup.  If this fails w/ key not found, will attempt to recreate the revision backup when body is non-empty.
func (db *DatabaseCollectionWithUser) refreshOldRevisionJSON(ctx context.Context, docid string, revid string, body []byte, expiry uint32, channels base.Set, deleted bool) error {