deno icon indicating copy to clipboard operation
deno copied to clipboard

Published 20 hours ago • verified publisher icon denoland

Not implemented: Http2Session.socket

Open uriva opened this issue 1 year ago • 21 comments 

$ 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));

uriva avatar Oct 13 '23 14:10 uriva

Which version of Deno are you using?

bartlomieju avatar Oct 13 '23 15:10 bartlomieju

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

michaelmass avatar Oct 13 '23 23:10 michaelmass

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);

cesumilo avatar Oct 17 '23 10:10 cesumilo

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'?

JonathonRP avatar Oct 19 '23 14:10 JonathonRP

@JonathonRP I think it's #20923.

MarybethGasman avatar Oct 23 '23 14:10 MarybethGasman

same here

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

With npm:firebase-admin/firestore.

RoXuS avatar Oct 24 '23 14:10 RoXuS

Same with @google-cloud/datastore

jacek-jablonski avatar Oct 29 '23 18:10 jacek-jablonski

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";

W4G1 avatar Nov 17 '23 21:11 W4G1

@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: https://github.com/denoland/deno/issues/16647

tenkoverse avatar Nov 22 '23 21:11 tenkoverse

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

yzalium avatar Nov 30 '23 14:11 yzalium

The same issue with Deno v1.38.5

akkadaya avatar Dec 06 '23 01:12 akkadaya

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!

samrocksc avatar Dec 08 '23 14:12 samrocksc

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

leo-lox avatar Dec 31 '23 11:12 leo-lox

Same here. If I understand correctly looking at the Deno codebase, Http2Session.socket is not implemented yet, which prevents using firebase-admin and deno: https://github.com/denoland/deno/blob/bc8d00c880756a46b0ce4c8bf0c89407a2de669c/ext/node/polyfills/http2.ts#L181-L184

PierreCapo avatar Jan 15 '24 09:01 PierreCapo

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? 🥲

cesumilo avatar Feb 02 '24 20:02 cesumilo

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 [email protected]: 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 [email protected]: this library is no longer supported
[npm] deprecated [email protected]: 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

PedroReyes avatar Feb 03 '24 21:02 PedroReyes

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

samrocksc avatar Feb 05 '24 08:02 samrocksc

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.

satyarohith avatar Feb 21 '24 14:02 satyarohith

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

yzalium avatar Feb 23 '24 16:02 yzalium

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

dylanpyle avatar Mar 19 '24 18:03 dylanpyle 

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

burakakca avatar May 15 '24 14:05 burakakca

@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?

satyarohith avatar May 30 '24 10:05 satyarohith

@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

burakakca avatar May 30 '24 20:05 burakakca

@burakakca can you try running with the latest canary (deno upgrade --canary)? I wonder if https://github.com/denoland/deno/pull/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.

satyarohith avatar Jun 11 '24 15:06 satyarohith

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".

burakakca avatar Jun 12 '24 12:06 burakakca

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);

yzalium avatar Jun 19 '24 17:06 yzalium

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

elizeuangelo avatar Jul 04 '24 16:07 elizeuangelo

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...

lukket avatar Jul 26 '24 11:07 lukket