Support Cloudflare workers

[ricky11]

The current library does not work with cloudflare workers.

Workers uses the runtime library not nodejs, and is a service worker under the hood.

Is there anyway to get pusher going on cloudflare workers?

[stale]

This issue has been automatically marked as stale because it has not had recent activity. It will be closed if no further activity occurs. If you'd like this issue to stay open please leave a comment indicating how this issue is affecting you. Thank you.

[shakib-2020]

You must use Pusher REST API manually with fetch, not the Node SDK. Create helper like this:

export const triggerPusher = async (
channel: string,
event: string,
data: any
) => {
const body = JSON.stringify({
name: event,
channel,
data: JSON.stringify(data),
});

const authTimestamp = Math.floor(Date.now() / 1000);

const stringToSign =
POST\n/apps/${process.env.PUSHER_APP_ID}/events\n +
auth_key=${process.env.PUSHER_KEY}&auth_timestamp=${authTimestamp}&auth_version=1.0&body_md5=${await md5(body)};

const signature = await hmacSHA256(
stringToSign,
process.env.PUSHER_SECRET!
);

const url =
https://api-${process.env.PUSHER_CLUSTER}.pusher.com/apps/${process.env.PUSHER_APP_ID}/events +
?auth_key=${process.env.PUSHER_KEY} +
&auth_timestamp=${authTimestamp} +
&auth_version=1.0 +
&body_md5=${await md5(body)} +
&auth_signature=${signature};

return fetch(url, {
method: "POST",
headers: { "Content-Type": "application/json" },
body,
});
};

async function md5(message: string) {
const buffer = new TextEncoder().encode(message);
const digest = await crypto.subtle.digest("MD5", buffer);
return Array.from(new Uint8Array(digest))
.map(b => b.toString(16).padStart(2, "0"))
.join("");
}

async function hmacSHA256(message: string, secret: string) {
const key = await crypto.subtle.importKey(
"raw",
new TextEncoder().encode(secret),
{ name: "HMAC", hash: "SHA-256" },
false,
["sign"]
);

const signature = await crypto.subtle.sign(
"HMAC",
key,
new TextEncoder().encode(message)
);

return Array.from(new Uint8Array(signature))
.map(b => b.toString(16).padStart(2, "0"))
.join("");
}

use it like this:
await pusher.trigger(...) ❌
await triggerPusher(...)✔

[ricky11]

Thanks, we moved to ably.