From fa101660a8927ad6672ea6fe16c2eaf8e71aa2c0 Mon Sep 17 00:00:00 2001
From: XANTRONIX Development <dev@xantronix.com>
Date: Mon, 11 Nov 2024 17:20:53 -0500
Subject: [PATCH] Preserve case of header keys

---
 lib/nntp/tiny/message.py | 63 ++++++++++++++++++++++++++--------------
 1 file changed, 41 insertions(+), 22 deletions(-)

diff --git a/lib/nntp/tiny/message.py b/lib/nntp/tiny/message.py
index 86de365..7c5484c 100644
--- a/lib/nntp/tiny/message.py
+++ b/lib/nntp/tiny/message.py
@@ -3,7 +3,7 @@ import enum
 import datetime
 
 from email.utils  import parsedate_to_datetime
-from email.header import decode_header
+from email.header import decode_header, Header
 
 from nntp.tiny.db import DatabaseTable
 
@@ -54,6 +54,7 @@ class Message(DatabaseTable):
     __slots__ = (
         '_cache',
         '_headers',
+        '_headers_lc',
         '_body',
         '_key',
         'id',
@@ -81,6 +82,7 @@ class Message(DatabaseTable):
     def __init__(self):
         self._cache       = dict()
         self._headers     = None
+        self._headers_lc  = None
         self._body        = None
         self._key         = None
         self.id           = None
@@ -133,11 +135,26 @@ class Message(DatabaseTable):
 
         return self._body
 
-    def header(self, key: str):
+    def _header_set(self, key: str, value: str):
+        self._headers[key]            = value
+        self._headers_lc[key.lower()] = value
+
+    def _header_append(self, key: str, value: str):
+        if key not in self._headers:
+            self._headers[key]            = value
+            self._headers_lc[key.lower()] = value
+        else:
+            self._headers[key]            += value
+            self._headers_lc[key.lower()] += value
+
+    def header(self, key: str, default=None):
         if self._headers is None:
             self.read(self.content)
 
-        return self.headers.get(key.lower())
+        value = self._headers_lc.get(key.lower(), default)
+
+        if value is not None:
+            return decode(value)
 
     @property
     def created_on(self):
@@ -156,10 +173,10 @@ class Message(DatabaseTable):
 
     @created_on.setter
     def created_on(self, value):
-        if self._headers is not None:
-            self._headers['date'] = str(value)
-
-        self._cache['created_on'] = str(value)
+        if self._headers is None:
+            self._cache['created_on'] = str(value)
+        elif value is not None:
+            self._header_set('Date', Header(str(value)).encode())
 
     @property
     def message_id(self) -> str:
@@ -172,8 +189,8 @@ class Message(DatabaseTable):
     def message_id(self, value):
         if self._headers is None:
             self._cache['message_id'] = value
-        else:
-            self.headers['message-id'] = value
+        elif value is not None:
+            self._header_set('Message-ID', Header(value).encode())
 
     @property
     def parent_id(self) -> str:
@@ -186,36 +203,36 @@ class Message(DatabaseTable):
     def parent_id(self, value):
         if self._headers is None:
             self._cache['parent_id'] = value
-        else:
-            self.headers['references'] = value
+        elif value is not None:
+            self._header_set('References', Header(value).encode())
 
     @property
     def sender(self) -> str:
         if self._headers is None:
             return self._cache.get('sender')
 
-        return self.headers.get('from', 'Unknown')
+        return self.header('From', 'Unknown')
 
     @sender.setter
     def sender(self, value):
         if self._headers is None:
             self._cache['sender'] = value
-        else:
-            self.headers['from'] = value
+        elif value is not None:
+            self._header_set('From', Header(value).encode())
 
     @property
     def subject(self) -> str:
         if self._headers is None:
             return self._cache.get('subject', '(no subject)')
 
-        return self.headers.get('subject', '(no subject)')
+        return self.header('subject', '(no subject)')
 
     @subject.setter
     def subject(self, value):
         if self._headers is None:
             self._cache['subject'] = value
-        else:
-            self.headers['subject'] = value
+        elif value is not None:
+            self._header_set('Subject', Header(value).encode())
 
     def is_first_line(self):
         return len(self.headers) == 1 and (self._body == '' or self._body is None)
@@ -225,21 +242,23 @@ class Message(DatabaseTable):
             self.content += self.line
 
         if self.state is MessageState.EMPTY:
-            self.state    = MessageState.HEADER
-            self._headers = dict()
+            self.state       = MessageState.HEADER
+            self._headers    = dict()
+            self._headers_lc = dict()
 
         if self.state is MessageState.HEADER:
             if line == '\n' or line == '\r\n':
                 self.state = MessageState.BODY
             elif line[0] == ' ' or line[0] == '\t':
-                self._headers[self._key] += ' ' + decode(line.strip())
+                self._header_append(self._key, ' ' + line.strip())
             else:
                 match = self.RE_HEADER.match(line)
 
                 if match:
-                    self._key = match[1].lower()
+                    self._key = match[1]
+
+                    self._header_append(self._key, match[2].rstrip())
 
-                    self._headers[self._key] = decode(match[2].rstrip())
         elif self.state is MessageState.BODY:
             if self._body is None:
                 self._body = ''