Add MNPD, fix NFD

Author: stephenyeargin

.flox/env/manifest.lock

@@ -17,6 +17,9 @@ version = 1
 [install]
 nodejs.pkg-path = "nodejs"
 ollama.pkg-path = "ollama"
+flox-mcp-server.pkg-path = "flox/flox-mcp-server"
+flox-mcp-server.systems = ["x86_64-linux", "aarch64-darwin", "aarch64-linux"]
+flox-mcp-server.pkg-group = "flox-mcp-server"
 
 
 ## Environment Variables ---------------------------------------------

.flox/env/manifest.toml

@@ -0,0 +1,79 @@
+// Description
+//   MNPD Active Dispatches
+//
+// Commands
+//   hubot police - Show all active dispatches
+//   hubot police <city name> - Filter incidents to a city name
+
+const dayjs = require('dayjs');
+const AsciiTable = require('ascii-table');
+const relativeTime = require('dayjs/plugin/relativeTime');
+const timezone = require('dayjs/plugin/timezone');
+const utc = require('dayjs/plugin/utc');
+
+dayjs.extend(relativeTime);
+dayjs.extend(timezone);
+dayjs.extend(utc);
+dayjs.tz.setDefault('America/Chicago');
+
+module.exports = (robot) => {
+  // Configure dayjs
+  const baseUrl = 'https://services2.arcgis.com/HdTo6HJqh92wn4D8/arcgis/rest/services/Metro_Nashville_Police_Department_Active_Dispatch_Table_view/FeatureServer/0/query?f=json&cacheHint=true&resultOffset=0&resultRecordCount=50&where=1%3D1&orderByFields=LastUpdated%20ASC%2CObjectId%20ASC&outFields=*&returnGeometry=false&spatialRel=esriSpatialRelIntersects';
+
+  const formatTable = (data) => {
+    const table = new AsciiTable('👮 MNPD Active Dispatches 🚔');
+    table.setHeading('Time', 'Code', 'Type', 'Location', 'City');
+
+    const sortedData = data.features.sort(
+      (a, b) =>
+        b.attributes.CallReceivedTime -
+        a.attributes.CallReceivedTime,
+    );
+
+    sortedData.forEach((row) => {
+      const { attributes } = row;
+
+      table.addRow([
+        dayjs
+          .tz(attributes.CallReceivedTime, 'America/Chicago')
+          .fromNow(),
+        attributes.IncidentTypeCode,
+        attributes.IncidentTypeName,
+        attributes.Location,
+        attributes.CityName,
+      ]);
+    });
+
+    return table.toString();
+  };
+
+  return robot.respond(/(?:mnpd|👮|police|:cop:)\s?(\d{5})?/i, (msg) => {
+    const cityName = msg.match[1];
+    const query = {
+      where: '1=1',
+      outFields: '*',
+      outSR: 4326,
+      f: 'json',
+    };
+    if (cityName) {
+      query.where = `CityName=${cityName}`;
+    }
+
+    return robot.http(baseUrl)
+      .query(query)
+      .get()((err, res, body) => {
+        const data = JSON.parse(body);
+        if (data.features?.length === 0) {
+          msg.send('No active incidents.');
+          return;
+        }
+
+        const adapterName = robot.adapterName ?? robot.adapter?.name;
+        if (/slack/.test(adapterName)) {
+          msg.send(`\`\`\`\n${formatTable(data, msg)}\n\`\`\``);
+          return;
+        }
+        msg.send(formatTable(data, msg));
+      });
+  });
+};

scripts/mnpd-dispatches.js

@@ -18,23 +18,53 @@ dayjs.tz.setDefault('America/Chicago');
 
 module.exports = (robot) => {
   // Configure dayjs
-  const baseUrl = 'https://services2.arcgis.com/HdTo6HJqh92wn4D8/arcgis/rest/services/Nashville_Fire_Department_Active_Incidents_view/FeatureServer/0/query?where=1%3D1&objectIds=&time=&resultType=none&outFields=*&returnIdsOnly=false&returnUniqueIdsOnly=false&returnCountOnly=false&returnDistinctValues=false&cacheHint=false&orderByFields=&groupByFieldsForStatistics=&outStatistics=&having=&resultOffset=&resultRecordCount=&sqlFormat=none&f=pjson&token=';
+  const baseUrl = 'https://services2.arcgis.com/HdTo6HJqh92wn4D8/arcgis/rest/services/Nashville_Fire_Department_Active_Incidents_view/FeatureServer/0/query';
 
   const formatTable = (data) => {
-    const table = new AsciiTable('Nashville Fire Active Incidents');
-    table.setHeading('Time', 'Postal Code', 'Type', 'Unit Dispatched');
-    const sortedData = data.features.sort(
-      (a, b) => b.attributes.DispatchDateTime - a.attributes.DispatchDateTime,
-    );
-    sortedData.forEach((row) => {
+    const table = new AsciiTable('🔥 Nashville Fire Active Incidents 🚒');
+    table.setHeading('Time', 'Postal Code', 'Type', 'Units Dispatched');
+
+    const events = {};
+
+    data.features.forEach((row) => {
       const { attributes } = row;
+      const eventId = attributes.event_number;
+
+      if (!events[eventId]) {
+        events[eventId] = {
+          DispatchDateTime: attributes.DispatchDateTime,
+          PostalCode: attributes.PostalCode,
+          incident_type_id: attributes.incident_type_id,
+          units: new Set(),
+        };
+      }
+
+      if (attributes.Unit_ID) {
+        events[eventId].units.add(attributes.Unit_ID);
+      }
+    });
+
+    const sortedEvents = Object.values(events).sort(
+      (a, b) => b.DispatchDateTime - a.DispatchDateTime,
+    );
+
+    sortedEvents.forEach((event) => {
+      const units = Array.from(event.units).sort();
+      const visibleUnits = units.slice(0, 5);
+      const remaining = units.length - visibleUnits.length;
+
       table.addRow([
-        dayjs.tz(attributes.DispatchDateTime, 'America/Chicago').fromNow(),
-        attributes.PostalCode,
-        attributes.incident_type_id,
-        attributes.Unit_ID,
+        dayjs
+          .tz(event.DispatchDateTime, 'America/Chicago')
+          .fromNow(),
+        event.PostalCode,
+        event.incident_type_id,
+        remaining > 0
+          ? `${visibleUnits.join(', ')} + ${remaining} more`
+          : visibleUnits.join(', '),
       ]);
     });
+
     return table.toString();
   };
 
@@ -43,11 +73,12 @@ module.exports = (robot) => {
     const query = {
       where: '1=1',
       outFields: '*',
-      outSR: 4326,
-      f: 'json',
+      returnGeometry: false,
+      f: 'pjson',
     };
+
     if (zip) {
-      query.where = `PostalCode=${zip}`;
+      query.where = `PostalCode='${zip}'`;
     }
 
     return robot.http(baseUrl)
@@ -59,7 +90,8 @@ module.exports = (robot) => {
           return;
         }
 
-        if (/slack/.test(robot.adapterName)) {
+        const adapterName = robot.adapterName ?? robot.adapter?.name;
+        if (/slack/.test(adapterName)) {
           msg.send(`\`\`\`\n${formatTable(data, msg)}\n\`\`\``);
           return;
         }