blocklist subscribers based on bounces

cmd/bounce.go

@@ -111,6 +111,41 @@ func handleDeleteBounces(c echo.Context) error {
 	return c.JSON(http.StatusOK, okResp{true})
 }
 
+func handleBlocklistSubscriberBounces(c echo.Context) error {
+	var (
+		app    = c.Get("app").(*App)
+		pID    = c.Param("id")
+		all, _ = strconv.ParseBool(c.QueryParam("all"))
+		IDs    = []int{}
+	)
+	// Is it an /:id call?
+	if pID != "" {
+		id, _ := strconv.Atoi(pID)
+		if id < 1 {
+			return echo.NewHTTPError(http.StatusBadRequest, app.i18n.T("globals.messages.invalidID"))
+		}
+		IDs = append(IDs, id)
+	} else if !all {
+		// Multiple IDs.
+		i, err := parseStringIDs(c.Request().URL.Query()["id"])
+		if err != nil {
+			return echo.NewHTTPError(http.StatusBadRequest,
+				app.i18n.Ts("globals.messages.invalidID", "error", err.Error()))
+		}
+
+		if len(i) == 0 {
+			return echo.NewHTTPError(http.StatusBadRequest,
+				app.i18n.Ts("globals.messages.invalidID"))
+		}
+		IDs = i
+	}
+
+	if err := app.core.BlocklistSubscriberBounces(IDs); err != nil {
+		return err
+	}
+	return c.JSON(http.StatusOK, okResp{true})
+}
+
 // handleBounceWebhook renders the HTML preview of a template.
 func handleBounceWebhook(c echo.Context) error {
 	var (

cmd/handlers.go

@@ -140,6 +140,8 @@ func initHTTPHandlers(e *echo.Echo, app *App) {
 	api.GET("/api/bounces/:id", pm(handleGetBounces, "bounces:get"))
 	api.DELETE("/api/bounces", pm(handleDeleteBounces, "bounces:manage"))
 	api.DELETE("/api/bounces/:id", pm(handleDeleteBounces, "bounces:manage"))
+	api.PUT("/api/bounces/blocklist", pm(handleBlocklistSubscriberBounces, "bounces:manage"))
+	api.PUT("/api/bounces/:id/blocklist", pm(handleBlocklistSubscriberBounces, "bounces:manage"))
 
 	// Subscriber operations based on arbitrary SQL queries.
 	// These aren't very REST-like.

frontend/src/api/index.js

@@ -179,6 +179,16 @@ export const deleteSubscriberBounces = async (id) => http.delete(
   { loading: models.bounces },
 );
 
+export const blocklistSubscriberBounce = async (id) => http.put(
+  `/api/bounces/${id}/blocklist`,
+  { loading: models.bounces },
+);
+
+export const blocklistSubscriberBounces = async (params) => http.put(
+  '/api/bounces/blocklist',
+  { params, loading: models.bounces },
+);
+
 export const deleteBounce = async (id) => http.delete(
   `/api/bounces/${id}`,
   { loading: models.bounces },

internal/core/bounces.go

@@ -100,3 +100,12 @@ func (c *Core) DeleteBounces(ids []int) error {
 	}
 	return nil
 }
+
+func (c *Core) BlocklistSubscriberBounces(ids []int) error {
+	if _, err := c.q.BlocklistSubscribersByBounces.Exec(pq.Array(ids)); err != nil {
+		c.log.Printf("error blocklisting subscribers by bounces: %v", err)
+		return echo.NewHTTPError(http.StatusInternalServerError,
+			c.i18n.Ts("globals.messages.errorUpdating", "name", "{globals.terms.bounce}", "error", pqErrMsg(err)))
+	}
+	return nil
+}

models/queries.go

@@ -104,11 +104,12 @@ type Queries struct {
 	UpdateSettings *sqlx.Stmt `query:"update-settings"`
 
 	// GetStats *sqlx.Stmt `query:"get-stats"`
-	RecordBounce              *sqlx.Stmt `query:"record-bounce"`
-	QueryBounces              string     `query:"query-bounces"`
-	DeleteBounces             *sqlx.Stmt `query:"delete-bounces"`
-	DeleteBouncesBySubscriber *sqlx.Stmt `query:"delete-bounces-by-subscriber"`
-	GetDBInfo                 string     `query:"get-db-info"`
+	RecordBounce                  *sqlx.Stmt `query:"record-bounce"`
+	QueryBounces                  string     `query:"query-bounces"`
+	DeleteBounces                 *sqlx.Stmt `query:"delete-bounces"`
+	DeleteBouncesBySubscriber     *sqlx.Stmt `query:"delete-bounces-by-subscriber"`
+	BlocklistSubscribersByBounces *sqlx.Stmt `query:"blocklist-subscribers-by-bounces"`
+	GetDBInfo                     string     `query:"get-db-info"`
 
 	CreateUser        *sqlx.Stmt `query:"create-user"`
 	UpdateUser        *sqlx.Stmt `query:"update-user"`

queries.sql

@@ -1040,6 +1040,16 @@ WITH sub AS (
 )
 DELETE FROM bounces WHERE subscriber_id = (SELECT id FROM sub);
 
+--name: blocklist-subscribers-by-bounces
+WITH subscriber_ids_to_blocklist AS (
+  SELECT DISTINCT b.subscriber_id
+  FROM bounces b
+  WHERE b.id = ANY($1)
+)
+UPDATE subscribers
+SET status = 'blocklisted'
+WHERE id IN (SELECT subscriber_id FROM subscriber_ids_to_blocklist)
+RETURNING id, email, status;
 
 -- name: get-db-info
 SELECT JSON_BUILD_OBJECT('version', (SELECT VERSION()),