62 lines
1.1 KiB
Go
62 lines
1.1 KiB
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"encoding/json"
|
|
"strings"
|
|
)
|
|
|
|
type User struct{
|
|
Age int `json:"age"`
|
|
Name string `json:"name"`
|
|
Email string `json:"email"`
|
|
}
|
|
|
|
var setChan = make(chan User)
|
|
|
|
func handle(w http.ResponseWriter, r *http.Request) {
|
|
if r.Method != http.MethodPost {
|
|
http.Error(w, "not", http.StatusMethodNotAllowed)
|
|
return
|
|
}
|
|
|
|
var data User
|
|
err := json.NewDecoder(r.Body).Decode(&data)
|
|
if err != nil {
|
|
http.Error(w,"no", http.StatusBadRequest)
|
|
return
|
|
}
|
|
CheckEmail := strings.ContainsAny(data.Email, "@.")
|
|
if CheckEmail != true {
|
|
http.Error(w, "incorrect email", http.StatusBadRequest)
|
|
return
|
|
}
|
|
if data.Age > 150 {
|
|
http.Error(w, "old", http.StatusBadRequest)
|
|
return
|
|
}
|
|
defer r.Body.Close()
|
|
|
|
setChan <- data
|
|
w.WriteHeader(http.StatusOK)
|
|
w.Write([]byte("Data received"))
|
|
}
|
|
|
|
func WatchChanell() {
|
|
for u := range setChan {
|
|
JsonData, err := json.Marshal(u)
|
|
if err != nil { continue }
|
|
fmt.Println(string(JsonData))
|
|
}
|
|
}
|
|
|
|
func main() {
|
|
go WatchChanell()
|
|
http.HandleFunc("/user", handle)
|
|
fmt.Println(":7777")
|
|
err := http.ListenAndServe(":7777", nil)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
}
|