···
···
PendingProfileUpdate string = "pending_profile_update"
-
func parseProfileForm(r *http.Request) (db.Profile, error) {
return db.Profile{}, fmt.Errorf("invalid profile form: %w", err)
···
for _, code := range languageCodes {
language, ok := db.Languages[db.LanguageCode(code)]
-
log.Printf("invalid language code submitted: %s", code)
languages = append(languages, language)
···
func (h *Handler) HandleProfilePage(w http.ResponseWriter, r *http.Request) {
didOrHandle := chi.URLParam(r, "user")
http.Error(w, "Bad request", http.StatusBadRequest)
···
totalStudyTime, err = db.GetTotalStudyTime(h.Db, profileDid)
-
log.Println("failed to get total study time:", err)
totalStudySessions, _ = db.GetTotalStudySessions(h.Db, profileDid)
-
log.Println("failed to get total study study sessions:", err)
followers, following, _ = db.GetFollowerFollowingCount(h.Db, profileDid)
-
log.Println("failed to get follow stats:", err)
streak, _ = db.GetCurrentStreak(h.Db, profileDid)
-
log.Println("failed to get streak:", err)
···
if err := g.Wait(); err != nil {
-
log.Printf("failed to fetch critical profile data for %s: %v", profileDid, err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to fetch profile data, try again later.")
···
err := h.Posthog.Enqueue(capture)
-
log.Println("failed to enqueue posthog event:", err)
···
func (h *Handler) HandleEditProfilePage(w http.ResponseWriter, r *http.Request) {
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
-
log.Println("failed to get logged-in user:", err)
htmx.HxRedirect(w, "/login")
profile, err := h.GetUserProfileWithAvatar(user.Did)
-
log.Printf("failed to find %s in db: %s", user.Did, err)
w.WriteHeader(http.StatusNotFound)
views.NotFoundPage(views.NotFoundPageParams{}).Render(r.Context(), w)
if user.Did != profile.Did {
-
log.Printf("user '%s' does not own record '%s'", user.Did, profile.Did)
htmx.HxError(w, http.StatusUnauthorized, "You do not have permissions to edit this profile.")
···
client, err := h.Oauth.AuthorizedClient(r)
-
log.Println("failed to get authorized client:", err)
htmx.HxRedirect(w, "/login")
-
updatedProfile, err := parseProfileForm(r)
-
log.Println("invalid profile form:", err)
htmx.HxError(w, http.StatusBadRequest, "Failed to update profile, ensure all fields contain valid data.")
···
if err := db.ValidateProfile(updatedProfile); err != nil {
-
log.Println("invalid profile:", err)
case errors.Is(err, db.ErrProfileNameTooLong):
htmx.HxError(w, http.StatusBadRequest, "Profile name cannot be more than 64 characters.")
···
-
log.Println("failed to put profile record:", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to update PDS, try again later.")
err = SavePendingUpdate(h, w, r, PendingProfileUpdate, profile)
-
log.Printf("failed to save yoten-session to add pending profile update: %v", err)
···
-
log.Println("failed to enqueue posthog identify event:", err)
err = h.Posthog.Enqueue(posthog.Capture{
···
Event: ph.ProfileRecordEditedEvent,
-
log.Println("failed to enqueue posthog event:", err)
···
func (h *Handler) HandleResourcesPage(w http.ResponseWriter, r *http.Request) {
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
-
log.Println("failed to get logged-in user:", err)
htmx.HxRedirect(w, "/login")
resources, err := db.GetResourcesByDid(h.Db, user.Did)
-
log.Println("failed to get resources:", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to retrieve profile resources, try again later.")
resources, err = ApplyPendingChanges(h, w, r, resources, PendingResourceCreation, PendingResourceUpdates, PendingResourceDeletion)
-
log.Printf("failed to save yoten-session after processing pending changes: %v", err)
activeResources := utils.Filter(resources, func(resource db.Resource) bool {
···
func (h *Handler) HandleActivitiesPage(w http.ResponseWriter, r *http.Request) {
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
-
log.Println("failed to get logged-in user:", err)
htmx.HxRedirect(w, "/login")
activities, err := db.GetActivitiesByDid(h.Db, user.Did)
-
log.Println("failed to get activities:", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to retrieve profile activities, try again later.")
activities, err = ApplyPendingChanges(h, w, r, activities, PendingActivityCreation, PendingActivityUpdates, PendingActivityDeletion)
-
log.Printf("failed to save yoten-session after processing pending changes: %v", err)
activeActivities := utils.Filter(activities, func(activity db.Activity) bool {
···
func (h *Handler) HandleProfileFeed(w http.ResponseWriter, r *http.Request) {
didOrHandle := chi.URLParam(r, "user")
http.Error(w, "Bad request", http.StatusBadRequest)
···
profile, err := h.GetUserProfileWithAvatar(ident.DID.String())
-
log.Printf("failed to find %s in db: %s", ident.DID.String(), err)
w.WriteHeader(http.StatusNotFound)
views.NotFoundPage(views.NotFoundPageParams{}).Render(r.Context(), w)
···
bskyProfile, err := bsky.GetBskyProfile(ident.DID.String())
-
log.Println("failed to get bsky profile:", err)
w.WriteHeader(http.StatusNotFound)
views.NotFoundPage(views.NotFoundPageParams{}).Render(r.Context(), w)
···
page, err := strconv.ParseInt(pageStr, 10, 64)
-
log.Println("failed to parse page value:", err)
···
sessions, err := db.GetStudySessionLogs(h.Db, ident.DID.String(), pageSize+1, int(offset))
-
log.Println("failed to get study sessions:", err)
w.WriteHeader(http.StatusNotFound)
views.NotFoundPage(views.NotFoundPageParams{}).Render(r.Context(), w)
···
sessions, err = ApplyPendingChanges(h, w, r, sessions, PendingStudySessionCreation, PendingStudySessionUpdates, PendingStudySessionDeletion)
-
log.Printf("failed to save yoten-session after processing pending changes: %v", err)
feed := []*db.StudySessionFeedItem{}
···
func (h *Handler) HandleFriendsPage(w http.ResponseWriter, r *http.Request) {
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
-
log.Println("failed to get logged-in user:", err)
htmx.HxRedirect(w, "/login")
followers, following, err := db.GetFollowerFollowingCount(h.Db, user.Did)
-
log.Printf("getting follow stats repos for %s: %s", user.Did, err)
views.FriendsPage(views.FriendsPageParams{
···
func (h *Handler) HandleFriendsFeed(w http.ResponseWriter, r *http.Request) {
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
-
log.Println("failed to get logged-in user")
htmx.HxRedirect(w, "/login")
···
page, err := strconv.ParseInt(pageStr, 10, 64)
-
log.Println("failed to parse page value:", err)
···
if mode == partials.Following {
feed, err := db.GetFollowing(h.Db, user.Did, pageSize+1, int(offset))
-
log.Println("failed to get following list:", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to get following list, try again later.")
bskyHydratedFeed, err = h.GetHydratedFollowerProfiles(feed)
-
log.Println("failed to hydrate bsky profiles:", 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))
-
log.Println("failed to get followers list:", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to get followers list, try again later.")
bskyHydratedFeed, err = h.GetHydratedFollowerProfiles(feed)
-
log.Println("failed to hydrate bsky profiles:", err)
htmx.HxError(w, http.StatusInternalServerError, "Failed to get following list, try again later.")
···
func (h *Handler) HandleNotificationsPage(w http.ResponseWriter, r *http.Request) {
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
-
log.Println("failed to get logged-in user:", err)
htmx.HxRedirect(w, "/login")
···
···
PendingProfileUpdate string = "pending_profile_update"
+
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)]
+
logger.Warn("invalid language code submitted", "languageCode", code)
languages = append(languages, language)
···
func (h *Handler) HandleProfilePage(w http.ResponseWriter, r *http.Request) {
+
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)
+
l.Error("failed to get total study time", "err", err)
totalStudySessions, _ = db.GetTotalStudySessions(h.Db, profileDid)
+
l.Error("failed to get total study study sessions", "err", err)
followers, following, _ = db.GetFollowerFollowingCount(h.Db, profileDid)
+
l.Error("failed to get follow stats", "err", err)
streak, _ = db.GetCurrentStreak(h.Db, profileDid)
+
l.Error("failed to get streak", "err", err)
···
if err := g.Wait(); err != nil {
+
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)
+
l.Error("failed to enqueue posthog event", "err", err)
···
func (h *Handler) HandleEditProfilePage(w http.ResponseWriter, r *http.Request) {
+
l := h.Logger.With("handler", "HandleEditProfilePage")
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
+
l.Error("failed to get logged-in user", "err", err)
htmx.HxRedirect(w, "/login")
profile, err := h.GetUserProfileWithAvatar(user.Did)
+
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 {
+
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)
+
l.Error("failed to get authorized client", "err", err)
htmx.HxRedirect(w, "/login")
+
updatedProfile, err := parseProfileForm(r, l)
+
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 {
+
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.")
···
+
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)
+
l.Error("failed to save yoten-session to add pending profile update", "err", err)
···
+
l.Error("failed to enqueue posthog identify event", "err", err)
err = h.Posthog.Enqueue(posthog.Capture{
···
Event: ph.ProfileRecordEditedEvent,
+
l.Error("failed to enqueue posthog event", "err", err)
···
func (h *Handler) HandleResourcesPage(w http.ResponseWriter, r *http.Request) {
+
l := h.Logger.With("handler", "HandleResourcesPage")
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
+
l.Error("failed to get logged-in user", "err", err)
htmx.HxRedirect(w, "/login")
resources, err := db.GetResourcesByDid(h.Db, user.Did)
+
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)
+
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) {
+
l := h.Logger.With("handler", "HandleActivitiesPage")
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
+
l.Error("failed to get logged-in user", "err", err)
htmx.HxRedirect(w, "/login")
activities, err := db.GetActivitiesByDid(h.Db, user.Did)
+
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)
+
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) {
+
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())
+
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())
+
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)
+
l.Error("failed to parse page value", "err", err)
···
sessions, err := db.GetStudySessionLogs(h.Db, ident.DID.String(), pageSize+1, int(offset))
+
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)
+
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) {
+
l := h.Logger.With("handler", "HandleFriendsPage")
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
+
l.Error("failed to get logged-in user", "err", err)
htmx.HxRedirect(w, "/login")
followers, following, err := db.GetFollowerFollowingCount(h.Db, user.Did)
+
l.Error("failed to get follow stats", "err", err)
views.FriendsPage(views.FriendsPageParams{
···
func (h *Handler) HandleFriendsFeed(w http.ResponseWriter, r *http.Request) {
+
l := h.Logger.With("handler", "HandleFriendsFeed")
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
+
l.Error("failed to get logged-in user")
htmx.HxRedirect(w, "/login")
···
page, err := strconv.ParseInt(pageStr, 10, 64)
+
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))
+
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)
+
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))
+
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)
+
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) {
+
l := h.Logger.With("handler", "HandleNotificationsPage")
user, err := bsky.GetUserWithBskyProfile(h.Oauth, r)
+
l.Error("failed to get logged-in user", "err", err)
htmx.HxRedirect(w, "/login")
brookjeynes.dev