mirror of
https://github.com/denoland/deno.git
synced 2024-12-29 10:39:10 -05:00
e438ac2c74
Removes the magic number hack to switch between flatbuffers and the minimal dispatcher. Adds machinery to pass the op_id through the shared_queue.
426 lines
14 KiB
C++
426 lines
14 KiB
C++
// Copyright 2018-2019 the Deno authors. All rights reserved. MIT license.
|
|
#include "test.h"
|
|
|
|
static int exec_count = 0;
|
|
void recv_cb(void* user_data, deno_op_id op_id, deno_buf buf,
|
|
deno_pinned_buf zero_copy_buf) {
|
|
// We use this to check that scripts have executed.
|
|
EXPECT_EQ(1u, buf.data_len);
|
|
EXPECT_EQ(42u, op_id);
|
|
EXPECT_EQ(buf.data_ptr[0], 4);
|
|
EXPECT_EQ(zero_copy_buf.data_ptr, nullptr);
|
|
EXPECT_EQ(zero_copy_buf.data_len, 0u);
|
|
EXPECT_EQ(zero_copy_buf.pin, nullptr);
|
|
exec_count++;
|
|
}
|
|
|
|
TEST(ModulesTest, Resolution) {
|
|
exec_count = 0; // Reset
|
|
Deno* d = deno_new(deno_config{0, empty_snapshot, empty, recv_cb, nullptr});
|
|
EXPECT_EQ(0, exec_count);
|
|
|
|
static deno_mod a = deno_mod_new(d, true, "a.js",
|
|
"import { b } from 'b.js'\n"
|
|
"if (b() != 'b') throw Error();\n"
|
|
"Deno.core.send(42, new Uint8Array([4]));");
|
|
EXPECT_NE(a, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
const char* b_src = "export function b() { return 'b' }";
|
|
static deno_mod b = deno_mod_new(d, false, "b.js", b_src);
|
|
EXPECT_NE(b, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
EXPECT_EQ(0, exec_count);
|
|
|
|
EXPECT_EQ(1u, deno_mod_imports_len(d, a));
|
|
EXPECT_EQ(0u, deno_mod_imports_len(d, b));
|
|
|
|
EXPECT_STREQ("b.js", deno_mod_imports_get(d, a, 0));
|
|
EXPECT_EQ(nullptr, deno_mod_imports_get(d, a, 1));
|
|
EXPECT_EQ(nullptr, deno_mod_imports_get(d, b, 0));
|
|
|
|
static int resolve_count = 0;
|
|
auto resolve_cb = [](void* user_data, const char* specifier,
|
|
deno_mod referrer) {
|
|
EXPECT_EQ(referrer, a);
|
|
EXPECT_STREQ(specifier, "b.js");
|
|
resolve_count++;
|
|
return b;
|
|
};
|
|
|
|
deno_mod_instantiate(d, d, b, resolve_cb);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
EXPECT_EQ(0, resolve_count);
|
|
EXPECT_EQ(0, exec_count);
|
|
|
|
deno_mod_instantiate(d, d, a, resolve_cb);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
EXPECT_EQ(1, resolve_count);
|
|
EXPECT_EQ(0, exec_count);
|
|
|
|
deno_mod_evaluate(d, d, a);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
EXPECT_EQ(1, resolve_count);
|
|
EXPECT_EQ(1, exec_count);
|
|
|
|
deno_delete(d);
|
|
}
|
|
|
|
TEST(ModulesTest, ResolutionError) {
|
|
exec_count = 0; // Reset
|
|
Deno* d = deno_new(deno_config{0, empty_snapshot, empty, recv_cb, nullptr});
|
|
EXPECT_EQ(0, exec_count);
|
|
|
|
static deno_mod a = deno_mod_new(d, true, "a.js",
|
|
"import 'bad'\n"
|
|
"Deno.core.send(42, new Uint8Array([4]));");
|
|
EXPECT_NE(a, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
EXPECT_EQ(0, exec_count);
|
|
|
|
EXPECT_EQ(1u, deno_mod_imports_len(d, a));
|
|
EXPECT_STREQ("bad", deno_mod_imports_get(d, a, 0));
|
|
|
|
static int resolve_count = 0;
|
|
auto resolve_cb = [](void* user_data, const char* specifier,
|
|
deno_mod referrer) {
|
|
EXPECT_EQ(referrer, a);
|
|
EXPECT_STREQ(specifier, "bad");
|
|
resolve_count++;
|
|
return 0;
|
|
};
|
|
|
|
deno_mod_instantiate(d, d, a, resolve_cb);
|
|
EXPECT_NE(nullptr, deno_last_exception(d));
|
|
EXPECT_EQ(1, resolve_count);
|
|
EXPECT_EQ(0, exec_count);
|
|
|
|
deno_delete(d);
|
|
}
|
|
|
|
TEST(ModulesTest, ImportMetaUrl) {
|
|
exec_count = 0; // Reset
|
|
Deno* d = deno_new(deno_config{0, empty_snapshot, empty, recv_cb, nullptr});
|
|
EXPECT_EQ(0, exec_count);
|
|
|
|
static deno_mod a =
|
|
deno_mod_new(d, true, "a.js",
|
|
"if ('a.js' != import.meta.url) throw 'hmm'\n"
|
|
"Deno.core.send(42, new Uint8Array([4]));");
|
|
EXPECT_NE(a, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
deno_mod_instantiate(d, d, a, nullptr);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
EXPECT_EQ(0, exec_count);
|
|
|
|
deno_mod_evaluate(d, d, a);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
EXPECT_EQ(1, exec_count);
|
|
}
|
|
|
|
TEST(ModulesTest, ImportMetaMain) {
|
|
Deno* d = deno_new(deno_config{0, empty_snapshot, empty, recv_cb, nullptr});
|
|
|
|
const char* throw_not_main_src = "if (!import.meta.main) throw 'err'";
|
|
static deno_mod throw_not_main =
|
|
deno_mod_new(d, true, "a.js", throw_not_main_src);
|
|
EXPECT_NE(throw_not_main, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
deno_mod_instantiate(d, d, throw_not_main, nullptr);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
deno_mod_evaluate(d, d, throw_not_main);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
const char* throw_main_src = "if (import.meta.main) throw 'err'";
|
|
static deno_mod throw_main = deno_mod_new(d, false, "b.js", throw_main_src);
|
|
EXPECT_NE(throw_main, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
deno_mod_instantiate(d, d, throw_main, nullptr);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
deno_mod_evaluate(d, d, throw_main);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
deno_delete(d);
|
|
}
|
|
|
|
TEST(ModulesTest, DynamicImportSuccess) {
|
|
exec_count = 0;
|
|
static int dyn_import_count = 0;
|
|
static deno_mod b = 0;
|
|
auto dyn_import_cb = [](auto user_data, const char* specifier,
|
|
const char* referrer, deno_dyn_import_id import_id) {
|
|
auto d = reinterpret_cast<Deno*>(user_data);
|
|
dyn_import_count++;
|
|
EXPECT_STREQ(specifier, "foo");
|
|
EXPECT_STREQ(referrer, "a.js");
|
|
deno_dyn_import_done(d, d, import_id, b, nullptr);
|
|
};
|
|
const char* src =
|
|
"(async () => { \n"
|
|
" let mod = await import('foo'); \n"
|
|
" assert(mod.b() === 'b'); \n"
|
|
// Send a message to signify that we're done.
|
|
" Deno.core.send(42, new Uint8Array([4])); \n"
|
|
"})(); \n";
|
|
Deno* d = deno_new(deno_config{0, snapshot, empty, recv_cb, dyn_import_cb});
|
|
static deno_mod a = deno_mod_new(d, true, "a.js", src);
|
|
EXPECT_NE(a, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_instantiate(d, d, a, nullptr);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
const char* b_src = "export function b() { return 'b' }";
|
|
b = deno_mod_new(d, false, "b.js", b_src);
|
|
EXPECT_NE(b, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_instantiate(d, d, b, nullptr);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_evaluate(d, d, b);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_evaluate(d, d, a);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_check_promise_errors(d);
|
|
EXPECT_EQ(deno_last_exception(d), nullptr);
|
|
deno_delete(d);
|
|
EXPECT_EQ(1, exec_count);
|
|
EXPECT_EQ(1, dyn_import_count);
|
|
}
|
|
|
|
TEST(ModulesTest, DynamicImportError) {
|
|
exec_count = 0;
|
|
static int dyn_import_count = 0;
|
|
auto dyn_import_cb = [](auto user_data, const char* specifier,
|
|
const char* referrer, deno_dyn_import_id import_id) {
|
|
auto d = reinterpret_cast<Deno*>(user_data);
|
|
dyn_import_count++;
|
|
EXPECT_STREQ(specifier, "foo");
|
|
EXPECT_STREQ(referrer, "a.js");
|
|
// We indicate there was an error resolving by returning mod_id 0.
|
|
deno_dyn_import_done(d, d, import_id, 0, "foo not found");
|
|
};
|
|
const char* src =
|
|
"(async () => { \n"
|
|
" let mod = await import('foo'); \n"
|
|
// The following should be unreachable.
|
|
" Deno.core.send(42, new Uint8Array([4])); \n"
|
|
"})(); \n";
|
|
Deno* d = deno_new(deno_config{0, snapshot, empty, recv_cb, dyn_import_cb});
|
|
static deno_mod a = deno_mod_new(d, true, "a.js", src);
|
|
EXPECT_NE(a, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_instantiate(d, d, a, nullptr);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
// No error when evaluating, because it's an async error.
|
|
deno_mod_evaluate(d, d, a);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
// Now we should get an error.
|
|
deno_check_promise_errors(d);
|
|
EXPECT_NE(deno_last_exception(d), nullptr);
|
|
std::string e(deno_last_exception(d));
|
|
EXPECT_NE(e.find("Uncaught TypeError: foo not found"), std::string::npos);
|
|
deno_delete(d);
|
|
EXPECT_EQ(0, exec_count);
|
|
EXPECT_EQ(1, dyn_import_count);
|
|
}
|
|
|
|
TEST(ModulesTest, DynamicImportAsync) {
|
|
exec_count = 0;
|
|
static int dyn_import_count = 0;
|
|
static deno_mod b = 0;
|
|
static std::vector<deno_dyn_import_id> import_ids = {};
|
|
auto dyn_import_cb = [](auto user_data, const char* specifier,
|
|
const char* referrer, deno_dyn_import_id import_id) {
|
|
// auto d = reinterpret_cast<Deno*>(user_data);
|
|
dyn_import_count++;
|
|
EXPECT_STREQ(specifier, "foo");
|
|
EXPECT_STREQ(referrer, "a.js");
|
|
// We don't call deno_dyn_import_done until later.
|
|
import_ids.push_back(import_id);
|
|
};
|
|
const char* src =
|
|
"(async () => { \n"
|
|
" let mod = await import('foo'); \n"
|
|
" assert(mod.b() === 'b'); \n"
|
|
// AGAIN!
|
|
" mod = await import('foo'); \n"
|
|
" assert(mod.b() === 'b'); \n"
|
|
// Send a message to signify that we're done.
|
|
" Deno.core.send(42, new Uint8Array([4])); \n"
|
|
"})(); \n";
|
|
Deno* d = deno_new(deno_config{0, snapshot, empty, recv_cb, dyn_import_cb});
|
|
static deno_mod a = deno_mod_new(d, true, "a.js", src);
|
|
EXPECT_NE(a, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_instantiate(d, d, a, nullptr);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
// Evaluate. We check that there are no errors, and Deno.core.send has not
|
|
// been called.
|
|
deno_mod_evaluate(d, d, a);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_check_promise_errors(d);
|
|
EXPECT_EQ(deno_last_exception(d), nullptr);
|
|
EXPECT_EQ(0, exec_count);
|
|
EXPECT_EQ(1, dyn_import_count);
|
|
|
|
// Instantiate b.js
|
|
const char* b_src = "export function b() { return 'b' }";
|
|
b = deno_mod_new(d, false, "b.js", b_src);
|
|
EXPECT_NE(b, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_instantiate(d, d, b, nullptr);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_evaluate(d, d, b);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
// Now we resolve the import.
|
|
EXPECT_EQ(1u, import_ids.size());
|
|
auto import_id = import_ids.back();
|
|
import_ids.pop_back();
|
|
|
|
deno_dyn_import_done(d, d, import_id, b, nullptr);
|
|
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_check_promise_errors(d);
|
|
EXPECT_EQ(deno_last_exception(d), nullptr);
|
|
|
|
EXPECT_EQ(1u, import_ids.size());
|
|
EXPECT_EQ(2, dyn_import_count);
|
|
EXPECT_EQ(0, exec_count);
|
|
|
|
import_id = import_ids.back();
|
|
import_ids.pop_back();
|
|
deno_dyn_import_done(d, d, import_id, b, nullptr);
|
|
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_check_promise_errors(d);
|
|
EXPECT_EQ(deno_last_exception(d), nullptr);
|
|
|
|
// We still have to resolve the second one
|
|
EXPECT_EQ(2, dyn_import_count);
|
|
EXPECT_EQ(1, exec_count);
|
|
|
|
deno_delete(d);
|
|
}
|
|
|
|
TEST(ModulesTest, DynamicImportThrows) {
|
|
exec_count = 0;
|
|
static int dyn_import_count = 0;
|
|
static deno_mod b = 0;
|
|
static std::vector<deno_dyn_import_id> import_ids = {};
|
|
auto dyn_import_cb = [](auto user_data, const char* specifier,
|
|
const char* referrer, deno_dyn_import_id import_id) {
|
|
dyn_import_count++;
|
|
EXPECT_STREQ(specifier, "b.js");
|
|
EXPECT_STREQ(referrer, "a.js");
|
|
// We don't call deno_dyn_import_done until later.
|
|
import_ids.push_back(import_id);
|
|
};
|
|
Deno* d = deno_new(deno_config{0, snapshot, empty, recv_cb, dyn_import_cb});
|
|
|
|
// Instantiate and evaluate the root module. This should succeed.
|
|
const char* a_src =
|
|
"(async () => { \n"
|
|
" let mod = await import('b.js'); \n"
|
|
// unreachable
|
|
" Deno.core.send(42, new Uint8Array([4])); \n"
|
|
"})(); \n";
|
|
static deno_mod a = deno_mod_new(d, true, "a.js", a_src);
|
|
EXPECT_NE(a, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_instantiate(d, d, a, nullptr);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_evaluate(d, d, a);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_check_promise_errors(d);
|
|
EXPECT_EQ(deno_last_exception(d), nullptr);
|
|
|
|
// Instantiate b.js, which should succeed.
|
|
const char* b_src = "throw new Error('foo')";
|
|
b = deno_mod_new(d, false, "b.js", b_src);
|
|
EXPECT_NE(b, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_instantiate(d, d, b, nullptr);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
// Evaluate b.js. It throws in the global scope, so deno_last_exception()
|
|
// should be non-null afterwards.
|
|
deno_mod_evaluate(d, d, b);
|
|
EXPECT_NE(deno_last_exception(d), nullptr);
|
|
|
|
// Resolve the dynamic import of b.js. Since deno_mod_evaluate() failed,
|
|
// we indicate failure to deno_dyn_import_done() by setting mod_id to 0.
|
|
// The last error should be picked up and cleared by deno_dyn_import_done().
|
|
EXPECT_EQ(1u, import_ids.size());
|
|
auto import_id = import_ids.back();
|
|
import_ids.pop_back();
|
|
deno_dyn_import_done(d, d, import_id, 0, nullptr);
|
|
EXPECT_EQ(deno_last_exception(d), nullptr);
|
|
|
|
// Since the dynamically imported module threw an error,
|
|
// it should show up as an unhandled promise rejection.
|
|
deno_check_promise_errors(d);
|
|
EXPECT_NE(deno_last_exception(d), nullptr);
|
|
std::string e(deno_last_exception(d));
|
|
EXPECT_NE(e.find("Uncaught Error: foo"), std::string::npos);
|
|
|
|
EXPECT_EQ(1, dyn_import_count);
|
|
EXPECT_EQ(0, exec_count);
|
|
|
|
deno_delete(d);
|
|
}
|
|
|
|
TEST(ModulesTest, DynamicImportSyntaxError) {
|
|
exec_count = 0;
|
|
static int dyn_import_count = 0;
|
|
auto dyn_import_cb = [](auto user_data, const char* specifier,
|
|
const char* referrer, deno_dyn_import_id import_id) {
|
|
auto d = reinterpret_cast<Deno*>(user_data);
|
|
dyn_import_count++;
|
|
EXPECT_STREQ(specifier, "b.js");
|
|
EXPECT_STREQ(referrer, "a.js");
|
|
|
|
// Compile b.js, which should fail because of the syntax error.
|
|
deno_mod b = deno_mod_new(d, false, "b.js", "syntax error");
|
|
EXPECT_EQ(b, 0);
|
|
EXPECT_NE(nullptr, deno_last_exception(d));
|
|
|
|
// `deno_dyn_import_done` should consume the last exception, and use it
|
|
// to reject the dynamic import promise.
|
|
deno_dyn_import_done(d, d, import_id, 0, nullptr);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
};
|
|
Deno* d = deno_new(deno_config{0, snapshot, empty, recv_cb, dyn_import_cb});
|
|
|
|
// Instantiate and evaluate the root module. This should succeed.
|
|
const char* src =
|
|
"(async () => { \n"
|
|
" let mod = await import('b.js'); \n"
|
|
// unreachable
|
|
" Deno.core.send(42, new Uint8Array([4])); \n"
|
|
"})(); \n";
|
|
static deno_mod a = deno_mod_new(d, true, "a.js", src);
|
|
EXPECT_NE(a, 0);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_instantiate(d, d, a, nullptr);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
deno_mod_evaluate(d, d, a);
|
|
EXPECT_EQ(nullptr, deno_last_exception(d));
|
|
|
|
// The failed dynamic import should cause an unhandled promise rejection.
|
|
deno_check_promise_errors(d);
|
|
EXPECT_NE(deno_last_exception(d), nullptr);
|
|
EXPECT_NE(std::string(deno_last_exception(d)).find("Syntax"),
|
|
std::string::npos);
|
|
|
|
EXPECT_EQ(1, dyn_import_count);
|
|
EXPECT_EQ(0, exec_count);
|
|
|
|
deno_delete(d);
|
|
}
|