cwUI.h/cpp, cwUiTest.cpp : Separated the UI component into three parts ui, ws, srv.
This commit is contained in:
kevin.larke
parent
38aab880a0
commit
c6ccaefcdb
618
cwUi.cpp
618
cwUi.cpp
@ -33,12 +33,13 @@ namespace cw
|
||||
|
||||
typedef struct ui_str
|
||||
{
|
||||
websockSrv::handle_t wssH; // websock server handle
|
||||
unsigned eleAllocN; // size of eleA[]
|
||||
unsigned eleN; // count of ele's in use
|
||||
ele_t** eleA; // eleA[ eleAllocN ]
|
||||
uiCallback_t cbFunc; // app. cb func
|
||||
void* cbArg; // app. cb func arg.
|
||||
uiCallback_t uiCbFunc; // app. cb func
|
||||
void* uiCbArg; // app. cb func arg.
|
||||
sendCallback_t sendCbFunc;
|
||||
void* sendCbArg;
|
||||
appIdMapRecd_t* appIdMap; // map of application parent/child/js id's
|
||||
char* buf; // buf[bufN] output message formatting buffer
|
||||
unsigned bufN; //
|
||||
@ -60,10 +61,6 @@ namespace cw
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
|
||||
if( p->wssH.isValid() )
|
||||
if((rc = websockSrv::destroy(p->wssH)) != kOkRC )
|
||||
return rc;
|
||||
|
||||
for(unsigned i=0; i<p->eleN; ++i)
|
||||
{
|
||||
mem::release(p->eleA[i]->eleName);
|
||||
@ -230,7 +227,16 @@ namespace cw
|
||||
|
||||
rc_t _websockSend( ui_t* p, unsigned wsSessId, const char* msg )
|
||||
{
|
||||
return websock::send( websockSrv::websockHandle( p->wssH ), kUiProtocolId, wsSessId, msg, strlen(msg) );
|
||||
rc_t rc = kOkRC;
|
||||
|
||||
//return websock::send( websockSrv::websockHandle( p->wssH ), kUiProtocolId, wsSessId, msg, strlen(msg) );
|
||||
if( p->sendCbFunc != nullptr )
|
||||
{
|
||||
unsigned msgByteN = msg==nullptr ? 0 : strlen(msg);
|
||||
return p->sendCbFunc( p->sendCbArg, wsSessId, msg, msgByteN );
|
||||
}
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
|
||||
@ -475,7 +481,7 @@ namespace cw
|
||||
}
|
||||
|
||||
|
||||
|
||||
// value message format: 'value' <uuid> <value_data_type> ':' <value>
|
||||
ele_t* _parse_value_msg( ui_t* p, value_t& valueRef, const char* msg )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
@ -553,90 +559,6 @@ namespace cw
|
||||
return ele;
|
||||
}
|
||||
|
||||
rc_t _send_app_id_msg( ui_t* p, unsigned wsSessId, ele_t* ele )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
|
||||
unsigned i = snprintf(p->buf,p->bufN,"{ \"op\":\"set_app_id\", \"parentUuId\":%i, \"eleName\":\"%s\", \"appId\":%i, \"uuId\":%i }", ele->parent->uuId, ele->eleName, ele->parent->appId, ele->appId );
|
||||
|
||||
if( i >= p->bufN )
|
||||
return cwLogError(kBufTooSmallRC,"The 'app_id' msg formatting buffer is too small (%i bytes).", p->bufN);
|
||||
|
||||
if((rc = _websockSend( p, wsSessId, p->buf )) != kOkRC )
|
||||
return cwLogError(rc,"'app_id' msg transmission failed.");
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
ele_t* _handle_register_msg( ui_t* p, unsigned wsSessId, const char* msg )
|
||||
{
|
||||
printf("%s\n",msg);
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
ele_t* _handle_register_msg0( ui_t* p, unsigned wsSessId, const char* msg )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
unsigned parentUuId = kInvalidId;
|
||||
ele_t* parentEle = nullptr;
|
||||
ele_t* ele = nullptr;
|
||||
|
||||
const char* s0 = nextNonWhiteChar(msg + strlen("register"));
|
||||
|
||||
const char* eleName = nextNonWhiteChar(nextWhiteChar(s0));
|
||||
|
||||
// verifity the message tokens
|
||||
if( s0 == nullptr || eleName == nullptr )
|
||||
{
|
||||
cwLogError(kSyntaxErrorRC, "'register' msg format error: '%s' is not a valid message.", cwStringNullGuard(msg) );
|
||||
goto errLabel;
|
||||
}
|
||||
|
||||
// verify the parentUuId parsing
|
||||
if((rc = string_to_number<unsigned>(s0,parentUuId)) != kOkRC )
|
||||
{
|
||||
cwLogError(kSyntaxErrorRC, "'register' msg parentUuId format error: '%s' does not contain a valid parentUuId.", cwStringNullGuard(msg) );
|
||||
goto errLabel;
|
||||
}
|
||||
|
||||
// get the parent ele
|
||||
if((parentEle = _uuIdToEle( p, parentUuId)) == nullptr )
|
||||
{
|
||||
cwLogError(kInvalidIdRC,"UI register msg parent element not found.");
|
||||
goto errLabel;
|
||||
}
|
||||
|
||||
// if the child element does not already exist
|
||||
if(( ele = _parentUuId_EleName_ToEle( p, parentUuId, eleName, false )) == nullptr )
|
||||
{
|
||||
// look up the parent/eleName pair map
|
||||
appIdMapRecd_t* m = _findAppIdMap( p, parentEle->appId, eleName );
|
||||
|
||||
// create the ele
|
||||
ele = _createEle( p, parentEle, m==nullptr ? kInvalidId : m->appId, eleName );
|
||||
|
||||
printf("creating: parent uuid:%i js:%s \n", parentUuId,eleName);
|
||||
|
||||
// notify the app of the new ele's uuid and appId
|
||||
if( m != nullptr )
|
||||
_send_app_id_msg( p, wsSessId, ele );
|
||||
|
||||
}
|
||||
else
|
||||
{
|
||||
printf("parent uuid:%i js:%s already exists.\n", parentUuId,eleName);
|
||||
}
|
||||
|
||||
if( ele != nullptr )
|
||||
_send_app_id_msg( p, wsSessId, ele );
|
||||
|
||||
return ele;
|
||||
|
||||
errLabel:
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
|
||||
opId_t _labelToOpId( const char* label )
|
||||
{
|
||||
typedef struct
|
||||
@ -650,9 +572,7 @@ namespace cw
|
||||
{ kConnectOpId, "connect" },
|
||||
{ kInitOpId, "init" },
|
||||
{ kValueOpId, "value" },
|
||||
{ kRegisterOpId, "register" },
|
||||
{ kDisconnectOpId, "disconnect" },
|
||||
{ kEndAppIdUpdateOpId, "end_app_id_update" },
|
||||
{ kInvalidOpId, "<invalid>" },
|
||||
};
|
||||
|
||||
@ -661,129 +581,40 @@ namespace cw
|
||||
return mapA[i].id;
|
||||
|
||||
return kInvalidOpId;
|
||||
|
||||
|
||||
}
|
||||
|
||||
void _websockCb( void* cbArg, unsigned protocolId, unsigned wsSessId, websock::msgTypeId_t msg_type, const void* msg, unsigned byteN )
|
||||
{
|
||||
ui_t* p = (ui_t*)cbArg;
|
||||
opId_t opId = kInvalidOpId;
|
||||
value_t value;
|
||||
|
||||
switch( msg_type )
|
||||
{
|
||||
case websock::kConnectTId:
|
||||
opId = kConnectOpId;
|
||||
break;
|
||||
|
||||
case websock::kDisconnectTId:
|
||||
opId = kDisconnectOpId;
|
||||
break;
|
||||
|
||||
case websock::kMessageTId:
|
||||
{
|
||||
ele_t* ele;
|
||||
|
||||
opId = _labelToOpId((const char*)msg);
|
||||
|
||||
switch( opId )
|
||||
{
|
||||
case kInitOpId:
|
||||
// Pass on the 'init' msg to the app.
|
||||
p->cbFunc( p->cbArg, wsSessId, opId, kInvalidId, kInvalidId, kInvalidId, nullptr );
|
||||
|
||||
break;
|
||||
|
||||
case kValueOpId:
|
||||
if((ele = _parse_value_msg(p, value, (const char*)msg )) == nullptr )
|
||||
cwLogError(kOpFailRC,"UI Value message parse failed.");
|
||||
else
|
||||
{
|
||||
unsigned parentEleAppId = ele->parent == nullptr ? kInvalidId : ele->parent->appId;
|
||||
|
||||
p->cbFunc( p->cbArg, wsSessId, opId, parentEleAppId, ele->uuId, ele->appId, &value );
|
||||
|
||||
}
|
||||
break;
|
||||
|
||||
|
||||
case kRegisterOpId:
|
||||
_handle_register_msg(p, wsSessId, (const char*)msg );
|
||||
break;
|
||||
|
||||
case kEndAppIdUpdateOpId:
|
||||
_print_eles( p );
|
||||
cwLogInfo("App Id Update Complete.");
|
||||
break;
|
||||
|
||||
|
||||
case kInvalidOpId:
|
||||
cwLogError(kInvalidIdRC,"The UI received a NULL op. id.");
|
||||
break;
|
||||
|
||||
default:
|
||||
cwLogError(kInvalidIdRC,"The UI received an unknown op. id.");
|
||||
break;
|
||||
|
||||
} // switch opId
|
||||
|
||||
} // kMessageTId
|
||||
break;
|
||||
|
||||
default:
|
||||
cwLogError(kInvalidOpRC,"Unknown websock message type:%i.", msg_type );
|
||||
return;
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::createUi(
|
||||
cw::rc_t cw::ui::create(
|
||||
handle_t& h,
|
||||
unsigned port,
|
||||
uiCallback_t cbFunc,
|
||||
void* cbArg,
|
||||
const char* physRootDir,
|
||||
const char* dfltPageFn,
|
||||
unsigned websockTimeOutMs,
|
||||
unsigned rcvBufByteN,
|
||||
unsigned xmtBufByteN,
|
||||
sendCallback_t sendCbFunc,
|
||||
void* sendCbArg,
|
||||
uiCallback_t uiCbFunc,
|
||||
void* uiCbArg,
|
||||
unsigned fmtBufByteN )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
ele_t* ele;
|
||||
|
||||
websock::protocol_t protocolA[] =
|
||||
{
|
||||
{ "http", kHttpProtocolId, 0, 0 },
|
||||
{ "ui_protocol", kUiProtocolId, rcvBufByteN, xmtBufByteN }
|
||||
};
|
||||
|
||||
unsigned protocolN = sizeof(protocolA)/sizeof(protocolA[0]);
|
||||
|
||||
if((rc = destroyUi(h)) != kOkRC )
|
||||
if((rc = destroy(h)) != kOkRC )
|
||||
return rc;
|
||||
|
||||
if( cbFunc == nullptr )
|
||||
if( sendCbFunc == nullptr )
|
||||
return cwLogError(kInvalidArgRC,"The UI send callback function must be a valid pointer.");
|
||||
|
||||
if( uiCbFunc == nullptr )
|
||||
return cwLogError(kInvalidArgRC,"The UI callback function must be a valid pointer.");
|
||||
|
||||
ui_t* p = mem::allocZ<ui_t>();
|
||||
|
||||
if((rc = websockSrv::create(p->wssH, _websockCb, p, physRootDir, dfltPageFn, port, protocolA, protocolN, websockTimeOutMs )) != kOkRC )
|
||||
{
|
||||
cwLogError(rc,"Internal websock server creation failed.");
|
||||
goto errLabel;
|
||||
}
|
||||
|
||||
p->eleAllocN = 100;
|
||||
p->eleA = mem::allocZ<ele_t*>( p->eleAllocN );
|
||||
p->eleN = 0;
|
||||
p->cbFunc = cbFunc;
|
||||
p->cbArg = cbArg;
|
||||
p->uiCbFunc = uiCbFunc;
|
||||
p->uiCbArg = uiCbArg;
|
||||
p->sendCbFunc = sendCbFunc;
|
||||
p->sendCbArg = sendCbArg;
|
||||
p->buf = mem::allocZ<char>(fmtBufByteN);
|
||||
p->bufN = fmtBufByteN;
|
||||
|
||||
@ -806,29 +637,8 @@ cw::rc_t cw::ui::createUi(
|
||||
return rc;
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::start( handle_t h )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
ui_t* p = _handleToPtr(h);
|
||||
|
||||
if((rc = websockSrv::start(p->wssH)) != kOkRC )
|
||||
rc = cwLogError(rc,"Internal websock server start failed.");
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::stop( handle_t h )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
ui_t* p = _handleToPtr(h);
|
||||
|
||||
if((rc = websockSrv::pause(p->wssH)) != kOkRC )
|
||||
rc = cwLogError(rc,"Internal websock server stop failed.");
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::destroyUi( handle_t& h )
|
||||
cw::rc_t cw::ui::destroy( handle_t& h )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
if( !h.isValid() )
|
||||
@ -843,6 +653,58 @@ cw::rc_t cw::ui::destroyUi( handle_t& h )
|
||||
return rc;
|
||||
}
|
||||
|
||||
|
||||
cw::rc_t cw::ui::onConnect( handle_t h, unsigned wsSessId )
|
||||
{
|
||||
return kOkRC;
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::onDisconnect( handle_t h, unsigned wsSessId )
|
||||
{
|
||||
return kOkRC;
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::onReceive( handle_t h, unsigned wsSessId, const void* msg, unsigned msgByteN )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
ui_t* p = _handleToPtr(h);
|
||||
opId_t opId = _labelToOpId((const char*)msg);
|
||||
value_t value;
|
||||
ele_t* ele;
|
||||
|
||||
switch( opId )
|
||||
{
|
||||
case kInitOpId:
|
||||
// Pass on the 'init' msg to the app.
|
||||
p->uiCbFunc( p->uiCbArg, wsSessId, opId, kInvalidId, kInvalidId, kInvalidId, nullptr );
|
||||
|
||||
break;
|
||||
|
||||
case kValueOpId:
|
||||
if((ele = _parse_value_msg(p, value, (const char*)msg )) == nullptr )
|
||||
cwLogError(kOpFailRC,"UI Value message parse failed.");
|
||||
else
|
||||
{
|
||||
unsigned parentEleAppId = ele->parent == nullptr ? kInvalidId : ele->parent->appId;
|
||||
|
||||
p->uiCbFunc( p->uiCbArg, wsSessId, opId, parentEleAppId, ele->uuId, ele->appId, &value );
|
||||
|
||||
}
|
||||
break;
|
||||
|
||||
case kInvalidOpId:
|
||||
cwLogError(kInvalidIdRC,"The UI received a NULL op. id.");
|
||||
break;
|
||||
|
||||
default:
|
||||
cwLogError(kInvalidIdRC,"The UI received an unknown op. id.");
|
||||
break;
|
||||
|
||||
} // switch opId
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
unsigned cw::ui::findElementAppId( handle_t h, unsigned parentUuId, const char* eleName )
|
||||
{
|
||||
ui_t* p = _handleToPtr(h);
|
||||
@ -983,5 +845,321 @@ cw::rc_t cw::ui::registerAppIds( handle_t h, const appIdMap_t* map, unsigned ma
|
||||
|
||||
|
||||
|
||||
namespace cw
|
||||
{
|
||||
namespace ui
|
||||
{
|
||||
namespace ws
|
||||
{
|
||||
typedef struct ui_ws_str
|
||||
{
|
||||
websock::handle_t wsH;
|
||||
ui::handle_t uiH;
|
||||
void* cbArg;
|
||||
uiCallback_t uiCbFunc;
|
||||
websock::cbFunc_t wsCbFunc;
|
||||
unsigned wsTimeOutMs;
|
||||
} ui_ws_t;
|
||||
|
||||
ui_ws_t* _handleToPtr( handle_t h )
|
||||
{ return handleToPtr<handle_t,ui_ws_t>(h); }
|
||||
|
||||
rc_t _destroy( ui_ws_t* p )
|
||||
{
|
||||
rc_t rc;
|
||||
|
||||
if((rc = ui::destroy(p->uiH)) != kOkRC )
|
||||
return rc;
|
||||
|
||||
if((rc = websock::destroy(p->wsH)) != kOkRC )
|
||||
return rc;
|
||||
|
||||
mem::release(p);
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
void _webSockCb( void* cbArg, unsigned protocolId, unsigned sessionId, websock::msgTypeId_t msg_type, const void* msg, unsigned byteN )
|
||||
{
|
||||
ui_ws_t* p = static_cast<ui_ws_t*>(cbArg);
|
||||
|
||||
switch( msg_type )
|
||||
{
|
||||
case websock::kConnectTId:
|
||||
ui::onConnect(p->uiH,sessionId);
|
||||
break;
|
||||
|
||||
case websock::kDisconnectTId:
|
||||
ui::onDisconnect(p->uiH,sessionId);
|
||||
break;
|
||||
|
||||
case websock::kMessageTId:
|
||||
ui::onReceive(p->uiH,sessionId,msg,byteN);
|
||||
break;
|
||||
|
||||
default:
|
||||
cwLogError(kInvalidIdRC,"An invalid websock msgTypeId (%i) was encountered",msg_type);
|
||||
}
|
||||
}
|
||||
|
||||
rc_t _webSockSend( void* cbArg, unsigned wsSessId, const void* msg, unsigned msgByteN )
|
||||
{
|
||||
ui_ws_t* p = static_cast<ui_ws_t*>(cbArg);
|
||||
return websock::send( p->wsH, kUiProtocolId, wsSessId, msg, msgByteN );
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::ws::create( handle_t& h,
|
||||
unsigned port,
|
||||
const char* physRootDir,
|
||||
void* cbArg,
|
||||
uiCallback_t uiCbFunc,
|
||||
websock::cbFunc_t wsCbFunc,
|
||||
const char* dfltPageFn,
|
||||
unsigned websockTimeOutMs,
|
||||
unsigned rcvBufByteN,
|
||||
unsigned xmtBufByteN,
|
||||
unsigned fmtBufByteN )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
|
||||
if((rc = destroy(h)) != kOkRC )
|
||||
return rc;
|
||||
|
||||
ui_ws_t* p = mem::allocZ<ui_ws_t>();
|
||||
|
||||
websock::protocol_t protocolA[] =
|
||||
{
|
||||
{ "http", kHttpProtocolId, 0, 0 },
|
||||
{ "ui_protocol", kUiProtocolId, rcvBufByteN, xmtBufByteN }
|
||||
};
|
||||
|
||||
unsigned protocolN = sizeof(protocolA)/sizeof(protocolA[0]);
|
||||
websock::cbFunc_t wsCbF = wsCbFunc==nullptr ? _webSockCb : wsCbFunc;
|
||||
void* wsCbA = wsCbFunc==nullptr ? p : cbArg;
|
||||
|
||||
// create the websocket
|
||||
if((rc = websock::create(p->wsH, wsCbF, wsCbA, physRootDir, dfltPageFn, port, protocolA, protocolN )) != kOkRC )
|
||||
{
|
||||
cwLogError(rc,"UI Websock create failed.");
|
||||
goto errLabel;
|
||||
}
|
||||
|
||||
// create the ui
|
||||
if((rc = ui::create(p->uiH, _webSockSend, p, uiCbFunc, cbArg, fmtBufByteN )) != kOkRC )
|
||||
{
|
||||
cwLogError(rc,"UI object create failed.");
|
||||
goto errLabel;
|
||||
}
|
||||
|
||||
p->cbArg = cbArg;
|
||||
p->uiCbFunc = uiCbFunc;
|
||||
p->wsCbFunc = wsCbFunc;
|
||||
p->wsTimeOutMs = websockTimeOutMs;
|
||||
|
||||
h.set(p);
|
||||
|
||||
errLabel:
|
||||
if( rc != kOkRC )
|
||||
_destroy(p);
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::ws::destroy( handle_t& h )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
ui_ws_t* p = nullptr;
|
||||
|
||||
if( !h.isValid() )
|
||||
return rc;
|
||||
|
||||
p = _handleToPtr(h);
|
||||
|
||||
if((rc = _destroy(p)) != kOkRC )
|
||||
return rc;
|
||||
|
||||
h.clear();
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::ws::exec( handle_t h, unsigned timeOutMs )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
ui_ws_t* p = _handleToPtr(h);
|
||||
|
||||
if((rc = websock::exec( p->wsH, p->wsTimeOutMs )) != kOkRC)
|
||||
cwLogError(rc,"The UI websock execution failed.");
|
||||
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::ws::onReceive( handle_t h, unsigned protocolId, unsigned sessionId, websock::msgTypeId_t msg_type, const void* msg, unsigned byteN )
|
||||
{
|
||||
ui_ws_t* p = _handleToPtr(h);
|
||||
_webSockCb( p, protocolId, sessionId, msg_type, msg, byteN );
|
||||
return kOkRC;
|
||||
}
|
||||
|
||||
cw::websock::handle_t cw::ui::ws::websockHandle( handle_t h )
|
||||
{
|
||||
ui_ws_t* p = _handleToPtr(h);
|
||||
return p->wsH;
|
||||
}
|
||||
|
||||
cw::ui::handle_t cw::ui::ws::uiHandle( handle_t h )
|
||||
{
|
||||
ui_ws_t* p = _handleToPtr(h);
|
||||
return p->uiH;
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
namespace cw
|
||||
{
|
||||
namespace ui
|
||||
{
|
||||
namespace srv
|
||||
{
|
||||
typedef struct ui_ws_srv_str
|
||||
{
|
||||
ws::handle_t wsUiH;
|
||||
thread::handle_t thH;
|
||||
unsigned wsTimeOutMs;
|
||||
} ui_ws_srv_t;
|
||||
|
||||
ui_ws_srv_t* _handleToPtr(handle_t h )
|
||||
{ return handleToPtr<handle_t,ui_ws_srv_t>(h); }
|
||||
|
||||
rc_t _destroy( ui_ws_srv_t* p )
|
||||
{
|
||||
rc_t rc;
|
||||
if((rc = thread::destroy(p->thH)) != kOkRC )
|
||||
return rc;
|
||||
|
||||
if((rc = ws::destroy(p->wsUiH)) != kOkRC )
|
||||
return rc;
|
||||
|
||||
mem::release(p);
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
bool _threadCallback( void* arg )
|
||||
{
|
||||
ui_ws_srv_t* p = static_cast<ui_ws_srv_t*>(arg);
|
||||
rc_t rc;
|
||||
|
||||
if((rc = ws::exec(p->wsUiH,p->wsTimeOutMs)) != kOkRC )
|
||||
{
|
||||
cwLogError(rc,"Websocket UI exec failed.");
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::srv::create( handle_t& h,
|
||||
unsigned port,
|
||||
const char* physRootDir,
|
||||
void* cbArg,
|
||||
uiCallback_t uiCbFunc,
|
||||
websock::cbFunc_t wsCbFunc,
|
||||
const char* dfltPageFn,
|
||||
unsigned websockTimeOutMs,
|
||||
unsigned rcvBufByteN,
|
||||
unsigned xmtBufByteN,
|
||||
unsigned fmtBufByteN )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
if((rc = destroy(h)) != kOkRC )
|
||||
return rc;
|
||||
|
||||
ui_ws_srv_t* p = mem::allocZ<ui_ws_srv_t>();
|
||||
|
||||
if((rc = ws::create(p->wsUiH, port, physRootDir, cbArg, uiCbFunc, wsCbFunc, dfltPageFn, websockTimeOutMs, rcvBufByteN, xmtBufByteN, fmtBufByteN )) != kOkRC )
|
||||
{
|
||||
cwLogError(rc,"The websock UI creationg failed.");
|
||||
goto errLabel;
|
||||
}
|
||||
|
||||
if((rc = thread::create( p->thH, _threadCallback, p )) != kOkRC )
|
||||
{
|
||||
cwLogError(rc,"The websock UI server thread create failed.");
|
||||
goto errLabel;
|
||||
}
|
||||
|
||||
p->wsTimeOutMs = websockTimeOutMs;
|
||||
|
||||
h.set(p);
|
||||
|
||||
errLabel:
|
||||
if( rc != kOkRC )
|
||||
_destroy(p);
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::srv::destroy( handle_t& h )
|
||||
{
|
||||
rc_t rc = kOkRC;
|
||||
|
||||
if( !h.isValid() )
|
||||
return rc;
|
||||
|
||||
ui_ws_srv_t* p = _handleToPtr(h);
|
||||
|
||||
if((rc = _destroy(p)) != kOkRC )
|
||||
return rc;
|
||||
|
||||
h.clear();
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::srv::start( handle_t h )
|
||||
{
|
||||
ui_ws_srv_t* p = _handleToPtr(h);
|
||||
rc_t rc;
|
||||
|
||||
if((rc = thread::unpause(p->thH)) != kOkRC )
|
||||
cwLogError(rc,"WebockUI server thread start failed.");
|
||||
return rc;
|
||||
}
|
||||
|
||||
cw::rc_t cw::ui::srv::stop( handle_t h )
|
||||
{
|
||||
ui_ws_srv_t* p = _handleToPtr(h);
|
||||
rc_t rc;
|
||||
|
||||
if((rc = thread::pause(p->thH, thread::kPauseFl | thread::kWaitFl )) != kOkRC )
|
||||
cwLogError(rc,"WebockUI server thread stop failed.");
|
||||
|
||||
return rc;
|
||||
}
|
||||
|
||||
cw::thread::handle_t cw::ui::srv::threadHandle( handle_t h )
|
||||
{
|
||||
ui_ws_srv_t* p = _handleToPtr(h);
|
||||
return p->thH;
|
||||
}
|
||||
|
||||
cw::websock::handle_t cw::ui::srv::websockHandle( handle_t h )
|
||||
{
|
||||
ui_ws_srv_t* p = _handleToPtr(h);
|
||||
return ws::websockHandle(p->wsUiH);
|
||||
}
|
||||
|
||||
cw::ui::handle_t cw::ui::srv::uiHandle( handle_t h )
|
||||
{
|
||||
ui_ws_srv_t* p = _handleToPtr(h);
|
||||
return ws::uiHandle(p->wsUiH);
|
||||
}
|
||||
|
||||
90
cwUi.h
90
cwUi.h
@ -21,8 +21,6 @@ namespace cw
|
||||
kConnectOpId,
|
||||
kInitOpId,
|
||||
kValueOpId,
|
||||
kRegisterOpId,
|
||||
kEndAppIdUpdateOpId,
|
||||
kDisconnectOpId
|
||||
} opId_t;
|
||||
|
||||
@ -58,23 +56,21 @@ namespace cw
|
||||
} u;
|
||||
} value_t;
|
||||
|
||||
typedef rc_t (*uiCallback_t)( void* cbArg, unsigned websockSessionId, opId_t opId, unsigned parentAppId, unsigned uuId, unsigned appId, const value_t* value );
|
||||
typedef rc_t (*uiCallback_t)( void* cbArg, unsigned wsSessId, opId_t opId, unsigned parentAppId, unsigned uuId, unsigned appId, const value_t* value );
|
||||
typedef rc_t (*sendCallback_t)( void* cbArg, unsigned wsSessId, const void* msg, unsigned msgByteN );
|
||||
|
||||
rc_t createUi( handle_t& h,
|
||||
unsigned port,
|
||||
uiCallback_t cbFunc,
|
||||
void* cbArg,
|
||||
const char* physRootDir,
|
||||
const char* dfltPageFn = "index.html",
|
||||
unsigned websockTimeOutMs = 50,
|
||||
unsigned rcvBufByteN = 1024,
|
||||
unsigned xmtBufByteN = 1024,
|
||||
rc_t create( handle_t& h,
|
||||
sendCallback_t sendCbFunc,
|
||||
void* sendCbArg,
|
||||
uiCallback_t uiCbFunc,
|
||||
void* uiCbArg,
|
||||
unsigned fmtBufByteN = 4096 );
|
||||
|
||||
rc_t destroyUi( handle_t& h );
|
||||
rc_t destroy( handle_t& h );
|
||||
|
||||
rc_t start( handle_t h );
|
||||
rc_t stop( handle_t h );
|
||||
rc_t onConnect( handle_t h, unsigned wsSessId );
|
||||
rc_t onDisconnect( handle_t h, unsigned wsSessId );
|
||||
rc_t onReceive( handle_t h, unsigned wsSessId, const void* msg, unsigned byteN );
|
||||
|
||||
unsigned findElementAppId( handle_t h, unsigned parentUuId, const char* eleName );
|
||||
unsigned findElementUuId( handle_t h, unsigned parentUuId, const char* eleName );
|
||||
@ -107,7 +103,71 @@ namespace cw
|
||||
// Register parent/child/name app id's
|
||||
rc_t registerAppIds( handle_t h, const appIdMap_t* map, unsigned mapN );
|
||||
|
||||
|
||||
namespace ws
|
||||
{
|
||||
typedef handle<struct ui_ws_str> handle_t;
|
||||
|
||||
rc_t create( handle_t& h,
|
||||
unsigned port,
|
||||
const char* physRootDir,
|
||||
void* cbArg,
|
||||
uiCallback_t uiCbFunc,
|
||||
websock::cbFunc_t wsCbFunc = nullptr,
|
||||
const char* dfltPageFn = "index.html",
|
||||
unsigned websockTimeOutMs = 50,
|
||||
unsigned rcvBufByteN = 1024,
|
||||
unsigned xmtBufByteN = 1024,
|
||||
unsigned fmtBufByteN = 4096 );
|
||||
|
||||
rc_t destroy( handle_t& h );
|
||||
|
||||
// This function should be called periodically to send and receive
|
||||
// queued messages to and from the websocket.
|
||||
rc_t exec( handle_t h, unsigned timeOutMs );
|
||||
|
||||
// This function executes the internal default websock callback function.
|
||||
// It is useful if the user provides a custom websock callback function
|
||||
// and wants to fallback to the default websock->ui interaction.
|
||||
rc_t onReceive( handle_t h, unsigned protocolId, unsigned sessionId, websock::msgTypeId_t msg_type, const void* msg, unsigned byteN );
|
||||
|
||||
websock::handle_t websockHandle( handle_t h );
|
||||
ui::handle_t uiHandle( handle_t h );
|
||||
|
||||
}
|
||||
|
||||
namespace srv
|
||||
{
|
||||
|
||||
typedef handle<struct ui_ws_srv_str> handle_t;
|
||||
|
||||
rc_t create( handle_t& h,
|
||||
unsigned port,
|
||||
const char* physRootDir,
|
||||
void* cbArg,
|
||||
uiCallback_t uiCbFunc,
|
||||
websock::cbFunc_t wsCbFunc = nullptr,
|
||||
const char* dfltPageFn = "index.html",
|
||||
unsigned websockTimeOutMs = 50,
|
||||
unsigned rcvBufByteN = 1024,
|
||||
unsigned xmtBufByteN = 1024,
|
||||
unsigned fmtBufByteN = 4096 );
|
||||
|
||||
rc_t destroy( handle_t& h );
|
||||
|
||||
rc_t start( handle_t h );
|
||||
rc_t stop( handle_t h );
|
||||
|
||||
thread::handle_t threadHandle( handle_t h );
|
||||
websock::handle_t websockHandle( handle_t h );
|
||||
ui::handle_t uiHandle( handle_t h );
|
||||
|
||||
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
54
cwUiTest.cpp
54
cwUiTest.cpp
@ -2,6 +2,8 @@
|
||||
#include "cwLog.h"
|
||||
#include "cwCommonImpl.h"
|
||||
#include "cwMem.h"
|
||||
#include "cwThread.h"
|
||||
#include "cwWebSock.h"
|
||||
#include "cwUi.h"
|
||||
#include "cwUiTest.h"
|
||||
|
||||
@ -12,8 +14,9 @@ namespace cw
|
||||
{
|
||||
typedef struct ui_test_str
|
||||
{
|
||||
handle_t uiH;
|
||||
const char* uiCfgFn;
|
||||
srv::handle_t wsUiSrvH;
|
||||
|
||||
} ui_test_t;
|
||||
|
||||
enum
|
||||
@ -49,39 +52,42 @@ namespace cw
|
||||
{ ui::kPanelDivId, kPanelCheckId, "myCheck1Id" },
|
||||
};
|
||||
|
||||
registerAppIds(p->uiH, mapA, sizeof(mapA)/sizeof(mapA[0]));
|
||||
handle_t uiH = srv::uiHandle(p->wsUiSrvH);
|
||||
|
||||
if((rc = createDiv( p->uiH, divUuId, wsSessId, kInvalidId, "myDivId", kDivId, "divClass", "My Panel" )) != kOkRC )
|
||||
|
||||
registerAppIds(uiH, mapA, sizeof(mapA)/sizeof(mapA[0]));
|
||||
|
||||
if((rc = createDiv( uiH, divUuId, wsSessId, kInvalidId, "myDivId", kDivId, "divClass", "My Panel" )) != kOkRC )
|
||||
goto errLabel;
|
||||
|
||||
if((rc = createButton( p->uiH, uuid, wsSessId, divUuId, "myBtnId", kBtnId, "btnClass", "Push Me" )) != kOkRC )
|
||||
if((rc = createButton( uiH, uuid, wsSessId, divUuId, "myBtnId", kBtnId, "btnClass", "Push Me" )) != kOkRC )
|
||||
goto errLabel;
|
||||
|
||||
if((rc = createCheck( p->uiH, uuid, wsSessId, divUuId, "myCheckId", kCheckId, "checkClass", "Check Me", true )) != kOkRC )
|
||||
if((rc = createCheck( uiH, uuid, wsSessId, divUuId, "myCheckId", kCheckId, "checkClass", "Check Me", true )) != kOkRC )
|
||||
goto errLabel;
|
||||
|
||||
if((rc = createSelect( p->uiH, selUuId, wsSessId, divUuId, "mySelId", kSelectId, "selClass", "Select" )) != kOkRC )
|
||||
if((rc = createSelect( uiH, selUuId, wsSessId, divUuId, "mySelId", kSelectId, "selClass", "Select" )) != kOkRC )
|
||||
goto errLabel;
|
||||
|
||||
if((rc = createOption( p->uiH, uuid, wsSessId, selUuId, "myOpt0Id", kOption0Id, "optClass", "Option 0" )) != kOkRC )
|
||||
if((rc = createOption( uiH, uuid, wsSessId, selUuId, "myOpt0Id", kOption0Id, "optClass", "Option 0" )) != kOkRC )
|
||||
goto errLabel;
|
||||
|
||||
if((rc = createOption( p->uiH, uuid, wsSessId, selUuId, "myOpt1Id", kOption1Id, "optClass", "Option 1" )) != kOkRC )
|
||||
if((rc = createOption( uiH, uuid, wsSessId, selUuId, "myOpt1Id", kOption1Id, "optClass", "Option 1" )) != kOkRC )
|
||||
goto errLabel;
|
||||
|
||||
if((rc = createOption( p->uiH, uuid, wsSessId, selUuId, "myOpt2Id", kOption2Id, "optClass", "Option 2" )) != kOkRC )
|
||||
if((rc = createOption( uiH, uuid, wsSessId, selUuId, "myOpt2Id", kOption2Id, "optClass", "Option 2" )) != kOkRC )
|
||||
goto errLabel;
|
||||
|
||||
if((rc = createString( p->uiH, uuid, wsSessId, divUuId, "myStringId", kStringId, "stringClass", "String", "a string value" )) != kOkRC )
|
||||
if((rc = createString( uiH, uuid, wsSessId, divUuId, "myStringId", kStringId, "stringClass", "String", "a string value" )) != kOkRC )
|
||||
goto errLabel;
|
||||
|
||||
if((rc = createNumber( p->uiH, uuid, wsSessId, divUuId, "myNumberId", kNumberId, "numberClass", "Number", 10, 0, 100, 1, 0 )) != kOkRC )
|
||||
if((rc = createNumber( uiH, uuid, wsSessId, divUuId, "myNumberId", kNumberId, "numberClass", "Number", 10, 0, 100, 1, 0 )) != kOkRC )
|
||||
goto errLabel;
|
||||
|
||||
if((rc = createProgress( p->uiH, uuid, wsSessId, divUuId, "myProgressId", kProgressId, "progressClass", "Progress", 5, 0, 10 )) != kOkRC )
|
||||
if((rc = createProgress( uiH, uuid, wsSessId, divUuId, "myProgressId", kProgressId, "progressClass", "Progress", 5, 0, 10 )) != kOkRC )
|
||||
goto errLabel;
|
||||
|
||||
if((rc = createFromFile( p->uiH, p->uiCfgFn, wsSessId )) != kOkRC )
|
||||
if((rc = createFromFile( uiH, p->uiCfgFn, wsSessId )) != kOkRC )
|
||||
goto errLabel;
|
||||
|
||||
errLabel:
|
||||
@ -140,10 +146,6 @@ namespace cw
|
||||
_uiTestCreateUi(p,wsSessId);
|
||||
break;
|
||||
|
||||
case kRegisterOpId:
|
||||
break;
|
||||
|
||||
|
||||
case kValueOpId:
|
||||
_handleUiValueMsg( p, wsSessId, parentAppId, uuId, appId, v );
|
||||
break;
|
||||
@ -167,17 +169,21 @@ cw::rc_t cw::ui::test( )
|
||||
int port = 5687;
|
||||
unsigned rcvBufByteN = 2048;
|
||||
unsigned xmtBufByteN = 2048;
|
||||
unsigned fmtBufByteN = 4096;
|
||||
unsigned websockTimeOutMs = 50;
|
||||
const unsigned sbufN = 31;
|
||||
char sbuf[ sbufN+1 ];
|
||||
ui_test_t* ui = mem::allocZ<ui_test_t>();
|
||||
ui_test_t* app = mem::allocZ<ui_test_t>();
|
||||
|
||||
ui->uiCfgFn = "/home/kevin/src/cwtest/src/libcw/html/uiTest/ui.cfg";
|
||||
app->uiCfgFn = "/home/kevin/src/cwtest/src/libcw/html/uiTest/ui.cfg";
|
||||
|
||||
if((rc = createUi(ui->uiH, port, _uiTestCallback, ui, physRootDir, dfltPageFn, websockTimeOutMs, rcvBufByteN, xmtBufByteN )) != kOkRC )
|
||||
// create the UI server
|
||||
if((rc = srv::create(app->wsUiSrvH, port, physRootDir, app, _uiTestCallback, nullptr, dfltPageFn, websockTimeOutMs, rcvBufByteN, xmtBufByteN, fmtBufByteN )) != kOkRC )
|
||||
return rc;
|
||||
|
||||
if((rc = start(ui->uiH)) != kOkRC )
|
||||
|
||||
// start the UI server
|
||||
if((rc = srv::start(app->wsUiSrvH)) != kOkRC )
|
||||
goto errLabel;
|
||||
|
||||
|
||||
@ -198,10 +204,10 @@ cw::rc_t cw::ui::test( )
|
||||
|
||||
errLabel:
|
||||
rc_t rc1 = kOkRC;
|
||||
if( ui->uiH.isValid() )
|
||||
rc1 = destroyUi(ui->uiH);
|
||||
if( app->wsUiSrvH.isValid() )
|
||||
rc1 = srv::destroy(app->wsUiSrvH);
|
||||
|
||||
mem::release(ui);
|
||||
mem::release(app);
|
||||
|
||||
return rcSelect(rc,rc1);
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user