ts file upload sources

app/main.py

@@ -106,9 +106,20 @@ async def chatui_file_adapter(data):
         text = data.text if hasattr(data, 'text') else data.get('text', '')
         files = getattr(data, 'files', None) if hasattr(data, 'files') else data.get('files', None)
         
+        # ===== LOGGING INPUT DATA FOR CHATUI FILE ADAPTER =====
+        logger.info("=" * 60)
+        logger.info("CHATUI FILE ADAPTER INPUT")
+        logger.info("=" * 60)
         logger.info(f"Text: {text[:100]}...")
         logger.info(f"Files present: {files is not None and len(files) > 0 if files else False}")
         
+        if files and len(files) > 0:
+            file_info = files[0]
+            logger.info(f"Processing file: {file_info.get('name', 'unknown')}")
+            logger.info(f"File type: {file_info.get('type', 'unknown')}")
+            logger.info(f"File content length: {len(file_info.get('content', '')) if file_info.get('content') else 0}")
+        logger.info("=" * 60)
+        
         file_content = None
         filename = None
         
@@ -146,18 +157,52 @@ async def chatui_file_adapter(data):
                     yield content
                 elif result_type == "sources":
                     sources_collected = content
+                    # ===== LOGGING SOURCES RECEIVED =====
+                    logger.info("=" * 60)
+                    logger.info("SOURCES RECEIVED IN CHATUI FILE ADAPTER")
+                    logger.info("=" * 60)
+                    logger.info(f"Number of sources: {len(sources_collected) if sources_collected else 0}")
+                    if sources_collected:
+                        for i, source in enumerate(sources_collected, 1):
+                            logger.info(f"Source {i}:")
+                            if isinstance(source, dict):
+                                logger.info(f"  - Title: {source.get('title', 'Unknown')}")
+                                logger.info(f"  - Link: {source.get('link', '#')}")
+                                logger.info(f"  - Type: {type(source).__name__}")
+                                # Log any additional fields
+                                for key, value in source.items():
+                                    if key not in ['title', 'link']:
+                                        logger.info(f"  - {key}: {value}")
+                            else:
+                                logger.info(f"  - Raw source: {source}")
+                                logger.info(f"  - Type: {type(source).__name__}")
+                            logger.info("  " + "-" * 40)
+                    logger.info("=" * 60)
                 elif result_type == "end":
-                    # Send sources at the end
+                    # ===== LOGGING SOURCES BEING SENT TO USER =====
+                    logger.info("=" * 60)
+                    logger.info("SOURCES BEING SENT TO USER (CHATUI FILE ADAPTER)")
+                    logger.info("=" * 60)
                     if sources_collected:
                         sources_text = "\n\n**Sources:**\n"
+                        logger.info(f"Formatting {len(sources_collected)} sources for user display:")
                         for i, source in enumerate(sources_collected, 1):
                             if isinstance(source, dict):
                                 title = source.get('title', 'Unknown')
                                 link = source.get('link', '#')
-                                sources_text += f"{i}. [{title}]({link})\n"
+                                source_line = f"{i}. [{title}]({link})\n"
+                                sources_text += source_line
+                                logger.info(f"  Source {i}: {source_line.strip()}")
                             else:
-                                sources_text += f"{i}. {source}\n"
+                                source_line = f"{i}. {source}\n"
+                                sources_text += source_line
+                                logger.info(f"  Source {i}: {source_line.strip()}")
+                        logger.info(f"Complete sources text length: {len(sources_text)} characters")
+                        logger.info(f"Sources text preview: {sources_text[:200]}{'...' if len(sources_text) > 200 else ''}")
                         yield sources_text
+                    else:
+                        logger.info("No sources to send to user")
+                    logger.info("=" * 60)
                 elif result_type == "error":
                     yield f"Error: {content}"
             else: