(ns metabase.task.email-remove-legacy-pulse (:require [clojurewerkz.quartzite.jobs :as jobs] [clojurewerkz.quartzite.triggers :as triggers] [metabase.channel.template.core :as channel.template] [metabase.email :as email] [metabase.task :as task] [metabase.util.log :as log] [metabase.util.urls :as urls] [toucan2.core :as t2])) | |
(set! *warn-on-reflection* true) | |
(defn- has-legacy-pulse? [] (pos? (t2/count :model/Pulse :dashboard_id nil :alert_condition nil :archived false))) | |
(def ^:private template-path "metabase/email/warn_deprecate_pulse.hbs") | |
(defn- email-remove-legacy-pulse []
(when (and (email/email-configured?)
(has-legacy-pulse?))
(log/info "Sending email to admins about removal of legacy pulses")
(let [legacy-pulse (->> (t2/select :model/Pulse :dashboard_id nil :alert_condition nil :archived false)
(map #(assoc % :url (urls/legacy-pulse-url (:id %)))))]
(doseq [admin (t2/select :model/User :is_superuser true)]
(email/send-email-retrying!
{:recipients [(:email admin)]
:message-type :html
:subject "[Metabase] Removal of legacy pulses in upcoming Metabase release"
:message (channel.template/render template-path {:userName (:common_name admin)
:pulses legacy-pulse
:instanceURL (urls/site-url)})}))))) | |
Send email to admins and warn about removal of Pulse in 49, This job will only run once. | (jobs/defjob EmailRemoveLegacyPulse [_ctx] (email-remove-legacy-pulse)) |
(defmethod task/init! ::SendWarnPulseRemovalEmail [_job-name]
(let [job (jobs/build
(jobs/of-type EmailRemoveLegacyPulse)
(jobs/with-identity (jobs/key "metabase.task.email-remove-legacy-pulse.job"))
(jobs/store-durably))
trigger (triggers/build
(triggers/with-identity (triggers/key "metabase.task.email-remove-legacy-pulse.trigger"))
(triggers/start-now))]
(task/schedule-task! job trigger))) | |