diff --git a/src/node_worker.cc b/src/node_worker.cc index a407cb956df2da..cc3a8cdd1c9425 100644 --- a/src/node_worker.cc +++ b/src/node_worker.cc @@ -400,63 +400,64 @@ void Worker::New(const FunctionCallbackInfo& args) { std::vector exec_argv_out; bool has_explicit_exec_argv = false; + CHECK_EQ(args.Length(), 2); // Argument might be a string or URL - if (args.Length() > 0 && !args[0]->IsNullOrUndefined()) { + if (!args[0]->IsNullOrUndefined()) { Utf8Value value( args.GetIsolate(), args[0]->ToString(env->context()).FromMaybe(v8::Local())); url.append(value.out(), value.length()); + } - if (args.Length() > 1 && args[1]->IsArray()) { - v8::Local array = args[1].As(); - // The first argument is reserved for program name, but we don't need it - // in workers. - has_explicit_exec_argv = true; - std::vector exec_argv = {""}; - uint32_t length = array->Length(); - for (uint32_t i = 0; i < length; i++) { - v8::Local arg; - if (!array->Get(env->context(), i).ToLocal(&arg)) { - return; - } - v8::MaybeLocal arg_v8_string = - arg->ToString(env->context()); - if (arg_v8_string.IsEmpty()) { - return; - } - Utf8Value arg_utf8_value( - args.GetIsolate(), - arg_v8_string.FromMaybe(v8::Local())); - std::string arg_string(arg_utf8_value.out(), arg_utf8_value.length()); - exec_argv.push_back(arg_string); + if (args[1]->IsArray()) { + v8::Local array = args[1].As(); + // The first argument is reserved for program name, but we don't need it + // in workers. + has_explicit_exec_argv = true; + std::vector exec_argv = {""}; + uint32_t length = array->Length(); + for (uint32_t i = 0; i < length; i++) { + v8::Local arg; + if (!array->Get(env->context(), i).ToLocal(&arg)) { + return; } - - std::vector invalid_args{}; - std::vector errors{}; - per_isolate_opts.reset(new PerIsolateOptions()); - - // Using invalid_args as the v8_args argument as it stores unknown - // options for the per isolate parser. - options_parser::Parse( - &exec_argv, - &exec_argv_out, - &invalid_args, - per_isolate_opts.get(), - kDisallowedInEnvironment, - &errors); - - // The first argument is program name. - invalid_args.erase(invalid_args.begin()); - if (errors.size() > 0 || invalid_args.size() > 0) { - v8::Local error = - ToV8Value(env->context(), - errors.size() > 0 ? errors : invalid_args) - .ToLocalChecked(); - Local key = - FIXED_ONE_BYTE_STRING(env->isolate(), "invalidExecArgv"); - USE(args.This()->Set(env->context(), key, error).FromJust()); + v8::MaybeLocal arg_v8_string = + arg->ToString(env->context()); + if (arg_v8_string.IsEmpty()) { return; } + Utf8Value arg_utf8_value( + args.GetIsolate(), + arg_v8_string.FromMaybe(v8::Local())); + std::string arg_string(arg_utf8_value.out(), arg_utf8_value.length()); + exec_argv.push_back(arg_string); + } + + std::vector invalid_args{}; + std::vector errors{}; + per_isolate_opts.reset(new PerIsolateOptions()); + + // Using invalid_args as the v8_args argument as it stores unknown + // options for the per isolate parser. + options_parser::Parse( + &exec_argv, + &exec_argv_out, + &invalid_args, + per_isolate_opts.get(), + kDisallowedInEnvironment, + &errors); + + // The first argument is program name. + invalid_args.erase(invalid_args.begin()); + if (errors.size() > 0 || invalid_args.size() > 0) { + v8::Local error = + ToV8Value(env->context(), + errors.size() > 0 ? errors : invalid_args) + .ToLocalChecked(); + Local key = + FIXED_ONE_BYTE_STRING(env->isolate(), "invalidExecArgv"); + USE(args.This()->Set(env->context(), key, error).FromJust()); + return; } } if (!has_explicit_exec_argv) diff --git a/test/parallel/test-worker-execargv.js b/test/parallel/test-worker-execargv.js index 16e46f2468dfe4..a2b52216165d77 100644 --- a/test/parallel/test-worker-execargv.js +++ b/test/parallel/test-worker-execargv.js @@ -19,6 +19,13 @@ if (!process.env.HAS_STARTED_WORKER) { /Warning: some warning[\s\S]*at Object\./.test(error) ); })); + + new Worker( + "require('worker_threads').parentPort.postMessage(process.execArgv)", + { eval: true, execArgv: ['--trace-warnings'] }) + .on('message', common.mustCall((data) => { + assert.deepStrictEqual(data, ['--trace-warnings']); + })); } else { process.emitWarning('some warning'); assert.deepStrictEqual(process.execArgv, ['--trace-warnings']);