Something went wrong. Try again.
Monorepo for Tangled — https://tangled.org forked from tangled.org/core
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339package state
import ( "net/http" "strings"
"github.com/go-chi/chi/v5" "tangled.org/core/appview/issues" "tangled.org/core/appview/knots" "tangled.org/core/appview/labels" "tangled.org/core/appview/middleware" "tangled.org/core/appview/notifications" "tangled.org/core/appview/pipelines" "tangled.org/core/appview/pulls" "tangled.org/core/appview/repo" "tangled.org/core/appview/settings" "tangled.org/core/appview/signup" "tangled.org/core/appview/spindles" "tangled.org/core/appview/state/userutil" avstrings "tangled.org/core/appview/strings" "tangled.org/core/log")
func (s *State) Router() http.Handler { router := chi.NewRouter() middleware := middleware.New( s.oauth, s.db, s.enforcer, s.repoResolver, s.idResolver, s.pages, )
router.Get("/favicon.svg", s.Favicon) router.Get("/favicon.ico", s.Favicon) router.Get("/pwa-manifest.json", s.PWAManifest) router.Get("/robots.txt", s.RobotsTxt)
userRouter := s.UserRouter(&middleware) standardRouter := s.StandardRouter(&middleware)
router.HandleFunc("/*", func(w http.ResponseWriter, r *http.Request) { pat := chi.URLParam(r, "*") if strings.HasPrefix(pat, "did:") || strings.HasPrefix(pat, "@") { userRouter.ServeHTTP(w, r) } else { // Check if the first path element is a valid handle without '@' or a flattened DID pathParts := strings.SplitN(pat, "/", 2) if len(pathParts) > 0 { if userutil.IsHandleNoAt(pathParts[0]) { // Redirect to the same path but with '@' prefixed to the handle redirectPath := "@" + pat http.Redirect(w, r, "/"+redirectPath, http.StatusFound) return } else if userutil.IsFlattenedDid(pathParts[0]) { // Redirect to the unflattened DID version unflattenedDid := userutil.UnflattenDid(pathParts[0]) var redirectPath string if len(pathParts) > 1 { redirectPath = unflattenedDid + "/" + pathParts[1] } else { redirectPath = unflattenedDid } http.Redirect(w, r, "/"+redirectPath, http.StatusFound) return } } standardRouter.ServeHTTP(w, r) } })
return router}
func (s *State) UserRouter(mw *middleware.Middleware) http.Handler { r := chi.NewRouter()
r.With(mw.ResolveIdent()).Route("/{user}", func(r chi.Router) { r.Get("/", s.Profile) r.Get("/feed.atom", s.AtomFeedPage)
// redirect /@handle/repo.git -> /@handle/repo r.Get("/{repo}.git", func(w http.ResponseWriter, r *http.Request) { nonDotGitPath := strings.TrimSuffix(r.URL.Path, ".git") http.Redirect(w, r, nonDotGitPath, http.StatusMovedPermanently) })
r.With(mw.ResolveRepo()).Route("/{repo}", func(r chi.Router) { r.Use(mw.GoImport()) r.Mount("/", s.RepoRouter(mw)) r.Mount("/issues", s.IssuesRouter(mw)) r.Mount("/pulls", s.PullsRouter(mw)) r.Mount("/pipelines", s.PipelinesRouter(mw)) r.Mount("/labels", s.LabelsRouter(mw))
// These routes get proxied to the knot r.Get("/info/refs", s.InfoRefs) r.Post("/git-upload-pack", s.UploadPack) r.Post("/git-receive-pack", s.ReceivePack)
}) })
r.NotFound(func(w http.ResponseWriter, r *http.Request) { s.pages.Error404(w) })
return r}
func (s *State) StandardRouter(mw *middleware.Middleware) http.Handler { r := chi.NewRouter()
r.Handle("/static/*", s.pages.Static())
r.Get("/", s.HomeOrTimeline) r.Get("/timeline", s.Timeline) r.Get("/upgradeBanner", s.UpgradeBanner)
// special-case handler for serving tangled.org/core r.Get("/core", s.Core())
r.Get("/login", s.Login) r.Post("/login", s.Login) r.Post("/logout", s.Logout)
r.Route("/repo", func(r chi.Router) { r.Route("/new", func(r chi.Router) { r.Use(middleware.AuthMiddleware(s.oauth)) r.Get("/", s.NewRepo) r.Post("/", s.NewRepo) }) // r.Post("/import", s.ImportRepo) })
r.Get("/goodfirstissues", s.GoodFirstIssues)
r.With(middleware.AuthMiddleware(s.oauth)).Route("/follow", func(r chi.Router) { r.Post("/", s.Follow) r.Delete("/", s.Follow) })
r.With(middleware.AuthMiddleware(s.oauth)).Route("/star", func(r chi.Router) { r.Post("/", s.Star) r.Delete("/", s.Star) })
r.With(middleware.AuthMiddleware(s.oauth)).Route("/react", func(r chi.Router) { r.Post("/", s.React) r.Delete("/", s.React) })
r.Route("/profile", func(r chi.Router) { r.Use(middleware.AuthMiddleware(s.oauth)) r.Get("/edit-bio", s.EditBioFragment) r.Get("/edit-pins", s.EditPinsFragment) r.Post("/bio", s.UpdateProfileBio) r.Post("/pins", s.UpdateProfilePins) })
r.Mount("/settings", s.SettingsRouter()) r.Mount("/strings", s.StringsRouter(mw)) r.Mount("/knots", s.KnotsRouter()) r.Mount("/spindles", s.SpindlesRouter()) r.Mount("/notifications", s.NotificationsRouter(mw))
r.Mount("/signup", s.SignupRouter()) r.Mount("/", s.oauth.Router())
r.Get("/keys/{user}", s.Keys) r.Get("/terms", s.TermsOfService) r.Get("/privacy", s.PrivacyPolicy) r.Get("/brand", s.Brand)
r.NotFound(func(w http.ResponseWriter, r *http.Request) { s.pages.Error404(w) }) return r}
// Core serves tangled.org/core go-import meta tags, and redirects// to the core repository if accessed normally.func (s *State) Core() http.HandlerFunc { return func(w http.ResponseWriter, r *http.Request) { if r.URL.Query().Get("go-get") == "1" { w.Header().Set("Content-Type", "text/html") w.Write([]byte(`<meta name="go-import" content="tangled.org/core git https://tangled.org/@tangled.org/core">`)) return }
http.Redirect(w, r, "/@tangled.org/core", http.StatusFound) }}
func (s *State) SettingsRouter() http.Handler { settings := &settings.Settings{ Db: s.db, OAuth: s.oauth, Pages: s.pages, Config: s.config, }
return settings.Router()}
func (s *State) SpindlesRouter() http.Handler { logger := log.SubLogger(s.logger, "spindles")
spindles := &spindles.Spindles{ Db: s.db, OAuth: s.oauth, Pages: s.pages, Config: s.config, Enforcer: s.enforcer, IdResolver: s.idResolver, Logger: logger, }
return spindles.Router()}
func (s *State) KnotsRouter() http.Handler { logger := log.SubLogger(s.logger, "knots")
knots := &knots.Knots{ Db: s.db, OAuth: s.oauth, Pages: s.pages, Config: s.config, Enforcer: s.enforcer, IdResolver: s.idResolver, Knotstream: s.knotstream, Logger: logger, }
return knots.Router()}
func (s *State) StringsRouter(mw *middleware.Middleware) http.Handler { logger := log.SubLogger(s.logger, "strings")
strs := &avstrings.Strings{ Db: s.db, OAuth: s.oauth, Pages: s.pages, IdResolver: s.idResolver, Notifier: s.notifier, Logger: logger, }
return strs.Router(mw)}
func (s *State) IssuesRouter(mw *middleware.Middleware) http.Handler { issues := issues.New( s.oauth, s.repoResolver, s.pages, s.idResolver, s.db, s.config, s.notifier, s.validator, log.SubLogger(s.logger, "issues"), ) return issues.Router(mw)}
func (s *State) PullsRouter(mw *middleware.Middleware) http.Handler { pulls := pulls.New( s.oauth, s.repoResolver, s.pages, s.idResolver, s.db, s.config, s.notifier, s.enforcer, s.validator, log.SubLogger(s.logger, "pulls"), ) return pulls.Router(mw)}
func (s *State) RepoRouter(mw *middleware.Middleware) http.Handler { repo := repo.New( s.oauth, s.repoResolver, s.pages, s.spindlestream, s.idResolver, s.db, s.config, s.notifier, s.enforcer, log.SubLogger(s.logger, "repo"), s.validator, ) return repo.Router(mw)}
func (s *State) PipelinesRouter(mw *middleware.Middleware) http.Handler { pipes := pipelines.New( s.oauth, s.repoResolver, s.pages, s.spindlestream, s.idResolver, s.db, s.config, s.enforcer, log.SubLogger(s.logger, "pipelines"), ) return pipes.Router(mw)}
func (s *State) LabelsRouter(mw *middleware.Middleware) http.Handler { ls := labels.New( s.oauth, s.pages, s.db, s.validator, s.enforcer, log.SubLogger(s.logger, "labels"), ) return ls.Router(mw)}
func (s *State) NotificationsRouter(mw *middleware.Middleware) http.Handler { notifs := notifications.New(s.db, s.oauth, s.pages, log.SubLogger(s.logger, "notifications")) return notifs.Router(mw)}
func (s *State) SignupRouter() http.Handler { sig := signup.New(s.config, s.db, s.posthog, s.idResolver, s.pages, log.SubLogger(s.logger, "signup")) return sig.Router()}