···
+
"tangled.sh/tangled.sh/core/appview/commitverify"
+
"tangled.sh/tangled.sh/core/appview/db"
+
"tangled.sh/tangled.sh/core/appview/oauth"
+
"tangled.sh/tangled.sh/core/appview/pages"
+
"tangled.sh/tangled.sh/core/appview/pages/repoinfo"
+
"tangled.sh/tangled.sh/core/appview/reporesolver"
+
"tangled.sh/tangled.sh/core/knotclient"
+
"tangled.sh/tangled.sh/core/types"
+
"github.com/go-chi/chi/v5"
+
func (rp *Repo) RepoIndex(w http.ResponseWriter, r *http.Request) {
+
ref := chi.URLParam(r, "ref")
+
f, err := rp.repoResolver.Resolve(r)
+
log.Println("failed to fully resolve repo", err)
+
us, err := knotclient.NewUnsignedClient(f.Knot, rp.config.Core.Dev)
+
log.Printf("failed to create unsigned client for %s", f.Knot)
+
result, err := us.Index(f.OwnerDid(), f.RepoName, ref)
+
log.Println("failed to reach knotserver", err)
+
tagMap := make(map[string][]string)
+
for _, tag := range result.Tags {
+
hash = tag.Tag.Target.String()
+
tagMap[hash] = append(tagMap[hash], tag.Name)
+
for _, branch := range result.Branches {
+
tagMap[hash] = append(tagMap[hash], branch.Name)
+
slices.SortFunc(result.Branches, func(a, b types.Branch) int {
+
if a.Name == result.Ref {
+
if a.Commit != nil && b.Commit != nil {
+
if a.Commit.Committer.When.Before(b.Commit.Committer.When) {
+
return strings.Compare(a.Name, b.Name) * -1
+
commitCount := len(result.Commits)
+
branchCount := len(result.Branches)
+
tagCount := len(result.Tags)
+
fileCount := len(result.Files)
+
commitCount, branchCount, tagCount = balanceIndexItems(commitCount, branchCount, tagCount, fileCount)
+
commitsTrunc := result.Commits[:min(commitCount, len(result.Commits))]
+
tagsTrunc := result.Tags[:min(tagCount, len(result.Tags))]
+
branchesTrunc := result.Branches[:min(branchCount, len(result.Branches))]
+
emails := uniqueEmails(commitsTrunc)
+
emailToDidMap, err := db.GetEmailToDid(rp.db, emails, true)
+
log.Println("failed to get email to did map", err)
+
vc, err := commitverify.GetVerifiedObjectCommits(rp.db, emailToDidMap, commitsTrunc)
+
user := rp.oauth.GetUser(r)
+
repoInfo := f.RepoInfo(user)
+
secret, err := db.GetRegistrationKey(rp.db, f.Knot)
+
log.Printf("failed to get registration key for %s: %s", f.Knot, err)
+
rp.pages.Notice(w, "resubmit-error", "Failed to create pull request. Try again later.")
+
signedClient, err := knotclient.NewSignedClient(f.Knot, secret, rp.config.Core.Dev)
+
log.Printf("failed to create signed client for %s: %s", f.Knot, err)
+
var forkInfo *types.ForkInfo
+
if user != nil && (repoInfo.Roles.IsOwner() || repoInfo.Roles.IsCollaborator()) {
+
forkInfo, err = getForkInfo(repoInfo, rp, f, user, signedClient)
+
log.Printf("Failed to fetch fork information: %v", err)
+
repoLanguages, err := signedClient.RepoLanguages(f.OwnerDid(), f.RepoName, ref)
+
log.Printf("failed to compute language percentages: %s", err)
+
rp.pages.RepoIndexPage(w, pages.RepoIndexParams{
+
RepoIndexResponse: *result,
+
CommitsTrunc: commitsTrunc,
+
BranchesTrunc: branchesTrunc,
+
EmailToDidOrHandle: emailToDidOrHandle(rp, emailToDidMap),
+
Languages: repoLanguages,
+
repoInfo repoinfo.RepoInfo,
+
f *reporesolver.ResolvedRepo,
+
signedClient *knotclient.SignedClient,
+
) (*types.ForkInfo, error) {
+
forkInfo := types.ForkInfo{
+
IsFork: repoInfo.Source != nil,
+
Status: types.UpToDate,
+
forkInfo.IsFork = false
+
us, err := knotclient.NewUnsignedClient(repoInfo.Source.Knot, rp.config.Core.Dev)
+
log.Printf("failed to create unsigned client for %s", repoInfo.Source.Knot)
+
result, err := us.Branches(repoInfo.Source.Did, repoInfo.Source.Name)
+
log.Println("failed to reach knotserver", err)
+
if !slices.ContainsFunc(result.Branches, func(branch types.Branch) bool {
+
return branch.Name == f.Ref
+
forkInfo.Status = types.MissingBranch
+
newHiddenRefResp, err := signedClient.NewHiddenRef(user.Did, repoInfo.Name, f.Ref, f.Ref)
+
if err != nil || newHiddenRefResp.StatusCode != http.StatusNoContent {
+
log.Printf("failed to update tracking branch: %s", err)
+
hiddenRef := fmt.Sprintf("hidden/%s/%s", f.Ref, f.Ref)
+
var status types.AncestorCheckResponse
+
forkSyncableResp, err := signedClient.RepoForkAheadBehind(user.Did, string(f.RepoAt), repoInfo.Name, f.Ref, hiddenRef)
+
log.Printf("failed to check if fork is ahead/behind: %s", err)
+
if err := json.NewDecoder(forkSyncableResp.Body).Decode(&status); err != nil {
+
log.Printf("failed to decode fork status: %s", err)
+
forkInfo.Status = status.Status