Unified API endpoing adding function

Author: kala13x

examples/async-client.c

@@ -194,7 +194,7 @@ int main(int argc, char* argv[])
     endpt.bUnix = args.bUnix;
     endpt.bTLS = args.bSSL;
 
-    if (XAPI_Connect(&api, &endpt) < 0)
+    if (XAPI_AddEndpoint(&api, &endpt, XAPI_CLIENT) < 0)
     {
         XAPI_Destroy(&api);
         return XSTDERR;

examples/async-server.c

@@ -231,7 +231,7 @@ int main(int argc, char* argv[])
 #endif
     }
 
-    if (XAPI_Listen(&api, &endpt) < 0)
+    if (XAPI_AddEndpoint(&api, &endpt, XAPI_SERVER) < 0)
     {
         XAPI_Destroy(&api);
         return XSTDERR;

examples/http-server.c

@@ -273,7 +273,7 @@ int main(int argc, char* argv[])
 #endif
     }
 
-    if (XAPI_Listen(&api, &endpt) < 0)
+    if (XAPI_AddEndpoint(&api, &endpt, XAPI_SERVER) < 0)
     {
         XAPI_Destroy(&api);
         return XSTDERR;

examples/ws-client.c

@@ -271,7 +271,7 @@ int main(int argc, char* argv[])
     session_data_t sessData;
     endpt.pSessionData = &sessData;
 
-    if (XAPI_Connect(&api, &endpt) < 0)
+    if (XAPI_AddEndpoint(&api, &endpt, XAPI_CLIENT) < 0)
     {
         XAPI_Destroy(&api);
         return XSTDERR;

examples/ws-server.c

@@ -354,7 +354,7 @@ int main(int argc, char* argv[])
 #endif
     }
 
-    if (XAPI_Listen(&api, &endpt) < 0)
+    if (XAPI_AddEndpoint(&api, &endpt, XAPI_SERVER) < 0)
     {
         XAPI_Destroy(&api);
         return XSTDERR;

src/net/api.c

@@ -1324,3 +1324,15 @@ XSTATUS XAPI_Connect(xapi_t *pApi, xapi_endpoint_t *pEndpt)
 
     return XSTDOK;
 }
+
+XSTATUS XAPI_AddEndpoint(xapi_t *pApi, xapi_endpoint_t *pEndpt, xapi_role_t eRole)
+{
+    switch (eRole)
+    {
+        case XAPI_SERVER: return XAPI_Listen(pApi, pEndpt);
+        case XAPI_CLIENT: return XAPI_Connect(pApi, pEndpt);
+        default: break;
+    }
+
+    return XSTDERR;
+}

src/net/api.h

@@ -174,6 +174,7 @@ XSTATUS XAPI_AuthorizeHTTP(xapi_data_t *pApiData, const char *pToken, const char
 void XAPI_InitEndpoint(xapi_endpoint_t *pEndpt);
 XSTATUS XAPI_Listen(xapi_t *pApi, xapi_endpoint_t *pEndpt);
 XSTATUS XAPI_Connect(xapi_t *pApi, xapi_endpoint_t *pEndpt);
+XSTATUS XAPI_AddEndpoint(xapi_t *pApi, xapi_endpoint_t *pEndpt, xapi_role_t eRole);
 
 xevent_status_t XAPI_Service(xapi_t *pApi, int nTimeoutMs);
 

tools/xtop.c

@@ -1567,7 +1567,7 @@ int XTOPApp_ServerMode(xtop_args_t *pArgs, xtop_stats_t *pStats)
     endpt.pAddr = pArgs->sAddr;
     endpt.nPort = pArgs->nPort;
 
-    if (XAPI_Listen(&api, &endpt) < 0)
+    if (XAPI_AddEndpoint(&api, &endpt, XAPI_SERVER) < 0)
     {
         XAPI_Destroy(&api);
         return XSTDERR;