search

denoland / deno

A modern runtime for JavaScript and TypeScript.
https://deno.com
MIT License
94.62k stars 5.25k forks source link

Not implemented: Http2Session.socket #20903

Closed uriva closed 1 month ago

uriva commented 11 months ago 
$ 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 commented 11 months ago

Which version of Deno are you using?

michaelmass commented 11 months ago

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 commented 11 months ago

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 commented 11 months ago

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 commented 11 months ago

@JonathonRP I think it's #20923.

RoXuS commented 11 months ago

same here

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

With npm:firebase-admin/firestore.

jacek-jablonski commented 11 months ago

Same with @google-cloud/datastore

W4G1 commented 10 months ago

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 commented 10 months ago

@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/@grpc+grpc-js@1.7.3/node_modules/@grpc/grpc-js/build/src/subchannel.js:536:32)
    at ClientHttp2Session.<anonymous> (->/node_modules/.deno/@grpc+grpc-js@1.7.3/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

yzalium commented 10 months ago

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/pubsub@4.0.7/denonext/pubsub.mjs:47:99164
    at https://esm.sh/v135/@google-cloud/pubsub@4.0.7/denonext/pubsub.mjs:47:458
    at https://esm.sh/v135/@google-cloud/pubsub@4.0.7/denonext/pubsub.mjs:47:101751
    at https://esm.sh/v135/@google-cloud/pubsub@4.0.7/denonext/pubsub.mjs:47:458
    at https://esm.sh/v135/@google-cloud/pubsub@4.0.7/denonext/pubsub.mjs:47:112692
    at https://esm.sh/v135/@google-cloud/pubsub@4.0.7/denonext/pubsub.mjs:47:458
    at https://esm.sh/v135/@google-cloud/pubsub@4.0.7/denonext/pubsub.mjs:47:120334
    at https://esm.sh/v135/@google-cloud/pubsub@4.0.7/denonext/pubsub.mjs:47:458
    at https://esm.sh/v135/@google-cloud/pubsub@4.0.7/denonext/pubsub.mjs:47:124744
    at https://esm.sh/v135/@google-cloud/pubsub@4.0.7/denonext/pubsub.mjs:47:458
deno 1.38.3 (release, aarch64-apple-darwin)
v8 12.0.267.1
typescript 5.2.2
akkadaya commented 10 months ago

The same issue with Deno v1.38.5

samrocksc commented 10 months ago

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/pubsub@4.0.7";

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 commented 9 months ago

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 commented 8 months ago

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

cesumilo commented 8 months ago

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 commented 8 months ago

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/firebase-admin@11.10.1/app";
import { getFirestore } from "https://esm.sh/firebase-admin@11.10.1/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 commented 8 months ago

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

satyarohith commented 7 months ago

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 commented 7 months ago

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

dylanpyle commented 6 months ago

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/pubsub@4.3.3";
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

burakakca commented 4 months ago 
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 commented 4 months ago

@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 commented 4 months ago

@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 commented 3 months ago

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

burakakca commented 3 months ago

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 commented 3 months ago

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 commented 3 months ago

I'm trying using "npm:firebase-admin@12.2.0" and it still doesn't work: Warning: Not implemented: Http2Session.socket

lukket commented 2 months ago

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