/*
 * Copyright (c) 2022 Trackunit Corporation
 *
 * SPDX-License-Identifier: Apache-2.0
 */

#include <zephyr/modem/pipe.h>
#include <zephyr/kernel.h>
#include <zephyr/sys/ring_buffer.h>

#ifndef ZEPHYR_DRIVERS_MODEM_MODEM_PIPE_MOCK
#define ZEPHYR_DRIVERS_MODEM_MODEM_PIPE_MOCK

struct modem_backend_mock_transaction {
	/* Get data which will trigger put */
	const uint8_t *get;
	size_t get_size;

	/* Data which will be put in response to get data */
	const uint8_t *put;
	size_t put_size;
};

struct modem_backend_mock {
	struct modem_pipe pipe;

	struct ring_buf rx_rb;
	struct ring_buf tx_rb;

	struct k_work receive_ready_work;
	struct k_work transmit_idle_work;

	const struct modem_backend_mock_transaction *transaction;
	size_t transaction_match_cnt;

	/* Max allowed read/write size */
	size_t limit;
	/* Mock Brige pair */
	struct modem_backend_mock *bridge;
};

struct modem_backend_mock_config {
	uint8_t *rx_buf;
	size_t rx_buf_size;
	uint8_t *tx_buf;
	size_t tx_buf_size;
	size_t limit;
};

struct modem_pipe *modem_backend_mock_init(struct modem_backend_mock *mock,
					   const struct modem_backend_mock_config *config);

void modem_backend_mock_reset(struct modem_backend_mock *mock);

int modem_backend_mock_get(struct modem_backend_mock *mock, uint8_t *buf, size_t size);

void modem_backend_mock_put(struct modem_backend_mock *mock, const uint8_t *buf, size_t size);

void modem_backend_mock_prime(struct modem_backend_mock *mock,
			      const struct modem_backend_mock_transaction *transaction);

void modem_backend_mock_bridge(struct modem_backend_mock *mock_a,
			       struct modem_backend_mock *mock_b);

#endif /* ZEPHYR_DRIVERS_MODEM_MODEM_PIPE_MOCK */