Method CmdAdd

src/go/plugin/framework/dyncfg/handler.go:427–470

CmdAdd handles the "add" command.

(fn Function)

// CmdAdd handles the "add" command.
func (h *Handler[C]) CmdAdd(fn Function) {
	if err := fn.ValidateArgs(3); err != nil {
		h.api.SendCodef(fn, 400, "%v", err)
		return
	}

	key, name, ok := h.cb.ExtractKey(fn)
	if !ok {
		h.api.SendCodef(fn, 400, "invalid job ID format.")
		return
	}

	if err := fn.ValidateHasPayload(); err != nil {
		h.api.SendCodef(fn, 400, "%v", err)
		return
	}

	if err := h.cb.ValidateJobName(name); err != nil {
		h.api.SendCodef(fn, 400, "invalid job name '%s': %v.", name, err)
		return
	}

	newCfg, err := h.cb.ParseAndValidate(fn, name)
	if err != nil {
		h.api.SendCodef(fn, 400, "%v", err)
		return
	}

	// Replace existing config at the same key, if any.
	if existing, ok := h.exposed.LookupByKey(key); ok {
		if _, found := h.seen.Lookup(existing.Cfg); found && existing.Cfg.SourceType() == "dyncfg" {
			h.seen.Remove(existing.Cfg)
		}
		h.exposed.Remove(existing.Cfg)
		h.cb.Stop(existing.Cfg)
	}

	h.seen.Add(newCfg)
	newEntry := &Entry[C]{Cfg: newCfg, Status: StatusAccepted}
	h.exposed.Add(newEntry)

	h.api.SendCodef(fn, 202, "")
	h.NotifyJobCreate(newCfg, StatusAccepted)
}

// CmdEnable handles the "enable" command.
func (h *Handler[C]) CmdEnable(fn Function) {