8bb9bb67db
The emulator can be used for unit testing of LoRaWAN services. It provides interfaces to send arbitrary messages to the LoRaWAN stack and receive the response through callbacks without using actual LoRa hardware. Signed-off-by: Martin Jäger <martin@libre.solar>
159 lines
3 KiB
C
159 lines
3 KiB
C
/*
|
|
* Copyright (c) 2024 A Labs GmbH
|
|
* Copyright (c) 2024 tado GmbH
|
|
*
|
|
* SPDX-License-Identifier: Apache-2.0
|
|
*/
|
|
|
|
#include <zephyr/lorawan/emul.h>
|
|
#include <zephyr/lorawan/lorawan.h>
|
|
|
|
#include <errno.h>
|
|
|
|
#include <LoRaMac.h>
|
|
#include <Region.h>
|
|
|
|
#include <zephyr/kernel.h>
|
|
#include <zephyr/init.h>
|
|
#include <zephyr/logging/log.h>
|
|
|
|
LOG_MODULE_REGISTER(lorawan_emul, CONFIG_LORAWAN_LOG_LEVEL);
|
|
|
|
static bool lorawan_adr_enable;
|
|
|
|
static sys_slist_t dl_callbacks;
|
|
|
|
static DeviceClass_t current_class;
|
|
|
|
static lorawan_battery_level_cb_t battery_level_cb;
|
|
static lorawan_dr_changed_cb_t dr_changed_cb;
|
|
static lorawan_uplink_cb_t uplink_cb;
|
|
|
|
/* implementation required by the soft-se (software secure element) */
|
|
void BoardGetUniqueId(uint8_t *id)
|
|
{
|
|
/* Do not change the default value */
|
|
}
|
|
|
|
void lorawan_emul_send_downlink(uint8_t port, bool data_pending, int16_t rssi, int8_t snr,
|
|
uint8_t len, const uint8_t *data)
|
|
{
|
|
struct lorawan_downlink_cb *cb;
|
|
|
|
/* Iterate over all registered downlink callbacks */
|
|
SYS_SLIST_FOR_EACH_CONTAINER(&dl_callbacks, cb, node) {
|
|
if ((cb->port == LW_RECV_PORT_ANY) || (cb->port == port)) {
|
|
cb->cb(port, data_pending, rssi, snr, len, data);
|
|
}
|
|
}
|
|
}
|
|
|
|
int lorawan_join(const struct lorawan_join_config *join_cfg)
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
int lorawan_set_class(enum lorawan_class dev_class)
|
|
{
|
|
switch (dev_class) {
|
|
case LORAWAN_CLASS_A:
|
|
current_class = CLASS_A;
|
|
break;
|
|
case LORAWAN_CLASS_B:
|
|
LOG_ERR("Class B not supported yet!");
|
|
return -ENOTSUP;
|
|
case LORAWAN_CLASS_C:
|
|
current_class = CLASS_C;
|
|
break;
|
|
default:
|
|
return -EINVAL;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
int lorawan_set_datarate(enum lorawan_datarate dr)
|
|
{
|
|
ARG_UNUSED(dr);
|
|
|
|
/* Bail out if using ADR */
|
|
if (lorawan_adr_enable) {
|
|
return -EINVAL;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
void lorawan_get_payload_sizes(uint8_t *max_next_payload_size, uint8_t *max_payload_size)
|
|
{
|
|
LoRaMacTxInfo_t tx_info;
|
|
|
|
/* QueryTxPossible cannot fail */
|
|
(void)LoRaMacQueryTxPossible(0, &tx_info);
|
|
|
|
*max_next_payload_size = tx_info.MaxPossibleApplicationDataSize;
|
|
*max_payload_size = tx_info.CurrentPossiblePayloadSize;
|
|
}
|
|
|
|
enum lorawan_datarate lorawan_get_min_datarate(void)
|
|
{
|
|
return LORAWAN_DR_0;
|
|
}
|
|
|
|
void lorawan_enable_adr(bool enable)
|
|
{
|
|
lorawan_adr_enable = enable;
|
|
}
|
|
|
|
int lorawan_set_conf_msg_tries(uint8_t tries)
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
int lorawan_send(uint8_t port, uint8_t *data, uint8_t len, enum lorawan_message_type type)
|
|
{
|
|
if (data == NULL) {
|
|
return -EINVAL;
|
|
}
|
|
|
|
if (uplink_cb != NULL) {
|
|
uplink_cb(port, len, data);
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
void lorawan_register_battery_level_callback(lorawan_battery_level_cb_t cb)
|
|
{
|
|
battery_level_cb = cb;
|
|
}
|
|
|
|
void lorawan_register_downlink_callback(struct lorawan_downlink_cb *cb)
|
|
{
|
|
sys_slist_append(&dl_callbacks, &cb->node);
|
|
}
|
|
|
|
void lorawan_register_dr_changed_callback(lorawan_dr_changed_cb_t cb)
|
|
{
|
|
dr_changed_cb = cb;
|
|
}
|
|
|
|
int lorawan_start(void)
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
static int lorawan_init(void)
|
|
{
|
|
sys_slist_init(&dl_callbacks);
|
|
|
|
return 0;
|
|
}
|
|
|
|
void lorawan_emul_register_uplink_callback(lorawan_uplink_cb_t cb)
|
|
{
|
|
uplink_cb = cb;
|
|
}
|
|
|
|
SYS_INIT(lorawan_init, POST_KERNEL, 0);
|