Head

GCC Code Coverage Report

Directory:	./		Exec	Total	Coverage
File:	inspector_js_api.cc	Lines:	191	211	90.5 %
Date:	2022-06-13 04:15:40	Branches:	37	78	47.4 %


#include "base_object-inl.h"
#include "inspector_agent.h"
#include "inspector_io.h"
#include "memory_tracker-inl.h"
#include "node_external_reference.h"
#include "util-inl.h"
#include "v8-inspector.h"
#include "v8.h"

#include <memory>

namespace node {
namespace inspector {
namespace {

using v8::Context;
using v8::Function;
using v8::FunctionCallbackInfo;
using v8::FunctionTemplate;
using v8::Global;
using v8::HandleScope;
using v8::Isolate;
using v8::Local;
using v8::MaybeLocal;
using v8::NewStringType;
using v8::Object;
using v8::String;
using v8::Uint32;
using v8::Value;

using v8_inspector::StringBuffer;
using v8_inspector::StringView;

std::unique_ptr<StringBuffer> ToProtocolString(Isolate* isolate,
                                               Local<Value> value) {
  TwoByteValue buffer(isolate, value);
  return StringBuffer::create(StringView(*buffer, buffer.length()));
}

struct LocalConnection {
  static std::unique_ptr<InspectorSession> Connect(
      Agent* inspector, std::unique_ptr<InspectorSessionDelegate> delegate) {
    return inspector->Connect(std::move(delegate), false);
  }

  static Local<String> GetClassName(Environment* env) {
    return FIXED_ONE_BYTE_STRING(env->isolate(), "Connection");
  }
};

struct MainThreadConnection {
  static std::unique_ptr<InspectorSession> Connect(
      Agent* inspector, std::unique_ptr<InspectorSessionDelegate> delegate) {
    return inspector->ConnectToMainThread(std::move(delegate), true);
  }

  static Local<String> GetClassName(Environment* env) {
    return FIXED_ONE_BYTE_STRING(env->isolate(), "MainThreadConnection");
  }
};

template <typename ConnectionType>
class JSBindingsConnection : public AsyncWrap {
 public:
  class JSBindingsSessionDelegate : public InspectorSessionDelegate {
   public:
    JSBindingsSessionDelegate(Environment* env,
                              JSBindingsConnection* connection)
                              : env_(env),
                                connection_(connection) {
    }

    void SendMessageToFrontend(const v8_inspector::StringView& message)
        override {
      Isolate* isolate = env_->isolate();
      HandleScope handle_scope(isolate);
      Context::Scope context_scope(env_->context());
      Local<Value> argument;
      if (!String::NewFromTwoByte(isolate, message.characters16(),
                                  NewStringType::kNormal,
                                  message.length()).ToLocal(&argument)) return;
      connection_->OnMessage(argument);
    }

   private:
    Environment* env_;
    BaseObjectPtr<JSBindingsConnection> connection_;
  };

  JSBindingsConnection(Environment* env,
                       Local<Object> wrap,
                       Local<Function> callback)
                       : AsyncWrap(env, wrap, PROVIDER_INSPECTORJSBINDING),
                         callback_(env->isolate(), callback) {
    Agent* inspector = env->inspector_agent();
    session_ = ConnectionType::Connect(
        inspector, std::make_unique<JSBindingsSessionDelegate>(env, this));
  }

  void OnMessage(Local<Value> value) {
    MakeCallback(callback_.Get(env()->isolate()), 1, &value);
  }

  static void Bind(Environment* env, Local<Object> target) {
    Local<FunctionTemplate> tmpl =
        env->NewFunctionTemplate(JSBindingsConnection::New);
    tmpl->InstanceTemplate()->SetInternalFieldCount(
        JSBindingsConnection::kInternalFieldCount);
    tmpl->Inherit(AsyncWrap::GetConstructorTemplate(env));
    env->SetProtoMethod(tmpl, "dispatch", JSBindingsConnection::Dispatch);
    env->SetProtoMethod(tmpl, "disconnect", JSBindingsConnection::Disconnect);
    env->SetConstructorFunction(
        target,
        ConnectionType::GetClassName(env),
        tmpl);
  }

  static void New(const FunctionCallbackInfo<Value>& info) {
    Environment* env = Environment::GetCurrent(info);
    CHECK(info[0]->IsFunction());
    Local<Function> callback = info[0].As<Function>();
    new JSBindingsConnection(env, info.This(), callback);
  }

  void Disconnect() {
    session_.reset();
    delete this;
  }

  static void Disconnect(const FunctionCallbackInfo<Value>& info) {
    JSBindingsConnection* session;
    ASSIGN_OR_RETURN_UNWRAP(&session, info.Holder());
    session->Disconnect();
  }

  static void Dispatch(const FunctionCallbackInfo<Value>& info) {
    Environment* env = Environment::GetCurrent(info);
    JSBindingsConnection* session;
    ASSIGN_OR_RETURN_UNWRAP(&session, info.Holder());
    CHECK(info[0]->IsString());

    if (session->session_) {
      session->session_->Dispatch(
          ToProtocolString(env->isolate(), info[0])->string());
    }
  }

  void MemoryInfo(MemoryTracker* tracker) const override {
    tracker->TrackField("callback", callback_);
    tracker->TrackFieldWithSize(
        "session", sizeof(*session_), "InspectorSession");
  }

  SET_MEMORY_INFO_NAME(JSBindingsConnection)
  SET_SELF_SIZE(JSBindingsConnection)

  bool IsNotIndicativeOfMemoryLeakAtExit() const override {
    return true;  // Binding connections emit events on their own.
  }

 private:
  std::unique_ptr<InspectorSession> session_;
  Global<Function> callback_;
};

static bool InspectorEnabled(Environment* env) {
  Agent* agent = env->inspector_agent();
  return agent->IsActive();
}

void SetConsoleExtensionInstaller(const FunctionCallbackInfo<Value>& info) {
  auto env = Environment::GetCurrent(info);

  CHECK_EQ(info.Length(), 1);
  CHECK(info[0]->IsFunction());

  env->set_inspector_console_extension_installer(info[0].As<Function>());
}

void CallAndPauseOnStart(const FunctionCallbackInfo<v8::Value>& args) {
  Environment* env = Environment::GetCurrent(args);
  CHECK_GT(args.Length(), 1);
  CHECK(args[0]->IsFunction());
  SlicedArguments call_args(args, /* start */ 2);
  env->inspector_agent()->PauseOnNextJavascriptStatement("Break on start");
  v8::MaybeLocal<v8::Value> retval =
      args[0].As<v8::Function>()->Call(env->context(), args[1],
                                       call_args.length(), call_args.out());
  if (!retval.IsEmpty()) {
    args.GetReturnValue().Set(retval.ToLocalChecked());
  }
}

void InspectorConsoleCall(const FunctionCallbackInfo<Value>& info) {
  Environment* env = Environment::GetCurrent(info);
  Isolate* isolate = env->isolate();
  Local<Context> context = isolate->GetCurrentContext();
  CHECK_GE(info.Length(), 2);
  SlicedArguments call_args(info, /* start */ 2);
  if (InspectorEnabled(env)) {
    Local<Value> inspector_method = info[0];
    CHECK(inspector_method->IsFunction());
    if (!env->is_in_inspector_console_call()) {
      env->set_is_in_inspector_console_call(true);
      MaybeLocal<Value> ret =
          inspector_method.As<Function>()->Call(context,
                                                info.Holder(),
                                                call_args.length(),
                                                call_args.out());
      env->set_is_in_inspector_console_call(false);
      if (ret.IsEmpty())
        return;
    }
  }

  Local<Value> node_method = info[1];
  CHECK(node_method->IsFunction());
  USE(node_method.As<Function>()->Call(context,
                                   info.Holder(),
                                   call_args.length(),
                                   call_args.out()));
}

static void* GetAsyncTask(int64_t asyncId) {
  // The inspector assumes that when other clients use its asyncTask* API,
  // they use real pointers, or at least something aligned like real pointer.
  // In general it means that our task_id should always be even.
  //
  // On 32bit platforms, the 64bit asyncId would get truncated when converted
  // to a 32bit pointer. However, the javascript part will never enable
  // the async_hook on 32bit platforms, therefore the truncation will never
  // happen in practice.
  return reinterpret_cast<void*>(asyncId << 1);
}

template <void (Agent::*asyncTaskFn)(void*)>
static void InvokeAsyncTaskFnWithId(const FunctionCallbackInfo<Value>& args) {
  Environment* env = Environment::GetCurrent(args);
  CHECK(args[0]->IsNumber());
  int64_t task_id = args[0]->IntegerValue(env->context()).FromJust();
  (env->inspector_agent()->*asyncTaskFn)(GetAsyncTask(task_id));
}

static void AsyncTaskScheduledWrapper(const FunctionCallbackInfo<Value>& args) {
  Environment* env = Environment::GetCurrent(args);

  CHECK(args[0]->IsString());
  Local<String> task_name = args[0].As<String>();
  String::Value task_name_value(args.GetIsolate(), task_name);
  StringView task_name_view(*task_name_value, task_name_value.length());

  CHECK(args[1]->IsNumber());
  int64_t task_id = args[1]->IntegerValue(env->context()).FromJust();
  void* task = GetAsyncTask(task_id);

  CHECK(args[2]->IsBoolean());
  bool recurring = args[2]->BooleanValue(args.GetIsolate());

  env->inspector_agent()->AsyncTaskScheduled(task_name_view, task, recurring);
}

static void RegisterAsyncHookWrapper(const FunctionCallbackInfo<Value>& args) {
  Environment* env = Environment::GetCurrent(args);

  CHECK(args[0]->IsFunction());
  Local<Function> enable_function = args[0].As<Function>();
  CHECK(args[1]->IsFunction());
  Local<Function> disable_function = args[1].As<Function>();
  env->inspector_agent()->RegisterAsyncHook(env->isolate(),
    enable_function, disable_function);
}

void IsEnabled(const FunctionCallbackInfo<Value>& args) {
  Environment* env = Environment::GetCurrent(args);
  args.GetReturnValue().Set(InspectorEnabled(env));
}

void Open(const FunctionCallbackInfo<Value>& args) {
  Environment* env = Environment::GetCurrent(args);
  Agent* agent = env->inspector_agent();

  if (args.Length() > 0 && args[0]->IsUint32()) {
    uint32_t port = args[0].As<Uint32>()->Value();
    ExclusiveAccess<HostPort>::Scoped host_port(agent->host_port());
    host_port->set_port(static_cast<int>(port));
  }

  if (args.Length() > 1 && args[1]->IsString()) {
    Utf8Value host(env->isolate(), args[1].As<String>());
    ExclusiveAccess<HostPort>::Scoped host_port(agent->host_port());
    host_port->set_host(*host);
  }

  agent->StartIoThread();
}

void WaitForDebugger(const FunctionCallbackInfo<Value>& args) {
  Environment* env = Environment::GetCurrent(args);
  Agent* agent = env->inspector_agent();
  if (agent->IsActive())
    agent->WaitForConnect();
  args.GetReturnValue().Set(agent->IsActive());
}

void Url(const FunctionCallbackInfo<Value>& args) {
  Environment* env = Environment::GetCurrent(args);
  std::string url = env->inspector_agent()->GetWsUrl();
  if (url.empty()) {
    return;
  }
  args.GetReturnValue().Set(OneByteString(env->isolate(), url.c_str()));
}

void Initialize(Local<Object> target, Local<Value> unused,
                Local<Context> context, void* priv) {
  Environment* env = Environment::GetCurrent(context);

  v8::Local<v8::Function> consoleCallFunc =
      env->NewFunctionTemplate(InspectorConsoleCall, v8::Local<v8::Signature>(),
                               v8::ConstructorBehavior::kThrow,
                               v8::SideEffectType::kHasSideEffect)
          ->GetFunction(context)
          .ToLocalChecked();
  auto name_string = FIXED_ONE_BYTE_STRING(env->isolate(), "consoleCall");
  target->Set(context, name_string, consoleCallFunc).Check();
  consoleCallFunc->SetName(name_string);

  env->SetMethod(
      target, "setConsoleExtensionInstaller", SetConsoleExtensionInstaller);
  env->SetMethod(target, "callAndPauseOnStart", CallAndPauseOnStart);
  env->SetMethod(target, "open", Open);
  env->SetMethodNoSideEffect(target, "url", Url);
  env->SetMethod(target, "waitForDebugger", WaitForDebugger);

  env->SetMethod(target, "asyncTaskScheduled", AsyncTaskScheduledWrapper);
  env->SetMethod(target, "asyncTaskCanceled",
      InvokeAsyncTaskFnWithId<&Agent::AsyncTaskCanceled>);
  env->SetMethod(target, "asyncTaskStarted",
      InvokeAsyncTaskFnWithId<&Agent::AsyncTaskStarted>);
  env->SetMethod(target, "asyncTaskFinished",
      InvokeAsyncTaskFnWithId<&Agent::AsyncTaskFinished>);

  env->SetMethod(target, "registerAsyncHook", RegisterAsyncHookWrapper);
  env->SetMethodNoSideEffect(target, "isEnabled", IsEnabled);

  Local<String> console_string =
      FIXED_ONE_BYTE_STRING(env->isolate(), "console");

  // Grab the console from the binding object and expose those to our binding
  // layer.
  Local<Object> binding = context->GetExtrasBindingObject();
  target
      ->Set(context,
            console_string,
            binding->Get(context, console_string).ToLocalChecked())
      .Check();

  JSBindingsConnection<LocalConnection>::Bind(env, target);
  JSBindingsConnection<MainThreadConnection>::Bind(env, target);
}

}  // namespace

void RegisterExternalReferences(ExternalReferenceRegistry* registry) {
  registry->Register(InspectorConsoleCall);
  registry->Register(SetConsoleExtensionInstaller);
  registry->Register(CallAndPauseOnStart);
  registry->Register(Open);
  registry->Register(Url);
  registry->Register(WaitForDebugger);

  registry->Register(AsyncTaskScheduledWrapper);
  registry->Register(InvokeAsyncTaskFnWithId<&Agent::AsyncTaskCanceled>);
  registry->Register(InvokeAsyncTaskFnWithId<&Agent::AsyncTaskStarted>);
  registry->Register(InvokeAsyncTaskFnWithId<&Agent::AsyncTaskFinished>);

  registry->Register(RegisterAsyncHookWrapper);
  registry->Register(IsEnabled);

  registry->Register(JSBindingsConnection<LocalConnection>::New);
  registry->Register(JSBindingsConnection<LocalConnection>::Dispatch);
  registry->Register(JSBindingsConnection<LocalConnection>::Disconnect);
  registry->Register(JSBindingsConnection<MainThreadConnection>::New);
  registry->Register(JSBindingsConnection<MainThreadConnection>::Dispatch);
  registry->Register(JSBindingsConnection<MainThreadConnection>::Disconnect);
}

}  // namespace inspector
}  // namespace node

NODE_MODULE_CONTEXT_AWARE_INTERNAL(inspector,
                                  node::inspector::Initialize)
NODE_MODULE_EXTERNAL_REFERENCE(inspector,
                               node::inspector::RegisterExternalReferences)


Generated by: GCOVR (Version 4.2)

Line	Branch	Exec	Source
1			#include "base_object-inl.h"
2			#include "inspector_agent.h"
3			#include "inspector_io.h"
4			#include "memory_tracker-inl.h"
5			#include "node_external_reference.h"
6			#include "util-inl.h"
7			#include "v8-inspector.h"
8			#include "v8.h"
9
10			#include <memory>
11
12			namespace node {
13			namespace inspector {
14			namespace {
15
16			using v8::Context;
17			using v8::Function;
18			using v8::FunctionCallbackInfo;
19			using v8::FunctionTemplate;
20			using v8::Global;
21			using v8::HandleScope;
22			using v8::Isolate;
23			using v8::Local;
24			using v8::MaybeLocal;
25			using v8::NewStringType;
26			using v8::Object;
27			using v8::String;
28			using v8::Uint32;
29			using v8::Value;
30
31			using v8_inspector::StringBuffer;
32			using v8_inspector::StringView;
33
34		1230	std::unique_ptr<StringBuffer> ToProtocolString(Isolate* isolate,
35			Local<Value> value) {
36		1230	TwoByteValue buffer(isolate, value);
37		1230	return StringBuffer::create(StringView(*buffer, buffer.length()));
38			}
39
40			struct LocalConnection {
41		919	static std::unique_ptr<InspectorSession> Connect(
42			Agent* inspector, std::unique_ptr<InspectorSessionDelegate> delegate) {
43		919	return inspector->Connect(std::move(delegate), false);
44			}
45
46		854	static Local<String> GetClassName(Environment* env) {
47		854	return FIXED_ONE_BYTE_STRING(env->isolate(), "Connection");
48			}
49			};
50
51			struct MainThreadConnection {
52		2	static std::unique_ptr<InspectorSession> Connect(
53			Agent* inspector, std::unique_ptr<InspectorSessionDelegate> delegate) {
54		2	return inspector->ConnectToMainThread(std::move(delegate), true);
55			}
56
57		854	static Local<String> GetClassName(Environment* env) {
58		854	return FIXED_ONE_BYTE_STRING(env->isolate(), "MainThreadConnection");
59			}
60			};
61
62			template <typename ConnectionType>
63			class JSBindingsConnection : public AsyncWrap {
64			public:
65			class JSBindingsSessionDelegate : public InspectorSessionDelegate {
66			public:
67		1842	JSBindingsSessionDelegate(Environment* env,
68			JSBindingsConnection* connection)
69			: env_(env),
70		1842	connection_(connection) {
71		1842	}
72
73		14118	void SendMessageToFrontend(const v8_inspector::StringView& message)
74			override {
75		14118	Isolate* isolate = env_->isolate();
76		14118	HandleScope handle_scope(isolate);
77		28236	Context::Scope context_scope(env_->context());
78			Local<Value> argument;
79		14118	if (!String::NewFromTwoByte(isolate, message.characters16(),
80			NewStringType::kNormal,
81	✗✓	28236	message.length()).ToLocal(&argument)) return;
82		14118	connection_->OnMessage(argument);
83			}
84
85			private:
86			Environment* env_;
87			BaseObjectPtr<JSBindingsConnection> connection_;
88			};
89
90		1842	JSBindingsConnection(Environment* env,
91			Local<Object> wrap,
92			Local<Function> callback)
93			: AsyncWrap(env, wrap, PROVIDER_INSPECTORJSBINDING),
94		1842	callback_(env->isolate(), callback) {
95		1842	Agent* inspector = env->inspector_agent();
96		1842	session_ = ConnectionType::Connect(
97			inspector, std::make_unique<JSBindingsSessionDelegate>(env, this));
98		1842	}
99
100		14118	void OnMessage(Local<Value> value) {
101		28236	MakeCallback(callback_.Get(env()->isolate()), 1, &value);
102		14118	}
103
104		3416	static void Bind(Environment* env, Local<Object> target) {
105			Local<FunctionTemplate> tmpl =
106		3416	env->NewFunctionTemplate(JSBindingsConnection::New);
107		6832	tmpl->InstanceTemplate()->SetInternalFieldCount(
108			JSBindingsConnection::kInternalFieldCount);
109		3416	tmpl->Inherit(AsyncWrap::GetConstructorTemplate(env));
110		3416	env->SetProtoMethod(tmpl, "dispatch", JSBindingsConnection::Dispatch);
111		3416	env->SetProtoMethod(tmpl, "disconnect", JSBindingsConnection::Disconnect);
112		3416	env->SetConstructorFunction(
113			target,
114			ConnectionType::GetClassName(env),
115			tmpl);
116		3416	}
117
118		1842	static void New(const FunctionCallbackInfo<Value>& info) {
119		1842	Environment* env = Environment::GetCurrent(info);
120	✗✓	1842	CHECK(info[0]->IsFunction());
121		3684	Local<Function> callback = info[0].As<Function>();
122		1842	new JSBindingsConnection(env, info.This(), callback);
123		1842	}
124
125		1812	void Disconnect() {
126		1812	session_.reset();
127	✓✗	1812	delete this;
128			}
129
130		1812	static void Disconnect(const FunctionCallbackInfo<Value>& info) {
131			JSBindingsConnection* session;
132	✗✓	1812	ASSIGN_OR_RETURN_UNWRAP(&session, info.Holder());
133		1812	session->Disconnect();
134			}
135
136		2460	static void Dispatch(const FunctionCallbackInfo<Value>& info) {
137		2460	Environment* env = Environment::GetCurrent(info);
138			JSBindingsConnection* session;
139	✗✓	2460	ASSIGN_OR_RETURN_UNWRAP(&session, info.Holder());
140	✗✓	4920	CHECK(info[0]->IsString());
141
142	✓✗	2460	if (session->session_) {
143	✓✗	4920	session->session_->Dispatch(
144		4920	ToProtocolString(env->isolate(), info[0])->string());
145			}
146			}
147
148		4	void MemoryInfo(MemoryTracker* tracker) const override {
149		4	tracker->TrackField("callback", callback_);
150		4	tracker->TrackFieldWithSize(
151			"session", sizeof(*session_), "InspectorSession");
152			}
153
154		4	SET_MEMORY_INFO_NAME(JSBindingsConnection)
155		2	SET_SELF_SIZE(JSBindingsConnection)
156
157			bool IsNotIndicativeOfMemoryLeakAtExit() const override {
158			return true; // Binding connections emit events on their own.
159			}
160
161			private:
162			std::unique_ptr<InspectorSession> session_;
163			Global<Function> callback_;
164			};
165
166		44233	static bool InspectorEnabled(Environment* env) {
167		44233	Agent* agent = env->inspector_agent();
168		44233	return agent->IsActive();
169			}
170
171		854	void SetConsoleExtensionInstaller(const FunctionCallbackInfo<Value>& info) {
172		854	auto env = Environment::GetCurrent(info);
173
174	✗✓	854	CHECK_EQ(info.Length(), 1);
175	✗✓	854	CHECK(info[0]->IsFunction());
176
177		1708	env->set_inspector_console_extension_installer(info[0].As<Function>());
178		854	}
179
180		8	void CallAndPauseOnStart(const FunctionCallbackInfo<v8::Value>& args) {
181		8	Environment* env = Environment::GetCurrent(args);
182	✗✓	8	CHECK_GT(args.Length(), 1);
183	✗✓	8	CHECK(args[0]->IsFunction());
184		14	SlicedArguments call_args(args, /* start */ 2);
185	✓✗	8	env->inspector_agent()->PauseOnNextJavascriptStatement("Break on start");
186			v8::MaybeLocal<v8::Value> retval =
187		22	args[0].As<v8::Function>()->Call(env->context(), args[1],
188	✓✗	16	call_args.length(), call_args.out());
189	✓✓	6	if (!retval.IsEmpty()) {
190	✗✓	10	args.GetReturnValue().Set(retval.ToLocalChecked());
191			}
192		6	}
193
194		44227	void InspectorConsoleCall(const FunctionCallbackInfo<Value>& info) {
195		44227	Environment* env = Environment::GetCurrent(info);
196		44227	Isolate* isolate = env->isolate();
197		44227	Local<Context> context = isolate->GetCurrentContext();
198	✗✓	44227	CHECK_GE(info.Length(), 2);
199		44227	SlicedArguments call_args(info, /* start */ 2);
200	✓✓	44227	if (InspectorEnabled(env)) {
201		44226	Local<Value> inspector_method = info[0];
202	✗✓	44226	CHECK(inspector_method->IsFunction());
203	✓✓	44226	if (!env->is_in_inspector_console_call()) {
204		44225	env->set_is_in_inspector_console_call(true);
205			MaybeLocal<Value> ret =
206		44225	inspector_method.As<Function>()->Call(context,
207			info.Holder(),
208		44225	call_args.length(),
209		132675	call_args.out());
210		44225	env->set_is_in_inspector_console_call(false);
211	✓✓	44225	if (ret.IsEmpty())
212		9	return;
213			}
214			}
215
216		44218	Local<Value> node_method = info[1];
217	✗✓	44218	CHECK(node_method->IsFunction());
218		88436	USE(node_method.As<Function>()->Call(context,
219			info.Holder(),
220		44218	call_args.length(),
221		176872	call_args.out()));
222			}
223
224		25	static void* GetAsyncTask(int64_t asyncId) {
225			// The inspector assumes that when other clients use its asyncTask* API,
226			// they use real pointers, or at least something aligned like real pointer.
227			// In general it means that our task_id should always be even.
228			//
229			// On 32bit platforms, the 64bit asyncId would get truncated when converted
230			// to a 32bit pointer. However, the javascript part will never enable
231			// the async_hook on 32bit platforms, therefore the truncation will never
232			// happen in practice.
233		25	return reinterpret_cast<void*>(asyncId << 1);
234			}
235
236			template <void (Agent::asyncTaskFn)(void)>
237		44	static void InvokeAsyncTaskFnWithId(const FunctionCallbackInfo<Value>& args) {
238		44	Environment* env = Environment::GetCurrent(args);
239	✗✓	44	CHECK(args[0]->IsNumber());
240		44	int64_t task_id = args[0]->IntegerValue(env->context()).FromJust();
241		44	(env->inspector_agent()->*asyncTaskFn)(GetAsyncTask(task_id));
242		44	}
243
244		3	static void AsyncTaskScheduledWrapper(const FunctionCallbackInfo<Value>& args) {
245		3	Environment* env = Environment::GetCurrent(args);
246
247	✗✓	6	CHECK(args[0]->IsString());
248		6	Local<String> task_name = args[0].As<String>();
249		6	String::Value task_name_value(args.GetIsolate(), task_name);
250		3	StringView task_name_view(*task_name_value, task_name_value.length());
251
252	✗✓	3	CHECK(args[1]->IsNumber());
253		3	int64_t task_id = args[1]->IntegerValue(env->context()).FromJust();
254		3	void* task = GetAsyncTask(task_id);
255
256	✗✓	3	CHECK(args[2]->IsBoolean());
257		3	bool recurring = args[2]->BooleanValue(args.GetIsolate());
258
259		3	env->inspector_agent()->AsyncTaskScheduled(task_name_view, task, recurring);
260		3	}
261
262		6020	static void RegisterAsyncHookWrapper(const FunctionCallbackInfo<Value>& args) {
263		6020	Environment* env = Environment::GetCurrent(args);
264
265	✗✓	6020	CHECK(args[0]->IsFunction());
266	✓✗	12040	Local<Function> enable_function = args[0].As<Function>();
267	✗✓	6020	CHECK(args[1]->IsFunction());
268		6020	Local<Function> disable_function = args[1].As<Function>();
269		6020	env->inspector_agent()->RegisterAsyncHook(env->isolate(),
270			enable_function, disable_function);
271		6020	}
272
273		6	void IsEnabled(const FunctionCallbackInfo<Value>& args) {
274		6	Environment* env = Environment::GetCurrent(args);
275	✓✓	6	args.GetReturnValue().Set(InspectorEnabled(env));
276		6	}
277
278			void Open(const FunctionCallbackInfo<Value>& args) {
279			Environment* env = Environment::GetCurrent(args);
280			Agent* agent = env->inspector_agent();
281
282			if (args.Length() > 0 && args[0]->IsUint32()) {
283			uint32_t port = args[0].As<Uint32>()->Value();
284			ExclusiveAccess<HostPort>::Scoped host_port(agent->host_port());
285			host_port->set_port(static_cast<int>(port));
286			}
287
288			if (args.Length() > 1 && args[1]->IsString()) {
289			Utf8Value host(env->isolate(), args[1].As<String>());
290			ExclusiveAccess<HostPort>::Scoped host_port(agent->host_port());
291			host_port->set_host(*host);
292			}
293
294			agent->StartIoThread();
295			}
296
297			void WaitForDebugger(const FunctionCallbackInfo<Value>& args) {
298			Environment* env = Environment::GetCurrent(args);
299			Agent* agent = env->inspector_agent();
300			if (agent->IsActive())
301			agent->WaitForConnect();
302			args.GetReturnValue().Set(agent->IsActive());
303			}
304
305		6	void Url(const FunctionCallbackInfo<Value>& args) {
306		6	Environment* env = Environment::GetCurrent(args);
307		6	std::string url = env->inspector_agent()->GetWsUrl();
308	✓✓	6	if (url.empty()) {
309		1	return;
310			}
311		10	args.GetReturnValue().Set(OneByteString(env->isolate(), url.c_str()));
312			}
313
314		854	void Initialize(Local<Object> target, Local<Value> unused,
315			Local<Context> context, void* priv) {
316		854	Environment* env = Environment::GetCurrent(context);
317
318			v8::Local<v8::Function> consoleCallFunc =
319		854	env->NewFunctionTemplate(InspectorConsoleCall, v8::Local<v8::Signature>(),
320			v8::ConstructorBehavior::kThrow,
321		854	v8::SideEffectType::kHasSideEffect)
322		854	->GetFunction(context)
323		854	.ToLocalChecked();
324		854	auto name_string = FIXED_ONE_BYTE_STRING(env->isolate(), "consoleCall");
325		1708	target->Set(context, name_string, consoleCallFunc).Check();
326		854	consoleCallFunc->SetName(name_string);
327
328		854	env->SetMethod(
329			target, "setConsoleExtensionInstaller", SetConsoleExtensionInstaller);
330		854	env->SetMethod(target, "callAndPauseOnStart", CallAndPauseOnStart);
331		854	env->SetMethod(target, "open", Open);
332		854	env->SetMethodNoSideEffect(target, "url", Url);
333		854	env->SetMethod(target, "waitForDebugger", WaitForDebugger);
334
335		854	env->SetMethod(target, "asyncTaskScheduled", AsyncTaskScheduledWrapper);
336		854	env->SetMethod(target, "asyncTaskCanceled",
337			InvokeAsyncTaskFnWithId<&Agent::AsyncTaskCanceled>);
338		854	env->SetMethod(target, "asyncTaskStarted",
339			InvokeAsyncTaskFnWithId<&Agent::AsyncTaskStarted>);
340		854	env->SetMethod(target, "asyncTaskFinished",
341			InvokeAsyncTaskFnWithId<&Agent::AsyncTaskFinished>);
342
343		854	env->SetMethod(target, "registerAsyncHook", RegisterAsyncHookWrapper);
344		854	env->SetMethodNoSideEffect(target, "isEnabled", IsEnabled);
345
346			Local<String> console_string =
347		854	FIXED_ONE_BYTE_STRING(env->isolate(), "console");
348
349			// Grab the console from the binding object and expose those to our binding
350			// layer.
351		854	Local<Object> binding = context->GetExtrasBindingObject();
352			target
353		854	->Set(context,
354			console_string,
355		1708	binding->Get(context, console_string).ToLocalChecked())
356			.Check();
357
358		854	JSBindingsConnection<LocalConnection>::Bind(env, target);
359		854	JSBindingsConnection<MainThreadConnection>::Bind(env, target);
360		854	}
361
362			} // namespace
363
364		5205	void RegisterExternalReferences(ExternalReferenceRegistry* registry) {
365		5205	registry->Register(InspectorConsoleCall);
366		5205	registry->Register(SetConsoleExtensionInstaller);
367		5205	registry->Register(CallAndPauseOnStart);
368		5205	registry->Register(Open);
369		5205	registry->Register(Url);
370		5205	registry->Register(WaitForDebugger);
371
372		5205	registry->Register(AsyncTaskScheduledWrapper);
373		5205	registry->Register(InvokeAsyncTaskFnWithId<&Agent::AsyncTaskCanceled>);
374		5205	registry->Register(InvokeAsyncTaskFnWithId<&Agent::AsyncTaskStarted>);
375		5205	registry->Register(InvokeAsyncTaskFnWithId<&Agent::AsyncTaskFinished>);
376
377		5205	registry->Register(RegisterAsyncHookWrapper);
378		5205	registry->Register(IsEnabled);
379
380		5205	registry->Register(JSBindingsConnection<LocalConnection>::New);
381		5205	registry->Register(JSBindingsConnection<LocalConnection>::Dispatch);
382		5205	registry->Register(JSBindingsConnection<LocalConnection>::Disconnect);
383		5205	registry->Register(JSBindingsConnection<MainThreadConnection>::New);
384		5205	registry->Register(JSBindingsConnection<MainThreadConnection>::Dispatch);
385		5205	registry->Register(JSBindingsConnection<MainThreadConnection>::Disconnect);
386		5205	}
387
388			} // namespace inspector
389			} // namespace node
390
391		5273	NODE_MODULE_CONTEXT_AWARE_INTERNAL(inspector,
392			node::inspector::Initialize)
393		5205	NODE_MODULE_EXTERNAL_REFERENCE(inspector,
394			node::inspector::RegisterExternalReferences)