diff --git a/src/services/pis.services.js b/src/services/pis.services.js
index 1f224a4..3ee34fe 100644
--- a/src/services/pis.services.js
+++ b/src/services/pis.services.js
@@ -2,11 +2,12 @@
 
 const db = require('../services/dbAccess.services')
 const log = require('../utils/log.utils')
+const clean = require('../utils/sanitizer.utils')
 
-async function findPisByOrigDest(start,end) { // Probably need to add a sanitize here
+async function findPisByOrigDest(start,end) {
     log.out(`pisServices.findPisByOrigDest: Searching for PIS for Orig: ${start}, Dest: ${end}`, "dbug")
-    const firstCrs = start.toLowerCase()
-    const lastCrs = end.toLowerCase()
+    const firstCrs = clean.cleanApiEndpointTxt(start.toLowerCase())
+    const lastCrs = clean.cleanApiEndpointTxt(end.toLowerCase())
     const search = db.query("pis", {$and:[{$expr:{$eq:[{$first:"$stops"},firstCrs]}},{$expr:{$eq:[{$last:"$stops"},lastCrs]}}]})
     return search
 }