forked from tangled.org/core
this repo has no description
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.sh/tangled.sh/core/api/tangled" 19 "tangled.sh/tangled.sh/core/appview/db" 20 // "tangled.sh/tangled.sh/core/appview/oauth" 21 "tangled.sh/tangled.sh/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 := db.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 := []db.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 := []db.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) ([]db.Follow, error), 276 extractDid func(db.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 288 follows, err := fetchFollows(s.db, profile.UserDid) 289 if err != nil { 290 l.Error("failed to fetch follows", "err", err) 291 return nil, err 292 } 293 294 if len(follows) == 0 { 295 return nil, nil 296 } 297 298 followDids := make([]string, 0, len(follows)) 299 for _, follow := range follows { 300 followDids = append(followDids, extractDid(follow)) 301 } 302 303 profiles, err := db.GetProfiles(s.db, db.FilterIn("did", followDids)) 304 if err != nil { 305 l.Error("failed to get profiles", "followDids", followDids, "err", err) 306 return nil, err 307 } 308 309 followStatsMap, err := db.GetFollowerFollowingCounts(s.db, followDids) 310 if err != nil { 311 log.Printf("getting follow counts for %s: %s", followDids, err) 312 } 313 314 loggedInUserFollowing := make(map[string]struct{}) 315 if loggedInUser != nil { 316 following, err := db.GetFollowing(s.db, loggedInUser.Did) 317 if err != nil { 318 l.Error("failed to get follow list", "err", err, "loggedInUser", loggedInUser.Did) 319 return nil, err 320 } 321 loggedInUserFollowing = make(map[string]struct{}, len(following)) 322 for _, follow := range following { 323 loggedInUserFollowing[follow.SubjectDid] = struct{}{} 324 } 325 } 326 327 followCards := make([]pages.FollowCard, len(follows)) 328 for i, did := range followDids { 329 followStats := followStatsMap[did] 330 followStatus := db.IsNotFollowing 331 if _, exists := loggedInUserFollowing[did]; exists { 332 followStatus = db.IsFollowing 333 } else if loggedInUser != nil && loggedInUser.Did == did { 334 followStatus = db.IsSelf 335 } 336 337 var profile *db.Profile 338 if p, exists := profiles[did]; exists { 339 profile = p 340 } else { 341 profile = &db.Profile{} 342 profile.Did = did 343 } 344 followCards[i] = pages.FollowCard{ 345 UserDid: did, 346 FollowStatus: followStatus, 347 FollowersCount: followStats.Followers, 348 FollowingCount: followStats.Following, 349 Profile: profile, 350 } 351 } 352 353 return &FollowsPageParams{ 354 Follows: followCards, 355 Card: profile, 356 }, nil 357} 358 359func (s *State) followersPage(w http.ResponseWriter, r *http.Request) { 360 followPage, err := s.followPage(r, db.GetFollowers, func(f db.Follow) string { return f.UserDid }) 361 if err != nil { 362 s.pages.Notice(w, "all-followers", "Failed to load followers") 363 return 364 } 365 366 s.pages.ProfileFollowers(w, pages.ProfileFollowersParams{ 367 LoggedInUser: s.oauth.GetUser(r), 368 Followers: followPage.Follows, 369 Card: followPage.Card, 370 }) 371} 372 373func (s *State) followingPage(w http.ResponseWriter, r *http.Request) { 374 followPage, err := s.followPage(r, db.GetFollowing, func(f db.Follow) string { return f.SubjectDid }) 375 if err != nil { 376 s.pages.Notice(w, "all-following", "Failed to load following") 377 return 378 } 379 380 s.pages.ProfileFollowing(w, pages.ProfileFollowingParams{ 381 LoggedInUser: s.oauth.GetUser(r), 382 Following: followPage.Follows, 383 Card: followPage.Card, 384 }) 385} 386 387func (s *State) AtomFeedPage(w http.ResponseWriter, r *http.Request) { 388 ident, ok := r.Context().Value("resolvedId").(identity.Identity) 389 if !ok { 390 s.pages.Error404(w) 391 return 392 } 393 394 feed, err := s.getProfileFeed(r.Context(), &ident) 395 if err != nil { 396 s.pages.Error500(w) 397 return 398 } 399 400 if feed == nil { 401 return 402 } 403 404 atom, err := feed.ToAtom() 405 if err != nil { 406 s.pages.Error500(w) 407 return 408 } 409 410 w.Header().Set("content-type", "application/atom+xml") 411 w.Write([]byte(atom)) 412} 413 414func (s *State) getProfileFeed(ctx context.Context, id *identity.Identity) (*feeds.Feed, error) { 415 timeline, err := db.MakeProfileTimeline(s.db, id.DID.String()) 416 if err != nil { 417 return nil, err 418 } 419 420 author := &feeds.Author{ 421 Name: fmt.Sprintf("@%s", id.Handle), 422 } 423 424 feed := feeds.Feed{ 425 Title: fmt.Sprintf("%s's timeline", author.Name), 426 Link: &feeds.Link{Href: fmt.Sprintf("%s/@%s", s.config.Core.AppviewHost, id.Handle), Type: "text/html", Rel: "alternate"}, 427 Items: make([]*feeds.Item, 0), 428 Updated: time.UnixMilli(0), 429 Author: author, 430 } 431 432 for _, byMonth := range timeline.ByMonth { 433 if err := s.addPullRequestItems(ctx, &feed, byMonth.PullEvents.Items, author); err != nil { 434 return nil, err 435 } 436 if err := s.addIssueItems(ctx, &feed, byMonth.IssueEvents.Items, author); err != nil { 437 return nil, err 438 } 439 if err := s.addRepoItems(ctx, &feed, byMonth.RepoEvents, author); err != nil { 440 return nil, err 441 } 442 } 443 444 slices.SortFunc(feed.Items, func(a *feeds.Item, b *feeds.Item) int { 445 return int(b.Created.UnixMilli()) - int(a.Created.UnixMilli()) 446 }) 447 448 if len(feed.Items) > 0 { 449 feed.Updated = feed.Items[0].Created 450 } 451 452 return &feed, nil 453} 454 455func (s *State) addPullRequestItems(ctx context.Context, feed *feeds.Feed, pulls []*db.Pull, author *feeds.Author) error { 456 for _, pull := range pulls { 457 owner, err := s.idResolver.ResolveIdent(ctx, pull.Repo.Did) 458 if err != nil { 459 return err 460 } 461 462 // Add pull request creation item 463 feed.Items = append(feed.Items, s.createPullRequestItem(pull, owner, author)) 464 } 465 return nil 466} 467 468func (s *State) addIssueItems(ctx context.Context, feed *feeds.Feed, issues []*db.Issue, author *feeds.Author) error { 469 for _, issue := range issues { 470 owner, err := s.idResolver.ResolveIdent(ctx, issue.Repo.Did) 471 if err != nil { 472 return err 473 } 474 475 feed.Items = append(feed.Items, s.createIssueItem(issue, owner, author)) 476 } 477 return nil 478} 479 480func (s *State) addRepoItems(ctx context.Context, feed *feeds.Feed, repos []db.RepoEvent, author *feeds.Author) error { 481 for _, repo := range repos { 482 item, err := s.createRepoItem(ctx, repo, author) 483 if err != nil { 484 return err 485 } 486 feed.Items = append(feed.Items, item) 487 } 488 return nil 489} 490 491func (s *State) createPullRequestItem(pull *db.Pull, owner *identity.Identity, author *feeds.Author) *feeds.Item { 492 return &feeds.Item{ 493 Title: fmt.Sprintf("%s created pull request '%s' in @%s/%s", author.Name, pull.Title, owner.Handle, pull.Repo.Name), 494 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"}, 495 Created: pull.Created, 496 Author: author, 497 } 498} 499 500func (s *State) createIssueItem(issue *db.Issue, owner *identity.Identity, author *feeds.Author) *feeds.Item { 501 return &feeds.Item{ 502 Title: fmt.Sprintf("%s created issue '%s' in @%s/%s", author.Name, issue.Title, owner.Handle, issue.Repo.Name), 503 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"}, 504 Created: issue.Created, 505 Author: author, 506 } 507} 508 509func (s *State) createRepoItem(ctx context.Context, repo db.RepoEvent, author *feeds.Author) (*feeds.Item, error) { 510 var title string 511 if repo.Source != nil { 512 sourceOwner, err := s.idResolver.ResolveIdent(ctx, repo.Source.Did) 513 if err != nil { 514 return nil, err 515 } 516 title = fmt.Sprintf("%s forked repository @%s/%s to '%s'", author.Name, sourceOwner.Handle, repo.Source.Name, repo.Repo.Name) 517 } else { 518 title = fmt.Sprintf("%s created repository '%s'", author.Name, repo.Repo.Name) 519 } 520 521 return &feeds.Item{ 522 Title: title, 523 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 524 Created: repo.Repo.Created, 525 Author: author, 526 }, nil 527} 528 529func (s *State) UpdateProfileBio(w http.ResponseWriter, r *http.Request) { 530 user := s.oauth.GetUser(r) 531 532 err := r.ParseForm() 533 if err != nil { 534 log.Println("invalid profile update form", err) 535 s.pages.Notice(w, "update-profile", "Invalid form.") 536 return 537 } 538 539 profile, err := db.GetProfile(s.db, user.Did) 540 if err != nil { 541 log.Printf("getting profile data for %s: %s", user.Did, err) 542 } 543 544 profile.Description = r.FormValue("description") 545 profile.IncludeBluesky = r.FormValue("includeBluesky") == "on" 546 profile.Location = r.FormValue("location") 547 548 var links [5]string 549 for i := range 5 { 550 iLink := r.FormValue(fmt.Sprintf("link%d", i)) 551 links[i] = iLink 552 } 553 profile.Links = links 554 555 // Parse stats (exactly 2) 556 stat0 := r.FormValue("stat0") 557 stat1 := r.FormValue("stat1") 558 559 if stat0 != "" { 560 profile.Stats[0].Kind = db.VanityStatKind(stat0) 561 } 562 563 if stat1 != "" { 564 profile.Stats[1].Kind = db.VanityStatKind(stat1) 565 } 566 567 if err := db.ValidateProfile(s.db, profile); err != nil { 568 log.Println("invalid profile", err) 569 s.pages.Notice(w, "update-profile", err.Error()) 570 return 571 } 572 573 s.updateProfile(profile, w, r) 574} 575 576func (s *State) UpdateProfilePins(w http.ResponseWriter, r *http.Request) { 577 user := s.oauth.GetUser(r) 578 579 err := r.ParseForm() 580 if err != nil { 581 log.Println("invalid profile update form", err) 582 s.pages.Notice(w, "update-profile", "Invalid form.") 583 return 584 } 585 586 profile, err := db.GetProfile(s.db, user.Did) 587 if err != nil { 588 log.Printf("getting profile data for %s: %s", user.Did, err) 589 } 590 591 i := 0 592 var pinnedRepos [6]syntax.ATURI 593 for key, values := range r.Form { 594 if i >= 6 { 595 log.Println("invalid pin update form", err) 596 s.pages.Notice(w, "update-profile", "Only 6 repositories can be pinned at a time.") 597 return 598 } 599 if strings.HasPrefix(key, "pinnedRepo") && len(values) > 0 && values[0] != "" && i < 6 { 600 aturi, err := syntax.ParseATURI(values[0]) 601 if err != nil { 602 log.Println("invalid profile update form", err) 603 s.pages.Notice(w, "update-profile", "Invalid form.") 604 return 605 } 606 pinnedRepos[i] = aturi 607 i++ 608 } 609 } 610 profile.PinnedRepos = pinnedRepos 611 612 s.updateProfile(profile, w, r) 613} 614 615func (s *State) updateProfile(profile *db.Profile, w http.ResponseWriter, r *http.Request) { 616 user := s.oauth.GetUser(r) 617 tx, err := s.db.BeginTx(r.Context(), nil) 618 if err != nil { 619 log.Println("failed to start transaction", err) 620 s.pages.Notice(w, "update-profile", "Failed to update profile, try again later.") 621 return 622 } 623 624 client, err := s.oauth.AuthorizedClient(r) 625 if err != nil { 626 log.Println("failed to get authorized client", err) 627 s.pages.Notice(w, "update-profile", "Failed to update profile, try again later.") 628 return 629 } 630 631 // yeah... lexgen dose not support syntax.ATURI in the record for some reason, 632 // nor does it support exact size arrays 633 var pinnedRepoStrings []string 634 for _, r := range profile.PinnedRepos { 635 pinnedRepoStrings = append(pinnedRepoStrings, r.String()) 636 } 637 638 var vanityStats []string 639 for _, v := range profile.Stats { 640 vanityStats = append(vanityStats, string(v.Kind)) 641 } 642 643 ex, _ := client.RepoGetRecord(r.Context(), "", tangled.ActorProfileNSID, user.Did, "self") 644 var cid *string 645 if ex != nil { 646 cid = ex.Cid 647 } 648 649 _, err = client.RepoPutRecord(r.Context(), &comatproto.RepoPutRecord_Input{ 650 Collection: tangled.ActorProfileNSID, 651 Repo: user.Did, 652 Rkey: "self", 653 Record: &lexutil.LexiconTypeDecoder{ 654 Val: &tangled.ActorProfile{ 655 Bluesky: profile.IncludeBluesky, 656 Description: &profile.Description, 657 Links: profile.Links[:], 658 Location: &profile.Location, 659 PinnedRepositories: pinnedRepoStrings, 660 Stats: vanityStats[:], 661 }}, 662 SwapRecord: cid, 663 }) 664 if err != nil { 665 log.Println("failed to update profile", err) 666 s.pages.Notice(w, "update-profile", "Failed to update PDS, try again later.") 667 return 668 } 669 670 err = db.UpsertProfile(tx, profile) 671 if err != nil { 672 log.Println("failed to update profile", err) 673 s.pages.Notice(w, "update-profile", "Failed to update profile, try again later.") 674 return 675 } 676 677 s.notifier.UpdateProfile(r.Context(), profile) 678 679 s.pages.HxRedirect(w, "/"+user.Did) 680} 681 682func (s *State) EditBioFragment(w http.ResponseWriter, r *http.Request) { 683 user := s.oauth.GetUser(r) 684 685 profile, err := db.GetProfile(s.db, user.Did) 686 if err != nil { 687 log.Printf("getting profile data for %s: %s", user.Did, err) 688 } 689 690 s.pages.EditBioFragment(w, pages.EditBioParams{ 691 LoggedInUser: user, 692 Profile: profile, 693 }) 694} 695 696func (s *State) EditPinsFragment(w http.ResponseWriter, r *http.Request) { 697 user := s.oauth.GetUser(r) 698 699 profile, err := db.GetProfile(s.db, user.Did) 700 if err != nil { 701 log.Printf("getting profile data for %s: %s", user.Did, err) 702 } 703 704 repos, err := db.GetRepos(s.db, 0, db.FilterEq("did", user.Did)) 705 if err != nil { 706 log.Printf("getting repos for %s: %s", user.Did, err) 707 } 708 709 collaboratingRepos, err := db.CollaboratingIn(s.db, user.Did) 710 if err != nil { 711 log.Printf("getting collaborating repos for %s: %s", user.Did, err) 712 } 713 714 allRepos := []pages.PinnedRepo{} 715 716 for _, r := range repos { 717 isPinned := slices.Contains(profile.PinnedRepos[:], r.RepoAt()) 718 allRepos = append(allRepos, pages.PinnedRepo{ 719 IsPinned: isPinned, 720 Repo: r, 721 }) 722 } 723 for _, r := range collaboratingRepos { 724 isPinned := slices.Contains(profile.PinnedRepos[:], r.RepoAt()) 725 allRepos = append(allRepos, pages.PinnedRepo{ 726 IsPinned: isPinned, 727 Repo: r, 728 }) 729 } 730 731 s.pages.EditPinsFragment(w, pages.EditPinsParams{ 732 LoggedInUser: user, 733 Profile: profile, 734 AllRepos: allRepos, 735 }) 736}