forked from tangled.org/core
Monorepo for Tangled — https://tangled.org
1package state 2 3import ( 4 "context" 5 "fmt" 6 "log" 7 "net/http" 8 "slices" 9 "strings" 10 "time" 11 12 comatproto "github.com/bluesky-social/indigo/api/atproto" 13 "github.com/bluesky-social/indigo/atproto/identity" 14 "github.com/bluesky-social/indigo/atproto/syntax" 15 lexutil "github.com/bluesky-social/indigo/lex/util" 16 "github.com/go-chi/chi/v5" 17 "github.com/gorilla/feeds" 18 "tangled.org/core/api/tangled" 19 "tangled.org/core/appview/db" 20 "tangled.org/core/appview/models" 21 "tangled.org/core/appview/pages" 22) 23 24func (s *State) Profile(w http.ResponseWriter, r *http.Request) { 25 tabVal := r.URL.Query().Get("tab") 26 switch tabVal { 27 case "repos": 28 s.reposPage(w, r) 29 case "followers": 30 s.followersPage(w, r) 31 case "following": 32 s.followingPage(w, r) 33 case "starred": 34 s.starredPage(w, r) 35 case "strings": 36 s.stringsPage(w, r) 37 default: 38 s.profileOverview(w, r) 39 } 40} 41 42func (s *State) profile(r *http.Request) (*pages.ProfileCard, error) { 43 didOrHandle := chi.URLParam(r, "user") 44 if didOrHandle == "" { 45 return nil, fmt.Errorf("empty DID or handle") 46 } 47 48 ident, ok := r.Context().Value("resolvedId").(identity.Identity) 49 if !ok { 50 return nil, fmt.Errorf("failed to resolve ID") 51 } 52 did := ident.DID.String() 53 54 profile, err := db.GetProfile(s.db, did) 55 if err != nil { 56 return nil, fmt.Errorf("failed to get profile: %w", err) 57 } 58 59 repoCount, err := db.CountRepos(s.db, db.FilterEq("did", did)) 60 if err != nil { 61 return nil, fmt.Errorf("failed to get repo count: %w", err) 62 } 63 64 stringCount, err := db.CountStrings(s.db, db.FilterEq("did", did)) 65 if err != nil { 66 return nil, fmt.Errorf("failed to get string count: %w", err) 67 } 68 69 starredCount, err := db.CountStars(s.db, db.FilterEq("starred_by_did", did)) 70 if err != nil { 71 return nil, fmt.Errorf("failed to get starred repo count: %w", err) 72 } 73 74 followStats, err := db.GetFollowerFollowingCount(s.db, did) 75 if err != nil { 76 return nil, fmt.Errorf("failed to get follower stats: %w", err) 77 } 78 79 loggedInUser := s.oauth.GetUser(r) 80 followStatus := models.IsNotFollowing 81 if loggedInUser != nil { 82 followStatus = db.GetFollowStatus(s.db, loggedInUser.Did, did) 83 } 84 85 now := time.Now() 86 startOfYear := time.Date(now.Year(), 1, 1, 0, 0, 0, 0, time.UTC) 87 punchcard, err := db.MakePunchcard( 88 s.db, 89 db.FilterEq("did", did), 90 db.FilterGte("date", startOfYear.Format(time.DateOnly)), 91 db.FilterLte("date", now.Format(time.DateOnly)), 92 ) 93 if err != nil { 94 return nil, fmt.Errorf("failed to get punchcard for %s: %w", did, err) 95 } 96 97 return &pages.ProfileCard{ 98 UserDid: did, 99 UserHandle: ident.Handle.String(), 100 Profile: profile, 101 FollowStatus: followStatus, 102 Stats: pages.ProfileStats{ 103 RepoCount: repoCount, 104 StringCount: stringCount, 105 StarredCount: starredCount, 106 FollowersCount: followStats.Followers, 107 FollowingCount: followStats.Following, 108 }, 109 Punchcard: punchcard, 110 }, nil 111} 112 113func (s *State) profileOverview(w http.ResponseWriter, r *http.Request) { 114 l := s.logger.With("handler", "profileHomePage") 115 116 profile, err := s.profile(r) 117 if err != nil { 118 l.Error("failed to build profile card", "err", err) 119 s.pages.Error500(w) 120 return 121 } 122 l = l.With("profileDid", profile.UserDid, "profileHandle", profile.UserHandle) 123 124 repos, err := db.GetRepos( 125 s.db, 126 0, 127 db.FilterEq("did", profile.UserDid), 128 ) 129 if err != nil { 130 l.Error("failed to fetch repos", "err", err) 131 } 132 133 // filter out ones that are pinned 134 pinnedRepos := []models.Repo{} 135 for i, r := range repos { 136 // if this is a pinned repo, add it 137 if slices.Contains(profile.Profile.PinnedRepos[:], r.RepoAt()) { 138 pinnedRepos = append(pinnedRepos, r) 139 } 140 141 // if there are no saved pins, add the first 4 repos 142 if profile.Profile.IsPinnedReposEmpty() && i < 4 { 143 pinnedRepos = append(pinnedRepos, r) 144 } 145 } 146 147 collaboratingRepos, err := db.CollaboratingIn(s.db, profile.UserDid) 148 if err != nil { 149 l.Error("failed to fetch collaborating repos", "err", err) 150 } 151 152 pinnedCollaboratingRepos := []models.Repo{} 153 for _, r := range collaboratingRepos { 154 // if this is a pinned repo, add it 155 if slices.Contains(profile.Profile.PinnedRepos[:], r.RepoAt()) { 156 pinnedCollaboratingRepos = append(pinnedCollaboratingRepos, r) 157 } 158 } 159 160 timeline, err := db.MakeProfileTimeline(s.db, profile.UserDid) 161 if err != nil { 162 l.Error("failed to create timeline", "err", err) 163 } 164 165 s.pages.ProfileOverview(w, pages.ProfileOverviewParams{ 166 LoggedInUser: s.oauth.GetUser(r), 167 Card: profile, 168 Repos: pinnedRepos, 169 CollaboratingRepos: pinnedCollaboratingRepos, 170 ProfileTimeline: timeline, 171 }) 172} 173 174func (s *State) reposPage(w http.ResponseWriter, r *http.Request) { 175 l := s.logger.With("handler", "reposPage") 176 177 profile, err := s.profile(r) 178 if err != nil { 179 l.Error("failed to build profile card", "err", err) 180 s.pages.Error500(w) 181 return 182 } 183 l = l.With("profileDid", profile.UserDid, "profileHandle", profile.UserHandle) 184 185 repos, err := db.GetRepos( 186 s.db, 187 0, 188 db.FilterEq("did", profile.UserDid), 189 ) 190 if err != nil { 191 l.Error("failed to get repos", "err", err) 192 s.pages.Error500(w) 193 return 194 } 195 196 err = s.pages.ProfileRepos(w, pages.ProfileReposParams{ 197 LoggedInUser: s.oauth.GetUser(r), 198 Repos: repos, 199 Card: profile, 200 }) 201} 202 203func (s *State) starredPage(w http.ResponseWriter, r *http.Request) { 204 l := s.logger.With("handler", "starredPage") 205 206 profile, err := s.profile(r) 207 if err != nil { 208 l.Error("failed to build profile card", "err", err) 209 s.pages.Error500(w) 210 return 211 } 212 l = l.With("profileDid", profile.UserDid, "profileHandle", profile.UserHandle) 213 214 stars, err := db.GetStars(s.db, 0, db.FilterEq("starred_by_did", profile.UserDid)) 215 if err != nil { 216 l.Error("failed to get stars", "err", err) 217 s.pages.Error500(w) 218 return 219 } 220 var repoAts []string 221 for _, s := range stars { 222 repoAts = append(repoAts, string(s.RepoAt)) 223 } 224 225 repos, err := db.GetRepos( 226 s.db, 227 0, 228 db.FilterIn("at_uri", repoAts), 229 ) 230 if err != nil { 231 l.Error("failed to get repos", "err", err) 232 s.pages.Error500(w) 233 return 234 } 235 236 err = s.pages.ProfileStarred(w, pages.ProfileStarredParams{ 237 LoggedInUser: s.oauth.GetUser(r), 238 Repos: repos, 239 Card: profile, 240 }) 241} 242 243func (s *State) stringsPage(w http.ResponseWriter, r *http.Request) { 244 l := s.logger.With("handler", "stringsPage") 245 246 profile, err := s.profile(r) 247 if err != nil { 248 l.Error("failed to build profile card", "err", err) 249 s.pages.Error500(w) 250 return 251 } 252 l = l.With("profileDid", profile.UserDid, "profileHandle", profile.UserHandle) 253 254 strings, err := db.GetStrings(s.db, 0, db.FilterEq("did", profile.UserDid)) 255 if err != nil { 256 l.Error("failed to get strings", "err", err) 257 s.pages.Error500(w) 258 return 259 } 260 261 err = s.pages.ProfileStrings(w, pages.ProfileStringsParams{ 262 LoggedInUser: s.oauth.GetUser(r), 263 Strings: strings, 264 Card: profile, 265 }) 266} 267 268type FollowsPageParams struct { 269 Follows []pages.FollowCard 270 Card *pages.ProfileCard 271} 272 273func (s *State) followPage( 274 r *http.Request, 275 fetchFollows func(db.Execer, string) ([]models.Follow, error), 276 extractDid func(models.Follow) string, 277) (*FollowsPageParams, error) { 278 l := s.logger.With("handler", "reposPage") 279 280 profile, err := s.profile(r) 281 if err != nil { 282 return nil, err 283 } 284 l = l.With("profileDid", profile.UserDid, "profileHandle", profile.UserHandle) 285 286 loggedInUser := s.oauth.GetUser(r) 287 params := FollowsPageParams{ 288 Card: profile, 289 } 290 291 follows, err := fetchFollows(s.db, profile.UserDid) 292 if err != nil { 293 l.Error("failed to fetch follows", "err", err) 294 return &params, err 295 } 296 297 if len(follows) == 0 { 298 return &params, nil 299 } 300 301 followDids := make([]string, 0, len(follows)) 302 for _, follow := range follows { 303 followDids = append(followDids, extractDid(follow)) 304 } 305 306 profiles, err := db.GetProfiles(s.db, db.FilterIn("did", followDids)) 307 if err != nil { 308 l.Error("failed to get profiles", "followDids", followDids, "err", err) 309 return &params, err 310 } 311 312 followStatsMap, err := db.GetFollowerFollowingCounts(s.db, followDids) 313 if err != nil { 314 log.Printf("getting follow counts for %s: %s", followDids, err) 315 } 316 317 loggedInUserFollowing := make(map[string]struct{}) 318 if loggedInUser != nil { 319 following, err := db.GetFollowing(s.db, loggedInUser.Did) 320 if err != nil { 321 l.Error("failed to get follow list", "err", err, "loggedInUser", loggedInUser.Did) 322 return &params, err 323 } 324 loggedInUserFollowing = make(map[string]struct{}, len(following)) 325 for _, follow := range following { 326 loggedInUserFollowing[follow.SubjectDid] = struct{}{} 327 } 328 } 329 330 followCards := make([]pages.FollowCard, len(follows)) 331 for i, did := range followDids { 332 followStats := followStatsMap[did] 333 followStatus := models.IsNotFollowing 334 if _, exists := loggedInUserFollowing[did]; exists { 335 followStatus = models.IsFollowing 336 } else if loggedInUser != nil && loggedInUser.Did == did { 337 followStatus = models.IsSelf 338 } 339 340 var profile *models.Profile 341 if p, exists := profiles[did]; exists { 342 profile = p 343 } else { 344 profile = &models.Profile{} 345 profile.Did = did 346 } 347 followCards[i] = pages.FollowCard{ 348 UserDid: did, 349 FollowStatus: followStatus, 350 FollowersCount: followStats.Followers, 351 FollowingCount: followStats.Following, 352 Profile: profile, 353 } 354 } 355 356 params.Follows = followCards 357 358 return &params, nil 359} 360 361func (s *State) followersPage(w http.ResponseWriter, r *http.Request) { 362 followPage, err := s.followPage(r, db.GetFollowers, func(f models.Follow) string { return f.UserDid }) 363 if err != nil { 364 s.pages.Notice(w, "all-followers", "Failed to load followers") 365 return 366 } 367 368 s.pages.ProfileFollowers(w, pages.ProfileFollowersParams{ 369 LoggedInUser: s.oauth.GetUser(r), 370 Followers: followPage.Follows, 371 Card: followPage.Card, 372 }) 373} 374 375func (s *State) followingPage(w http.ResponseWriter, r *http.Request) { 376 followPage, err := s.followPage(r, db.GetFollowing, func(f models.Follow) string { return f.SubjectDid }) 377 if err != nil { 378 s.pages.Notice(w, "all-following", "Failed to load following") 379 return 380 } 381 382 s.pages.ProfileFollowing(w, pages.ProfileFollowingParams{ 383 LoggedInUser: s.oauth.GetUser(r), 384 Following: followPage.Follows, 385 Card: followPage.Card, 386 }) 387} 388 389func (s *State) AtomFeedPage(w http.ResponseWriter, r *http.Request) { 390 ident, ok := r.Context().Value("resolvedId").(identity.Identity) 391 if !ok { 392 s.pages.Error404(w) 393 return 394 } 395 396 feed, err := s.getProfileFeed(r.Context(), &ident) 397 if err != nil { 398 s.pages.Error500(w) 399 return 400 } 401 402 if feed == nil { 403 return 404 } 405 406 atom, err := feed.ToAtom() 407 if err != nil { 408 s.pages.Error500(w) 409 return 410 } 411 412 w.Header().Set("content-type", "application/atom+xml") 413 w.Write([]byte(atom)) 414} 415 416func (s *State) getProfileFeed(ctx context.Context, id *identity.Identity) (*feeds.Feed, error) { 417 timeline, err := db.MakeProfileTimeline(s.db, id.DID.String()) 418 if err != nil { 419 return nil, err 420 } 421 422 author := &feeds.Author{ 423 Name: fmt.Sprintf("@%s", id.Handle), 424 } 425 426 feed := feeds.Feed{ 427 Title: fmt.Sprintf("%s's timeline", author.Name), 428 Link: &feeds.Link{Href: fmt.Sprintf("%s/@%s", s.config.Core.AppviewHost, id.Handle), Type: "text/html", Rel: "alternate"}, 429 Items: make([]*feeds.Item, 0), 430 Updated: time.UnixMilli(0), 431 Author: author, 432 } 433 434 for _, byMonth := range timeline.ByMonth { 435 if err := s.addPullRequestItems(ctx, &feed, byMonth.PullEvents.Items, author); err != nil { 436 return nil, err 437 } 438 if err := s.addIssueItems(ctx, &feed, byMonth.IssueEvents.Items, author); err != nil { 439 return nil, err 440 } 441 if err := s.addRepoItems(ctx, &feed, byMonth.RepoEvents, author); err != nil { 442 return nil, err 443 } 444 } 445 446 slices.SortFunc(feed.Items, func(a *feeds.Item, b *feeds.Item) int { 447 return int(b.Created.UnixMilli()) - int(a.Created.UnixMilli()) 448 }) 449 450 if len(feed.Items) > 0 { 451 feed.Updated = feed.Items[0].Created 452 } 453 454 return &feed, nil 455} 456 457func (s *State) addPullRequestItems(ctx context.Context, feed *feeds.Feed, pulls []*models.Pull, author *feeds.Author) error { 458 for _, pull := range pulls { 459 owner, err := s.idResolver.ResolveIdent(ctx, pull.Repo.Did) 460 if err != nil { 461 return err 462 } 463 464 // Add pull request creation item 465 feed.Items = append(feed.Items, s.createPullRequestItem(pull, owner, author)) 466 } 467 return nil 468} 469 470func (s *State) addIssueItems(ctx context.Context, feed *feeds.Feed, issues []*models.Issue, author *feeds.Author) error { 471 for _, issue := range issues { 472 owner, err := s.idResolver.ResolveIdent(ctx, issue.Repo.Did) 473 if err != nil { 474 return err 475 } 476 477 feed.Items = append(feed.Items, s.createIssueItem(issue, owner, author)) 478 } 479 return nil 480} 481 482func (s *State) addRepoItems(ctx context.Context, feed *feeds.Feed, repos []models.RepoEvent, author *feeds.Author) error { 483 for _, repo := range repos { 484 item, err := s.createRepoItem(ctx, repo, author) 485 if err != nil { 486 return err 487 } 488 feed.Items = append(feed.Items, item) 489 } 490 return nil 491} 492 493func (s *State) createPullRequestItem(pull *models.Pull, owner *identity.Identity, author *feeds.Author) *feeds.Item { 494 return &feeds.Item{ 495 Title: fmt.Sprintf("%s created pull request '%s' in @%s/%s", author.Name, pull.Title, owner.Handle, pull.Repo.Name), 496 Link: &feeds.Link{Href: fmt.Sprintf("%s/@%s/%s/pulls/%d", s.config.Core.AppviewHost, owner.Handle, pull.Repo.Name, pull.PullId), Type: "text/html", Rel: "alternate"}, 497 Created: pull.Created, 498 Author: author, 499 } 500} 501 502func (s *State) createIssueItem(issue *models.Issue, owner *identity.Identity, author *feeds.Author) *feeds.Item { 503 return &feeds.Item{ 504 Title: fmt.Sprintf("%s created issue '%s' in @%s/%s", author.Name, issue.Title, owner.Handle, issue.Repo.Name), 505 Link: &feeds.Link{Href: fmt.Sprintf("%s/@%s/%s/issues/%d", s.config.Core.AppviewHost, owner.Handle, issue.Repo.Name, issue.IssueId), Type: "text/html", Rel: "alternate"}, 506 Created: issue.Created, 507 Author: author, 508 } 509} 510 511func (s *State) createRepoItem(ctx context.Context, repo models.RepoEvent, author *feeds.Author) (*feeds.Item, error) { 512 var title string 513 if repo.Source != nil { 514 sourceOwner, err := s.idResolver.ResolveIdent(ctx, repo.Source.Did) 515 if err != nil { 516 return nil, err 517 } 518 title = fmt.Sprintf("%s forked repository @%s/%s to '%s'", author.Name, sourceOwner.Handle, repo.Source.Name, repo.Repo.Name) 519 } else { 520 title = fmt.Sprintf("%s created repository '%s'", author.Name, repo.Repo.Name) 521 } 522 523 return &feeds.Item{ 524 Title: title, 525 Link: &feeds.Link{Href: fmt.Sprintf("%s/@%s/%s", s.config.Core.AppviewHost, author.Name[1:], repo.Repo.Name), Type: "text/html", Rel: "alternate"}, // Remove @ prefix 526 Created: repo.Repo.Created, 527 Author: author, 528 }, nil 529} 530 531func (s *State) UpdateProfileBio(w http.ResponseWriter, r *http.Request) { 532 user := s.oauth.GetUser(r) 533 534 err := r.ParseForm() 535 if err != nil { 536 log.Println("invalid profile update form", err) 537 s.pages.Notice(w, "update-profile", "Invalid form.") 538 return 539 } 540 541 profile, err := db.GetProfile(s.db, user.Did) 542 if err != nil { 543 log.Printf("getting profile data for %s: %s", user.Did, err) 544 } 545 546 profile.Description = r.FormValue("description") 547 profile.IncludeBluesky = r.FormValue("includeBluesky") == "on" 548 profile.Location = r.FormValue("location") 549 550 var links [5]string 551 for i := range 5 { 552 iLink := r.FormValue(fmt.Sprintf("link%d", i)) 553 links[i] = iLink 554 } 555 profile.Links = links 556 557 // Parse stats (exactly 2) 558 stat0 := r.FormValue("stat0") 559 stat1 := r.FormValue("stat1") 560 561 if stat0 != "" { 562 profile.Stats[0].Kind = models.VanityStatKind(stat0) 563 } 564 565 if stat1 != "" { 566 profile.Stats[1].Kind = models.VanityStatKind(stat1) 567 } 568 569 if err := db.ValidateProfile(s.db, profile); err != nil { 570 log.Println("invalid profile", err) 571 s.pages.Notice(w, "update-profile", err.Error()) 572 return 573 } 574 575 s.updateProfile(profile, w, r) 576} 577 578func (s *State) UpdateProfilePins(w http.ResponseWriter, r *http.Request) { 579 user := s.oauth.GetUser(r) 580 581 err := r.ParseForm() 582 if err != nil { 583 log.Println("invalid profile update form", err) 584 s.pages.Notice(w, "update-profile", "Invalid form.") 585 return 586 } 587 588 profile, err := db.GetProfile(s.db, user.Did) 589 if err != nil { 590 log.Printf("getting profile data for %s: %s", user.Did, err) 591 } 592 593 i := 0 594 var pinnedRepos [6]syntax.ATURI 595 for key, values := range r.Form { 596 if i >= 6 { 597 log.Println("invalid pin update form", err) 598 s.pages.Notice(w, "update-profile", "Only 6 repositories can be pinned at a time.") 599 return 600 } 601 if strings.HasPrefix(key, "pinnedRepo") && len(values) > 0 && values[0] != "" && i < 6 { 602 aturi, err := syntax.ParseATURI(values[0]) 603 if err != nil { 604 log.Println("invalid profile update form", err) 605 s.pages.Notice(w, "update-profile", "Invalid form.") 606 return 607 } 608 pinnedRepos[i] = aturi 609 i++ 610 } 611 } 612 profile.PinnedRepos = pinnedRepos 613 614 s.updateProfile(profile, w, r) 615} 616 617func (s *State) updateProfile(profile *models.Profile, w http.ResponseWriter, r *http.Request) { 618 user := s.oauth.GetUser(r) 619 tx, err := s.db.BeginTx(r.Context(), nil) 620 if err != nil { 621 log.Println("failed to start transaction", err) 622 s.pages.Notice(w, "update-profile", "Failed to update profile, try again later.") 623 return 624 } 625 626 client, err := s.oauth.AuthorizedClient(r) 627 if err != nil { 628 log.Println("failed to get authorized client", err) 629 s.pages.Notice(w, "update-profile", "Failed to update profile, try again later.") 630 return 631 } 632 633 // yeah... lexgen dose not support syntax.ATURI in the record for some reason, 634 // nor does it support exact size arrays 635 var pinnedRepoStrings []string 636 for _, r := range profile.PinnedRepos { 637 pinnedRepoStrings = append(pinnedRepoStrings, r.String()) 638 } 639 640 var vanityStats []string 641 for _, v := range profile.Stats { 642 vanityStats = append(vanityStats, string(v.Kind)) 643 } 644 645 ex, _ := client.RepoGetRecord(r.Context(), "", tangled.ActorProfileNSID, user.Did, "self") 646 var cid *string 647 if ex != nil { 648 cid = ex.Cid 649 } 650 651 _, err = client.RepoPutRecord(r.Context(), &comatproto.RepoPutRecord_Input{ 652 Collection: tangled.ActorProfileNSID, 653 Repo: user.Did, 654 Rkey: "self", 655 Record: &lexutil.LexiconTypeDecoder{ 656 Val: &tangled.ActorProfile{ 657 Bluesky: profile.IncludeBluesky, 658 Description: &profile.Description, 659 Links: profile.Links[:], 660 Location: &profile.Location, 661 PinnedRepositories: pinnedRepoStrings, 662 Stats: vanityStats[:], 663 }}, 664 SwapRecord: cid, 665 }) 666 if err != nil { 667 log.Println("failed to update profile", err) 668 s.pages.Notice(w, "update-profile", "Failed to update PDS, try again later.") 669 return 670 } 671 672 err = db.UpsertProfile(tx, profile) 673 if err != nil { 674 log.Println("failed to update profile", err) 675 s.pages.Notice(w, "update-profile", "Failed to update profile, try again later.") 676 return 677 } 678 679 s.notifier.UpdateProfile(r.Context(), profile) 680 681 s.pages.HxRedirect(w, "/"+user.Did) 682} 683 684func (s *State) EditBioFragment(w http.ResponseWriter, r *http.Request) { 685 user := s.oauth.GetUser(r) 686 687 profile, err := db.GetProfile(s.db, user.Did) 688 if err != nil { 689 log.Printf("getting profile data for %s: %s", user.Did, err) 690 } 691 692 s.pages.EditBioFragment(w, pages.EditBioParams{ 693 LoggedInUser: user, 694 Profile: profile, 695 }) 696} 697 698func (s *State) EditPinsFragment(w http.ResponseWriter, r *http.Request) { 699 user := s.oauth.GetUser(r) 700 701 profile, err := db.GetProfile(s.db, user.Did) 702 if err != nil { 703 log.Printf("getting profile data for %s: %s", user.Did, err) 704 } 705 706 repos, err := db.GetRepos(s.db, 0, db.FilterEq("did", user.Did)) 707 if err != nil { 708 log.Printf("getting repos for %s: %s", user.Did, err) 709 } 710 711 collaboratingRepos, err := db.CollaboratingIn(s.db, user.Did) 712 if err != nil { 713 log.Printf("getting collaborating repos for %s: %s", user.Did, err) 714 } 715 716 allRepos := []pages.PinnedRepo{} 717 718 for _, r := range repos { 719 isPinned := slices.Contains(profile.PinnedRepos[:], r.RepoAt()) 720 allRepos = append(allRepos, pages.PinnedRepo{ 721 IsPinned: isPinned, 722 Repo: r, 723 }) 724 } 725 for _, r := range collaboratingRepos { 726 isPinned := slices.Contains(profile.PinnedRepos[:], r.RepoAt()) 727 allRepos = append(allRepos, pages.PinnedRepo{ 728 IsPinned: isPinned, 729 Repo: r, 730 }) 731 } 732 733 s.pages.EditPinsFragment(w, pages.EditPinsParams{ 734 LoggedInUser: user, 735 Profile: profile, 736 AllRepos: allRepos, 737 }) 738}