How are you calling it? Can you share a snippet? - Cloudflare Developers

© 2026 Hedgehog Software, LLC

More

Communities Docs About Terms Privacy

James

JJames How are you calling it? Can you share a snippet?

johtso

J

johtso•4/6/24, 10:12 PM

async function membershipRequestHandler (request: Request, env: Env) {
    const body = await request.arrayBuffer();

    console.log(`Parsing PDF size ${body.byteLength / 1024 / 1024} MBs`)

    const result = await env.PDFPARSER_SERVICE.parsePdf(body);

async function membershipRequestHandler (request: Request, env: Env) {
    const body = await request.arrayBuffer();

    console.log(`Parsing PDF size ${body.byteLength / 1024 / 1024} MBs`)

    const result = await env.PDFPARSER_SERVICE.parsePdf(body);

johtso

J

johtso•4/6/24, 10:13 PM

export class PdfParserService extends WorkerEntrypoint<Env> {
  async fetch() { return new Response("Hello from Worker B"); }
  
  async parsePdf(data: ArrayBuffer) {
        return await pdf2array(Buffer.from(data));
    }
}

export class PdfParserService extends WorkerEntrypoint<Env> {
  async fetch() { return new Response("Hello from Worker B"); }
  
  async parsePdf(data: ArrayBuffer) {
        return await pdf2array(Buffer.from(data));
    }
}

James

J

JamesOP•4/6/24, 10:13 PM

And your toml is this?

[[services]]
binding = "PDFPARSER_SERVICE"
service = "pdfparser"
entrypoint = "PdfParserService"

[[services]]
binding = "PDFPARSER_SERVICE"
service = "pdfparser"
entrypoint = "PdfParserService"

johtso

J

johtso•4/6/24, 10:14 PM

exactly

James

J

JamesOP•4/6/24, 10:14 PM

Hmm, looks fine on the surface to me

johtso

J

johtso•4/6/24, 10:14 PM

I do have lots of linting errors in my TOML file.. I can't for a life of me remember what's responsible for that linting though

johtso

J

johtso•4/6/24, 10:15 PM

whatever it is doesn't know about upload_source_mapsupload_source_maps or services -> entrypointservices -> entrypoint

johtso

J

johtso•4/6/24, 10:20 PM

@James from a bit of google I think it might actually have something to do with what I'm doing with the request body

johtso

J

johtso•4/6/24, 10:21 PM

I'll try just doing a hello world method on the service worker

johtso

J

johtso•4/6/24, 10:23 PM

nope, no luck with that either

kian

K

kian•4/6/24, 11:18 PM

What's your full TOML?

kian

Kkian What's your full TOML?

johtso

J

johtso•4/6/24, 11:26 PM

name = "newdo"
main = "src/index.ts"
compatibility_date = "2024-04-06"
compatibility_flags = [ "nodejs_compat" ]
logpush = true
upload_source_maps = true

[vars]
SERVICE_NAME = "datawrangler"

[[services]]
binding = "PDFPARSER_SERVICE"
service = "pdfparser"
entrypoint = "PdfParserService"

[[d1_databases]]
binding = "DB" # i.e. available in your Worker on env.DB
database_name = "memberships"
database_id = "xxxxxxxxxxx"
migrations_dir = "../database/src/migrations"

[[durable_objects.bindings]]
name = "MY_DURABLE_OBJECT"
class_name = "MyDurableObject"

[[migrations]]
tag = "v1"
new_classes = ["MyDurableObject"]

name = "newdo"
main = "src/index.ts"
compatibility_date = "2024-04-06"
compatibility_flags = [ "nodejs_compat" ]
logpush = true
upload_source_maps = true

[vars]
SERVICE_NAME = "datawrangler"

[[services]]
binding = "PDFPARSER_SERVICE"
service = "pdfparser"
entrypoint = "PdfParserService"

[[d1_databases]]
binding = "DB" # i.e. available in your Worker on env.DB
database_name = "memberships"
database_id = "xxxxxxxxxxx"
migrations_dir = "../database/src/migrations"

[[durable_objects.bindings]]
name = "MY_DURABLE_OBJECT"
class_name = "MyDurableObject"

[[migrations]]
tag = "v1"
new_classes = ["MyDurableObject"]

johtso

J

johtso•4/6/24, 11:27 PM

OH

johtso

J

johtso•4/6/24, 11:27 PM

I have an idea..

johtso

J

johtso•4/6/24, 11:30 PM

@kian aha! it was because I was instrumenting my worker with otel-cf-workers

johtso

J

johtso•4/6/24, 11:30 PM

makes total sense that that would break things

johtso

J

johtso•4/6/24, 11:31 PM

and now that I look at the stacktrace again I see it..

johtso

J

johtso•4/6/24, 11:32 PM

so I now get "Error: Cannot access

hello

hello

as we couldn't find a

wrangler dev

wrangler dev

session for service "pdfparser" to proxy to"

Silent

S

Silent•4/6/24, 11:35 PM

How do i trigger a workers cron schedule code manually once?

Walshy

W

Walshy•4/6/24, 11:47 PM

What I do is just have a fetch handler with some auth check and I just manually hit it

Walshy

W

Walshy•4/6/24, 11:47 PM

In local dev I think you can hit like /__trigger_cron or something but prod doesn't have that

johtso

J

johtso•4/6/24, 11:47 PM

RPC is now working deployed! just not working locally with the dev server

johtso

J

johtso•4/6/24, 11:48 PM

not sure how wrangler tries to find the other dev session with the service.. but something ain't working

johtso

J

johtso•4/6/24, 11:48 PM

on a different note, is there a way to proxy the incoming request data to the service instead of serializing the data?

johtso

J

johtso•4/6/24, 11:49 PM

I'm handling files that exceed the 1MB limit

johtso

J

johtso•4/6/24, 11:49 PM

so just passing the request body ArrayBuffer as an argument to the service worker method doesn't work

johtso

J

johtso•4/6/24, 11:51 PM

the blog post says "You can send a byte stream over RPC, and the system will automatically stream the bytes with proper flow control."

johtso

J

johtso•4/6/24, 11:52 PM

I guess I just give it the whole ResponseResponse instead? the post doesn't seem to say

johtso

J

johtso•4/7/24, 12:04 AM

that works

johtso

J

johtso•4/7/24, 12:25 AM

also not sure what changed.. but it's working locally now too

johtso

J

johtso•4/7/24, 12:25 AM

the only thing that isn't working now is the types

boywonder350

B

boywonder350•4/7/24, 12:29 AM

Does anyone know if you need to read the

body

body

of a

fetch

fetch

response for it to be garbage collected properly? Sometimes I make requests but don't care about the body and want to make sure this is ok

user

U

user•4/7/24, 4:11 AM

I am suffering getting my CF pages site to be able to access my CF worker

user

U

user•4/7/24, 4:12 AM

cors my behated

addison

A

addison•4/7/24, 6:50 AM

is anyone having issues with mailchannels on workers? getting

"Get \"http://customer-accounts-service.outbound.svc.cluster.local.:9292/v1/accounts/cloudflare\": read tcp 100.112.254.53:39318->100.70.108.250:9292: read: connection reset by peer"

"Get \"http://customer-accounts-service.outbound.svc.cluster.local.:9292/v1/accounts/cloudflare\": read tcp 100.112.254.53:39318->100.70.108.250:9292: read: connection reset by peer"

jlworkshop

Jjlworkshop for example, your CF page served at example.com, and you would like to trigger y...

user

U

user•4/7/24, 7:17 AM

._.

user

U

user•4/7/24, 7:17 AM

hadn’t thought of that.

johtso

J

johtso•4/7/24, 9:57 AM

Does anyone know what's up with this style of import? https://github.com/cloudflare/js-rpc-and-entrypoints-demo/blob/main/public-admin-api-interfaces%2Fpublic-service%2Fsrc%2Findex.ts#L1

GitHub

js-rpc-and-entrypoints-demo/public-admin-api-interfaces/public-serv...

Contribute to cloudflare/js-rpc-and-entrypoints-demo development by creating an account on GitHub.

johtso

J

johtso•4/7/24, 9:58 AM

Seems strange to be importing a type from .js in a typescript project.. but I can't get RPC types working and this is the only difference I can see..

johtso

J

johtso•4/7/24, 11:13 AM

aha, apparently it's to do with using module: preserve and moduleResolution: Bundler

johtso

J

johtso•4/7/24, 11:14 AM

Is it intended behavior that RPC calls to services appear as "Unknown Event - Ok @ 07/04/2024, 12:11:08" in logs?

johtso

J

johtso•4/7/24, 1:16 PM

Okay, so switching to @cloudflare/workers-types/experimental@cloudflare/workers-types/experimental fixes my type issues with Workers RPC

johtso

J

johtso•4/7/24, 1:17 PM

is this a bug? should @cloudflare/workers-types/2023-07-01@cloudflare/workers-types/2023-07-01 support the new RPC functionality?

James

J

JamesOP•4/7/24, 1:17 PM

Not yet afaik: https://cfdata.lol/workerd/

workerd - Cloudflare Datamining

Automated datamining from workerd, the Cloudflare Workers runtime. Including compatibility flags.

async function membershipRequestHandler (request: Request, env: Env) {
    const body = await request.arrayBuffer();

    console.log(`Parsing PDF size ${body.byteLength / 1024 / 1024} MBs`)

    const result = await env.PDFPARSER_SERVICE.parsePdf(body);

async function membershipRequestHandler (request: Request, env: Env) {
    const body = await request.arrayBuffer();

    console.log(`Parsing PDF size ${body.byteLength / 1024 / 1024} MBs`)

    const result = await env.PDFPARSER_SERVICE.parsePdf(body);

export class PdfParserService extends WorkerEntrypoint<Env> {
  async fetch() { return new Response("Hello from Worker B"); }
  
  async parsePdf(data: ArrayBuffer) {
        return await pdf2array(Buffer.from(data));
    }
}

export class PdfParserService extends WorkerEntrypoint<Env> {
  async fetch() { return new Response("Hello from Worker B"); }
  
  async parsePdf(data: ArrayBuffer) {
        return await pdf2array(Buffer.from(data));
    }
}

name = "newdo"
main = "src/index.ts"
compatibility_date = "2024-04-06"
compatibility_flags = [ "nodejs_compat" ]
logpush = true
upload_source_maps = true

[vars]
SERVICE_NAME = "datawrangler"

[[services]]
binding = "PDFPARSER_SERVICE"
service = "pdfparser"
entrypoint = "PdfParserService"

[[d1_databases]]
binding = "DB" # i.e. available in your Worker on env.DB
database_name = "memberships"
database_id = "xxxxxxxxxxx"
migrations_dir = "../database/src/migrations"

[[durable_objects.bindings]]
name = "MY_DURABLE_OBJECT"
class_name = "MyDurableObject"

[[migrations]]
tag = "v1"
new_classes = ["MyDurableObject"]

name = "newdo"
main = "src/index.ts"
compatibility_date = "2024-04-06"
compatibility_flags = [ "nodejs_compat" ]
logpush = true
upload_source_maps = true

[vars]
SERVICE_NAME = "datawrangler"

[[services]]
binding = "PDFPARSER_SERVICE"
service = "pdfparser"
entrypoint = "PdfParserService"

[[d1_databases]]
binding = "DB" # i.e. available in your Worker on env.DB
database_name = "memberships"
database_id = "xxxxxxxxxxx"
migrations_dir = "../database/src/migrations"

[[durable_objects.bindings]]
name = "MY_DURABLE_OBJECT"
class_name = "MyDurableObject"

[[migrations]]
tag = "v1"
new_classes = ["MyDurableObject"]