models.py

from typing import Any, Optional, List
from datetime import datetime, timezone
from pydantic import BaseModel, Field


# ---------- CloudEvent ----------
class CloudEvent(BaseModel):
    specversion: str = "1.0"
    id: str
    type: str
    source: str
    time: datetime
    datacontenttype: str = "application/json"
    data: Optional[Any] = None

    @staticmethod
    def now_iso() -> datetime:
        return datetime.now(timezone.utc)

    @classmethod
    def wrap(cls, *, event_id: str, event_type: str, source: str, data: Any) -> "CloudEvent":
        return cls(
            id=event_id,
            type=event_type or ("NullOrEmpty" if data is None else type(data).__name__),
            source=source,
            time=cls.now_iso(),
            data=data,
        )


from typing import Any, Dict, Optional, List
from datetime import datetime, timezone
from pydantic import BaseModel, Field, ConfigDict  # <-- add ConfigDict

# ... keep CloudEvent as you had it ...

# ---------- Permissive ancillary types ----------
class FunctionState(BaseModel):
    IsFunctionCall: bool = False
    IsFunctionCallResponse: bool = False
    IsFunctionCallError: bool = False
    IsFunctionCallStatus: bool = False
    IsFunctionStillRunning: bool = False

    def set_tuple(self, call: bool, resp: bool, err: bool, status: bool, running: bool):
        self.IsFunctionCall = call
        self.IsFunctionCallResponse = resp
        self.IsFunctionCallError = err
        self.IsFunctionCallStatus = status
        self.IsFunctionStillRunning = running

class FunctionCallData(BaseModel):
    # Accept any extra keys (v2 style)
    model_config = ConfigDict(extra="allow")

class UserInfo(BaseModel):
    # Accept any extra keys (v2 style)
    model_config = ConfigDict(extra="allow")


# ---------- LLMServiceObj (field names match C# exactly) ----------
class LLMServiceObj(BaseModel):
    # strings
    SessionId: str = ""
    JsonFunction: str = ""
    LlmMessage: str = ""
    ResultMessage: str = ""
    UserInput: str = ""
    RequestSessionId: str = ""
    FunctionName: str = ""
    TimeZone: str = ""
    LLMRunnerType: str = "TurboLLM"
    SourceLlm: str = ""
    DestinationLlm: str = ""
    MessageID: str = ""
    LlmSessionStartName: str = ""
    SwapFunctionName: str = ""
    ChatAgentLocation: str = ""
    ToolsDefinitionId: Optional[str] = None
    JsonToolsBuilderSpec: Optional[str] = None

    # ints / bools
    TokensUsed: int = 0
    IsUserLoggedIn: bool = False
    IsFuncAck: bool = False
    IsProcessed: bool = False
    IsSystemLlm: bool = False
    Timeout: Optional[int] = None

    # complex
    FunctionCallId: str = ""
    FunctionCallData: FunctionCallData = Field(default_factory=FunctionCallData)
    UserInfo: UserInfo = Field(default_factory=UserInfo)
    StartTimeUTC: datetime = Field(default_factory=lambda: datetime.now(timezone.utc))

    # stacks (serialize as arrays; C# Stack<T> will read fine)
    LlmStack: List[str] = Field(default_factory=list)
    FunctionCallIdStack: List[str] = Field(default_factory=list)
    FunctionNameStack: List[str] = Field(default_factory=list)
    IsProcessedStack: List[bool] = Field(default_factory=list)
    MessageIDStack: List[str] = Field(default_factory=list)

    # function state (maps to your FunctionState object)
    # Your C# stores this in a private field + setters; we expose the same booleans as a nested object.
    IsFunctionCall: bool = False
    IsFunctionCallResponse: bool = False
    IsFunctionCallError: bool = False
    IsFunctionCallStatus: bool = False
    IsFunctionStillRunning: bool = False

    # Convenience helpers (optional)
    def push_llm(self, llm_name: str, new_call_id: str, new_func_name: str, new_message_id: str, new_is_processed: bool):
        if self.SourceLlm:
            self.LlmStack.append(self.SourceLlm)
        self.SourceLlm = self.DestinationLlm
        self.DestinationLlm = llm_name

        if self.MessageID:
            self.MessageIDStack.append(self.MessageID)
        self.MessageID = new_message_id

        if self.FunctionCallId:
            self.FunctionCallIdStack.append(self.FunctionCallId)
        self.FunctionCallId = new_call_id

        if self.FunctionName:
            self.FunctionNameStack.append(self.FunctionName)
        self.FunctionName = new_func_name

        self.IsProcessedStack.append(self.IsProcessed)
        self.IsProcessed = new_is_processed

    def pop_llm(self):
        if self.LlmStack:
            self.SourceLlm = self.LlmStack.pop()
        self.DestinationLlm = self.SourceLlm

        if self.MessageIDStack:
            self.MessageID = self.MessageIDStack.pop()
        if self.FunctionCallIdStack:
            self.FunctionCallId = self.FunctionCallIdStack.pop()
        if self.FunctionNameStack:
            self.FunctionName = self.FunctionNameStack.pop()
        if self.IsProcessedStack:
            self.IsProcessed = self.IsProcessedStack.pop()


# ---------- ResultObj ----------
class ResultObj(BaseModel):
    Message: str = ""
    Success: bool = False
    Data: Optional[Any] = None