to have several service bindings to other workers in one worker, what's the correct way of formattin

C

Corsix👾OP•9/23/24, 8:48 PM

i presume but didn't se any in the documentation about it

HHello, I’m Allie!Maybe try pushing them via a `ReadableStream`?

M

Murder Chicken•9/23/24, 10:01 PM

If we're hitting the RPC argument size limit, what are our options. For instance, if we're dealing with a lot of data that needs to to be sent to a service layer via a binding, are we forced to break the data up to get past this limit. You mentioned

ReadableStream

ReadableStream

ReadableStream

ReadableStream ... is there a way to use this to push large arrays of data as an argument?

M

Mingxi•9/24/24, 1:57 AM

Has anyone encountered this issue? I have a domain name pointing to 192.0.2.1 and it's working fine, but no matter what, I can't find the worker that has this domain name bound to it in the worker section.

Y

Yash Bindal (yB)•9/24/24, 8:20 AM

Hi Is there any way possible to use ipv4 to hit external APi instead of Ipv6

Jjam_zaw Hello everyone, I'm looking to implement a caching strategy for my Cloudflare Wo...

C

chocolatkey•9/24/24, 8:28 AM

I saw this, I think this is worth discussing. I've always wondered when using workers what the closest memcached equivalent is, for when I want to store data in a K/V layout, but I don't care about consistency, replication, reliability etc, I just want to e.g. reduce the amount of requests to a database or storage. I've settled on using the cache API + a local map for now, and it seems to work pretty well. I'm not sure how normal this is, but here's what I do:
helpers:

interface ExpiringValue<T> {
    value: T;
    expires: number;
}

// Cloudflare cache namespaces
export const MY_KV_NAMESPACE = 'myservice.internal/v1'
export const MY_CACHE_NAMESPACE = 'https://' + FLAME_KV_NAMESPACE

// These types let you operate on an in-memory cache stored in a Map

/**
 * Get a value from cache
 * @param store Store to access
 * @param key Lookup key
 * @returns Stored type
 */
export function cget<T>(store: Map<string, ExpiringValue<T>>, key: string): T | undefined {
    const val = store.get(key)
    if (!val) return undefined
    if(val.expires < (Date.now() / 1000)) {
        store.delete(key)
        return undefined
    }
    return val.value
}

/**
 * Store a value in cache
 * @param store Store to access
 * @param key Lookup key
 * @param value Value to store
 * @param ttl Time to live in seconds
 */
export function cset<T>(store: Map<string, ExpiringValue<T>>, key: string, value: T, ttl: number) {
    store.set(key, {
        expires: (Date.now() / 1000) + ttl,
        value
    })
}

/**
 * Delete a value in cache
 * @param store Store to access
 * @param key Lookup key
 */
export function cdel<T>(store: Map<string, ExpiringValue<T>>, key: string) {
    store.delete(key)
}

interface ExpiringValue<T> {
    value: T;
    expires: number;
}

// Cloudflare cache namespaces
export const MY_KV_NAMESPACE = 'myservice.internal/v1'
export const MY_CACHE_NAMESPACE = 'https://' + FLAME_KV_NAMESPACE

// These types let you operate on an in-memory cache stored in a Map

/**
 * Get a value from cache
 * @param store Store to access
 * @param key Lookup key
 * @returns Stored type
 */
export function cget<T>(store: Map<string, ExpiringValue<T>>, key: string): T | undefined {
    const val = store.get(key)
    if (!val) return undefined
    if(val.expires < (Date.now() / 1000)) {
        store.delete(key)
        return undefined
    }
    return val.value
}

/**
 * Store a value in cache
 * @param store Store to access
 * @param key Lookup key
 * @param value Value to store
 * @param ttl Time to live in seconds
 */
export function cset<T>(store: Map<string, ExpiringValue<T>>, key: string, value: T, ttl: number) {
    store.set(key, {
        expires: (Date.now() / 1000) + ttl,
        value
    })
}

/**
 * Delete a value in cache
 * @param store Store to access
 * @param key Lookup key
 */
export function cdel<T>(store: Map<string, ExpiringValue<T>>, key: string) {
    store.delete(key)
}

interface ExpiringValue<T> {
    value: T;
    expires: number;
}

// Cloudflare cache namespaces
export const MY_KV_NAMESPACE = 'myservice.internal/v1'
export const MY_CACHE_NAMESPACE = 'https://' + FLAME_KV_NAMESPACE

// These types let you operate on an in-memory cache stored in a Map

/**
 * Get a value from cache
 * @param store Store to access
 * @param key Lookup key
 * @returns Stored type
 */
export function cget<T>(store: Map<string, ExpiringValue<T>>, key: string): T | undefined {
    const val = store.get(key)
    if (!val) return undefined
    if(val.expires < (Date.now() / 1000)) {
        store.delete(key)
        return undefined
    }
    return val.value
}

/**
 * Store a value in cache
 * @param store Store to access
 * @param key Lookup key
 * @param value Value to store
 * @param ttl Time to live in seconds
 */
export function cset<T>(store: Map<string, ExpiringValue<T>>, key: string, value: T, ttl: number) {
    store.set(key, {
        expires: (Date.now() / 1000) + ttl,
        value
    })
}

/**
 * Delete a value in cache
 * @param store Store to access
 * @param key Lookup key
 */
export function cdel<T>(store: Map<string, ExpiringValue<T>>, key: string) {
    store.delete(key)
}

interface ExpiringValue<T> {
    value: T;
    expires: number;
}

// Cloudflare cache namespaces
export const MY_KV_NAMESPACE = 'myservice.internal/v1'
export const MY_CACHE_NAMESPACE = 'https://' + FLAME_KV_NAMESPACE

// These types let you operate on an in-memory cache stored in a Map

/**
 * Get a value from cache
 * @param store Store to access
 * @param key Lookup key
 * @returns Stored type
 */
export function cget<T>(store: Map<string, ExpiringValue<T>>, key: string): T | undefined {
    const val = store.get(key)
    if (!val) return undefined
    if(val.expires < (Date.now() / 1000)) {
        store.delete(key)
        return undefined
    }
    return val.value
}

/**
 * Store a value in cache
 * @param store Store to access
 * @param key Lookup key
 * @param value Value to store
 * @param ttl Time to live in seconds
 */
export function cset<T>(store: Map<string, ExpiringValue<T>>, key: string, value: T, ttl: number) {
    store.set(key, {
        expires: (Date.now() / 1000) + ttl,
        value
    })
}

/**
 * Delete a value in cache
 * @param store Store to access
 * @param key Lookup key
 */
export function cdel<T>(store: Map<string, ExpiringValue<T>>, key: string) {
    store.delete(key)
}

C

chocolatkey•9/24/24, 8:28 AM

(continued from previous message) implementation:

const thingCache = new Map<string, ExpiringValue<ThingType>>() // Global scope

async function something(id: string) {
    let thing = cget(thingCache, id);
    if(!thing) {
        // Try to get thing from DC cache
        const cacheKey = `things/${id}`
        const dcache = caches.default
        const cachedClient = await dcache.match(`${MY_KV_NAMESPACE}/${cacheKey}`)
        if(cachedClient) {
            thing = await cachedClient.json()
        } else {
            // Finally, try getting it from the database
            thing = await queryTheDatabase();
            if(!thing) return null; // or whatever

            // Place it in the DC cache
            ctx.waitUntil(dcache.put(`${MY_CACHE_NAMESPACE}/${cacheKey}`, new Response(JSON.stringify(thing), {
                status: 200,
                headers: {
                    'cache-control': 'public, max-age=3600' // 1 hour
                }
            })))
        }

        // Place it in the in-memory cache
        cset(thingCache, id, thing, 3600) // 1 hour
    }
    
    return thing;
}

const thingCache = new Map<string, ExpiringValue<ThingType>>() // Global scope

async function something(id: string) {
    let thing = cget(thingCache, id);
    if(!thing) {
        // Try to get thing from DC cache
        const cacheKey = `things/${id}`
        const dcache = caches.default
        const cachedClient = await dcache.match(`${MY_KV_NAMESPACE}/${cacheKey}`)
        if(cachedClient) {
            thing = await cachedClient.json()
        } else {
            // Finally, try getting it from the database
            thing = await queryTheDatabase();
            if(!thing) return null; // or whatever

            // Place it in the DC cache
            ctx.waitUntil(dcache.put(`${MY_CACHE_NAMESPACE}/${cacheKey}`, new Response(JSON.stringify(thing), {
                status: 200,
                headers: {
                    'cache-control': 'public, max-age=3600' // 1 hour
                }
            })))
        }

        // Place it in the in-memory cache
        cset(thingCache, id, thing, 3600) // 1 hour
    }
    
    return thing;
}

const thingCache = new Map<string, ExpiringValue<ThingType>>() // Global scope

async function something(id: string) {
    let thing = cget(thingCache, id);
    if(!thing) {
        // Try to get thing from DC cache
        const cacheKey = `things/${id}`
        const dcache = caches.default
        const cachedClient = await dcache.match(`${MY_KV_NAMESPACE}/${cacheKey}`)
        if(cachedClient) {
            thing = await cachedClient.json()
        } else {
            // Finally, try getting it from the database
            thing = await queryTheDatabase();
            if(!thing) return null; // or whatever

            // Place it in the DC cache
            ctx.waitUntil(dcache.put(`${MY_CACHE_NAMESPACE}/${cacheKey}`, new Response(JSON.stringify(thing), {
                status: 200,
                headers: {
                    'cache-control': 'public, max-age=3600' // 1 hour
                }
            })))
        }

        // Place it in the in-memory cache
        cset(thingCache, id, thing, 3600) // 1 hour
    }
    
    return thing;
}

const thingCache = new Map<string, ExpiringValue<ThingType>>() // Global scope

async function something(id: string) {
    let thing = cget(thingCache, id);
    if(!thing) {
        // Try to get thing from DC cache
        const cacheKey = `things/${id}`
        const dcache = caches.default
        const cachedClient = await dcache.match(`${MY_KV_NAMESPACE}/${cacheKey}`)
        if(cachedClient) {
            thing = await cachedClient.json()
        } else {
            // Finally, try getting it from the database
            thing = await queryTheDatabase();
            if(!thing) return null; // or whatever

            // Place it in the DC cache
            ctx.waitUntil(dcache.put(`${MY_CACHE_NAMESPACE}/${cacheKey}`, new Response(JSON.stringify(thing), {
                status: 200,
                headers: {
                    'cache-control': 'public, max-age=3600' // 1 hour
                }
            })))
        }

        // Place it in the in-memory cache
        cset(thingCache, id, thing, 3600) // 1 hour
    }
    
    return thing;
}

YYash Bindal (yB)Hi Is there any way possible to use ipv4 to hit external APi instead of Ipv6

Y

Yash Bindal (yB)•9/24/24, 8:34 AM

#IPv6 -> IPv4

0

0x146231489231923•9/24/24, 3:47 PM

what web framework you all use in workers??

A

AkuEye•9/24/24, 4:23 PM

hi

A

AkuEye•9/24/24, 4:23 PM

I am trying to update the code in one of my Cloudflare Workers, but the deploy/save button is not working. The button is not giving any option to do anything, due to which I haven't been able to update the code for the past 3 days. Please fix this or suggest a solution.

AAkuEye I am trying to update the code in one of my Cloudflare Workers, but the deploy/s...

H

Hard@Work•9/24/24, 4:23 PM

Try saving the file?

H

Hard@Work•9/24/24, 4:24 PM

CTRL+S

00x146231489231923 what web framework you all use in workers??

C

chocolatkey•9/24/24, 4:44 PM

Hono

K

kingmesal•9/24/24, 5:25 PM

Regarding the https://developers.cloudflare.com/workers/runtime-apis/bindings/version-metadata/

I just want to make sure I'm not missing something and that what I'm seeing is intentional... when running

wrangler dev --remote

wrangler dev --remote

the

id

id

and

tag

tag

are empty and

timestamp

timestamp

timestamp

timestamp is garbage:

{
  "id": "",
  "tag": "",
  "timestamp": "0001-01-01T00:00:00Z"
}

{
  "id": "",
  "tag": "",
  "timestamp": "0001-01-01T00:00:00Z"
}

{
  "id": "",
  "tag": "",
  "timestamp": "0001-01-01T00:00:00Z"
}

{
  "id": "",
  "tag": "",
  "timestamp": "0001-01-01T00:00:00Z"
}

Cchocolatkey Hono

0

0x146231489231923•9/24/24, 5:26 PM

same

0

0x146231489231923•9/24/24, 5:26 PM

anymore other options?

AAkuEye I am trying to update the code in one of my Cloudflare Workers, but the deploy/s...

T

texan•9/24/24, 8:27 PM

If you don't have any changes to your script, it won't allow you to save/deploy. The dot in the top corner of that

worker.js

worker.js

worker.js

worker.js tab shows you have unsaved changes. Control+s should re-enable that button for you

K

kchro3•9/24/24, 8:42 PM

i started seeing errors when running wrangler dev --remote like this:

text: 'Uncaught Error: No such module "node:events".\n' +

Is this related to https://developers.cloudflare.com/workers/runtime-apis/nodejs/#get-started where it says that

Starting on September 23rd, 2024, when your compatibility date is on or after 2024-09-23, the nodejs_compat compatibility flag will enable the exact same behavior as nodejs_compat_v2.

Starting on September 23rd, 2024, when your compatibility date is on or after 2024-09-23, the nodejs_compat compatibility flag will enable the exact same behavior as nodejs_compat_v2.

Starting on September 23rd, 2024, when your compatibility date is on or after 2024-09-23, the nodejs_compat compatibility flag will enable the exact same behavior as nodejs_compat_v2.

Starting on September 23rd, 2024, when your compatibility date is on or after 2024-09-23, the nodejs_compat compatibility flag will enable the exact same behavior as nodejs_compat_v2.

I only started seeing this issue today and nothing materially changed from my set up yesterday

Cloudflare Docs

Node.js compatibility | Cloudflare Workers docs

Node.js APIs available in Cloudflare Workers

R

root@alien:~#•9/24/24, 10:48 PM

Why do I get this error after selecting the smart option in cloudflare workers? "placement is currently unsupported when using assets"

Rroot@alien:~#Why do I get this error after selecting the smart option in cloudflare workers? ...

T

texan•9/24/24, 11:09 PM

Thanks for letting us know! We're working on fixing this!

Edit: fixed!

CCorsix👾to have several service bindings to other workers in one worker, what's the corr...

R

Radoš•9/24/24, 11:14 PM

you can also do it like this

[[services]]
binding = "AUTH"
service = "myproject-auth"
entrypoint = "MyProjecAuthEntrypoint"

[[env.production.services]]
binding = "AUTH"
service = "myproject-auth"
entrypoint = "MyProjecAuthEntrypoint"

[[services]]
binding = "AUTH"
service = "myproject-auth"
entrypoint = "MyProjecAuthEntrypoint"

[[env.production.services]]
binding = "AUTH"
service = "myproject-auth"
entrypoint = "MyProjecAuthEntrypoint"

[[services]]
binding = "AUTH"
service = "myproject-auth"
entrypoint = "MyProjecAuthEntrypoint"

[[env.production.services]]
binding = "AUTH"
service = "myproject-auth"
entrypoint = "MyProjecAuthEntrypoint"

[[services]]
binding = "AUTH"
service = "myproject-auth"
entrypoint = "MyProjecAuthEntrypoint"

[[env.production.services]]
binding = "AUTH"
service = "myproject-auth"
entrypoint = "MyProjecAuthEntrypoint"

Rroot@alien:~#Why do I get this error after selecting the smart option in cloudflare workers? ...

W

Walshy•9/24/24, 11:40 PM

This is fixed, sorry for the issue!

S

SpiraTech•9/25/24, 12:33 AM

just a note for anyone thinking of staying with mailchannels via contacting their sales team, you need credit card info on record to keep using it free so I'm no longer interested. I've instead migrated to resend and it's working better than ever!

R

Radoš•9/25/24, 12:34 AM

@SpiraTech just create a worker connected to Amazon SES and you are set for any project and it costs nothing.

R

Radoš•9/25/24, 12:35 AM

There is even a repo on GitHub.

RRadoš @SpiraTech just create a worker connected to Amazon SES and you are set for any ...

S

SpiraTech•9/25/24, 12:35 AM

that is probably a great idea, I am a bit too dumb, and I only need a few emails a month so I kept it simple and integrated into my pages worker - well with help from ChatGPT lol

Thanks for the info though I'll check that out if I need to use anything else with more emails in the future! thanks

R

Robin Genz•9/25/24, 6:10 AM

Hey

I'm using the Rate Limiting API to define rate limits in my worker. I could not find any information on how long a rate limiting remains active once it takes effect. Is there any information on this?

Cloudflare Docs

Rate Limiting | Cloudflare Workers docs

Define rate limits and interact with them directly from your Cloudflare Worker

RRobin Genz Hey 👋 I'm using the [Rate Limiting API](https://developers.cloudflare.com/worke...

H

Hello, I’m Allie!•9/25/24, 6:15 AM

The period you configure?

HHello, I’m Allie!The period you configure?

R

Robin Genz•9/25/24, 6:16 AM

I thought the period specifies how often I have to call the limit method within the time for the limit to take effect.

RRobin Genz I thought the period specifies how often I have to call the limit method within ...

H

Hello, I’m Allie!•9/25/24, 6:17 AM

I’m not sure what you are looking for then?

HHello, I’m Allie!I’m not sure what you are looking for then?

R

Robin Genz•9/25/24, 6:18 AM

I must be able to specify two things:

the time period in which the limit calls are counted so that the limit comes into effect.
how long the limit remains in force.

Or am I misunderstanding the API?

Btw: Thanks for your help!

HHello, I’m Allie!I’m not sure what you are looking for then?

R

Robin Genz•9/25/24, 6:20 AM

Example: I want an IP address to be allowed to make 10 requests in 60 seconds. If this limit is reached, the IP address should be blocked for 5 minutes.

RRobin Genz Example: I want an IP address to be allowed to make 10 requests in 60 seconds. I...

H

Hello, I’m Allie!•9/25/24, 6:21 AM

Oh, yeah, I don’t think that is quite possible yet

HHello, I’m Allie!Oh, yeah, I don’t think that is quite possible yet

R

Robin Genz•9/25/24, 6:23 AM

simple = { limit = 10, period = 60 }

simple = { limit = 10, period = 60 }

simple = { limit = 10, period = 60 }

simple = { limit = 10, period = 60 }

So if a user makes 10 requests in 50 seconds, he can make another 10 requests 10 seconds later? Do I understand this correctly?

RRobin Genz `simple = { limit = 10, period = 60 }` So if a user makes 10 requests in 50 sec...

H

Hello, I’m Allie!•9/25/24, 6:26 AM

That’s how I understand it, yeah

HHello, I’m Allie!That’s how I understand it, yeah

R

Robin Genz•9/25/24, 6:26 AM

Alright, thanks!

J

Johnny Silverhand•9/25/24, 8:48 AM

Hello guys,
i am using a worker which differs requests by http-method and path.
I would like to run the worker on-premise; in my own nodejs context.
what webserver should i use? express? or http.createServer?

JJohnny Silverhand Hello guys, i am using a worker which differs requests by http-method and path. ...

H

Hard@Work•9/25/24, 8:50 AM

Does your Worker use any Workers-specific APIs?

HHard@Work Does your Worker use any Workers-specific APIs?

J

Johnny Silverhand•9/25/24, 8:50 AM

no

JJohnny Silverhand no

H

Hard@Work•9/25/24, 8:51 AM

If it uses a framework like Hono, then you might just be able to do

import { serve } from '@hono/node-server'

serve(app)

import { serve } from '@hono/node-server'

serve(app)

import { serve } from '@hono/node-server'

serve(app)

import { serve } from '@hono/node-server'

serve(app)

J

Johnny Silverhand•9/25/24, 8:51 AM

it just modifies the url/path and sets some headers, thats all

J

Johnny Silverhand•9/25/24, 8:52 AM

i will try hono

E

Elyo•9/25/24, 2:00 PM

Hi guys

I have a website in Webflow with DNS managed by Cloudflare.
Also I have a worker with a specific route on that same domain, but never trigger.
basically i have

www.mydomain.com

www.mydomain.com

www.mydomain.com

www.mydomain.com for Webflow and my worker route

www.mydomain.com/.well-known/assetlinks.json

www.mydomain.com/.well-known/assetlinks.json

www.mydomain.com/.well-known/assetlinks.json

www.mydomain.com/.well-known/assetlinks.json which provide me a json file.

I thought the worker routing take over the DNS webflow one.

Is that incorrect to think as such?

A

ac•9/25/24, 2:09 PM

Can Workers have both RPC calls and cron triggers? (e.g. both a WorkerEntrypoint class for RPC and a scheduled function for cron)

Aac Can Workers have both RPC calls and cron triggers? (e.g. both a WorkerEntrypoint...

A

ac•9/25/24, 3:05 PM

(answering my own question) yes it looks like they can, just need to be inside of a WorkerEntrypoint

K

kingmesal•9/25/24, 5:40 PM

bumping this workers-and-pages-discussions

I think this is a legit question because the id field gets set properly when running local wrangler dev and when deployed, but --remote has missing values.

Kkingmesal Regarding the https://developers.cloudflare.com/workers/runtime-apis/bindings/ve...

W

Walshy•9/25/24, 6:55 PM

there is no script version or technically script name in remote dev, it's an ephemeral script

W

Walshy•9/25/24, 6:55 PM

and timestamp, there was no time this version was created hence the 0

Jjonasnobile Hey everyone, I’ve come across some unexpected behavior with the Worker. When ru...

W

Walshy•9/25/24, 6:56 PM

Yep sounds like a bug, we should match production as much as possible locally - can you make an issue here: https://github.com/cloudflare/workers-sdk/issues

to have several service bindings to other workers in one worker, what's the correct way of formattin

Similar Threads

Similar Threads

Similar Threads