Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Not implemented: Http2Session.socket #20903

Closed
uriva opened this issue Oct 13, 2023 · 28 comments · Fixed by #24786
Closed

Not implemented: Http2Session.socket #20903

uriva opened this issue Oct 13, 2023 · 28 comments · Fixed by #24786
Assignees
Labels
bug Something isn't working correctly node API polyfill Related to various "node:*" modules APIs node compat

Comments

@uriva
Copy link

uriva commented Oct 13, 2023

$ deno run -A src/ocr.ts 
Warning: Not implemented: Http2Session.socket
error: Uncaught (in promise) Error: connection error detected: frame with invalid size
    at clientHttp2Request (node:http2:560:21)
    at Object.runMicrotasks (ext:core/01_core.js:848:30)
    at processTicksAndRejections (ext:deno_node/_next_tick.ts:53:10)
    at runNextTicks (ext:deno_node/_next_tick.ts:71:3)
    at eventLoopTick (ext:core/01_core.js:189:21)
    at async node:http2:592:37

code

import vision from "npm:@google-cloud/vision";

// Creates a client
const client = new vision.ImageAnnotatorClient();

const [result] = await client.textDetection("bla.jpeg");
const detections = result.textAnnotations;
console.log("Text:");
detections.forEach((text) => console.log(text));
@bartlomieju
Copy link
Member

Which version of Deno are you using?

@bartlomieju bartlomieju added bug Something isn't working correctly node compat labels Oct 13, 2023
@michaelmass
Copy link

I got the same issue. I am running deno version 1.37.2.

Here's the version information:

deno 1.37.2 (release, x86_64-pc-windows-msvc)
v8 11.8.172.13
typescript 5.2.2

@cesumilo
Copy link

cesumilo commented Oct 17, 2023

Same issue here with @google-cloud/pub-sub and deno 1.37.2.

Here is the code used:

import {GetTopicsResponse, PubSub} from "npm:@google-cloud/pubsub";

const pubsub = new PubSub({
  projectId: "project-id"
});
const response: GetTopicsResponse = await pubsub.getTopics();

console.dir(response);

@JonathonRP
Copy link

could this be the reason I get this error 'Uncaught TypeError: socket.setTimeout is not a function' when I run 'deno run -A npm:sanity@latest init --env'?

@MarybethGasman
Copy link
Contributor

@JonathonRP I think it's #20923.

@RoXuS
Copy link

RoXuS commented Oct 24, 2023

same here

Warning: Not implemented: Http2Session.socket
Warning: Not implemented: Http2Session.goaway

With npm:firebase-admin/firestore.

@jacek-jablonski
Copy link

Same with @google-cloud/datastore

@W4G1
Copy link

W4G1 commented Nov 17, 2023

I got it working by using esm.sh which automatically provides polyfills for features Deno doesn't support yet.

import vision from "https://esm.sh/@google-cloud/vision";

@tenkoverse
Copy link

tenkoverse commented Nov 22, 2023

@bartlomieju I'm also running into this when trying to run a basic variation of the hello-world temporal example here https://github.com/temporalio/samples-typescript/tree/main/hello-world.

Warning: Not implemented: Http2Session.goaway
Warning: Not implemented: Http2Session.socket
error: Uncaught (in promise) TypeError: session.socket.once is not a function
    at Subchannel.transitionToState (->/node_modules/.deno/@[email protected]/node_modules/@grpc/grpc-js/build/src/subchannel.js:536:32)
    at ClientHttp2Session.<anonymous> (->/node_modules/.deno/@[email protected]/node_modules/@grpc/grpc-js/build/src/subchannel.js:420:22)
    at Object.onceWrapper (ext:deno_node/_events.mjs:508:26)
    at ClientHttp2Session.emit (ext:deno_node/_events.mjs:383:28)
    at node:http2:297:12
    at Object.runMicrotasks (ext:core/01_core.js:790:30)
    at processTicksAndRejections (ext:deno_node/_next_tick.ts:53:10)
    at runNextTicks (ext:deno_node/_next_tick.ts:71:3)
    at eventLoopTick (ext:core/01_core.js:184:21)
deno --version
deno 1.38.2 (release, x86_64-apple-darwin)
v8 12.0.267.1
typescript 5.2.2

Have to go back to node :( temporal is a non-negotiable.

Seems to also be related to: #16647

@yzalium
Copy link

yzalium commented Nov 30, 2023

I guess this should be more an issue regarding esm.sh but I figured I'd post it here as well if it helps with debugging.
While esm import works for some other google-cloud packages (like vision above), it triggers the following error when importing pubsub

import ps from 'https://esm.sh/@google-cloud/pubsub';
Uncaught TypeError: Cannot read properties of undefined (reading 'DEADLINE_EXCEEDED')
    at https://esm.sh/v135/@google-cloud/[email protected]/denonext/pubsub.mjs:47:99164
    at https://esm.sh/v135/@google-cloud/[email protected]/denonext/pubsub.mjs:47:458
    at https://esm.sh/v135/@google-cloud/[email protected]/denonext/pubsub.mjs:47:101751
    at https://esm.sh/v135/@google-cloud/[email protected]/denonext/pubsub.mjs:47:458
    at https://esm.sh/v135/@google-cloud/[email protected]/denonext/pubsub.mjs:47:112692
    at https://esm.sh/v135/@google-cloud/[email protected]/denonext/pubsub.mjs:47:458
    at https://esm.sh/v135/@google-cloud/[email protected]/denonext/pubsub.mjs:47:120334
    at https://esm.sh/v135/@google-cloud/[email protected]/denonext/pubsub.mjs:47:458
    at https://esm.sh/v135/@google-cloud/[email protected]/denonext/pubsub.mjs:47:124744
    at https://esm.sh/v135/@google-cloud/[email protected]/denonext/pubsub.mjs:47:458
deno 1.38.3 (release, aarch64-apple-darwin)
v8 12.0.267.1
typescript 5.2.2

@akkadaya
Copy link

akkadaya commented Dec 6, 2023

The same issue with Deno v1.38.5

@samrocksc
Copy link

samrocksc commented Dec 8, 2023

any luck from anyone regarding pubsub? I tried using an import map and a few other things, and no bueno

deno --version
deno 1.38.5 (release, aarch64-apple-darwin)
v8 12.0.267.1
typescript 5.2.2

import { GetTopicsResponse, PubSub } from "npm:@google-cloud/[email protected]";

const pubsub = new PubSub({
  projectId: "xxx",
});
try {
  const response: GetTopicsResponse = await pubsub.getTopics();
  console.dir(response);
} catch (err) {
  console.log("error", err);
}

it's almost there :) just a little bit more!

@leo-lox
Copy link

leo-lox commented Dec 31, 2023

same here with firebase-admin (12.0.0)

Warning: Not implemented: Http2Session.socket
error: Uncaught (in promise) Error: connection error detected: frame with invalid size
    at async node:http2:596:24
deno 1.39.1 (release, x86_64-pc-windows-msvc)
v8 12.0.267.8
typescript 5.3.3

@PierreCapo
Copy link

Same here. If I understand correctly looking at the Deno codebase, Http2Session.socket is not implemented yet, which prevents using firebase-admin and deno:

get socket(): Socket /*| TlsSocket*/ {
warnNotImplemented("Http2Session.socket");
return {};
}

@cesumilo
Copy link

cesumilo commented Feb 2, 2024

Hello, I've been following this issue very closely and I didn't see any update on discord or github. @bartlomieju do you have any update to share? 🥲

@PedroReyes
Copy link

PedroReyes commented Feb 3, 2024

Same situation here, trying to use Deno with Firebase Admin. Let us know if there is any update @bartlomieju

In my case I am getting the next error:

[npm] deprecated uuid@3.4.0: Please upgrade  to version 7 or higher.  Older versions may use Math.random() in certain circumstances, which is known to be problematic.  See https://v8.dev/blog/math-random for details.

[npm] deprecated har-validator@5.1.5: this library is no longer supported
[npm] deprecated request@2.88.2: request has been deprecated, see https://github.com/request/request/issues/3142
error: Uncaught (in promise) Error: Failed to initialize Google Cloud Firestore client with the available credentials. Must initialize the SDK with a certificate credential or application default credentials to use Cloud Firestore API.

For the next code:

import {
  applicationDefault,
  initializeApp,
} from "https://esm.sh/[email protected]/app";
import { getFirestore } from "https://esm.sh/[email protected]/firestore";
const app = initializeApp({
  credential: applicationDefault(),
});

const firestore = getFirestore(app);

// Get document from Firestore
firestore
  .doc("users/test")
  .get()
  .then((doc) => {
    console.log(doc.data());
  });

I have tried this same code in NodeJS exporting export GOOGLE_APPLICATION_CREDENTIALS="./admin_service_account.json" as usual and it worked.

Wanted to give it a try to the cron jobs. Hopefully this will get to deno soon . . .

Deno version I am using:

$ deno --version
deno 1.40.3 (release, x86_64-pc-windows-msvc)
v8 12.1.285.6
typescript 5.3.3

@samrocksc
Copy link

i have tried peaking through the Google Cloud issues, and haven't found a lot pertaining to deno

@satyarohith
Copy link
Member

After #22512, @google-cloud/pubsub is working even though warnings are thrown:

➜ cat t.ts --plain
import { GetTopicsResponse, PubSub } from "npm:@google-cloud/pubsub";

const pubsub = new PubSub({
  projectId: "xxx",
});
const response: GetTopicsResponse = await pubsub.getTopics();

console.log(response[0][0].name);

➜ ./target/debug/deno run -A t.ts
Warning: Not implemented: Http2Session.socket
{"grpc-status": "0", "content-disposition": "attachment"}
projects/xxx/topics/test-topic

I'll work on supporting socket now.

@yzalium
Copy link

yzalium commented Feb 23, 2024

I confirm It doesn't crash anymore! Thanks a lot for your help and the progress made on this topic 🚀

@bartlomieju bartlomieju added the node API polyfill Related to various "node:*" modules APIs label Mar 4, 2024
@dylanpyle
Copy link

dylanpyle commented Mar 19, 2024

Not sure if this is a misconfiguration on my end, but I'm hitting this warning (then a timeout) when publishing messages to PubSub, using deno 1.41.3:

import { PubSub } from "npm:@google-cloud/[email protected]";
import { Buffer } from "node:buffer";

const keyFilename = '/path/to/file';

const pubsub = new PubSub({ keyFilename });
const handle = pubsub.topic('my-test-topic');
await handle.publishMessage({
  data: Buffer.from('test'),
  attributes: {
    articleId: "a5470071-0764-4dab-a645-afd2af2bcb79",
    trackerId: "9b156235-463f-4eb8-9dc2-ea12057eeb14"
  },
});

Output:

...
Warning: Not implemented: Http2Session.socket
Warning: Not implemented: Http2Session.socket
Warning: Not implemented: Http2Session.socket
Warning: Not implemented: Http2Session.socket
Warning: Not implemented: Http2Session.socket
Warning: Not implemented: Http2Session.socket
Warning: Not implemented: Http2Session.socket
Error: Total timeout of API google.pubsub.v1.Publisher exceeded 60000 milliseconds before any response was received.
    at repeat (file:///Users/dylan/Library/Caches/deno/npm/registry.npmjs.org/google-gax/4.3.1/build/src/normalCalls/retries.js:66:31)
    at Timeout._onTimeout (file:///Users/dylan/Library/Caches/deno/npm/registry.npmjs.org/google-gax/4.3.1/build/src/normalCalls/retries.js:102:25)
    at cb (ext:deno_node/internal/timers.mjs:64:31)
    at eventLoopTick (ext:core/01_core.js:204:13) {
  code: 4
}

Edit: Debugging info for posterity

  • I get one warning and seemingly publishes successfully if the attributes payload is smaller, e.g. attributes: { foo: 'bar' } warns once, still hangs indefinitely, but does appear to publish a message.
  • I ended up use using the REST API to do this directly, which seems like a more reliable move for now

@burakakca
Copy link

import { Connection, Client } from 'npm:@temporalio/client';
try {
	const connection = await Connection.connect();

	const temporalClient = new Client({
		connection,
	})

} catch (error) {
	console.error('Failed to connect to the Temporal server:', error);
}
Warning: Not implemented: Http2Session.socket
error: Uncaught (in promise) TypeError: session.socket.once is not a function
    at Subchannel.transitionToState (file:///home/burak/.cache/deno/npm/registry.npmjs.org/@grpc/grpc-js/1.7.3/build/src/subchannel.js:536:32)
    at ClientHttp2Session.<anonymous> (file:///home/burak/.cache/deno/npm/registry.npmjs.org/@grpc/grpc-js/1.7.3/build/src/subchannel.js:420:22)
    at Object.onceWrapper (ext:deno_node/_events.mjs:511:26)
    at ClientHttp2Session.emit (ext:deno_node/_events.mjs:386:28)
    at node:http2:284:12
    at Object.runMicrotasks (ext:core/01_core.js:642:26)
    at processTicksAndRejections (ext:deno_node/_next_tick.ts:39:10)
    at runNextTicks (ext:deno_node/_next_tick.ts:48:3)
    at eventLoopTick (ext:core/01_core.js:175:21)
Watcher Process failed. Restarting on file change...
deno --version
deno 1.43.3 (release, x86_64-unknown-linux-gnu)
v8 12.4.254.13
typescript 5.4.5

@satyarohith
Copy link
Member

@burakakca npm:@temporalio/client depends on @grpc/grpc-js for which the support has been improved in Deno v1.44. Can you upgrade and try again?

@burakakca
Copy link

@satyarohith I tried and I got same error like above

Also i tried latest version of that package npm:@temporalio/client@latest and I got

Warning: Not implemented: Http2Session.socket
error: Uncaught (in promise) Error: stream closed because of a broken pipe
    at async node:http2:569:37

@satyarohith
Copy link
Member

satyarohith commented Jun 11, 2024

@burakakca can you try running with the latest canary (deno upgrade --canary)? I wonder if #24147 fixed it. I appreciate if you can paste debug logs too (use GRPC_VERBOSITY=debug GRPC_TRACE=all)

I could run the example but temporal charges $200 to just sign up.

@burakakca
Copy link

burakakca commented Jun 12, 2024

Yes, sure I'm just using the temporalio docker for local development.

deno 1.44.1+3765e6b (canary, x86_64-unknown-linux-gnu)
v8 12.6.228.9
typescript 5.4.5

Output:

GRPC_VERBOSITY=debug GRPC_TRACE=all deno run main.ts
✅ Granted env access to "GRPC_NODE_VERBOSITY".
✅ Granted env access to "GRPC_VERBOSITY".
✅ Granted env access to "GRPC_NODE_TRACE".
✅ Granted env access to "GRPC_TRACE".
✅ Granted env access to "GRPC_SSL_CIPHER_SUITES".
✅ Granted env access to "GRPC_DEFAULT_SSL_ROOTS_FILE_PATH".
✅ Granted env access to "GRPC_EXPERIMENTAL_ENABLE_OUTLIER_DETECTION".
✅ Granted env access to "grpc_proxy".
✅ Granted env access to "https_proxy".
✅ Granted env access to "http_proxy".
D 2024-06-12T12:31:24.122Z | v1.10.8 887139 | resolving_load_balancer | dns:127.0.0.1:7233 IDLE -> IDLE
D 2024-06-12T12:31:24.125Z | v1.10.8 887139 | connectivity_state | (1) dns:127.0.0.1:7233 IDLE -> IDLE
D 2024-06-12T12:31:24.126Z | v1.10.8 887139 | dns_resolver | Resolver constructed for target dns:127.0.0.1:7233
D 2024-06-12T12:31:24.128Z | v1.10.8 887139 | channel | (1) dns:127.0.0.1:7233 Channel constructed with options {
  "grpc.keepalive_permit_without_calls": 1,
  "grpc.keepalive_time_ms": 30000,
  "grpc.keepalive_timeout_ms": 15000
}
D 2024-06-12T12:31:24.133Z | v1.10.8 887139 | channel_stacktrace | (1) Channel constructed
    at new InternalChannel (file:///home/burak/.cache/deno/npm/registry.npmjs.org/@grpc/grpc-js/1.10.8/build/src/internal-channel.js:248:23)
    at new ChannelImplementation (file:///home/burak/.cache/deno/npm/registry.npmjs.org/@grpc/grpc-js/1.10.8/build/src/channel.js:35:32)
    at new Client (file:///home/burak/.cache/deno/npm/registry.npmjs.org/@grpc/grpc-js/1.10.8/build/src/client.js:66:36)
    at new ServiceClientImpl (file:///home/burak/.cache/deno/npm/registry.npmjs.org/@grpc/grpc-js/1.10.8/build/src/make-client.js:58:5)
    at Function.createCtorOptions (file:///home/burak/.cache/deno/npm/registry.npmjs.org/@temporalio/client/1.10.1/lib/connection.js:124:24)
    at Function.lazy (file:///home/burak/.cache/deno/npm/registry.npmjs.org/@temporalio/client/1.10.1/lib/connection.js:201:30)
    at Function.connect (file:///home/burak/.cache/deno/npm/registry.npmjs.org/@temporalio/client/1.10.1/lib/connection.js:210:27)
    at file:///home/burak/Desktop/deno/testTemporal/main.ts:6:37
D 2024-06-12T12:31:24.221Z | v1.10.8 887139 | dns_resolver | Returning IP address for target dns:127.0.0.1:7233
D 2024-06-12T12:31:24.221Z | v1.10.8 887139 | resolving_load_balancer | dns:127.0.0.1:7233 IDLE -> CONNECTING
D 2024-06-12T12:31:24.221Z | v1.10.8 887139 | connectivity_state | (1) dns:127.0.0.1:7233 IDLE -> CONNECTING
D 2024-06-12T12:31:24.225Z | v1.10.8 887139 | subchannel | (1) 127.0.0.1:7233 Subchannel constructed with options {
  "grpc.keepalive_permit_without_calls": 1,
  "grpc.keepalive_time_ms": 30000,
  "grpc.keepalive_timeout_ms": 15000
}
D 2024-06-12T12:31:24.225Z | v1.10.8 887139 | subchannel_refcount | (1) 127.0.0.1:7233 refcount 0 -> 1
D 2024-06-12T12:31:24.225Z | v1.10.8 887139 | subchannel_refcount | (1) 127.0.0.1:7233 refcount 1 -> 2
D 2024-06-12T12:31:24.225Z | v1.10.8 887139 | pick_first | Start connecting to subchannel with address 127.0.0.1:7233
D 2024-06-12T12:31:24.226Z | v1.10.8 887139 | pick_first | IDLE -> CONNECTING
D 2024-06-12T12:31:24.226Z | v1.10.8 887139 | resolving_load_balancer | dns:127.0.0.1:7233 CONNECTING -> CONNECTING
D 2024-06-12T12:31:24.226Z | v1.10.8 887139 | connectivity_state | (1) dns:127.0.0.1:7233 CONNECTING -> CONNECTING
D 2024-06-12T12:31:24.226Z | v1.10.8 887139 | subchannel | (1) 127.0.0.1:7233 IDLE -> CONNECTING
D 2024-06-12T12:31:24.226Z | v1.10.8 887139 | transport | dns:127.0.0.1:7233 creating HTTP/2 session to 127.0.0.1:7233
✅ Granted net access to "127.0.0.1:7233".
D 2024-06-12T12:31:26.946Z | v1.10.8 887139 | keepalive | (1) 127.0.0.1:7233 Starting keepalive timer for 30000ms
D 2024-06-12T12:31:26.946Z | v1.10.8 887139 | subchannel | (1) 127.0.0.1:7233 CONNECTING -> READY
D 2024-06-12T12:31:26.947Z | v1.10.8 887139 | pick_first | Pick subchannel with address 127.0.0.1:7233
D 2024-06-12T12:31:26.947Z | v1.10.8 887139 | subchannel_refcount | (1) 127.0.0.1:7233 refcount 2 -> 3
D 2024-06-12T12:31:26.947Z | v1.10.8 887139 | subchannel_refcount | (1) 127.0.0.1:7233 refcount 3 -> 2
D 2024-06-12T12:31:26.948Z | v1.10.8 887139 | pick_first | CONNECTING -> READY
D 2024-06-12T12:31:26.948Z | v1.10.8 887139 | resolving_load_balancer | dns:127.0.0.1:7233 CONNECTING -> READY
D 2024-06-12T12:31:26.948Z | v1.10.8 887139 | connectivity_state | (1) dns:127.0.0.1:7233 CONNECTING -> READY
D 2024-06-12T12:31:26.960Z | v1.10.8 887139 | channel | (1) dns:127.0.0.1:7233 createResolvingCall [0] method="/temporal.api.workflowservice.v1.WorkflowService/GetSystemInfo", deadline=2024-06-12T12:31:34.220Z
D 2024-06-12T12:31:26.960Z | v1.10.8 887139 | resolving_call | [0] Created
D 2024-06-12T12:31:26.961Z | v1.10.8 887139 | resolving_call | [0] Deadline: 2024-06-12T12:31:34.220Z
D 2024-06-12T12:31:26.961Z | v1.10.8 887139 | resolving_call | [0] Deadline will be reached in 7259ms
D 2024-06-12T12:31:26.963Z | v1.10.8 887139 | resolving_call | [0] start called
D 2024-06-12T12:31:26.967Z | v1.10.8 887139 | resolving_call | [0] startRead called
D 2024-06-12T12:31:26.967Z | v1.10.8 887139 | resolving_call | [0] write() called with message of length 0
D 2024-06-12T12:31:26.968Z | v1.10.8 887139 | resolving_call | [0] halfClose called
D 2024-06-12T12:31:26.968Z | v1.10.8 887139 | channel | (1) dns:127.0.0.1:7233 createRetryingCall [1] method="/temporal.api.workflowservice.v1.WorkflowService/GetSystemInfo"
D 2024-06-12T12:31:26.969Z | v1.10.8 887139 | resolving_call | [0] Created child [1]
D 2024-06-12T12:31:26.969Z | v1.10.8 887139 | retrying_call | [1] start called
D 2024-06-12T12:31:26.969Z | v1.10.8 887139 | channel | (1) dns:127.0.0.1:7233 createLoadBalancingCall [2] method="/temporal.api.workflowservice.v1.WorkflowService/GetSystemInfo"
D 2024-06-12T12:31:26.970Z | v1.10.8 887139 | retrying_call | [1] Created child call [2] for attempt 1
D 2024-06-12T12:31:26.970Z | v1.10.8 887139 | load_balancing_call | [2] start called
D 2024-06-12T12:31:26.970Z | v1.10.8 887139 | load_balancing_call | [2] Pick called
D 2024-06-12T12:31:26.971Z | v1.10.8 887139 | load_balancing_call | [2] Pick result: COMPLETE subchannel: (1) 127.0.0.1:7233 status: undefined undefined
D 2024-06-12T12:31:26.971Z | v1.10.8 887139 | retrying_call | [1] startRead called
D 2024-06-12T12:31:26.971Z | v1.10.8 887139 | load_balancing_call | [2] startRead called
D 2024-06-12T12:31:26.974Z | v1.10.8 887139 | transport_flowctrl | (1) 127.0.0.1:7233 local window size: undefined remote window size: undefined
Warning: Not implemented: Http2Session.socket
D 2024-06-12T12:31:26.974Z | v1.10.8 887139 | transport_internals | (1) 127.0.0.1:7233 session.closed=false session.destroyed=false session.socket.destroyed=undefined
D 2024-06-12T12:31:26.975Z | v1.10.8 887139 | load_balancing_call | [2] Created child call [3]
D 2024-06-12T12:31:26.977Z | v1.10.8 887139 | retrying_call | [1] write() called with message of length 5
D 2024-06-12T12:31:26.977Z | v1.10.8 887139 | load_balancing_call | [2] write() called with message of length 5
D 2024-06-12T12:31:26.977Z | v1.10.8 887139 | subchannel_call | [3] write() called with message of length 5
D 2024-06-12T12:31:26.977Z | v1.10.8 887139 | subchannel_call | [3] sending data chunk of length 5
D 2024-06-12T12:31:26.978Z | v1.10.8 887139 | retrying_call | [1] halfClose called
D 2024-06-12T12:31:26.979Z | v1.10.8 887139 | load_balancing_call | [2] halfClose called
D 2024-06-12T12:31:26.979Z | v1.10.8 887139 | subchannel_call | [3] end() called
D 2024-06-12T12:31:26.979Z | v1.10.8 887139 | subchannel_call | [3] calling end() on HTTP/2 stream
D 2024-06-12T12:31:26.980Z | v1.10.8 887139 | pick_first | READY -> READY
D 2024-06-12T12:31:26.980Z | v1.10.8 887139 | resolving_load_balancer | dns:127.0.0.1:7233 READY -> READY
D 2024-06-12T12:31:26.980Z | v1.10.8 887139 | connectivity_state | (1) dns:127.0.0.1:7233 READY -> READY
D 2024-06-12T12:31:26.981Z | v1.10.8 887139 | subchannel_call | [3] Received server headers:
		:status: 200
		content-type: application/grpc

D 2024-06-12T12:31:26.982Z | v1.10.8 887139 | load_balancing_call | [2] Received metadata
D 2024-06-12T12:31:26.982Z | v1.10.8 887139 | retrying_call | [1] Received metadata from child [2]
D 2024-06-12T12:31:26.982Z | v1.10.8 887139 | retrying_call | [1] Committing call [2] at index 0
D 2024-06-12T12:31:26.982Z | v1.10.8 887139 | resolving_call | [0] Received metadata
D 2024-06-12T12:31:26.983Z | v1.10.8 887139 | subchannel_call | [3] receive HTTP/2 data frame of length 35
D 2024-06-12T12:31:26.983Z | v1.10.8 887139 | subchannel_call | [3] parsed message of length 35
D 2024-06-12T12:31:26.983Z | v1.10.8 887139 | subchannel_call | [3] pushing to reader message of length 35
D 2024-06-12T12:31:26.983Z | v1.10.8 887139 | load_balancing_call | [2] Received message
D 2024-06-12T12:31:26.983Z | v1.10.8 887139 | retrying_call | [1] Received message from child [2]
D 2024-06-12T12:31:26.984Z | v1.10.8 887139 | resolving_call | [0] Received message
D 2024-06-12T12:31:26.984Z | v1.10.8 887139 | subchannel_call | [3] Received server trailers:
		grpc-status: 0
		grpc-message:

D 2024-06-12T12:31:26.984Z | v1.10.8 887139 | subchannel_call | [3] received status code 0 from server
D 2024-06-12T12:31:26.984Z | v1.10.8 887139 | subchannel_call | [3] received status details string "" from server
D 2024-06-12T12:31:26.986Z | v1.10.8 887139 | resolving_call | [0] Finished filtering received message
D 2024-06-12T12:31:26.987Z | v1.10.8 887139 | subchannel_call | [3] ended with status: code=0 details=""
D 2024-06-12T12:31:26.987Z | v1.10.8 887139 | load_balancing_call | [2] Received status
D 2024-06-12T12:31:26.987Z | v1.10.8 887139 | load_balancing_call | [2] ended with status: code=0 details="" start time=2024-06-12T12:31:26.970Z
D 2024-06-12T12:31:26.987Z | v1.10.8 887139 | retrying_call | [1] Received status from child [2]
D 2024-06-12T12:31:26.987Z | v1.10.8 887139 | retrying_call | [1] state=COMMITTED handling status with progress PROCESSED from child [2] in state ACTIVE
D 2024-06-12T12:31:26.987Z | v1.10.8 887139 | retrying_call | [1] ended with status: code=0 details="" start time=2024-06-12T12:31:26.969Z
D 2024-06-12T12:31:26.987Z | v1.10.8 887139 | resolving_call | [0] Received status
D 2024-06-12T12:31:26.988Z | v1.10.8 887139 | resolving_call | [0] ended with status: code=0 details=""
✅ Granted sys access to "hostname".

@yzalium
Copy link

yzalium commented Jun 19, 2024

While I was mistaken on my previous message, PubSub works properly now with Deno v1.44 despite still raising a warning about Http2Session.socket being not implemented.

deno 1.44.3 (release, aarch64-apple-darwin)
v8 12.6.228.9
typescript 5.4.5
import { PubSub } from '@google-cloud/pubsub';

const projectId = 'my-project';
const messageId = await new PubSub({ projectId })
  .topic('my-topic')
  .publishMessage({ json: { id: 'foo' } });

console.log(messageId);

@elizeuangelo
Copy link

elizeuangelo commented Jul 4, 2024

I'm trying using "npm:[email protected]" and it still doesn't work: Warning: Not implemented: Http2Session.socket

@lukket
Copy link

lukket commented Jul 26, 2024

I have the same issue with npm:@eventstore/db-client which also depends on @grpc/grpc-js. After the warning appeared a couple of times, my application crashes. I was able to work around the issue by setting the keep alive interval to a high value.

deno 1.45.3+7776636 (canary, aarch64-apple-darwin)
v8 12.7.224.13
typescript 5.5.2
Debug Logs
Task start deno run -A --watch=static/,routes/ dev.ts
Watcher Process started.
The manifest has been generated for 6 routes and 1 islands.

 🍋 Fresh ready
    Local: http://localhost:3000/

D 2024-07-26T11:02:41.685Z | v1.11.1 2404 | resolving_load_balancer | dns:localhost:2113 IDLE -> IDLE
D 2024-07-26T11:02:41.685Z | v1.11.1 2404 | connectivity_state | (1) dns:localhost:2113 IDLE -> IDLE
D 2024-07-26T11:02:41.685Z | v1.11.1 2404 | dns_resolver | Resolver constructed for target dns:localhost:2113
D 2024-07-26T11:02:41.686Z | v1.11.1 2404 | channel | (1) dns:localhost:2113 Channel constructed with options {}
D 2024-07-26T11:02:41.686Z | v1.11.1 2404 | channel_stacktrace | (1) Channel constructed
    at new InternalChannel (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@grpc/grpc-js/1.11.1/build/src/internal-channel.js:262:23)
    at new ChannelImplementation (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@grpc/grpc-js/1.11.1/build/src/channel.js:35:32)
    at new Client (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@grpc/grpc-js/1.11.1/build/src/client.js:66:36)
    at new ServiceClientImpl (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@grpc/grpc-js/1.11.1/build/src/make-client.js:58:5)
    at listClusterMembers (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@eventstore/db-client/6.2.1/dist/Client/discovery.js:103:20)
    at discoverEndpoint (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@eventstore/db-client/6.2.1/dist/Client/discovery.js:29:43)
    at Client.resolveUri (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@eventstore/db-client/6.2.1/dist/Client/index.js:270:82)
    at Client.createChannel (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@eventstore/db-client/6.2.1/dist/Client/index.js:244:36)
    at Client.getChannel (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@eventstore/db-client/6.2.1/dist/Client/index.js:196:64)
    at Client.createGRPCClient (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@eventstore/db-client/6.2.1/dist/Client/index.js:200:48)
D 2024-07-26T11:02:41.687Z | v1.11.1 2404 | channel | (1) dns:localhost:2113 createResolvingCall [0] method="/event_store.client.gossip.Gossip/Read", deadline=2024-07-26T11:02:46.684Z
D 2024-07-26T11:02:41.687Z | v1.11.1 2404 | resolving_call | [0] Created
D 2024-07-26T11:02:41.687Z | v1.11.1 2404 | resolving_call | [0] Deadline: 2024-07-26T11:02:46.684Z
D 2024-07-26T11:02:41.687Z | v1.11.1 2404 | resolving_call | [0] Deadline will be reached in 4997ms
D 2024-07-26T11:02:41.687Z | v1.11.1 2404 | resolving_call | [0] start called
D 2024-07-26T11:02:41.687Z | v1.11.1 2404 | dns_resolver | Looking up DNS hostname localhost
D 2024-07-26T11:02:41.689Z | v1.11.1 2404 | resolving_load_balancer | dns:localhost:2113 IDLE -> CONNECTING
D 2024-07-26T11:02:41.689Z | v1.11.1 2404 | connectivity_state | (1) dns:localhost:2113 IDLE -> CONNECTING
D 2024-07-26T11:02:41.689Z | v1.11.1 2404 | channel | (1) dns:localhost:2113 callRefTimer.ref | configSelectionQueue.length=1 pickQueue.length=0
D 2024-07-26T11:02:41.689Z | v1.11.1 2404 | resolving_call | [0] startRead called
D 2024-07-26T11:02:41.689Z | v1.11.1 2404 | resolving_call | [0] write() called with message of length 0
D 2024-07-26T11:02:41.689Z | v1.11.1 2404 | resolving_call | [0] halfClose called
D 2024-07-26T11:02:41.689Z | v1.11.1 2404 | dns_resolver | Resolved addresses for target dns:localhost:2113: [127.0.0.1:2113,::1:2113]
D 2024-07-26T11:02:41.689Z | v1.11.1 2404 | pick_first | updateAddressList([127.0.0.1:2113,[::1]:2113])
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | subchannel | (1) 127.0.0.1:2113 Subchannel constructed with options {}
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | subchannel_refcount | (1) 127.0.0.1:2113 refcount 0 -> 1
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | subchannel | (2) [::1]:2113 Subchannel constructed with options {}
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | subchannel_refcount | (2) [::1]:2113 refcount 0 -> 1
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | pick_first | connectToAddressList([127.0.0.1:2113,[::1]:2113])
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | subchannel_refcount | (1) 127.0.0.1:2113 refcount 1 -> 2
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | subchannel_refcount | (2) [::1]:2113 refcount 1 -> 2
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | pick_first | Start connecting to subchannel with address 127.0.0.1:2113
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | pick_first | IDLE -> CONNECTING
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | resolving_load_balancer | dns:localhost:2113 CONNECTING -> CONNECTING
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | connectivity_state | (1) dns:localhost:2113 CONNECTING -> CONNECTING
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | channel | (1) dns:localhost:2113 callRefTimer.unref | configSelectionQueue.length=0 pickQueue.length=0
D 2024-07-26T11:02:41.690Z | v1.11.1 2404 | subchannel | (1) 127.0.0.1:2113 IDLE -> CONNECTING
D 2024-07-26T11:02:41.691Z | v1.11.1 2404 | transport | dns:localhost:2113 creating HTTP/2 session to 127.0.0.1:2113
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | channel | (1) dns:localhost:2113 createRetryingCall [1] method="/event_store.client.gossip.Gossip/Read"
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | resolving_call | [0] Created child [1]
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | retrying_call | [1] start called
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | channel | (1) dns:localhost:2113 createLoadBalancingCall [2] method="/event_store.client.gossip.Gossip/Read"
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | retrying_call | [1] Created child call [2] for attempt 1
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | load_balancing_call | [2] start called
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | load_balancing_call | [2] Pick called
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | load_balancing_call | [2] Pick result: QUEUE subchannel: null status: undefined undefined
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | channel | (1) dns:localhost:2113 callRefTimer.ref | configSelectionQueue.length=0 pickQueue.length=1
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | retrying_call | [1] startRead called
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | load_balancing_call | [2] startRead called
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | retrying_call | [1] write() called with message of length 5
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | load_balancing_call | [2] write() called with message of length 5
D 2024-07-26T11:02:41.692Z | v1.11.1 2404 | retrying_call | [1] halfClose called
D 2024-07-26T11:02:41.693Z | v1.11.1 2404 | subchannel | (1) 127.0.0.1:2113 CONNECTING -> READY
D 2024-07-26T11:02:41.693Z | v1.11.1 2404 | pick_first | Pick subchannel with address 127.0.0.1:2113
D 2024-07-26T11:02:41.693Z | v1.11.1 2404 | subchannel_refcount | (1) 127.0.0.1:2113 refcount 2 -> 3
D 2024-07-26T11:02:41.693Z | v1.11.1 2404 | subchannel_refcount | (1) 127.0.0.1:2113 refcount 3 -> 2
D 2024-07-26T11:02:41.693Z | v1.11.1 2404 | subchannel_refcount | (2) [::1]:2113 refcount 2 -> 1
D 2024-07-26T11:02:41.693Z | v1.11.1 2404 | pick_first | CONNECTING -> READY
D 2024-07-26T11:02:41.693Z | v1.11.1 2404 | resolving_load_balancer | dns:localhost:2113 CONNECTING -> READY
D 2024-07-26T11:02:41.693Z | v1.11.1 2404 | channel | (1) dns:localhost:2113 callRefTimer.unref | configSelectionQueue.length=0 pickQueue.length=0
D 2024-07-26T11:02:41.693Z | v1.11.1 2404 | load_balancing_call | [2] Pick called
D 2024-07-26T11:02:41.693Z | v1.11.1 2404 | load_balancing_call | [2] Pick result: COMPLETE subchannel: (1) 127.0.0.1:2113 status: undefined undefined
D 2024-07-26T11:02:41.693Z | v1.11.1 2404 | connectivity_state | (1) dns:localhost:2113 CONNECTING -> READY
D 2024-07-26T11:02:41.695Z | v1.11.1 2404 | transport_flowctrl | (1) 127.0.0.1:2113 local window size: undefined remote window size: undefined
Warning: Not implemented: Http2Session.socket
D 2024-07-26T11:02:41.695Z | v1.11.1 2404 | transport_internals | (1) 127.0.0.1:2113 session.closed=false session.destroyed=false session.socket.destroyed=undefined
D 2024-07-26T11:02:41.695Z | v1.11.1 2404 | load_balancing_call | [2] Created child call [3]
D 2024-07-26T11:02:41.695Z | v1.11.1 2404 | subchannel_call | [3] write() called with message of length 5
D 2024-07-26T11:02:41.695Z | v1.11.1 2404 | subchannel_call | [3] sending data chunk of length 5
D 2024-07-26T11:02:41.695Z | v1.11.1 2404 | load_balancing_call | [2] halfClose called
D 2024-07-26T11:02:41.695Z | v1.11.1 2404 | subchannel_call | [3] end() called
D 2024-07-26T11:02:41.695Z | v1.11.1 2404 | subchannel_call | [3] calling end() on HTTP/2 stream
D 2024-07-26T11:02:41.697Z | v1.11.1 2404 | subchannel_call | [3] Received server headers:
                :status: 200
                content-type: application/grpc
                date: Fri, 26 Jul 2024 11:02:41 GMT
                server: Kestrel

D 2024-07-26T11:02:41.697Z | v1.11.1 2404 | load_balancing_call | [2] Received metadata
D 2024-07-26T11:02:41.697Z | v1.11.1 2404 | retrying_call | [1] Received metadata from child [2]
D 2024-07-26T11:02:41.697Z | v1.11.1 2404 | retrying_call | [1] Committing call [2] at index 0
D 2024-07-26T11:02:41.697Z | v1.11.1 2404 | resolving_call | [0] Received metadata
D 2024-07-26T11:02:41.697Z | v1.11.1 2404 | subchannel_call | [3] receive HTTP/2 data frame of length 62
D 2024-07-26T11:02:41.697Z | v1.11.1 2404 | subchannel_call | [3] parsed message of length 62
D 2024-07-26T11:02:41.697Z | v1.11.1 2404 | subchannel_call | [3] pushing to reader message of length 62
D 2024-07-26T11:02:41.697Z | v1.11.1 2404 | load_balancing_call | [2] Received message
D 2024-07-26T11:02:41.697Z | v1.11.1 2404 | retrying_call | [1] Received message from child [2]
D 2024-07-26T11:02:41.697Z | v1.11.1 2404 | resolving_call | [0] Received message
D 2024-07-26T11:02:41.698Z | v1.11.1 2404 | subchannel_call | [3] Received server trailers:
                grpc-status: 0

D 2024-07-26T11:02:41.698Z | v1.11.1 2404 | subchannel_call | [3] received status code 0 from server
D 2024-07-26T11:02:41.698Z | v1.11.1 2404 | resolving_call | [0] Finished filtering received message
D 2024-07-26T11:02:41.699Z | v1.11.1 2404 | subchannel_call | [3] ended with status: code=0 details=""
D 2024-07-26T11:02:41.699Z | v1.11.1 2404 | load_balancing_call | [2] Received status
D 2024-07-26T11:02:41.699Z | v1.11.1 2404 | load_balancing_call | [2] ended with status: code=0 details="" start time=2024-07-26T11:02:41.692Z
D 2024-07-26T11:02:41.699Z | v1.11.1 2404 | retrying_call | [1] Received status from child [2]
D 2024-07-26T11:02:41.699Z | v1.11.1 2404 | retrying_call | [1] state=COMMITTED handling status with progress PROCESSED from child [2] in state ACTIVE
D 2024-07-26T11:02:41.699Z | v1.11.1 2404 | retrying_call | [1] ended with status: code=0 details="" start time=2024-07-26T11:02:41.692Z
D 2024-07-26T11:02:41.699Z | v1.11.1 2404 | resolving_call | [0] Received status
D 2024-07-26T11:02:41.699Z | v1.11.1 2404 | resolving_call | [0] ended with status: code=0 details=""
D 2024-07-26T11:02:41.699Z | v1.11.1 2404 | subchannel_refcount | (1) 127.0.0.1:2113 refcount 2 -> 1
D 2024-07-26T11:02:41.699Z | v1.11.1 2404 | connectivity_state | (1) dns:localhost:2113 READY -> SHUTDOWN
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | subchannel_refcount | (1) 127.0.0.1:2113 refcount 1 -> 0
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | subchannel_refcount | (2) [::1]:2113 refcount 1 -> 0
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | subchannel | (1) 127.0.0.1:2113 READY -> IDLE
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | resolving_load_balancer | dns:127.0.0.1:2113 IDLE -> IDLE
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | connectivity_state | (2) dns:127.0.0.1:2113 IDLE -> IDLE
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | dns_resolver | Resolver constructed for target dns:127.0.0.1:2113
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | channel | (2) dns:127.0.0.1:2113 Channel constructed with options {
  "grpc.keepalive_time_ms": 10000,
  "grpc.keepalive_timeout_ms": 10000,
  "grpc.max_receive_message_length": 17825792
}
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | channel_stacktrace | (2) Channel constructed
    at new InternalChannel (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@grpc/grpc-js/1.11.1/build/src/internal-channel.js:262:23)
    at new ChannelImplementation (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@grpc/grpc-js/1.11.1/build/src/channel.js:35:32)
    at Client.createChannel (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@eventstore/db-client/6.2.1/dist/Client/index.js:247:20)
    at Object.runMicrotasks (ext:core/01_core.js:653:26)
    at processTicksAndRejections (ext:deno_node/_next_tick.ts:53:10)
    at runNextTicks (ext:deno_node/_next_tick.ts:71:3)
    at eventLoopTick (ext:core/01_core.js:175:21)
    at async Client.createGRPCClient (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@eventstore/db-client/6.2.1/dist/Client/index.js:200:37)
    at async Client.execute (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@eventstore/db-client/6.2.1/dist/Client/index.js:182:28)
    at async Client.supports (file:///Users/MY_USERNAME/Library/Caches/deno/npm/registry.npmjs.org/@eventstore/db-client/6.2.1/dist/Client/index.js:305:30)
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | channel | (2) dns:127.0.0.1:2113 createResolvingCall [4] method="/event_store.client.server_features.ServerFeatures/GetSupportedMethods", deadline=Infinity
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | resolving_call | [4] Created
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | resolving_call | [4] Deadline: Infinity
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | resolving_call | [4] start called
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | dns_resolver | Returning IP address for target dns:127.0.0.1:2113
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | resolving_load_balancer | dns:127.0.0.1:2113 IDLE -> CONNECTING
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | connectivity_state | (2) dns:127.0.0.1:2113 IDLE -> CONNECTING
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | channel | (2) dns:127.0.0.1:2113 callRefTimer.ref | configSelectionQueue.length=1 pickQueue.length=0
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | resolving_call | [4] startRead called
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | resolving_call | [4] write() called with message of length 0
D 2024-07-26T11:02:41.700Z | v1.11.1 2404 | resolving_call | [4] halfClose called
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | pick_first | updateAddressList([127.0.0.1:2113])
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | subchannel | (3) 127.0.0.1:2113 Subchannel constructed with options {
  "grpc.keepalive_time_ms": 10000,
  "grpc.keepalive_timeout_ms": 10000,
  "grpc.max_receive_message_length": 17825792
}
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | subchannel_refcount | (3) 127.0.0.1:2113 refcount 0 -> 1
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | pick_first | connectToAddressList([127.0.0.1:2113])
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | subchannel_refcount | (3) 127.0.0.1:2113 refcount 1 -> 2
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | pick_first | Start connecting to subchannel with address 127.0.0.1:2113
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | pick_first | IDLE -> CONNECTING
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | resolving_load_balancer | dns:127.0.0.1:2113 CONNECTING -> CONNECTING
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | connectivity_state | (2) dns:127.0.0.1:2113 CONNECTING -> CONNECTING
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | channel | (2) dns:127.0.0.1:2113 callRefTimer.unref | configSelectionQueue.length=0 pickQueue.length=0
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | subchannel | (3) 127.0.0.1:2113 IDLE -> CONNECTING
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | transport | dns:127.0.0.1:2113 creating HTTP/2 session to 127.0.0.1:2113
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | channel | (2) dns:127.0.0.1:2113 createRetryingCall [5] method="/event_store.client.server_features.ServerFeatures/GetSupportedMethods"
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | resolving_call | [4] Created child [5]
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | retrying_call | [5] start called
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | channel | (2) dns:127.0.0.1:2113 createLoadBalancingCall [6] method="/event_store.client.server_features.ServerFeatures/GetSupportedMethods"
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | retrying_call | [5] Created child call [6] for attempt 1
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | load_balancing_call | [6] start called
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | load_balancing_call | [6] Pick called
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | load_balancing_call | [6] Pick result: QUEUE subchannel: null status: undefined undefined
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | channel | (2) dns:127.0.0.1:2113 callRefTimer.ref | configSelectionQueue.length=0 pickQueue.length=1
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | retrying_call | [5] startRead called
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | load_balancing_call | [6] startRead called
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | retrying_call | [5] write() called with message of length 5
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | load_balancing_call | [6] write() called with message of length 5
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | retrying_call | [5] halfClose called
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | subchannel | (3) 127.0.0.1:2113 CONNECTING -> READY
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | pick_first | Pick subchannel with address 127.0.0.1:2113
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | subchannel_refcount | (3) 127.0.0.1:2113 refcount 2 -> 3
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | subchannel_refcount | (3) 127.0.0.1:2113 refcount 3 -> 2
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | pick_first | CONNECTING -> READY
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | resolving_load_balancer | dns:127.0.0.1:2113 CONNECTING -> READY
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | channel | (2) dns:127.0.0.1:2113 callRefTimer.unref | configSelectionQueue.length=0 pickQueue.length=0
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | load_balancing_call | [6] Pick called
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | load_balancing_call | [6] Pick result: COMPLETE subchannel: (3) 127.0.0.1:2113 status: undefined undefined
D 2024-07-26T11:02:41.702Z | v1.11.1 2404 | connectivity_state | (2) dns:127.0.0.1:2113 CONNECTING -> READY
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | transport_flowctrl | (2) 127.0.0.1:2113 local window size: undefined remote window size: undefined
Warning: Not implemented: Http2Session.socket
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | transport_internals | (2) 127.0.0.1:2113 session.closed=false session.destroyed=false session.socket.destroyed=undefined
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | keepalive | (2) 127.0.0.1:2113 Starting keepalive timer for 10000ms
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | load_balancing_call | [6] Created child call [7]
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | subchannel_call | [7] write() called with message of length 5
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | subchannel_call | [7] sending data chunk of length 5
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | load_balancing_call | [6] halfClose called
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | subchannel_call | [7] end() called
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | subchannel_call | [7] calling end() on HTTP/2 stream
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | subchannel_call | [7] Received server headers:
                :status: 200
                content-type: application/grpc
                date: Fri, 26 Jul 2024 11:02:41 GMT
                server: Kestrel

D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | load_balancing_call | [6] Received metadata
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | retrying_call | [5] Received metadata from child [6]
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | retrying_call | [5] Committing call [6] at index 0
D 2024-07-26T11:02:41.703Z | v1.11.1 2404 | resolving_call | [4] Received metadata
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | subchannel_call | [7] receive HTTP/2 data frame of length 2670
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | subchannel_call | [7] parsed message of length 2670
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | subchannel_call | [7] pushing to reader message of length 2670
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | load_balancing_call | [6] Received message
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | retrying_call | [5] Received message from child [6]
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | resolving_call | [4] Received message
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | subchannel_call | [7] Received server trailers:
                grpc-status: 0

D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | subchannel_call | [7] received status code 0 from server
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | resolving_call | [4] Finished filtering received message
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | subchannel_call | [7] ended with status: code=0 details=""
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | load_balancing_call | [6] Received status
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | load_balancing_call | [6] ended with status: code=0 details="" start time=2024-07-26T11:02:41.702Z
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | retrying_call | [5] Received status from child [6]
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | retrying_call | [5] state=COMMITTED handling status with progress PROCESSED from child [6] in state ACTIVE
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | retrying_call | [5] ended with status: code=0 details="" start time=2024-07-26T11:02:41.702Z
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | resolving_call | [4] Received status
D 2024-07-26T11:02:41.704Z | v1.11.1 2404 | resolving_call | [4] ended with status: code=0 details=""
D 2024-07-26T11:02:41.705Z | v1.11.1 2404 | channel | (2) dns:127.0.0.1:2113 createResolvingCall [8] method="/event_store.client.streams.Streams/BatchAppend", deadline=Infinity
D 2024-07-26T11:02:41.705Z | v1.11.1 2404 | resolving_call | [8] Created
D 2024-07-26T11:02:41.705Z | v1.11.1 2404 | resolving_call | [8] Deadline: Infinity
D 2024-07-26T11:02:41.705Z | v1.11.1 2404 | resolving_call | [8] start called
D 2024-07-26T11:02:41.705Z | v1.11.1 2404 | channel | (2) dns:127.0.0.1:2113 createRetryingCall [9] method="/event_store.client.streams.Streams/BatchAppend"
D 2024-07-26T11:02:41.705Z | v1.11.1 2404 | resolving_call | [8] Created child [9]
D 2024-07-26T11:02:41.705Z | v1.11.1 2404 | retrying_call | [9] start called
D 2024-07-26T11:02:41.705Z | v1.11.1 2404 | channel | (2) dns:127.0.0.1:2113 createLoadBalancingCall [10] method="/event_store.client.streams.Streams/BatchAppend"
D 2024-07-26T11:02:41.705Z | v1.11.1 2404 | retrying_call | [9] Created child call [10] for attempt 1
D 2024-07-26T11:02:41.705Z | v1.11.1 2404 | load_balancing_call | [10] start called
D 2024-07-26T11:02:41.705Z | v1.11.1 2404 | load_balancing_call | [10] Pick called
D 2024-07-26T11:02:41.705Z | v1.11.1 2404 | load_balancing_call | [10] Pick result: COMPLETE subchannel: (3) 127.0.0.1:2113 status: undefined undefined
D 2024-07-26T11:02:41.706Z | v1.11.1 2404 | resolving_call | [8] write() called with message of length 287
D 2024-07-26T11:02:41.706Z | v1.11.1 2404 | transport_flowctrl | (2) 127.0.0.1:2113 local window size: undefined remote window size: undefined
Warning: Not implemented: Http2Session.socket
D 2024-07-26T11:02:41.706Z | v1.11.1 2404 | transport_internals | (2) 127.0.0.1:2113 session.closed=false session.destroyed=false session.socket.destroyed=undefined
D 2024-07-26T11:02:41.706Z | v1.11.1 2404 | load_balancing_call | [10] Created child call [11]
D 2024-07-26T11:02:41.706Z | v1.11.1 2404 | retrying_call | [9] write() called with message of length 292
D 2024-07-26T11:02:41.706Z | v1.11.1 2404 | load_balancing_call | [10] write() called with message of length 292
D 2024-07-26T11:02:41.706Z | v1.11.1 2404 | subchannel_call | [11] write() called with message of length 292
D 2024-07-26T11:02:41.706Z | v1.11.1 2404 | subchannel_call | [11] sending data chunk of length 292
D 2024-07-26T11:02:41.706Z | v1.11.1 2404 | resolving_call | [8] startRead called
D 2024-07-26T11:02:41.706Z | v1.11.1 2404 | retrying_call | [9] startRead called
D 2024-07-26T11:02:41.706Z | v1.11.1 2404 | load_balancing_call | [10] startRead called
D 2024-07-26T11:02:41.711Z | v1.11.1 2404 | subchannel_call | [11] Received server headers:
                :status: 200
                content-type: application/grpc
                date: Fri, 26 Jul 2024 11:02:41 GMT
                server: Kestrel

D 2024-07-26T11:02:41.711Z | v1.11.1 2404 | load_balancing_call | [10] Received metadata
D 2024-07-26T11:02:41.711Z | v1.11.1 2404 | retrying_call | [9] Received metadata from child [10]
D 2024-07-26T11:02:41.711Z | v1.11.1 2404 | retrying_call | [9] Committing call [10] at index 0
D 2024-07-26T11:02:41.711Z | v1.11.1 2404 | resolving_call | [8] Received metadata
D 2024-07-26T11:02:41.711Z | v1.11.1 2404 | subchannel_call | [11] receive HTTP/2 data frame of length 108
D 2024-07-26T11:02:41.711Z | v1.11.1 2404 | subchannel_call | [11] parsed message of length 108
D 2024-07-26T11:02:41.711Z | v1.11.1 2404 | subchannel_call | [11] pushing to reader message of length 108
D 2024-07-26T11:02:41.711Z | v1.11.1 2404 | load_balancing_call | [10] Received message
D 2024-07-26T11:02:41.711Z | v1.11.1 2404 | retrying_call | [9] Received message from child [10]
D 2024-07-26T11:02:41.712Z | v1.11.1 2404 | resolving_call | [8] Received message
D 2024-07-26T11:02:41.712Z | v1.11.1 2404 | resolving_call | [8] Finished filtering received message
D 2024-07-26T11:02:41.715Z | v1.11.1 2404 | resolving_call | [8] startRead called
D 2024-07-26T11:02:41.715Z | v1.11.1 2404 | retrying_call | [9] startRead called
D 2024-07-26T11:02:41.715Z | v1.11.1 2404 | load_balancing_call | [10] startRead called
D 2024-07-26T11:02:43.411Z | v1.11.1 2404 | resolving_call | [8] write() called with message of length 287
D 2024-07-26T11:02:43.411Z | v1.11.1 2404 | retrying_call | [9] write() called with message of length 292
D 2024-07-26T11:02:43.411Z | v1.11.1 2404 | load_balancing_call | [10] write() called with message of length 292
D 2024-07-26T11:02:43.411Z | v1.11.1 2404 | subchannel_call | [11] write() called with message of length 292
D 2024-07-26T11:02:43.411Z | v1.11.1 2404 | subchannel_call | [11] sending data chunk of length 292
D 2024-07-26T11:02:43.417Z | v1.11.1 2404 | subchannel_call | [11] receive HTTP/2 data frame of length 108
D 2024-07-26T11:02:43.417Z | v1.11.1 2404 | subchannel_call | [11] parsed message of length 108
D 2024-07-26T11:02:43.417Z | v1.11.1 2404 | subchannel_call | [11] pushing to reader message of length 108
D 2024-07-26T11:02:43.418Z | v1.11.1 2404 | load_balancing_call | [10] Received message
D 2024-07-26T11:02:43.418Z | v1.11.1 2404 | retrying_call | [9] Received message from child [10]
D 2024-07-26T11:02:43.418Z | v1.11.1 2404 | resolving_call | [8] Received message
D 2024-07-26T11:02:43.418Z | v1.11.1 2404 | resolving_call | [8] Finished filtering received message
D 2024-07-26T11:02:43.419Z | v1.11.1 2404 | resolving_call | [8] startRead called
D 2024-07-26T11:02:43.419Z | v1.11.1 2404 | retrying_call | [9] startRead called
D 2024-07-26T11:02:43.420Z | v1.11.1 2404 | load_balancing_call | [10] startRead called
D 2024-07-26T11:02:51.703Z | v1.11.1 2404 | keepalive | (2) 127.0.0.1:2113 Sending ping with timeout 10000ms
D 2024-07-26T11:02:51.703Z | v1.11.1 2404 | keepalive | (2) 127.0.0.1:2113 Ping send failed: Not implemented: Http2Session.ping
D 2024-07-26T11:02:51.703Z | v1.11.1 2404 | subchannel | (3) 127.0.0.1:2113 READY -> IDLE
D 2024-07-26T11:02:51.703Z | v1.11.1 2404 | subchannel_refcount | (3) 127.0.0.1:2113 refcount 2 -> 1
D 2024-07-26T11:02:51.704Z | v1.11.1 2404 | pick_first | READY -> IDLE
D 2024-07-26T11:02:51.704Z | v1.11.1 2404 | resolving_load_balancer | dns:127.0.0.1:2113 READY -> IDLE
D 2024-07-26T11:02:51.704Z | v1.11.1 2404 | connectivity_state | (2) dns:127.0.0.1:2113 READY -> IDLE
error: Uncaught (in promise) Error: stream closed because of a broken pipe
    at async node:http2:735:44
Watcher Process failed. Restarting on file change...

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working correctly node API polyfill Related to various "node:*" modules APIs node compat
Projects
None yet