Index email sent from webapp to other Lokole user (#303)

opwen_email_server/integration/celery.py

@@ -80,7 +80,7 @@ def inbound_store(resource_id: str) -> None:
     action(resource_id)
 
 
-def send_and_index(resource_id: str) -> None:
+def _send_email(resource_id: str) -> None:
     send.delay(resource_id)
     index_sent_email_for_mailbox.delay(resource_id)
 
@@ -91,7 +91,7 @@ def written_store(resource_id: str) -> None:
         client_storage=get_client_storage(),
         email_storage=get_email_storage(),
         user_storage=get_user_storage(),
-        next_task=send_and_index,
+        next_task=_send_email,
     )
 
     action(resource_id)

opwen_email_server/integration/webapp.py

@@ -21,7 +21,9 @@
 from opwen_email_server.integration.azure import get_email_storage
 from opwen_email_server.integration.azure import get_mailbox_storage
 from opwen_email_server.integration.azure import get_user_storage
-from opwen_email_server.integration.celery import send_and_index
+from opwen_email_server.integration.celery import index_received_email_for_mailbox
+from opwen_email_server.integration.celery import index_sent_email_for_mailbox
+from opwen_email_server.integration.celery import send
 from opwen_email_server.services.storage import AzureObjectStorage
 from opwen_email_server.utils.collections import chunks
 from opwen_email_server.utils.email_parser import get_domain
@@ -247,13 +249,19 @@ def download(self) -> Iterable:
         return []
 
 
+def _send_email(resource_id: str) -> None:
+    send.delay(resource_id)
+    index_sent_email_for_mailbox.delay(resource_id)
+    index_received_email_for_mailbox.delay(resource_id)
+
+
 class AzureIoc:
     @cached_property
     def email_store(self):
         return AzureEmailStore(
             email_storage=get_email_storage(),
             mailbox_storage=get_mailbox_storage(),
-            send_email=send_and_index,
+            send_email=_send_email,
         )
 
     @cached_property