|
@@ -8,6 +8,16 @@
|
|
|
#include "../helpers/camera_suite_speaker.h"
|
|
#include "../helpers/camera_suite_speaker.h"
|
|
|
#include "../helpers/camera_suite_led.h"
|
|
#include "../helpers/camera_suite_led.h"
|
|
|
|
|
|
|
|
|
|
+void camera_suite_view_wifi_camera_set_callback(
|
|
|
|
|
+ CameraSuiteViewWiFiCamera* instance,
|
|
|
|
|
+ CameraSuiteViewWiFiCameraCallback callback,
|
|
|
|
|
+ void* context) {
|
|
|
|
|
+ furi_assert(instance);
|
|
|
|
|
+ furi_assert(callback);
|
|
|
|
|
+ instance->callback = callback;
|
|
|
|
|
+ instance->context = context;
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
static void camera_suite_view_wifi_camera_draw(Canvas* canvas, void* model) {
|
|
static void camera_suite_view_wifi_camera_draw(Canvas* canvas, void* model) {
|
|
|
furi_assert(canvas);
|
|
furi_assert(canvas);
|
|
|
furi_assert(model);
|
|
furi_assert(model);
|
|
@@ -19,61 +29,13 @@ static void camera_suite_view_wifi_camera_draw(Canvas* canvas, void* model) {
|
|
|
canvas_set_font(canvas, FontSecondary);
|
|
canvas_set_font(canvas, FontSecondary);
|
|
|
canvas_draw_frame(canvas, 0, 0, FRAME_WIDTH, FRAME_HEIGHT);
|
|
canvas_draw_frame(canvas, 0, 0, FRAME_WIDTH, FRAME_HEIGHT);
|
|
|
|
|
|
|
|
- canvas_draw_str_aligned(canvas, 3, 3, AlignLeft, AlignTop, "Starting WiFi Stream at:");
|
|
|
|
|
|
|
+ canvas_draw_str_aligned(canvas, 3, 3, AlignLeft, AlignTop, "Feature coming soon!");
|
|
|
|
|
+
|
|
|
|
|
+ // Draw log from camera.
|
|
|
canvas_draw_str_aligned(
|
|
canvas_draw_str_aligned(
|
|
|
canvas, 3, 13, AlignLeft, AlignTop, furi_string_get_cstr(instance->log));
|
|
canvas, 3, 13, AlignLeft, AlignTop, furi_string_get_cstr(instance->log));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-static int32_t camera_suite_wifi_camera_worker(void* context) {
|
|
|
|
|
- furi_assert(context);
|
|
|
|
|
-
|
|
|
|
|
- CameraSuiteViewWiFiCamera* instance = context;
|
|
|
|
|
-
|
|
|
|
|
- while(1) {
|
|
|
|
|
- uint32_t events =
|
|
|
|
|
- furi_thread_flags_wait(WIFI_WORKER_EVENTS_MASK, FuriFlagWaitAny, FuriWaitForever);
|
|
|
|
|
-
|
|
|
|
|
- // Check if an error occurred.
|
|
|
|
|
- furi_check((events & FuriFlagError) == 0);
|
|
|
|
|
-
|
|
|
|
|
- // Check if the thread should stop.
|
|
|
|
|
- if(events & WorkerEventStop) {
|
|
|
|
|
- break;
|
|
|
|
|
- } else if(events & WorkerEventRx) {
|
|
|
|
|
- size_t length = 0;
|
|
|
|
|
- do {
|
|
|
|
|
- size_t buffer_size = 320;
|
|
|
|
|
- uint8_t data[buffer_size];
|
|
|
|
|
- length =
|
|
|
|
|
- furi_stream_buffer_receive(instance->wifi_rx_stream, data, buffer_size, 0);
|
|
|
|
|
- if(length > 0) {
|
|
|
|
|
- data[length] = '\0';
|
|
|
|
|
-
|
|
|
|
|
- with_view_model(
|
|
|
|
|
- instance->view,
|
|
|
|
|
- CameraSuiteViewWiFiCameraModel * model,
|
|
|
|
|
- {
|
|
|
|
|
- furi_string_cat_printf(model->log, "%s", data);
|
|
|
|
|
-
|
|
|
|
|
- // Truncate if too long.
|
|
|
|
|
- model->log_strlen += length;
|
|
|
|
|
- if(model->log_strlen >= 4096 - 1) {
|
|
|
|
|
- furi_string_right(model->log, model->log_strlen / 2);
|
|
|
|
|
- model->log_strlen = furi_string_size(model->log) + length;
|
|
|
|
|
- }
|
|
|
|
|
- },
|
|
|
|
|
- true);
|
|
|
|
|
- }
|
|
|
|
|
- } while(length > 0);
|
|
|
|
|
-
|
|
|
|
|
- with_view_model(
|
|
|
|
|
- instance->view, CameraSuiteViewWiFiCameraModel * model, { UNUSED(model); }, true);
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- return 0;
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
static bool camera_suite_view_wifi_camera_input(InputEvent* event, void* context) {
|
|
static bool camera_suite_view_wifi_camera_input(InputEvent* event, void* context) {
|
|
|
furi_assert(context);
|
|
furi_assert(context);
|
|
|
furi_assert(event);
|
|
furi_assert(event);
|
|
@@ -82,12 +44,13 @@ static bool camera_suite_view_wifi_camera_input(InputEvent* event, void* context
|
|
|
|
|
|
|
|
if(event->type == InputTypeRelease) {
|
|
if(event->type == InputTypeRelease) {
|
|
|
switch(event->key) {
|
|
switch(event->key) {
|
|
|
- default: // Stop all sounds, reset the LED.
|
|
|
|
|
|
|
+ default:
|
|
|
with_view_model(
|
|
with_view_model(
|
|
|
instance->view,
|
|
instance->view,
|
|
|
CameraSuiteViewWiFiCameraModel * model,
|
|
CameraSuiteViewWiFiCameraModel * model,
|
|
|
{
|
|
{
|
|
|
UNUSED(model);
|
|
UNUSED(model);
|
|
|
|
|
+ // Stop all sounds, reset the LED.
|
|
|
camera_suite_play_bad_bump(instance->context);
|
|
camera_suite_play_bad_bump(instance->context);
|
|
|
camera_suite_stop_all_sound(instance->context);
|
|
camera_suite_stop_all_sound(instance->context);
|
|
|
camera_suite_led_set_rgb(instance->context, 0, 0, 0);
|
|
camera_suite_led_set_rgb(instance->context, 0, 0, 0);
|
|
@@ -105,8 +68,8 @@ static bool camera_suite_view_wifi_camera_input(InputEvent* event, void* context
|
|
|
UNUSED(model);
|
|
UNUSED(model);
|
|
|
|
|
|
|
|
// Stop camera WiFi stream.
|
|
// Stop camera WiFi stream.
|
|
|
- furi_hal_uart_tx(FuriHalUartIdUSART1, (uint8_t[]){'w'}, 1);
|
|
|
|
|
- furi_delay_ms(50);
|
|
|
|
|
|
|
+ // furi_hal_uart_tx(FuriHalUartIdUSART1, (uint8_t[]){'w'}, 1);
|
|
|
|
|
+ // furi_delay_ms(50);
|
|
|
|
|
|
|
|
// Go back to the main menu.
|
|
// Go back to the main menu.
|
|
|
instance->callback(CameraSuiteCustomEventSceneCameraBack, instance->context);
|
|
instance->callback(CameraSuiteCustomEventSceneCameraBack, instance->context);
|
|
@@ -136,9 +99,6 @@ static void camera_suite_view_wifi_camera_exit(void* context) {
|
|
|
static void camera_suite_view_wifi_camera_model_init(CameraSuiteViewWiFiCameraModel* const model) {
|
|
static void camera_suite_view_wifi_camera_model_init(CameraSuiteViewWiFiCameraModel* const model) {
|
|
|
model->log = furi_string_alloc();
|
|
model->log = furi_string_alloc();
|
|
|
furi_string_reserve(model->log, 4096);
|
|
furi_string_reserve(model->log, 4096);
|
|
|
-
|
|
|
|
|
- // Set the initial log message.
|
|
|
|
|
- // furi_string_printf(model->log, "Starting WiFi Camera Stream...:\n");
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
static void camera_suite_view_wifi_camera_enter(void* context) {
|
|
static void camera_suite_view_wifi_camera_enter(void* context) {
|
|
@@ -148,7 +108,7 @@ static void camera_suite_view_wifi_camera_enter(void* context) {
|
|
|
CameraSuiteViewWiFiCamera* instance = (CameraSuiteViewWiFiCamera*)context;
|
|
CameraSuiteViewWiFiCamera* instance = (CameraSuiteViewWiFiCamera*)context;
|
|
|
|
|
|
|
|
// Start wifi camera stream.
|
|
// Start wifi camera stream.
|
|
|
- furi_hal_uart_tx(FuriHalUartIdUSART1, (uint8_t[]){'W'}, 1);
|
|
|
|
|
|
|
+ // furi_hal_uart_tx(FuriHalUartIdUSART1, (uint8_t[]){'W'}, 1);
|
|
|
|
|
|
|
|
with_view_model(
|
|
with_view_model(
|
|
|
instance->view,
|
|
instance->view,
|
|
@@ -157,22 +117,6 @@ static void camera_suite_view_wifi_camera_enter(void* context) {
|
|
|
true);
|
|
true);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-static void wifi_camera_on_irq_cb(UartIrqEvent uartIrqEvent, uint8_t data, void* context) {
|
|
|
|
|
- furi_assert(uartIrqEvent);
|
|
|
|
|
- furi_assert(data);
|
|
|
|
|
- furi_assert(context);
|
|
|
|
|
-
|
|
|
|
|
- // Cast `context` to `CameraSuiteViewWiFiCamera*` and store it in `instance`.
|
|
|
|
|
- CameraSuiteViewWiFiCamera* instance = context;
|
|
|
|
|
-
|
|
|
|
|
- // If `uartIrqEvent` is `UartIrqEventRXNE`, send the data to the
|
|
|
|
|
- // `wifi_rx_stream` and set the `WorkerEventRx` flag.
|
|
|
|
|
- if(uartIrqEvent == UartIrqEventRXNE) {
|
|
|
|
|
- furi_stream_buffer_send(instance->wifi_rx_stream, &data, 1, 0);
|
|
|
|
|
- furi_thread_flags_set(furi_thread_get_id(instance->wifi_worker_thread), WorkerEventRx);
|
|
|
|
|
- }
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
CameraSuiteViewWiFiCamera* camera_suite_view_wifi_camera_alloc() {
|
|
CameraSuiteViewWiFiCamera* camera_suite_view_wifi_camera_alloc() {
|
|
|
// Allocate memory for the instance
|
|
// Allocate memory for the instance
|
|
|
CameraSuiteViewWiFiCamera* instance = malloc(sizeof(CameraSuiteViewWiFiCamera));
|
|
CameraSuiteViewWiFiCamera* instance = malloc(sizeof(CameraSuiteViewWiFiCamera));
|
|
@@ -184,7 +128,7 @@ CameraSuiteViewWiFiCamera* camera_suite_view_wifi_camera_alloc() {
|
|
|
view_allocate_model(
|
|
view_allocate_model(
|
|
|
instance->view, ViewModelTypeLocking, sizeof(CameraSuiteViewWiFiCameraModel));
|
|
instance->view, ViewModelTypeLocking, sizeof(CameraSuiteViewWiFiCameraModel));
|
|
|
|
|
|
|
|
- // Set context for the view
|
|
|
|
|
|
|
+ // Set context for the view (furi_assert crashes in events without this)
|
|
|
view_set_context(instance->view, instance);
|
|
view_set_context(instance->view, instance);
|
|
|
|
|
|
|
|
// Set draw callback
|
|
// Set draw callback
|
|
@@ -199,24 +143,6 @@ CameraSuiteViewWiFiCamera* camera_suite_view_wifi_camera_alloc() {
|
|
|
// Set exit callback
|
|
// Set exit callback
|
|
|
view_set_exit_callback(instance->view, camera_suite_view_wifi_camera_exit);
|
|
view_set_exit_callback(instance->view, camera_suite_view_wifi_camera_exit);
|
|
|
|
|
|
|
|
- // Allocate a stream buffer
|
|
|
|
|
- instance->wifi_rx_stream = furi_stream_buffer_alloc(1024, 1);
|
|
|
|
|
-
|
|
|
|
|
- // Allocate a thread for this camera to run on.
|
|
|
|
|
- FuriThread* thread = furi_thread_alloc_ex(
|
|
|
|
|
- "Camera_Suite_WiFi_Rx_Thread", 1024, camera_suite_wifi_camera_worker, instance);
|
|
|
|
|
- instance->wifi_worker_thread = thread;
|
|
|
|
|
- furi_thread_start(instance->wifi_worker_thread);
|
|
|
|
|
-
|
|
|
|
|
- // Disable console.
|
|
|
|
|
- furi_hal_console_disable();
|
|
|
|
|
-
|
|
|
|
|
- // 115200 is the default baud rate for the ESP32-CAM.
|
|
|
|
|
- furi_hal_uart_set_br(FuriHalUartIdUSART1, 230400);
|
|
|
|
|
-
|
|
|
|
|
- // Enable UART1 and set the IRQ callback.
|
|
|
|
|
- furi_hal_uart_set_irq_cb(FuriHalUartIdUSART1, wifi_camera_on_irq_cb, instance);
|
|
|
|
|
-
|
|
|
|
|
with_view_model(
|
|
with_view_model(
|
|
|
instance->view,
|
|
instance->view,
|
|
|
CameraSuiteViewWiFiCameraModel * model,
|
|
CameraSuiteViewWiFiCameraModel * model,
|
|
@@ -229,18 +155,6 @@ CameraSuiteViewWiFiCamera* camera_suite_view_wifi_camera_alloc() {
|
|
|
void camera_suite_view_wifi_camera_free(CameraSuiteViewWiFiCamera* instance) {
|
|
void camera_suite_view_wifi_camera_free(CameraSuiteViewWiFiCamera* instance) {
|
|
|
furi_assert(instance);
|
|
furi_assert(instance);
|
|
|
|
|
|
|
|
- // Remove the IRQ callback.
|
|
|
|
|
- furi_hal_uart_set_irq_cb(FuriHalUartIdUSART1, NULL, NULL);
|
|
|
|
|
-
|
|
|
|
|
- // Free the worker thread.
|
|
|
|
|
- furi_thread_free(instance->wifi_worker_thread);
|
|
|
|
|
-
|
|
|
|
|
- // Free the allocated stream buffer.
|
|
|
|
|
- furi_stream_buffer_free(instance->wifi_rx_stream);
|
|
|
|
|
-
|
|
|
|
|
- // Re-enable the console.
|
|
|
|
|
- furi_hal_console_enable();
|
|
|
|
|
-
|
|
|
|
|
with_view_model(
|
|
with_view_model(
|
|
|
instance->view,
|
|
instance->view,
|
|
|
CameraSuiteViewWiFiCameraModel * model,
|
|
CameraSuiteViewWiFiCameraModel * model,
|
|
@@ -254,13 +168,3 @@ View* camera_suite_view_wifi_camera_get_view(CameraSuiteViewWiFiCamera* instance
|
|
|
furi_assert(instance);
|
|
furi_assert(instance);
|
|
|
return instance->view;
|
|
return instance->view;
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
-void camera_suite_view_wifi_camera_set_callback(
|
|
|
|
|
- CameraSuiteViewWiFiCamera* instance,
|
|
|
|
|
- CameraSuiteViewWiFiCameraCallback callback,
|
|
|
|
|
- void* context) {
|
|
|
|
|
- furi_assert(instance);
|
|
|
|
|
- furi_assert(callback);
|
|
|
|
|
- instance->callback = callback;
|
|
|
|
|
- instance->context = context;
|
|
|
|
|
-}
|
|
|