(ns metabase.events.driver-notifications
  "Driver notifications are used to let drivers know database details or other relevant information has
  changed (`:database-update`) or that a Database has been deleted (`:database-delete`). Drivers can choose to be
  notified of these events by implementing the `metabase.driver/notify-database-updated` multimethod. At the time of
  this writing, the SQL JDBC driver 'superclass' is the only thing that implements this method, and does so to close
  connection pools when database details change or when they are deleted."
  (:require [clojure.core.async :as a]
            [clojure.tools.logging :as log]
            [metabase.driver :as driver]
            [metabase.events :as events]))

(def ^:private driver-notifications-topics
  "The `Set` of event topics which are subscribed to for use in driver notifications."
  #{:database-update :database-delete})

(defonce ^:private ^{:doc "Channel for receiving event notifications we want to subscribe to for driver notifications
  events."} driver-notifications-channel
  (a/chan))


;;; ------------------------------------------------ EVENT PROCESSING ------------------------------------------------


(defn process-driver-notifications-event
  "Handle processing for a single event notification received on the driver-notifications-channel"
  [driver-notifications-event]
  ;; try/catch here to prevent individual topic processing exceptions from bubbling up.  better to handle them here.
  (when-let [{_topic :topic database :item} driver-notifications-event]
    (try
      ;; notify the appropriate driver about the updated database
      (driver/notify-database-updated (:engine database) database)
      (catch Throwable e
        (log/warn (format "Failed to process driver notifications event. %s" (:topic driver-notifications-event)) e)))))



  ---------------------------------------------------- LIFECYLE ----------------------------------------------------

(defmethod events/init! ::DriverNotifications
  [_]
  (events/start-event-listener! driver-notifications-topics driver-notifications-channel process-driver-notifications-event))

 ------------------------------------------------ EVENT PROCESSING ------------------------------------------------
 try/catch here to prevent individual topic processing exceptions from bubbling up.  better to handle them here.
 notify the appropriate driver about the updated database
(ns metabase.events.driver-notifications
  "Driver notifications are used to let drivers know database details or other relevant information has
  changed (`:database-update`) or that a Database has been deleted (`:database-delete`). Drivers can choose to be
  notified of these events by implementing the `metabase.driver/notify-database-updated` multimethod. At the time of
  this writing, the SQL JDBC driver 'superclass' is the only thing that implements this method, and does so to close
  connection pools when database details change or when they are deleted."
  (:require [clojure.core.async :as a]
            [clojure.tools.logging :as log]
            [metabase.driver :as driver]
            [metabase.events :as events]))

(def ^:private driver-notifications-topics
  "The `Set` of event topics which are subscribed to for use in driver notifications."
  #{:database-update :database-delete})

(defonce ^:private ^{:doc "Channel for receiving event notifications we want to subscribe to for driver notifications
  events."} driver-notifications-channel
  (a/chan))




(defn process-driver-notifications-event
  "Handle processing for a single event notification received on the driver-notifications-channel"
  [driver-notifications-event]
  (when-let [{_topic :topic database :item} driver-notifications-event]
    (try
      (driver/notify-database-updated (:engine database) database)
      (catch Throwable e
        (log/warn (format "Failed to process driver notifications event. %s" (:topic driver-notifications-event)) e)))))



  ---------------------------------------------------- LIFECYLE ----------------------------------------------------

(defmethod events/init! ::DriverNotifications
  [_]
  (events/start-event-listener! driver-notifications-topics driver-notifications-channel process-driver-notifications-event))
