package main import ( "h4kor/kiss-social" "h4kor/kiss-social/cmd/kiss-web/static" "net/http" "os" "strconv" "strings" ) func handler(repo kiss.Repository) func(http.ResponseWriter, *http.Request) { return func(w http.ResponseWriter, r *http.Request) { // normalize the path path := r.URL.Path // remove leading '/' if len(path) > 0 && path[0] == '/' { path = path[1:] } // remove trailing '/' if len(path) > 0 && path[len(path)-1] == '/' { path = path[:len(path)-1] } // index page if path == "" { println("Index page") indexHandler(repo)(w, r) return } // parse the path parts := strings.Split(path, "/") userName := parts[0] // only one part -> user page if len(parts) == 1 { println("User page") userHandler(repo, userName)(w, r) return } // multiple parts -> post page println("Post page") postId := strings.Join(parts[1:], "/") postHandler(repo, userName, postId)(w, r) } } func indexHandler(repo kiss.Repository) func(http.ResponseWriter, *http.Request) { return func(w http.ResponseWriter, r *http.Request) { html, err := kiss.RenderUserList(repo) if err != nil { println("Error rendering index: ", err.Error()) w.WriteHeader(http.StatusInternalServerError) w.Write([]byte("Internal server error")) return } println("Rendering index") w.Write([]byte(html)) } } func userHandler(repo kiss.Repository, userName string) func(http.ResponseWriter, *http.Request) { return func(w http.ResponseWriter, r *http.Request) { user, err := repo.GetUser(userName) if err != nil { println("Error getting user: ", err.Error()) w.WriteHeader(http.StatusNotFound) w.Write([]byte("User not found")) return } html, err := kiss.RenderIndexPage(user) if err != nil { println("Error rendering index page: ", err.Error()) w.WriteHeader(http.StatusInternalServerError) w.Write([]byte("Internal server error")) return } println("Rendering index page for user", userName) w.Write([]byte(html)) } } func postHandler(repo kiss.Repository, userName string, postId string) func(http.ResponseWriter, *http.Request) { return func(w http.ResponseWriter, r *http.Request) { user, err := repo.GetUser(userName) if err != nil { println("Error getting user: ", err.Error()) w.WriteHeader(http.StatusNotFound) w.Write([]byte("User not found")) return } post, err := user.GetPost(postId) if err != nil { println("Error getting post: ", err.Error()) w.WriteHeader(http.StatusNotFound) w.Write([]byte("Post not found")) return } html, err := kiss.RenderPost(post) if err != nil { println("Error rendering post: ", err.Error()) w.WriteHeader(http.StatusInternalServerError) w.Write([]byte("Internal server error")) return } println("Rendering post", postId) w.Write([]byte(html)) } } func main() { println("KISS Web Server") println("Parameters") println("-repo - Specify the repository to use. Defaults to '.'") println("-port - Specify the port to use, Default is '8080'") var repoName string var port int for i, arg := range os.Args[0 : len(os.Args)-1] { if arg == "-port" { port, _ = strconv.Atoi(os.Args[i+1]) } if arg == "-repo" { repoName = os.Args[i+1] } } if repoName == "" { repoName = "." } if port == 0 { port = 8080 } repo, err := kiss.OpenRepository(repoName) if err != nil { println("Error opening repository: ", err.Error()) os.Exit(1) } http.Handle("/static/", static.StaticHandler(repo)) http.HandleFunc("/", handler(repo)) println("Listening on port", port) http.ListenAndServe(":"+strconv.Itoa(port), nil) }