Update app.py

app.py

@@ -8,6 +8,7 @@ import pytz
 import tzlocal
 import logging
 import json
+import ast # Import the ast module for safe string evaluation
 
 # --- Basic Setup ---
 
@@ -24,7 +25,7 @@ class DateTimeValidationError(ValueError):
 hist_url = "https://groww.in/v1/api/charting_service/v2/chart/exchange/NSE/segment/CASH"
 
 
-# --- Date/Time Functions ---
+# --- Date/Time Functions (No changes here) ---
 
 def validate_datetime_format(dt_str: str) -> datetime:
     """Validate datetime string in strict 'YYYY-MM-DD' format."""
@@ -71,7 +72,7 @@ def get_time_range_in_unix_ms(start_date_str: str, end_date_str: str, timezone:
     return {"start_timestamp_ms": start_timestamp, "end_timestamp_ms": end_timestamp}
 
 
-# --- Asynchronous API Function ---
+# --- Asynchronous API & Processing Functions (No changes here) ---
 
 async def call_price_api_async(session: aiohttp.ClientSession, ticker: str, start: int, end: int, interval: int) -> Dict:
     """Asynchronously calls the candle API."""
@@ -85,9 +86,6 @@ async def call_price_api_async(session: aiohttp.ClientSession, ticker: str, star
     except aiohttp.ClientError as e:
         return {"ticker": ticker, "interval": interval, "data": None, "error": str(e)}
 
-
-# --- Main Processing Logic ---
-
 async def main_task(tickers: List[str], start_time: int, end_time: int, intervals: List[int], progress: gr.Progress):
     """Main function to run the asynchronous API calls in batches."""
     results = []
@@ -124,17 +122,33 @@ def process_and_merge_data(results: list) -> str:
             
     return json.dumps(list(merged_data.values()), indent=4)
 
-# --- Gradio Backend Function ---
+
+# --- Gradio Backend Function (MODIFIED FOR NEW INPUT FORMAT) ---
 
 async def run_backend_processing(tickers_text: str, progress=gr.Progress(track_tqdm=True)):
     """The main function to be called by the Gradio interface."""
     if not tickers_text.strip():
-        yield "Please enter at least one ticker.", "{}"
-        return  # Correct way to exit an async generator
+        yield "Error: Input is empty. Please provide a list of tickers.", "{}"
+        return
+
+    try:
+        # Safely parse the string input into a Python list
+        parsed_input = ast.literal_eval(tickers_text)
+        if not isinstance(parsed_input, list):
+            raise TypeError("Input must be a list.")
+        # Clean and validate tickers
+        tickers = [str(item).strip().upper() for item in parsed_input]
+        if not tickers:
+            yield "Error: The provided list is empty.", "{}"
+            return
+
+    except (ValueError, SyntaxError, TypeError) as e:
+        error_message = 'Invalid input format. Please provide a list of strings, e.g., ["RELIANCE", "INFY"]'
+        yield error_message, "{}"
+        return
 
-    tickers = [ticker.strip().upper() for ticker in tickers_text.split('\n') if ticker.strip()]
     today_str = date.today().strftime("%Y-%m-%d")
-    yield f"Starting processing for {len(tickers)} tickers for date: {today_str}", "{}"
+    yield f"Starting processing for {len(tickers)} tickers: {tickers}", "{}"
     
     try:
         time_range = get_time_range_in_unix_ms(today_str, today_str)
@@ -153,19 +167,20 @@ async def run_backend_processing(tickers_text: str, progress=gr.Progress(track_t
         logger.error(f"An unhandled error occurred: {e}")
         yield f"An error occurred: {e}", "{}"
 
-# --- Gradio UI ---
+
+# --- Gradio UI (MODIFIED FOR NEW INPUT FORMAT) ---
 
 with gr.Blocks(theme=gr.themes.Soft()) as demo:
     gr.Markdown("## Stock Data Backend Processor")
-    gr.Markdown("Enter stock tickers (one per line) and click 'Start Processing' or press Enter.")
+    gr.Markdown("Enter a list of stock tickers in Python list format.")
     
     with gr.Row():
         with gr.Column(scale=1):
-            # Pre-fill the textbox with the example tickers
+            # Update textbox to be single-line and show the correct example format
             tickers_input = gr.Textbox(
-                lines=10, 
-                label="Enter Tickers", 
-                value="RELIANCE\nINFY"
+                lines=1, 
+                label='Enter Tickers as a List', 
+                value='["RELIANCE", "INFY"]'
             )
             start_button = gr.Button("Start Processing", variant="primary")
         
@@ -174,16 +189,17 @@ with gr.Blocks(theme=gr.themes.Soft()) as demo:
             json_output = gr.JSON(label="Processed JSON Output")
 
     # --- Triggers ---
-    
-    # Define a list of components that trigger the function
-    triggers = [start_button.click, tickers_input.submit]
-    
-    for event in triggers:
-        event(
-            fn=run_backend_processing,
-            inputs=[tickers_input],
-            outputs=[logs_output, json_output]
-        )
+    # Trigger on button click or pressing Enter in the textbox
+    start_button.click(
+        fn=run_backend_processing,
+        inputs=[tickers_input],
+        outputs=[logs_output, json_output]
+    )
+    tickers_input.submit(
+        fn=run_backend_processing,
+        inputs=[tickers_input],
+        outputs=[logs_output, json_output]
+    )
 
 if __name__ == "__main__":
     demo.launch()