Something went wrong. Try again.
Monorepo for Tangled — https://tangled.org forked from tangled.org/core
Something went wrong. Try again.
6.0 kB · 241 lines
Go
at master
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242package reporesolver
import ( "context" "database/sql" "errors" "fmt" "log" "net/http" "path" "regexp" "strings"
"github.com/bluesky-social/indigo/atproto/identity" securejoin "github.com/cyphar/filepath-securejoin" "github.com/go-chi/chi/v5" "tangled.org/core/appview/config" "tangled.org/core/appview/db" "tangled.org/core/appview/models" "tangled.org/core/appview/oauth" "tangled.org/core/appview/pages" "tangled.org/core/appview/pages/repoinfo" "tangled.org/core/idresolver" "tangled.org/core/rbac")
type ResolvedRepo struct { models.Repo OwnerId identity.Identity CurrentDir string Ref string
rr *RepoResolver}
type RepoResolver struct { config *config.Config enforcer *rbac.Enforcer idResolver *idresolver.Resolver execer db.Execer}
func New(config *config.Config, enforcer *rbac.Enforcer, resolver *idresolver.Resolver, execer db.Execer) *RepoResolver { return &RepoResolver{config: config, enforcer: enforcer, idResolver: resolver, execer: execer}}
func (rr *RepoResolver) Resolve(r *http.Request) (*ResolvedRepo, error) { repo, ok := r.Context().Value("repo").(*models.Repo) if !ok { log.Println("malformed middleware: `repo` not exist in context") return nil, fmt.Errorf("malformed middleware") } id, ok := r.Context().Value("resolvedId").(identity.Identity) if !ok { log.Println("malformed middleware") return nil, fmt.Errorf("malformed middleware") }
currentDir := path.Dir(extractPathAfterRef(r.URL.EscapedPath())) ref := chi.URLParam(r, "ref")
return &ResolvedRepo{ Repo: *repo, OwnerId: id, CurrentDir: currentDir, Ref: ref,
rr: rr, }, nil}
func (f *ResolvedRepo) OwnerDid() string { return f.OwnerId.DID.String()}
func (f *ResolvedRepo) OwnerHandle() string { return f.OwnerId.Handle.String()}
func (f *ResolvedRepo) OwnerSlashRepo() string { handle := f.OwnerId.Handle
var p string if handle != "" && !handle.IsInvalidHandle() { p, _ = securejoin.SecureJoin(fmt.Sprintf("@%s", handle), f.Name) } else { p, _ = securejoin.SecureJoin(f.OwnerDid(), f.Name) }
return p}
func (f *ResolvedRepo) Collaborators(ctx context.Context) ([]pages.Collaborator, error) { repoCollaborators, err := f.rr.enforcer.E.GetImplicitUsersForResourceByDomain(f.DidSlashRepo(), f.Knot) if err != nil { return nil, err }
var collaborators []pages.Collaborator for _, item := range repoCollaborators { // currently only two roles: owner and member var role string switch item[3] { case "repo:owner": role = "owner" case "repo:collaborator": role = "collaborator" default: continue }
did := item[0]
c := pages.Collaborator{ Did: did, Handle: "", Role: role, } collaborators = append(collaborators, c) }
// populate all collborators with handles identsToResolve := make([]string, len(collaborators)) for i, collab := range collaborators { identsToResolve[i] = collab.Did }
resolvedIdents := f.rr.idResolver.ResolveIdents(ctx, identsToResolve) for i, resolved := range resolvedIdents { if resolved != nil { collaborators[i].Handle = resolved.Handle.String() } }
return collaborators, nil}
// this function is a bit weird since it now returns RepoInfo from an entirely different// package. we should refactor this or get rid of RepoInfo entirely.func (f *ResolvedRepo) RepoInfo(user *oauth.User) repoinfo.RepoInfo { repoAt := f.RepoAt() isStarred := false if user != nil { isStarred = db.GetStarStatus(f.rr.execer, user.Did, repoAt) }
starCount, err := db.GetStarCount(f.rr.execer, repoAt) if err != nil { log.Println("failed to get star count for ", repoAt) } issueCount, err := db.GetIssueCount(f.rr.execer, repoAt) if err != nil { log.Println("failed to get issue count for ", repoAt) } pullCount, err := db.GetPullCount(f.rr.execer, repoAt) if err != nil { log.Println("failed to get issue count for ", repoAt) } source, err := db.GetRepoSource(f.rr.execer, repoAt) if errors.Is(err, sql.ErrNoRows) { source = "" } else if err != nil { log.Println("failed to get repo source for ", repoAt, err) }
var sourceRepo *models.Repo if source != "" { sourceRepo, err = db.GetRepoByAtUri(f.rr.execer, source) if err != nil { log.Println("failed to get repo by at uri", err) } }
var sourceHandle *identity.Identity if sourceRepo != nil { sourceHandle, err = f.rr.idResolver.ResolveIdent(context.Background(), sourceRepo.Did) if err != nil { log.Println("failed to resolve source repo", err) } }
knot := f.Knot
repoInfo := repoinfo.RepoInfo{ OwnerDid: f.OwnerDid(), OwnerHandle: f.OwnerHandle(), Name: f.Name, Rkey: f.Repo.Rkey, RepoAt: repoAt, Description: f.Description, IsStarred: isStarred, Knot: knot, Spindle: f.Spindle, Roles: f.RolesInRepo(user), Stats: models.RepoStats{ StarCount: starCount, IssueCount: issueCount, PullCount: pullCount, }, CurrentDir: f.CurrentDir, Ref: f.Ref, }
if sourceRepo != nil { repoInfo.Source = sourceRepo repoInfo.SourceHandle = sourceHandle.Handle.String() }
return repoInfo}
func (f *ResolvedRepo) RolesInRepo(u *oauth.User) repoinfo.RolesInRepo { if u != nil { r := f.rr.enforcer.GetPermissionsInRepo(u.Did, f.Knot, f.DidSlashRepo()) return repoinfo.RolesInRepo{Roles: r} } else { return repoinfo.RolesInRepo{} }}
// extractPathAfterRef gets the actual repository path// after the ref. for example://// /@icyphox.sh/foorepo/blob/main/abc/xyz/ => abc/xyz/func extractPathAfterRef(fullPath string) string { fullPath = strings.TrimPrefix(fullPath, "/")
// match blob/, tree/, or raw/ followed by any ref and then a slash // // captures everything after the final slash pattern := `(?:blob|tree|raw)/[^/]+/(.*)$`
re := regexp.MustCompile(pattern) matches := re.FindStringSubmatch(fullPath)
if len(matches) > 1 { return matches[1] }
return ""}