Function newDeviceHandler

server/http_config_device_handler.go:340–417

newDeviceHandler creates a new device by class

(site site.API, authObject auth.Auth)

// newDeviceHandler creates a new device by class
func newDeviceHandler(site site.API, authObject auth.Auth) http.HandlerFunc {
	return func(w http.ResponseWriter, r *http.Request) {
		vars := mux.Vars(r)

		class, err := templates.ClassString(vars["class"])
		if err != nil {
			jsonError(w, http.StatusBadRequest, err)
			return
		}

		req, err := decodeDeviceConfig(r.Body)
		if err != nil {
			jsonError(w, http.StatusBadRequest, err)
			return
		}

		if !requireCriticalConfigAuth(w, r, authObject, req) {
			return
		}

		var conf *config.Config
		ctx, cancel, done := startDeviceTimeout()

		force := r.URL.Query().Get("force") == "true"

		switch class {
		case templates.Charger:
			conf, err = newDevice(ctx, class, req, charger.NewFromConfig, config.Chargers(), force)

		case templates.Meter:
			conf, err = newDevice(ctx, class, req, meter.NewFromConfig, config.Meters(), force)

		case templates.Vehicle:
			conf, err = newDevice(ctx, class, req, vehicle.NewFromConfig, config.Vehicles(), force)

		case templates.Circuit:
			conf, err = newDevice(ctx, class, req, circuit.NewFromConfig, config.Circuits(), force)

		case templates.Hems:
			if existing, _ := config.ConfigurationByClass(templates.Hems); existing != nil {
				err = errors.New("hems already configured")
			} else {
				conf, err = newDevice(ctx, class, req, newHemsFactory(site), config.Hems(), force)
			}

		case templates.Tariff:
			conf, err = newDevice(ctx, class, req, tariff.NewFromConfig, config.Tariffs(), force)

		case templates.Messenger:
			conf, err = newDevice(ctx, class, req, messenger.NewFromConfig, config.Messengers(), force)
		}

		if err != nil {
			cancel()
			jsonError(w, http.StatusBadRequest, err)
			return
		}