Fix notification database errors and duplication issues

- Fixed 'NoneType' object has no attribute 'get' errors in notification_db.py
- Added proper null checking for record fields and reply information
- Fixed logic in save_notification_to_queue to prevent queueing when DB add fails
- This resolves notification duplication where failed DB adds led to reprocessing

The bot was reprocessing the same notifications because:
1. Notification gets fetched and queued
2. Database add fails due to None field access
3. Notification gets processed but never marked as processed in DB
4. Next fetch cycle finds it again and re-queues it

bsky.py

···
             if NOTIFICATION_DB.is_processed(notification_uri):
                 logger.debug(f"Notification already processed (DB): {notification_uri}")
                 return False
-            # Add to database
-            NOTIFICATION_DB.add_notification(notif_dict)
+            # Add to database - if this fails, don't queue the notification
+            if not NOTIFICATION_DB.add_notification(notif_dict):
+                logger.warning(f"Failed to add notification to database, skipping: {notification_uri}")
+                return False
         else:
             # Fall back to old JSON method
             processed_uris = load_processed_notifications()

notification_db.py

···
             author_handle = author.get('handle', '') if author else ''
             author_did = author.get('did', '') if author else ''
             
-            # Extract text from record if available
-            record = notif_dict.get('record', {})
-            text = record.get('text', '')[:500]  # Limit text length
+            # Extract text from record if available (handle None records)
+            record = notif_dict.get('record') or {}
+            text = record.get('text', '')[:500] if record else ''
             
             # Extract thread info
             parent_uri = None
             root_uri = None
-            if 'reply' in record:
-                parent_uri = record['reply'].get('parent', {}).get('uri')
-                root_uri = record['reply'].get('root', {}).get('uri')
+            if record and 'reply' in record and record['reply']:
+                reply_info = record['reply']
+                if reply_info and isinstance(reply_info, dict):
+                    parent_info = reply_info.get('parent', {})
+                    root_info = reply_info.get('root', {})
+                    if parent_info:
+                        parent_uri = parent_info.get('uri')
+                    if root_info:
+                        root_uri = root_info.get('uri')
             
             # Store additional metadata as JSON
             metadata = {