Lindenii Project Forge
Commit info | |
---|---|
ID | 83f9f192b52020b7fecc8ff9ad3f976ea7485935 |
Author | Runxi Yu<me@runxiyu.org> |
Author date | Wed, 12 Feb 2025 11:47:11 +0800 |
Committer | Runxi Yu<me@runxiyu.org> |
Committer date | Wed, 12 Feb 2025 11:47:11 +0800 |
Actions | Get patch |
*.go: Reformat
package main import ( "flag" "net" "net/http" "go.lindenii.runxiyu.org/lindenii-common/clog" ) func main() { config_path := flag.String( "config", "/etc/lindenii/forge.scfg", "path to configuration file", ) flag.Parse() err := load_config(*config_path) if err != nil { clog.Fatal(1, "Loading configuration: "+err.Error()) } err = load_templates() if err != nil { clog.Fatal(1, "Loading templates: "+err.Error()) }
// http.HandleFunc("/{$}", handle_index) // http.HandleFunc("/g/{group_name}/repos/{$}", handle_group_repos) // http.HandleFunc("/g/{group_name}/repos/{repo_name}/{$}", handle_repo_index) // http.HandleFunc("/g/{group_name}/repos/{repo_name}/tree/{rest...}", handle_repo_tree) // http.HandleFunc("/g/{group_name}/repos/{repo_name}/raw/{rest...}", handle_repo_raw) // http.HandleFunc("/g/{group_name}/repos/{repo_name}/log/{ref}/", handle_repo_log) // http.HandleFunc("/g/{group_name}/repos/{repo_name}/commit/{commit_id}", handle_repo_commit)
listener, err := net.Listen(config.HTTP.Net, config.HTTP.Addr) if err != nil { clog.Fatal(1, "Listening: "+err.Error()) } err = http.Serve(listener, &http_router_t{}) if err != nil { clog.Fatal(1, "Serving: "+err.Error()) } }
package main import ( "embed" "html/template" "io/fs" "net/http" ) //go:embed .gitignore LICENSE README.md //go:embed *.go go.mod go.sum //go:embed *.scfg //go:embed schema.sql //go:embed static/* templates/* var source_fs embed.FS var source_handler http.Handler func init() { source_handler = http.StripPrefix( "/:/source/", http.FileServer(http.FS(source_fs)), ) } //go:embed templates/* static/* var resources_fs embed.FS var templates *template.Template func load_templates() (err error) { templates, err = template.New("templates").Funcs(template.FuncMap{ "first_line": first_line, "base_name": base_name, }).ParseFS(resources_fs, "templates/*") return err } var static_handler http.Handler
func init() { static_fs, err := fs.Sub(resources_fs, "static") if err != nil { panic(err) } static_handler = http.StripPrefix("/:/static/", http.FileServer(http.FS(static_fs))) }
package main import ( "errors" "fmt" "net/http" "strings" ) type http_router_t struct{} func (router *http_router_t) ServeHTTP(w http.ResponseWriter, r *http.Request) { segments, _, err := parse_request_uri(r.RequestURI) if err != nil { http.Error(w, err.Error(), http.StatusBadRequest) return } if segments[0] == ":" { switch segments[1] { case "static": static_handler.ServeHTTP(w, r) case "source": source_handler.ServeHTTP(w, r) default: fmt.Fprintln(w, "Unknown system module type:", segments[1]) } return } separator_index := -1 for i, part := range segments { if part == ":" { separator_index = i break } } non_empty_last_segments_len := len(segments) dir_mode := false if segments[len(segments)-1] == "" { non_empty_last_segments_len-- dir_mode = true } params := make(map[string]string) _ = params switch { case non_empty_last_segments_len == 0: handle_index(w, r) case separator_index == -1: fmt.Fprintln(w, "Group indexing hasn't been implemented yet") case non_empty_last_segments_len == separator_index+1: fmt.Fprintln(w, "Group root hasn't been implemented yet") case non_empty_last_segments_len == separator_index+2: module_type := segments[separator_index+1] params["group_name"] = segments[0] switch module_type { case "repos": handle_group_repos(w, r, params) default: fmt.Fprintln(w, "Unknown module type:", module_type) } default: module_type := segments[separator_index+1] module_name := segments[separator_index+2] params["group_name"] = segments[0] switch module_type { case "repos": params["repo_name"] = module_name // TODO: subgroups if non_empty_last_segments_len == separator_index+3 { if !dir_mode { http.Redirect(w, r, r.URL.Path+"/", http.StatusSeeOther) return } handle_repo_index(w, r, params) return } repo_feature := segments[separator_index+3] switch repo_feature { case "tree": params["rest"] = strings.Join(segments[separator_index+4:], "/") handle_repo_tree(w, r, params) case "raw": params["rest"] = strings.Join(segments[separator_index+4:], "/") handle_repo_raw(w, r, params) case "log": if non_empty_last_segments_len != separator_index+5 { fmt.Fprintln(w, "Too many parameters") return } if dir_mode { http.Redirect(w, r, strings.TrimSuffix(r.URL.Path, "/"), http.StatusSeeOther) return } params["ref"] = segments[separator_index+4] handle_repo_log(w, r, params) case "commit": if dir_mode { http.Redirect(w, r, strings.TrimSuffix(r.URL.Path, "/"), http.StatusSeeOther) return } params["commit_id"] = segments[separator_index+4] handle_repo_commit(w, r, params) } default: fmt.Fprintln(w, "Unknown module type:", module_type) } } } var err_bad_request = errors.New("Bad Request")
package main type display_git_tree_entry_t struct { Name string Mode string Size int64 Is_file bool Is_subtree bool }