X-Git-Url: https://git.njae.me.uk/?a=blobdiff_plain;f=dmarc_to_database;h=ca6eafb52c20477651a6078a97f824cc8be86dc1;hb=63dc7509a66d6c0653bae12a7ff311b0e8adfe71;hp=ac7baa39c034ac7e00dc3616de4ac0c5be382c0f;hpb=1804dc85cd913ace36a9627f5ee3b956fb0ffe45;p=dmarc.git

diff --git a/dmarc_to_database b/dmarc_to_database
index ac7baa3..ca6eafb 100755
--- a/dmarc_to_database
+++ b/dmarc_to_database
@@ -9,6 +9,16 @@ import xml.etree.ElementTree
 import psycopg2
 import re
 import datetime
+import argparse
+
+parser = argparse.ArgumentParser(description='Process DMARC records.')
+parser.add_argument('-c', '--config', action='store',
+  default='', dest='config_file',
+  help='Path to config file')
+parser.add_argument('-t', '--test', action='store_true',
+                   default=False,
+                   help='Test, but do not add records to the database')
+args = parser.parse_args()
 
 def fetch_msg(num):
     return mailbox.uid('FETCH', num, '(RFC822)')[1][0][1]
@@ -158,7 +168,13 @@ def write_report(connection, cursor, report):
     connection.commit()
 
 config = configparser.ConfigParser()
-config.read('dmarc.ini')
+if args.config_file:
+    config.read(args.config_file)
+else:
+    config.read(['/etc/dmarc_to_database.ini', './dmarc_to_database.ini'])
+
+if not config.sections():
+    raise RuntimeError('Could not find configuration file')
 
 conn = psycopg2.connect(host=config['database']['server'],
                         database=config['database']['database'], 
@@ -196,6 +212,7 @@ for report in dmarc_reports:
     results = cur.fetchall()
     if not results:
         print('write', report.find('./report_metadata/report_id').text)
-        write_report(conn, cur, report)
+        if not args.test:
+            write_report(conn, cur, report)
 
 conn.close()