mirror of
https://github.com/DarkFlippers/unleashed-firmware.git
synced 2024-12-11 07:12:09 +03:00
9a9abd59e9
* WeatherStation: start * SubGhz: rename protocol magellen -> magellan * WeatherStation: err Unresolved symbols: {'subghz_protocol_decoder_base_get_string'} * WeatherStation: fix Unresolved symbols: {'subghz_protocol_decoder_base_get_string'} * Subghz: add set protocol_items * WeatherStation: adding your protocols * WS: add Infactory protocol * WS: add history * WS: add setting * WS: add lock * WS: add hopper frequency * WS: fix history * WS fix string_t -> FuriString* * WS: add images * WS: history record update when receiving data from the sensor again * WS: add receiver info, delete extra code * WS: add protocol ThermoPRO_TX4 * [FL-2900] SubGhz: Move icons in Sub-GHz * WS: add Notification * [FL-2890] SubGhz: Rename *_user files in resources to _user.example * WS: add about scene * WS: removing redundant code * WS: add protocol Nexus-TH * WS: add protocol GT_WT03 * WS: fix notification and rename "Weather Station" -> "Read Weather Station" * SubGhz: partial unit tests fix * SubGhz: fix unit_test * SubGhz: remove dead code * SubGhz: rename SubGhzPresetDefinition into SubGhzRadioPreset, cleanup subghz types. Co-authored-by: Aleksandr Kutuzov <alleteam@gmail.com>
125 lines
3.7 KiB
C
125 lines
3.7 KiB
C
#include "receiver.h"
|
|
|
|
#include "registry.h"
|
|
#include "protocols/protocol_items.h"
|
|
|
|
#include <m-array.h>
|
|
|
|
typedef struct {
|
|
SubGhzProtocolEncoderBase* base;
|
|
} SubGhzReceiverSlot;
|
|
|
|
ARRAY_DEF(SubGhzReceiverSlotArray, SubGhzReceiverSlot, M_POD_OPLIST);
|
|
#define M_OPL_SubGhzReceiverSlotArray_t() ARRAY_OPLIST(SubGhzReceiverSlotArray, M_POD_OPLIST)
|
|
|
|
struct SubGhzReceiver {
|
|
SubGhzReceiverSlotArray_t slots;
|
|
SubGhzProtocolFlag filter;
|
|
|
|
SubGhzReceiverCallback callback;
|
|
void* context;
|
|
};
|
|
|
|
SubGhzReceiver* subghz_receiver_alloc_init(SubGhzEnvironment* environment) {
|
|
SubGhzReceiver* instance = malloc(sizeof(SubGhzReceiver));
|
|
SubGhzReceiverSlotArray_init(instance->slots);
|
|
const SubGhzProtocolRegistry* protocol_registry_items =
|
|
subghz_environment_get_protocol_registry(environment);
|
|
|
|
for(size_t i = 0; i < subghz_protocol_registry_count(protocol_registry_items); ++i) {
|
|
const SubGhzProtocol* protocol =
|
|
subghz_protocol_registry_get_by_index(protocol_registry_items, i);
|
|
|
|
if(protocol->decoder && protocol->decoder->alloc) {
|
|
SubGhzReceiverSlot* slot = SubGhzReceiverSlotArray_push_new(instance->slots);
|
|
slot->base = protocol->decoder->alloc(environment);
|
|
}
|
|
}
|
|
|
|
instance->callback = NULL;
|
|
instance->context = NULL;
|
|
return instance;
|
|
}
|
|
|
|
void subghz_receiver_free(SubGhzReceiver* instance) {
|
|
furi_assert(instance);
|
|
|
|
instance->callback = NULL;
|
|
instance->context = NULL;
|
|
|
|
// Release allocated slots
|
|
for
|
|
M_EACH(slot, instance->slots, SubGhzReceiverSlotArray_t) {
|
|
slot->base->protocol->decoder->free(slot->base);
|
|
slot->base = NULL;
|
|
}
|
|
SubGhzReceiverSlotArray_clear(instance->slots);
|
|
|
|
free(instance);
|
|
}
|
|
|
|
void subghz_receiver_decode(SubGhzReceiver* instance, bool level, uint32_t duration) {
|
|
furi_assert(instance);
|
|
furi_assert(instance->slots);
|
|
|
|
for
|
|
M_EACH(slot, instance->slots, SubGhzReceiverSlotArray_t) {
|
|
if((slot->base->protocol->flag & instance->filter) == instance->filter) {
|
|
slot->base->protocol->decoder->feed(slot->base, level, duration);
|
|
}
|
|
}
|
|
}
|
|
|
|
void subghz_receiver_reset(SubGhzReceiver* instance) {
|
|
furi_assert(instance);
|
|
furi_assert(instance->slots);
|
|
|
|
for
|
|
M_EACH(slot, instance->slots, SubGhzReceiverSlotArray_t) {
|
|
slot->base->protocol->decoder->reset(slot->base);
|
|
}
|
|
}
|
|
|
|
static void subghz_receiver_rx_callback(SubGhzProtocolDecoderBase* decoder_base, void* context) {
|
|
SubGhzReceiver* instance = context;
|
|
if(instance->callback) {
|
|
instance->callback(instance, decoder_base, instance->context);
|
|
}
|
|
}
|
|
|
|
void subghz_receiver_set_rx_callback(
|
|
SubGhzReceiver* instance,
|
|
SubGhzReceiverCallback callback,
|
|
void* context) {
|
|
furi_assert(instance);
|
|
|
|
for
|
|
M_EACH(slot, instance->slots, SubGhzReceiverSlotArray_t) {
|
|
subghz_protocol_decoder_base_set_decoder_callback(
|
|
(SubGhzProtocolDecoderBase*)slot->base, subghz_receiver_rx_callback, instance);
|
|
}
|
|
|
|
instance->callback = callback;
|
|
instance->context = context;
|
|
}
|
|
|
|
void subghz_receiver_set_filter(SubGhzReceiver* instance, SubGhzProtocolFlag filter) {
|
|
furi_assert(instance);
|
|
instance->filter = filter;
|
|
}
|
|
|
|
SubGhzProtocolDecoderBase* subghz_receiver_search_decoder_base_by_name(
|
|
SubGhzReceiver* instance,
|
|
const char* decoder_name) {
|
|
SubGhzProtocolDecoderBase* result = NULL;
|
|
|
|
for
|
|
M_EACH(slot, instance->slots, SubGhzReceiverSlotArray_t) {
|
|
if(strcmp(slot->base->protocol->name, decoder_name) == 0) {
|
|
result = (SubGhzProtocolDecoderBase*)slot->base;
|
|
break;
|
|
}
|
|
}
|
|
return result;
|
|
}
|