X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=client%2Fsrc%2Fpkgmgr_client_connection.c;h=0c7d47148f2dcd64db9c559f84abacf14ae7e05f;hb=bebaf7844a20d4698caefecafceccac55dad62c3;hp=eab1228258fa49af6fbe60b4a5511936fea6b1ba;hpb=66aa6ae7f27c4fb8ebd823dbf6646ae6f974dd5e;p=platform%2Fcore%2Fappfw%2Fslp-pkgmgr.git

diff --git a/client/src/pkgmgr_client_connection.c b/client/src/pkgmgr_client_connection.c
index eab1228..0c7d471 100644
--- a/client/src/pkgmgr_client_connection.c
+++ b/client/src/pkgmgr_client_connection.c
@@ -103,6 +103,13 @@ struct signal_map map[] = {
 		PKGMGR_CLIENT_STATUS_ENABLE_APP_SPLASH_SCREEN},
 	{PKGMGR_INSTALLER_APP_DISABLE_SPLASH_SCREEN_EVENT_STR,
 		PKGMGR_CLIENT_STATUS_DISABLE_APP_SPLASH_SCREEN},
+	{PKGMGR_INSTALLER_RES_COPY_EVENT_STR, PKGMGR_CLIENT_STATUS_RES_COPY},
+	{PKGMGR_INSTALLER_RES_CREATE_DIR_EVENT_STR,
+		PKGMGR_CLIENT_STATUS_RES_CREATE_DIR},
+	{PKGMGR_INSTALLER_RES_REMOVE_EVENT_STR,
+		PKGMGR_CLIENT_STATUS_RES_REMOVE},
+	{PKGMGR_INSTALLER_RES_UNINSTALL_EVENT_STR,
+		PKGMGR_CLIENT_STATUS_RES_UNINSTALL},
 	{NULL, -1}
 };
 
@@ -187,47 +194,148 @@ static void __handle_size_info_callback(struct cb_info *cb_info,
 	}
 }
 
-static void __signal_handler(GDBusConnection *conn, const gchar *sender_name,
-		const gchar *object_path, const gchar *interface_name,
-		const gchar *signal_name, GVariant *parameters,
-		gpointer user_data)
+static void __handle_pkg_signal(const gchar *signal_name,
+		GVariant *parameters, gpointer user_data)
 {
 	uid_t target_uid;
 	char *req_id;
 	char *pkg_type = NULL;
+	char *appid = NULL;
 	char *pkgid = NULL;
 	char *key = NULL;
 	char *val = NULL;
-	char *appid = NULL;
+	struct cb_info *cb_info = (struct cb_info *)user_data;
+	GVariantIter *iter = NULL;
 	int signal_type;
+
+	g_variant_get(parameters, "(u&sa(sss)&s&s)", &target_uid, &req_id, &iter,
+			&key, &val);
+	while (g_variant_iter_loop(iter, "(&s&s&s)", &pkgid, &appid, &pkg_type)) {
+		if (cb_info->req_key) {
+			if (strcmp(cb_info->req_key, req_id) != 0)
+				continue;
+		} else {
+			signal_type = __get_signal_type(signal_name);
+			if (signal_type < 0 || !(cb_info->status_type & signal_type)) {
+				g_variant_iter_free(iter);
+				return;
+			}
+		}
+
+		/* each cb_data can only has one callback */
+		if (cb_info->event_cb) {
+			cb_info->event_cb(target_uid, cb_info->req_id,
+					pkg_type, pkgid, key, val, NULL, cb_info->data);
+		} else if (cb_info->app_event_cb && strcmp(appid, "") != 0) {
+			cb_info->app_event_cb(target_uid, cb_info->req_id,
+					pkg_type, pkgid, appid, key, val, NULL,
+					cb_info->data);
+		} else if (cb_info->size_info_cb) {
+			__handle_size_info_callback(cb_info, pkgid, val);
+		}
+
+		/* TODO: unsubscribe request callback */
+	}
+	g_variant_iter_free(iter);
+}
+
+static void __handle_res_event_signal(const gchar *signal_name,
+		GVariant *parameters, gpointer user_data)
+{
+	uid_t target_uid;
+	char *req_id;
+	char *pkgid = NULL;
+	char *status = NULL;
+	char *path = NULL;
+	pkgmgr_res_event_path_state state;
 	struct cb_info *cb_info = (struct cb_info *)user_data;
+	int signal_type;
+	GVariant *extra_param = NULL;
+	pkgmgr_res_event_info_t *event_info;
+	GVariantIter *iter;
 
-	g_variant_get(parameters, "(u&s&s&s&s&s&s)",
-			&target_uid, &req_id, &pkg_type,
-			&pkgid, &appid, &key, &val);
+	if (!cb_info->res_event_cb)
+		return;
 
-	/* in case of request, check reqkey */
+	g_variant_get(parameters, "(u&s&s&sv)", &target_uid, &req_id, &pkgid, &status, &extra_param);
+	if (!g_variant_type_equal(G_VARIANT_TYPE("(ia(si))"),
+			g_variant_get_type(extra_param))) {
+		ERR("invalid extra parameter");
+		g_variant_unref(extra_param);
+		return;
+	}
 	if (cb_info->req_key) {
-		if (strcmp(cb_info->req_key, req_id) != 0)
+		if (strcmp(cb_info->req_key, req_id) != 0) {
+			g_variant_unref(extra_param);
 			return;
+		}
 	} else {
 		signal_type = __get_signal_type(signal_name);
-		if (signal_type < 0 || !(cb_info->status_type & signal_type))
+		if (signal_type < 0 || !(cb_info->status_type & signal_type)) {
+			g_variant_unref(extra_param);
+			return;
+		}
+	}
+
+	event_info = pkgmgr_res_event_info_new();
+	if (event_info == NULL) {
+		ERR("out of memory");
+		g_variant_unref(extra_param);
+		return;
+	}
+
+	g_variant_get(extra_param, "(ia(si))", &event_info->error_code, &iter);
+
+	while (g_variant_iter_loop(iter, "(&si)", &path, &state)) {
+		if (pkgmgr_res_event_info_add_path_state(event_info,
+				path, state) != PKGMGR_R_OK) {
+			ERR("Fail to add path state");
+			g_variant_unref(extra_param);
+			g_variant_iter_free(iter);
+			pkgmgr_res_event_info_free(event_info);
 			return;
+		}
 	}
+	cb_info->res_event_cb(target_uid, cb_info->req_id, pkgid, signal_name,
+			status, event_info, cb_info->data);
+	g_variant_unref(extra_param);
+	g_variant_iter_free(iter);
+	pkgmgr_res_event_info_free(event_info);
+}
 
-	/* each cb_data can only has one callback */
-	if (cb_info->event_cb && strcmp(appid, "") == 0)
-		cb_info->event_cb(target_uid, cb_info->req_id,
-				pkg_type, pkgid, key, val, NULL, cb_info->data);
-	else if (cb_info->app_event_cb && strcmp(appid, "") != 0)
-		cb_info->app_event_cb(target_uid, cb_info->req_id,
-				pkg_type, pkgid, appid, key, val, NULL,
-				cb_info->data);
-	else if (cb_info->size_info_cb)
-		__handle_size_info_callback(cb_info, pkgid, val);
+static void __handle_pkg_upgrade_event_signal(const gchar *signal_name,
+		GVariant *parameters, gpointer user_data)
+{
+	guint32 progress;
+	struct cb_info *cb_info = (struct cb_info *)user_data;
 
-	/* TODO: unsubscribe request callback */
+	if (!cb_info->upgrade_event_cb)
+		return;
+
+	if (strcmp(signal_name, PKGMGR_INSTALLER_PKG_UPGRADE_EVENT_STR) != 0) {
+		return;
+	}
+
+	g_variant_get(parameters, "(u)", &progress);
+	cb_info->upgrade_event_cb(progress, cb_info->data);
+}
+
+static void __signal_handler(GDBusConnection *conn, const gchar *sender_name,
+		const gchar *object_path, const gchar *interface_name,
+		const gchar *signal_name, GVariant *parameters,
+		gpointer user_data)
+{
+	if (g_variant_type_equal(G_VARIANT_TYPE("(usa(sss)ss)"),
+			g_variant_get_type(parameters))) {
+		__handle_pkg_signal(signal_name, parameters, user_data);
+	} else if (!strcmp(signal_name, PKGMGR_INSTALLER_RES_COPY_EVENT_STR) ||
+			!strcmp(signal_name, PKGMGR_INSTALLER_RES_REMOVE_EVENT_STR) ||
+			!strcmp(signal_name, PKGMGR_INSTALLER_RES_UNINSTALL_EVENT_STR) ||
+			!strcmp(signal_name, PKGMGR_INSTALLER_RES_CREATE_DIR_EVENT_STR)) {
+		__handle_res_event_signal(signal_name, parameters, user_data);
+	} else if (!strcmp(signal_name, PKGMGR_INSTALLER_PKG_UPGRADE_EVENT_STR)) {
+		__handle_pkg_upgrade_event_signal(signal_name, parameters, user_data);
+	}
 }
 
 static void __set_signal_list(int event, GList **signal_list)