deno_node 0.192.0

Node compatibility for Deno
Documentation 
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

// Copyright 2018-2026 the Deno authors. MIT license.

// Installs `internals.__inspectorNetwork`, the bridge that other
// extensions (ext/fetch, http, websocket) use to emit `Network.*` CDP
// events without depending on ext/node directly. It needs to be
// installed eagerly so that `deno run --inspect` alone is enough to
// see fetch traffic in DevTools - previously the bridge lived in the
// `node:inspector` polyfill and only appeared if user code imported
// that module.

(function () {
const { core, internals, primordials } = __bootstrap;
const {
  op_base64_encode_from_buffer,
  op_inspector_emit_protocol_event,
  op_inspector_enabled,
} = core.ops;
const {
  ArrayBufferPrototype,
  JSONStringify,
  ObjectAssign,
  ObjectPrototypeIsPrototypeOf,
  TypeError,
  TypedArrayPrototypeGetByteLength,
  TypedArrayPrototypeGetSymbolToStringTag,
  Uint8Array,
} = primordials;

function encodeNetworkData(data) {
  if (data == null) return undefined;
  if (typeof data === "string") {
    const buf = core.encode(data);
    return op_base64_encode_from_buffer(
      buf,
      0,
      TypedArrayPrototypeGetByteLength(buf),
    );
  }
  if (TypedArrayPrototypeGetSymbolToStringTag(data) === "Uint8Array") {
    return op_base64_encode_from_buffer(
      data,
      0,
      TypedArrayPrototypeGetByteLength(data),
    );
  }
  if (ObjectPrototypeIsPrototypeOf(ArrayBufferPrototype, data)) {
    const view = new Uint8Array(data);
    return op_base64_encode_from_buffer(
      view,
      0,
      TypedArrayPrototypeGetByteLength(view),
    );
  }
  throw new TypeError(
    "Expected data to be a string, Buffer, Uint8Array, or ArrayBuffer",
  );
}

function emit(eventName, params) {
  op_inspector_emit_protocol_event(eventName, JSONStringify(params ?? {}));
}

function emitWithData(eventName, params) {
  if (params && params.data !== undefined) {
    const encoded = encodeNetworkData(params.data);
    if (encoded !== params.data) {
      params = ObjectAssign({ __proto__: null }, params, { data: encoded });
    }
  }
  emit(eventName, params);
}

// CDP's `webSocketFrameSent`/`webSocketFrameReceived` carry the payload
// inside `params.response.payloadData`. Text frames go through as-is, binary
// frames must be base64-encoded (DevTools uses `opcode` to decide how to
// render the panel - 1=text, 2=binary).
function emitFrame(eventName, params) {
  const payload = params?.response?.payloadData;
  if (payload != null && typeof payload !== "string") {
    let view = null;
    if (TypedArrayPrototypeGetSymbolToStringTag(payload) === "Uint8Array") {
      view = payload;
    } else if (ObjectPrototypeIsPrototypeOf(ArrayBufferPrototype, payload)) {
      view = new Uint8Array(payload);
    }
    if (view !== null) {
      const encoded = op_base64_encode_from_buffer(
        view,
        0,
        TypedArrayPrototypeGetByteLength(view),
      );
      params = ObjectAssign({ __proto__: null }, params, {
        response: ObjectAssign({ __proto__: null }, params.response, {
          payloadData: encoded,
        }),
      });
    }
  }
  emit(eventName, params);
}

let networkRequestIdCounter = 0;
internals.__inspectorNetwork = {
  isEnabled: () => op_inspector_enabled(),
  nextRequestId: () => `node-network-event-${++networkRequestIdCounter}`,
  requestWillBeSent: (p) => emit("Network.requestWillBeSent", p),
  responseReceived: (p) => emit("Network.responseReceived", p),
  loadingFinished: (p) => emit("Network.loadingFinished", p),
  loadingFailed: (p) => emit("Network.loadingFailed", p),
  dataReceived: (p) => emitWithData("Network.dataReceived", p),
  dataSent: (p) => emitWithData("Network.dataSent", p),
  webSocketCreated: (p) => emit("Network.webSocketCreated", p),
  // Not part of the public `inspector.Network` surface (Node doesn't
  // expose it either - see node_compat test-inspector-emit-protocol-event)
  // but DevTools still needs the event to populate the request-side
  // Headers panel for websocket connections.
  webSocketWillSendHandshakeRequest: (p) =>
    emit("Network.webSocketWillSendHandshakeRequest", p),
  webSocketHandshakeResponseReceived: (p) =>
    emit("Network.webSocketHandshakeResponseReceived", p),
  webSocketClosed: (p) => emit("Network.webSocketClosed", p),
  webSocketFrameSent: (p) => emitFrame("Network.webSocketFrameSent", p),
  webSocketFrameReceived: (p) => emitFrame("Network.webSocketFrameReceived", p),
  webSocketFrameError: (p) => emit("Network.webSocketFrameError", p),
};
})();