forked from xyTom/Url-Shorten-Worker
-
Notifications
You must be signed in to change notification settings - Fork 339
/
worker.js
394 lines (348 loc) · 12.3 KB
/
worker.js
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
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
const config = {
result_page: false, // After get the value from KV, if use a page to show the result.
theme: "", // Homepage theme, use the empty value for default theme. To use urlcool theme, please fill with "theme/urlcool" .
cors: true, // Allow Cross-origin resource sharing for API requests.
unique_link: false, // If it is true, the same long url will be shorten into the same short url
custom_link: true, // Allow users to customize the short url.
overwrite_kv: false, // Allow user to overwrite an existed key.
snapchat_mode: false, // The link will be distroyed after access.
visit_count: false, // Count visit times.
load_kv: false, // Load all from Cloudflare KV
system_type: "shorturl", // shorturl, imghost, other types {pastebin, journal}
}
// key in protect_keylist can't read, add, del from UI and API
const protect_keylist = [
"password",
]
let index_html = "https://crazypeace.github.io/Url-Shorten-Worker/" + config.theme + "/index.html"
let result_html = "https://crazypeace.github.io/Url-Shorten-Worker/" + config.theme + "/result.html"
const html404 = `<!DOCTYPE html>
<html>
<body>
<h1>404 Not Found.</h1>
<p>The url you visit is not found.</p>
<p> <a href="https://github.com/crazypeace/Url-Shorten-Worker/" target="_self">Fork me on GitHub</a> </p>
</body>
</html>`
let response_header = {
"Content-type": "text/html;charset=UTF-8;application/json",
}
if (config.cors) {
response_header = {
"Content-type": "text/html;charset=UTF-8;application/json",
"Access-Control-Allow-Origin": "*",
"Access-Control-Allow-Methods": "POST",
"Access-Control-Allow-Headers": "Content-Type",
}
}
function base64ToBlob(base64String) {
var parts = base64String.split(';base64,');
var contentType = parts[0].split(':')[1];
var raw = atob(parts[1]);
var rawLength = raw.length;
var uInt8Array = new Uint8Array(rawLength);
for (var i = 0; i < rawLength; ++i) {
uInt8Array[i] = raw.charCodeAt(i);
}
return new Blob([uInt8Array], { type: contentType });
}
async function randomString(len) {
len = len || 6;
let chars = 'ABCDEFGHJKMNPQRSTWXYZabcdefhijkmnprstwxyz2345678'; /*去掉了容易混淆的字符oOLl,9gq,Vv,Uu,I1 *** Easily confused characters removed */
let maxPos = chars.length;
let result = '';
for (i = 0; i < len; i++) {
result += chars.charAt(Math.floor(Math.random() * maxPos));
}
return result;
}
async function sha512(url) {
url = new TextEncoder().encode(url)
const url_digest = await crypto.subtle.digest(
{
name: "SHA-512",
},
url, // The data you want to hash as an ArrayBuffer
)
const hashArray = Array.from(new Uint8Array(url_digest)); // convert buffer to byte array
const hashHex = hashArray.map(b => b.toString(16).padStart(2, '0')).join('');
//console.log(hashHex)
return hashHex
}
async function checkURL(URL) {
let str = URL;
let Expression = /http(s)?:\/\/([\w-]+\.)+[\w-]+(\/[\w- .\/?%&=]*)?/;
let objExp = new RegExp(Expression);
if (objExp.test(str) == true) {
if (str[0] == 'h')
return true;
else
return false;
} else {
return false;
}
}
async function save_url(URL) {
let random_key = await randomString()
let is_exist = await LINKS.get(random_key)
// console.log(is_exist)
if (is_exist == null) {
return await LINKS.put(random_key, URL), random_key
}
else {
save_url(URL)
}
}
async function is_url_exist(url_sha512) {
let is_exist = await LINKS.get(url_sha512)
// console.log(is_exist)
if (is_exist == null) {
return false
} else {
return is_exist
}
}
async function handleRequest(request) {
// console.log(request)
// 查KV中的password对应的值 Query "password" in KV
const password_value = await LINKS.get("password");
/************************/
// 以下是API接口的处理 Below is operation for API
if (request.method === "POST") {
let req = await request.json()
// console.log(req)
let req_cmd = req["cmd"]
let req_url = req["url"]
let req_key = req["key"]
let req_password = req["password"]
/*
console.log(req_cmd)
console.log(req_url)
console.log(req_key)
console.log(req_password)
*/
if (req_password != password_value) {
return new Response(`{"status":500,"key": "", "error":"Error: Invalid password."}`, {
headers: response_header,
})
}
if (req_cmd == "add") {
if ((config.system_type == "shorturl") && !await checkURL(req_url)) {
return new Response(`{"status":500, "url": "` + req_url + `", "error":"Error: Url illegal."}`, {
headers: response_header,
})
}
let stat, random_key
if (config.custom_link && (req_key != "")) {
// Refuse 'password" as Custom shortURL
if (protect_keylist.includes(req_key)) {
return new Response(`{"status":500,"key": "` + req_key + `", "error":"Error: Key in protect_keylist."}`, {
headers: response_header,
})
}
let is_exist = await is_url_exist(req_key)
if ((!config.overwrite_kv) && (is_exist)) {
return new Response(`{"status":500,"key": "` + req_key + `", "error":"Error: Specific key existed."}`, {
headers: response_header,
})
} else {
random_key = req_key
stat, await LINKS.put(req_key, req_url)
}
} else if (config.unique_link) {
let url_sha512 = await sha512(req_url)
let url_key = await is_url_exist(url_sha512)
if (url_key) {
random_key = url_key
} else {
stat, random_key = await save_url(req_url)
if (typeof (stat) == "undefined") {
await LINKS.put(url_sha512, random_key)
// console.log()
}
}
} else {
stat, random_key = await save_url(req_url)
}
// console.log(stat)
if (typeof (stat) == "undefined") {
return new Response(`{"status":200, "key":"` + random_key + `", "error": ""}`, {
headers: response_header,
})
} else {
return new Response(`{"status":500, "key": "", "error":"Error: Reach the KV write limitation."}`, {
headers: response_header,
})
}
} else if (req_cmd == "del") {
// Refuse to delete 'password' entry
if (protect_keylist.includes(req_key)) {
return new Response(`{"status":500, "key": "` + req_key + `", "error":"Error: Key in protect_keylist."}`, {
headers: response_header,
})
}
await LINKS.delete(req_key)
// 计数功能打开的话, 要把计数的那条KV也删掉 Remove the visit times record
if (config.visit_count) {
await LINKS.delete(req_key + "-count")
}
return new Response(`{"status":200, "key": "` + req_key + `", "error": ""}`, {
headers: response_header,
})
} else if (req_cmd == "qry") {
// Refuse to query 'password'
if (protect_keylist.includes(req_key)) {
return new Response(`{"status":500,"key": "` + req_key + `", "error":"Error: Key in protect_keylist."}`, {
headers: response_header,
})
}
let value = await LINKS.get(req_key)
if (value != null) {
let jsonObjectRetrun = JSON.parse(`{"status":200, "error":"", "key":"", "url":""}`);
jsonObjectRetrun.key = req_key;
jsonObjectRetrun.url = value;
return new Response(JSON.stringify(jsonObjectRetrun), {
headers: response_header,
})
} else {
return new Response(`{"status":500, "key": "` + req_key + `", "error":"Error: Key not exist."}`, {
headers: response_header,
})
}
} else if (req_cmd == "qryall") {
if ( !config.load_kv) {
return new Response(`{"status":500, "error":"Error: Config.load_kv false."}`, {
headers: response_header,
})
}
let keyList = await LINKS.list()
if (keyList != null) {
// 初始化返回数据结构 Init the return struct
let jsonObjectRetrun = JSON.parse(`{"status":200, "error":"", "kvlist": []}`);
for (var i = 0; i < keyList.keys.length; i++) {
let item = keyList.keys[i];
// Hide 'password' from the query all result
if (protect_keylist.includes(item.name)) {
continue;
}
// Hide '-count' from the query all result
if (item.name.endsWith("-count")) {
continue;
}
let url = await LINKS.get(item.name);
let newElement = { "key": item.name, "value": url };
// 填充要返回的列表 Fill the return list
jsonObjectRetrun.kvlist.push(newElement);
}
return new Response(JSON.stringify(jsonObjectRetrun) , {
headers: response_header,
})
} else {
return new Response(`{"status":500, "error":"Error: Load keyList failed."}`, {
headers: response_header,
})
}
}
} else if (request.method === "OPTIONS") {
return new Response(``, {
headers: response_header,
})
}
/************************/
// 以下是浏览器直接访问worker页面的处理 Below is operation for browser visit worker page
const requestURL = new URL(request.url)
let path = requestURL.pathname.split("/")[1]
path = decodeURIComponent(path);
const params = requestURL.search;
// console.log(path)
// 如果path为空, 即直接访问本worker
// If visit this worker directly (no path)
if (!path) {
return Response.redirect("https://zelikk.blogspot.com/search/label/Url-Shorten-Worker", 302)
/* new Response(html404, {
headers: response_header,
status: 404
}) */
}
// 如果path符合password 显示操作页面index.html
// if path equals password, return index.html
if (path == password_value) {
let index = await fetch(index_html)
index = await index.text()
index = index.replace(/__PASSWORD__/gm, password_value)
// 操作页面文字修改
// index = index.replace(/短链系统变身/gm, "")
return new Response(index, {
headers: response_header,
})
}
// 在KV中查询 短链接 对应的原链接
// Query the value(long url) in KV by key(short url)
let value = await LINKS.get(path);
// console.log(value)
// 如果path是'password', 让查询结果为空, 不然直接就把password查出来了
// Protect password. If path equals 'password', set result null
if (protect_keylist.includes(path)) {
value = ""
}
if (!value) {
// KV中没有数据, 返回404
// If request not in KV, return 404
return new Response(html404, {
headers: response_header,
status: 404
})
}
// 计数功能
if (config.visit_count) {
// 获取并增加访问计数
let count = await LINKS.get(path + "-count");
if (count === null) {
await LINKS.put(path + "-count", "1"); // 初始化为1，因为这是首次访问
} else {
count = parseInt(count) + 1;
await LINKS.put(path + "-count", count.toString());
}
}
// 如果阅后即焚模式
if (config.snapchat_mode) {
// 删除KV中的记录
// Remove record before jump to long url
await LINKS.delete(path)
}
// 带上参数部分, 拼装要跳转的最终网址
// URL to jump finally
if (params) {
value = value + params
}
// 如果自定义了结果页面
if (config.result_page) {
let result_page_html = await fetch(result_html)
let result_page_html_text = await result_page_html.text()
result_page_html_text = result_page_html_text.replace(/{__FINAL_LINK__}/gm, value)
return new Response(result_page_html_text, {
headers: response_header,
})
}
// 以下是不使用自定义结果页面的处理
// 作为一个短链系统, 需要跳转
if (config.system_type == "shorturl") {
return Response.redirect(value, 302)
} else if (config.system_type == "imghost") {
// 如果是图床
var blob = base64ToBlob(value)
return new Response(blob, {
// 图片不能指定content-type为 text/plain
})
} else {
// 如果只是一个单纯的key-value系统, 简单的显示value就行了
return new Response(value, {
headers: {
"Content-type": "text/plain;charset=UTF-8;",
},
})
}
}
addEventListener("fetch", async event => {
event.respondWith(handleRequest(event.request))
})