Method handleCompact

rest/api.go:180–274

()

}

func (h *handler) handleCompact() error {
	action := h.getQuery("action")
	if action == "" {
		action = string(db.BackgroundProcessActionStart)
	}

	if action != string(db.BackgroundProcessActionStart) && action != string(db.BackgroundProcessActionStop) {
		return base.HTTPErrorf(http.StatusBadRequest, "Unknown parameter for 'action'. Must be start or stop")
	}

	compactionType := h.getQuery("type")
	if compactionType == "" {
		compactionType = compactionTypeTombstone
	}

	if compactionType != compactionTypeTombstone && compactionType != compactionTypeAttachment {
		return base.HTTPErrorf(http.StatusBadRequest, "Unknown parameter for 'type'. Must be 'tombstone' or 'attachment'")
	}

	auditFields := base.AuditFields{base.AuditFieldCompactionType: compactionType}
	if compactionType == compactionTypeTombstone {
		if action == string(db.BackgroundProcessActionStart) {
			if atomic.CompareAndSwapUint32(&h.db.CompactState, db.DBCompactNotRunning, db.DBCompactRunning) {
				err := h.db.TombstoneCompactionManager.Start(h.ctx(), map[string]interface{}{
					"database": h.db,
				})
				if err != nil {
					return err
				}

				status, err := h.db.TombstoneCompactionManager.GetStatus(h.ctx())
				if err != nil {
					return err
				}
				h.writeRawJSON(status)
				base.Audit(h.ctx(), base.AuditIDDatabaseCompactStart, auditFields)
			} else {
				return base.HTTPErrorf(http.StatusServiceUnavailable, "Database compact already in progress")

			}
		} else if action == string(db.BackgroundProcessActionStop) {
			dbState := atomic.LoadUint32(&h.db.CompactState)
			if dbState != db.DBCompactRunning {
				return base.HTTPErrorf(http.StatusBadRequest, "Database compact is not running")
			}

			err := h.db.TombstoneCompactionManager.Stop()
			if err != nil {
				return err
			}
			status, err := h.db.TombstoneCompactionManager.GetStatus(h.ctx())
			if err != nil {
				return err
			}
			h.writeRawJSON(status)
			base.Audit(h.ctx(), base.AuditIDDatabaseCompactStop, auditFields)
		}
	}