Skip to content
This repository has been archived by the owner on Jul 28, 2024. It is now read-only.

Commit

Permalink
listen mode
Browse files Browse the repository at this point in the history
  • Loading branch information
@vad7
vad7 committed Mar 6, 2023
1 parent 0dbf1a1 commit 8438749
Show file tree
Hide file tree
Showing 2 changed files with 143 additions and 44 deletions.
2 changes: 2 additions & 0 deletions Distr/nrf24batch/CO2_mini.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,8 @@ R default: ,EEPROM,0xC1
W default: n,,0x81
Write start: 0,0,0x8F

Listen: C8C8C1=CO2,Alarm,-

R: ID*=,ID
R: OSCCAL=0x51,RAM
R: OSCCAL_EMEM=0
Expand Down
185 changes: 141 additions & 44 deletions nrf24batch.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
#include <u8g2.h>

#define TAG "nrf24batch"
#define VERSION "1.2"
#define VERSION "1.3"

#define SCAN_APP_PATH_FOLDER "/ext/nrf24batch"
#define LOG_FILEEXT ".txt"
Expand All @@ -41,17 +41,19 @@ const char SettingsFld_Write[] = "W:"; // Write cmd
const char SettingsFld_Set[] = "S:"; // Set cmd (like Write but without "Write start" packet)
const char SettingsFld_ReadBatch[] = "RBatch:";
const char SettingsFld_WriteBatch[] = "WBatch:";
const char SettingsFld_Listen[] = "Listen:";
const char AskQuestion_Save[] = "SAVE BATCH?";
#define Settings_i 'i'
#define Settings_n 'n'
#define VAR_EMPTY ((int32_t)0x80000000)

nRF24Batch* APP;
uint8_t what_doing = 0; // 0 - setup, 1 - cmd list, 2 - view send cmd
uint8_t what_doing = 0; // 0 - setup, 1 - cmd list, 2 - read/write/listen cmd
enum {
rwt_read_batch = 0,
rwt_read_cmd,
rwt_write_batch
rwt_write_batch,
rwt_listen
};
uint8_t rw_type = rwt_read_batch; // What to do: rwt_*
enum {
Expand Down Expand Up @@ -110,6 +112,10 @@ FuriString *ReadDefault = NULL;
FuriString *WriteDefault = NULL;
FuriString *WriteStart = NULL;
FuriString *Constants = NULL; // text of STR=x
char *ListenAddr = NULL;
char *ListenFields = NULL; // ptr to string: field1,field2,... max 5 field now
bool ListenNew;
FuriHalRtcDateTime ListenLastTime = { 0 };
FuriString **Read_cmd = NULL; // Names of read cmd
uint16_t Read_cmd_Total = 0;
FuriString **Log = NULL; // Strings: var=n
Expand Down Expand Up @@ -201,6 +207,14 @@ static void add_to_str_hex_bytes(char *out, uint8_t *arr, int bytes)
} while(--bytes);
}

int32_t get_payload_receive_field(uint8_t size)
{
if(size <= 1) return *payload_receive;
else if(size == 2) return *(int16_t*)payload_receive;
else if(size == 3) return (*(uint32_t*)payload_receive) & 0xFFFFFF;
else return *(int32_t*)payload_receive;
}

void free_Log()
{
if(Log_Total) {
Expand Down Expand Up @@ -231,6 +245,14 @@ void free_store(void)
furi_string_free(WriteStart);
WriteDefault = NULL;
}
if(ListenAddr) {
free(ListenAddr);
ListenAddr = NULL;
}
if(ListenFields) {
free(ListenFields);
ListenFields = NULL;
}
if(Read_cmd_Total) {
for(uint16_t i = 0; i < Read_cmd_Total; i++) furi_string_free(Read_cmd[i]);
Read_cmd_Total = 0;
Expand Down Expand Up @@ -370,11 +392,7 @@ bool nrf24_read_newpacket() {
if(size > 4) size = 0;
}
}
int32_t var;
if(size <= 1) var = *payload_receive;
else if(size == 2) var = *(int16_t*)payload_receive;
else if(size == 3) var = (*(uint32_t*)payload_receive) & 0xFFFFFF;
else var = *(int32_t*)payload_receive;
int32_t var = get_payload_receive_field(size);
//FURI_LOG_D(TAG, "VAR(%d): %ld", size, var);
if(size == 0) furi_string_cat_printf(str, "%c", (char)var);
else {
Expand Down Expand Up @@ -710,7 +728,7 @@ static uint8_t load_settings_file() {
char *p = (char*)furi_string_get_cstr(str);
if(*p <= ' ') continue;
//char* delim_eq = strchr(p, '=');
char* delim_col = strchr(p, ':');
char *delim_col = strchr(p, ':');
if(delim_col == NULL) { // Constant found - no ':'
if(Constants == NULL) {
Constants = furi_string_alloc_set(str);
Expand Down Expand Up @@ -796,6 +814,21 @@ static uint8_t load_settings_file() {
break;
}
WriteBatch_cmd[WriteBatch_cmd_Total++] = furi_string_alloc_set_str(p);
} else if(strncmp(p, SettingsFld_Listen, sizeof(SettingsFld_Listen)-1) == 0) {
p += sizeof(SettingsFld_Listen);
char *p2 = strchr(p, '=');
if(p2) {
uint8_t len = p2 - p;
ListenAddr = malloc(len + 1);
if(ListenAddr) {
memcpy(ListenAddr, p, len);
ListenAddr[len] = '\0';
p2++;
len = strlen(p2);
ListenFields = malloc(len + 1);
if(ListenFields) memcpy(ListenFields, p2, len);
}
}
}
}
}
Expand Down Expand Up @@ -893,6 +926,22 @@ void display_remove_asterisk(char *fsp, uint8_t vx)
}
}

void display_edit_ttf_font(Canvas* const canvas, uint8_t start_x, uint8_t start_y)
{
screen_buf[0] = *Edit_pos; screen_buf[1] = '\0';
int n = canvas_string_width(canvas, screen_buf);
int len = Edit_pos - Edit_start;
memcpy(screen_buf, Edit_start, len);
screen_buf[len] = '\0';
int x = start_x + canvas_string_width(canvas, screen_buf);
int len2 = strlen(Edit_pos);
memcpy(screen_buf + len, Edit_pos, len2);
screen_buf[len + len2] = '\0';
canvas_draw_str(canvas, start_x, start_y, screen_buf);
start_y += 1;
canvas_draw_line(canvas, x + (len ? 1 : 0), start_y, x + n + (*Edit_pos == '1' && len ? 1 : 0), start_y);
}

static void render_callback(Canvas* const canvas, void* ctx) {
const PluginState* plugin_state = acquire_mutex((ValueMutex*)ctx, 25);
if(plugin_state == NULL) return;
Expand All @@ -903,20 +952,8 @@ static void render_callback(Canvas* const canvas, void* ctx) {
canvas_draw_str(canvas, 8, 10, screen_buf);
if(addr_len) {
if(Edit) {
screen_buf[0] = *Edit_pos; screen_buf[1] = '\0';
int n = canvas_string_width(canvas, screen_buf);
int len = Edit_pos - Edit_start;
memcpy(screen_buf, Edit_start, len);
screen_buf[len] = '\0';
int x = setup_cursor == 1 ? 45 : 55;
x += canvas_string_width(canvas, screen_buf);
int len2 = strlen(Edit_pos);
memcpy(screen_buf + len, Edit_pos, len2);
screen_buf[len + len2] = '\0';
int y = 10 + setup_cursor * 10;
if(setup_cursor == 1) canvas_draw_str(canvas, 45, 20, screen_buf);
else if(setup_cursor == 2) canvas_draw_str(canvas, 55, 30, screen_buf);
canvas_draw_line(canvas, x + (len ? 1 : 0), y + 1, x + n + (*Edit_pos == '1' && len ? 1 : 0), y + 1);
if(setup_cursor == 1) display_edit_ttf_font(canvas, 45, 20);
else if(setup_cursor == 2) display_edit_ttf_font(canvas, 55, 30);
}
if(!Edit || setup_cursor != 1) {
screen_buf[0] = '\0';
Expand All @@ -940,19 +977,25 @@ static void render_callback(Canvas* const canvas, void* ctx) {
canvas_draw_str(canvas, 0, 10, ">");
}
} else if(what_doing == 1){
canvas_set_font(canvas, FontBatteryPercent); // 5x7 font, 9 lines, 25 cols
if(rw_type == rwt_read_batch) {
canvas_draw_str(canvas, 0, 7, "Read Batch:");
render_display_list(canvas, &ReadBatch_cmd, ':', view_cmd[rw_type], ReadBatch_cmd_Total);
} else if(rw_type == rwt_read_cmd) {
canvas_draw_str(canvas, 0, 7, "Read Command:");
render_display_list(canvas, &Read_cmd, '=', view_cmd[rw_type], Read_cmd_Total);
} else { // rwt_write_batch
if(!ask_fill_screen_buf()) strcpy(screen_buf, "Write Batch:");
canvas_draw_str(canvas, 0, 7, screen_buf);
render_display_list(canvas, &WriteBatch_cmd, ':', view_cmd[rw_type], WriteBatch_cmd_Total);
if(rw_type == rwt_listen) {
canvas_set_font(canvas, FontSecondary); // 8x10 font, 6 lines
canvas_draw_str(canvas, 0, 10, "Listen mode");
canvas_draw_str(canvas, 0, 25, "Address:");
if(Edit) display_edit_ttf_font(canvas, 40, 25); else if(ListenAddr) canvas_draw_str(canvas, 40, 25, ListenAddr);
} else {
canvas_set_font(canvas, FontBatteryPercent); // 5x7 font, 9 lines, 25 cols
if(rw_type == rwt_read_batch) {
canvas_draw_str(canvas, 0, 7, "Read Batch:");
render_display_list(canvas, &ReadBatch_cmd, ':', view_cmd[rw_type], ReadBatch_cmd_Total);
} else if(rw_type == rwt_read_cmd) {
canvas_draw_str(canvas, 0, 7, "Read Command:");
render_display_list(canvas, &Read_cmd, '=', view_cmd[rw_type], Read_cmd_Total);
} else if(rw_type == rwt_write_batch) {
if(!ask_fill_screen_buf()) strcpy(screen_buf, "Write Batch:");
canvas_draw_str(canvas, 0, 7, screen_buf);
render_display_list(canvas, &WriteBatch_cmd, ':', view_cmd[rw_type], WriteBatch_cmd_Total);
}
}
if(NRF_ERROR) canvas_draw_str(canvas, 70, 7, "nRF24 ERROR!");
} else { // what_doing == 2
if(rw_type == rwt_read_cmd) { // Read command
canvas_set_font(canvas, FontSecondary); // 8x10 font, 6 lines
Expand All @@ -975,6 +1018,35 @@ static void render_callback(Canvas* const canvas, void* ctx) {
canvas_draw_str(canvas, 0, 15 + 10, screen_buf);
}

} else if(rw_type == rwt_listen) {
canvas_set_font(canvas, FontSecondary); // 8x10 font, 6 lines
strcpy(screen_buf, "Listen: ");
if(NRF_ERROR) strcat(screen_buf, "nRF24 ERROR!");
else if(ListenNew) snprintf(screen_buf + strlen(screen_buf), 16, "%02d:%02d:%02d", ListenLastTime.hour, ListenLastTime.minute, ListenLastTime.second);
else strcat(screen_buf, "receiving");
canvas_draw_str(canvas, 0, 10, screen_buf);
if(ListenFields) {
char *p2, *p = ListenFields;
uint8_t hex, len, *pld = payload_receive;
for(uint8_t i = 0; i < 5 && *p; i++) {
hex = false;
p2 = strchr(p, ',');
if(p2 == NULL) p2 = p + strlen(p); else if(*(p2 - 1) == '#') hex = true;
memcpy(screen_buf, p, len = p2 - p);
strcpy(screen_buf + len, ": ");
if(ListenNew) {
len = payload_struct[i];
if(hex) strcat(screen_buf, "0x");
else snprintf(screen_buf, strlen(screen_buf), "%ld (", get_payload_receive_field(len));
add_to_str_hex_bytes(screen_buf, pld, len);
if(!hex) strcat(screen_buf, ")");
pld += len;
}
canvas_draw_str(canvas, 0, 20 + i * 10, screen_buf);
if(*p2 == '\0') break;
p = p2 + 1;
}
}
} else { // if(rw_type == rwt_read_batch || rw_type == rwt_write_batch)
canvas_set_font(canvas, FontBatteryPercent); // 5x7 font, 9 lines, 25 cols
if(!ask_fill_screen_buf()) {
Expand Down Expand Up @@ -1069,8 +1141,11 @@ void work_timer_callback(void* ctx)
for(uint8_t i = 0; i < 3; i++) {
bool new = nrf24_read_newpacket();
if(new) {
if(send_status != sst_receiving) break;
} else if(furi_get_tick() - NRF_time > NRF_READ_TIMEOUT) {
if(rw_type == rwt_listen) {
furi_hal_rtc_get_datetime(&ListenLastTime);
ListenNew = true;
} else if(send_status != sst_receiving) break;
} else if(rw_type != rwt_listen && furi_get_tick() - NRF_time > NRF_READ_TIMEOUT) {
if(NRF_repeat++ < NRF_resend) {
send_status = sst_sending;
nrf24_resend_read_packet();
Expand Down Expand Up @@ -1192,11 +1267,11 @@ int32_t nrf24batch_app(void* p) {
else if(*(Edit_pos - 1) == ',') Edit_pos -= 2;
}
} else if(what_doing == 0) {
rw_type = rwt_write_batch;
rw_type = rwt_listen;
what_doing = 1;
} else if(what_doing == 1) {
if(event.input.type == InputTypeShort) {
if(--rw_type > rwt_write_batch) rw_type = rwt_write_batch;
if(--rw_type > rwt_listen) rw_type = rwt_listen;
} else if(view_x) view_x--;
} else if(what_doing == 2) {
if(view_x) view_x--;
Expand Down Expand Up @@ -1224,7 +1299,7 @@ int32_t nrf24batch_app(void* p) {
what_doing = 1;
} else if(what_doing == 1) {
if(event.input.type == InputTypeShort) {
if(++rw_type > rwt_write_batch) rw_type = rwt_read_batch;
if(++rw_type > rwt_listen) rw_type = rwt_read_batch;
} else view_x++;
} else if(what_doing == 2) {
view_x++;
Expand Down Expand Up @@ -1331,6 +1406,15 @@ int32_t nrf24batch_app(void* p) {
view_Batch = 0;
what_doing = 2;
}
} else if(rw_type == rwt_listen) {
free_Log();
prepare_nrf24();
if(!NRF_ERROR) {
nrf24_set_rx_mode(nrf24_HANDLE);
ListenNew = false;
send_status = sst_receiving; // receiving
}
what_doing = 2;
}
} else if(what_doing == 2) {
if(Log_Total) {
Expand All @@ -1339,8 +1423,7 @@ int32_t nrf24batch_app(void* p) {
ask_question_answer = 0;
} else if(rw_type == rwt_write_batch) {
if(!Edit) {
Edit = 1;
Edited = true;
Edit = 0;
Edit_hex = 0;
char *s = (char*)furi_string_get_cstr(Log[view_Batch]);
char *p = strchr(s, '=');
Expand All @@ -1351,8 +1434,14 @@ int32_t nrf24batch_app(void* p) {
p += 2;
Edit_hex = 1; // hex
}
Edit_start = Edit_pos = p;
} else Edit = 0;
if(is_digit(p, Edit_hex)) {
Edit_start = p;
while(is_digit(p, Edit_hex)) p++;
Edit_pos = p - 1;
Edited = true;
Edit = 1;
}
}
}
}
}
Expand All @@ -1371,6 +1460,14 @@ int32_t nrf24batch_app(void* p) {
furi_string_left(fs, furi_string_size(fs) - 1);
}
}
} else if(what_doing == 1) {
if(rw_type == rwt_listen) {
NRF_INITED = false;
Edit_start = ListenAddr;
Edit_pos = ListenAddr + strlen(ListenAddr) - 1;
Edit_hex = true;
Edit = 1;
}
} else if(what_doing == 2 && Log_Total) {
if(rw_type == rwt_write_batch) {
ask_question = ask_write_batch;
Expand Down

0 comments on commit 8438749

Please sign in to comment.