mirror of
https://github.com/nushell/nushell.git
synced 2024-12-12 02:02:32 +01:00
c82dfce246
# Description Because the plugin interface reader thread can be responsible for sending a drop notification, it's possible for it to end up in a deadlock where it's waiting for the response to the drop notification call. I decided that the best way to address this is to just discard the response and not wait for it. It's not really important to synchronize with the response to `Dropped`, so this is probably faster anyway. cc @ayax79, this is your issue where polars is getting stuck # User-Facing Changes - A bug fix - Custom value plugin: `custom-value handle update` command # Tests + Formatting Tried to add a test with a long pipeline with a lot of drops and run it over and over to reproduce the deadlock. - 🟢 `toolkit fmt` - 🟢 `toolkit clippy` - 🟢 `toolkit test` - 🟢 `toolkit test stdlib`
244 lines
6.3 KiB
Rust
244 lines
6.3 KiB
Rust
use nu_test_support::nu_with_plugins;
|
|
use pretty_assertions::assert_eq;
|
|
|
|
#[test]
|
|
fn can_get_custom_value_from_plugin_and_instantly_collapse_it() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"custom-value generate"
|
|
);
|
|
|
|
assert_eq!(actual.out, "I used to be a custom value! My data was (abc)");
|
|
}
|
|
|
|
#[test]
|
|
fn can_get_custom_value_from_plugin_and_pass_it_over() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"custom-value generate | custom-value update"
|
|
);
|
|
|
|
assert_eq!(
|
|
actual.out,
|
|
"I used to be a custom value! My data was (abcxyz)"
|
|
);
|
|
}
|
|
|
|
#[test]
|
|
fn can_get_custom_value_from_plugin_and_pass_it_over_as_an_argument() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"custom-value update-arg (custom-value generate)"
|
|
);
|
|
|
|
assert_eq!(
|
|
actual.out,
|
|
"I used to be a custom value! My data was (abcxyz)"
|
|
);
|
|
}
|
|
|
|
#[test]
|
|
fn can_generate_and_updated_multiple_types_of_custom_values() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"custom-value generate2 | custom-value update"
|
|
);
|
|
|
|
assert_eq!(
|
|
actual.out,
|
|
"I used to be a DIFFERENT custom value! (xyzabc)"
|
|
);
|
|
}
|
|
|
|
#[test]
|
|
fn can_generate_custom_value_and_pass_through_closure() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"custom-value generate2 { custom-value update }"
|
|
);
|
|
|
|
assert_eq!(
|
|
actual.out,
|
|
"I used to be a DIFFERENT custom value! (xyzabc)"
|
|
);
|
|
}
|
|
|
|
#[test]
|
|
fn can_get_describe_plugin_custom_values() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"custom-value generate | describe"
|
|
);
|
|
|
|
assert_eq!(actual.out, "CoolCustomValue");
|
|
}
|
|
|
|
#[test]
|
|
fn can_get_plugin_custom_value_int_cell_path() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"(custom-value generate).0"
|
|
);
|
|
|
|
assert_eq!(actual.out, "abc");
|
|
}
|
|
|
|
#[test]
|
|
fn can_get_plugin_custom_value_string_cell_path() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"(custom-value generate).cool"
|
|
);
|
|
|
|
assert_eq!(actual.out, "abc");
|
|
}
|
|
|
|
#[test]
|
|
fn can_sort_plugin_custom_values() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"[(custom-value generate | custom-value update) (custom-value generate)] | sort | each { print } | ignore"
|
|
);
|
|
|
|
assert_eq!(
|
|
actual.out,
|
|
"I used to be a custom value! My data was (abc)\
|
|
I used to be a custom value! My data was (abcxyz)"
|
|
);
|
|
}
|
|
|
|
#[test]
|
|
fn can_append_plugin_custom_values() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"(custom-value generate) ++ (custom-value generate)"
|
|
);
|
|
|
|
assert_eq!(
|
|
actual.out,
|
|
"I used to be a custom value! My data was (abcabc)"
|
|
);
|
|
}
|
|
|
|
// There are currently no custom values defined by the engine that aren't hidden behind an extra
|
|
// feature
|
|
#[cfg(feature = "sqlite")]
|
|
#[test]
|
|
fn fails_if_passing_engine_custom_values_to_plugins() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests/fixtures/formats",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"open sample.db | custom-value update"
|
|
);
|
|
|
|
assert!(actual
|
|
.err
|
|
.contains("`SQLiteDatabase` cannot be sent to plugin"));
|
|
assert!(actual
|
|
.err
|
|
.contains("the `custom_values` plugin does not support this kind of value"));
|
|
}
|
|
|
|
#[test]
|
|
fn fails_if_passing_custom_values_across_plugins() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugins: [
|
|
("nu_plugin_custom_values"),
|
|
("nu_plugin_inc")
|
|
],
|
|
"custom-value generate | inc --major"
|
|
);
|
|
|
|
assert!(actual
|
|
.err
|
|
.contains("`CoolCustomValue` cannot be sent to plugin"));
|
|
assert!(actual
|
|
.err
|
|
.contains("the `inc` plugin does not support this kind of value"));
|
|
}
|
|
|
|
#[test]
|
|
fn drop_check_custom_value_prints_message_on_drop() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
// We build an array with the value copied twice to verify that it only gets dropped once
|
|
"do { |v| [$v $v] } (custom-value drop-check 'Hello') | ignore"
|
|
);
|
|
|
|
assert_eq!(actual.err, "DropCheckValue was dropped: Hello\n");
|
|
assert!(actual.status.success());
|
|
}
|
|
|
|
#[test]
|
|
fn handle_make_then_get_success() {
|
|
// The drop notification must wait until the `handle get` call has finished in order for this
|
|
// to succeed
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"42 | custom-value handle make | custom-value handle get"
|
|
);
|
|
|
|
assert_eq!(actual.out, "42");
|
|
assert!(actual.status.success());
|
|
}
|
|
|
|
#[test]
|
|
fn handle_update_several_times_doesnt_deadlock() {
|
|
// Do this in a loop to try to provoke a deadlock on drop
|
|
for _ in 0..10 {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
r#"
|
|
"hEllO" |
|
|
custom-value handle make |
|
|
custom-value handle update { str upcase } |
|
|
custom-value handle update { str downcase } |
|
|
custom-value handle update { str title-case } |
|
|
custom-value handle get
|
|
"#
|
|
);
|
|
|
|
assert_eq!(actual.out, "Hello");
|
|
assert!(actual.status.success());
|
|
}
|
|
}
|
|
|
|
#[test]
|
|
fn custom_value_in_example_is_rendered() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"custom-value generate --help"
|
|
);
|
|
|
|
assert!(actual
|
|
.out
|
|
.contains("I used to be a custom value! My data was (abc)"));
|
|
assert!(actual.status.success());
|
|
}
|
|
|
|
#[test]
|
|
fn custom_value_into_string() {
|
|
let actual = nu_with_plugins!(
|
|
cwd: "tests",
|
|
plugin: ("nu_plugin_custom_values"),
|
|
"custom-value generate | into string"
|
|
);
|
|
|
|
assert_eq!(actual.out, "I used to be a custom value! My data was (abc)");
|
|
}
|