graphql-engine/server/src-lib/Hasura/Server/API/Metadata.hs

-- | The RQL metadata query ('/v1/metadata')
module Hasura.Server.API.Metadata where

import           Hasura.Prelude

import qualified Data.Environment                          as Env
import qualified Network.HTTP.Client.Extended              as HTTP

import           Control.Monad.Trans.Control               (MonadBaseControl)
import           Control.Monad.Unique
import           Data.Aeson
import           Data.Aeson.Casing
import           Data.Aeson.TH

import qualified Hasura.Tracing                            as Tracing

import           Hasura.Base.Error
import           Hasura.EncJSON
import           Hasura.Metadata.Class
import           Hasura.RQL.DDL.Action
import           Hasura.RQL.DDL.ApiLimit
import           Hasura.RQL.DDL.ComputedField
import           Hasura.RQL.DDL.CustomTypes
import           Hasura.RQL.DDL.Endpoint
import           Hasura.RQL.DDL.EventTrigger
import           Hasura.RQL.DDL.GraphqlSchemaIntrospection
import           Hasura.RQL.DDL.InheritedRoles
import           Hasura.RQL.DDL.Metadata
import           Hasura.RQL.DDL.Permission
import           Hasura.RQL.DDL.QueryCollection
import           Hasura.RQL.DDL.Relationship
import           Hasura.RQL.DDL.Relationship.Rename
import           Hasura.RQL.DDL.RemoteRelationship
import           Hasura.RQL.DDL.RemoteSchema
import           Hasura.RQL.DDL.ScheduledTrigger
import           Hasura.RQL.DDL.Schema
import           Hasura.RQL.DDL.Schema.Source
import           Hasura.RQL.Types
import           Hasura.RQL.Types.Run
import           Hasura.Server.Types                       (InstanceId (..), MaintenanceMode (..))
import           Hasura.Server.Utils                       (APIVersion (..))
import           Hasura.Server.Version                     (HasVersion)
import           Hasura.Session


data RQLMetadataV1
  = RMPgAddSource !(AddSource ('Postgres 'Vanilla))
  | RMPgDropSource !DropSource

  | RMPgTrackTable !(TrackTableV2 ('Postgres 'Vanilla))
  | RMPgUntrackTable !(UntrackTable ('Postgres 'Vanilla))
  | RMPgSetTableIsEnum !SetTableIsEnum
  | RMPgSetTableCustomization !(SetTableCustomization ('Postgres 'Vanilla))

  -- Postgres functions
  | RMPgTrackFunction !(TrackFunctionV2 ('Postgres 'Vanilla))
  | RMPgUntrackFunction !(UnTrackFunction ('Postgres 'Vanilla))

  -- Postgres function permissions
  | RMPgCreateFunctionPermission !(CreateFunctionPermission ('Postgres 'Vanilla))
  | RMPgDropFunctionPermission !(DropFunctionPermission ('Postgres 'Vanilla))

  -- Postgres table relationships
  | RMPgCreateObjectRelationship !(CreateObjRel ('Postgres 'Vanilla))
  | RMPgCreateArrayRelationship !(CreateArrRel ('Postgres 'Vanilla))
  | RMPgDropRelationship !(DropRel ('Postgres 'Vanilla))
  | RMPgSetRelationshipComment !(SetRelComment ('Postgres 'Vanilla))
  | RMPgRenameRelationship !(RenameRel ('Postgres 'Vanilla))

  -- Postgres computed fields
  | RMPgAddComputedField !(AddComputedField ('Postgres 'Vanilla))
  | RMPgDropComputedField !(DropComputedField ('Postgres 'Vanilla))

  -- Postgres tables remote relationships
  | RMPgCreateRemoteRelationship !(RemoteRelationship ('Postgres 'Vanilla))
  | RMPgUpdateRemoteRelationship !(RemoteRelationship ('Postgres 'Vanilla))
  | RMPgDeleteRemoteRelationship !(DeleteRemoteRelationship ('Postgres 'Vanilla))

  -- Postgres tables permissions
  | RMPgCreateInsertPermission !(CreatePerm InsPerm ('Postgres 'Vanilla))
  | RMPgCreateSelectPermission !(CreatePerm SelPerm ('Postgres 'Vanilla))
  | RMPgCreateUpdatePermission !(CreatePerm UpdPerm ('Postgres 'Vanilla))
  | RMPgCreateDeletePermission !(CreatePerm DelPerm ('Postgres 'Vanilla))

  | RMPgDropInsertPermission !(DropPerm InsPerm ('Postgres 'Vanilla))
  | RMPgDropSelectPermission !(DropPerm SelPerm ('Postgres 'Vanilla))
  | RMPgDropUpdatePermission !(DropPerm UpdPerm ('Postgres 'Vanilla))
  | RMPgDropDeletePermission !(DropPerm DelPerm ('Postgres 'Vanilla))
  | RMPgSetPermissionComment !(SetPermComment ('Postgres 'Vanilla))

  -- Postgres tables event triggers
  | RMPgCreateEventTrigger !(CreateEventTriggerQuery ('Postgres 'Vanilla))
  | RMPgDeleteEventTrigger !(DeleteEventTriggerQuery ('Postgres 'Vanilla))
  | RMPgRedeliverEvent     !(RedeliverEventQuery     ('Postgres 'Vanilla))
  | RMPgInvokeEventTrigger !(InvokeEventTriggerQuery ('Postgres 'Vanilla))

  -- MSSQL sources
  | RMMssqlAddSource !(AddSource 'MSSQL)
  | RMMssqlDropSource !DropSource
  | RMMssqlTrackTable !(TrackTableV2 'MSSQL)
  | RMMssqlUntrackTable !(UntrackTable 'MSSQL)
  | RMMssqlSetTableCustomization !(SetTableCustomization 'MSSQL)

  | RMMssqlCreateObjectRelationship !(CreateObjRel 'MSSQL)
  | RMMssqlCreateArrayRelationship !(CreateArrRel 'MSSQL)
  | RMMssqlDropRelationship !(DropRel 'MSSQL)
  | RMMssqlSetRelationshipComment !(SetRelComment 'MSSQL)
  | RMMssqlRenameRelationship !(RenameRel 'MSSQL)

  | RMMssqlCreateInsertPermission !(CreatePerm InsPerm 'MSSQL)
  | RMMssqlCreateSelectPermission !(CreatePerm SelPerm 'MSSQL)
  | RMMssqlCreateUpdatePermission !(CreatePerm UpdPerm 'MSSQL)
  | RMMssqlCreateDeletePermission !(CreatePerm DelPerm 'MSSQL)

  | RMMssqlDropInsertPermission !(DropPerm InsPerm 'MSSQL)
  | RMMssqlDropSelectPermission !(DropPerm SelPerm 'MSSQL)
  | RMMssqlDropUpdatePermission !(DropPerm UpdPerm 'MSSQL)
  | RMMssqlDropDeletePermission !(DropPerm DelPerm 'MSSQL)
  | RMMssqlSetPermissionComment !(SetPermComment 'MSSQL)

  -- Citus functions
  | RMCitusTrackFunction !(TrackFunctionV2 ('Postgres 'Citus))
  | RMCitusUntrackFunction !(UnTrackFunction ('Postgres 'Citus))

  -- Citus function permissions
  | RMCitusCreateFunctionPermission !(CreateFunctionPermission ('Postgres 'Citus))
  | RMCitusDropFunctionPermission !(DropFunctionPermission ('Postgres 'Citus))

  -- Citus sources
  | RMCitusAddSource !(AddSource ('Postgres 'Citus))
  | RMCitusDropSource !DropSource
  | RMCitusTrackTable !(TrackTableV2 ('Postgres 'Citus))
  | RMCitusUntrackTable !(UntrackTable ('Postgres 'Citus))
  | RMCitusSetTableCustomization !(SetTableCustomization ('Postgres 'Citus))

  -- Citus relationship
  | RMCitusCreateObjectRelationship !(CreateObjRel ('Postgres 'Citus))
  | RMCitusCreateArrayRelationship !(CreateArrRel ('Postgres 'Citus))
  | RMCitusDropRelationship !(DropRel ('Postgres 'Citus))
  | RMCitusSetRelationshipComment !(SetRelComment ('Postgres 'Citus))
  | RMCitusRenameRelationship !(RenameRel ('Postgres 'Citus))

  -- Citus permissions
  | RMCitusCreateInsertPermission !(CreatePerm InsPerm ('Postgres 'Citus))
  | RMCitusCreateSelectPermission !(CreatePerm SelPerm ('Postgres 'Citus))
  | RMCitusCreateUpdatePermission !(CreatePerm UpdPerm ('Postgres 'Citus))
  | RMCitusCreateDeletePermission !(CreatePerm DelPerm ('Postgres 'Citus))

  | RMCitusDropInsertPermission !(DropPerm InsPerm ('Postgres 'Citus))
  | RMCitusDropSelectPermission !(DropPerm SelPerm ('Postgres 'Citus))
  | RMCitusDropUpdatePermission !(DropPerm UpdPerm ('Postgres 'Citus))
  | RMCitusDropDeletePermission !(DropPerm DelPerm ('Postgres 'Citus))
  | RMCitusSetPermissionComment !(SetPermComment ('Postgres 'Citus))

  -- BigQuery sources
  | RMBigqueryAddSource !(AddSource 'BigQuery)
  | RMBigqueryDropSource !DropSource
  | RMBigqueryTrackTable !(TrackTableV2 'BigQuery)
  | RMBigquerySetTableCustomization !(SetTableCustomization 'BigQuery)
  | RMBigqueryUntrackTable !(UntrackTable 'BigQuery)
  | RMBigqueryCreateObjectRelationship !(CreateObjRel 'BigQuery)
  | RMBigqueryCreateArrayRelationship !(CreateArrRel 'BigQuery)
  | RMBigqueryDropRelationship !(DropRel 'BigQuery)
  | RMBigquerySetRelationshipComment !(SetRelComment 'BigQuery)
  | RMBigqueryRenameRelationship !(RenameRel 'BigQuery)

  | RMBigqueryCreateInsertPermission !(CreatePerm InsPerm 'BigQuery)
  | RMBigqueryCreateSelectPermission !(CreatePerm SelPerm 'BigQuery)
  | RMBigqueryCreateUpdatePermission !(CreatePerm UpdPerm 'BigQuery)
  | RMBigqueryCreateDeletePermission !(CreatePerm DelPerm 'BigQuery)

  | RMBigqueryDropInsertPermission !(DropPerm InsPerm 'BigQuery)
  | RMBigqueryDropSelectPermission !(DropPerm SelPerm 'BigQuery)
  | RMBigqueryDropUpdatePermission !(DropPerm UpdPerm 'BigQuery)
  | RMBigqueryDropDeletePermission !(DropPerm DelPerm 'BigQuery)
  | RMBigquerySetPermissionComment !(SetPermComment 'BigQuery)

  | RMRenameSource !RenameSource

  -- Inconsistent metadata
  | RMGetInconsistentMetadata !GetInconsistentMetadata
  | RMDropInconsistentMetadata !DropInconsistentMetadata

  -- Remote schemas
  | RMAddRemoteSchema !AddRemoteSchemaQuery
  | RMUpdateRemoteSchema !AddRemoteSchemaQuery
  | RMRemoveRemoteSchema !RemoteSchemaNameQuery
  | RMReloadRemoteSchema !RemoteSchemaNameQuery
  | RMIntrospectRemoteSchema !RemoteSchemaNameQuery

  -- remote-schema permissions
  | RMAddRemoteSchemaPermissions !AddRemoteSchemaPermissions
  | RMDropRemoteSchemaPermissions !DropRemoteSchemaPermissions

  -- scheduled triggers
  | RMCreateCronTrigger !CreateCronTrigger
  | RMDeleteCronTrigger !ScheduledTriggerName
  | RMCreateScheduledEvent !CreateScheduledEvent
  | RMDeleteScheduledEvent !DeleteScheduledEvent
  | RMGetScheduledEvents !GetScheduledEvents
  | RMGetEventInvocations !GetEventInvocations

  -- query collections, allow list related
  | RMCreateQueryCollection !CreateCollection
  | RMDropQueryCollection !DropCollection
  | RMAddQueryToCollection !AddQueryToCollection
  | RMDropQueryFromCollection !DropQueryFromCollection
  | RMAddCollectionToAllowlist !CollectionReq
  | RMDropCollectionFromAllowlist !CollectionReq

  -- basic metadata management
  | RMReplaceMetadata !ReplaceMetadata
  | RMExportMetadata !ExportMetadata
  | RMClearMetadata !ClearMetadata
  | RMReloadMetadata !ReloadMetadata

  -- actions
  | RMCreateAction !CreateAction
  | RMDropAction !DropAction
  | RMUpdateAction !UpdateAction
  | RMCreateActionPermission !CreateActionPermission
  | RMDropActionPermission !DropActionPermission

  | RMCreateRestEndpoint !CreateEndpoint
  | RMDropRestEndpoint !DropEndpoint

  | RMSetCustomTypes !CustomTypes

  | RMDumpInternalState !DumpInternalState

  | RMGetCatalogState !GetCatalogState
  | RMSetCatalogState !SetCatalogState

  -- 'ApiLimit' related
  | RMSetApiLimits !ApiLimit
  | RMRemoveApiLimits

  -- 'MetricsConfig' related
  | RMSetMetricsConfig !MetricsConfig
  | RMRemoveMetricsConfig

  -- inherited roles
  | RMAddInheritedRole !AddInheritedRole
  | RMDropInheritedRole !DropInheritedRole

  | RMSetGraphqlSchemaIntrospectionOptions !SetGraphqlIntrospectionOptions

  -- bulk metadata queries
  | RMBulk [RQLMetadataRequest]
  deriving (Eq)

data RQLMetadataV2
  = RMV2ReplaceMetadata !ReplaceMetadataV2
  | RMV2ExportMetadata !ExportMetadata
  deriving (Eq)

data RQLMetadataRequest
  = RMV1 !RQLMetadataV1
  | RMV2 !RQLMetadataV2
  deriving (Eq)

instance FromJSON RQLMetadataRequest where
  parseJSON = withObject "RQLMetadataRequest" $ \o -> do
    version <- o .:? "version" .!= VIVersion1
    let val = Object o
    case version of
      VIVersion1 -> RMV1 <$> parseJSON val
      VIVersion2 -> RMV2 <$> parseJSON val

instance ToJSON RQLMetadataRequest where
  toJSON = \case
    RMV1 q -> embedVersion VIVersion1 $ toJSON q
    RMV2 q -> embedVersion VIVersion2 $ toJSON q
    where
      embedVersion version (Object o) =
        Object $ o <> "version" .= version
      -- never happens since JSON value of RQL queries are always objects
      embedVersion _ _ = error "Unexpected: toJSON of RQLMetadtaV is not an object"

data RQLMetadata
  = RQLMetadata
  { _rqlMetadataResourceVersion :: !(Maybe MetadataResourceVersion)
  , _rqlMetadata                :: !RQLMetadataRequest
  } deriving (Eq)

instance FromJSON RQLMetadata where
  parseJSON = withObject "RQLMetadata" $ \o -> do
    _rqlMetadataResourceVersion <- o .:? "resource_version"
    _rqlMetadata <- parseJSON $ Object o
    pure RQLMetadata{..}

instance ToJSON RQLMetadata where
  toJSON RQLMetadata{..} =
    embedResourceVersion $ toJSON _rqlMetadata
    where
      embedResourceVersion (Object o) =
        Object $ o <> "resource_version" .= _rqlMetadataResourceVersion
      -- never happens since JSON value of RQL queries are always objects
      embedResourceVersion _ = error "Unexpected: toJSON of RQLMetadata is not an object"

$(deriveJSON
  defaultOptions { constructorTagModifier = snakeCase . drop 2
                 , sumEncoding = TaggedObject "type" "args"
                 }
  ''RQLMetadataV1)

$(deriveJSON
  defaultOptions { constructorTagModifier = snakeCase . drop 4
                 , sumEncoding = TaggedObject "type" "args"
                 }
  ''RQLMetadataV2)

runMetadataQuery
  :: ( HasVersion
     , MonadIO m
     , MonadBaseControl IO m
     , Tracing.MonadTrace m
     , MonadMetadataStorage m
     , MonadResolveSource m
     )
  => Env.Environment
  -> InstanceId
  -> UserInfo
  -> HTTP.Manager
  -> ServerConfigCtx
  -> RebuildableSchemaCache
  -> RQLMetadata
  -> m (EncJSON, RebuildableSchemaCache)
runMetadataQuery env instanceId userInfo httpManager serverConfigCtx schemaCache RQLMetadata{..} = do
  (metadata, currentResourceVersion) <- fetchMetadata
  ((r, modMetadata), modSchemaCache, cacheInvalidations) <-
    runMetadataQueryM env currentResourceVersion _rqlMetadata
    & runMetadataT metadata
    & runCacheRWT schemaCache
    & peelRun (RunCtx userInfo httpManager serverConfigCtx)
    & runExceptT
    & liftEitherM
  -- set modified metadata in storage
  if queryModifiesMetadata _rqlMetadata
    then
      case _sccMaintenanceMode serverConfigCtx of
        MaintenanceModeDisabled -> do
          -- set modified metadata in storage
          newResourceVersion <- setMetadata (fromMaybe currentResourceVersion _rqlMetadataResourceVersion) modMetadata
          -- notify schema cache sync
          notifySchemaCacheSync newResourceVersion instanceId cacheInvalidations
          (_, modSchemaCache', _) <- setMetadataResourceVersionInSchemaCache newResourceVersion
            & runCacheRWT modSchemaCache
            & peelRun (RunCtx userInfo httpManager serverConfigCtx)
            & runExceptT
            & liftEitherM
          pure (r, modSchemaCache')
        MaintenanceModeEnabled ->
          throw500 "metadata cannot be modified in maintenance mode"
    else
      pure (r, modSchemaCache)

queryModifiesMetadata :: RQLMetadataRequest -> Bool
queryModifiesMetadata = \case
  RMV1 q ->
    case q of
      RMPgRedeliverEvent _        -> False
      RMPgInvokeEventTrigger _    -> False
      RMGetInconsistentMetadata _ -> False
      RMIntrospectRemoteSchema _  -> False
      RMDumpInternalState _       -> False
      RMSetCatalogState _         -> False
      RMGetCatalogState _         -> False
      RMExportMetadata _          -> False
      RMGetEventInvocations _     -> False
      RMGetScheduledEvents _      -> False
      RMCreateScheduledEvent _    -> False
      RMDeleteScheduledEvent _    -> False
      RMBulk qs                   -> any queryModifiesMetadata qs
      _                           -> True
  RMV2 q ->
    case q of
      RMV2ExportMetadata _ -> False
      _                    -> True

runMetadataQueryM
  :: ( HasVersion
     , MonadIO m
     , MonadBaseControl IO m
     , CacheRWM m
     , Tracing.MonadTrace m
     , UserInfoM m
     , MonadUnique m
     , HTTP.HasHttpManagerM m
     , MetadataM m
     , MonadMetadataStorageQueryAPI m
     , HasServerConfigCtx m
     )
  => Env.Environment
  -> MetadataResourceVersion
  -> RQLMetadataRequest
  -> m EncJSON
runMetadataQueryM env currentResourceVersion = withPathK "args" . \case
  RMV1 q -> runMetadataQueryV1M env currentResourceVersion q
  RMV2 q -> runMetadataQueryV2M currentResourceVersion q

runMetadataQueryV1M
  :: ( HasVersion
     , MonadIO m
     , MonadBaseControl IO m
     , CacheRWM m
     , Tracing.MonadTrace m
     , UserInfoM m
     , MonadUnique m
     , HTTP.HasHttpManagerM m
     , MetadataM m
     , MonadMetadataStorageQueryAPI m
     , HasServerConfigCtx m
     )
  => Env.Environment
  -> MetadataResourceVersion
  -> RQLMetadataV1
  -> m EncJSON
runMetadataQueryV1M env currentResourceVersion = \case
  RMPgAddSource q                   -> runAddSource q
  RMRenameSource   q                -> runRenameSource q
  RMPgDropSource q                  -> runDropSource q

  RMPgTrackTable q                  -> runTrackTableV2Q q
  RMPgUntrackTable q                -> runUntrackTableQ q
  RMPgSetTableIsEnum q              -> runSetExistingTableIsEnumQ q
  RMPgSetTableCustomization q       -> runSetTableCustomization q

  RMPgTrackFunction q               -> runTrackFunctionV2 q
  RMPgUntrackFunction q             -> runUntrackFunc q

  RMPgCreateFunctionPermission q    -> runCreateFunctionPermission q
  RMPgDropFunctionPermission   q    -> runDropFunctionPermission q

  RMPgCreateObjectRelationship q    -> runCreateRelationship ObjRel q
  RMPgCreateArrayRelationship q     -> runCreateRelationship ArrRel q
  RMPgDropRelationship q            -> runDropRel q
  RMPgSetRelationshipComment q      -> runSetRelComment q
  RMPgRenameRelationship q          -> runRenameRel q

  RMPgAddComputedField q            -> runAddComputedField q
  RMPgDropComputedField q           -> runDropComputedField q

  RMPgCreateRemoteRelationship q    -> runCreateRemoteRelationship q
  RMPgUpdateRemoteRelationship q    -> runUpdateRemoteRelationship q
  RMPgDeleteRemoteRelationship q    -> runDeleteRemoteRelationship q

  RMPgCreateInsertPermission q      -> runCreatePerm q
  RMPgCreateSelectPermission q      -> runCreatePerm q
  RMPgCreateUpdatePermission q      -> runCreatePerm q
  RMPgCreateDeletePermission q      -> runCreatePerm q

  RMPgDropInsertPermission q        -> runDropPerm q
  RMPgDropSelectPermission q        -> runDropPerm q
  RMPgDropUpdatePermission q        -> runDropPerm q
  RMPgDropDeletePermission q        -> runDropPerm q
  RMPgSetPermissionComment q        -> runSetPermComment q

  RMPgCreateEventTrigger q          -> runCreateEventTriggerQuery q
  RMPgDeleteEventTrigger q          -> runDeleteEventTriggerQuery q
  RMPgRedeliverEvent     q          -> runRedeliverEvent q
  RMPgInvokeEventTrigger q          -> runInvokeEventTrigger q

  RMBigqueryAddSource q             -> runAddSource q
  RMBigqueryDropSource q            -> runDropSource q
  RMBigqueryTrackTable q            -> runTrackTableV2Q q
  RMBigqueryUntrackTable q          -> runUntrackTableQ q
  RMBigquerySetTableCustomization q -> runSetTableCustomization q

  RMBigqueryCreateObjectRelationship q -> runCreateRelationship ObjRel q
  RMBigqueryCreateArrayRelationship q  -> runCreateRelationship ArrRel q
  RMBigqueryDropRelationship q         -> runDropRel q
  RMBigquerySetRelationshipComment q   -> runSetRelComment q
  RMBigqueryRenameRelationship q       -> runRenameRel q

  RMBigqueryCreateInsertPermission q   -> runCreatePerm q
  RMBigqueryCreateSelectPermission q   -> runCreatePerm q
  RMBigqueryCreateUpdatePermission q   -> runCreatePerm q
  RMBigqueryCreateDeletePermission q   -> runCreatePerm q

  RMBigqueryDropInsertPermission q     -> runDropPerm q
  RMBigqueryDropSelectPermission q     -> runDropPerm q
  RMBigqueryDropUpdatePermission q     -> runDropPerm q
  RMBigqueryDropDeletePermission q     -> runDropPerm q
  RMBigquerySetPermissionComment q     -> runSetPermComment q

  RMMssqlAddSource q                -> runAddSource q
  RMMssqlDropSource q               -> runDropSource q
  RMMssqlTrackTable q               -> runTrackTableV2Q q
  RMMssqlUntrackTable q             -> runUntrackTableQ q
  RMMssqlSetTableCustomization q    -> runSetTableCustomization q

  RMMssqlCreateObjectRelationship q -> runCreateRelationship ObjRel q
  RMMssqlCreateArrayRelationship q  -> runCreateRelationship ArrRel q
  RMMssqlDropRelationship q         -> runDropRel q
  RMMssqlSetRelationshipComment q   -> runSetRelComment q
  RMMssqlRenameRelationship q       -> runRenameRel q

  RMMssqlCreateInsertPermission q   -> runCreatePerm q
  RMMssqlCreateSelectPermission q   -> runCreatePerm q
  RMMssqlCreateUpdatePermission q   -> runCreatePerm q
  RMMssqlCreateDeletePermission q   -> runCreatePerm q

  RMMssqlDropInsertPermission q     -> runDropPerm q
  RMMssqlDropSelectPermission q     -> runDropPerm q
  RMMssqlDropUpdatePermission q     -> runDropPerm q
  RMMssqlDropDeletePermission q     -> runDropPerm q
  RMMssqlSetPermissionComment q     -> runSetPermComment q

  RMCitusAddSource q                -> runAddSource q
  RMCitusDropSource q               -> runDropSource q
  RMCitusTrackTable q               -> runTrackTableV2Q q
  RMCitusUntrackTable q             -> runUntrackTableQ q
  RMCitusSetTableCustomization q    -> runSetTableCustomization q

  RMCitusTrackFunction q               -> runTrackFunctionV2 q
  RMCitusUntrackFunction q             -> runUntrackFunc q

  RMCitusCreateFunctionPermission q    -> runCreateFunctionPermission q
  RMCitusDropFunctionPermission   q    -> runDropFunctionPermission q

  RMCitusCreateObjectRelationship q -> runCreateRelationship ObjRel q
  RMCitusCreateArrayRelationship  q -> runCreateRelationship ArrRel q
  RMCitusDropRelationship q         -> runDropRel q
  RMCitusSetRelationshipComment q   -> runSetRelComment q
  RMCitusRenameRelationship q       -> runRenameRel q

  RMCitusCreateInsertPermission q   -> runCreatePerm q
  RMCitusCreateSelectPermission q   -> runCreatePerm q
  RMCitusCreateUpdatePermission q   -> runCreatePerm q
  RMCitusCreateDeletePermission q   -> runCreatePerm q

  RMCitusDropInsertPermission q     -> runDropPerm q
  RMCitusDropSelectPermission q     -> runDropPerm q
  RMCitusDropUpdatePermission q     -> runDropPerm q
  RMCitusDropDeletePermission q     -> runDropPerm q
  RMCitusSetPermissionComment q     -> runSetPermComment q

  RMGetInconsistentMetadata q       -> runGetInconsistentMetadata q
  RMDropInconsistentMetadata q      -> runDropInconsistentMetadata q

  RMAddRemoteSchema q               -> runAddRemoteSchema env q
  RMUpdateRemoteSchema q            -> runUpdateRemoteSchema env q
  RMRemoveRemoteSchema q            -> runRemoveRemoteSchema q
  RMReloadRemoteSchema q            -> runReloadRemoteSchema q
  RMIntrospectRemoteSchema q        -> runIntrospectRemoteSchema q

  RMAddRemoteSchemaPermissions q    -> runAddRemoteSchemaPermissions q
  RMDropRemoteSchemaPermissions q   -> runDropRemoteSchemaPermissions q

  RMCreateCronTrigger q             -> runCreateCronTrigger q
  RMDeleteCronTrigger q             -> runDeleteCronTrigger q
  RMCreateScheduledEvent q          -> runCreateScheduledEvent q
  RMDeleteScheduledEvent q          -> runDeleteScheduledEvent q
  RMGetScheduledEvents q            -> runGetScheduledEvents q
  RMGetEventInvocations q           -> runGetEventInvocations q

  RMCreateQueryCollection q         -> runCreateCollection q
  RMDropQueryCollection q           -> runDropCollection q
  RMAddQueryToCollection q          -> runAddQueryToCollection q
  RMDropQueryFromCollection q       -> runDropQueryFromCollection q
  RMAddCollectionToAllowlist q      -> runAddCollectionToAllowlist q
  RMDropCollectionFromAllowlist q   -> runDropCollectionFromAllowlist q

  RMReplaceMetadata q               -> runReplaceMetadata q
  RMExportMetadata q                -> runExportMetadata q
  RMClearMetadata q                 -> runClearMetadata q
  RMReloadMetadata q                -> runReloadMetadata q

  RMCreateAction q                  -> runCreateAction q
  RMDropAction q                    -> runDropAction q
  RMUpdateAction q                  -> runUpdateAction q
  RMCreateActionPermission q        -> runCreateActionPermission q
  RMDropActionPermission q          -> runDropActionPermission q

  RMCreateRestEndpoint q            -> runCreateEndpoint q
  RMDropRestEndpoint q              -> runDropEndpoint q

  RMSetCustomTypes q                -> runSetCustomTypes q

  RMDumpInternalState q             -> runDumpInternalState q

  RMGetCatalogState q               -> runGetCatalogState q
  RMSetCatalogState q               -> runSetCatalogState q

  RMSetApiLimits q                  -> runSetApiLimits q
  RMRemoveApiLimits                 -> runRemoveApiLimits

  RMSetMetricsConfig q              -> runSetMetricsConfig q
  RMRemoveMetricsConfig             -> runRemoveMetricsConfig

  RMAddInheritedRole q              -> runAddInheritedRole q
  RMDropInheritedRole q             -> runDropInheritedRole q

  RMSetGraphqlSchemaIntrospectionOptions q -> runSetGraphqlSchemaIntrospectionOptions q

  RMBulk q                                 -> encJFromList <$> indexedMapM (runMetadataQueryM env currentResourceVersion) q

runMetadataQueryV2M
  :: ( MonadIO m
     , CacheRWM m
     , MetadataM m
     , MonadMetadataStorageQueryAPI m
     , HasServerConfigCtx m
     )
  => MetadataResourceVersion
  -> RQLMetadataV2
  -> m EncJSON
runMetadataQueryV2M currentResourceVersion = \case
  RMV2ReplaceMetadata q -> runReplaceMetadataV2 q
  RMV2ExportMetadata q  -> runExportMetadataV2 currentResourceVersion q