Method HandleRegisterForEvent

Core/KernelSML/src/sml_KernelSMLHandlers.cpp:154–339

Handle registering and unregistering for kernel events

// Handle registering and unregistering for kernel events
bool KernelSML::HandleRegisterForEvent(AgentSML* pAgentSML, char const* pCommandName, Connection* pConnection, AnalyzeXML* pIncoming, soarxml::ElementXML* pResponse)
{
    // Decide if registering or unregistering
    bool registerForEvent = (strcmp(pCommandName, sml_Names::kCommand_RegisterForEvent) == 0) ;
    
    // Get the parameters
    char const* pEventName = pIncoming->GetArgString(sml_Names::kParamEventID) ;
    
    if (!pEventName)
    {
        return InvalidArg(pConnection, pResponse, pCommandName, "Event id is missing") ;
    }
    
    // Convert from the event name to the id value
    int id = ConvertStringToEvent(pEventName) ;
    
    // Decide what type of event this is and where to register/unregister it
    if (IsSystemEventID(id))
    {
        // System Events
        if (registerForEvent)
        {
            this->AddSystemListener(static_cast<smlSystemEventId>(id), pConnection) ;
        }
        else
        {
            this->RemoveSystemListener(static_cast<smlSystemEventId>(id), pConnection) ;
        }
        
    }
    else if (IsAgentEventID(id))
    {
    
        // Agent events
        if (registerForEvent)
        {
            this->AddAgentListener(static_cast<smlAgentEventId>(id), pConnection) ;
        }
        else
        {
            this->RemoveAgentListener(static_cast<smlAgentEventId>(id), pConnection) ;
        }
    }
    else if (IsRhsEventID(id))
    {
    
        // Rhs user functions
        char const* pRhsFunctionName = pIncoming->GetArgString(sml_Names::kParamName) ;
        
        if (!pRhsFunctionName)
        {
            return InvalidArg(pConnection, pResponse, pCommandName, "Registering for rhs user function, but no function name was provided") ;
        }
        
        if (registerForEvent)
        {
            this->AddRhsListener(pRhsFunctionName, pConnection) ;
        }