Spaces:

devcom-corp-ai
/

ThreeAI-Demo

Sleeping

+{
+    "customers": [
+        {
+            "customerID": 451930,
+            "firstName": "Test",
+            "lastName": "Test",
+            "company": "",
+            "customerType": 3,
+            "customerStatus": 1,
+            "email": "testtest@gmail.com",
+            "phone": "8011111111",
+            "phone2": "",
+            "mobilePhone": "",
+            "fax": "",
+            "mainAddress1": "test1",
+            "mainAddress2": "test",
+            "mainCity": "test",
+            "mainState": "JHR",
+            "mainZip": "93000",
+            "mainCountry": "MY",
+            "mainCounty": "Utah",
+            "mailAddress1": "1441 Innovation Way",
+            "mailAddress2": "",
+            "mailCity": "Lehi",
+            "mailState": "JHR",
+            "mailZip": "84043",
+            "mailCountry": "MY",
+            "mailCounty": "Utah",
+            "otherAddress1": "1441 Innovation Way",
+            "otherAddress2": "",
+            "otherCity": "Lehi",
+            "otherState": "JHR",
+            "otherZip": "84043",
+            "otherCountry": "MY",
+            "otherCounty": "UT",
+            "loginName": "IvoryTest",
+            "enrollerID": 1,
+            "sponsorID": 0,
+            "rankID": 40,
+            "birthDate": "1987-01-03T00:00:00",
+            "field1": "",
+            "field2": "",
+            "field3": "",
+            "field4": "",
+            "field5": "",
+            "field6": "",
+            "field7": "0",
+            "field8": "",
+            "field9": "",
+            "field10": "0",
+            "field11": "1",
+            "field12": "2026-01-01 12:00:00",
+            "field13": "",
+            "field14": "",
+            "field15": "",
+            "date1": "2020-11-02T11:45:24",
+            "date2": "2023-02-16T20:48:20",
+            "date3": null,
+            "date4": null,
+            "date5": null,
+            "currencyCode": "myr",
+            "payableToName": "",
+            "defaultWarehouseID": 11,
+            "payableType": 8,
+            "checkThreshold": 0.0000,
+            "priceType": 3,
+            "languageID": 0,
+            "gender": 0,
+            "salesTaxID": "",
+            "vatRegistration": "",
+            "isSalesTaxExempt": false,
+            "isSubscribedToBroadcasts": true,
+            "createdDate": "2020-11-02T10:43:24",
+            "modifiedDate": "2025-10-21T16:21:05.843",
+            "middleName": "",
+            "nameSuffix": "",
+            "mainAddress3": "",
+            "mailAddress3": "",
+            "otherAddress3": "",
+            "binaryPlacementPreference": 11,
+            "useBinaryHoldingTank": false,
+            "mainAddressVerified": false,
+            "mailAddressVerified": false,
+            "otherAddressVerified": false,
+            "customerKey": null,
+            "enrollerKey": null,
+            "sponsorKey": null,
+            "payableTyID": 8,
+            "canLogin": true,
+            "genderID": "U",
+            "genderDescription": "Unspecified"
+        }
+    ],
+    "recordCount": 1
+}

data/GetRealTimeCommissions.json ADDED Viewed

	@@ -0,0 +1,66 @@

+{
+    "commissions": [
+        {
+            "customerID": 451930,
+            "periodType": 1,
+            "periodID": 377,
+            "periodDescription": "Week 139 10/13-10/19",
+            "currencyCode": "usd",
+            "commissionTotal": 42758.1575,
+            "bonuses": [
+                {
+                    "description": "Team Commissions",
+                    "amount": 22500.0000,
+                    "bonusID": 26
+                },
+                {
+                    "description": "Leadership Matching Bonus",
+                    "amount": 16334.5000,
+                    "bonusID": 27
+                },
+                {
+                    "description": "Global Leadership Pool Bonus (GLPB)",
+                    "amount": 3417.1916,
+                    "bonusID": 28
+                },
+                {
+                    "description": "Founders Pool Bonus (FPB)",
+                    "amount": 506.4659,
+                    "bonusID": 29
+                }
+            ],
+            "customerKey": null
+        },
+        {
+            "customerID": 451930,
+            "periodType": 1,
+            "periodID": 378,
+            "periodDescription": "Week 140 10/20-10/26",
+            "currencyCode": "usd",
+            "commissionTotal": 35335.7143,
+            "bonuses": [
+                {
+                    "description": "Team Commissions",
+                    "amount": 20385.0000,
+                    "bonusID": 26
+                },
+                {
+                    "description": "Leadership Matching Bonus",
+                    "amount": 12906.2500,
+                    "bonusID": 27
+                },
+                {
+                    "description": "Global Leadership Pool Bonus (GLPB)",
+                    "amount": 1854.4252,
+                    "bonusID": 28
+                },
+                {
+                    "description": "Founders Pool Bonus (FPB)",
+                    "amount": 190.0391,
+                    "bonusID": 29
+                }
+            ],
+            "customerKey": null
+        }
+    ]
+}

data/GetVolumes.json ADDED Viewed

	@@ -0,0 +1,213 @@

+{
+    "volumes": [
+        {
+            "customerID": 451930,
+            "periodType": 1,
+            "periodID": 364,
+            "periodDescription": "Week 126 7/14-7/20",
+            "volume1": 1.0000,
+            "volume2": 0.0000,
+            "volume3": -250.0000,
+            "volume4": 1315.0000,
+            "volume5": 2485.0000,
+            "volume6": 0.0000,
+            "volume7": 58.0000,
+            "volume8": 1.0000,
+            "volume9": 59.0000,
+            "volume10": 0.0000,
+            "volume11": 18.0000,
+            "volume12": 1.0000,
+            "volume13": 0.0000,
+            "volume14": 1.0000,
+            "volume15": 0.0000,
+            "volume16": 2145.0000,
+            "volume17": 0.0000,
+            "volume18": 180.0000,
+            "volume19": 1565.0000,
+            "volume20": 510.0000,
+            "volume21": 2454.0000,
+            "volume22": 3254.0000,
+            "volume23": 4594.0000,
+            "volume24": 1.0000,
+            "volume25": 0.0000,
+            "volume26": 0.0000,
+            "volume27": 0.0000,
+            "volume28": 0.0000,
+            "volume29": 0.0000,
+            "volume30": 0.0000,
+            "volume31": 7236.0000,
+            "volume32": 740.0000,
+            "volume33": 760.0000,
+            "volume34": 0.0000,
+            "volume35": 6000.0000,
+            "volume36": 84.0000,
+            "volume37": 6760.0000,
+            "volume38": 84.0000,
+            "volume39": 6000.0000,
+            "volume40": 84.0000,
+            "volume41": 2314.0000,
+            "volume42": 300.0000,
+            "volume43": 3014.0000,
+            "volume44": 400.0000,
+            "volume45": 4114.0000,
+            "volume46": 640.0000,
+            "volume47": 6760.0000,
+            "volume48": 84.0000,
+            "volume49": 0.0000,
+            "volume50": 0.0000,
+            "volume51": 6760.0000,
+            "volume52": 84.0000,
+            "volume53": 0.0000,
+            "volume54": 0.0000,
+            "volume55": 84.0000,
+            "volume56": 6760.0000,
+            "volume57": 0.0000,
+            "volume58": 1.0000,
+            "volume59": 1.0000,
+            "volume60": 0.0000,
+            "volume61": 1.0000,
+            "volume62": 0.0000,
+            "volume63": 0.0000,
+            "volume64": 1.0000,
+            "volume65": 1.0000,
+            "volume66": 0.0000,
+            "volume67": 0.0000,
+            "volume68": 0.0000,
+            "volume69": 510.0000,
+            "volume70": 0.0000,
+            "volume71": 0.0000,
+            "volume72": 0.0000,
+            "volume73": 0.0000,
+            "volume74": 0.0000,
+            "volume75": 40.0000,
+            "volume76": 40.0000,
+            "volume77": 40.0000,
+            "volume78": 40.0000,
+            "volume79": 40.0000,
+            "volume80": 40.0000,
+            "volume81": 0.0000,
+            "volume82": 40.0000,
+            "volume83": 1.0000,
+            "volume84": 830.0000,
+            "volume85": 0.0000,
+            "volume86": 1.0000,
+            "volume87": 0.0000,
+            "volume88": 0.0000,
+            "volume89": 0.0000,
+            "volume90": 0.0000,
+            "volume91": 2.0000,
+            "volume92": 0.0000,
+            "volume93": 0.0000,
+            "volume94": 0.0000,
+            "volume95": 31.0000,
+            "volume96": 0.0000,
+            "volume97": 0.0000,
+            "volume98": 0.0000,
+            "volume99": 0.0000,
+            "volume100": 0.0000,
+            "rankID": 40,
+            "paidRankID": 40,
+            "volume101": 390.0000,
+            "volume102": 390.0000,
+            "volume103": 0.0000,
+            "volume104": 2205.0000,
+            "volume105": 1.0000,
+            "volume106": 0.0000,
+            "volume107": -250.0000,
+            "volume108": 0.0000,
+            "volume109": 9.0000,
+            "volume110": 0.0000,
+            "volume111": 0.0000,
+            "volume112": 1.0000,
+            "volume113": 61.0000,
+            "volume114": 6.0000,
+            "volume115": 5.0000,
+            "volume116": 0.0000,
+            "volume117": 67.0000,
+            "volume118": 0.0000,
+            "volume119": 0.0000,
+            "volume120": 5.0000,
+            "volume121": 1860.0000,
+            "volume122": 0.0000,
+            "volume123": 0.0000,
+            "volume124": 1535.0000,
+            "volume125": 0.0000,
+            "volume126": 0.0000,
+            "volume127": 0.0000,
+            "volume128": 1535.0000,
+            "volume129": 74200.0000,
+            "volume130": 200.0000,
+            "volume131": 0.0000,
+            "volume132": 1430.0000,
+            "volume133": 0.0000,
+            "volume134": 0.0000,
+            "volume135": 0.0000,
+            "volume136": 2915.0000,
+            "volume137": 0.0000,
+            "volume138": 0.0000,
+            "volume139": 0.0000,
+            "volume140": 0.0000,
+            "volume141": 0.0000,
+            "volume142": 0.0000,
+            "volume143": 10111.0000,
+            "volume144": 0.0000,
+            "volume145": 0.0000,
+            "volume146": 0.0000,
+            "volume147": 0.0000,
+            "volume148": 0.0000,
+            "volume149": 0.0000,
+            "volume150": 0.0000,
+            "volume151": 830.0000,
+            "volume152": 740.0000,
+            "volume153": 4.0000,
+            "volume154": 0.0000,
+            "volume155": 830.0000,
+            "volume156": 830.0000,
+            "volume157": 0.0000,
+            "volume158": 0.0000,
+            "volume159": 125.0000,
+            "volume160": 830.0000,
+            "volume161": 0.0000,
+            "volume162": 0.0000,
+            "volume163": 0.0000,
+            "volume164": 0.0000,
+            "volume165": 0.0000,
+            "volume166": 0.0000,
+            "volume167": 2288.0000,
+            "volume168": 7.0000,
+            "volume169": 0.0000,
+            "volume170": 0.0000,
+            "volume171": 0.0000,
+            "volume172": 0.0000,
+            "volume173": 2265.0000,
+            "volume174": 240.0000,
+            "volume175": 240.0000,
+            "volume176": 130.0000,
+            "volume177": 130.0000,
+            "volume178": 0.0000,
+            "volume179": 110.0000,
+            "volume180": 240.0000,
+            "volume181": 240.0000,
+            "volume182": 240.0000,
+            "volume183": 0.0000,
+            "volume184": 0.0000,
+            "volume185": 0.0000,
+            "volume186": 0.0000,
+            "volume187": 0.0000,
+            "volume188": 0.0000,
+            "volume189": 0.0000,
+            "volume190": 3220.0000,
+            "volume191": 2265.0000,
+            "volume192": 2265.0000,
+            "volume193": 2265.0000,
+            "volume194": 650.0000,
+            "volume195": 3.0000,
+            "volume196": 2485.0000,
+            "volume197": 0.0000,
+            "volume198": 0.0000,
+            "volume199": 1315.0000,
+            "volume200": 0.0000,
+            "customerKey": null
+        }
+    ]
+}

data_service.py ADDED Viewed

	@@ -0,0 +1,55 @@

+import json
+import os
+from pathlib import Path
+from typing import Dict, Any, Optional
+import logging
+logging.basicConfig(level=logging.INFO)
+logger = logging.getLogger(__name__)
+class DataService:
+    def __init__(self, data_dir: str = "data"):
+        """
+        Initialize data service.
+        Args:
+            data_dir: Path to data directory (default: "data")
+        """
+        self.data_dir = Path(data_dir)
+        if not self.data_dir.exists():
+            raise ValueError(f"Data directory '{data_dir}' does not exist")
+        logger.info(f"DataService initialized with directory: {self.data_dir}")
+    def get_data(self, filename: str) -> Optional[Dict[str, Any]]:
+        """
+        Read and return complete data from JSON file.
+        Args:
+            filename: Name of JSON file (e.g., "GetCustomers.json")
+        Returns:
+            Dictionary with complete JSON data or None if error
+        """
+        file_path = self.data_dir / filename
+        try:
+            if not file_path.exists():
+                logger.error(f"File not found: {file_path}")
+                return None
+            with open(file_path, 'r', encoding='utf-8') as f:
+                data = json.load(f)
+            logger.info(f"Successfully loaded data from {filename}")
+            return data
+        except json.JSONDecodeError as e:
+            logger.error(f"Invalid JSON in {filename}: {e}")
+            return None
+        except Exception as e:
+            logger.error(f"Error reading {filename}: {e}")
+            return None

generate_service.py ADDED Viewed

	@@ -0,0 +1,203 @@

+import os
+import logging
+import json
+from openai import OpenAI
+from dotenv import load_dotenv
+from data_service import DataService
+# Load environment variables from .env file
+load_dotenv(override=True)
+# Configure logging
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s'
+)
+logger = logging.getLogger(__name__)
+class OpenAIService:
+    def __init__(self, api_key=None, assistant_id=None, data_dir="data"):
+        """
+        Initialize OpenAI service with Assistant API.
+        Args:
+            api_key: OpenAI API key (defaults to OPENAI_API_KEY env var)
+            assistant_id: OpenAI Assistant ID (defaults to ASSISTANT_ID env var)
+            data_dir: Path to data directory for DataService (default: "data")
+        """
+        logger.info("Initializing OpenAI service...")
+        self.api_key = api_key or os.getenv("OPENAI_API_KEY")
+        self.assistant_id = assistant_id or os.getenv("ASSISTANT_ID")
+        if not self.api_key:
+            logger.error("OpenAI API key not found in environment variables")
+            raise ValueError("OpenAI API key is required. Set OPENAI_API_KEY environment variable.")
+        if not self.assistant_id:
+            logger.error("Assistant ID not found in environment variables")
+            raise ValueError("Assistant ID is required. Set ASSISTANT_ID environment variable.")
+        logger.info(f"API key loaded (length: {len(self.api_key)})")
+        logger.info(f"Assistant ID: {self.assistant_id}")
+        self.client = OpenAI(api_key=self.api_key)
+        self.thread = None
+        self.data_service = DataService(data_dir)
+        logger.info("OpenAI service initialized successfully")
+    def create_thread(self):
+        """Create a new conversation thread."""
+        logger.info("Creating new conversation thread...")
+        self.thread = self.client.beta.threads.create()
+        logger.info(f"Thread created successfully: {self.thread.id}")
+        return self.thread.id
+    def get_or_create_thread(self):
+        """Get existing thread or create a new one."""
+        if not self.thread:
+            logger.info("No existing thread found, creating new thread")
+            self.create_thread()
+        else:
+            logger.info(f"Using existing thread: {self.thread.id}")
+        return self.thread.id
+    def execute_tool_call(self, tool_name, tool_arguments):
+        """
+        Execute a tool call and return the result.
+        Args:
+            tool_name: Name of the tool to execute
+            tool_arguments: Dictionary of arguments for the tool
+        Returns:
+            str: JSON string with the tool execution result in format { success: bool, result/error: data }
+        """
+        logger.info(f"Executing tool: {tool_name} with arguments: {tool_arguments}")
+        try:
+            if tool_name == "get_real_time_commissions":
+                result = self.data_service.get_data("GetRealTimeCommissions.json")
+                if result is None:
+                    return json.dumps({"success": False, "error": f"Failed to load data from GetRealTimeCommissions.json"})
+                return json.dumps({"success": True, "result": result})
+            elif tool_name == "get_volumes":
+                result = self.data_service.get_data("GetVolumes.json")
+                if result is None:
+                    return json.dumps({"success": False, "error": f"Failed to load data from GetVolumes.json"})
+                return json.dumps({"success": True, "result": result})
+            elif tool_name == "get_customers":
+                result = self.data_service.get_data("GetCustomers.json")
+                if result is None:
+                    return json.dumps({"success": False, "error": f"Failed to load data from GetCustomers.json"})
+                return json.dumps({"success": True, "result": result})
+            else:
+                logger.warning(f"Unknown tool: {tool_name}")
+                return json.dumps({"success": False, "error": f"Unknown tool: {tool_name}"})
+        except Exception as e:
+            logger.error(f"Error executing tool {tool_name}: {str(e)}", exc_info=True)
+            return json.dumps({"success": False, "error": str(e)})
+    def generate_stream(self, message):
+        """
+        Generate response from assistant with streaming and tool handling.
+        Args:
+            message: User's message string
+        Yields:
+            str: Chunks of the response as they arrive
+        """
+        try:
+            logger.info(f"Processing message: {message[:50]}...")
+            thread_id = self.get_or_create_thread()
+            # Add user message to thread
+            logger.info(f"Adding message to thread {thread_id}")
+            self.client.beta.threads.messages.create(
+                thread_id=thread_id,
+                role="user",
+                content=message
+            )
+            logger.info("Message added successfully")
+            # Stream the assistant's response
+            logger.info("Starting assistant response stream...")
+            chunk_count = 0
+            skipped_annotations = 0
+            with self.client.beta.threads.runs.stream(
+                thread_id=thread_id,
+                assistant_id=self.assistant_id
+            ) as stream:
+                for event in stream:
+                    # Handle text streaming
+                    if event.event == "thread.message.delta":
+                        for content in event.data.delta.content:
+                            if hasattr(content, 'text') and hasattr(content.text, 'value'):
+                                if hasattr(content.text, 'annotations') and content.text.annotations:
+                                    skipped_annotations += 1
+                                    continue
+                                chunk_count += 1
+                                yield content.text.value
+                    # Handle tool calls
+                    elif event.event == "thread.run.requires_action":
+                        logger.info("Assistant requires action (tool calls)")
+                        run_id = event.data.id
+                        tool_calls = event.data.required_action.submit_tool_outputs.tool_calls
+                        tool_outputs = []
+                        for tool_call in tool_calls:
+                            logger.info(f"Processing tool call: {tool_call.function.name}")
+                            tool_arguments = json.loads(tool_call.function.arguments)
+                            tool_output = self.execute_tool_call(
+                                tool_call.function.name,
+                                tool_arguments
+                            )
+                            tool_outputs.append({
+                                "tool_call_id": tool_call.id,
+                                "output": tool_output
+                            })
+                        # Submit tool outputs and continue streaming
+                        logger.info(f"Submitting {len(tool_outputs)} tool outputs")
+                        with self.client.beta.threads.runs.submit_tool_outputs_stream(
+                            thread_id=thread_id,
+                            run_id=run_id,
+                            tool_outputs=tool_outputs
+                        ) as tool_stream:
+                            for tool_event in tool_stream:
+                                if tool_event.event == "thread.message.delta":
+                                    for content in tool_event.data.delta.content:
+                                        if hasattr(content, 'text') and hasattr(content.text, 'value'):
+                                            if hasattr(content.text, 'annotations') and content.text.annotations:
+                                                skipped_annotations += 1
+                                                continue
+                                            chunk_count += 1
+                                            yield content.text.value
+            logger.info(f"Stream completed. Chunks received: {chunk_count}, Annotations skipped: {skipped_annotations}")
+        except Exception as e:
+            logger.error(f"Error in generate_stream: {str(e)}", exc_info=True)
+            yield f"Error: {str(e)}"
+    def clear_thread(self):
+        """Clear the current thread by creating a new one."""
+        if self.thread:
+            logger.info(f"Clearing thread: {self.thread.id}")
+        else:
+            logger.info("No active thread to clear")
+        self.thread = None
+        logger.info("Thread cleared. New thread will be created on next message")

interface.py ADDED Viewed

	@@ -0,0 +1,121 @@

+import gradio as gr
+from generate_service import OpenAIService
+# Initialize OpenAI service
+openai_service = OpenAIService()
+def respond(message, history):
+    """
+    Process user message and stream the response from OpenAI Assistant.
+    Args:
+        message: User's input message
+        history: Chat history as list of tuples
+    Yields:
+        Updated history with streaming response
+    """
+    if not message.strip():
+        return
+    # Add user message to history with loading indicator
+    history.append((message, '<span class="loading-dots">🤔 Thinking<span style="animation: blink 1.4s infinite; animation-delay: 0s;">.</span><span style="animation: blink 1.4s infinite; animation-delay: 0.2s;">.</span><span style="animation: blink 1.4s infinite; animation-delay: 0.4s;">.</span></span>'))
+    yield history, ""
+    # Stream the assistant's response
+    response_text = ""
+    first_chunk = True
+    for chunk in openai_service.generate_stream(message):
+        response_text += chunk
+        # Replace loading message with actual response
+        history[-1] = (message, response_text)
+        yield history, ""
+        first_chunk = False
+def clear_chat():
+    """Clear the chat history and create a new thread."""
+    openai_service.clear_thread()
+    return []
+with gr.Blocks(css="""
+    #chatbot-container {
+        height: calc(100vh - 200px) !important;
+        min-height: 600px;
+    }
+    #input-row {
+        position: sticky;
+        bottom: 0;
+        background: white;
+        padding: 10px 0;
+    }
+    .contain {
+        max-width: 100% !important;
+        padding: 0 !important;
+    }
+    #clear-btn {
+        position: absolute;
+        right: 10px;
+        top: 10px;
+        z-index: 100;
+    }
+    @keyframes blink {
+        0%, 100% { opacity: 1; }
+        50% { opacity: 0.3; }
+    }
+    .message.bot:has(.loading-dots) {
+        animation: pulse 1.5s ease-in-out infinite;
+    }
+    @keyframes pulse {
+        0%, 100% { opacity: 1; }
+        50% { opacity: 0.6; }
+    }
+""") as demo:
+    with gr.Row():
+        gr.Markdown("# Chat Interface")
+        clear_button = gr.Button("Clear", elem_id="clear-btn", size="sm")
+    chatbot = gr.Chatbot(
+        value=[],
+        elem_id="chatbot-container",
+        height="calc(100vh - 200px)",
+        show_label=False,
+        sanitize_html=False,
+    )
+    with gr.Row(elem_id="input-row"):
+        with gr.Column(scale=9):
+            msg_input = gr.Textbox(
+                placeholder="Type your message here...",
+                show_label=False,
+                container=False
+            )
+        with gr.Column(scale=1, min_width=100):
+            send_button = gr.Button("Send", variant="primary")
+    # Event handlers
+    msg_input.submit(
+        respond,
+        inputs=[msg_input, chatbot],
+        outputs=[chatbot, msg_input]
+    )
+    send_button.click(
+        respond,
+        inputs=[msg_input, chatbot],
+        outputs=[chatbot, msg_input]
+    )
+    clear_button.click(
+        clear_chat,
+        inputs=None,
+        outputs=chatbot
+    )
+if __name__ == "__main__":
+    demo.launch(inbrowser=True)

requirements.txt ADDED Viewed

Binary file (2.47 kB). View file