#ifndef LIGHTNING_LIGHTNINGD_DAEMON_CONN_H
#define LIGHTNING_LIGHTNINGD_DAEMON_CONN_H

#include "config.h"
#include <ccan/io/io.h>
#include <ccan/short_types/short_types.h>
#include <lightningd/msg_queue.h>

struct daemon_conn {
	/* Context to tallocate all things from, possibly the
	 * container of this connection. */
	tal_t *ctx;

	/* Last message we received */
	u8 *msg_in;

	/* Queue of outgoing messages */
	struct msg_queue out;

	/* Underlying connection */
	struct io_conn *conn;

	/* Callback for incoming messages */
	struct io_plan *(*daemon_conn_recv)(struct io_conn *conn,
					    struct daemon_conn *);

	/* Called whenever we've cleared the msg_out queue. Used to
	 * inject things into the write loop */
	struct io_plan *(*msg_queue_cleared_cb)(struct io_conn *conn,
						struct daemon_conn *);
};

/**
 * daemon_conn_init - Initialize a new daemon connection
 *
 * @ctx: context to allocate from
 * @dc: daemon_conn to initialize
 * @fd: socket file descriptor to wrap
 * @daemon_conn_recv: callback function to be called upon receiving a message
 */
void daemon_conn_init(tal_t *ctx, struct daemon_conn *dc, int fd,
		      struct io_plan *(*daemon_conn_recv)(
			  struct io_conn *, struct daemon_conn *));
/**
 * daemon_conn_send - Enqueue an outgoing message to be sent
 */
void daemon_conn_send(struct daemon_conn *dc, const u8 *msg);

/**
 * daemon_conn_send_fd - Enqueue a file descriptor to be sent (closed after)
 */
void daemon_conn_send_fd(struct daemon_conn *dc, int fd);

/**
 * daemon_conn_write_next - Continue writing from the msg-queue
 *
 * Exposed here so that, if `msg_queue_cleared_cb` is used to break
 * out of the write-loop, we can get back in.
 */
struct io_plan *daemon_conn_write_next(struct io_conn *conn,
				       struct daemon_conn *dc);

/**
 * daemon_conn_read_next - Read the next message
 */
struct io_plan *daemon_conn_read_next(struct io_conn *conn,
				      struct daemon_conn *dc);

/**
 * daemon_conn_sync_flush - Flush connection by sending all messages now..
 */
bool daemon_conn_sync_flush(struct daemon_conn *dc);
#endif /* LIGHTNING_LIGHTNINGD_DAEMON_CONN_H */