src/libsystemd-bus/test-bus-marshal.c

   1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
   2
   3 /***
   4   This file is part of systemd.
   5
   6   Copyright 2013 Lennart Poettering
   7
   8   systemd is free software; you can redistribute it and/or modify it
   9   under the terms of the GNU Lesser General Public License as published by
  10   the Free Software Foundation; either version 2.1 of the License, or
  11   (at your option) any later version.
  12
  13   systemd is distributed in the hope that it will be useful, but
  14   WITHOUT ANY WARRANTY; without even the implied warranty of
  15   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  16   Lesser General Public License for more details.
  17
  18   You should have received a copy of the GNU Lesser General Public License
  19   along with systemd; If not, see <http://www.gnu.org/licenses/>.
  20 ***/
  21
  22 #include <assert.h>
  23 #include <stdlib.h>
  24 #include <byteswap.h>
  25
  26 #ifdef HAVE_GLIB
  27 #include <gio/gio.h>
  28 #endif
  29
  30 #include <dbus.h>
  31
  32 #include "log.h"
  33 #include "util.h"
  34
  35 #include "sd-bus.h"
  36 #include "bus-message.h"
  37
  38 int main(int argc, char *argv[]) {
  39         _cleanup_bus_message_unref_ sd_bus_message *m = NULL;
  40         int r, boolean;
  41         const char *x, *y, *z, *a, *b, *c, *d;
  42         uint8_t u, v;
  43         void *buffer = NULL;
  44         size_t sz;
  45         char *h;
  46
  47         r = sd_bus_message_new_method_call(NULL, "foobar.waldo", "/", "foobar.waldo", "Piep", &m);
  48         assert_se(r >= 0);
  49
  50         r = sd_bus_message_append(m, "s", "a string");
  51         assert_se(r >= 0);
  52
  53         r = sd_bus_message_append(m, "s", NULL);
  54         assert_se(r < 0);
  55
  56         r = sd_bus_message_append(m, "as", 2, "string #1", "string #2");
  57         assert_se(r >= 0);
  58
  59         r = sd_bus_message_append(m, "sass", "foobar", 5, "foo", "bar", "waldo", "piep", "pap", "after");
  60         assert_se(r >= 0);
  61
  62         r = sd_bus_message_append(m, "a{yv}", 2, 3, "s", "foo", 5, "s", "waldo");
  63         assert_se(r >= 0);
  64
  65         r = sd_bus_message_append(m, "ba(ss)", 255, 3, "aaa", "1", "bbb", "2", "ccc", "3");
  66         assert_se(r >= 0);
  67
  68         r = sd_bus_message_open_container(m, 'a', "s");
  69         assert_se(r >= 0);
  70
  71         r = sd_bus_message_append_basic(m, 's', "foobar");
  72         assert_se(r >= 0);
  73
  74         r = sd_bus_message_append_basic(m, 's', "waldo");
  75         assert_se(r >= 0);
  76
  77         r = sd_bus_message_close_container(m);
  78         assert_se(r >= 0);
  79
  80         r = bus_message_seal(m, 4711);
  81         assert_se(r >= 0);
  82
  83         bus_message_dump(m);
  84
  85         r = bus_message_get_blob(m, &buffer, &sz);
  86         assert_se(r >= 0);
  87
  88         h = hexmem(buffer, sz);
  89         assert_se(h);
  90
  91         log_info("message size = %lu, contents =\n%s", (unsigned long) sz, h);
  92         free(h);
  93
  94 #ifdef HAVE_GLIB
  95         {
  96                 GDBusMessage *g;
  97                 char *p;
  98
  99                 g_type_init();
 100
 101                 g = g_dbus_message_new_from_blob(buffer, sz, 0, NULL);
 102                 p = g_dbus_message_print(g, 0);
 103                 log_info("%s", p);
 104                 g_free(p);
 105                 g_object_unref(g);
 106         }
 107 #endif
 108
 109         {
 110                 DBusMessage *w;
 111                 DBusError error;
 112
 113                 dbus_error_init(&error);
 114
 115                 w = dbus_message_demarshal(buffer, sz, &error);
 116                 if (!w) {
 117                         log_error("%s", error.message);
 118                 } else
 119                         dbus_message_unref(w);
 120         }
 121
 122         m = sd_bus_message_unref(m);
 123
 124         r = bus_message_from_malloc(buffer, sz, &m);
 125         assert_se(r >= 0);
 126
 127         bus_message_dump(m);
 128
 129         assert_se(sd_bus_message_rewind(m, true) >= 0);
 130
 131         r = sd_bus_message_read(m, "sas", &x, 2, &y, &z);
 132         assert_se(r > 0);
 133         assert_se(streq(x, "a string"));
 134         assert_se(streq(y, "string #1"));
 135         assert_se(streq(z, "string #2"));
 136
 137         r = sd_bus_message_read(m, "sass", &x, 5, &y, &z, &a, &b, &c, &d);
 138         assert_se(r > 0);
 139         assert_se(streq(x, "foobar"));
 140         assert_se(streq(y, "foo"));
 141         assert_se(streq(z, "bar"));
 142         assert_se(streq(a, "waldo"));
 143         assert_se(streq(b, "piep"));
 144         assert_se(streq(c, "pap"));
 145         assert_se(streq(d, "after"));
 146
 147         r = sd_bus_message_read(m, "a{yv}", 2, &u, "s", &x, &v, "s", &y);
 148         assert_se(r > 0);
 149         assert_se(u == 3);
 150         assert_se(streq(x, "foo"));
 151         assert_se(v == 5);
 152         assert_se(streq(y, "waldo"));
 153
 154         r = sd_bus_message_read(m, "ba(ss)", &boolean, 3, &x, &y, &a, &b, &c, &d);
 155         assert_se(r > 0);
 156         assert_se(boolean);
 157         assert_se(streq(x, "aaa"));
 158         assert_se(streq(y, "1"));
 159         assert_se(streq(a, "bbb"));
 160         assert_se(streq(b, "2"));
 161         assert_se(streq(c, "ccc"));
 162         assert_se(streq(d, "3"));
 163
 164         r = sd_bus_message_read(m, "as", 2, &x, &y);
 165         assert_se(r > 0);
 166         assert_se(streq(x, "foobar"));
 167         assert_se(streq(y, "waldo"));
 168
 169         r = sd_bus_message_peek_type(m, NULL, NULL);
 170         assert_se(r == 0);
 171
 172         return 0;
 173 }