Method configuration

control/methods.go:30–59

( writer http.ResponseWriter, request *http.Request )

)

func ( s *Server ) configuration( writer http.ResponseWriter, request *http.Request ) {
	select {
		case s.connectionOpsLock<-struct{}{}: defer func() { <-s.connectionOpsLock }(); break
		case <-time.NewTimer( time.Second ).C: http.Error( writer, http.StatusText( http.StatusConflict ), http.StatusConflict ); return
	}
	switch request.Method {
		case "GET":
			writer.WriteHeader( http.StatusOK )
			encoder := json.NewEncoder( writer )
			s.connection.Lock(); defer s.connection.Unlock()
			if err := encoder.Encode( s.connection.Config ); err != nil { log.Println( "Serv: [ERR] Configure failed: ", err ); return }
			log.Println( "Serv: Configuration sent to", request.RemoteAddr )
			s.connection.StateNotify( &connection.State{ Code: connection.ConfigurationGet, Timestamp: time.Now() } )
		case "POST":
			logBuffer := &bytes.Buffer{}
			decoder := json.NewDecoder( io.TeeReader( io.LimitReader( request.Body, 8192 ), logBuffer ) )
			s.connection.Lock(); defer s.connection.Unlock()
			if err := decoder.Decode( s.connection.Config ); err != nil {
				log.Println( "Serv: [ERR] Configure failed:", err )
				writer.WriteHeader( http.StatusBadRequest )
				writer.Write( Result{ Error: &Error{ Code: CodeConfig, Message: err.Error() } }.Json() )
				return
			}
			log.Println( "Serv: Configured from", request.RemoteAddr, "with", logBuffer.String() )
			writer.WriteHeader( http.StatusOK )
			writer.Write( Result{ Result: true }.Json() )
			s.connection.StateNotify( &connection.State{ Code: connection.ConfigurationSet, Timestamp: time.Now()} )
		default: http.Error( writer, "not found", http.StatusNotFound )
	}
}

func ( s *Server ) route( writer http.ResponseWriter, request *http.Request ) {
	if request.Method != "GET" { http.Error( writer, http.StatusText( http.StatusNotFound ), http.StatusNotFound ); return }