appview: settings: add email preference setting

Signed-off-by: Seongmin Lee <[e-mail]>

appview/db/db.go

···
 		return err
 	})
 
+	runMigration(conn, "add-email-notif-preference-to-profile", func(tx *sql.Tx) error {
+		_, err := tx.Exec(`
+			alter table profile add column email_notif_preference integer not null default 0 check (email_notif_preference in (0, 1, 2)); -- disable, metion, enable
+		`)
+		return err
+	})
+
 	return &DB{db}, nil
 }
 

appview/db/email.go

···
 	_, err := e.Exec(query, code, did, email)
 	return err
 }
+
+func GetUserEmailPreference(e Execer, did string) (EmailPreference, error) {
+	var preference EmailPreference
+	err := e.QueryRow(`
+		select email_notif_preference
+		from profile
+		where did = ?
+	`, did).Scan(&preference)
+	if err != nil {
+		return preference, err
+	}
+	return preference, nil
+}
+
+func UpdateSettingsEmailPreference(e Execer, did string, preference EmailPreference) error {
+	_, err := e.Exec(`
+		update profile
+		set email_notif_preference = ?
+		where did = ?
+	`, preference, did)
+	return err
+}

appview/db/profile.go

···
 	Links          [5]string
 	Stats          [2]VanityStat
 	PinnedRepos    [6]syntax.ATURI
+
+	// settings
+	EmailNotifPreference EmailPreference
+}
+
+type EmailPreference int
+
+const (
+	EmailNotifDisabled EmailPreference = iota
+	EmailNotifMention
+	EmailNotifEnabled
+)
+
+func (p EmailPreference) IsDisabled() bool {
+	return p == EmailNotifDisabled
+}
+
+func (p EmailPreference) IsMention() bool {
+	return p == EmailNotifMention
+}
+
+func (p EmailPreference) IsEnabled() bool {
+	return p == EmailNotifEnabled
 }
 
 func (p Profile) IsLinksEmpty() bool {
···
 			did,
 			description,
 			include_bluesky,
-			location
+			location,
+			email_notif_preference
 		)
-		values (?, ?, ?, ?)`,
+		values (?, ?, ?, ?, ?)`,
 		profile.Did,
 		profile.Description,
 		includeBskyValue,
 		profile.Location,
+		profile.EmailNotifPreference,
 	)
 
 	if err != nil {
···
 			did,
 			description,
 			include_bluesky,
-			location
+			location,
+			email_notif_preference
 		from
 			profile
 		%s`,
···
 		var profile Profile
 		var includeBluesky int
 
-		err = rows.Scan(&profile.ID, &profile.Did, &profile.Description, &includeBluesky, &profile.Location)
+		err = rows.Scan(&profile.ID, &profile.Did, &profile.Description, &includeBluesky, &profile.Location, &profile.EmailNotifPreference)
 		if err != nil {
 			return nil, err
 		}
···
 
 	includeBluesky := 0
 	err := e.QueryRow(
-		`select description, include_bluesky, location from profile where did = ?`,
+		`select description, include_bluesky, location, email_notif_preference from profile where did = ?`,
 		did,
-	).Scan(&profile.Description, &includeBluesky, &profile.Location)
+	).Scan(&profile.Description, &includeBluesky, &profile.Location, &profile.EmailNotifPreference)
 	if err == sql.ErrNoRows {
 		profile := Profile{}
 		profile.Did = did

appview/email/notifier.go

···
 
 func (n *EmailNotifier) gatherRecipientEmails(ctx context.Context, handles []string) []string {
 	recipients := []string{}
-	resolvedIdents := n.idResolver.ResolveIdents(ctx, handles)
-	for _, id := range resolvedIdents {
+	for _, handle := range handles {
+		id, err := n.idResolver.ResolveIdent(ctx, handle)
+		if err != nil {
+			log.Println("failed to resolve handle:", err)
+			continue
+		}
+		emailPreference, err := db.GetUserEmailPreference(n.db, id.DID.String())
+		if err != nil {
+			log.Println("failed to get user email preference:", err)
+			continue
+		}
+		if emailPreference == db.EmailNotifDisabled {
+			continue
+		}
 		email, err := db.GetPrimaryEmail(n.db, id.DID.String())
 		if err != nil {
 			log.Println("failed to get primary email:", err)

appview/pages/pages.go

···
 }
 
 type UserEmailsSettingsParams struct {
-	LoggedInUser *oauth.User
-	Emails       []db.Email
-	Tabs         []map[string]any
-	Tab          string
+	LoggedInUser    *oauth.User
+	Emails          []db.Email
+	NotifPreference db.EmailPreference
+	Tabs            []map[string]any
+	Tab             string
 }
 
 func (p *Pages) UserEmailsSettings(w io.Writer, params UserEmailsSettingsParams) error {

appview/pages/templates/user/settings/emails.html

···
       </div>
       <div class="col-span-1 md:col-span-3 flex flex-col gap-6">
         {{ template "emailSettings" . }}
+        {{ template "emailList" . }}
       </div>
     </section>
   </div>
 {{ end }}
 
 {{ define "emailSettings" }}
+  <form
+    hx-post="/settings/email/preference"
+    hx-swap="none"
+    hx-indicator="#email-preference-spinner"
+    class="grid grid-cols-1 md:grid-cols-3 gap-4"
+  >
+    <div class="col-span-1 md:col-span-2">
+      <h2 class="text-sm pb-2 uppercase font-bold">Email Notifications</h2>
+    </div>
+    <select
+      name="preference"
+      class="p-1 border border-gray-200 bg-white dark:bg-gray-700 dark:text-white dark:border-gray-600"
+    >
+      <option value="enable" {{ if .NotifPreference.IsEnabled }}selected{{ end }}>Enable</option>
+      <option value="mention" {{ if .NotifPreference.IsMention }}selected{{ end }}>Only on Mentions</option>
+      <option value="disable" {{ if .NotifPreference.IsDisabled }}selected{{ end }}>Disable</option>
+    </select>
+    <div class="md:col-start-2 col-span-2 flex justify-end">
+      <button type="submit" class="btn text-base">
+        <span>Save Preference</span>
+        <span id="email-preference-spinner" class="group">
+          {{ i "loader-circle" "w-4 h-4 animate-spin hidden group-[.htmx-request]:inline" }}
+        </span>
+      </button>
+    </div>
+  </form>
+{{ end }}
+
+{{ define "emailList" }}
   <div class="grid grid-cols-1 md:grid-cols-3 gap-4 items-center">
     <div class="col-span-1 md:col-span-2">
       <h2 class="text-sm pb-2 uppercase font-bold">Email Addresses</h2>
···
   <div id="settings-emails-error" class="text-red-500 dark:text-red-400"></div>
   <div id="settings-emails-success" class="text-green-500 dark:text-green-400"></div>
 </form>
-{{ end }}
+{{ end }}

appview/settings/settings.go

···
 		r.Delete("/", s.keys)
 	})
 
+	r.Post("/email/preference", s.emailPreference)
+
 	r.Route("/emails", func(r chi.Router) {
 		r.Get("/", s.emailsSettings)
 		r.Put("/", s.emails)
···
 
 func (s *Settings) emailsSettings(w http.ResponseWriter, r *http.Request) {
 	user := s.OAuth.GetUser(r)
+	preference, err := db.GetUserEmailPreference(s.Db, user.Did)
+
 	emails, err := db.GetAllEmails(s.Db, user.Did)
 	if err != nil {
 		log.Println(err)
 	}
 
 	s.Pages.UserEmailsSettings(w, pages.UserEmailsSettingsParams{
-		LoggedInUser: user,
-		Emails:       emails,
-		Tabs:         settingsTabs,
-		Tab:          "emails",
+		LoggedInUser:    user,
+		Emails:          emails,
+		NotifPreference: preference,
+		Tabs:            settingsTabs,
+		Tab:             "emails",
 	})
 }
 
···
 	}
 
 	s.Pages.HxLocation(w, "/settings/emails")
+}
+
+func (s *Settings) emailPreference(w http.ResponseWriter, r *http.Request) {
+	did := s.OAuth.GetDid(r)
+	preferenceValue := r.FormValue("preference")
+	var preference db.EmailPreference
+	switch preferenceValue {
+	case "enable":
+		preference = db.EmailNotifEnabled
+	case "mention":
+		preference = db.EmailNotifMention
+	case "disable":
+		preference = db.EmailNotifDisabled
+	default:
+		log.Printf("Incorrect email preference value")
+		return
+	}
+
+	err := db.UpdateSettingsEmailPreference(s.Db, did, preference)
+	if err != nil {
+		log.Printf("failed to update email preference setting: %v", err)
+		s.Pages.Notice(w, "settings-keys", "Failed to update email preference. Try again later.")
+		return
+	}
 }
 
 func (s *Settings) keys(w http.ResponseWriter, r *http.Request) {