package main import ( "h4kor/kiss-social" "net/http" "os" "strconv" "github.com/julienschmidt/httprouter" ) // 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, httprouter.Params) { return func(w http.ResponseWriter, r *http.Request, _ httprouter.Params) { 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) func(http.ResponseWriter, *http.Request, httprouter.Params) { return func(w http.ResponseWriter, r *http.Request, ps httprouter.Params) { userName := ps.ByName("user") 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) func(http.ResponseWriter, *http.Request, httprouter.Params) { return func(w http.ResponseWriter, r *http.Request, ps httprouter.Params) { userName := ps.ByName("user") postId := ps.ByName("post") 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) } router := httprouter.New() router.ServeFiles("/static/*filepath", http.Dir(repo.StaticDir())) router.GET("/", indexHandler(repo)) router.GET("/user/:user", userHandler(repo)) router.GET("/user/:user/posts/*post", postHandler(repo)) println("Listening on port", port) http.ListenAndServe(":"+strconv.Itoa(port), router) }