update

Author: epfromer

packages/mysql/src/doImport.ts

@@ -152,6 +152,7 @@ async function run() {
   await processCustodians(insertCustodians, (msg) => process.send(msg))
 
   process.send(`completed ${numEmails} emails`)
+  // TODO connection not released, so proc never issues exit to parent
   // connection.close()
 }
 

packages/redis/src/doImport.ts

@@ -46,7 +46,7 @@ async function run() {
         email.from,
         'fromCustodian',
         email.fromCustodian,
-        'emailto',
+        'to',
         email.to,
         'toCustodians',
         email.toCustodians.join(','),
@@ -121,7 +121,7 @@ async function run() {
     'SORTABLE',
     'fromCustodian',
     'TEXT',
-    'emailto',
+    'to',
     'TEXT',
     'SORTABLE',
     'toCustodians',
@@ -168,7 +168,7 @@ async function run() {
   await processCustodians(insertCustodians, (msg) => process.send(msg))
 
   process.send(`completed ${numEmails} emails`)
-  // TODO proc not stopping?
+  client.quit()
 }
 
 run().catch((err) => console.error(err))

packages/redis/src/getAllEmail.ts

@@ -45,7 +45,7 @@ const createSearchParams = (httpQuery: HTTPQuery) => {
   } else {
     // Else, we have specific field searching.
     if (from) query += ` @from|fromCustodian:${from} `
-    if (to) query += ` @emailto|toCustodians|cc|bcc:${to} `
+    if (to) query += ` @to|toCustodians|cc|bcc:${to} `
     if (subject) query += ` @subject:${subject} `
     if (body) query += ` @body:${body} `
   }
@@ -93,7 +93,7 @@ export async function getAllEmail(req: Request, res: Response): Promise<void> {
         sentShort: new Date(doc.sentStr).toISOString().slice(0, 10),
         from: doc.from,
         fromCustodian: doc.fromCustodian,
-        to: doc.emailto,
+        to: doc.to,
         toCustodians: doc.toCustodians ? doc.toCustodians.split(',') : [],
         cc: doc.cc,
         bcc: doc.bcc,

packages/redis/src/getSpecificEmail.ts

@@ -34,7 +34,7 @@ export async function getSpecificEmail(
       sentShort: new Date(doc.sentStr).toISOString().slice(0, 10),
       from: doc.from,
       fromCustodian: doc.fromCustodian,
-      to: doc.emailto,
+      to: doc.to,
       toCustodians: doc.toCustodians ? doc.toCustodians.split(',') : [],
       cc: doc.cc,
       bcc: doc.bcc,