func setEnv(w http.ResponseWriter, r *http.Request, t auth.Token) (err error) {
	var e apiTypes.Envs
	err = ParseInput(r, &e)
	if err != nil {
		return err
	}
	if len(e.Envs) == 0 {
		msg := "You must provide the list of environment variables"
		return &errors.HTTP{Code: http.StatusBadRequest, Message: msg}
	}
	appName := r.URL.Query().Get(":app")
	a, err := getAppFromContext(appName, r)
	if err != nil {
		return err
	}
	allowed := permission.Check(t, permission.PermAppUpdateEnvSet,
		contextsForApp(&a)...,
	)
	if !allowed {
		return permission.ErrUnauthorized
	}
	var toExclude []string
	if e.Private {
		for i := 0; i < len(e.Envs); i++ {
			toExclude = append(toExclude, fmt.Sprintf("Envs.%d.Value", i))
		}
	}
	evt, err := event.New(&event.Opts{
		Target:     appTarget(appName),
		Kind:       permission.PermAppUpdateEnvSet,
		Owner:      t,
		CustomData: event.FormToCustomData(InputFields(r, toExclude...)),
		Allowed:    event.Allowed(permission.PermAppReadEvents, contextsForApp(&a)...),
	})
	if err != nil {
		return err
	}
	defer func() { evt.Done(err) }()
	envs := map[string]string{}
	variables := []bind.EnvVar{}
	for _, v := range e.Envs {
		envs[v.Name] = v.Value
		variables = append(variables, bind.EnvVar{Name: v.Name, Value: v.Value, Public: !e.Private})
	}
	w.Header().Set("Content-Type", "application/x-json-stream")
	keepAliveWriter := tsuruIo.NewKeepAliveWriter(w, 30*time.Second, "")
	defer keepAliveWriter.Stop()
	writer := &tsuruIo.SimpleJsonMessageEncoderWriter{Encoder: json.NewEncoder(keepAliveWriter)}
	evt.SetLogWriter(writer)
	err = a.SetEnvs(bind.SetEnvArgs{
		Envs:          variables,
		ShouldRestart: !e.NoRestart,
		Writer:        evt,
	})
	if v, ok := err.(*errors.ValidationError); ok {
		return &errors.HTTP{Code: http.StatusBadRequest, Message: v.Message}
	}
	return err
}
func setEnv(w http.ResponseWriter, r *http.Request, t auth.Token) (err error) {
	var e apiTypes.Envs
	err = ParseInput(r, &e)
	if err != nil {
		return err
	}
	if len(e.Envs) == 0 {
		msg := "You must provide the list of environment variables"
		return &errors.HTTP{Code: http.StatusBadRequest, Message: msg}
	}
	appName := r.URL.Query().Get(":app")
	a, err := getAppFromContext(appName, r)
	if err != nil {
		return err
	}
	allowed := permission.Check(t, permission.PermAppUpdateEnvSet,
		contextsForApp(&a)...,
	)
	if !allowed {
		return permission.ErrUnauthorized
	}
	var toExclude []string
	if e.Private {
		for i := 0; i < len(e.Envs); i++ {
			toExclude = append(toExclude, fmt.Sprintf("Envs.%d.Value", i))
		}
	}
	evt, err := event.New(&event.Opts{
		Target:     appTarget(appName),
		Kind:       permission.PermAppUpdateEnvSet,
		Owner:      t,
		CustomData: event.FormToCustomData(InputFields(r, toExclude...)),
		Allowed:    event.Allowed(permission.PermAppReadEvents, contextsForApp(&a)...),
	})
	if err != nil {
		return err
	}
	defer func() { evt.Done(err) }()
	envs := map[string]string{}
	variables := []bind.EnvVar{}
	for _, v := range e.Envs {
		envs[v.Name] = v.Value
		variables = append(variables, bind.EnvVar{Name: v.Name, Value: v.Value, Public: !e.Private})
	}
	w.Header().Set("Content-Type", "application/x-json-stream")
	keepAliveWriter := tsuruIo.NewKeepAliveWriter(w, 30*time.Second, "")
	defer keepAliveWriter.Stop()
	writer := &tsuruIo.SimpleJsonMessageEncoderWriter{Encoder: json.NewEncoder(keepAliveWriter)}
	evt.SetLogWriter(writer)
	err = a.SetEnvs(bind.SetEnvArgs{
		Envs:          variables,
		ShouldRestart: !e.NoRestart,
		Writer:        evt,
	})
	if v, ok := err.(*errors.ValidationError); ok {
		return &errors.HTTP{Code: http.StatusBadRequest, Message: v.Message}
	}
	return err
}
func setEnv ( w http . ResponseWriter , r * http . Request , t auth . Token ) ( err error ) { var e apiTypes . Envs err = ParseInput ( r , & e ) if err != nil { return err } if len ( e . Envs ) == 0 { msg := " " return & errors . HTTP { Code : http . StatusBadRequest , Message : msg } } appName := r . URL . Query ( ) . Get ( " " ) a , err := getAppFromContext ( appName , r ) if err != nil { return err } allowed := permission . Check ( t , permission . PermAppUpdateEnvSet , contextsForApp ( & a ) ... , ) if ! allowed { return permission . ErrUnauthorized } var toExclude [ ] string if e . Private { for i := 0 ; i < len ( e . Envs ) ; i ++ { toExclude = append ( toExclude , fmt . Sprintf ( " " , i ) ) } } evt , err := event . New ( & event . Opts { Target : appTarget ( appName ) , Kind : permission . PermAppUpdateEnvSet , Owner : t , CustomData : event . FormToCustomData ( InputFields ( r , toExclude ... ) ) , Allowed : event . Allowed ( permission . PermAppReadEvents , contextsForApp ( & a ) ... ) , } ) if err != nil { return err } defer func ( ) { evt . Done ( err ) } ( ) envs := map [ string ] string { } variables := [ ] bind . EnvVar { } for _ , v := range e . Envs { envs [ v . Name ] = v . Value variables = append ( variables , bind . EnvVar { Name : v . Name , Value : v . Value , Public : ! e . Private } ) } w . Header ( ) . Set ( " " , " " ) keepAliveWriter := tsuruIo . NewKeepAliveWriter ( w , 30 * time . Second , " " ) defer keepAliveWriter . Stop ( ) writer := & tsuruIo . SimpleJsonMessageEncoderWriter { Encoder : json . NewEncoder ( keepAliveWriter ) } evt . SetLogWriter ( writer ) err = a . SetEnvs ( bind . SetEnvArgs { Envs : variables , ShouldRestart : ! e . NoRestart , Writer : evt , } ) if v , ok := err . ( * errors . ValidationError ) ; ok { return & errors . HTTP { Code : http . StatusBadRequest , Message : v . Message } } return err }
// title: set envs
// path: /apps/{app}/env
// method: POST
// consume: application/x-www-form-urlencoded
// produce: application/x-json-stream
// responses:
//   200: Envs updated
//   400: Invalid data
//   401: Unauthorized
//   404: App not found
title : set envs path : / apps / { app } / env method : POST consume : application / x - www - form - urlencoded produce : application / x - json - stream responses : 200 : Envs updated 400 : Invalid data 401 : Unauthorized 404 : App not found