#pragma once

#include "sd-event.h"

#include "sd-bus.h"

#include "hashmap.h"

#include "time-util.h"

#include "util.h"

typedef enum BusTransport {

BUS_TRANSPORT_LOCAL,

BUS_TRANSPORT_REMOTE,

BUS_TRANSPORT_CONTAINER,

_BUS_TRANSPORT_MAX,

_BUS_TRANSPORT_INVALID = -1

} BusTransport;

typedef int (*bus_property_set_t) (sd_bus *bus, const char *member, sd_bus_message *m, sd_bus_error *error, void *userdata);

struct bus_properties_map {

const char *member;

const char *signature;

bus_property_set_t set;

size_t offset;

};

int bus_map_id128(sd_bus *bus, const char *member, sd_bus_message *m, sd_bus_error *error, void *userdata);

int bus_map_all_properties(sd_bus *bus,

const char *destination,

const char *path,

const struct bus_properties_map *map,

void *userdata);

int bus_async_unregister_and_exit(sd_event *e, sd_bus *bus, const char *name);

typedef bool (*check_idle_t)(void *userdata);

int bus_event_loop_with_idle(sd_event *e, sd_bus *bus, const char *name, usec_t timeout, check_idle_t check_idle, void *userdata);

int bus_name_has_owner(sd_bus *c, const char *name, sd_bus_error *error);

int bus_check_peercred(sd_bus *c);

int bus_verify_polkit(sd_bus *bus, sd_bus_message *m, const char *action, bool interactive, bool *_challenge, sd_bus_error *e);

int bus_verify_polkit_async(sd_bus *bus, Hashmap **registry, sd_bus_message *m, const char *action, bool interactive, sd_bus_error *error, sd_bus_message_handler_t callback, void *userdata);

void bus_verify_polkit_async_registry_free(sd_bus *bus, Hashmap *registry);

int bus_open_system_systemd(sd_bus **_bus);

int bus_open_user_systemd(sd_bus **_bus);

int bus_open_transport(BusTransport transport, const char *host, bool user, sd_bus **bus);

int bus_open_transport_systemd(BusTransport transport, const char *host, bool user, sd_bus **bus);

int bus_print_property(const char *name, sd_bus_message *property, bool all);

int bus_print_all_properties(sd_bus *bus, const char *dest, const char *path, char **filter, bool all);

int bus_property_get_bool(sd_bus *bus, const char *path, const char *interface, const char *property, sd_bus_message *reply, void *userdata, sd_bus_error *error);

#define bus_property_get_usec ((sd_bus_property_get_t) NULL)

#define bus_property_set_usec ((sd_bus_property_set_t) NULL)

assert_cc(sizeof(int) == sizeof(int32_t));

#define bus_property_get_int ((sd_bus_property_get_t) NULL)

assert_cc(sizeof(unsigned) == sizeof(unsigned));

#define bus_property_get_unsigned ((sd_bus_property_get_t) NULL)

#if __SIZEOF_SIZE_T__ == 8

#define bus_property_get_size ((sd_bus_property_get_t) NULL)

#else

int bus_property_get_size(sd_bus *bus, const char *path, const char *interface, const char *property, sd_bus_message *reply, void *userdata, sd_bus_error *error);

#endif

#if __SIZEOF_LONG__ == 8

#define bus_property_get_long ((sd_bus_property_get_t) NULL)

#define bus_property_get_ulong ((sd_bus_property_get_t) NULL)

#else

int bus_property_get_long(sd_bus *bus, const char *path, const char *interface, const char *property, sd_bus_message *reply, void *userdata, sd_bus_error *error);

int bus_property_get_ulong(sd_bus *bus, const char *path, const char *interface, const char *property, sd_bus_message *reply, void *userdata, sd_bus_error *error);

#endif

assert_cc(sizeof(uid_t) == sizeof(uint32_t));

#define bus_property_get_uid ((sd_bus_property_get_t) NULL)

assert_cc(sizeof(gid_t) == sizeof(uint32_t));

#define bus_property_get_gid ((sd_bus_property_get_t) NULL)

assert_cc(sizeof(pid_t) == sizeof(uint32_t));

#define bus_property_get_pid ((sd_bus_property_get_t) NULL)

assert_cc(sizeof(mode_t) == sizeof(uint32_t));

#define bus_property_get_mode ((sd_bus_property_get_t) NULL)

int bus_log_parse_error(int r);

int bus_log_create_error(int r);

typedef struct UnitInfo {

const char *machine;

const char *id;

const char *description;

const char *load_state;

const char *active_state;

const char *sub_state;

const char *following;

const char *unit_path;

uint32_t job_id;

const char *job_type;

const char *job_path;

} UnitInfo;

int bus_parse_unit_info(sd_bus_message *message, UnitInfo *u);

static inline void sd_bus_close_unrefp(sd_bus **bus) {

if (*bus) {

sd_bus_flush(*bus);

sd_bus_close(*bus);

sd_bus_unref(*bus);

}

}

DEFINE_TRIVIAL_CLEANUP_FUNC(sd_bus*, sd_bus_unref);

DEFINE_TRIVIAL_CLEANUP_FUNC(sd_bus_slot*, sd_bus_slot_unref);

DEFINE_TRIVIAL_CLEANUP_FUNC(sd_bus_message*, sd_bus_message_unref);

DEFINE_TRIVIAL_CLEANUP_FUNC(sd_bus_creds*, sd_bus_creds_unref);

DEFINE_TRIVIAL_CLEANUP_FUNC(sd_bus_track*, sd_bus_track_unref);

#define _cleanup_bus_unref_ _cleanup_(sd_bus_unrefp)

#define _cleanup_bus_close_unref_ _cleanup_(sd_bus_close_unrefp)

#define _cleanup_bus_slot_unref_ _cleanup_(sd_bus_slot_unrefp)

#define _cleanup_bus_message_unref_ _cleanup_(sd_bus_message_unrefp)

#define _cleanup_bus_creds_unref_ _cleanup_(sd_bus_creds_unrefp)

#define _cleanup_bus_track_unref_ _cleanup_(sd_bus_slot_unrefp)

#define _cleanup_bus_error_free_ _cleanup_(sd_bus_error_free)

#define BUS_DEFINE_PROPERTY_GET_ENUM(function, name, type) \

int function(sd_bus *bus, \

const char *path, \

const char *interface, \

const char *property, \

sd_bus_message *reply, \

void *userdata, \

sd_bus_error *error) { \

\

const char *value; \

type *field = userdata; \

int r; \

\

assert(bus); \

assert(reply); \

assert(field); \

\

value = strempty(name##_to_string(*field)); \

\

r = sd_bus_message_append_basic(reply, 's', value); \

if (r < 0) \

return r; \

\

return 1; \

} \

struct __useless_struct_to_allow_trailing_semicolon__

#define BUS_PROPERTY_DUAL_TIMESTAMP(name, offset, flags) \

SD_BUS_PROPERTY(name, "t", bus_property_get_usec, (offset) + offsetof(struct dual_timestamp, realtime), (flags)), \

SD_BUS_PROPERTY(name "Monotonic", "t", bus_property_get_usec, (offset) + offsetof(struct dual_timestamp, monotonic), (flags))

int bus_maybe_reply_error(sd_bus_message *m, int r, sd_bus_error *error);

int bus_append_unit_property_assignment(sd_bus_message *m, const char *assignment);