Method handlePostResync

rest/api.go:369–453

()

}

func (h *handler) handlePostResync() error {

	action := h.getQuery("action")
	regenerateSequences, _ := h.getOptBoolQuery("regenerate_sequences", false)
	reset := h.getBoolQuery("reset")

	body, err := h.readBody()
	if err != nil {
		return err
	}

	resyncPostReqBody := ResyncPostReqBody{}
	if len(body) != 0 {
		if err := json.Unmarshal(body, &resyncPostReqBody); err != nil {
			return err
		}
	}

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

	if action == "" {
		action = string(db.BackgroundProcessActionStart)
	}

	// Regenerate sequences if it is set true via query param or via request body
	regenerateSequences = regenerateSequences || resyncPostReqBody.RegenerateSequences

	if action == string(db.BackgroundProcessActionStart) {
		if atomic.CompareAndSwapUint32(&h.db.State, db.DBOffline, db.DBResyncing) {
			err := h.db.ResyncManager.Start(h.ctx(), map[string]interface{}{
				"database":            h.db,
				"regenerateSequences": regenerateSequences,
				"collections":         resyncPostReqBody.Scope,
				"reset":               reset,
			})
			if err != nil {
				return err
			}

			status, err := h.db.ResyncManager.GetStatus(h.ctx())
			if err != nil {
				return err
			}
			h.writeRawJSON(status)
			base.Audit(h.ctx(), base.AuditIDDatabaseResyncStart, base.AuditFields{
				"collections":          resyncPostReqBody.Scope,
				"regenerate_sequences": regenerateSequences,
				"reset":                reset,
			})
		} else {
			dbState := atomic.LoadUint32(&h.db.State)
			if dbState == db.DBResyncing {
				return base.HTTPErrorf(http.StatusServiceUnavailable, "Database _resync already in progress")
			}

			if dbState != db.DBOffline {