Create app.py

app.py

@@ -0,0 +1,98 @@
+# File: main.py (Enhanced Entry Point)
+import time
+import threading
+import queue
+from audio_capture import AudioRecorder
+from transcriber import WhisperTranscriber
+from analyzer import MeetingAnalyzer
+from integrations import Notifier
+import config
+
+class MeetingProcessor:
+    def __init__(self):
+        self.recorder = AudioRecorder()
+        self.transcriber = WhisperTranscriber()
+        self.analyzer = MeetingAnalyzer()
+        self.notifier = Notifier()
+        self.transcript_queue = queue.Queue()
+        self.running = True
+        
+        # Start processing threads
+        threading.Thread(target=self._transcription_worker, daemon=True).start()
+        threading.Thread(target=self._analysis_worker, daemon=True).start()
+        
+    def _transcription_worker(self):
+        while self.running:
+            audio_chunk = self.recorder.get_audio_chunk()
+            if audio_chunk:
+                try:
+                    transcript = self.transcriber.transcribe(audio_chunk)
+                    if transcript:
+                        self.transcript_queue.put(transcript)
+                except Exception as e:
+                    print(f"Transcription error: {str(e)}")
+            time.sleep(0.1)
+    
+    def _analysis_worker(self):
+        while self.running:
+            try:
+                transcript = self.transcript_queue.get(timeout=1.0)
+                self.analyzer.process_chunk(transcript)
+                # Real-time action item detection
+                urgent_items = self.analyzer.detect_urgent_action_items()
+                if urgent_items:
+                    print("\n🚨 URGENT ACTION ITEM DETECTED!")
+                    for item in urgent_items:
+                        print(f"• {item['task']} (Owner: {item['owner']}, Deadline: {item['deadline']})")
+                    self.notifier.send_urgent_alert(urgent_items)
+            except queue.Empty:
+                continue
+    
+    def start(self):
+        print("🎤 Starting meeting processing... Press Ctrl+C to end meeting")
+        self.recorder.start_recording()
+        
+        try:
+            # Keep main thread alive
+            while True:
+                time.sleep(1)
+        except KeyboardInterrupt:
+            print("\n⏹️ Meeting ended. Generating final report...")
+            self.running = False
+            self._finalize_processing()
+    
+    def _finalize_processing(self):
+        # Process remaining audio
+        final_audio = self.recorder.stop_recording()
+        if final_audio:
+            final_transcript = self.transcriber.transcribe_final(final_audio)
+            if final_transcript:
+                self.analyzer.process_chunk(final_transcript)
+        
+        # Generate AI analysis
+        full_transcript = self.analyzer.get_full_transcript()
+        summary = self.analyzer.generate_summary()
+        action_items = self.analyzer.extract_action_items()
+        decisions = self.analyzer.extract_decisions()
+        
+        # Display results
+        print("\n📝 Final Meeting Summary:")
+        print(summary)
+        print("\n✅ Action Items:")
+        for i, item in enumerate(action_items, 1):
+            print(f"{i}. {item['task']} (Owner: {item['owner']}, Deadline: {item['deadline']})")
+        
+        # Send comprehensive report
+        self.notifier.send_comprehensive_report(
+            summary=summary,
+            action_items=action_items,
+            decisions=decisions,
+            transcript=full_transcript,
+            recipients=config.NOTIFICATION_RECIPIENTS
+        )
+        
+        print("\n🚀 Comprehensive report sent to all recipients!")
+
+if __name__ == "__main__":
+    processor = MeetingProcessor()
+    processor.start()