nrf24batch.c 58 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788
  1. //
  2. // Written by vad7, 10.01.2023. vad7@yahoo.com
  3. //
  4. #include "nrf24batch.h"
  5. #include <furi.h>
  6. #include <furi_hal.h>
  7. #include <gui/gui.h>
  8. #include <dialogs/dialogs.h>
  9. #include <input/input.h>
  10. #include <stdlib.h>
  11. #include <dolphin/dolphin.h>
  12. #include <nrf24.h>
  13. #include <u8g2.h>
  14. #define TAG "nrf24batch"
  15. #define VERSION "1.9"
  16. #define SCAN_APP_PATH_FOLDER "/ext/nrf24batch"
  17. #define LOG_FILEEXT ".txt"
  18. #define NRF_READ_TIMEOUT 300UL // ms
  19. #define WORK_PERIOD 2 // ms, Timer period
  20. #define MAX_CHANNEL 125
  21. #define FONT_5x7_SCREEN_WIDTH 25
  22. #define NRF_EN_DYN_ACK 0 // does not work on some nrf24l01+ chips, (0/1)
  23. const char SettingsFld_Info[] = "Info:";
  24. const char SettingsFld_Ch[] = "Ch:";
  25. const char SettingsFld_Rate[] = "Rate:";
  26. const char SettingsFld_DPL[] = "DPL:";
  27. const char SettingsFld_CRC[] = "CRC:";
  28. const char SettingsFld_RETR[] = "RETR:";
  29. const char SettingsFld_Address[] = "Address:";
  30. const char SettingsFld_Resend[] = "Resend:";
  31. const char SettingsFld_Delay[] = "Delay_ms:";
  32. const char SettingsFld_WriteStart[] = "Write start:";
  33. const char SettingsFld_Payload[] = "Payload struct:";
  34. const char SettingsFld_ReadDefault[] = "R default:";
  35. const char SettingsFld_WriteDefault[] = "W default:";
  36. const char SettingsFld_Read[] = "R:"; // Read cmd
  37. const char SettingsFld_Write[] = "W:"; // Write cmd
  38. const char SettingsFld_Set[] = "S:"; // Set cmd (like Write but without "Write start" packet)
  39. const char SettingsFld_ReadBatch[] = "RBatch:";
  40. const char SettingsFld_WriteBatch[] = "WBatch:";
  41. const char SettingsFld_SetBatch[] = "SBatch:";
  42. const char SettingsFld_Listen[] = "Listen:";
  43. const char SettingsFld_ReadCmdRepeatPeriod[] = "ReadCmd repeat:";
  44. const char AskQuestion_Save[] = "SAVE BATCH?";
  45. #define Settings_i 'i'
  46. #define Settings_n 'n'
  47. #define VAR_EMPTY ((int32_t)0x80000000)
  48. nRF24Batch* APP;
  49. uint8_t what_doing = 0; // 0 - setup, 1 - cmd list, 2 - read/write/listen cmd
  50. enum {
  51. rwt_set_batch = 0, // fast send packet without question
  52. rwt_read_batch, // Send read cmd and wait for answer in batch
  53. rwt_read_cmd, // Send read cmd and wait for answer
  54. rwt_write_batch, // Send write cmd (with Write start pkt if available) with a question before it
  55. rwt_listen, // Listen mode (wait incoming pkts)
  56. rwt_max
  57. };
  58. uint8_t rw_type = rwt_read_batch; // What to do: rwt_*
  59. enum {
  60. sst_none = 0,
  61. sst_sending,
  62. sst_receiving,
  63. sst_ok,
  64. sst_error,
  65. sst_timeout
  66. };
  67. uint8_t send_status = sst_none;// sst_*
  68. bool cmd_array = false;
  69. uint8_t cmd_array_idx;
  70. uint8_t cmd_array_cnt = 0;
  71. bool cmd_array_hex;
  72. uint8_t save_settings = 0;
  73. uint16_t view_cmd[rwt_max - 1] = {0}; // SetBatch, ReadBatch, Read, WriteBatch
  74. uint8_t view_x = 0;
  75. char screen_buf[64];
  76. char Info[35] = "";
  77. char file_name[FONT_5x7_SCREEN_WIDTH];
  78. char ERR_STR[FONT_5x7_SCREEN_WIDTH];
  79. uint8_t ERR = 0;
  80. uint8_t NRF_rate; // 0 - 250Kbps, 1 - 1Mbps, 2 - 2Mbps
  81. uint8_t NRF_channel;// 0..125
  82. uint8_t NRF_DPL; // 1 - Dynamic Payload Length
  83. uint8_t NRF_CRC; // 1 - No, 1 - CRC 1byte, 2 - CRC 2byte
  84. uint8_t NRF_RETR = ((0b0011<<4) | 0b1111); // Automatic Retransmission, ARD, ARC
  85. uint8_t NRF_Payload;// Payload len in bytes, 0..32
  86. bool NRF_ERROR = 0;
  87. uint8_t NRF_INITED = 0; // 0 - not, 1 - rw, rwt_listen - listen
  88. bool NRF_BOARD_POWER_5V = false;
  89. uint8_t NRF_last_packet_send_st = 0;
  90. uint8_t NRF_resend = 1; // number of transaction attempts
  91. int8_t NRF_repeat = 0; // count number of repeated requests (until < NRF_resend)
  92. uint32_t NRF_time;
  93. uint16_t ReadCmdRepeatPeriod = 10; // s
  94. bool ReadRepeat = false;
  95. uint32_t delay_between_pkt = 10;// ms
  96. uint8_t addr[5]; // nRF24 address, MSB first
  97. uint8_t addr_len = 0; // 2..5
  98. uint8_t payload[32];
  99. uint8_t payload_receive[32];
  100. uint8_t payload_struct[32]; // sizeof(1..4) in bytes of each field, example: 2,1,1
  101. uint8_t payload_fields = 0;
  102. uint8_t payload_size = 0; // bytes
  103. uint16_t view_Batch = 0; // view pos in Batch or inside WriteBatch (Log[view_Batch])
  104. uint16_t view_WriteBatch = 0; // view pos of WriteBatch list
  105. uint8_t setup_cursor = 0; // cursor position on Setup scr
  106. uint8_t Edit = 0;
  107. char *Edit_pos;
  108. char *Edit_start;
  109. bool Edit_hex; // 0 - decimal, 1 - hex
  110. bool Edited = false; // list of cmds edited
  111. Stream* file_stream = NULL;
  112. FuriString *ReadDefault = NULL;
  113. FuriString *WriteDefault = NULL;
  114. FuriString *WriteStart = NULL;
  115. FuriString *Constants = NULL; // text of STR=x
  116. uint8_t listen_addr[5];
  117. uint8_t listen_addr_len = 0;
  118. char *ListenFields = NULL; // ptr to string: field1,field2,... max 5 field now
  119. bool ListenNew;
  120. FuriHalRtcDateTime ListenLastTime = { 0 };
  121. uint32_t ListenPrev = 0;
  122. uint32_t ListenLast = 0;
  123. FuriString **Read_cmd = NULL; // Names of read cmd
  124. uint16_t Read_cmd_Total = 0;
  125. FuriString **Log = NULL; // Strings: var=n
  126. uint16_t Log_Total = 0;
  127. FuriString **ReadBatch_cmd = NULL; // Names of read batch cmd
  128. uint16_t ReadBatch_cmd_Total = 0;
  129. char *ReadBatch_cmd_curr = NULL; // =0xFFFFFFFF - finish
  130. FuriString **WriteBatch_cmd = NULL; // Names of write batch cmd
  131. uint16_t WriteBatch_cmd_Total = 0;
  132. uint16_t WriteBatch_cmd_curr = 0; // == _Total - finish
  133. FuriString **SetBatch_cmd = NULL; // Names of set batch cmd
  134. uint16_t SetBatch_cmd_Total = 0;
  135. uint16_t SetBatch_cmd_curr = 0; // == _Total - finish
  136. #define POWER_READ_PERIOD 501 // ms
  137. uint16_t pwr_read_timer = 0;
  138. int Current = 0;
  139. int CurrentStart = 0;
  140. enum {
  141. ask_write_batch = 1,
  142. ask_save_batch,
  143. ask_skip_cmd,
  144. ask_return,
  145. ask_exit
  146. };
  147. uint8_t ask_question = 0; // 1 - Ask now - ask_*
  148. uint8_t ask_question_answer = 0;// 0 - no, 1 - yes
  149. static bool ask_fill_screen_buf(void)
  150. {
  151. if(ask_question == ask_write_batch) strcpy(screen_buf, "RUN WRITE BATCH?");
  152. else if(ask_question == ask_save_batch) strcpy(screen_buf, "SAVE AS WRITE BATCH?");
  153. else if(ask_question == ask_skip_cmd) strcpy(screen_buf, "SKIP CMD?");
  154. else if(ask_question == ask_return) strcpy(screen_buf, "RETURN?");
  155. else if(ask_question == ask_exit) strcpy(screen_buf, "EXIT?");
  156. else return false;
  157. strcat(screen_buf, ask_question_answer ? " YES" : " NO");
  158. return true;
  159. }
  160. //#define MIN(a, b) ((a<b)?a:b)
  161. static uint8_t GetHexVal(char hex) {
  162. return hex == 0 ? 0 : ((uint8_t)hex - ((uint8_t)hex < 58 ? 48 : ((uint8_t)hex < 97 ? 55 : 87)));
  163. }
  164. static bool is_digit(char *ptr, bool hex)
  165. {
  166. char c = *ptr;
  167. if(c >= '0' && c <= '9') return true;
  168. if(hex) {
  169. c &= ~0x20;
  170. if(c >= 'A' && c <= 'F') return true;
  171. } else if(c == '-') return true;
  172. return false;
  173. }
  174. // Return num bytes in array
  175. static uint8_t ConvertHexToArray(char * hex, uint8_t * array, uint8_t maxlen) {
  176. uint8_t len = 0;
  177. while(maxlen) {
  178. uint8_t ch = *hex++;
  179. if(ch < ' ') break;
  180. if(ch < '0') continue;
  181. *array++ = (GetHexVal(ch) << 4) + GetHexVal(*hex++);
  182. len++;
  183. maxlen--;
  184. }
  185. return len;
  186. }
  187. int32_t str_to_int(char *p)
  188. {
  189. if(*(p+1) == 'x') { // hex
  190. return strtol(p + 2, NULL, 16);
  191. } else return strtol(p, NULL, 10);
  192. }
  193. void str_rtrim(char *p)
  194. {
  195. char *delim_col = strchr(p, '\r');
  196. if(delim_col) *delim_col = '\0';
  197. else {
  198. delim_col = strchr(p, '\n');
  199. if(delim_col) *delim_col = '\0';
  200. }
  201. }
  202. static void add_to_str_hex_bytes(char *out, uint8_t *arr, int bytes)
  203. {
  204. if(bytes <= 0) return;
  205. out += strlen(out);
  206. do {
  207. snprintf(out, 3, "%02X", *arr++);
  208. out += 2;
  209. } while(--bytes);
  210. }
  211. void Edit_insert_digit(char new)
  212. {
  213. if(*Edit_pos == '-') return;
  214. if(what_doing <= 1) {
  215. if(strlen(Edit_start) < (what_doing == 0 && setup_cursor == 2 ? 3 : 5 * 2)) {
  216. memmove(Edit_pos + 1, Edit_pos, strlen(Edit_pos) + 1);
  217. *Edit_pos = new;
  218. }
  219. } else {
  220. FuriString *fs = Log[view_Batch];
  221. FuriString *ns = furi_string_alloc();
  222. if(ns) {
  223. uint16_t len = Edit_pos - (char*)furi_string_get_cstr(fs);
  224. furi_string_set_n(ns, fs, 0, len);
  225. furi_string_cat_printf(ns, "%c", new);
  226. furi_string_cat_str(ns, Edit_pos);
  227. Log[view_Batch] = ns;
  228. Edit_pos = (char*)furi_string_get_cstr(ns);
  229. Edit_start = Edit_pos + (Edit_start - (char*)furi_string_get_cstr(fs));
  230. Edit_pos += len;
  231. furi_string_free(fs);
  232. }
  233. }
  234. }
  235. int32_t get_payload_receive_field(uint8_t *var, uint8_t size)
  236. {
  237. if(size <= 1) return *var;
  238. else if(size == 2) return *(int16_t*)var;
  239. else if(size == 3) return (*(uint32_t*)var) & 0xFFFFFF;
  240. else return *(int32_t*)var;
  241. }
  242. void free_Log()
  243. {
  244. if(Log_Total) {
  245. for(uint16_t i = 0; i < Log_Total; i++) if(Log[i]) furi_string_free(Log[i]);
  246. Log_Total = 0;
  247. }
  248. if(Log) {
  249. free(Log);
  250. Log = NULL;
  251. }
  252. }
  253. void free_store(void)
  254. {
  255. if(Constants) {
  256. furi_string_free(Constants);
  257. Constants = NULL;
  258. }
  259. if(ReadDefault) {
  260. furi_string_free(ReadDefault);
  261. ReadDefault = NULL;
  262. }
  263. if(WriteDefault) {
  264. furi_string_free(WriteDefault);
  265. WriteDefault = NULL;
  266. }
  267. if(WriteStart) {
  268. furi_string_free(WriteStart);
  269. WriteDefault = NULL;
  270. }
  271. if(ListenFields) {
  272. free(ListenFields);
  273. ListenFields = NULL;
  274. }
  275. if(Read_cmd_Total) {
  276. for(uint16_t i = 0; i < Read_cmd_Total; i++) furi_string_free(Read_cmd[i]);
  277. Read_cmd_Total = 0;
  278. }
  279. if(Read_cmd) {
  280. free(Read_cmd);
  281. Read_cmd = NULL;
  282. }
  283. if(ReadBatch_cmd_Total) {
  284. for(uint16_t i = 0; i < ReadBatch_cmd_Total; i++) furi_string_free(ReadBatch_cmd[i]);
  285. ReadBatch_cmd_Total = 0;
  286. }
  287. if(ReadBatch_cmd) {
  288. free(ReadBatch_cmd);
  289. ReadBatch_cmd = NULL;
  290. }
  291. if(WriteBatch_cmd_Total) {
  292. for(uint16_t i = 0; i < WriteBatch_cmd_Total; i++) furi_string_free(WriteBatch_cmd[i]);
  293. WriteBatch_cmd_Total = 0;
  294. }
  295. if(WriteBatch_cmd) {
  296. free(WriteBatch_cmd);
  297. WriteBatch_cmd = NULL;
  298. }
  299. if(SetBatch_cmd_Total) {
  300. for(uint16_t i = 0; i < SetBatch_cmd_Total; i++) furi_string_free(SetBatch_cmd[i]);
  301. SetBatch_cmd_Total = 0;
  302. }
  303. if(SetBatch_cmd) {
  304. free(SetBatch_cmd);
  305. SetBatch_cmd = NULL;
  306. }
  307. free_Log();
  308. }
  309. void update_power(void)
  310. {
  311. Current = furi_hal_power_get_battery_current(FuriHalPowerICFuelGauge) * 1000;
  312. }
  313. void check_en_power_5V(void)
  314. {
  315. if(!furi_hal_power_is_otg_enabled() && !furi_hal_power_is_charging()) {
  316. FURI_LOG_D("PWR", "NO 5V, TURN ON");
  317. notification_message(APP->notification, &sequence_blink_yellow_100);
  318. furi_delay_ms(10);
  319. update_power();
  320. CurrentStart = Current;
  321. furi_hal_power_enable_otg();
  322. NRF_BOARD_POWER_5V = true;
  323. furi_delay_ms(100);
  324. NRF_INITED = 0;
  325. }
  326. }
  327. static bool select_settings_file() {
  328. DialogsApp* dialogs = furi_record_open("dialogs");
  329. bool result = false;
  330. FuriString* path;
  331. path = furi_string_alloc();
  332. furi_string_set(path, SCAN_APP_PATH_FOLDER);
  333. DialogsFileBrowserOptions browser_options;
  334. dialog_file_browser_set_basic_options(&browser_options, ".txt", NULL);
  335. browser_options.hide_ext = false;
  336. bool ret = dialog_file_browser_show(dialogs, path, path, &browser_options);
  337. furi_record_close("dialogs");
  338. if(ret) {
  339. if(!file_stream_open(file_stream, furi_string_get_cstr(path), FSAM_READ_WRITE, FSOM_OPEN_EXISTING)) {
  340. FURI_LOG_D(TAG, "Cannot open file \"%s\"", furi_string_get_cstr(path));
  341. file_stream_close(file_stream);
  342. } else {
  343. FURI_LOG_D(TAG, "Open file \"%s\"", furi_string_get_cstr(path));
  344. strncpy(file_name, furi_string_get_cstr(path) + sizeof(SCAN_APP_PATH_FOLDER), sizeof(file_name));
  345. result = true;
  346. }
  347. }
  348. furi_string_free(path);
  349. return result;
  350. }
  351. static void prepare_nrf24(void)
  352. {
  353. check_en_power_5V();
  354. if(!NRF_INITED || rw_type == rwt_listen || NRF_INITED == rwt_listen) {
  355. FURI_LOG_D("NRF", "Prepare");
  356. uint8_t adrlen, *adr;
  357. if(rw_type == rwt_listen) {
  358. adrlen = listen_addr_len;
  359. adr = listen_addr;
  360. NRF_INITED = rwt_listen;
  361. } else {
  362. adrlen = addr_len;
  363. adr = addr;
  364. NRF_INITED = 1;
  365. }
  366. furi_hal_gpio_write(nrf24_CE_PIN, false);
  367. nrf24_set_mac(REG_RX_ADDR_P0, adr, adrlen);
  368. uint8_t tmp[5] = { 0 };
  369. nrf24_read_reg(nrf24_HANDLE, REG_RX_ADDR_P0, tmp, adrlen);
  370. for(uint8_t i = 0; i < adrlen / 2; i++) {
  371. uint8_t tb = tmp[i];
  372. tmp[i] = tmp[adrlen - i - 1];
  373. tmp[adrlen - i - 1] = tb;
  374. }
  375. NRF_ERROR = memcmp(adr, tmp, adrlen) != 0;
  376. if(NRF_ERROR) {
  377. NRF_INITED = 0;
  378. return;
  379. }
  380. // EN_DYN_ACK(0x01) option for W_TX_PAYLOAD_NOACK cmd broke AA on some fake nRF24l01+, i.e. set it to 0
  381. nrf24_write_reg(nrf24_HANDLE, REG_FEATURE, NRF_EN_DYN_ACK + (NRF_DPL ? 4 : 0)); // Dynamic Payload, Payload with ACK, W_TX_PAYLOAD_NOACK command
  382. nrf24_write_reg(nrf24_HANDLE, REG_RF_CH, NRF_channel);
  383. nrf24_write_reg(nrf24_HANDLE, REG_RF_SETUP, (NRF_rate == 0 ? 0b00100000 : NRF_rate == 1 ? 0 : 0b00001000) | 0b111); // +TX high power
  384. nrf24_write_reg(nrf24_HANDLE, REG_CONFIG, 0x70 | ((NRF_CRC == 1 ? 0b1000 : NRF_CRC == 2 ? 0b1100 : 0))); // Mask all interrupts
  385. nrf24_write_reg(nrf24_HANDLE, REG_SETUP_RETR, NRF_RETR); // Automatic Retransmission, ARD<<4 + ARC
  386. nrf24_write_reg(nrf24_HANDLE, REG_EN_AA, 0x01); // Auto acknowledgement
  387. nrf24_write_reg(nrf24_HANDLE, REG_DYNPD, NRF_DPL ? 0x3F : 0); // Enable dynamic payload reg
  388. nrf24_write_reg(nrf24_HANDLE, RX_PW_P0, payload_size);
  389. nrf24_set_maclen(nrf24_HANDLE, adrlen);
  390. nrf24_set_mac(REG_TX_ADDR, adr, adrlen);
  391. nrf24_write_reg(nrf24_HANDLE, REG_EN_RXADDR, 1);
  392. //nrf24_set_idle(nrf24_HANDLE);
  393. }
  394. nrf24_flush_tx(nrf24_HANDLE);
  395. nrf24_flush_rx(nrf24_HANDLE);
  396. nrf24_write_reg(nrf24_HANDLE, REG_STATUS, MAX_RT | RX_DR | TX_DS);
  397. }
  398. // true - ok
  399. uint8_t nrf24_send_packet()
  400. {
  401. if(furi_log_get_level() == FuriLogLevelDebug) {
  402. char buf[65]; buf[0] = 0; add_to_str_hex_bytes(buf, payload, payload_size); FURI_LOG_D(TAG, "SEND: %s", buf);
  403. }
  404. //nrf24_flush_tx(nrf24_HANDLE);
  405. //nrf24_write_reg(nrf24_HANDLE, REG_STATUS, RX_DR | TX_DS | MAX_RT);
  406. NRF_last_packet_send_st = nrf24_txpacket(nrf24_HANDLE, payload, payload_size, true); // ACK
  407. if(NRF_last_packet_send_st) {
  408. if((rw_type == rwt_read_cmd || rw_type == rwt_read_batch) && send_status == sst_sending) { // Read
  409. nrf24_set_rx_mode(nrf24_HANDLE);
  410. send_status = sst_receiving; // receiving
  411. }
  412. } else notification_message(APP->notification, &sequence_blink_red_100);
  413. NRF_time = furi_get_tick();
  414. FURI_LOG_D(TAG, "Send packet: %d%s", NRF_last_packet_send_st, send_status == sst_receiving ? ", Receiving" : "");
  415. return NRF_last_packet_send_st;
  416. }
  417. uint8_t nrf24_resend_read_packet()
  418. {
  419. if(Log_Total && !cmd_array) {
  420. FuriString *str = Log[Log_Total - 1];
  421. char *p = strstr(furi_string_get_cstr(str), ": ");
  422. if(p) {
  423. if(strncmp(p + 2, "0x", 2) == 0) p += 2;
  424. furi_string_left(str, p - furi_string_get_cstr(str) + 2);
  425. }
  426. }
  427. return nrf24_send_packet();
  428. }
  429. // true - new packet
  430. bool nrf24_read_newpacket() {
  431. bool found = false;
  432. uint8_t packetsize;
  433. uint8_t st = nrf24_rxpacket(nrf24_HANDLE, payload_receive, &packetsize, NRF_DPL ? 0 : payload_size);
  434. if(st & RX_DR) {
  435. NRF_time = furi_get_tick();
  436. if(furi_log_get_level() == FuriLogLevelDebug) {
  437. char buf[65]; buf[0] = 0; add_to_str_hex_bytes(buf, payload_receive, packetsize); FURI_LOG_D(TAG, "READ(%X): %s", st, buf);
  438. }
  439. if(Log_Total) {
  440. FuriString *str = Log[Log_Total - 1];
  441. uint8_t size = 1;
  442. char *p = strchr((char*)furi_string_get_cstr(str), '*');
  443. if(p) {
  444. p++;
  445. if(*p == '=') size = 0; // string
  446. else {
  447. size = *p - '0';
  448. if(size > 4) size = 0;
  449. }
  450. }
  451. int32_t var = get_payload_receive_field(payload_receive, size);
  452. //FURI_LOG_D(TAG, "VAR(%d): %ld", size, var);
  453. if(size == 0) furi_string_cat_printf(str, "%c", (char)var);
  454. else {
  455. char hex[9];
  456. hex[0] = '\0';
  457. add_to_str_hex_bytes(hex, (uint8_t*)&var, size);
  458. if((cmd_array && cmd_array_hex) || furi_string_end_with_str(str, "0x")) furi_string_cat_str(str, hex);
  459. else {
  460. if(var >= 0 && var <= 9) furi_string_cat_printf(str, "%ld", var);
  461. else furi_string_cat_printf(str, "%ld (%s)", var, hex);
  462. }
  463. }
  464. if(cmd_array) {
  465. if(--cmd_array_cnt) {
  466. furi_string_cat_str(str, ",");
  467. if(cmd_array_hex) furi_string_cat_str(str, "0x");
  468. payload[cmd_array_idx] += size; // next array element
  469. NRF_repeat = -1;
  470. send_status = sst_sending; // Will be send after delay_between_pkt
  471. } else send_status = sst_ok;
  472. } else {
  473. if(size == 0) { // string, until '\0'
  474. if(var == 0) send_status = sst_ok;
  475. } else send_status = sst_ok;
  476. }
  477. }
  478. //notification_message(APP->notification, &sequence_blink_white_100);
  479. found = true;
  480. } else if(st & 0x80) { // NRF24 hardware error
  481. NRF_ERROR = 1;
  482. NRF_INITED = 0;
  483. }
  484. return found;
  485. }
  486. // Search in constatnt pull (Const1=n; Const2=n;...)
  487. // VAR_EMPTY - not found
  488. int32_t subs_constant(char *p, uint8_t len)
  489. {
  490. char *c = (char*)furi_string_get_cstr(Constants);
  491. while((c = strchr(c, *p))) {
  492. if(strncmp(c, p, len) != 0) {
  493. c++;
  494. continue;
  495. }
  496. if(c == (char*)furi_string_get_cstr(Constants) || *(c-1) == ';' || *(c-1) <= ' ') {
  497. c += len;
  498. if(*c == '=') {
  499. c++;
  500. return str_to_int(c);
  501. }
  502. } else c += len;
  503. }
  504. return VAR_EMPTY;
  505. }
  506. // fill payload with default = p
  507. // if var_n = VAR_EMPTY - skip filling var_*
  508. bool fill_payload(char *p, uint8_t *idx_i, int32_t var_n)
  509. {
  510. if(idx_i) *idx_i = 255;
  511. uint8_t fld = 0; // field #
  512. uint8_t idx = 0; // byte index
  513. do {
  514. int32_t b = 0;
  515. char *end = strchr(p, ',');
  516. if(*p >= '0' && *p <= '9') { // Number found
  517. b = str_to_int(p);
  518. } else if(*p == 'i' && *(p + 1) == ':') { // 'i:' array index
  519. b = str_to_int(p + 2);
  520. if(idx_i) *idx_i = idx;
  521. } else if(*p == 'n' && *(p + 1) < '0') { // var_n
  522. if(var_n != VAR_EMPTY) b = var_n;
  523. } else if(*p >= 'A') { // constant found
  524. uint8_t len;
  525. if(end) len = end - p;
  526. else {
  527. len = strlen(p);
  528. if(*(p + len - 1) == '#') len--;
  529. }
  530. b = subs_constant(p, len);
  531. if(b == VAR_EMPTY) {
  532. ERR = 1;
  533. memset(ERR_STR, 0, sizeof(ERR_STR));
  534. strcpy(ERR_STR, "No ");
  535. strncpy(ERR_STR + strlen(ERR_STR), p, sizeof(ERR_STR) - 4);
  536. FURI_LOG_D(TAG, "Constant not found: %s", p);
  537. return false;
  538. }
  539. } else if(end == p) {
  540. idx += payload_struct[fld];
  541. } else if(*p == '#') { // value in Hexadecimal, end string
  542. break;
  543. } else {
  544. ERR = 2;
  545. strcpy(ERR_STR, "char: ");
  546. uint8_t l = strlen(ERR_STR);
  547. ERR_STR[l] = *p;
  548. ERR_STR[l+1] = '\0';
  549. FURI_LOG_D(TAG, "Wrong format char(%c)", *p);
  550. return false;
  551. }
  552. if(end != p) {
  553. payload[idx++] = b;
  554. if(payload_struct[fld] > 1) payload[idx++] = b >> 8;
  555. if(payload_struct[fld] > 2) payload[idx++] = b >> 16;
  556. if(payload_struct[fld] > 3) payload[idx++] = b >> 24;
  557. }
  558. if(++fld == payload_fields || idx >= sizeof(payload) || end == NULL) break;
  559. p = end + 1;
  560. } while(1);
  561. return true;
  562. }
  563. // Cmd: "name=payload"
  564. bool Run_Read_cmd(FuriString *cmd)
  565. {
  566. char *p = (char*)furi_string_get_cstr(cmd);
  567. p = strchr(p, '=');
  568. if(p == NULL) return false;
  569. if(Log == NULL) Log = malloc(sizeof(Log));
  570. else Log = realloc(Log, sizeof(Log) * (Log_Total + 1));
  571. if(Log == NULL) {
  572. ERR = 3;
  573. strcpy(ERR_STR, "Memory low");
  574. FURI_LOG_D(TAG, ERR_STR);
  575. return false;
  576. }
  577. FuriString *fs = furi_string_alloc();
  578. furi_string_set_strn(fs, (char*)furi_string_get_cstr(cmd), p - (char*)furi_string_get_cstr(cmd));
  579. furi_string_cat_str(fs, ": ");
  580. bool hexval;
  581. if((hexval = *(p + strlen(p) - 1) == '#')) furi_string_cat_str(fs, "0x"); // value in Hex format
  582. Log[Log_Total++] = fs;
  583. p++;
  584. memset(payload, 0, sizeof(payload));
  585. if(ReadDefault && !fill_payload((char*)furi_string_get_cstr(ReadDefault), NULL, VAR_EMPTY)) return false;
  586. if(!fill_payload(p, &cmd_array_idx, VAR_EMPTY)) return false;
  587. memset(payload_receive, 0, sizeof(payload_receive));
  588. cmd_array = false;
  589. if(*(p - 2) == ']' && cmd_array_idx != 255) { // array
  590. p = strchr(furi_string_get_cstr(cmd), '[');
  591. if(p) {
  592. cmd_array_cnt = str_to_int(p + 1);
  593. if(cmd_array_cnt > 1) {
  594. cmd_array_hex = hexval;
  595. cmd_array = true; // array
  596. }
  597. }
  598. }
  599. prepare_nrf24();
  600. if(NRF_ERROR) return false;
  601. what_doing = 2;
  602. NRF_repeat = 0;
  603. send_status = sst_sending; // Read - sending
  604. nrf24_send_packet();
  605. return true;
  606. }
  607. // run commands one by one, true - command running
  608. bool Run_ReadBatch_cmd(FuriString *cmd)
  609. {
  610. char *p;
  611. if(cmd) {
  612. p = strchr((char*)furi_string_get_cstr(cmd), ':');
  613. if(p == NULL) {
  614. ERR = 5;
  615. strcpy(ERR_STR, "WRONG FORMAT");
  616. return false;
  617. }
  618. p += 2;
  619. ReadBatch_cmd_curr = NULL;
  620. free_Log();
  621. } else {
  622. if(ReadBatch_cmd_curr) p = ReadBatch_cmd_curr; else return false;
  623. }
  624. char *end = strchr(p, ';');
  625. uint8_t len;
  626. if(end) len = end - p;
  627. else {
  628. str_rtrim(p);
  629. len = strlen(p);
  630. }
  631. for(uint16_t i = 0; i < Read_cmd_Total; i++) {
  632. FuriString *fs = Read_cmd[i];
  633. if(strncmp((char*)furi_string_get_cstr(fs), p, len) == 0) {
  634. char c = *((char*)furi_string_get_cstr(fs) + len);
  635. if(c != '=' && c != '*' && c != '[') continue;
  636. if(end) ReadBatch_cmd_curr = end + 1; else ReadBatch_cmd_curr = (char*)0xFFFFFFFF;
  637. if(!Run_Read_cmd(fs)) break;
  638. return true;
  639. }
  640. }
  641. if(NRF_ERROR) return false;
  642. if(ERR == 0) {
  643. ERR = 4;
  644. strcpy(ERR_STR, "NOT FOUND");
  645. FuriString *fs = furi_string_alloc();
  646. furi_string_set_strn(fs, p, len);
  647. Log[Log_Total++] = fs;
  648. FURI_LOG_D(TAG, "CMD %s: %s", ERR_STR, p);
  649. }
  650. view_Batch = Log_Total ? Log_Total - 1 : 0;
  651. return false;
  652. }
  653. void Prepare_Write_cmd(FuriString *cmd)
  654. {
  655. free_Log();
  656. if(cmd == NULL) return;
  657. char *end, *p = strchr((char*)furi_string_get_cstr(cmd), ':');
  658. if(p == NULL) {
  659. ERR = 8;
  660. strcpy(ERR_STR, "Wrong batch");
  661. FURI_LOG_D(TAG, ERR_STR);
  662. return;
  663. }
  664. p += 2;
  665. Log = malloc(sizeof(Log));
  666. do {
  667. end = strchr(p, ';');
  668. uint8_t len;
  669. if(end) {
  670. len = end - p;
  671. end++;
  672. } else {
  673. str_rtrim(p);
  674. len = strlen(p);
  675. }
  676. FuriString *fs = furi_string_alloc();
  677. if(Log_Total) Log = realloc(Log, sizeof(Log) * (Log_Total + 1));
  678. if(Log == NULL) {
  679. ERR = 3;
  680. strcpy(ERR_STR, "Memory low");
  681. FURI_LOG_D(TAG, ERR_STR);
  682. return;
  683. }
  684. furi_string_set_strn(fs, p, len);
  685. Log[Log_Total++] = fs;
  686. } while((p = end));
  687. }
  688. // Write / Set batch
  689. bool Run_WriteBatch_cmd()
  690. {
  691. if(Log_Total == 0) return false;
  692. uint16_t cmd_curr = rw_type == rwt_write_batch ? WriteBatch_cmd_curr : SetBatch_cmd_curr;
  693. if(cmd_curr == 0) { // first
  694. prepare_nrf24();
  695. if(NRF_ERROR) return false;
  696. if(rw_type == rwt_write_batch && WriteStart) {
  697. if(!fill_payload((char*)furi_string_get_cstr(WriteStart), NULL, VAR_EMPTY)) return false;
  698. send_status = sst_sending;
  699. if(!nrf24_send_packet()) return false;
  700. }
  701. }
  702. char *p = (char*)furi_string_get_cstr(Log[cmd_curr]);
  703. uint16_t len = furi_string_size(Log[cmd_curr]);
  704. char *arr = NULL;
  705. cmd_array = false;
  706. int32_t new = 0;
  707. for(uint16_t i = 0; i < len; i++) {
  708. if(p[i] == '=') {
  709. len = i;
  710. char *p2 = p + i + 1;
  711. if(*p2 == '{') {
  712. arr = ++p2; // array
  713. cmd_array = true;
  714. }
  715. new = str_to_int(p2);
  716. break;
  717. }
  718. }
  719. FURI_LOG_D(TAG, "%cBatch: =%d, (%d)%s", rw_type == rwt_write_batch ? 'W' : 'S', (int)new, len, p);
  720. char *w, *delim_col, i, size;
  721. FuriString* str = furi_string_alloc();
  722. stream_rewind(file_stream);
  723. while(stream_read_line(file_stream, str)) {
  724. w = (char*)furi_string_get_cstr(str);
  725. if(strncmp(w, SettingsFld_Write, sizeof(SettingsFld_Write)-1) == 0) w += sizeof(SettingsFld_Write);
  726. else if(strncmp(w, SettingsFld_Set, sizeof(SettingsFld_Set)-1) == 0) w += sizeof(SettingsFld_Set);
  727. else continue;
  728. delim_col = strchr(w, '=');
  729. if(delim_col == NULL) continue;
  730. size = 1;
  731. if(*(delim_col - 2) == '*') {
  732. if(len != delim_col - w - 2) continue;
  733. size = *(delim_col - 1) - '0';
  734. new = new & (size == 1 ? 0xFF : size == 2 ? 0xFFFF : size == 3 ? 0xFFFFFF : 0xFFFFFFFF);
  735. } else if(len != delim_col - w) continue;
  736. if(strncmp(p, w, len) != 0) continue;
  737. delim_col++;
  738. str_rtrim(delim_col);
  739. cmd_array_cnt = 255;
  740. do {
  741. memset(payload, 0, sizeof(payload));
  742. if(WriteDefault && !fill_payload((char*)furi_string_get_cstr(WriteDefault), NULL, new)) {
  743. view_Batch = cmd_curr;
  744. return false;
  745. }
  746. if(!fill_payload(delim_col, &cmd_array_idx, VAR_EMPTY)) {
  747. view_Batch = cmd_curr;
  748. return false;
  749. }
  750. if(cmd_array && cmd_array_idx != 255) {
  751. if(cmd_array_cnt != 255) payload[cmd_array_idx] = cmd_array_cnt;
  752. } else cmd_array = false;
  753. send_status = sst_sending;
  754. NRF_repeat = 0;
  755. i = 0;
  756. do {
  757. if(nrf24_send_packet()) break;
  758. furi_delay_ms(delay_between_pkt);
  759. } while(i++ < NRF_resend);
  760. if(i < NRF_resend || i == 0) { // ok
  761. if(cmd_array) { // array
  762. for(; arr != NULL;) {
  763. if(*arr == ',') break;
  764. if(*arr == '}' || *arr < ' ') arr = NULL; else arr++;
  765. }
  766. if(arr == NULL) {
  767. send_status = sst_ok;
  768. break;
  769. }
  770. arr++;
  771. new = str_to_int(arr);
  772. cmd_array_cnt = payload[cmd_array_idx] + size;
  773. //furi_delay_ms(delay_between_pkt); // do it fast
  774. continue; // send next array element
  775. } else send_status = sst_ok;
  776. }
  777. break;
  778. } while(1);
  779. if(send_status != sst_ok) {
  780. send_status = sst_error;
  781. view_Batch = cmd_curr;
  782. return false;
  783. }
  784. return true;
  785. }
  786. ERR = 7;
  787. strcpy(ERR_STR, "NOT FOUND!");
  788. send_status = sst_error;
  789. view_Batch = cmd_curr;
  790. return false;
  791. }
  792. // Return 0 - success, otherwise an error
  793. static uint8_t load_settings_file() {
  794. uint8_t err = 0;
  795. FURI_LOG_D(TAG, "Loading settings file");
  796. FuriString* str = furi_string_alloc();
  797. free_store();
  798. Info[0] = '\0';
  799. NRF_INITED = false;
  800. while(stream_read_line(file_stream, str)) {
  801. char *p = (char*)furi_string_get_cstr(str);
  802. if(*p <= ' ') continue;
  803. //char* delim_eq = strchr(p, '=');
  804. char *delim_col = strchr(p, ':');
  805. if(delim_col == NULL) { // Constant found - no ':'
  806. if(Constants == NULL) {
  807. Constants = furi_string_alloc_set(str);
  808. } else furi_string_cat(Constants, str);
  809. } else {
  810. str_rtrim(p);
  811. if(strncmp(p, SettingsFld_Rate, sizeof(SettingsFld_Rate)-1) == 0) {
  812. NRF_rate = str_to_int(p + sizeof(SettingsFld_Rate));
  813. } else if(strncmp(p, SettingsFld_Info, sizeof(SettingsFld_Info)-1) == 0) {
  814. strncpy(Info, p + sizeof(SettingsFld_Info), sizeof(Info)-1);
  815. } else if(strncmp(p, SettingsFld_Ch, sizeof(SettingsFld_Ch)-1) == 0) {
  816. NRF_channel = str_to_int(p + sizeof(SettingsFld_Ch));
  817. } else if(strncmp(p, SettingsFld_Address, sizeof(SettingsFld_Address)-1) == 0) {
  818. p += sizeof(SettingsFld_Address);
  819. addr_len = ConvertHexToArray(p, addr, 5);
  820. } else if(strncmp(p, SettingsFld_CRC, sizeof(SettingsFld_CRC)-1) == 0) {
  821. NRF_CRC = str_to_int(p + sizeof(SettingsFld_CRC));
  822. } else if(strncmp(p, SettingsFld_DPL, sizeof(SettingsFld_DPL)-1) == 0) {
  823. NRF_DPL = str_to_int(p + sizeof(SettingsFld_DPL));
  824. } else if(strncmp(p, SettingsFld_RETR, sizeof(SettingsFld_RETR)-1) == 0) {
  825. NRF_RETR = str_to_int(p + sizeof(SettingsFld_RETR));
  826. } else if(strncmp(p, SettingsFld_Resend, sizeof(SettingsFld_Resend)-1) == 0) {
  827. NRF_resend = str_to_int(p + sizeof(SettingsFld_Resend));
  828. } else if(strncmp(p, SettingsFld_Delay, sizeof(SettingsFld_Delay)-1) == 0) {
  829. delay_between_pkt = str_to_int(p + sizeof(SettingsFld_Delay));
  830. } else if(strncmp(p, SettingsFld_ReadCmdRepeatPeriod, sizeof(SettingsFld_ReadCmdRepeatPeriod)-1) == 0) {
  831. ReadCmdRepeatPeriod = str_to_int(p + sizeof(SettingsFld_ReadCmdRepeatPeriod));
  832. } else if(strncmp(p, SettingsFld_Payload, sizeof(SettingsFld_Payload)-1) == 0) {
  833. p += sizeof(SettingsFld_Payload);
  834. payload_fields = 0;
  835. payload_size = 0;
  836. do {
  837. uint8_t b = str_to_int(p);
  838. if(b < 1 || b > 4) {
  839. FURI_LOG_D(TAG, "Wrong payload format (%d)", b);
  840. err = 3;
  841. break;
  842. }
  843. payload_struct[payload_fields++] = b;
  844. payload_size += b;
  845. if(payload_fields == sizeof(payload_struct) - 1) break;
  846. if((p = strchr(p, ',')) == NULL) break;
  847. p++;
  848. } while(1);
  849. FURI_LOG_D(TAG, "Payload fields %d: %d,%d,%d", payload_fields, payload_struct[0], payload_struct[1], payload_struct[2]);
  850. } else if(strncmp(p, SettingsFld_ReadDefault, sizeof(SettingsFld_ReadDefault)-1) == 0) {
  851. ReadDefault = furi_string_alloc_set_str(p + sizeof(SettingsFld_ReadDefault));
  852. } else if(strncmp(p, SettingsFld_WriteStart, sizeof(SettingsFld_WriteStart)-1) == 0) {
  853. WriteStart = furi_string_alloc_set_str(p + sizeof(SettingsFld_WriteStart));
  854. } else if(strncmp(p, SettingsFld_WriteDefault, sizeof(SettingsFld_WriteDefault)-1) == 0) {
  855. WriteDefault = furi_string_alloc_set_str(p + sizeof(SettingsFld_WriteDefault));
  856. } else if(strncmp(p, SettingsFld_Read, sizeof(SettingsFld_Read)-1) == 0) {
  857. p += sizeof(SettingsFld_Read);
  858. if(Read_cmd == NULL) Read_cmd = malloc(sizeof(Read_cmd));
  859. else {
  860. Read_cmd = realloc(Read_cmd, sizeof(Read_cmd) * (Read_cmd_Total + 1));
  861. }
  862. if(Read_cmd == NULL) {
  863. FURI_LOG_D(TAG, "Memory low, err 4");
  864. err = 4;
  865. break;
  866. }
  867. Read_cmd[Read_cmd_Total++] = furi_string_alloc_set_str(p);
  868. } else if(strncmp(p, SettingsFld_ReadBatch, sizeof(SettingsFld_ReadBatch)-1) == 0) {
  869. p += sizeof(SettingsFld_ReadBatch);
  870. if(ReadBatch_cmd == NULL) ReadBatch_cmd = malloc(sizeof(ReadBatch_cmd));
  871. else {
  872. ReadBatch_cmd = realloc(ReadBatch_cmd, sizeof(ReadBatch_cmd) * (ReadBatch_cmd_Total + 1));
  873. }
  874. if(ReadBatch_cmd == NULL) {
  875. FURI_LOG_D(TAG, "Memory low, err 5");
  876. err = 5;
  877. break;
  878. }
  879. ReadBatch_cmd[ReadBatch_cmd_Total++] = furi_string_alloc_set_str(p);
  880. } else if(strncmp(p, SettingsFld_WriteBatch, sizeof(SettingsFld_WriteBatch)-1) == 0) {
  881. p += sizeof(SettingsFld_WriteBatch);
  882. if(WriteBatch_cmd == NULL) WriteBatch_cmd = malloc(sizeof(WriteBatch_cmd));
  883. else {
  884. WriteBatch_cmd = realloc(WriteBatch_cmd, sizeof(WriteBatch_cmd) * (WriteBatch_cmd_Total + 1));
  885. }
  886. if(WriteBatch_cmd == NULL) {
  887. FURI_LOG_D(TAG, "Memory low, err 6");
  888. err = 6;
  889. break;
  890. }
  891. WriteBatch_cmd[WriteBatch_cmd_Total++] = furi_string_alloc_set_str(p);
  892. } else if(strncmp(p, SettingsFld_SetBatch, sizeof(SettingsFld_SetBatch)-1) == 0) {
  893. p += sizeof(SettingsFld_SetBatch);
  894. if(SetBatch_cmd == NULL) SetBatch_cmd = malloc(sizeof(SetBatch_cmd));
  895. else {
  896. SetBatch_cmd = realloc(SetBatch_cmd, sizeof(SetBatch_cmd) * (SetBatch_cmd_Total + 1));
  897. }
  898. if(SetBatch_cmd == NULL) {
  899. FURI_LOG_D(TAG, "Memory low, err 7");
  900. err = 7;
  901. break;
  902. }
  903. SetBatch_cmd[SetBatch_cmd_Total++] = furi_string_alloc_set_str(p);
  904. } else if(strncmp(p, SettingsFld_Listen, sizeof(SettingsFld_Listen)-1) == 0) {
  905. p += sizeof(SettingsFld_Listen);
  906. char *p2 = strchr(p, '=');
  907. if(p2) {
  908. listen_addr_len = ConvertHexToArray(p, listen_addr, (p2 - p) / 2);
  909. p2++;
  910. uint8_t len = strlen(p2);
  911. ListenFields = malloc(len + 1);
  912. if(ListenFields) memcpy(ListenFields, p2, len);
  913. }
  914. }
  915. }
  916. }
  917. furi_string_free(str);
  918. return err;
  919. }
  920. static void save_batch(void)
  921. {
  922. FURI_LOG_D(TAG, "Save Batch");
  923. char *p, *p2;
  924. stream_seek(file_stream, 0, StreamOffsetFromEnd);
  925. FuriHalRtcDateTime dt;
  926. furi_hal_rtc_get_datetime(&dt);
  927. stream_write_format(file_stream, "\n%s ", SettingsFld_WriteBatch);
  928. p = (char*)furi_string_get_cstr(ReadBatch_cmd[view_cmd[rwt_read_batch]]);
  929. p2 = strchr(p, ':');
  930. if(p2 == NULL) p2 = p + strlen(p);
  931. stream_write(file_stream, (uint8_t*)p, p2 - p);
  932. stream_write_format(file_stream, " %02d.%02d.%02d %02d.%02d: ", dt.day, dt.month, dt.year % 100, dt.hour, dt.minute);
  933. for(uint16_t i = 0; i < Log_Total; i++) {
  934. p = (char*) furi_string_get_cstr(Log[i]);
  935. p2 = strchr(p, ':');
  936. if(p2 && *(p2-1) != '*') { // skip string
  937. if(*(p2-1) == ']') { // array
  938. char *p3 = strchr(p, '[');
  939. if(p3) {
  940. stream_write(file_stream, (uint8_t*)p, p3 - p - (*(p3-2) == '*' ? 2 : 0));
  941. stream_write_cstring(file_stream, "={");
  942. p = (p2 += 2);
  943. do {
  944. while(is_digit(p2, true) || *p2 == 'x') p2++;
  945. stream_write(file_stream, (uint8_t*)p, p2 - p);
  946. char c = *p2;
  947. if(c == '\0') break;
  948. if(c != ',') {
  949. p2 = strchr(p2, ',');
  950. if(p2 == NULL) break;
  951. }
  952. stream_write_char(file_stream, ',');
  953. p = ++p2;
  954. } while(1);
  955. stream_write_char(file_stream, '}');
  956. }
  957. } else {
  958. stream_write(file_stream, (uint8_t*)p, p2 - p - (*(p2-2) == '*' ? 2 : 0));
  959. stream_write_char(file_stream, '=');
  960. p2 += 2;
  961. p = strchr(p2, ' ');
  962. if(p == NULL) p = p2 + strlen(p2);
  963. stream_write(file_stream, (uint8_t*)p2, p - p2);
  964. }
  965. if(i < Log_Total - 1) stream_write_char(file_stream, ';');
  966. }
  967. }
  968. }
  969. static void input_callback(InputEvent* input_event, FuriMessageQueue* event_queue) {
  970. furi_assert(event_queue);
  971. PluginEvent event = {.type = EventTypeKey, .input = *input_event};
  972. furi_message_queue_put(event_queue, &event, FuriWaitForever);
  973. }
  974. void display_remove_asterisk(char *fsp, uint8_t vx)
  975. {
  976. char *p2 = strchr(fsp, '*');
  977. if(p2) { // remove '*' or '*n'
  978. int pos = p2 - fsp;
  979. if((pos -= vx) < 0) pos = 0;
  980. char c = *(p2 + 1);
  981. if(*(screen_buf + pos))
  982. memmove(screen_buf + pos, screen_buf + pos + (c == ':' || c == '=' ? 1 : 2), FONT_5x7_SCREEN_WIDTH + 1 + 2 - pos);
  983. }
  984. }
  985. void render_display_list(Canvas* const canvas, FuriString ***fsa, char delim, uint16_t view_pos, uint16_t max_i)
  986. {
  987. uint16_t page = view_pos & ~7;
  988. char *p, *end;
  989. uint16_t y, len;
  990. for(uint8_t i = 0; i < 8 && page + i < max_i; i++) {
  991. y = 14 + i * 7;
  992. p = (char*) furi_string_get_cstr((*fsa)[page + i]);
  993. end = strchr(p, delim);
  994. if(end) {
  995. len = MIN(end - p, view_x);
  996. len = MIN(end - p - len, FONT_5x7_SCREEN_WIDTH);
  997. strncpy(screen_buf, p + view_x, len);
  998. screen_buf[len] = '\0';
  999. display_remove_asterisk(p, MIN(end - p, view_x));
  1000. canvas_draw_str(canvas, 5, y, screen_buf);
  1001. }
  1002. if((view_pos & 7) == i) {
  1003. canvas_draw_str(canvas, 0, y, ">");
  1004. canvas_draw_str(canvas, -1, y, ">");
  1005. }
  1006. }
  1007. }
  1008. void display_edit_ttf_font(Canvas* const canvas, uint8_t start_x, uint8_t start_y)
  1009. {
  1010. screen_buf[0] = *Edit_pos; screen_buf[1] = '\0';
  1011. int n = canvas_string_width(canvas, screen_buf);
  1012. int len = Edit_pos - Edit_start;
  1013. memcpy(screen_buf, Edit_start, len);
  1014. screen_buf[len] = '\0';
  1015. int x = start_x + canvas_string_width(canvas, screen_buf);
  1016. int len2 = strlen(Edit_pos);
  1017. memcpy(screen_buf + len, Edit_pos, len2);
  1018. screen_buf[len + len2] = '\0';
  1019. canvas_draw_str(canvas, start_x, start_y, screen_buf);
  1020. start_y += 1;
  1021. canvas_draw_line(canvas, x + (len ? 1 : 0), start_y, x + n + (*Edit_pos == '1' && len ? 1 : 0), start_y);
  1022. }
  1023. void display_add_status(void)
  1024. {
  1025. if(NRF_ERROR) strcat(screen_buf, "nRF24 ERROR!");
  1026. else if(ERR) snprintf(screen_buf, sizeof(screen_buf), "ERROR %s", ERR_STR);
  1027. else if(send_status == sst_error) strcat(screen_buf, "NO ACK!");
  1028. else if(send_status == sst_timeout) strcat(screen_buf, "TIMEOUT!");
  1029. else if(send_status == sst_none) ;
  1030. else if(send_status == sst_sending) strcat(screen_buf, "sending");
  1031. else if(send_status == sst_receiving) strcat(screen_buf, "receiving");
  1032. else if(send_status == sst_ok &&
  1033. (rw_type == rwt_read_cmd
  1034. || (rw_type == rwt_read_batch && (uint32_t)ReadBatch_cmd_curr == 0xFFFFFFFF)
  1035. || (rw_type == rwt_set_batch && SetBatch_cmd_curr == Log_Total)
  1036. || (rw_type == rwt_write_batch && WriteBatch_cmd_curr == Log_Total)))
  1037. strcat(screen_buf, "OK");
  1038. else strcat(screen_buf, "working");
  1039. }
  1040. static void render_callback(Canvas* const canvas, void* ctx) {
  1041. if(ctx == NULL) return;
  1042. const PluginState* plugin_state = ctx;
  1043. if(furi_mutex_acquire(plugin_state->mutex, 5) != FuriStatusOk) return;
  1044. //canvas_draw_frame(canvas, 0, 0, 128, 64); // border around the edge of the screen
  1045. if(what_doing == 0) {
  1046. canvas_set_font(canvas, FontSecondary); // 8x10 font, 6 lines
  1047. snprintf(screen_buf, sizeof(screen_buf), "%s: %s", addr_len ? "File" : "Open", file_name);
  1048. canvas_draw_str(canvas, 8, 10, screen_buf);
  1049. if(addr_len) {
  1050. if(Edit) {
  1051. if(setup_cursor == 1) display_edit_ttf_font(canvas, 45, 20);
  1052. else if(setup_cursor == 2) display_edit_ttf_font(canvas, 55, 30);
  1053. }
  1054. if(!Edit || setup_cursor != 1) {
  1055. screen_buf[0] = '\0';
  1056. add_to_str_hex_bytes(screen_buf, addr, addr_len);
  1057. canvas_draw_str(canvas, 45, 20, screen_buf);
  1058. }
  1059. if(!Edit || setup_cursor != 2) {
  1060. snprintf(screen_buf, sizeof(screen_buf), "%d", NRF_channel);
  1061. canvas_draw_str(canvas, 55, 30, screen_buf);
  1062. }
  1063. canvas_draw_str(canvas, 8, 20, "Address:");
  1064. snprintf(screen_buf, sizeof(screen_buf), "Rate: %d, Ch:", NRF_rate);
  1065. canvas_draw_str(canvas, 8, 30, screen_buf);
  1066. snprintf(screen_buf, sizeof(screen_buf), "RB: %d, R: %d, WB: %d", ReadBatch_cmd_Total, Read_cmd_Total, WriteBatch_cmd_Total);
  1067. canvas_draw_str(canvas, 8, 40, screen_buf);
  1068. canvas_draw_str(canvas, 0, 64, Info);
  1069. canvas_draw_str(canvas, 0, 10 + setup_cursor * 10, ">");
  1070. } else {
  1071. snprintf(screen_buf, sizeof(screen_buf), "Ver. %s, vad7", VERSION);
  1072. canvas_draw_str(canvas, 10, 60, screen_buf);
  1073. canvas_draw_str(canvas, 0, 10, ">");
  1074. }
  1075. } else if(what_doing == 1){
  1076. if(rw_type == rwt_listen) {
  1077. canvas_set_font(canvas, FontSecondary); // 8x10 font, 6 lines
  1078. canvas_draw_str(canvas, 0, 10, "Listen mode");
  1079. canvas_draw_str(canvas, 0, 25, "Address:");
  1080. if(Edit) display_edit_ttf_font(canvas, 40, 25);
  1081. else if(listen_addr_len) {
  1082. screen_buf[0] = '\0';
  1083. add_to_str_hex_bytes(screen_buf, listen_addr, listen_addr_len);
  1084. canvas_draw_str(canvas, 40, 25, screen_buf);
  1085. }
  1086. snprintf(screen_buf, sizeof(screen_buf), "I: %d +(%d) mA", Current - CurrentStart, CurrentStart);
  1087. canvas_draw_str(canvas, 0, 60, screen_buf);
  1088. } else {
  1089. canvas_set_font(canvas, FontBatteryPercent); // 5x7 font, 9 lines, 25 cols
  1090. if(rw_type == rwt_read_batch) {
  1091. canvas_draw_str(canvas, 0, 7, "Read Batch:");
  1092. render_display_list(canvas, &ReadBatch_cmd, ':', view_cmd[rw_type], ReadBatch_cmd_Total);
  1093. } else if(rw_type == rwt_read_cmd) {
  1094. canvas_draw_str(canvas, 0, 7, "Read Command:");
  1095. render_display_list(canvas, &Read_cmd, '=', view_cmd[rw_type], Read_cmd_Total);
  1096. } else if(rw_type == rwt_write_batch) {
  1097. if(!ask_fill_screen_buf()) strcpy(screen_buf, "Write Batch:");
  1098. canvas_draw_str(canvas, 0, 7, screen_buf);
  1099. render_display_list(canvas, &WriteBatch_cmd, ':', view_cmd[rw_type], WriteBatch_cmd_Total);
  1100. } else if(rw_type == rwt_set_batch) {
  1101. strcpy(screen_buf, "Set: ");
  1102. display_add_status();
  1103. canvas_draw_str(canvas, 0, 7, screen_buf);
  1104. render_display_list(canvas, &SetBatch_cmd, ':', view_cmd[rw_type], SetBatch_cmd_Total);
  1105. }
  1106. }
  1107. } else { // what_doing == 2
  1108. if(rw_type == rwt_listen) {
  1109. canvas_set_font(canvas, FontSecondary); // 8x10 font, 6 lines
  1110. strcpy(screen_buf, "Listen: ");
  1111. if(NRF_ERROR) strcat(screen_buf, "nRF24 ERROR!");
  1112. else if(ListenNew) {
  1113. snprintf(screen_buf + strlen(screen_buf), 16, "%02d:%02d:%02d", ListenLastTime.hour, ListenLastTime.minute, ListenLastTime.second);
  1114. if(ListenPrev) snprintf(screen_buf + strlen(screen_buf), 16, " (%lu)", ListenLast - ListenPrev);
  1115. } else strcat(screen_buf, "receiving");
  1116. snprintf(screen_buf + strlen(screen_buf), 16, " %dmA", Current - CurrentStart);
  1117. canvas_draw_str(canvas, 0, 10, screen_buf);
  1118. if(ListenFields) {
  1119. char *p2, *p = ListenFields;
  1120. uint8_t hex, len, *pld = payload_receive;
  1121. for(uint8_t i = 0; i < 5 && *p; i++) {
  1122. hex = false;
  1123. p2 = strchr(p, ',');
  1124. if(p2 == NULL) p2 = p + strlen(p);
  1125. if(*(p2 - 1) == '#') hex = true;
  1126. memcpy(screen_buf, p, len = p2 - p);
  1127. strcpy(screen_buf + len, ": ");
  1128. if(ListenNew) {
  1129. len = payload_struct[i];
  1130. int32_t n = get_payload_receive_field(pld, len);
  1131. if(hex) {
  1132. strcat(screen_buf, "0x");
  1133. add_to_str_hex_bytes(screen_buf, pld, len);
  1134. } else {
  1135. snprintf(screen_buf + strlen(screen_buf), 20, "%ld", n);
  1136. if(n > 9) {
  1137. strcat(screen_buf, " (");
  1138. add_to_str_hex_bytes(screen_buf, pld, len);
  1139. strcat(screen_buf, ")");
  1140. }
  1141. }
  1142. pld += len;
  1143. }
  1144. canvas_draw_str(canvas, 0, 20 + i * 10, screen_buf);
  1145. if(*p2 == '\0') break;
  1146. p = p2 + 1;
  1147. }
  1148. }
  1149. } else if(rw_type == rwt_read_cmd) { // Read command
  1150. canvas_set_font(canvas, FontSecondary); // 8x10 font, 6 lines
  1151. if(!ask_fill_screen_buf()) {
  1152. strcpy(screen_buf, "Read ");
  1153. strcat(screen_buf, ReadRepeat ? "rep: " : "cmd: ");
  1154. }
  1155. display_add_status();
  1156. canvas_draw_str(canvas, 0, 10, screen_buf);
  1157. if(Log_Total) {
  1158. char *p = (char*)furi_string_get_cstr(Log[Log_Total - 1]);
  1159. uint8_t vx = MIN(view_x, strlen(p));
  1160. strncpy(screen_buf, p + vx, 30);
  1161. display_remove_asterisk(p, vx);
  1162. canvas_draw_str(canvas, 0, 15 + 10, screen_buf);
  1163. }
  1164. } else if(rw_type == rwt_set_batch) {
  1165. canvas_set_font(canvas, FontBatteryPercent); // 5x7 font, 9 lines, 25 cols
  1166. strcpy(screen_buf, "Set: ");
  1167. display_add_status();
  1168. canvas_draw_str(canvas, 0, 7, screen_buf);
  1169. render_display_list(canvas, &SetBatch_cmd, ':', view_cmd[rw_type], SetBatch_cmd_Total);
  1170. } else { // rwt_read_batch, rwt_write_batch
  1171. canvas_set_font(canvas, FontBatteryPercent); // 5x7 font, 9 lines, 25 cols
  1172. if(!ask_fill_screen_buf()) {
  1173. strcpy(screen_buf, rw_type == rwt_read_batch ? "Read Batch: " : "Write: ");
  1174. if(rw_type == rwt_read_batch || send_status != sst_none) {
  1175. display_add_status();
  1176. } else if(rw_type == rwt_write_batch) {
  1177. char *p = (char*)furi_string_get_cstr(WriteBatch_cmd[view_cmd[rwt_write_batch]]);
  1178. char *end = strchr(p, ':');
  1179. if(end) {
  1180. uint8_t len = end - p;
  1181. uint8_t lenb = strlen(screen_buf);
  1182. end = screen_buf + lenb;
  1183. lenb = FONT_5x7_SCREEN_WIDTH - lenb;
  1184. if(len > lenb) {
  1185. if(view_x < len) {
  1186. strncpy(end, p + view_x, len = MIN(lenb, len - view_x));
  1187. end[len] = '\0';
  1188. }
  1189. } else {
  1190. strncpy(end, p, len);
  1191. end[len] = '\0';
  1192. }
  1193. }
  1194. }
  1195. }
  1196. canvas_draw_str(canvas, 0, 7, screen_buf);
  1197. if(Log_Total) {
  1198. char *p;
  1199. uint16_t y, page = view_Batch & ~7;
  1200. uint8_t vx;
  1201. for(uint8_t i = 0; i < 8 && page + i < Log_Total; i++) {
  1202. p = (char*)furi_string_get_cstr(Log[page + i]);
  1203. y = 14 + i * 7;
  1204. vx = MIN(view_x, strlen(p));
  1205. if((view_Batch & 7) == i) {
  1206. canvas_draw_str(canvas, 0, y, ">");
  1207. canvas_draw_str(canvas, -1, y, ">");
  1208. if(Edit) {
  1209. int n = Edit_pos - p - vx - (FONT_5x7_SCREEN_WIDTH - 4);
  1210. if(n > 0) vx += n; // fix out of screen
  1211. int x = 6 + (Edit_pos - p - vx) * 5;
  1212. canvas_draw_line(canvas, x - 1, y, x - 1, y - 1);
  1213. canvas_draw_line(canvas, x - 1, y, n = x + 1 * 5, y);
  1214. canvas_draw_line(canvas, n, y, n, y - 1);
  1215. }
  1216. }
  1217. strncpy(screen_buf, p + vx, FONT_5x7_SCREEN_WIDTH + 2);
  1218. screen_buf[FONT_5x7_SCREEN_WIDTH + 2] = '\0';
  1219. display_remove_asterisk(p, vx);
  1220. canvas_draw_str(canvas, 6, y, screen_buf);
  1221. }
  1222. }
  1223. }
  1224. }
  1225. furi_mutex_release(plugin_state->mutex);
  1226. }
  1227. void work_timer_callback(void* ctx)
  1228. {
  1229. if(ctx == NULL) return;
  1230. if(rw_type == rwt_listen && (pwr_read_timer += WORK_PERIOD) >= POWER_READ_PERIOD) {
  1231. pwr_read_timer = 0;
  1232. update_power();
  1233. }
  1234. if(what_doing == 2) {
  1235. const PluginState* plugin_state = ctx;
  1236. if(furi_mutex_acquire(plugin_state->mutex, 0) != FuriStatusOk) return;
  1237. if(rw_type == rwt_write_batch || rw_type == rwt_set_batch) {
  1238. uint16_t *cmd_curr = rw_type == rwt_set_batch ? &SetBatch_cmd_curr : &WriteBatch_cmd_curr;
  1239. if(ERR == 0 && furi_get_tick() - NRF_time >= delay_between_pkt) {
  1240. if(send_status == sst_ok) {
  1241. if(ERR == 0 && *cmd_curr < Log_Total) {
  1242. if(++(*cmd_curr) < Log_Total) Run_WriteBatch_cmd();
  1243. else { // finished ok
  1244. if(rw_type == rwt_set_batch) what_doing = 1;
  1245. Edited = false;
  1246. }
  1247. }
  1248. } else if(send_status == sst_sending) {
  1249. if(NRF_repeat++ < NRF_resend) nrf24_send_packet();
  1250. else {
  1251. view_Batch = *cmd_curr;
  1252. send_status = sst_error; // error NO_ACK
  1253. }
  1254. }
  1255. }
  1256. if((ERR || send_status == sst_error) && rw_type == rwt_set_batch) {
  1257. what_doing = 1;
  1258. }
  1259. // ReadBatch or ReadCmd
  1260. } else if(send_status == sst_sending) { // sending
  1261. if(furi_get_tick() - NRF_time > delay_between_pkt) {
  1262. if(NRF_repeat++ < NRF_resend) {
  1263. nrf24_resend_read_packet();
  1264. } else send_status = sst_error; // error NO_ACK
  1265. }
  1266. } else if(send_status == sst_receiving) { // receiving
  1267. for(uint8_t i = 0; i < 3; i++) {
  1268. if(nrf24_read_newpacket()) {
  1269. if(rw_type == rwt_listen) {
  1270. ListenPrev = ListenLast;
  1271. furi_hal_rtc_get_datetime(&ListenLastTime);
  1272. ListenLast = furi_hal_rtc_datetime_to_timestamp(&ListenLastTime);
  1273. ListenNew = true;
  1274. } else if(send_status != sst_receiving) break;
  1275. } else {
  1276. if(rw_type != rwt_listen && furi_get_tick() - NRF_time > NRF_READ_TIMEOUT) {
  1277. if(NRF_repeat++ < NRF_resend) {
  1278. send_status = sst_sending;
  1279. nrf24_resend_read_packet();
  1280. } else {
  1281. FURI_LOG_D(TAG, "TIMEOUT: %lu", furi_get_tick() - NRF_time);
  1282. send_status = sst_timeout;
  1283. }
  1284. }
  1285. break;
  1286. }
  1287. }
  1288. } else if(send_status == sst_ok) {
  1289. if(rw_type == rwt_read_batch) {
  1290. if((uint32_t)ReadBatch_cmd_curr != 0xFFFFFFFF && ERR == 0 && furi_get_tick() - NRF_time >= delay_between_pkt) {
  1291. Run_ReadBatch_cmd(NULL);
  1292. }
  1293. }
  1294. }
  1295. furi_mutex_release(plugin_state->mutex);
  1296. }
  1297. }
  1298. void next_rw_type(int8_t add)
  1299. {
  1300. do {
  1301. rw_type += add;
  1302. if(rw_type >= rwt_max) {
  1303. if(add > 0) rw_type = 0; else rw_type = rwt_max - 1;
  1304. }
  1305. if(rw_type == rwt_set_batch && SetBatch_cmd_Total) break;
  1306. if(rw_type == rwt_read_batch && ReadBatch_cmd_Total) break;
  1307. if(rw_type == rwt_read_cmd && Read_cmd_Total) break;
  1308. if(rw_type == rwt_write_batch && WriteBatch_cmd_Total) break;
  1309. } while(rw_type != rwt_listen);
  1310. send_status = sst_none;
  1311. }
  1312. void next_view_cmd(int8_t add)
  1313. {
  1314. if(rw_type == rwt_listen) return;
  1315. uint16_t max = (rw_type == rwt_read_batch ? ReadBatch_cmd_Total :
  1316. rw_type == rwt_read_cmd ? Read_cmd_Total :
  1317. rw_type == rwt_set_batch ? SetBatch_cmd_Total : WriteBatch_cmd_Total);
  1318. if((view_cmd[rw_type] += add) >= max) view_cmd[rw_type] = add > 0 ? 0 : max - 1;
  1319. }
  1320. int32_t nrf24batch_app(void* p) {
  1321. UNUSED(p);
  1322. APP = malloc(sizeof(nRF24Batch));
  1323. FuriMessageQueue* event_queue = furi_message_queue_alloc(8, sizeof(PluginEvent));
  1324. APP->plugin_state = malloc(sizeof(PluginState));
  1325. APP->plugin_state->mutex = furi_mutex_alloc(FuriMutexTypeNormal);
  1326. if(!APP->plugin_state->mutex) {
  1327. furi_message_queue_free(event_queue);
  1328. FURI_LOG_E(TAG, "cannot create mutex");
  1329. free(APP->plugin_state);
  1330. return 255;
  1331. }
  1332. // Set system callbacks
  1333. ViewPort* view_port = view_port_alloc();
  1334. view_port_draw_callback_set(view_port, render_callback, APP->plugin_state);
  1335. view_port_input_callback_set(view_port, input_callback, event_queue);
  1336. // Open GUI and register view_port
  1337. APP->gui = furi_record_open(RECORD_GUI);
  1338. gui_add_view_port(APP->gui, view_port, GuiLayerFullscreen);
  1339. APP->notification = furi_record_open(RECORD_NOTIFICATION);
  1340. APP->storage = furi_record_open(RECORD_STORAGE);
  1341. storage_common_mkdir(APP->storage, SCAN_APP_PATH_FOLDER);
  1342. file_stream = file_stream_alloc(APP->storage);
  1343. FuriTimer *work_timer = furi_timer_alloc(work_timer_callback, FuriTimerTypePeriodic, APP->plugin_state);
  1344. furi_timer_start(work_timer, WORK_PERIOD);
  1345. nrf24_init();
  1346. check_en_power_5V();
  1347. PluginEvent event;
  1348. for(bool processing = true; processing;) {
  1349. FuriStatus event_status = furi_message_queue_get(event_queue, &event, 100);
  1350. furi_mutex_acquire(APP->plugin_state->mutex, FuriWaitForever);
  1351. static FuriLogLevel FuriLogLevel = FuriLogLevelDefault;
  1352. if(furi_log_get_level() != FuriLogLevel) {
  1353. FuriLogLevel = furi_log_get_level();
  1354. if(FuriLogLevel == FuriLogLevelDebug) furi_hal_uart_set_br(FuriHalUartIdUSART1, 1843200);
  1355. }
  1356. if(what_doing == 2 && rw_type == rwt_read_cmd && ReadRepeat && furi_get_tick() - NRF_time > (uint32_t)(ReadCmdRepeatPeriod * 1000)) {
  1357. ERR = 0;
  1358. free_Log();
  1359. Run_Read_cmd(Read_cmd[view_cmd[rwt_read_cmd]]);
  1360. notification_message(APP->notification, &sequence_blink_blue_100);
  1361. }
  1362. if(event_status == FuriStatusOk) {
  1363. // press events
  1364. if(event.type == EventTypeKey) {
  1365. switch(event.input.key) {
  1366. case InputKeyUp:
  1367. if(event.input.type == InputTypeShort || event.input.type == InputTypeRepeat) {
  1368. if(!ask_question) {
  1369. if(Edit) {
  1370. char c = *Edit_pos;
  1371. if(Edit_hex) {
  1372. if(c == '9') *Edit_pos = 'A';
  1373. else if(c < 'F' || c < '9') *Edit_pos = c + 1;
  1374. } else {
  1375. if(c == '-') *Edit_pos = '0';
  1376. else if(c < '9') *Edit_pos = c + 1;
  1377. else {
  1378. c = *(Edit_pos - 1);
  1379. if(Edit_pos > Edit_start && c < '9' && c >= '0') {
  1380. *Edit_pos = '0';
  1381. (*(Edit_pos - 1)) = c + 1;
  1382. }
  1383. }
  1384. }
  1385. } else if(what_doing == 0) {
  1386. if(addr_len) {
  1387. if(setup_cursor > 0) setup_cursor--; else setup_cursor = 2;
  1388. }
  1389. } else if(what_doing == 1) next_view_cmd(-1);
  1390. else if(what_doing == 2) if(view_Batch) view_Batch--;
  1391. }
  1392. }
  1393. break;
  1394. case InputKeyDown:
  1395. if(event.input.type == InputTypeShort || event.input.type == InputTypeRepeat) {
  1396. if(!ask_question) {
  1397. if(Edit) {
  1398. if(*Edit_pos != '-') {
  1399. if(Edit_hex && *Edit_pos == 'A') (*Edit_pos) = '9';
  1400. else if(*Edit_pos > '0') (*Edit_pos)--;
  1401. else if(!Edit_hex) {
  1402. if(Edit_pos > Edit_start) {
  1403. if(*(Edit_pos - 1) > '0' && *(Edit_pos - 1) <= '9') {
  1404. *Edit_pos = '9';
  1405. (*(Edit_pos - 1))--;
  1406. }
  1407. } else Edit_insert_digit('-'); // negative
  1408. }
  1409. }
  1410. } else if(what_doing == 0) {
  1411. if(addr_len) {
  1412. if(setup_cursor < 2) setup_cursor++; else setup_cursor = 0;
  1413. }
  1414. } else if(what_doing == 1) next_view_cmd(+1);
  1415. else if(what_doing == 2) if(view_Batch < Log_Total - 1) view_Batch++;
  1416. }
  1417. }
  1418. break;
  1419. case InputKeyLeft:
  1420. if(event.input.type == InputTypeShort || event.input.type == InputTypeRepeat) {
  1421. if(ask_question) {
  1422. if(event.input.type == InputTypeShort) ask_question_answer ^= 1;
  1423. } else if(Edit) {
  1424. if(Edit_pos > Edit_start) {
  1425. if(is_digit(Edit_pos - 1, Edit_hex)) Edit_pos--;
  1426. else if(*(Edit_pos - 1) == 'x' && *(Edit_pos - 3) == ',') Edit_pos -= 4;
  1427. else if(*(Edit_pos - 1) == ',') Edit_pos -= 2;
  1428. }
  1429. } else if(what_doing == 0) {
  1430. if(addr_len) {
  1431. rw_type = rwt_listen;
  1432. what_doing = 1;
  1433. }
  1434. } else if(what_doing == 1) {
  1435. if(event.input.type == InputTypeShort) next_rw_type(-1); else if(view_x) view_x--;
  1436. } else if(what_doing == 2) if(view_x) view_x--;
  1437. } else if(event.input.type == InputTypeLong) {
  1438. if(!ask_question && view_x == 0 && what_doing == 2 && (rw_type == rwt_write_batch || rw_type == rwt_read_batch)
  1439. && Log_Total && Log[view_Batch] != NULL) {
  1440. ask_question = ask_skip_cmd;
  1441. ask_question_answer = 1;
  1442. }
  1443. }
  1444. break;
  1445. case InputKeyRight:
  1446. if(event.input.type == InputTypeShort || event.input.type == InputTypeRepeat) {
  1447. if(ask_question) {
  1448. ask_question_answer ^= 1;
  1449. } else if(Edit) {
  1450. if(is_digit(Edit_pos + 1, Edit_hex)) Edit_pos++;
  1451. else if(*(Edit_pos + 1) == ',') {
  1452. Edit_pos += 2;
  1453. if(*(Edit_pos + 1) == 'x') Edit_pos += 2;
  1454. }
  1455. } else if(what_doing == 0) {
  1456. if(addr_len) {
  1457. rw_type = rwt_set_batch;
  1458. what_doing = 1;
  1459. }
  1460. } else if(what_doing == 1) {
  1461. if(event.input.type == InputTypeShort) next_rw_type(+1); else view_x++;
  1462. } else if(what_doing == 2) view_x++;
  1463. }
  1464. break;
  1465. case InputKeyOk:
  1466. if(event.input.type == InputTypeShort) {
  1467. if(ask_question) {
  1468. if(ask_question_answer) {
  1469. if(ask_question == ask_save_batch) {
  1470. save_batch();
  1471. } else if(ask_question == ask_write_batch) {
  1472. if(WriteBatch_cmd_Total) {
  1473. if(what_doing == 1) {
  1474. Prepare_Write_cmd(WriteBatch_cmd[view_cmd[rwt_write_batch]]);
  1475. send_status = sst_none;
  1476. Edited = false;
  1477. view_x = 0;
  1478. view_Batch = 0;
  1479. }
  1480. if(Log_Total) {
  1481. ERR = 0;
  1482. WriteBatch_cmd_curr = 0;
  1483. Run_WriteBatch_cmd();
  1484. what_doing = 2;
  1485. }
  1486. }
  1487. } else if(ask_question == ask_skip_cmd) {
  1488. if(rw_type == rwt_write_batch || rw_type == rwt_read_batch) {
  1489. furi_string_free(Log[view_Batch]);
  1490. if(view_Batch < Log_Total - 1) memmove(&Log[view_Batch], &Log[view_Batch + 1], sizeof(Log) * (Log_Total - view_Batch - 1));
  1491. else view_Batch--;
  1492. Log_Total--;
  1493. }
  1494. } else if(ask_question == ask_exit) {
  1495. processing = false;
  1496. } else if(ask_question == ask_return) {
  1497. if(what_doing == 2) {
  1498. ERR = 0;
  1499. send_status = sst_none;
  1500. Edited = false;
  1501. what_doing--;
  1502. }
  1503. }
  1504. }
  1505. ask_question = 0;
  1506. } else if(Edit) { // insert digit
  1507. Edit_insert_digit('0');
  1508. } else if(what_doing == 0) {
  1509. if(setup_cursor == 0) { // open file
  1510. file_stream_close(file_stream);
  1511. if(select_settings_file()) {
  1512. uint8_t err = load_settings_file();
  1513. if(err) snprintf(file_name, sizeof(file_name), "LOAD ERROR #%d", err);
  1514. }
  1515. } else if(setup_cursor == 1) { // change address
  1516. char *ebuf = (char*)payload;
  1517. ebuf[0] = '\0';
  1518. add_to_str_hex_bytes(ebuf, addr, addr_len);
  1519. Edit_hex = true;
  1520. Edit_pos = ebuf + strlen(ebuf) - 1;
  1521. Edit_start = ebuf;
  1522. Edit = 1;
  1523. NRF_INITED = 0;
  1524. } else if(setup_cursor == 2) { // change channel
  1525. char *ebuf = (char*)payload;
  1526. snprintf(ebuf, sizeof(payload), "%d", NRF_channel);
  1527. Edit_hex = false;
  1528. Edit_pos = ebuf + strlen(ebuf) - 1;
  1529. Edit_start = ebuf;
  1530. Edit = 1;
  1531. NRF_INITED = 0;
  1532. }
  1533. } else if(what_doing == 1) {
  1534. if(rw_type == rwt_set_batch) {
  1535. if(SetBatch_cmd_Total) {
  1536. ERR = 0;
  1537. send_status = sst_none;
  1538. Prepare_Write_cmd(SetBatch_cmd[view_cmd[rwt_set_batch]]);
  1539. if(!ERR) {
  1540. SetBatch_cmd_curr = 0;
  1541. Run_WriteBatch_cmd();
  1542. what_doing = 2;
  1543. }
  1544. Edited = false;
  1545. }
  1546. } else if(rw_type == rwt_read_batch) {
  1547. if(ReadBatch_cmd_Total) {
  1548. ERR = 0;
  1549. Run_ReadBatch_cmd(ReadBatch_cmd[view_cmd[rwt_read_batch]]);
  1550. view_x = 0;
  1551. view_Batch = 0;
  1552. what_doing = 2;
  1553. }
  1554. } else if(rw_type == rwt_read_cmd) {
  1555. if(Read_cmd_Total) {
  1556. ERR = 0;
  1557. free_Log();
  1558. Run_Read_cmd(Read_cmd[view_cmd[rwt_read_cmd]]);
  1559. view_x = 0;
  1560. what_doing = 2;
  1561. }
  1562. } else if(rw_type == rwt_write_batch) {
  1563. if(WriteBatch_cmd_Total) {
  1564. ERR = 0;
  1565. Prepare_Write_cmd(WriteBatch_cmd[view_cmd[rwt_write_batch]]);
  1566. send_status = sst_none;
  1567. Edited = false;
  1568. view_x = 0;
  1569. view_Batch = 0;
  1570. what_doing = 2;
  1571. }
  1572. } else if(rw_type == rwt_listen) {
  1573. if(listen_addr_len) {
  1574. free_Log();
  1575. prepare_nrf24();
  1576. if(!NRF_ERROR) {
  1577. nrf24_set_rx_mode(nrf24_HANDLE);
  1578. ListenNew = false;
  1579. send_status = sst_receiving; // receiving
  1580. }
  1581. what_doing = 2;
  1582. }
  1583. }
  1584. } else if(what_doing == 2) {
  1585. if(rw_type == rwt_read_cmd) {
  1586. ERR = 0;
  1587. free_Log();
  1588. Run_Read_cmd(Read_cmd[view_cmd[rwt_read_cmd]]);
  1589. } else if(Log_Total) {
  1590. if(rw_type == rwt_read_batch) {
  1591. ask_question = ask_save_batch;
  1592. ask_question_answer = 0;
  1593. } else if(rw_type == rwt_write_batch) {
  1594. ask_question = ask_write_batch;
  1595. ask_question_answer = 0;
  1596. }
  1597. }
  1598. }
  1599. } else if(event.input.type == InputTypeLong) {
  1600. if(Edit) { // delete
  1601. if(what_doing <= 1) {
  1602. if(strlen(Edit_start) > 1) {
  1603. memmove(Edit_pos, Edit_pos + 1, strlen(Edit_pos));
  1604. if(*Edit_pos == '\0') Edit_pos--;
  1605. }
  1606. } else {
  1607. FuriString *fs = Log[view_Batch];
  1608. if(is_digit(Edit_pos + 1, Edit_hex) || (Edit_pos > Edit_start && is_digit(Edit_pos - 1, Edit_hex))) {
  1609. memmove(Edit_pos, Edit_pos + 1, strlen(Edit_pos));
  1610. if(*Edit_pos == '\0') Edit_pos--;
  1611. furi_string_left(fs, furi_string_size(fs) - 1);
  1612. }
  1613. }
  1614. } else if(what_doing == 1) {
  1615. if(rw_type == rwt_listen) {
  1616. if(listen_addr_len) {
  1617. char *ebuf = (char*)payload;
  1618. ebuf[0] = '\0';
  1619. add_to_str_hex_bytes(ebuf, listen_addr, listen_addr_len);
  1620. Edit_hex = true;
  1621. Edit_pos = ebuf + strlen(ebuf) - 1;
  1622. Edit_start = ebuf;
  1623. Edit = 1;
  1624. NRF_INITED = 0;
  1625. }
  1626. } else if(rw_type == rwt_read_batch) {
  1627. if(ReadBatch_cmd_Total) {
  1628. ERR = 0;
  1629. Run_ReadBatch_cmd(ReadBatch_cmd[view_cmd[rwt_read_batch]]);
  1630. view_x = 0;
  1631. view_Batch = 0;
  1632. what_doing = 2;
  1633. }
  1634. } else if(rw_type == rwt_write_batch) {
  1635. ask_question = ask_write_batch;
  1636. ask_question_answer = 0;
  1637. }
  1638. } else if(what_doing == 2) {
  1639. if(rw_type == rwt_read_cmd) {
  1640. ReadRepeat = !ReadRepeat;
  1641. } else if(Log_Total) {
  1642. if(rw_type == rwt_write_batch) {
  1643. if(!Edit) {
  1644. Edit = 0;
  1645. Edit_hex = 0;
  1646. char *s = (char*)furi_string_get_cstr(Log[view_Batch]);
  1647. char *p = strchr(s, '=');
  1648. if(p) {
  1649. p++;
  1650. if(*p == '{') p++; // array
  1651. if(*(p + 1) == 'x') {
  1652. p += 2;
  1653. Edit_hex = 1; // hex
  1654. }
  1655. if(is_digit(p, Edit_hex)) {
  1656. Edit_start = p;
  1657. while(is_digit(p, Edit_hex)) p++;
  1658. Edit_pos = p - 1;
  1659. Edited = true;
  1660. Edit = 1;
  1661. }
  1662. }
  1663. }
  1664. } else if(rw_type == rwt_read_batch) {
  1665. ask_question = ask_save_batch;
  1666. ask_question_answer = 0;
  1667. }
  1668. }
  1669. }
  1670. }
  1671. break;
  1672. case InputKeyBack:
  1673. if(event.input.type == InputTypeLong) {
  1674. if(what_doing == 2 && Edited) {
  1675. if(!ask_question) ask_question_answer = 1;
  1676. ask_question = ask_exit;
  1677. } else processing = false;
  1678. } else if(event.input.type == InputTypeShort) {
  1679. if(ask_question) ask_question = 0;
  1680. else if(Edit) {
  1681. if(what_doing == 0) {
  1682. if(setup_cursor == 1) {
  1683. addr_len = ConvertHexToArray((char*)payload, addr, 5);
  1684. } else if(setup_cursor == 2) {
  1685. NRF_channel = str_to_int((char*)payload);
  1686. if(NRF_channel > MAX_CHANNEL) NRF_channel = MAX_CHANNEL;
  1687. }
  1688. } else if(what_doing == 1 && rw_type == rwt_listen) {
  1689. listen_addr_len = ConvertHexToArray((char*)payload, listen_addr, 5);
  1690. }
  1691. Edit = 0;
  1692. } else {
  1693. if(what_doing == 2 && Edited) {
  1694. ask_question = ask_return;
  1695. ask_question_answer = 1;
  1696. } else if(what_doing != 0) {
  1697. if(what_doing) what_doing--;
  1698. if(what_doing == 0) rw_type = rwt_read_batch;
  1699. if(what_doing <= 1) view_x = 0;
  1700. ERR = 0;
  1701. send_status = sst_none;
  1702. }
  1703. }
  1704. }
  1705. break;
  1706. default:
  1707. break;
  1708. }
  1709. }
  1710. }
  1711. view_port_update(view_port);
  1712. furi_mutex_release(APP->plugin_state->mutex);
  1713. }
  1714. nrf24_set_idle(nrf24_HANDLE);
  1715. nrf24_deinit();
  1716. if(NRF_BOARD_POWER_5V) furi_hal_power_disable_otg();
  1717. view_port_enabled_set(view_port, false);
  1718. gui_remove_view_port(APP->gui, view_port);
  1719. furi_record_close(RECORD_GUI);
  1720. furi_record_close(RECORD_NOTIFICATION);
  1721. furi_record_close(RECORD_STORAGE);
  1722. if(file_stream) {
  1723. file_stream_close(file_stream);
  1724. stream_free(file_stream);
  1725. }
  1726. view_port_free(view_port);
  1727. furi_message_queue_free(event_queue);
  1728. free_store();
  1729. furi_timer_stop(work_timer);
  1730. furi_timer_free(work_timer);
  1731. furi_mutex_free(APP->plugin_state->mutex);
  1732. free(APP->plugin_state);
  1733. free(APP);
  1734. return 0;
  1735. }