Initial commit introducing new patient search service

src/api/handlers/patients/getPatients.js

@@ -0,0 +1,16 @@
+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
+}