From ccedec7703a719635533b26c8bd7d254e0e37bd0 Mon Sep 17 00:00:00 2001
From: Jackson Harper <jacksonh@gmail.com>
Date: Mon, 4 Apr 2022 21:21:57 -0700
Subject: [PATCH] Make sure we refresh the elastic index when running tests

---
 .../api/test/services/save_newsletter_email.test.ts  | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/packages/api/test/services/save_newsletter_email.test.ts b/packages/api/test/services/save_newsletter_email.test.ts
index cbd070f26..5fda82add 100644
--- a/packages/api/test/services/save_newsletter_email.test.ts
+++ b/packages/api/test/services/save_newsletter_email.test.ts
@@ -7,16 +7,24 @@ import { saveNewsletterEmail } from '../../src/services/save_newsletter_email'
 import { getPageByParam } from '../../src/elastic'
 import { User } from '../../src/entity/user'
 import { NewsletterEmail } from '../../src/entity/newsletter_email'
+import { SaveContext } from '../../src/services/save_email'
+import { createPubSubClient } from '../../src/datalayer/pubsub'
 
 describe('saveNewsletterEmail', () => {
   const username = 'fakeUser'
 
   let user: User
   let email: NewsletterEmail
+  let ctx: SaveContext
 
   before(async () => {
     user = await createTestUser(username)
     email = await createNewsletterEmail(user.id)
+    ctx = {
+      pubsub: createPubSubClient(),
+      refresh: true,
+      uid: user.id,
+    }
   })
 
   after(async () => {
@@ -30,7 +38,7 @@ describe('saveNewsletterEmail', () => {
       url: 'https://example.com',
       title: 'fake title',
       author: 'fake author',
-    })
+    }, ctx)
 
     setTimeout(async () => {
       const page = await getPageByParam({ userId: user.id })
@@ -56,7 +64,7 @@ describe('saveNewsletterEmail', () => {
       url: 'https://example.com/2',
       title: 'fake title',
       author: 'fake author',
-    })
+    }, ctx)
 
     setTimeout(async () => {
       const page = await getPageByParam({ userId: user.id })