throw for http error

activities-bot/src/utils.mjs

@@ -44,6 +44,14 @@ function isAllowedEvent(event) {
   }
 }
 
+const throwForHttpError = async (res) => {
+  if (!res.ok) {
+    throw new Error(await res.text());
+  }
+
+  return res;
+};
+
 const octokit = new Octokit({ auth: GITHUB_TOKEN });
 
 export async function getEvents(allowedAuthors) {
@@ -112,17 +120,22 @@ const leaderboardApiHeaders = {
 const eodUpdatesApi = `${LEADERBOARD_URL}/api/slack-eod-bot/eod-updates`;
 
 export async function getEODUpdates() {
-  const res = await fetch(eodUpdatesApi, {
-    headers: leaderboardApiHeaders,
-  });
+  const res = throwForHttpError(
+    await fetch(eodUpdatesApi, {
+      headers: leaderboardApiHeaders,
+    }),
+  );
+
   return res.json();
 }
 
 export async function flushEODUpdates() {
-  await fetch(eodUpdatesApi, {
-    headers: leaderboardApiHeaders,
-    method: "DELETE",
-  });
+  const res = throwForHttpError(
+    await fetch(eodUpdatesApi, {
+      headers: leaderboardApiHeaders,
+      method: "DELETE",
+    }),
+  );
 }
 
 const slackApiHeaders = {
@@ -131,15 +144,17 @@ const slackApiHeaders = {
 };
 
 export async function sendSlackMessage(channel, text, blocks) {
-  const res = await fetch("https://slack.com/api/chat.postMessage", {
-    method: "POST",
-    headers: slackApiHeaders,
-    body: JSON.stringify({
-      channel,
-      text,
-      ...blocks,
+  const res = throwForHttpError(
+    await fetch("https://slack.com/api/chat.postMessage", {
+      method: "POST",
+      headers: slackApiHeaders,
+      body: JSON.stringify({
+        channel,
+        text,
+        ...blocks,
+      }),
     }),
-  });
+  );
 
   const data = await res.json();
   if (!data.ok) {