Support querying events by location name

package.json

@@ -6,7 +6,7 @@
   "scripts": {
     "start": "ts-node-dev --respawn --transpile-only --require dotenv/config src/index.ts",
     "test": "NODE_ENV=test jest --silent --testPathIgnorePatterns integration",
-    "integration": "NODE_ENV=test jest --silent --testPathPattern integration",
+    "integration": "NODE_ENV=test jest --silent --runInBand --testPathPattern integration",
     "migrate": "env $(cat .env) knex migrate:latest",
     "rollback": "env $(cat .env) knex migrate:rollback"
   },

src/controllers/events.ts

@@ -4,7 +4,7 @@ import { events } from "../services/events";
 
 export async function listEvents(req: Request, res: Response): Promise<void> {
   try {
-    const allEvents = await events.findAll();
+    const allEvents = await events.find();
     res.json(
       allEvents.map(({ type, location, time }) => ({
         type,

src/routes/events.test.ts

@@ -7,7 +7,7 @@ jest.mock("../services/events");
 describe("/events", () => {
   it("returns list of events", async () => {
     const mockEvents = events as jest.Mocked<typeof events>;
-    mockEvents.findAll.mockResolvedValue([
+    mockEvents.find.mockResolvedValue([
       {
         type: "rakennuspalo: keskisuuri",
         location: "Tuusula",

src/services/events.integration.test.ts

@@ -14,14 +14,14 @@ describe("Service", () => {
     await db.destroy();
   });
 
-  it("adds events", async () => {
+  it("adds event", async () => {
     await events.add({
       location: "Kemi",
       type: "tulipalo muu: pieni",
       time: new Date("2021-01-31T22:00:00.000Z"),
       hash: "dffab7da0d65580c2c09ee683dd8f18632fa27c1",
     });
-    const allEvents = await events.findAll();
+    const allEvents = await events.find();
     expect(allEvents).toEqual([
       {
         location: "Kemi",
@@ -31,6 +31,27 @@ describe("Service", () => {
       },
     ]);
   });
+  it("filters events based on location", async () => {
+    const newEvents = [
+      {
+        type: "rakennuspalo: pieni",
+        location: "Helsinki",
+        time: new Date("2021-03-01T15:40:52.000Z"),
+        hash: "169a28a0c1979d7c105490bde4e30ce5b64418a5",
+      },
+      {
+        location: "Kemi",
+        type: "tulipalo muu: pieni",
+        time: new Date("2021-01-31T22:00:00.000Z"),
+        hash: "dffab7da0d65580c2c09ee683dd8f18632fa27c1",
+      },
+    ];
+    for (const event of newEvents) {
+      await events.add(event);
+    }
+    expect(await events.find({ location: "Helsinki" })).toEqual([newEvents[0]]);
+    expect(await events.find({ location: "Kemi" })).toEqual([newEvents[1]]);
+  });
 
   it("indicates if event exists", async () => {
     await events.add({

src/services/events.ts

@@ -24,18 +24,27 @@ type Event = {
   hash: string;
 };
 
+type QueryFilters = {
+  location?: string;
+};
+
 export const events = {
-  async findAll(): Promise<RescueEvent[]> {
-    const events = await db("events")
-      .join("types", "types.id", "events.type_id")
-      .join("locations", "locations.id", "events.location_id")
-      .select<RescueEvent[]>(
+  async find(filters: QueryFilters = {}): Promise<RescueEvent[]> {
+    let events = db("events")
+      .select(
         "events.time",
         "events.hash",
         "locations.name as location",
         "types.name as type"
-      );
-    return events;
+      )
+      .join("types", "types.id", "events.type_id")
+      .join("locations", "locations.id", "events.location_id");
+    if (filters.location !== undefined) {
+      events = events.where({
+        "locations.name": filters.location,
+      });
+    }
+    return (await events) as RescueEvent[];
   },
   async exists(event: RescueEvent): Promise<boolean> {
     const knownEvent = await db<Event>("events")