Method Purge

db/crud.go:3213–3263

Purges a document from the bucket (no tombstone)

(ctx context.Context, key string, needsAudit bool)

// Purges a document from the bucket (no tombstone)
func (db *DatabaseCollectionWithUser) Purge(ctx context.Context, key string, needsAudit bool) error {
	doc, rawBucketDoc, err := db.GetDocumentWithRaw(ctx, key, DocUnmarshalAll)
	if err != nil {
		return err
	}

	attachments, err := getAttachmentIDsForLeafRevisions(ctx, db, doc, "")
	if err != nil {
		return err
	}

	for attachmentID, attachmentNames := range attachments {
		err = db.dataStore.Delete(attachmentID)
		if err != nil {
			base.WarnfCtx(ctx, "Unable to delete attachment %q. Error: %v", attachmentID, err)
		}
		for _, attachmentName := range attachmentNames {
			base.Audit(ctx, base.AuditIDAttachmentDelete, base.AuditFields{
				base.AuditFieldDocID:        doc.ID,
				base.AuditFieldAttachmentID: attachmentName,
			})
		}

	}

	if db.UseXattrs() {
		// Clean up _sync and _globalSync (if present). Leave _vv and _mou since they are also shared by XDCR/Eventing.
		xattrsToDelete := []string{base.SyncXattrName, base.GlobalXattrName}
		// TODO: CBG-4796 - we currently need to determine a list of present xattrs before we delete to avoid differences
		// between Rosmar and Couchbase Server implementations of DeleteWithXattrs and GetWithXattrs.
		var presentXattrsToDelete []string
		if rawBucketDoc != nil && rawBucketDoc.Xattrs != nil {
			presentXattrsToDelete = base.KeysPresent(rawBucketDoc.Xattrs, xattrsToDelete)
		}
		if err := db.dataStore.DeleteWithXattrs(ctx, key, presentXattrsToDelete); err != nil {
			return err
		}
	} else {
		err := db.dataStore.Delete(key)
		if err != nil {
			return err
		}
	}
	if needsAudit {
		base.Audit(ctx, base.AuditIDDocumentDelete, base.AuditFields{
			base.AuditFieldDocID:  key,
			base.AuditFieldPurged: true,
		})
	}
	return nil
}

// ////// CHANNELS: