-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathmain.tsx
126 lines (122 loc) · 3.82 KB
/
main.tsx
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
import { h } from "https://esm.sh/preact@10.19.3?pin=v135";
import { renderToString } from "https://esm.sh/preact-render-to-string@6.3.1?pin=v135";
import { App } from "./app.tsx";
import dist from "./dist.json" with { type: "json" };
import { Client } from "https://deno.land/x/notion_sdk@v2.2.3/src/mod.ts";
import { getTasksCompleted, setTaskCompletedAndCommented } from "./task.ts";
import { commentToDiscord } from "./commentToDiscord.ts";
export const notificationToDiscord = async (parameter: {
readonly notionIntegrationSecret: string;
readonly discordWebHookUrl: string;
}): Promise<void> => {
console.log("タスク通知 処理開始");
const notionClient = new Client({
auth: parameter.notionIntegrationSecret,
});
const taskList = await getTasksCompleted(notionClient, console.warn);
if (taskList.length === 0) {
console.log("タスクなし");
return;
}
const userMap = await getUserMap(notionClient);
for (const task of taskList) {
console.log(`タスク通知 ${task.id}`);
await commentToDiscord({
discordWebHookUrl: parameter.discordWebHookUrl,
task,
userMap,
});
await setTaskCompletedAndCommented(notionClient, task.id);
}
console.log("タスク通知 すべて完了");
};
export const start = (
parameter: {
readonly notionIntegrationSecret: string;
readonly discordWebHookUrl: string;
},
): void => {
// Deno.cron("task complete check", "* * * * *", async () => {
// await notificationToDiscord(parameter);
// });
Deno.serve((request) => {
const url = new URL(request.url);
if (url.pathname === "/" && request.method === "GET") {
return new Response(
"<!doctype html>" + renderToString(
<html style="height: 100%;">
<head>
<title>提出埋め込み用ページ</title>
<meta charset="utf-8" />
<script
type="module"
src={`/${dist.jsHash}`}
/>
</head>
<body style="height: 100%; margin: 0;background: white;">
<div id="root" style="height: 100%;">
<App state={undefined} onClick={undefined} />
</div>
</body>
</html>,
),
{
headers: {
"content-type": "text/html",
},
},
);
}
if (url.pathname === `/${dist.jsHash}` && request.method === "GET") {
return new Response(
dist.jsCode,
{
headers: {
"content-type": "text/javascript",
},
},
);
}
if (url.pathname === "/submit" && request.method === "POST") {
const body = new ReadableStream<Uint8Array>({
start: (controller) => {
controller.enqueue(
new TextEncoder().encode(`やっぱここでは何もしないことにしました`),
);
controller.close();
},
});
return new Response(body, { headers: { "content-type": "text/plain" } });
}
return new Response("Not Found", { status: 404 });
});
};
const getUserMap = async (
notionClient: Client,
): Promise<ReadonlyMap<string, string>> => {
const users = new Map<string, string>();
let cursor: string | undefined = undefined;
while (true) {
const response = await notionClient.databases.query({
database_id: "94fbeb491c7e43c6a550f09f91fe50fa",
start_cursor: cursor,
});
response.results.forEach((page) => {
if (!("properties" in page)) {
return;
}
const nameProperty = page.properties["名前"];
if (nameProperty.type !== "title") {
return;
}
users.set(
page.id,
nameProperty.title.map((item) => item.plain_text).join(""),
);
});
if (!response.next_cursor) {
return users;
}
cursor = response.next_cursor;
}
};