@ -797,7 +797,7 @@ fn generate_code_block_test(fn_name: &str, code_block: &str, index: usize) -> pr
|
|||||||
let ctx = crate::ExecutorContext {
|
let ctx = crate::ExecutorContext {
|
||||||
engine: std::sync::Arc::new(Box::new(crate::engine::conn_mock::EngineConnection::new().await.unwrap())),
|
engine: std::sync::Arc::new(Box::new(crate::engine::conn_mock::EngineConnection::new().await.unwrap())),
|
||||||
fs: std::sync::Arc::new(crate::fs::FileManager::new()),
|
fs: std::sync::Arc::new(crate::fs::FileManager::new()),
|
||||||
stdlib: std::sync::Arc::new(tokio::sync::RwLock::new(crate::std::StdLib::new())),
|
stdlib: std::sync::Arc::new(crate::std::StdLib::new()),
|
||||||
settings: Default::default(),
|
settings: Default::default(),
|
||||||
context_type: crate::execution::ContextType::Mock,
|
context_type: crate::execution::ContextType::Mock,
|
||||||
};
|
};
|
||||||
|
@ -1218,7 +1218,7 @@ impl Node<CallExpressionKw> {
|
|||||||
ctx.clone(),
|
ctx.clone(),
|
||||||
exec_state.mod_local.pipe_value.clone().map(|v| Arg::new(v, callsite)),
|
exec_state.mod_local.pipe_value.clone().map(|v| Arg::new(v, callsite)),
|
||||||
);
|
);
|
||||||
match ctx.stdlib.read().await.get_either(fn_name) {
|
match ctx.stdlib.get_either(fn_name) {
|
||||||
FunctionKind::Core(func) => {
|
FunctionKind::Core(func) => {
|
||||||
if func.deprecated() {
|
if func.deprecated() {
|
||||||
exec_state.warn(CompilationError::err(
|
exec_state.warn(CompilationError::err(
|
||||||
@ -1370,7 +1370,7 @@ impl Node<CallExpression> {
|
|||||||
}
|
}
|
||||||
let fn_args = fn_args; // remove mutability
|
let fn_args = fn_args; // remove mutability
|
||||||
|
|
||||||
match ctx.stdlib.read().await.get_either(fn_name) {
|
match ctx.stdlib.get_either(fn_name) {
|
||||||
FunctionKind::Core(func) => {
|
FunctionKind::Core(func) => {
|
||||||
if func.deprecated() {
|
if func.deprecated() {
|
||||||
exec_state.warn(CompilationError::err(
|
exec_state.warn(CompilationError::err(
|
||||||
@ -2229,7 +2229,7 @@ mod test {
|
|||||||
parsing::ast::types::{DefaultParamVal, Identifier, Parameter},
|
parsing::ast::types::{DefaultParamVal, Identifier, Parameter},
|
||||||
};
|
};
|
||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
use tokio::{io::AsyncWriteExt, sync::RwLock, task::JoinSet};
|
use tokio::{io::AsyncWriteExt, task::JoinSet};
|
||||||
|
|
||||||
#[tokio::test(flavor = "multi_thread")]
|
#[tokio::test(flavor = "multi_thread")]
|
||||||
async fn test_assign_args_to_params() {
|
async fn test_assign_args_to_params() {
|
||||||
@ -2348,7 +2348,7 @@ mod test {
|
|||||||
crate::engine::conn_mock::EngineConnection::new().await.unwrap(),
|
crate::engine::conn_mock::EngineConnection::new().await.unwrap(),
|
||||||
)),
|
)),
|
||||||
fs: Arc::new(crate::fs::FileManager::new()),
|
fs: Arc::new(crate::fs::FileManager::new()),
|
||||||
stdlib: Arc::new(RwLock::new(crate::std::StdLib::new())),
|
stdlib: Arc::new(crate::std::StdLib::new()),
|
||||||
settings: Default::default(),
|
settings: Default::default(),
|
||||||
context_type: ContextType::Mock,
|
context_type: ContextType::Mock,
|
||||||
};
|
};
|
||||||
@ -2515,11 +2515,11 @@ export c = a + 2
|
|||||||
.unwrap(),
|
.unwrap(),
|
||||||
)),
|
)),
|
||||||
fs: Arc::new(crate::fs::FileManager::new()),
|
fs: Arc::new(crate::fs::FileManager::new()),
|
||||||
stdlib: Arc::new(RwLock::new(crate::std::StdLib::new())),
|
|
||||||
settings: ExecutorSettings {
|
settings: ExecutorSettings {
|
||||||
project_directory: Some(tmpdir.path().into()),
|
project_directory: Some(tmpdir.path().into()),
|
||||||
..Default::default()
|
..Default::default()
|
||||||
},
|
},
|
||||||
|
stdlib: Arc::new(crate::std::StdLib::new()),
|
||||||
context_type: ContextType::Mock,
|
context_type: ContextType::Mock,
|
||||||
};
|
};
|
||||||
let mut exec_state = ExecState::new(&exec_ctxt);
|
let mut exec_state = ExecState::new(&exec_ctxt);
|
||||||
|
@ -27,7 +27,6 @@ pub use memory::EnvironmentRef;
|
|||||||
use schemars::JsonSchema;
|
use schemars::JsonSchema;
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
pub use state::{ExecState, MetaSettings};
|
pub use state::{ExecState, MetaSettings};
|
||||||
use tokio::sync::RwLock;
|
|
||||||
|
|
||||||
use crate::{
|
use crate::{
|
||||||
engine::EngineManager,
|
engine::EngineManager,
|
||||||
@ -256,7 +255,7 @@ pub enum ContextType {
|
|||||||
pub struct ExecutorContext {
|
pub struct ExecutorContext {
|
||||||
pub engine: Arc<Box<dyn EngineManager>>,
|
pub engine: Arc<Box<dyn EngineManager>>,
|
||||||
pub fs: Arc<FileManager>,
|
pub fs: Arc<FileManager>,
|
||||||
pub stdlib: Arc<RwLock<StdLib>>,
|
pub stdlib: Arc<StdLib>,
|
||||||
pub settings: ExecutorSettings,
|
pub settings: ExecutorSettings,
|
||||||
pub context_type: ContextType,
|
pub context_type: ContextType,
|
||||||
}
|
}
|
||||||
@ -394,7 +393,7 @@ impl ExecutorContext {
|
|||||||
Ok(Self {
|
Ok(Self {
|
||||||
engine,
|
engine,
|
||||||
fs: Arc::new(FileManager::new()),
|
fs: Arc::new(FileManager::new()),
|
||||||
stdlib: Arc::new(RwLock::new(StdLib::new())),
|
stdlib: Arc::new(StdLib::new()),
|
||||||
settings,
|
settings,
|
||||||
context_type: ContextType::Live,
|
context_type: ContextType::Live,
|
||||||
})
|
})
|
||||||
@ -413,7 +412,7 @@ impl ExecutorContext {
|
|||||||
.map_err(|e| format!("{:?}", e))?,
|
.map_err(|e| format!("{:?}", e))?,
|
||||||
)),
|
)),
|
||||||
fs: Arc::new(FileManager::new(fs_manager)),
|
fs: Arc::new(FileManager::new(fs_manager)),
|
||||||
stdlib: Arc::new(RwLock::new(StdLib::new())),
|
stdlib: Arc::new(StdLib::new()),
|
||||||
settings,
|
settings,
|
||||||
context_type: ContextType::Live,
|
context_type: ContextType::Live,
|
||||||
})
|
})
|
||||||
@ -426,7 +425,7 @@ impl ExecutorContext {
|
|||||||
crate::engine::conn_mock::EngineConnection::new().await.unwrap(),
|
crate::engine::conn_mock::EngineConnection::new().await.unwrap(),
|
||||||
)),
|
)),
|
||||||
fs: Arc::new(FileManager::new()),
|
fs: Arc::new(FileManager::new()),
|
||||||
stdlib: Arc::new(RwLock::new(StdLib::new())),
|
stdlib: Arc::new(StdLib::new()),
|
||||||
settings: Default::default(),
|
settings: Default::default(),
|
||||||
context_type: ContextType::Mock,
|
context_type: ContextType::Mock,
|
||||||
}
|
}
|
||||||
@ -444,7 +443,7 @@ impl ExecutorContext {
|
|||||||
.map_err(|e| format!("{:?}", e))?,
|
.map_err(|e| format!("{:?}", e))?,
|
||||||
)),
|
)),
|
||||||
fs: Arc::new(FileManager::new(fs_manager)),
|
fs: Arc::new(FileManager::new(fs_manager)),
|
||||||
stdlib: Arc::new(RwLock::new(StdLib::new())),
|
stdlib: Arc::new(StdLib::new()),
|
||||||
settings,
|
settings,
|
||||||
context_type: ContextType::Mock,
|
context_type: ContextType::Mock,
|
||||||
})
|
})
|
||||||
@ -455,7 +454,7 @@ impl ExecutorContext {
|
|||||||
ExecutorContext {
|
ExecutorContext {
|
||||||
engine,
|
engine,
|
||||||
fs: Arc::new(FileManager::new()),
|
fs: Arc::new(FileManager::new()),
|
||||||
stdlib: Arc::new(RwLock::new(StdLib::new())),
|
stdlib: Arc::new(StdLib::new()),
|
||||||
settings: Default::default(),
|
settings: Default::default(),
|
||||||
context_type: ContextType::MockCustomForwarded,
|
context_type: ContextType::MockCustomForwarded,
|
||||||
}
|
}
|
||||||
@ -973,7 +972,7 @@ pub(crate) async fn parse_execute(code: &str) -> Result<ExecTestResults, KclErro
|
|||||||
})?,
|
})?,
|
||||||
)),
|
)),
|
||||||
fs: Arc::new(crate::fs::FileManager::new()),
|
fs: Arc::new(crate::fs::FileManager::new()),
|
||||||
stdlib: Arc::new(RwLock::new(crate::std::StdLib::new())),
|
stdlib: Arc::new(crate::std::StdLib::new()),
|
||||||
settings: Default::default(),
|
settings: Default::default(),
|
||||||
context_type: ContextType::Mock,
|
context_type: ContextType::Mock,
|
||||||
};
|
};
|
||||||
|
Reference in New Issue
Block a user