(ns metabase.models (:require [clojure.string :as str] [environ.core :as env] [metabase.config :as config] [metabase.models.action :as action] [metabase.models.application-permissions-revision :as a-perm-revision] [metabase.models.bookmark :as bookmark] [metabase.models.cache-config :as cache-config] [metabase.models.card :as card] [metabase.models.channel :as models.channel] [metabase.models.collection :as collection] [metabase.models.collection-permission-graph-revision :as c-perm-revision] [metabase.models.dashboard :as dashboard] [metabase.models.dashboard-card :as dashboard-card] [metabase.models.dashboard-card-series :as dashboard-card-series] [metabase.models.dashboard-tab :as dashboard-tab] [metabase.models.database :as database] [metabase.models.dimension :as dimension] [metabase.models.field :as field] [metabase.models.field-usage :as field-usage] [metabase.models.field-values :as field-values] [metabase.models.legacy-metric :as legacy-metric] [metabase.models.legacy-metric-important-field :as legacy-metric-important-field] [metabase.models.login-history :as login-history] [metabase.models.model-index :as model-index] [metabase.models.moderation-review :as moderation-review] [metabase.models.native-query-snippet :as native-query-snippet] [metabase.models.parameter-card :as parameter-card] [metabase.models.permissions :as perms] [metabase.models.permissions-group :as perms-group] [metabase.models.permissions-group-membership :as perms-group-membership] [metabase.models.permissions-revision :as perms-revision] [metabase.models.persisted-info :as persisted-info] [metabase.models.pulse :as models.pulse] [metabase.models.pulse-card :as pulse-card] [metabase.models.pulse-channel :as pulse-channel] [metabase.models.pulse-channel-recipient :as pulse-channel-recipient] [metabase.models.query-analysis :as query-analysis] [metabase.models.query-cache :as query-cache] [metabase.models.query-execution :as query-execution] [metabase.models.query-field :as query-field] [metabase.models.query-table :as query-table] [metabase.models.revision :as revision] [metabase.models.secret :as secret] [metabase.models.segment :as segment] [metabase.models.session :as session] [metabase.models.setting :as setting] [metabase.models.table :as table] [metabase.models.table-privileges] [metabase.models.task-history :as task-history] [metabase.models.timeline :as timeline] [metabase.models.timeline-event :as timeline-event] [metabase.models.user :as user] [metabase.models.view-log :as view-log] [metabase.plugins.classloader :as classloader] [metabase.public-settings.premium-features :refer [defenterprise]] [metabase.search.core :as search] [metabase.util :as u] [methodical.core :as methodical] [potemkin :as p] [toucan2.core :as t2] [toucan2.model :as t2.model])) | |
Fool the linter | (comment a-perm-revision/keep-me action/keep-me bookmark/keep-me c-perm-revision/keep-me cache-config/keep-me card/keep-me collection/keep-me dashboard-card-series/keep-me dashboard-card/keep-me dashboard-tab/keep-me dashboard/keep-me database/keep-me dimension/keep-me field/keep-me field-usage/keep-me field-values/keep-me legacy-metric/keep-me legacy-metric-important-field/keep-me login-history/keep-me moderation-review/keep-me models.channel/keep-me native-query-snippet/keep-me parameter-card/keep-me perms-group-membership/keep-me perms-group/keep-me perms-revision/keep-me perms/keep-me persisted-info/keep-me pulse-card/keep-me pulse-channel-recipient/keep-me pulse-channel/keep-me models.pulse/keep-me query-cache/keep-me query-execution/keep-me query-analysis/keep-me query-field/keep-me query-table/keep-me revision/keep-me secret/keep-me segment/keep-me session/keep-me setting/keep-me table/keep-me task-history/keep-me timeline-event/keep-me timeline/keep-me user/keep-me view-log/keep-me) |
(p/import-vars [action Action HTTPAction ImplicitAction QueryAction] [bookmark CardBookmark] [bookmark DashboardBookmark] [bookmark CollectionBookmark] [bookmark BookmarkOrdering] [cache-config CacheConfig] [card Card] [collection Collection] [c-perm-revision CollectionPermissionGraphRevision] [dashboard Dashboard] [dashboard-card DashboardCard] [dashboard-card-series DashboardCardSeries] [database Database] [dimension Dimension] [field Field] [field-values FieldValues] [legacy-metric LegacyMetric] [login-history LoginHistory] [moderation-review ModerationReview] [model-index ModelIndex ModelIndexValue] [legacy-metric-important-field LegacyMetricImportantField] [native-query-snippet NativeQuerySnippet] [parameter-card ParameterCard] [perms Permissions] [perms-group PermissionsGroup] [perms-group-membership PermissionsGroupMembership] [perms-revision PermissionsRevision] [a-perm-revision ApplicationPermissionsRevision] [persisted-info PersistedInfo] [models.pulse Pulse] [pulse-card PulseCard] [pulse-channel PulseChannel] [pulse-channel-recipient PulseChannelRecipient] [query-cache QueryCache] [query-execution QueryExecution] [revision Revision] [secret Secret] [segment Segment] [session Session] [setting Setting] [table Table] [task-history TaskHistory] [timeline Timeline] [timeline-event TimelineEvent] [user User] [view-log ViewLog]) | |
TODO -- we should move this stuff into [[metabase.models.interface]] so we can be more certain it's always loaded during REPL usage and tests | |
OSS version; no-op. | (defenterprise resolve-enterprise-model metabase-enterprise.models [x] x) |
(methodical/defmethod t2.model/resolve-model :before :default "Ensure the namespace for given model is loaded. This is a safety mechanism as we are moving to toucan2 and we don't need to require the model namespaces in order to use it." [x] (when (and (keyword? x) (= (namespace x) "model") ;; Don't try to require if it's already registered as a :metabase/model, since that means it has already ;; been required (not (isa? x :metabase/model))) (try (let [model-namespace (str "metabase.models." (u/->kebab-case-en (name x)))] ;; use `classloader/require` which is thread-safe and plays nice with our plugins system (classloader/require model-namespace)) (catch clojure.lang.ExceptionInfo _ (resolve-enterprise-model x)))) x) | |
(methodical/defmethod t2.model/resolve-model :around clojure.lang.Symbol "Handle models deriving from :metabase/model." [symb] (or (when (simple-symbol? symb) (let [metabase-models-keyword (keyword "model" (name symb))] (when (isa? metabase-models-keyword :metabase/model) metabase-models-keyword))) (next-method symb))) | |
Models must derive from :hook/search-index if their state can influence the contents of the Search Index. Note that it might not be the model itself that depends on it, for example, Dashcards are used in Card entries. Don't worry about whether you've added it in the right place, we have tests to ensure that it is derived if, and only if, it is required. | |
(t2/define-after-insert :hook/search-index [instance] (search/update! instance true) instance) | |
Hidden behind an obscure environment variable, as it may cause performance problems. See https://github.com/camsaul/toucan2/issues/195 | (defn- update-hook-enabled? [] (or config/is-dev? config/is-test? (when-let [setting (:mb-experimental-search-index-realtime-updates env/env)] (and (not (str/blank? setting)) (not= "false" setting))))) |
(when (update-hook-enabled?) (t2/define-after-update :hook/search-index [instance] (search/update! instance) nil)) | |
Too much of a performance risk. | |