move ast

Author: Shubham8287

crates/core/src/estimation.rs

@@ -132,7 +132,7 @@ mod tests {
     use crate::db::relational_db::tests_utils::{begin_tx, insert, with_auto_commit};
     use crate::db::relational_db::{tests_utils::TestDB, RelationalDB};
     use crate::error::DBError;
-    use crate::sql::ast::SchemaViewer;
+    use spacetimedb_engine::ast::SchemaViewer;
     use spacetimedb_lib::{identity::AuthCtx, AlgebraicType};
     use spacetimedb_query::compile_subscription;
     use spacetimedb_sats::product;

crates/core/src/host/module_host.rs

@@ -18,7 +18,7 @@ use crate::host::{InvalidFunctionArguments, InvalidViewArguments};
 use crate::identity::Identity;
 use crate::messages::control_db::{Database, HostType};
 use crate::replica_context::ReplicaContext;
-use crate::sql::ast::SchemaViewer;
+use spacetimedb_engine::ast::SchemaViewer;
 use crate::sql::execute::SqlResult;
 use crate::subscription::module_subscription_actor::ModuleSubscriptions;
 use crate::subscription::module_subscription_manager::BroadcastError;
@@ -67,7 +67,6 @@ use spacetimedb_schema::auto_migrate::{AutoMigrateError, MigrationPolicy};
 use spacetimedb_schema::def::{ModuleDef, ProcedureDef, ReducerDef, ViewDef};
 use spacetimedb_schema::identifier::Identifier;
 use spacetimedb_schema::reducer_name::ReducerName;
-
 use spacetimedb_schema::table_name::TableName;
 use std::collections::VecDeque;
 use std::fmt;

crates/core/src/host/wasm_common/module_host_actor.rs

@@ -22,7 +22,7 @@ use crate::identity::Identity;
 use crate::messages::control_db::HostType;
 use crate::module_host_context::ModuleCreationContext;
 use crate::replica_context::ReplicaContext;
-use crate::sql::ast::SchemaViewer;
+use spacetimedb_engine::ast::SchemaViewer;
 use crate::sql::execute::run_with_instance;
 use crate::subscription::module_subscription_actor::{commit_and_broadcast_event, CommitAndBroadcastEventSuccess};
 use crate::subscription::module_subscription_manager::TransactionOffset;

crates/core/src/sql/ast.rs

@@ -1,8 +1,6 @@
 use std::sync::Arc;
 use std::time::Duration;
 
-use super::ast::SchemaViewer;
-use crate::db::relational_db::RelationalDB;
 use crate::energy::FunctionBudget;
 use crate::error::DBError;
 use crate::estimation::{check_row_limit, estimate_rows_scanned};
@@ -17,6 +15,8 @@ use crate::subscription::tx::DeltaTx;
 use anyhow::anyhow;
 use spacetimedb_datastore::execution_context::Workload;
 use spacetimedb_datastore::traits::IsolationLevel;
+use spacetimedb_engine::ast::SchemaViewer;
+use spacetimedb_engine::relational_db::RelationalDB;
 use spacetimedb_expr::statement::Statement;
 use spacetimedb_lib::identity::AuthCtx;
 use spacetimedb_lib::metrics::ExecutionMetrics;

crates/core/src/sql/execute.rs

@@ -1,2 +1 @@
-pub mod ast;
 pub mod execute;

crates/core/src/sql/mod.rs

@@ -2204,7 +2204,7 @@ mod tests {
     use super::{Plan, SubscriptionManager};
     use crate::db::relational_db::tests_utils::with_read_only;
     use crate::host::module_host::DatabaseTableUpdate;
-    use crate::sql::ast::SchemaViewer;
+    use spacetimedb_engine::ast::SchemaViewer;
     use crate::subscription::module_subscription_manager::ClientQueryId;
     use crate::subscription::row_list_builder_pool::BsatnRowListBuilderPool;
     use crate::subscription::tx::DeltaTx;

crates/core/src/subscription/module_subscription_manager.rs

@@ -2,7 +2,7 @@ use super::execution_unit::QueryHash;
 use super::module_subscription_manager::Plan;
 use crate::db::relational_db::Tx;
 use crate::error::{DBError, SubscriptionError};
-use crate::sql::ast::SchemaViewer;
+use spacetimedb_engine::ast::SchemaViewer;
 use once_cell::sync::Lazy;
 use regex::Regex;
 use spacetimedb_datastore::locking_tx_datastore::state_view::StateView;

crates/core/src/subscription/query.rs

@@ -2,7 +2,7 @@ use super::execution_unit::QueryHash;
 use super::module_subscription_manager::Plan;
 use crate::db::relational_db::RelationalDB;
 use crate::error::DBError;
-use crate::sql::ast::SchemaViewer;
+use spacetimedb_engine::ast::SchemaViewer;
 use spacetimedb_datastore::locking_tx_datastore::state_view::StateView;
 use spacetimedb_lib::db::auth::StTableType;
 use spacetimedb_lib::identity::AuthCtx;

crates/core/src/subscription/subscription.rs

@@ -1,4 +1,4 @@
-mod ast;
+pub mod ast;
 pub(crate) mod durability;
 pub mod error;
 pub mod metrics;