File content as of revision 76:b375b3d750d8:

#include "ModJsonRpc.h"
#include "../net/httpd/mod/NyLPC_cModWebSocket_protected.h"
#include "HttpdConnection.h"

namespace MiMic
{
    #define NUM_OF_OBJECTS 32
    ModJsonRpc::BasicRpcObject** newObjectArray()
    {
        ModJsonRpc::BasicRpcObject** r=new ModJsonRpc::BasicRpcObject*[NUM_OF_OBJECTS];
        memset(r,0,sizeof(ModJsonRpc::BasicRpcObject*)*NUM_OF_OBJECTS);
        return r;
    }
    void deleteObjectArray(ModJsonRpc::BasicRpcObject** v)
    {
        for(int i=0;i<NUM_OF_OBJECTS;i++){
            if(v[i]!=NULL){
                delete v[i];
            }
        }
        delete[] v;
    }    
    
    ModJsonRpc::ModJsonRpc(const char* i_path,const struct NyLPC_TJsonRpcClassDef** i_rpc_table):ModBaseClass(i_path)
    {
        this->_mod=NULL;
        this->_rpc_table=i_rpc_table;
    }
    ModJsonRpc::ModJsonRpc()
    {
        this->_mod=NULL;
    }
    ModJsonRpc::~ModJsonRpc()
    {
        if(this->_mod!=NULL){
            NyLPC_cModJsonRpc_finalize(this->_mod);
            free(this->_mod);
            deleteObjectArray(this->_objects);
            this->_mod=NULL;
        }
    }
    void ModJsonRpc::setParam(const char* i_path,const struct NyLPC_TJsonRpcClassDef** i_rpc_table)
    {
        ModBaseClass::setParam(i_path);
        this->_rpc_table=i_rpc_table;
    }

    bool ModJsonRpc::execute(HttpdConnection& i_connection)
    {
        if(this->_mod!=NULL){
            return false;
        }
        this->_mod=(NyLPC_TcModJsonRpc_t*)malloc(sizeof(NyLPC_TcModJsonRpc_t));
        if(this->_mod==NULL){
            return false;
        }
        
        //initialize websocket
        NyLPC_cModJsonRpc_initialize(this->_mod,this->_path,this->_rpc_table);        
        if(NyLPC_cModJsonRpc_canHandle(this->_mod,i_connection._ref_inst)){
            if(NyLPC_cModJsonRpc_execute(this->_mod,i_connection._ref_inst)){
                //initialize object array
                this->_objects=newObjectArray();
                return true;
            }
        }
        NyLPC_cModJsonRpc_finalize(this->_mod);
        free(this->_mod);
        this->_mod=NULL;
        return false;
    }

    void ModJsonRpc::dispatchRpc()
    {
        const union NyLPC_TJsonRpcParserResult* rpc_result;
        if(this->_mod==NULL){
            return;
        }        
        for(;;){
            if(!NyLPC_cModJsonRpc_processRpcMessage(this->_mod)){
                break;
            }
            //メッセージ取得を試行
            rpc_result=NyLPC_cModJsonRpc_getMessage(this->_mod);
            if(rpc_result==NULL){
                //nothing
                continue;
            }
            if(NyLPC_TJsonRpcParserResult_hasMethodHandler(rpc_result)){
                if(NyLPC_TJsonRpcParserResult_callMethodHandler(rpc_result,this)){
                    continue;
                }else{
                    //function failed.
                    break;
                }
            }else{
                //no handler
                break;
            }
        }
        NyLPC_cModJsonRpc_close(this->_mod,1000);
        NyLPC_cModJsonRpc_finalize(this->_mod);
        deleteObjectArray(this->_objects);
        free(this->_mod);
        this->_mod=NULL;
        return;
    }
    bool ModJsonRpc::putResult(unsigned int i_id,const char* i_params_fmt,...)
    {
        bool ret;
        va_list a;
        va_start(a,i_params_fmt);
        ret=NyLPC_cModJsonRpc_putResultV(this->_mod,i_id,i_params_fmt,a)?true:false;
        va_end(a);
        return ret;
    }
    bool ModJsonRpc::putError(unsigned int i_id,int i_code)
    {
        return NyLPC_cModJsonRpc_putError(this->_mod,i_id,i_code)?true:false;
    }
    
    int ModJsonRpc::addObject(BasicRpcObject* i_object)
    {
        for(int i=0;i<NUM_OF_OBJECTS;i++){
            if(this->_objects[i]==NULL){
                this->_objects[i]=i_object;
                return i;
            }
        }
        return -1;
    }
    void* ModJsonRpc::getObject(int i_oid)
    {
        return this->_objects[i_oid]->obj;
    }

}