1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
import Router from "./library/router/index.js";
import talent96 from "./data/talent96.js";
export default {
/*
Fetch event handler, this function will be called whenever a request is made to the worker.
The function will parse the request and return a response based on the request path.
@param {Request} request - the incoming request object
@param {Environment} environment - the environment object
@param {Context} context - the context object
@returns {Response} a new Response object
*/
async fetch(request, environment, context) {
const router = new Router(request, environment, context);
router.add("/", () => {
return router.respond({
message: "Hello, World! :3",
});
});
router.add("/status", (request) => {
const url = new URL(request.url);
const service = url.searchParams.get("service");
const acceptedServices = [
"dns",
"load-balancer",
"cdn",
"functions",
"mysql-cluster",
"mongodb-cluster",
"redis-cluster",
"elasticsearch-cluster",
"git-connector",
"job-runners",
"container-registry",
"kubernetes-cluster",
"bare-metal-servers",
"game-server-api",
"anti-ddos-protection",
"anti-cheat-api",
];
if (acceptedServices.includes(service))
return router.respond({
status: "ok",
});
return router.respond({
error: `service not found`,
});
});
router.add("/96/twitch/streaming", async (request) => {
const url = new URL(request.url);
const channel = url.searchParams.get("channel");
if (!channel)
return router.respond({
error: `channel not provided`,
});
const whitelist = ["zuedev", ...talent96];
if (!whitelist.includes(channel))
return router.respond({
error: `channel not whitelisted`,
});
const channelLive = await isTwitchChannelLive(channel);
if (channelLive)
return router.respond({
status: "live",
});
return router.respond({
status: "offline",
});
});
return router.route();
},
/*
Email event handler, this function will be called whenever an email is sent to the worker.
The function will parse the email message and forward it to a specified email address.
@param {Message} message - the incoming email message object
@param {Environment} environment - the environment object
@param {Context} context - the context object
@returns {void}
*/
async email(message, environment, context) {
message.forward("alex@zue.dev");
},
/*
Scheduled event handler, this function will be called whenever a scheduled event is triggered.
The function will perform a task and return a response based on the task outcome.
@param {Event} event - the incoming event object
@param {Environment} environment - the environment object
@param {Context} context - the context object
@returns {void}
*/
async scheduled(event, environment, context) {
console.log("Scheduled event triggered!");
},
};
/*
Checks if a twitch channel is live by fetching the "live" preview image of the channel,
if the image is fetched successfully, then the channel is live, otherwise it's offline.
@param {string} channel - the twitch channel name
@returns {boolean} true if the channel is live, false otherwise
*/
async function isTwitchChannelLive(channel) {
// construct preview image url with channel name
const livePreviewUrl = `https://static-cdn.jtvnw.net/previews-ttv/live_user_${channel}-320x180.jpg`;
// fetch the preview image, don't follow redirects
const response = await fetch(livePreviewUrl, {
redirect: "manual",
});
// check if the image was fetched successfully
return response.ok;
}
|
