ecore_con: add test cases for ecore_con_eet.

Summary:
Added test case for ecore_con_eet.

Signed-off-by: Srivardhan Hebbar <sri.hebbar@samsung.com>

Reviewers: cedric

Subscribers: cedric

Differential Revision: https://phab.enlightenment.org/D2347

Signed-off-by: Cedric BAIL <cedric@osg.samsung.com>

src/Makefile_Ecore_Con.am

@@ -84,6 +84,7 @@ tests_ecore_con_ecore_con_suite_SOURCES = \
 tests/ecore_con/ecore_con_suite.c \
 tests/ecore_con/ecore_con_test_ecore_con.c \
 tests/ecore_con/ecore_con_test_ecore_con_url.c \
+tests/ecore_con/ecore_con_test_ecore_con_eet.c \
 tests/ecore_con/ecore_con_suite.h
 
 tests_ecore_con_ecore_con_suite_CPPFLAGS = -I$(top_builddir)/src/lib/efl \

src/tests/ecore_con/ecore_con_suite.c

@@ -20,6 +20,7 @@ struct _Ecore_Con_Test_Case
 static const Ecore_Con_Test_Case etc[] = {
   { "Ecore_Con", ecore_con_test_ecore_con },
   { "Ecore_Con_Url", ecore_con_test_ecore_con_url },
+  { "Ecore_Con_Eet", ecore_con_test_ecore_con_eet },
   { NULL, NULL }
 };
 

src/tests/ecore_con/ecore_con_suite.h

@@ -5,5 +5,6 @@
 
 void ecore_con_test_ecore_con(TCase *tc);
 void ecore_con_test_ecore_con_url(TCase *tc);
+void ecore_con_test_ecore_con_eet(TCase *tc);
 
 #endif /* _ECORE_CON_SUITE_H */

src/tests/ecore_con/ecore_con_test_ecore_con_eet.c

@@ -0,0 +1,173 @@
+#ifdef HAVE_CONFIG_H
+# include <config.h>
+#endif
+
+#include "ecore_con_suite.h"
+
+#include <Eet.h>
+#include <Ecore_Con_Eet.h>
+
+#define TEST_STREAM "test_stream"
+#define SRV_MSG "Server Message"
+#define CLI_MSG "Client Message"
+
+static Eet_Data_Descriptor *_ece_test_descriptor;
+static char eet_data[] = "test_data";
+
+typedef struct
+{
+   int id;
+   char *message;
+}ECE_Test;
+
+static void
+_ece_test_descriptor_init(void)
+{
+   Eet_Data_Descriptor_Class eddc;
+
+   EET_EINA_STREAM_DATA_DESCRIPTOR_CLASS_SET(&eddc, ECE_Test);
+   _ece_test_descriptor = eet_data_descriptor_stream_new(&eddc);
+
+#define ECE_TEST_ADD_BASIC(member, eet_type) \
+  EET_DATA_DESCRIPTOR_ADD_BASIC             \
+    (_ece_test_descriptor, ECE_Test, # member, member, eet_type)
+
+   ECE_TEST_ADD_BASIC(id, EET_T_INT);
+   ECE_TEST_ADD_BASIC(message, EET_T_STRING);
+#undef ECE_TEST_ADD_BASIC
+}
+
+static void
+_ece_test_descriptor_shutdown(void)
+{
+   eet_data_descriptor_free(_ece_test_descriptor);
+}
+
+Eina_Bool
+_eet_client_discnct_cb(void *data EINA_UNUSED, Ecore_Con_Reply *reply EINA_UNUSED, Ecore_Con_Client *conn EINA_UNUSED)
+{
+   ecore_main_loop_quit();
+
+   return EINA_FALSE;
+}
+
+Eina_Bool
+_eet_client_cnct_cb(void *data EINA_UNUSED, Ecore_Con_Reply *reply, Ecore_Con_Client *conn EINA_UNUSED)
+{
+   char *ec_eet_data;
+   Ecore_Con_Eet *ec_eet = ecore_con_eet_reply(reply);
+   fail_unless(ec_eet);
+
+   ec_eet_data = ecore_con_eet_data_get(ec_eet);
+   fail_if(strcmp(ec_eet_data, eet_data));
+
+   return EINA_TRUE;
+}
+
+static void
+_eet_data_cb(void *data EINA_UNUSED, Ecore_Con_Reply *reply, const char *protocol_name, void *value)
+{
+   char toSend[] = SRV_MSG;
+   ECE_Test *received = value;
+
+   fprintf(stderr, "id: %d\n message: %s\n",
+           received->id, received->message);
+   fail_if(strcmp(received->message, CLI_MSG));
+   fail_if(received->id != 1);
+
+   ecore_con_eet_raw_send(reply, protocol_name, "message", toSend,
+                          strlen(toSend));
+}
+
+Eina_Bool
+_eet_svr_discnct_cb(void *data EINA_UNUSED, Ecore_Con_Reply *reply EINA_UNUSED, Ecore_Con_Client *conn EINA_UNUSED)
+{
+   ecore_main_loop_quit();
+   return EINA_FALSE;
+}
+
+Eina_Bool
+_eet_svr_cnct_cb(void *data EINA_UNUSED, Ecore_Con_Reply *reply, Ecore_Con_Client *conn EINA_UNUSED)
+{
+   ECE_Test toSend = {1, CLI_MSG};
+
+   ecore_con_eet_send(reply, TEST_STREAM, &toSend);
+   return EINA_TRUE;
+}
+
+static void
+_eet_raw_data_cb(void *data EINA_UNUSED, Ecore_Con_Reply *reply EINA_UNUSED, const char *protocol_name EINA_UNUSED, const char *section, void *value, size_t length)
+{
+   fprintf(stderr, "Section: %s\n", section);
+   fprintf(stderr, "Value: %s\n", (char *) value);
+   fail_if(strncmp((char *) value, SRV_MSG, length));
+
+   ecore_main_loop_quit();
+}
+
+START_TEST(ecore_con_test_ecore_con_eet_svr_cl)
+{
+   Ecore_Con_Eet *ece_svr, *ece_cl;
+   Ecore_Con_Server *svr, *cl;
+
+   eina_init();
+   eet_init();
+   ecore_con_init();
+   _ece_test_descriptor_init();
+
+   svr = ecore_con_server_add(ECORE_CON_REMOTE_TCP, "127.0.0.1",
+                              8080, NULL);
+   fail_unless(svr);
+
+   ece_svr = ecore_con_eet_server_new(svr);
+   fail_unless(ece_svr);
+
+   ecore_con_eet_data_set(ece_svr, eet_data);
+
+   ecore_con_eet_register(ece_svr, TEST_STREAM, _ece_test_descriptor);
+   ecore_con_eet_data_callback_add(ece_svr, TEST_STREAM, _eet_data_cb,
+                                   NULL);
+   ecore_con_eet_client_connect_callback_add(ece_svr, _eet_client_cnct_cb,
+                                             NULL);
+   ecore_con_eet_client_disconnect_callback_add(ece_svr,
+                                                _eet_client_discnct_cb, NULL);
+
+   cl = ecore_con_server_connect(ECORE_CON_REMOTE_TCP, "127.0.0.1",
+                                 8080, NULL);
+   fail_unless (cl);
+
+   ece_cl = ecore_con_eet_client_new(cl);
+   fail_unless (ece_cl);
+
+   ecore_con_eet_register(ece_cl, TEST_STREAM, _ece_test_descriptor);
+   ecore_con_eet_raw_data_callback_add(ece_cl, TEST_STREAM,
+                                       _eet_raw_data_cb, NULL);
+   ecore_con_eet_server_connect_callback_add(ece_cl, _eet_svr_cnct_cb, NULL);
+   ecore_con_eet_server_disconnect_callback_add(ece_cl, _eet_svr_discnct_cb,
+                                                NULL);
+
+   ecore_main_loop_begin();
+
+   ecore_con_eet_raw_data_callback_del(ece_cl, TEST_STREAM);
+   ecore_con_eet_server_connect_callback_del(ece_cl, _eet_svr_cnct_cb, NULL);
+   ecore_con_eet_server_disconnect_callback_del(ece_cl, _eet_svr_discnct_cb,
+                                                NULL);
+
+   ecore_con_eet_data_callback_del(ece_svr, TEST_STREAM);
+   ecore_con_eet_client_connect_callback_del(ece_svr, _eet_client_cnct_cb,
+                                             NULL);
+   ecore_con_eet_client_disconnect_callback_del(ece_svr,
+                                                _eet_client_discnct_cb, NULL);
+
+   _ece_test_descriptor_shutdown();
+   ecore_con_server_del(cl);
+   ecore_con_server_del(svr);
+   ecore_con_shutdown();
+   eet_shutdown();
+   eina_shutdown();
+}
+END_TEST
+void ecore_con_test_ecore_con_eet(TCase *tc)
+{
+   tcase_add_test(tc, ecore_con_test_ecore_con_eet_svr_cl);
+}