feat: morning weather status report

Author: cirex-web

app.ts

@@ -3,7 +3,6 @@ import registerListeners from "./listeners";
 import { setUpDailyGreeting } from "./intervals/morning";
 import { setUpUptimeChecker } from "./intervals/uptimeChecker";
 import { env } from "./env";
-import { trackedSitesTable } from "./db/schema";
 import { db } from "./db";
 
 /** Initialization */
@@ -56,7 +55,7 @@ registerListeners(app);
             text: msg,
             channel: channelId,
           })
-          .catch(app.logger.error),
+          .catch((er) => app.logger.error(er)),
       db
     );
   } catch (error) {

intervals/morning.ts

@@ -1,5 +1,5 @@
 import { DateTime } from "luxon";
-import { getWebsiteStatusString } from "./uptimeChecker";
+import { getTodaysWeather } from "./weather";
 
 const greetingTime = {
   hour: 9,
@@ -29,9 +29,10 @@ export const scheduleNextGreeting = (
   );
   setTimeout(async () => {
     sendMessage(
-      `${
-        greetings[Math.floor(Math.random() * greetings.length)]
-      }\n\n${await getWebsiteStatusString()}`
+      await getTodaysWeather().catch((e) => {
+        console.error(e);
+        return "Morning! I would give you the weather report for today, but the National Weather Service api seems to be unavailable. >_<";
+      })
     );
     scheduleNextGreeting(sendMessage, nextMorningTime.plus({ days: 1 })); // this actually accounts for DST properly
   }, nextMorningTime.diff(currentTime).toMillis());

intervals/siteMonitor.ts

@@ -45,11 +45,14 @@ export class SiteMonitor {
 
     const downState = this.downSites[site.url];
     downState.failErrors.push(error);
-    await this.db.insert(uptimeRecordsTable).values({
-      up: false,
-      details: error,
-      site_id: site.id,
-    });
+    await this.db
+      .insert(uptimeRecordsTable)
+      .values({
+        up: false,
+        details: error,
+        site_id: site.id,
+      })
+      .catch();
 
     if (
       Date.now() - downState.firstDownTimestamp >= this.alertThresholdMs &&
@@ -86,12 +89,15 @@ export class SiteMonitor {
   async siteUp(site: SiteInfo, responseTimeMs: number) {
     console.log(`check successful for ${site.url}`);
 
-    await this.db.insert(uptimeRecordsTable).values({
-      up: true,
-      details: null,
-      site_id: site.id,
-      response_time_ms: responseTimeMs,
-    });
+    await this.db
+      .insert(uptimeRecordsTable)
+      .values({
+        up: true,
+        details: null,
+        site_id: site.id,
+        response_time_ms: responseTimeMs,
+      })
+      .catch();
     if (this.downSites[site.url] === undefined) return;
 
     if (this.downSites[site.url].alertStage !== "NONE") {

intervals/uptimeChecker.ts

@@ -35,7 +35,11 @@ export const setUpUptimeChecker = (
     const trackedURLs = await db
       .select()
       .from(trackedSitesTable)
-      .where(eq(trackedSitesTable.actively_tracked, true));
+      .where(eq(trackedSitesTable.actively_tracked, true))
+      .catch((e) => {
+        console.error(e);
+        return [];
+      });
     trackedURLs.forEach((site) =>
       checkSite(
         site.url,
@@ -52,7 +56,9 @@ export const setUpUptimeChecker = (
 
 export const getWebsiteStatusString = async () => {
   return (
-    (await siteMonitor?.getStatusAsString()) ??
-    "Site monitor has not been initialized!"
+    (await siteMonitor?.getStatusAsString().catch((e) => {
+      console.error(e);
+      return "Site status unavailable!";
+    })) ?? "Site monitor has not been initialized!"
   );
 };

intervals/weather.ts

@@ -0,0 +1,50 @@
+import { z, ZodType, ZodTypeAny } from "zod";
+const generalLocationSchema = z.object({
+  properties: z.object({
+    forecast: z.string(),
+  }),
+});
+const forecastSchema = z.object({
+  properties: z.object({
+    periods: z.array(
+      z.object({
+        name: z.string(),
+        detailedForecast: z.string(),
+      })
+    ),
+  }),
+});
+const rootApiURL = "https://api.weather.gov/points/40.4442,-79.9396";
+const fetchData = async <UWU extends ZodTypeAny>(
+  url: string,
+  schema: UWU,
+  retriesLeft = 3
+) => {
+  try {
+    const data = schema.parse(await (await fetch(url)).json()) as z.infer<UWU>;
+    return data;
+  } catch (e) {
+    if (retriesLeft === 1) throw e;
+    return fetchData(url, schema, retriesLeft - 1);
+  }
+};
+export async function getTodaysWeather() {
+  const generalLocationData = await fetchData(
+    rootApiURL,
+    generalLocationSchema
+  );
+  const forecastURL = generalLocationData.properties.forecast;
+  const forecast = await fetchData(forecastURL, forecastSchema);
+  let weatherToday: string | undefined, weatherTonight: string | undefined;
+  for (const entry of forecast.properties.periods) {
+    if (entry.name === "Today") {
+      weatherToday = entry.detailedForecast;
+    }
+    if (entry.name === "Tonight") {
+      weatherTonight = entry.detailedForecast;
+    }
+  }
+  return `おはよう! Here's today's weather forecast for CMU, Pittsburgh\n\n*Today:* ${
+    weatherToday ?? "Unavailable"
+  }\n\n*Tonight:* ${weatherTonight ?? "Unavailable"}`;
+}