···
···
PendingProfileUpdate string = "pending_profile_update"
33
-
func parseProfileForm(r *http.Request) (db.Profile, error) {
33
+
func parseProfileForm(r *http.Request, logger *slog.Logger) (db.Profile, error) {
return db.Profile{}, fmt.Errorf("invalid profile form: %w", err)
···
for _, code := range languageCodes {
language, ok := db.Languages[db.LanguageCode(code)]
48
-
log.Printf("invalid language code submitted: %s", code)
48
+
logger.Warn("invalid language code submitted", "languageCode", code)
languages = append(languages, language)
···
func (h *Handler) HandleProfilePage(w http.ResponseWriter, r *http.Request) {
65
+
l := h.Logger.With("handler", "HandleProfilePage")
didOrHandle := chi.URLParam(r, "user")
http.Error(w, "Bad request", http.StatusBadRequest)
···
totalStudyTime, err = db.GetTotalStudyTime(h.Db, profileDid)
105
-
log.Println("failed to get total study time:", err)
107
+
l.Error("failed to get total study time", "err", err)
totalStudySessions, _ = db.GetTotalStudySessions(h.Db, profileDid)
110
-
log.Println("failed to get total study study sessions:", err)
112
+
l.Error("failed to get total study study sessions", "err", err)
followers, following, _ = db.GetFollowerFollowingCount(h.Db, profileDid)
115
-
log.Println("failed to get follow stats:", err)
117
+
l.Error("failed to get follow stats", "err", err)
streak, _ = db.GetCurrentStreak(h.Db, profileDid)
120
-
log.Println("failed to get streak:", err)
122
+
l.Error("failed to get streak", "err", err)
···
if err := g.Wait(); err != nil {
131
-
log.Printf("failed to fetch critical profile data for %s: %v", profileDid, err)
133
+
l.Error("failed to fetch critical profile data for", "did", profileDid, "err", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to fetch profile data, try again later.")
···
err := h.Posthog.Enqueue(capture)
163
-
log.Println("failed to enqueue posthog event:", err)
165
+
l.Error("failed to enqueue posthog event", "err", err)
···
func (h *Handler) HandleEditProfilePage(w http.ResponseWriter, r *http.Request) {
183
+
l := h.Logger.With("handler", "HandleEditProfilePage")
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
183
-
log.Println("failed to get logged-in user:", err)
187
+
l.Error("failed to get logged-in user", "err", err)
htmx.HxRedirect(w, "/login")
profile, err := h.GetUserProfileWithAvatar(user.Did)
190
-
log.Printf("failed to find %s in db: %s", user.Did, err)
194
+
l.Error("failed to find user in db", "did", user.Did, "err", err)
w.WriteHeader(http.StatusNotFound)
views.NotFoundPage(views.NotFoundPageParams{}).Render(r.Context(), w)
if user.Did != profile.Did {
197
-
log.Printf("user '%s' does not own record '%s'", user.Did, profile.Did)
201
+
l.Error("user does not own record", "did", user.Did, "profileDid", profile.Did)
htmx.HxError(w, http.StatusUnauthorized, "You do not have permissions to edit this profile.")
···
client, err := h.Oauth.AuthorizedClient(r)
217
-
log.Println("failed to get authorized client:", err)
221
+
l.Error("failed to get authorized client", "err", err)
htmx.HxRedirect(w, "/login")
222
-
updatedProfile, err := parseProfileForm(r)
226
+
updatedProfile, err := parseProfileForm(r, l)
224
-
log.Println("invalid profile form:", err)
228
+
l.Error("invalid profile form", "err", err)
htmx.HxError(w, http.StatusBadRequest, "Failed to update profile, ensure all fields contain valid data.")
···
if err := db.ValidateProfile(updatedProfile); err != nil {
239
-
log.Println("invalid profile:", err)
243
+
l.Error("invalid profile", "err", err)
case errors.Is(err, db.ErrProfileNameTooLong):
htmx.HxError(w, http.StatusBadRequest, "Profile name cannot be more than 64 characters.")
···
283
-
log.Println("failed to put profile record:", err)
287
+
l.Error("failed to put profile record", "err", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to update PDS, try again later.")
err = SavePendingUpdate(h, w, r, PendingProfileUpdate, profile)
290
-
log.Printf("failed to save yoten-session to add pending profile update: %v", err)
294
+
l.Error("failed to save yoten-session to add pending profile update", "err", err)
···
311
-
log.Println("failed to enqueue posthog identify event:", err)
315
+
l.Error("failed to enqueue posthog identify event", "err", err)
err = h.Posthog.Enqueue(posthog.Capture{
···
Event: ph.ProfileRecordEditedEvent,
319
-
log.Println("failed to enqueue posthog event:", err)
323
+
l.Error("failed to enqueue posthog event", "err", err)
···
func (h *Handler) HandleResourcesPage(w http.ResponseWriter, r *http.Request) {
332
+
l := h.Logger.With("handler", "HandleResourcesPage")
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
330
-
log.Println("failed to get logged-in user:", err)
336
+
l.Error("failed to get logged-in user", "err", err)
htmx.HxRedirect(w, "/login")
resources, err := db.GetResourcesByDid(h.Db, user.Did)
337
-
log.Println("failed to get resources:", err)
343
+
l.Error("failed to get resources", "err", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to retrieve profile resources, try again later.")
resources, err = ApplyPendingChanges(h, w, r, resources, PendingResourceCreation, PendingResourceUpdates, PendingResourceDeletion)
344
-
log.Printf("failed to save yoten-session after processing pending changes: %v", err)
350
+
l.Error("failed to save yoten-session after processing pending changes", "err", err)
activeResources := utils.Filter(resources, func(resource db.Resource) bool {
···
func (h *Handler) HandleActivitiesPage(w http.ResponseWriter, r *http.Request) {
364
+
l := h.Logger.With("handler", "HandleActivitiesPage")
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
360
-
log.Println("failed to get logged-in user:", err)
368
+
l.Error("failed to get logged-in user", "err", err)
htmx.HxRedirect(w, "/login")
activities, err := db.GetActivitiesByDid(h.Db, user.Did)
367
-
log.Println("failed to get activities:", err)
375
+
l.Error("failed to get activities", "err", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to retrieve profile activities, try again later.")
activities, err = ApplyPendingChanges(h, w, r, activities, PendingActivityCreation, PendingActivityUpdates, PendingActivityDeletion)
374
-
log.Printf("failed to save yoten-session after processing pending changes: %v", err)
382
+
l.Error("failed to save yoten-session after processing pending changes", "err", err)
activeActivities := utils.Filter(activities, func(activity db.Activity) bool {
···
func (h *Handler) HandleProfileFeed(w http.ResponseWriter, r *http.Request) {
411
+
l := h.Logger.With("handler", "HandleProfileFeed")
didOrHandle := chi.URLParam(r, "user")
http.Error(w, "Bad request", http.StatusBadRequest)
···
profile, err := h.GetUserProfileWithAvatar(ident.DID.String())
418
-
log.Printf("failed to find %s in db: %s", ident.DID.String(), err)
428
+
l.Error("failed to find user in db", "did", ident.DID.String(), "err", err)
w.WriteHeader(http.StatusNotFound)
views.NotFoundPage(views.NotFoundPageParams{}).Render(r.Context(), w)
···
bskyProfile, err := bsky.GetBskyProfile(ident.DID.String())
426
-
log.Println("failed to get bsky profile:", err)
436
+
l.Error("failed to get bsky profile", "err", err)
w.WriteHeader(http.StatusNotFound)
views.NotFoundPage(views.NotFoundPageParams{}).Render(r.Context(), w)
···
page, err := strconv.ParseInt(pageStr, 10, 64)
438
-
log.Println("failed to parse page value:", err)
448
+
l.Error("failed to parse page value", "err", err)
···
sessions, err := db.GetStudySessionLogs(h.Db, ident.DID.String(), pageSize+1, int(offset))
450
-
log.Println("failed to get study sessions:", err)
460
+
l.Error("failed to get study sessions", "err", err)
w.WriteHeader(http.StatusNotFound)
views.NotFoundPage(views.NotFoundPageParams{}).Render(r.Context(), w)
···
sessions, err = ApplyPendingChanges(h, w, r, sessions, PendingStudySessionCreation, PendingStudySessionUpdates, PendingStudySessionDeletion)
458
-
log.Printf("failed to save yoten-session after processing pending changes: %v", err)
468
+
l.Error("failed to save yoten-session after processing pending changes", "err", err)
feed := []*db.StudySessionFeedItem{}
···
func (h *Handler) HandleFriendsPage(w http.ResponseWriter, r *http.Request) {
506
+
l := h.Logger.With("handler", "HandleFriendsPage")
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
498
-
log.Println("failed to get logged-in user:", err)
510
+
l.Error("failed to get logged-in user", "err", err)
htmx.HxRedirect(w, "/login")
followers, following, err := db.GetFollowerFollowingCount(h.Db, user.Did)
505
-
log.Printf("getting follow stats repos for %s: %s", user.Did, err)
517
+
l.Error("failed to get follow stats", "err", err)
views.FriendsPage(views.FriendsPageParams{
···
func (h *Handler) HandleFriendsFeed(w http.ResponseWriter, r *http.Request) {
528
+
l := h.Logger.With("handler", "HandleFriendsFeed")
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
518
-
log.Println("failed to get logged-in user")
532
+
l.Error("failed to get logged-in user")
htmx.HxRedirect(w, "/login")
···
page, err := strconv.ParseInt(pageStr, 10, 64)
532
-
log.Println("failed to parse page value:", err)
546
+
l.Error("failed to parse page value", "err", err)
···
if mode == partials.Following {
feed, err := db.GetFollowing(h.Db, user.Did, pageSize+1, int(offset))
548
-
log.Println("failed to get following list:", err)
562
+
l.Error("failed to get following list", "err", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to get following list, try again later.")
bskyHydratedFeed, err = h.GetHydratedFollowerProfiles(feed)
554
-
log.Println("failed to hydrate bsky profiles:", err)
568
+
l.Error("failed to hydrate bsky profiles", "err", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to get following list, try again later.")
feed, err := db.GetFollowers(h.Db, user.Did, pageSize+1, int(offset))
561
-
log.Println("failed to get followers list:", err)
575
+
l.Error("failed to get followers list", "err", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to get followers list, try again later.")
bskyHydratedFeed, err = h.GetHydratedFollowerProfiles(feed)
567
-
log.Println("failed to hydrate bsky profiles:", err)
581
+
l.Error("failed to hydrate bsky profiles", "err", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to get following list, try again later.")
···
func (h *Handler) HandleNotificationsPage(w http.ResponseWriter, r *http.Request) {
603
+
l := h.Logger.With("handler", "HandleNotificationsPage")
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
591
-
log.Println("failed to get logged-in user:", err)
607
+
l.Error("failed to get logged-in user", "err", err)
htmx.HxRedirect(w, "/login")
brookjeynes.dev