Add pkgmgr_installer_send_signal_for_uid

This api sends signal to agent, and agent emit signal into session bus.

Change-Id: I7c01c5703f836a19a0b19805b50b33d088a2a80e
Signed-off-by: Sangyoon Jang <s89.jang@samsung.com>

diff --git a/installer/pkgmgr_installer.c b/installer/pkgmgr_installer.c
index 5c9be31b3e01e365c536d63c256f5f016403048d..b031a06f196008f13667462ff079502e76841fd6 100644 (file)
--- a/installer/pkgmgr_installer.c
+++ b/installer/pkgmgr_installer.c
@@ -20,13 +20,17 @@
  *
  */
 
-
-
+#include <stdio.h>
 #include <stdlib.h>
 #include <unistd.h>
 #include <string.h>
+#include <errno.h>
 #include <getopt.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <sys/un.h>
 
+#include <glib.h>
 #include <gio/gio.h>
 
 #include "pkgmgr_installer.h"
@@ -171,6 +175,166 @@ static int __send_signal_for_event(pkgmgr_installer *pi, const char *pkg_type,
        return 0;
 }
 
+static int __send_signal_to_agent(uid_t uid, void *data, size_t len)
+{
+       int fd;
+       struct sockaddr_un sa;
+       int r;
+
+       fd = socket(AF_UNIX, SOCK_STREAM | SOCK_NONBLOCK, 0);
+       if (fd == -1) {
+               ERR("failed to create socket: %d", errno);
+               return -1;
+       }
+
+       sa.sun_family = AF_UNIX;
+       snprintf(sa.sun_path, sizeof(sa.sun_path), "/run/pkgmgr/agent/%d", uid);
+
+       r = connect(fd, (struct sockaddr *)&sa, sizeof(sa));
+       if (r == -1) {
+               ERR("failed to connect socket(%s): %d", sa.sun_path, errno);
+               close(fd);
+               return -1;
+       }
+
+       r = send(fd, data, len, 0);
+       if (r < 0) {
+               ERR("failed to send data: %d", errno);
+               close(fd);
+               return -1;
+       }
+
+       close(fd);
+
+       return 0;
+}
+
+/* TODO: it should be refactored */
+static int __send_app_signal_for_event_for_uid(pkgmgr_installer *pi, uid_t uid,
+               const char *pkg_type, const char *pkgid, const char *appid,
+               const char *key, const char *val)
+{
+       char *sid;
+       const char *name;
+       size_t name_size;
+       GVariant *gv;
+       gsize gv_len;
+       gpointer gv_data;
+       void *data;
+       void *ptr;
+       size_t data_len;
+
+       if (!pi || pi->conn == NULL)
+               return -1;
+
+       sid = pi->session_id;
+       if (!sid)
+               sid = "";
+
+       data_len = sizeof(size_t) + sizeof(gsize);
+
+       name = __get_signal_name(pi, key);
+       if (name == NULL) {
+               ERR("unknown signal type");
+               return -1;
+       }
+       /* including null byte */
+       name_size = strlen(name) + 1;
+       data_len += name_size;
+
+       gv = g_variant_new("(ussssss)", pi->target_uid, sid,
+                       pkg_type, pkgid, appid, key, val);
+       gv_len = g_variant_get_size(gv);
+       gv_data = g_malloc(gv_len);
+       g_variant_store(gv, gv_data);
+       g_variant_unref(gv);
+       data_len += gv_len;
+
+       data = malloc(data_len);
+       ptr = data;
+       memcpy(ptr, &name_size, sizeof(size_t));
+       ptr += sizeof(size_t);
+       memcpy(ptr, &gv_len, sizeof(gsize));
+       ptr += sizeof(gsize);
+       memcpy(ptr, name, name_size);
+       ptr += name_size;
+       memcpy(ptr, gv_data, gv_len);
+
+       if (__send_signal_to_agent(uid, data, data_len)) {
+               ERR("failed to send signal to agent");
+               g_free(data);
+               return -1;
+       }
+
+       g_free(gv_data);
+       free(data);
+
+       return 0;
+}
+
+/* TODO: it should be refactored */
+static int __send_signal_for_event_for_uid(pkgmgr_installer *pi, uid_t uid,
+               const char *pkg_type, const char *pkgid,
+               const char *key, const char *val)
+{
+       char *sid;
+       const char *name;
+       size_t name_size;
+       GVariant *gv;
+       gsize gv_len;
+       gpointer gv_data;
+       void *data;
+       void *ptr;
+       size_t data_len;
+
+       if (!pi || pi->conn == NULL)
+               return -1;
+
+       sid = pi->session_id;
+       if (!sid)
+               sid = "";
+
+       data_len = sizeof(size_t) + sizeof(gsize);
+
+       name = __get_signal_name(pi, key);
+       if (name == NULL) {
+               ERR("unknown signal type");
+               return -1;
+       }
+       /* including null byte */
+       name_size = strlen(name) + 1;
+       data_len += name_size;
+
+       gv = g_variant_new("(ussssss)", pi->target_uid, sid,
+                       pkg_type, pkgid, "", key, val);
+       gv_len = g_variant_get_size(gv);
+       gv_data = g_malloc(gv_len);
+       g_variant_store(gv, gv_data);
+       g_variant_unref(gv);
+       data_len += gv_len;
+
+       data = malloc(data_len);
+       ptr = data;
+       memcpy(ptr, &name_size, sizeof(size_t));
+       ptr += sizeof(size_t);
+       memcpy(ptr, &gv_len, sizeof(gsize));
+       ptr += sizeof(gsize);
+       memcpy(ptr, name, name_size);
+       ptr += name_size;
+       memcpy(ptr, gv_data, gv_len);
+
+       if (__send_signal_to_agent(uid, data, data_len)) {
+               ERR("failed to send signal to agent");
+               g_free(data);
+               return -1;
+       }
+
+       g_free(gv_data);
+       free(data);
+
+       return 0;
+}
+
 API pkgmgr_installer *pkgmgr_installer_new(void)
 {
        pkgmgr_installer *pi;
@@ -584,6 +748,42 @@ pkgmgr_installer_send_signal(pkgmgr_installer *pi,
        return r;
 }
 
+API int pkgmgr_installer_send_app_signal_for_uid(pkgmgr_installer *pi,
+               uid_t uid, const char *pkg_type, const char *pkgid,
+               const char *appid, const char *key, const char *val)
+{
+       int r = 0;
+
+       if (!pi->conn) {
+               ERR("connection is NULL");
+               return -1;
+       }
+
+       r = __send_app_signal_for_event_for_uid(pi, uid, pkg_type, pkgid, appid, key, val);
+
+       return r;
+}
+
+API int pkgmgr_installer_send_signal_for_uid(pkgmgr_installer *pi,
+               uid_t uid, const char *pkg_type, const char *pkgid,
+               const char *key, const char *val)
+{
+       int r = 0;
+
+       if (!pi->conn) {
+               ERR("connection is NULL");
+               return -1;
+       }
+
+       if (strcmp(key, PKGMGR_INSTALLER_START_KEY_STR) == 0 &&
+                       strcmp(val, PKGMGR_INSTALLER_UPGRADE_EVENT_STR) == 0)
+               pi->request_type = PKGMGR_REQ_UPGRADE;
+
+       r = __send_signal_for_event_for_uid(pi, uid, pkg_type, pkgid, key, val);
+
+       return r;
+}
+
 API int pkgmgr_installer_set_request_type(pkgmgr_installer *pi, int request_type)
 {
        if (pi == NULL)

diff --git a/installer/pkgmgr_installer.h b/installer/pkgmgr_installer.h
index 33747765ee9bd0c41063858c736df94765c3e503..b4e6f42d456a5b9be268ee95bc0b058f16e3bc86 100644 (file)
--- a/installer/pkgmgr_installer.h
+++ b/installer/pkgmgr_installer.h
@@ -747,6 +747,50 @@ int pkgmgr_installer_send_signal(pkgmgr_installer *pi,
                                 const char *pkgid, const char *key,
                                 const char *val);
 
+/**
+       @brief          Send a app status signal
+       @pre            None
+       @post           None
+       @see            None
+       @param[in]      pi      pkgmgr_installer object
+       @param[in]      uid     user id
+       @param[in]      pkg_type        package type: "deb", "jar", "wgt", ...
+       @param[in]      pkgid   package id
+       @param[in]      appid   application id
+       @param[in]      key                     Signal key
+       @param[in]      val                     Signal value
+       @return         Operation result
+       @retval         0 on success, otherwise -1
+       @remark         If pkgmgr_installer_receive_request() is not called, the session ID will be null string (=="/0").
+ */
+int pkgmgr_installer_send_app_signal_for_uid(pkgmgr_installer *pi,
+                                uid_t uid,
+                                const char *pkg_type,
+                                const char *pkgid,
+                                const char *appid,
+                                const char *key, const char *val);
+
+/**
+       @brief          Send a process status signal
+       @pre            None
+       @post           None
+       @see            None
+       @param[in]      pi      pkgmgr_installer object
+       @param[in]      uid     user id
+       @param[in]      pkg_type        package type: "deb", "jar", "wgt", ...
+       @param[in]      pkgid   package id
+       @param[in]      key                     Signal key
+       @param[in]      val                     Signal value
+       @return         Operation result
+       @retval         0 on success, otherwise -1
+       @remark         If pkgmgr_installer_receive_request() is not called, the session ID will be null string (=="/0").
+ */
+int pkgmgr_installer_send_signal_for_uid(pkgmgr_installer *pi,
+                                uid_t uid,
+                                const char *pkg_type,
+                                const char *pkgid, const char *key,
+                                const char *val);
+
 /**
        @brief          Send a signal which indicates application is being uninstalled
        @pre            None