feeds: imm-notmuch-insert

1 files changed, 37 insertions, 0 deletions

diff --git a/user-profiles/feeds/imm-notmuch-insert.py b/user-profiles/feeds/imm-notmuch-insert.py
new file mode 100644
index 00000000..855f3a83
--- /dev/null
+++ b/user-profiles/feeds/imm-notmuch-insert.py
@@ -0,0 +1,37 @@
+#!@python@/bin/python
+
+import json
+import sys
+import subprocess
+from io import StringIO
+from email.message import EmailMessage
+import configparser
+from os import environ
+from dateutil.parser import isoparse
+
+def main():
+    notmuchConfig = configparser.ConfigParser()
+    notmuchConfig.read(environ.get('NOTMUCH_CONFIG'))
+
+    callbackMessage = json.load(sys.stdin)
+
+    msg = EmailMessage()
+    authors = ', '.join(map(lambda author: author['name'], callbackMessage['feed_item']['authors']))
+    msg['From'] = f"{callbackMessage['feed_definition']['title']} ({authors}) <imm@imm.invalid>"
+    msg['To'] = f"{notmuchConfig['user']['name']} <{notmuchConfig['user']['primary_email']}>"
+    msg['Subject'] = callbackMessage['feed_item']['title']
+    msg['Message-ID'] = f"{callbackMessage['feed_item']['identifier']@imm.invalid}"
+    for link in callbackMessage['feed_item']['links']:
+        msg.add_header('Link', link)
+    if 'date' in callbackMessage['feed_item']:
+        date = isoparse(callbackMessage['feed_item']['date'])
+        msg['Date'] = date.strftime('%a, %e %b %Y %T %z')
+
+    subprocess.run(
+        args=['notmuch', 'insert'],
+        check=True,
+        stdin=StringIO(bytes(msg))
+    )
+
+if __name__ == '__main__':
+    sys.exit(main())