1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
use crate::utils::pckg;
use duckscript::types::command::{Command, CommandInvocationContext, CommandResult};
use duckscript::types::instruction::InstructionType;
use duckscript::types::runtime::Context;
use duckscript::{parser, runner};
#[cfg(test)]
#[path = "./mod_test.rs"]
mod mod_test;
fn create_test_script(file: &str, test_name: &str) -> String {
format!(
r#"
!include_files {}
{}
"#,
file, test_name
)
.to_string()
}
#[derive(Clone)]
pub(crate) struct CommandImpl {
package: String,
}
impl Command for CommandImpl {
fn name(&self) -> String {
pckg::concat(&self.package, "TestFile")
}
fn aliases(&self) -> Vec<String> {
vec!["test_file".to_string()]
}
fn help(&self) -> String {
include_str!("help.md").to_string()
}
fn clone_and_box(&self) -> Box<dyn Command> {
Box::new((*self).clone())
}
fn run(&self, context: CommandInvocationContext) -> CommandResult {
if context.arguments.is_empty() {
CommandResult::Crash("File name not provided.".to_string())
} else {
let file = context.arguments[0].clone();
let requested_test_name = if context.arguments.len() > 1 {
context.arguments[1].clone()
} else {
"".to_string()
};
match parser::parse_file(&context.arguments[0]) {
Ok(instructions) => match context.commands.get("function") {
Some(function_command) => {
let mut command_names = function_command.aliases();
command_names.push(function_command.name());
let mut test_names = vec![];
for instruction in instructions {
match instruction.instruction_type {
InstructionType::Script(ref script_instruction) => {
match (
script_instruction.command.as_ref(),
script_instruction.arguments.as_ref(),
) {
(Some(current_command), Some(current_arguments)) => {
if !current_arguments.is_empty()
&& command_names.contains(¤t_command)
{
if current_arguments[0].starts_with("test_") {
test_names.push(current_arguments[0].clone());
}
}
}
_ => (),
};
}
_ => (),
};
}
let file_included = file.contains(&requested_test_name);
for test_name in test_names {
if file_included || test_name.contains(&requested_test_name) {
let script = create_test_script(&file, &test_name);
let mut runner_context = Context::new();
runner_context.commands = context.commands.clone();
match runner::run_script(&script, runner_context, None) {
Err(error) => {
writeln!(
context.env.out,
"test: [{}][{}] ... failed",
&file, &test_name
)
.unwrap();
return CommandResult::Crash(
format!(
"Error while running test: {}\n{}",
&test_name,
&error.to_string()
)
.to_string(),
);
}
_ => writeln!(
context.env.out,
"test: [{}][{}] ... ok",
&file, &test_name
)
.unwrap(),
}
}
}
CommandResult::Continue(Some("true".to_string()))
}
None => {
CommandResult::Crash("Unable to find the function command.".to_string())
}
},
Err(error) => CommandResult::Crash(
format!(
"Error while parsing file: {}\n{}",
&context.arguments[0],
&error.to_string()
)
.to_string(),
),
}
}
}
}
pub(crate) fn create(package: &str) -> Box<dyn Command> {
Box::new(CommandImpl {
package: package.to_string(),
})
}