#ifndef __DP_BACKEND_H__

#define __DP_BACKEND_H__

#include "providers/data_provider.h"

#include "providers/fail_over.h"

#include "util/child_common.h"

#include "db/sysdb.h"

#define BE_SRV_IDENTIFIER "_srv_"

struct be_ctx;

struct bet_ops;

struct be_req;

typedef int (*bet_init_fn_t)(TALLOC_CTX *, struct bet_ops **, void **);

typedef void (*be_shutdown_fn)(void *);

typedef void (*be_req_fn_t)(struct be_req *);

typedef void (*be_async_callback_t)(struct be_req *, int, int, const char *);

typedef void (*be_callback_t)(void *);

enum bet_type {

BET_NULL = 0,

BET_ID,

BET_AUTH,

BET_ACCESS,

BET_CHPASS,

BET_SUDO,

BET_MAX

};

struct bet_data {

enum bet_type bet_type;

const char *option_name;

const char *mod_init_fn_name_fmt;

};

struct loaded_be {

char *be_name;

void *handle;

};

struct bet_info {

enum bet_type bet_type;

struct bet_ops *bet_ops;

void *pvt_bet_data;

char *mod_name;

};

struct be_offline_status {

time_t went_offline;

bool offline;

};

struct be_client {

struct be_ctx *bectx;

struct sbus_connection *conn;

struct tevent_timer *timeout;

bool initialized;

};

struct be_failover_ctx;

struct be_cb;

struct be_ctx {

struct tevent_context *ev;

struct confdb_ctx *cdb;

struct sysdb_ctx *sysdb;

struct sss_domain_info *domain;

const char *identity;

const char *conf_path;

struct be_failover_ctx *be_fo;

struct sss_sigchild_ctx *sigchld_ctx;

/* Functions to be invoked when the

struct be_cb *online_cb_list;

bool run_online_cb;

struct be_cb *offline_cb_list;

struct be_offline_status offstat;

struct sbus_connection *mon_conn;

struct sbus_connection *sbus_srv;

struct be_client *nss_cli;

struct be_client *pam_cli;

struct be_client *sudo_cli;

struct loaded_be loaded_be[BET_MAX];

struct bet_info bet_info[BET_MAX];

size_t check_online_ref_count;

};

struct bet_ops {

be_req_fn_t check_online;

be_req_fn_t handler;

be_req_fn_t finalize;

};

#define MAX_BE_REQ_RESTARTS 2

struct be_req {

struct be_client *becli;

struct be_ctx *be_ctx;

void *req_data;

be_async_callback_t fn;

void *pvt;

int restarts;

};

struct be_acct_req {

int entry_type;

int attr_type;

int filter_type;

char *filter_value;

char *extra_value;

};

struct be_sudo_req {

uint32_t type;

char *username;

uid_t uid;

char **groups;

};

bool be_is_offline(struct be_ctx *ctx);

void be_mark_offline(struct be_ctx *ctx);

int be_add_online_cb(TALLOC_CTX *mem_ctx,

struct be_ctx *ctx,

be_callback_t cb,

void *pvt,

struct be_cb **online_cb);

void be_run_online_cb(struct be_ctx *be);

int be_add_offline_cb(TALLOC_CTX *mem_ctx,

struct be_ctx *ctx,

be_callback_t cb,

void *pvt,

struct be_cb **online_cb);

void be_run_offline_cb(struct be_ctx *be);

enum be_fo_protocol {

BE_FO_PROTO_TCP,

BE_FO_PROTO_UDP,

BE_FO_PROTO_SENTINEL

};

typedef void (be_svc_callback_fn_t)(void *, struct fo_server *);

int be_init_failover(struct be_ctx *ctx);

int be_fo_is_srv_identifier(const char *server);

int be_fo_add_service(struct be_ctx *ctx, const char *service_name);

int be_fo_service_add_callback(TALLOC_CTX *memctx,

struct be_ctx *ctx, const char *service_name,

be_svc_callback_fn_t *fn, void *private_data);

int be_fo_get_server_count(struct be_ctx *ctx, const char *service_name);

int be_fo_add_srv_server(struct be_ctx *ctx, const char *service_name,

const char *query_service, enum be_fo_protocol proto,

bool proto_fallback, void *user_data);

int be_fo_add_server(struct be_ctx *ctx, const char *service_name,

const char *server, int port, void *user_data);

struct tevent_req *be_resolve_server_send(TALLOC_CTX *memctx,

struct tevent_context *ev,

struct be_ctx *ctx,

const char *service_name);

int be_resolve_server_recv(struct tevent_req *req, struct fo_server **srv);

void be_fo_try_next_server(struct be_ctx *ctx, const char *service_name);

int be_fo_run_callbacks_at_next_request(struct be_ctx *ctx,

const char *service_name);

void reset_fo(struct be_ctx *be_ctx);

#endif /* __DP_BACKEND_H___ */