Initial commit introducing new patient search service

src/api/handlers/patients/getPatients.js

@@ -0,0 +1,13 @@
+import { getPatients } from "../../../models/patient";
+
+export default async (req, res) => {
+  const filter = req.query.filter;
+
+  if (filter === null || typeof filter !== "string" || filter.length < 3) {
+    return res.status(400).send({
+      message: "Invalid filter criteria.",
+    });
+  }
+
+  return res.status(200).send(await getPatients(filter));
+};

src/api/handlers/patients/index.js

@@ -0,0 +1,3 @@
+import getPatients from "./getPatients";
+
+export { getPatients };

src/api/index.js

@@ -11,6 +11,7 @@ import { getToken } from "./handlers/auth";
 import { getCommunications } from "./handlers/communications";
 import { getLanguages } from "./handlers/languages";
 import { postReply } from "./handlers/twilio";
+import getPatients from "./handlers/patients/getPatients";
 
 // eslint-disable-next-line no-unused-vars
 export default ({ config }) => {
@@ -34,6 +35,9 @@ export default ({ config }) => {
   api.post("/appointments", postAppointments);
   api.patch("/appointments/:appointmentId", patchAppointments);
 
+  // -- Patients
+  api.get("/patients", getPatients);
+
   // -- Languages
   api.get("/languages", getLanguages);
 

src/models/patient.js

@@ -0,0 +1,16 @@
+import { db } from "../../knex";
+
+const patientFields = [
+  "patientName",
+  "patientPhoneNumber",
+  "language",
+  { patientLanguage: "language" },
+];
+
+export const getPatients = (substring) => {
+  const query = db("appointments")
+    .distinct(patientFields)
+    .where("patientName", "like", `%${substring}%`);
+
+  return query;
+};