*: UID:UUID -> crash_id conversion

This fixes at least three instances where we did not check whether
user is even allowed to report or delete a crash.

Also fixes a few cases when root might inadvertently act on (e.g. delete)
mote than one crash.

Renamed FILENAME_UID to CD_UID - makes more sense this way.
Added COL_INFORMALL and CD_INFORMALL. Nuked UID == -1 hacks.
Renamed getReport() to start_job on Python side.
Dropped a few unused parameters from server -> client dbus signals.
Fixed CLI's way of reverencing crashes (see updated help text).

Run-tested (GUI and CLI).

Signed-off-by: Denys Vlasenko <vda.linux@googlemail.com>
Acked-by: Nikola Pajkovsky <npajkovs@redhat.com>

11 files changed, 191 insertions, 163 deletions

diff --git a/lib/Plugins/CCpp.cpp b/lib/Plugins/CCpp.cpp
index d2bbf3c5..47378690 100644
--- a/lib/Plugins/CCpp.cpp
+++ b/lib/Plugins/CCpp.cpp
@@ -280,7 +280,7 @@ static void GetBacktrace(const char *pDebugDumpDir,
         CDebugDump dd;
         dd.Open(pDebugDumpDir);
         dd.LoadText(FILENAME_EXECUTABLE, executable);
-        dd.LoadText(FILENAME_UID, UID);
+        dd.LoadText(CD_UID, UID);
     }
 
     // Workaround for
@@ -414,7 +414,7 @@ static string run_unstrip_n(const char *pDebugDumpDir)
     {
         CDebugDump dd;
         dd.Open(pDebugDumpDir);
-        dd.LoadText(FILENAME_UID, UID);
+        dd.LoadText(CD_UID, UID);
     }
 
     char* args[4];
@@ -648,7 +648,7 @@ string CAnalyzerCCpp::GetGlobalUUID(const char *pDebugDumpDir)
         dd.LoadText(FILENAME_EXECUTABLE, executable);
         dd.LoadText(FILENAME_PACKAGE, package);
         if (m_bBacktrace)
-            dd.LoadText(FILENAME_UID, uid_str);
+            dd.LoadText(CD_UID, uid_str);
     }
 
     string independent_backtrace;
@@ -798,7 +798,7 @@ void CAnalyzerCCpp::CreateReport(const char *pDebugDumpDir, int force)
     }
 
     dd.LoadText(FILENAME_PACKAGE, package);
-    dd.LoadText(FILENAME_UID, UID);
+    dd.LoadText(CD_UID, UID);
     dd.Close(); /* do not keep dir locked longer than needed */
 
     string build_ids;
diff --git a/lib/Plugins/Firefox.cpp b/lib/Plugins/Firefox.cpp
index 3cb9c938..ac7ab2cd 100644
--- a/lib/Plugins/Firefox.cpp
+++ b/lib/Plugins/Firefox.cpp
@@ -246,7 +246,7 @@ static void GetBacktrace(const char *pDebugDumpDir, std::string& pBacktrace)
         CDebugDump dd;
         dd.Open(pDebugDumpDir);
         dd.LoadText(FILENAME_EXECUTABLE, executable);
-        dd.LoadText(FILENAME_UID, UID);
+        dd.LoadText(CD_UID, UID);
     }
 
     // Workaround for
@@ -440,7 +440,7 @@ static std::string run_unstrip_n(const char *pDebugDumpDir)
     {
         CDebugDump dd;
         dd.Open(pDebugDumpDir);
-        dd.LoadText(FILENAME_UID, UID);
+        dd.LoadText(CD_UID, UID);
     }
 
     char* args[4];
@@ -884,7 +884,7 @@ void CAnalyzerFirefox::CreateReport(const char *pDebugDumpDir, int force)
     }
 
     dd.LoadText(FILENAME_PACKAGE, package);
-    dd.LoadText(FILENAME_UID, UID);
+    dd.LoadText(CD_UID, UID);
     dd.Close(); /* do not keep dir locked longer than needed */
 
     std::string build_ids;
diff --git a/lib/Plugins/Mailx.cpp b/lib/Plugins/Mailx.cpp
index 50bc3920..f9dd2cca 100644
--- a/lib/Plugins/Mailx.cpp
+++ b/lib/Plugins/Mailx.cpp
@@ -132,7 +132,7 @@ std::string CMailx::Report(const map_crash_data_t& pCrashData,
     args = append_str_to_vector(args, arg_size, m_sEmailTo.c_str());
 
     update_client(_("Sending an email..."));
-    const char *uid_str = get_crash_data_item_content(pCrashData, FILENAME_UID).c_str();
+    const char *uid_str = get_crash_data_item_content(pCrashData, CD_UID).c_str();
     exec_and_feed_input(xatoi_u(uid_str), emailBody.c_str(), args);
 
     while (*args)
diff --git a/lib/Plugins/SQLite3.cpp b/lib/Plugins/SQLite3.cpp
index 5819b98c..b076dfaf 100644
--- a/lib/Plugins/SQLite3.cpp
+++ b/lib/Plugins/SQLite3.cpp
@@ -25,14 +25,15 @@
 
 using namespace std;
 
-#define ABRT_TABLE_VERSION      3
-#define ABRT_TABLE_VERSION_STR "3"
+#define ABRT_TABLE_VERSION      4
+#define ABRT_TABLE_VERSION_STR "4"
 #define ABRT_TABLE             "abrt_v"ABRT_TABLE_VERSION_STR
 #define ABRT_REPRESULT_TABLE   "abrt_v"ABRT_TABLE_VERSION_STR"_reportresult"
 #define SQLITE3_MASTER_TABLE   "sqlite_master"
 
-#define COL_UUID               "UUID"
 #define COL_UID                "UID"
+#define COL_UUID               "UUID"
+#define COL_INFORMALL          "InformAll"
 #define COL_DEBUG_DUMP_PATH    "DebugDumpPath"
 #define COL_COUNT              "Count"
 #define COL_REPORTED           "Reported"
@@ -99,6 +100,9 @@ static string sql_escape(const char *str)
 }
 #endif
 
+/* Note:
+ * expects "SELECT * FROM ...", not "SELECT <only some fields> FROM ..."
+ */
 static void get_table(vector_database_rows_t& pTable,
                 sqlite3 *db, const char *fmt, ...)
 {
@@ -134,11 +138,12 @@ static void get_table(vector_database_rows_t& pTable,
             {
                 case 0: row.m_sUUID         = val; break;
                 case 1: row.m_sUID          = val; break;
-                case 2: row.m_sDebugDumpDir = val; break;
-                case 3: row.m_sCount        = val; break;
-                case 4: row.m_sReported     = val; break;
-                case 5: row.m_sTime         = val; break;
-                case 6: row.m_sMessage      = val; break;
+                case 2: row.m_sInformAll    = val; break;
+                case 3: row.m_sDebugDumpDir = val; break;
+                case 4: row.m_sCount        = val; break;
+                case 5: row.m_sReported     = val; break;
+                case 6: row.m_sTime         = val; break;
+                case 7: row.m_sMessage      = val; break;
             }
         }
         pTable.push_back(row);
@@ -170,14 +175,13 @@ static int execute_sql(sqlite3 *db, const char *fmt, ...)
     return affected;
 }
 
-static bool exists_uuid_uid(sqlite3 *db, const char *pUUID, const char *pUID)
+static bool exists_uuid_uid(sqlite3 *db, const char *UUID, const char *UID)
 {
     vector_database_rows_t table;
     get_table(table, db,
-                "SELECT "COL_REPORTED" FROM "ABRT_TABLE" WHERE "
-                COL_UUID" = '%s' "
-                "AND ("COL_UID" = '%s' OR "COL_UID" = '-1');",
-                pUUID, pUID
+                "SELECT * FROM "ABRT_TABLE
+                " WHERE "COL_UUID"='%s' AND "COL_UID"='%s';",
+                UUID, UID
     );
     return !table.empty();
 }
@@ -230,13 +234,49 @@ static void update_from_old_ver(sqlite3 *db, int old_version)
                     COL_MESSAGE
             " FROM abrt_v2;"
         "DROP TABLE abrt_v2;"
-        "CREATE TABLE "ABRT_REPRESULT_TABLE" ("
+        "CREATE TABLE abrt_v3_reportresult ("
                 COL_UUID" VARCHAR NOT NULL,"
                 COL_UID" VARCHAR NOT NULL,"
                 COL_REPORTER" VARCHAR NOT NULL,"
                 COL_MESSAGE" VARCHAR NOT NULL DEFAULT '',"
                 "PRIMARY KEY ("COL_UUID","COL_UID","COL_REPORTER"));"
         "COMMIT;",
+        // v3-> v4
+        "BEGIN TRANSACTION;"
+        "CREATE TABLE abrt_v4("
+                COL_UUID" VARCHAR NOT NULL,"
+                COL_UID" VARCHAR NOT NULL,"
+                COL_INFORMALL" INT NOT NULL DEFAULT 0,"
+                COL_DEBUG_DUMP_PATH" VARCHAR NOT NULL,"
+                COL_COUNT" INT NOT NULL DEFAULT 1,"
+                COL_REPORTED" INT NOT NULL DEFAULT 0,"
+                COL_TIME" VARCHAR NOT NULL DEFAULT 0,"
+                COL_MESSAGE" VARCHAR NOT NULL DEFAULT '',"
+                "PRIMARY KEY ("COL_UUID","COL_UID"));"
+        "INSERT INTO abrt_v4 "
+            "SELECT "COL_UUID","
+                    COL_UID","
+                    "0," /* COL_INFORMALL */
+                    COL_DEBUG_DUMP_PATH","
+                    COL_COUNT","
+                    COL_REPORTED","
+                    COL_TIME","
+                    COL_MESSAGE
+            " FROM abrt_v3;"
+        "DROP TABLE abrt_v3;"
+        "UPDATE abrt_v4"
+        " SET "COL_UID"='0', "COL_INFORMALL"=1"
+        " WHERE "COL_UID"='-1';"
+        "CREATE TABLE abrt_v4_reportresult ("
+                COL_UUID" VARCHAR NOT NULL,"
+                COL_UID" VARCHAR NOT NULL,"
+                COL_REPORTER" VARCHAR NOT NULL,"
+                COL_MESSAGE" VARCHAR NOT NULL DEFAULT '',"
+                "PRIMARY KEY ("COL_UUID","COL_UID","COL_REPORTER"));"
+        "INSERT INTO abrt_v4_reportresult "
+            "SELECT * FROM abrt_v3_reportresult;"
+        "DROP TABLE abrt_v3_reportresult;"
+        "COMMIT;",
     };
 
     while (old_version < ABRT_TABLE_VERSION)
@@ -266,13 +306,14 @@ static bool check_table(sqlite3 *db)
     }
 
     // table format:
-    // table[0]:"NAME"     // table[1]:"SQL"       <== field names from SELECT
+    // table[0]:"NAME"     // table[1]:"SQL"  <== field names from SELECT
     // table[2]:"abrt_vNN" // table[3]:"sql"
     char *tableName = table[0 + ncol];
     char *underscore = strchr(tableName, '_');
     if (underscore)
     {
-        int tableVersion = xatoi_u(underscore + 2);
+        // It can be "abrt_vNN_something", thus using atoi(), not xatoi()
+        int tableVersion = atoi(underscore + 2);
         sqlite3_free_table(table);
         if (tableVersion < ABRT_TABLE_VERSION)
         {
@@ -348,6 +389,7 @@ void CSQLite3::Connect()
                 "CREATE TABLE "ABRT_TABLE" ("
                 COL_UUID" VARCHAR NOT NULL,"
                 COL_UID" VARCHAR NOT NULL,"
+                COL_INFORMALL" INT NOT NULL DEFAULT 0,"
                 COL_DEBUG_DUMP_PATH" VARCHAR NOT NULL,"
                 COL_COUNT" INT NOT NULL DEFAULT 1,"
                 COL_REPORTED" INT NOT NULL DEFAULT 0,"
@@ -366,82 +408,83 @@ void CSQLite3::Connect()
     }
 }
 
-void CSQLite3::Insert_or_Update(const char *pUUID,
-                const char *pUID,
+void CSQLite3::Insert_or_Update(const char *crash_id,
+                bool inform_all_users,
                 const char *pDebugDumpPath,
                 const char *pTime)
 {
-    if (!is_string_safe(pUUID)
-     || !is_string_safe(pUID)
+    const char *UUID = strchr(crash_id, ':');
+    if (!UUID
+     || !is_string_safe(crash_id)
      || !is_string_safe(pDebugDumpPath)
      || !is_string_safe(pTime)
     ) {
         return;
     }
 
-    if (!exists_uuid_uid(m_pDB, pUUID, pUID))
+    /* Split crash_id into UID:UUID */
+    unsigned uid_len = UUID - crash_id;
+    UUID++;
+    char UID[uid_len + 1];
+    strncpy(UID, crash_id, uid_len);
+    UID[uid_len] = '\0';
+
+    if (!exists_uuid_uid(m_pDB, UUID, UID))
     {
         execute_sql(m_pDB,
                 "INSERT INTO "ABRT_TABLE" ("
                 COL_UUID","
                 COL_UID","
+                COL_INFORMALL","
                 COL_DEBUG_DUMP_PATH","
                 COL_TIME
                 ")"
-                " VALUES ('%s','%s','%s','%s');",
-                pUUID, pUID, pDebugDumpPath, pTime
+                " VALUES ('%s','%s',%u,'%s','%s');",
+                UUID, UID, (unsigned)inform_all_users, pDebugDumpPath, pTime
         );
     }
     else
     {
         execute_sql(m_pDB,
-                "UPDATE "ABRT_TABLE" SET "
-                COL_COUNT" = "COL_COUNT" + 1, "
-                COL_TIME" = '%s'"
-                " WHERE "COL_UUID" = '%s'"
-                    " AND "COL_UID" = '%s';",
-                pTime, pUUID, pUID
+                "UPDATE "ABRT_TABLE
+                " SET "COL_COUNT"="COL_COUNT"+1,"COL_TIME"='%s'"
+                " WHERE "COL_UUID"='%s' AND "COL_UID"='%s';",
+                pTime,
+                UUID, UID
         );
     }
 }
 
-void CSQLite3::DeleteRow(const char *pUUID, const char *pUID)
+void CSQLite3::DeleteRow(const char *crash_id)
 {
-    if (!is_string_safe(pUUID)
-     || !is_string_safe(pUID)
+    const char *UUID = strchr(crash_id, ':');
+    if (!UUID
+     || !is_string_safe(crash_id)
     ) {
         return;
     }
 
-    if (pUID[0] == '0' && !pUID[1])
-    {
-        execute_sql(m_pDB,
-                "DELETE FROM "ABRT_TABLE" "
-                "WHERE "COL_UUID" = '%s';",
-                pUUID
-        );
-        execute_sql(m_pDB,
-                "DELETE FROM "ABRT_REPRESULT_TABLE" "
-                "WHERE "COL_UUID" = '%s';",
-                pUUID
-        );
-    }
-    else if (exists_uuid_uid(m_pDB, pUUID, pUID))
+    /* Split crash_id into UID:UUID */
+    unsigned uid_len = UUID - crash_id;
+    UUID++;
+    char UID[uid_len + 1];
+    strncpy(UID, crash_id, uid_len);
+    UID[uid_len] = '\0';
+
+    if (exists_uuid_uid(m_pDB, UUID, UID))
     {
-        execute_sql(m_pDB, "DELETE FROM "ABRT_TABLE" "
-                "WHERE "COL_UUID" = '%s' "
-                "AND ("COL_UID" = '%s' OR "COL_UID" = '-1');",
-                pUUID, pUID
+        execute_sql(m_pDB, "DELETE FROM "ABRT_TABLE
+                " WHERE "COL_UUID"='%s' AND "COL_UID"='%s';",
+                UUID, UID
         );
-        execute_sql(m_pDB, "DELETE FROM "ABRT_REPRESULT_TABLE" "
-                "WHERE "COL_UUID" = '%s' "
-                "AND ("COL_UID" = '%s' OR "COL_UID" = '-1');",
-                pUUID, pUID
+        execute_sql(m_pDB, "DELETE FROM "ABRT_REPRESULT_TABLE
+                " WHERE "COL_UUID"='%s' AND "COL_UID"='%s';",
+                UUID, UID
         );
     }
     else
     {
-        error_msg("UUID,UID %s,%s is not found in DB", pUUID, pUID);
+        error_msg("crash_id %s is not found in DB", crash_id);
     }
 }
 
@@ -455,8 +498,8 @@ void CSQLite3::DeleteRows_by_dir(const char *dump_dir)
     /* Get UID:UUID pair(s) to delete */
     vector_database_rows_t table;
     get_table(table, m_pDB,
-                "SELECT * FROM "ABRT_TABLE" "
-                "WHERE "COL_DEBUG_DUMP_PATH" = '%s'",
+                "SELECT * FROM "ABRT_TABLE
+                " WHERE "COL_DEBUG_DUMP_PATH"='%s';",
                 dump_dir
     );
     if (table.empty())
@@ -469,84 +512,82 @@ void CSQLite3::DeleteRows_by_dir(const char *dump_dir)
     while (it != table.end())
     {
         execute_sql(m_pDB,
-                "DELETE FROM "ABRT_REPRESULT_TABLE" "
-                "WHERE "COL_UUID" = '%s' "
-                "AND ("COL_UID" = '%s');",
+                "DELETE FROM "ABRT_REPRESULT_TABLE
+                " WHERE "COL_UUID"='%s' AND "COL_UID"='%s';",
                 it->m_sUUID.c_str(), it->m_sUID.c_str()
         );
     }
     execute_sql(m_pDB,
-                "DELETE FROM "ABRT_TABLE" "
-                "WHERE "COL_DEBUG_DUMP_PATH" = '%s'",
+                "DELETE FROM "ABRT_TABLE
+                " WHERE "COL_DEBUG_DUMP_PATH"='%s'",
                 dump_dir
     );
 }
 
-void CSQLite3::SetReported(const char *pUUID, const char *pUID, const char *pMessage)
+void CSQLite3::SetReported(const char *crash_id, const char *pMessage)
 {
-    if (!is_string_safe(pUUID)
-     || !is_string_safe(pUID)
+    const char *UUID = strchr(crash_id, ':');
+    if (!UUID
+     || !is_string_safe(crash_id)
      || !is_string_safe(pMessage)
     ) {
         return;
     }
 
-    if (pUID[0] == '0' && !pUID[1])
-    {
-        execute_sql(m_pDB,
-                "UPDATE "ABRT_TABLE" "
-                "SET "COL_REPORTED" = 1 "
-                "WHERE "COL_UUID" = '%s';",
-                pUUID
-        );
-        execute_sql(m_pDB, "UPDATE "ABRT_TABLE" "
-                "SET "COL_MESSAGE" = '%s' "
-                "WHERE "COL_UUID" = '%s';",
-                pMessage, pUUID
-        );
-    }
-    else if (exists_uuid_uid(m_pDB, pUUID, pUID))
+    /* Split crash_id into UID:UUID */
+    unsigned uid_len = UUID - crash_id;
+    UUID++;
+    char UID[uid_len + 1];
+    strncpy(UID, crash_id, uid_len);
+    UID[uid_len] = '\0';
+
+    if (exists_uuid_uid(m_pDB, UUID, UID))
     {
         execute_sql(m_pDB,
-                "UPDATE "ABRT_TABLE" "
-                "SET "COL_REPORTED" = 1 "
-                "WHERE "COL_UUID" = '%s' "
-                "AND ("COL_UID" = '%s' OR "COL_UID" = '-1');",
-                pUUID, pUID
+                "UPDATE "ABRT_TABLE
+                " SET "COL_REPORTED"=1"
+                " WHERE "COL_UUID"='%s' AND "COL_UID"='%s';",
+                UUID, UID
         );
         execute_sql(m_pDB,
-                "UPDATE "ABRT_TABLE" "
-                "SET "COL_MESSAGE" = '%s' "
-                "WHERE "COL_UUID" = '%s' "
-                "AND ("COL_UID" = '%s' OR "COL_UID" = '-1');",
-                pMessage, pUUID, pUID
+                "UPDATE "ABRT_TABLE
+                " SET "COL_MESSAGE"='%s'"
+                " WHERE "COL_UUID"='%s' AND "COL_UID"='%s';",
+                pMessage, UUID, UID
         );
     }
     else
     {
-        error_msg("UUID,UID %s,%s is not found in DB", pUUID, pUID);
+        error_msg("crash_id %s is not found in DB", crash_id);
     }
 }
 
-void CSQLite3::SetReportedPerReporter(const char *pUUID,
-                                 const char *pUID,
+void CSQLite3::SetReportedPerReporter(const char *crash_id,
                                  const char *reporter,
                                  const char *pMessage)
 {
-    if (!is_string_safe(pUUID)
-     || !is_string_safe(pUID)
+    const char *UUID = strchr(crash_id, ':');
+    if (!UUID
+     || !is_string_safe(crash_id)
      || !is_string_safe(reporter)
      || !is_string_safe(pMessage)
     ) {
         return;
     }
 
+    /* Split crash_id into UID:UUID */
+    unsigned uid_len = UUID - crash_id;
+    UUID++;
+    char UID[uid_len + 1];
+    strncpy(UID, crash_id, uid_len);
+    UID[uid_len] = '\0';
+
     int affected_rows = execute_sql(m_pDB,
                 "UPDATE "ABRT_REPRESULT_TABLE
                 " SET "COL_MESSAGE"='%s'"
                 " WHERE "COL_UUID"='%s' AND "COL_UID"='%s' AND "COL_REPORTER"='%s'",
                 pMessage,
-                pUUID, pUID, reporter
+                UUID, UID, reporter
     );
     if (!affected_rows)
     {
@@ -554,21 +595,16 @@ void CSQLite3::SetReportedPerReporter(const char *pUUID,
                 "INSERT INTO "ABRT_REPRESULT_TABLE
                 " ("COL_UUID","COL_UID","COL_REPORTER","COL_MESSAGE")"
                 " VALUES ('%s','%s','%s','%s');",
-                pUUID, pUID, reporter, pMessage
+                UUID, UID, reporter, pMessage
 	);
     }
 }
 
-vector_database_rows_t CSQLite3::GetUIDData(const char *pUID)
+vector_database_rows_t CSQLite3::GetUIDData(long caller_uid)
 {
     vector_database_rows_t table;
 
-    if (!is_string_safe(pUID))
-    {
-        return table;
-    }
-
-    if (pUID[0] == '0' && !pUID[1])
+    if (caller_uid == 0)
     {
         get_table(table, m_pDB, "SELECT * FROM "ABRT_TABLE";");
     }
@@ -576,40 +612,35 @@ vector_database_rows_t CSQLite3::GetUIDData(const char *pUID)
     {
         get_table(table, m_pDB,
                 "SELECT * FROM "ABRT_TABLE
-                " WHERE "COL_UID" = '%s' OR "COL_UID" = '-1';",
-                pUID
+                " WHERE "COL_UID"='%ld' OR "COL_INFORMALL"=1;",
+                caller_uid
         );
     }
     return table;
 }
 
-database_row_t CSQLite3::GetRow(const char *pUUID, const char *pUID)
+database_row_t CSQLite3::GetRow(const char *crash_id)
 {
-    if (!is_string_safe(pUUID)
-     || !is_string_safe(pUID)
+    const char *UUID = strchr(crash_id, ':');
+    if (!UUID
+     || !is_string_safe(crash_id)
     ) {
         return database_row_t();
     }
 
-    vector_database_rows_t table;
+    /* Split crash_id into UID:UUID */
+    unsigned uid_len = UUID - crash_id;
+    UUID++;
+    char UID[uid_len + 1];
+    strncpy(UID, crash_id, uid_len);
+    UID[uid_len] = '\0';
 
-    if (pUID[0] == '0' && !pUID[1])
-    {
-        get_table(table, m_pDB,
-                "SELECT * FROM "ABRT_TABLE" "
-                "WHERE "COL_UUID" = '%s';",
-                pUUID
-        );
-    }
-    else
-    {
-        get_table(table, m_pDB,
-                "SELECT * FROM "ABRT_TABLE" "
-                "WHERE "COL_UUID" = '%s' "
-                "AND ("COL_UID" = '%s' OR "COL_UID" = '-1');",
-                pUUID, pUID
-        );
-    }
+    vector_database_rows_t table;
+    get_table(table, m_pDB,
+                "SELECT * FROM "ABRT_TABLE
+                " WHERE "COL_UUID"='%s' AND "COL_UID"='%s';",
+                UUID, UID
+    );
 
     if (table.size() == 0)
     {
diff --git a/lib/Plugins/SQLite3.h b/lib/Plugins/SQLite3.h
index 94cb0422..b9dc9e7f 100644
--- a/lib/Plugins/SQLite3.h
+++ b/lib/Plugins/SQLite3.h
@@ -37,20 +37,18 @@ class CSQLite3 : public CDatabase
         virtual void Connect();
         virtual void DisConnect();
 
-        virtual void Insert_or_Update(const char *pUUID,
-                        const char *pUID,
+        virtual void Insert_or_Update(const char *crash_id,
+                        bool inform_all_users,
                         const char *pDebugDumpPath,
                         const char *pTime);
-
-        virtual void DeleteRow(const char *pUUID, const char *pUID);
+        virtual void DeleteRow(const char *crash_id);
         virtual void DeleteRows_by_dir(const char *dump_dir);
-        virtual void SetReported(const char *pUUID, const char *pUID, const char *pMessage);
-        virtual void SetReportedPerReporter(const char *pUUID,
-                                 const char *pUID,
+        virtual void SetReported(const char *crash_id, const char *pMessage);
+        virtual void SetReportedPerReporter(const char *crash_id,
                                  const char *reporter,
                                  const char *pMessage);
-        virtual vector_database_rows_t GetUIDData(const char *pUID);
-        virtual database_row_t GetRow(const char *pUUID, const char *pUID);
+        virtual vector_database_rows_t GetUIDData(long caller_uid);
+        virtual database_row_t GetRow(const char *crash_id);
 
         virtual void SetSettings(const map_plugin_settings_t& pSettings);
 };
diff --git a/lib/Utils/CommLayerInner.cpp b/lib/Utils/CommLayerInner.cpp
index bde3a71c..9512019d 100644
--- a/lib/Utils/CommLayerInner.cpp
+++ b/lib/Utils/CommLayerInner.cpp
@@ -42,7 +42,7 @@ static void warn_client(const char *msg)
     pthread_mutex_unlock(&s_map_mutex);
 
     if (peer)
-        s_pObs->Warning(msg, peer, key);
+        s_pObs->Warning(msg, peer);
 }
 
 void init_daemon_logging(CObserver *pObs)
@@ -89,6 +89,6 @@ void update_client(const char *fmt, ...)
     char *msg = xvasprintf(fmt, p);
     va_end(p);
 
-    s_pObs->Status(msg, peer, key);
+    s_pObs->Status(msg, peer);
     free(msg);
 }
diff --git a/lib/Utils/Database.h b/lib/Utils/Database.h
index 6d7613bb..a698bcbc 100644
--- a/lib/Utils/Database.h
+++ b/lib/Utils/Database.h
@@ -40,6 +40,7 @@ typedef struct database_row_t
 {
     std::string m_sUUID; /**< A local UUID.*/
     std::string m_sUID; /**< An UID of an user.*/
+    std::string m_sInformAll;
     std::string m_sDebugDumpDir; /**< A debugdump directory of a crash.*/
     std::string m_sCount; /**< Crash rate.*/
     std::string m_sReported; /**< Is a row reported?*/
@@ -73,8 +74,8 @@ class CDatabase : public CPlugin
          * @param pDebugDumpPath A debugdump path.
          * @param pTime Time when a crash occurs.
          */
-        virtual void Insert_or_Update(const char *pUUID,
-                        const char *pUID,
+        virtual void Insert_or_Update(const char *crash_id,
+                        bool inform_all_users,
                         const char *pDebugDumpPath,
                         const char *pTime) = 0;
         /**
@@ -82,8 +83,7 @@ class CDatabase : public CPlugin
          * @param pUUID A lodal UUID of a crash.
          * @param pUID An UID of an user.
          */
-        virtual void DeleteRow(const char *pUUID,
-                            const char *pUID) = 0;
+        virtual void DeleteRow(const char *crash_id) = 0;
         virtual void DeleteRows_by_dir(const char *dump_dir) = 0;
         /**
          * A method, which sets that particular row was reported.
@@ -92,11 +92,9 @@ class CDatabase : public CPlugin
          * @param pMessage A text explanation of reported problem
          * (where it is stored etc)...
          */
-        virtual void SetReported(const char *pUUID,
-                                 const char *pUID,
+        virtual void SetReported(const char *crash_id,
                                  const char *pMessage) = 0;
-        virtual void SetReportedPerReporter(const char *pUUID,
-                                 const char *pUID,
+        virtual void SetReportedPerReporter(const char *crash_id,
                                  const char *reporter,
                                  const char *pMessage) = 0;
         /**
@@ -106,7 +104,7 @@ class CDatabase : public CPlugin
          * @param pUID An UID of an user.
          * @return A vector of matched rows.
          */
-        virtual vector_database_rows_t GetUIDData(const char *pUID) = 0;
+        virtual vector_database_rows_t GetUIDData(long caller_uid) = 0;
         /**
          * A method, which returns one row accordind to UUID of a crash and
          * UID of an user. If there are no row, empty row is returned.
@@ -114,8 +112,7 @@ class CDatabase : public CPlugin
          * @param pUID An UID of an user.
          * @return A matched row.
          */
-        virtual database_row_t GetRow(const char *pUUID,
-                                                 const char *pUID) = 0;
+        virtual database_row_t GetRow(const char *crash_id) = 0;
 };
 
 #endif
diff --git a/lib/Utils/DebugDump.cpp b/lib/Utils/DebugDump.cpp
index b8f8827c..97c387c5 100644
--- a/lib/Utils/DebugDump.cpp
+++ b/lib/Utils/DebugDump.cpp
@@ -319,7 +319,7 @@ void CDebugDump::Create(const char *pDir, uid_t uid)
 		   (long)m_uid, (long)m_gid);
     }
 
-    SaveText(FILENAME_UID, to_string(uid).c_str());
+    SaveText(CD_UID, to_string(uid).c_str());
     SaveKernelArchitectureRelease();
     time_t t = time(NULL);
     SaveText(FILENAME_TIME, to_string(t).c_str());
diff --git a/lib/Utils/Observer.h b/lib/Utils/Observer.h
index adf6844a..ec7dfa7b 100644
--- a/lib/Utils/Observer.h
+++ b/lib/Utils/Observer.h
@@ -26,8 +26,8 @@
 class CObserver {
     public:
         virtual ~CObserver() {}
-        virtual void Status(const char *pMessage, const char* peer, uint64_t pDest) = 0;
-        virtual void Warning(const char *pMessage, const char* peer, uint64_t pDest) = 0;
+        virtual void Status(const char *pMessage, const char* peer) = 0;
+        virtual void Warning(const char *pMessage, const char* peer) = 0;
 };
 
 #endif
diff --git a/lib/Utils/make_descr.cpp b/lib/Utils/make_descr.cpp
index 80198965..a2f0c034 100644
--- a/lib/Utils/make_descr.cpp
+++ b/lib/Utils/make_descr.cpp
@@ -68,14 +68,16 @@ static void add_content(bool &was_multiline, string& description, const char *he
     }
 }
 
+/* Items we don't want to include */
 static const char *const blacklisted_items_bz[] = {
     FILENAME_TIME     ,
-    FILENAME_UID      ,
     FILENAME_ANALYZER ,
     FILENAME_COREDUMP ,
     FILENAME_DESCRIPTION, /* package description - basically useless */
-    CD_DUPHASH        ,
+    CD_UID            ,
     CD_UUID           ,
+    CD_INFORMALL      ,
+    CD_DUPHASH        ,
     CD_DUMPDIR        ,
     CD_COUNT          ,
     CD_REPORTED       ,
diff --git a/lib/Utils/test.cpp b/lib/Utils/test.cpp
index 24a62760..35edb0c5 100644
--- a/lib/Utils/test.cpp
+++ b/lib/Utils/test.cpp
@@ -92,7 +92,7 @@ int main(int argc, char** argv)
              */
             map_crash_data_t crashReport;
             middleWare.CreateCrashReport(crashInfo[CD_DUPHASH][CD_CONTENT],
-                                         crashInfo[FILENAME_UID][CD_CONTENT],
+                                         crashInfo[CD_UID][CD_CONTENT],
                                          crashReport);
             /* Report crash */
             middleWare.Report(crashReport);