nrf24batch.c 58 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785
  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.8"
  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. snprintf(hex, sizeof(hex), "%lX", var);
  457. if((cmd_array && cmd_array_hex) || furi_string_end_with_str(str, "0x")) furi_string_cat_str(str, hex);
  458. else {
  459. if(var >= 0 && var <= 9) furi_string_cat_printf(str, "%ld", var);
  460. else furi_string_cat_printf(str, "%ld (%s)", var, hex + (var < 0 ? 8 - size * 2 : 0));
  461. }
  462. }
  463. if(cmd_array) {
  464. if(--cmd_array_cnt) {
  465. furi_string_cat_str(str, ",");
  466. if(cmd_array_hex) furi_string_cat_str(str, "0x");
  467. payload[cmd_array_idx] += size; // next array element
  468. NRF_repeat = -1;
  469. send_status = sst_sending; // Will be send after delay_between_pkt
  470. } else send_status = sst_ok;
  471. } else {
  472. if(size == 0) { // string, until '\0'
  473. if(var == 0) send_status = sst_ok;
  474. } else send_status = sst_ok;
  475. }
  476. }
  477. //notification_message(APP->notification, &sequence_blink_white_100);
  478. found = true;
  479. } else if(st & 0x80) { // NRF24 hardware error
  480. NRF_ERROR = 1;
  481. NRF_INITED = 0;
  482. }
  483. return found;
  484. }
  485. // Search in constatnt pull (Const1=n; Const2=n;...)
  486. // VAR_EMPTY - not found
  487. int32_t subs_constant(char *p, uint8_t len)
  488. {
  489. char *c = (char*)furi_string_get_cstr(Constants);
  490. while((c = strchr(c, *p))) {
  491. if(strncmp(c, p, len) != 0) {
  492. c++;
  493. continue;
  494. }
  495. if(c == (char*)furi_string_get_cstr(Constants) || *(c-1) == ';' || *(c-1) <= ' ') {
  496. c += len;
  497. if(*c == '=') {
  498. c++;
  499. return str_to_int(c);
  500. }
  501. } else c += len;
  502. }
  503. return VAR_EMPTY;
  504. }
  505. // fill payload with default = p
  506. // if var_n = VAR_EMPTY - skip filling var_*
  507. bool fill_payload(char *p, uint8_t *idx_i, int32_t var_n)
  508. {
  509. if(idx_i) *idx_i = 255;
  510. uint8_t fld = 0; // field #
  511. uint8_t idx = 0; // byte index
  512. do {
  513. int32_t b = 0;
  514. char *end = strchr(p, ',');
  515. if(*p >= '0' && *p <= '9') { // Number found
  516. b = str_to_int(p);
  517. } else if(*p == 'i' && *(p + 1) == ':') { // 'i:' array index
  518. b = str_to_int(p + 2);
  519. if(idx_i) *idx_i = idx;
  520. } else if(*p == 'n' && *(p + 1) < '0') { // var_n
  521. if(var_n != VAR_EMPTY) b = var_n;
  522. } else if(*p >= 'A') { // constant found
  523. uint8_t len;
  524. if(end) len = end - p;
  525. else {
  526. len = strlen(p);
  527. if(*(p + len - 1) == '#') len--;
  528. }
  529. b = subs_constant(p, len);
  530. if(b == VAR_EMPTY) {
  531. ERR = 1;
  532. memset(ERR_STR, 0, sizeof(ERR_STR));
  533. strcpy(ERR_STR, "No ");
  534. strncpy(ERR_STR + strlen(ERR_STR), p, sizeof(ERR_STR) - 4);
  535. FURI_LOG_D(TAG, "Constant not found: %s", p);
  536. return false;
  537. }
  538. } else if(end == p) {
  539. idx += payload_struct[fld];
  540. } else if(*p == '#') { // value in Hexadecimal, end string
  541. break;
  542. } else {
  543. ERR = 2;
  544. strcpy(ERR_STR, "char: ");
  545. uint8_t l = strlen(ERR_STR);
  546. ERR_STR[l] = *p;
  547. ERR_STR[l+1] = '\0';
  548. FURI_LOG_D(TAG, "Wrong format char(%c)", *p);
  549. return false;
  550. }
  551. if(end != p) {
  552. payload[idx++] = b;
  553. if(payload_struct[fld] > 1) payload[idx++] = b >> 8;
  554. if(payload_struct[fld] > 2) payload[idx++] = b >> 16;
  555. if(payload_struct[fld] > 3) payload[idx++] = b >> 24;
  556. }
  557. if(++fld == payload_fields || idx >= sizeof(payload) || end == NULL) break;
  558. p = end + 1;
  559. } while(1);
  560. return true;
  561. }
  562. // Cmd: "name=payload"
  563. bool Run_Read_cmd(FuriString *cmd)
  564. {
  565. char *p = (char*)furi_string_get_cstr(cmd);
  566. p = strchr(p, '=');
  567. if(p == NULL) return false;
  568. if(Log == NULL) Log = malloc(sizeof(Log));
  569. else Log = realloc(Log, sizeof(Log) * (Log_Total + 1));
  570. if(Log == NULL) {
  571. ERR = 3;
  572. strcpy(ERR_STR, "Memory low");
  573. FURI_LOG_D(TAG, ERR_STR);
  574. return false;
  575. }
  576. FuriString *fs = furi_string_alloc();
  577. furi_string_set_strn(fs, (char*)furi_string_get_cstr(cmd), p - (char*)furi_string_get_cstr(cmd));
  578. furi_string_cat_str(fs, ": ");
  579. bool hexval;
  580. if((hexval = *(p + strlen(p) - 1) == '#')) furi_string_cat_str(fs, "0x"); // value in Hex format
  581. Log[Log_Total++] = fs;
  582. p++;
  583. memset(payload, 0, sizeof(payload));
  584. if(ReadDefault && !fill_payload((char*)furi_string_get_cstr(ReadDefault), NULL, VAR_EMPTY)) return false;
  585. if(!fill_payload(p, &cmd_array_idx, VAR_EMPTY)) return false;
  586. memset(payload_receive, 0, sizeof(payload_receive));
  587. cmd_array = false;
  588. if(*(p - 2) == ']' && cmd_array_idx != 255) { // array
  589. p = strchr(furi_string_get_cstr(cmd), '[');
  590. if(p) {
  591. cmd_array_cnt = str_to_int(p + 1);
  592. if(cmd_array_cnt > 1) {
  593. cmd_array_hex = hexval;
  594. cmd_array = true; // array
  595. }
  596. }
  597. }
  598. prepare_nrf24();
  599. if(NRF_ERROR) return false;
  600. what_doing = 2;
  601. NRF_repeat = 0;
  602. send_status = sst_sending; // Read - sending
  603. nrf24_send_packet();
  604. return true;
  605. }
  606. // run commands one by one, true - command running
  607. bool Run_ReadBatch_cmd(FuriString *cmd)
  608. {
  609. char *p;
  610. if(cmd) {
  611. p = strchr((char*)furi_string_get_cstr(cmd), ':');
  612. if(p == NULL) {
  613. ERR = 5;
  614. strcpy(ERR_STR, "WRONG FORMAT");
  615. return false;
  616. }
  617. p += 2;
  618. ReadBatch_cmd_curr = NULL;
  619. free_Log();
  620. } else {
  621. if(ReadBatch_cmd_curr) p = ReadBatch_cmd_curr; else return false;
  622. }
  623. char *end = strchr(p, ';');
  624. uint8_t len;
  625. if(end) len = end - p;
  626. else {
  627. str_rtrim(p);
  628. len = strlen(p);
  629. }
  630. for(uint16_t i = 0; i < Read_cmd_Total; i++) {
  631. FuriString *fs = Read_cmd[i];
  632. if(strncmp((char*)furi_string_get_cstr(fs), p, len) == 0) {
  633. char c = *((char*)furi_string_get_cstr(fs) + len);
  634. if(c != '=' && c != '*' && c != '[') continue;
  635. if(end) ReadBatch_cmd_curr = end + 1; else ReadBatch_cmd_curr = (char*)0xFFFFFFFF;
  636. if(!Run_Read_cmd(fs)) break;
  637. return true;
  638. }
  639. }
  640. if(NRF_ERROR) return false;
  641. if(ERR == 0) {
  642. ERR = 4;
  643. strcpy(ERR_STR, "NOT FOUND");
  644. FuriString *fs = furi_string_alloc();
  645. furi_string_set_strn(fs, p, len);
  646. Log[Log_Total++] = fs;
  647. FURI_LOG_D(TAG, "CMD %s: %s", ERR_STR, p);
  648. }
  649. view_Batch = Log_Total ? Log_Total - 1 : 0;
  650. return false;
  651. }
  652. void Prepare_Write_cmd(FuriString *cmd)
  653. {
  654. free_Log();
  655. if(cmd == NULL) return;
  656. char *end, *p = strchr((char*)furi_string_get_cstr(cmd), ':');
  657. if(p == NULL) {
  658. ERR = 8;
  659. strcpy(ERR_STR, "Wrong batch");
  660. FURI_LOG_D(TAG, ERR_STR);
  661. return;
  662. }
  663. p += 2;
  664. Log = malloc(sizeof(Log));
  665. do {
  666. end = strchr(p, ';');
  667. uint8_t len;
  668. if(end) {
  669. len = end - p;
  670. end++;
  671. } else {
  672. str_rtrim(p);
  673. len = strlen(p);
  674. }
  675. FuriString *fs = furi_string_alloc();
  676. if(Log_Total) Log = realloc(Log, sizeof(Log) * (Log_Total + 1));
  677. if(Log == NULL) {
  678. ERR = 3;
  679. strcpy(ERR_STR, "Memory low");
  680. FURI_LOG_D(TAG, ERR_STR);
  681. return;
  682. }
  683. furi_string_set_strn(fs, p, len);
  684. Log[Log_Total++] = fs;
  685. } while((p = end));
  686. }
  687. // Write / Set batch
  688. bool Run_WriteBatch_cmd()
  689. {
  690. if(Log_Total == 0) return false;
  691. uint16_t cmd_curr = rw_type == rwt_write_batch ? WriteBatch_cmd_curr : SetBatch_cmd_curr;
  692. if(cmd_curr == 0) { // first
  693. prepare_nrf24();
  694. if(NRF_ERROR) return false;
  695. if(rw_type == rwt_write_batch && WriteStart) {
  696. if(!fill_payload((char*)furi_string_get_cstr(WriteStart), NULL, VAR_EMPTY)) return false;
  697. send_status = sst_sending;
  698. if(!nrf24_send_packet()) return false;
  699. }
  700. }
  701. char *p = (char*)furi_string_get_cstr(Log[cmd_curr]);
  702. uint16_t len = furi_string_size(Log[cmd_curr]);
  703. char *arr = NULL;
  704. cmd_array = false;
  705. int32_t new = 0;
  706. for(uint16_t i = 0; i < len; i++) {
  707. if(p[i] == '=') {
  708. len = i;
  709. char *p2 = p + i + 1;
  710. if(*p2 == '{') {
  711. arr = ++p2; // array
  712. cmd_array = true;
  713. }
  714. new = str_to_int(p2);
  715. break;
  716. }
  717. }
  718. FURI_LOG_D(TAG, "%cBatch: =%d, (%d)%s", rw_type == rwt_write_batch ? 'W' : 'S', (int)new, len, p);
  719. char *w, *delim_col, i, size;
  720. FuriString* str = furi_string_alloc();
  721. stream_rewind(file_stream);
  722. while(stream_read_line(file_stream, str)) {
  723. w = (char*)furi_string_get_cstr(str);
  724. if(strncmp(w, SettingsFld_Write, sizeof(SettingsFld_Write)-1) == 0) w += sizeof(SettingsFld_Write);
  725. else if(strncmp(w, SettingsFld_Set, sizeof(SettingsFld_Set)-1) == 0) w += sizeof(SettingsFld_Set);
  726. else continue;
  727. delim_col = strchr(w, '=');
  728. if(delim_col == NULL) continue;
  729. size = 1;
  730. if(*(delim_col - 2) == '*') {
  731. if(len != delim_col - w - 2) continue;
  732. size = *(delim_col - 1) - '0';
  733. } else if(len != delim_col - w) continue;
  734. if(strncmp(p, w, len) != 0) continue;
  735. delim_col++;
  736. str_rtrim(delim_col);
  737. cmd_array_cnt = 255;
  738. do {
  739. memset(payload, 0, sizeof(payload));
  740. if(WriteDefault && !fill_payload((char*)furi_string_get_cstr(WriteDefault), NULL, new)) {
  741. view_Batch = cmd_curr;
  742. return false;
  743. }
  744. if(!fill_payload(delim_col, &cmd_array_idx, VAR_EMPTY)) {
  745. view_Batch = cmd_curr;
  746. return false;
  747. }
  748. if(cmd_array && cmd_array_idx != 255) {
  749. if(cmd_array_cnt != 255) payload[cmd_array_idx] = cmd_array_cnt;
  750. } else cmd_array = false;
  751. send_status = sst_sending;
  752. NRF_repeat = 0;
  753. i = 0;
  754. do {
  755. if(nrf24_send_packet()) break;
  756. furi_delay_ms(delay_between_pkt);
  757. } while(i++ < NRF_resend);
  758. if(i < NRF_resend || i == 0) { // ok
  759. if(cmd_array) { // array
  760. for(; arr != NULL;) {
  761. if(*arr == ',') break;
  762. if(*arr == '}' || *arr < ' ') arr = NULL; else arr++;
  763. }
  764. if(arr == NULL) {
  765. send_status = sst_ok;
  766. break;
  767. }
  768. arr++;
  769. new = str_to_int(arr);
  770. cmd_array_cnt = payload[cmd_array_idx] + size;
  771. //furi_delay_ms(delay_between_pkt); // do it fast
  772. continue; // send next array element
  773. } else send_status = sst_ok;
  774. }
  775. break;
  776. } while(1);
  777. if(send_status != sst_ok) {
  778. send_status = sst_error;
  779. view_Batch = cmd_curr;
  780. return false;
  781. }
  782. return true;
  783. }
  784. ERR = 7;
  785. strcpy(ERR_STR, "NOT FOUND!");
  786. send_status = sst_error;
  787. view_Batch = cmd_curr;
  788. return false;
  789. }
  790. // Return 0 - success, otherwise an error
  791. static uint8_t load_settings_file() {
  792. uint8_t err = 0;
  793. FURI_LOG_D(TAG, "Loading settings file");
  794. FuriString* str = furi_string_alloc();
  795. free_store();
  796. Info[0] = '\0';
  797. NRF_INITED = false;
  798. while(stream_read_line(file_stream, str)) {
  799. char *p = (char*)furi_string_get_cstr(str);
  800. if(*p <= ' ') continue;
  801. //char* delim_eq = strchr(p, '=');
  802. char *delim_col = strchr(p, ':');
  803. if(delim_col == NULL) { // Constant found - no ':'
  804. if(Constants == NULL) {
  805. Constants = furi_string_alloc_set(str);
  806. } else furi_string_cat(Constants, str);
  807. } else {
  808. str_rtrim(p);
  809. if(strncmp(p, SettingsFld_Rate, sizeof(SettingsFld_Rate)-1) == 0) {
  810. NRF_rate = str_to_int(p + sizeof(SettingsFld_Rate));
  811. } else if(strncmp(p, SettingsFld_Info, sizeof(SettingsFld_Info)-1) == 0) {
  812. strncpy(Info, p + sizeof(SettingsFld_Info), sizeof(Info)-1);
  813. } else if(strncmp(p, SettingsFld_Ch, sizeof(SettingsFld_Ch)-1) == 0) {
  814. NRF_channel = str_to_int(p + sizeof(SettingsFld_Ch));
  815. } else if(strncmp(p, SettingsFld_Address, sizeof(SettingsFld_Address)-1) == 0) {
  816. p += sizeof(SettingsFld_Address);
  817. addr_len = ConvertHexToArray(p, addr, 5);
  818. } else if(strncmp(p, SettingsFld_CRC, sizeof(SettingsFld_CRC)-1) == 0) {
  819. NRF_CRC = str_to_int(p + sizeof(SettingsFld_CRC));
  820. } else if(strncmp(p, SettingsFld_DPL, sizeof(SettingsFld_DPL)-1) == 0) {
  821. NRF_DPL = str_to_int(p + sizeof(SettingsFld_DPL));
  822. } else if(strncmp(p, SettingsFld_RETR, sizeof(SettingsFld_RETR)-1) == 0) {
  823. NRF_RETR = str_to_int(p + sizeof(SettingsFld_RETR));
  824. } else if(strncmp(p, SettingsFld_Resend, sizeof(SettingsFld_Resend)-1) == 0) {
  825. NRF_resend = str_to_int(p + sizeof(SettingsFld_Resend));
  826. } else if(strncmp(p, SettingsFld_Delay, sizeof(SettingsFld_Delay)-1) == 0) {
  827. delay_between_pkt = str_to_int(p + sizeof(SettingsFld_Delay));
  828. } else if(strncmp(p, SettingsFld_ReadCmdRepeatPeriod, sizeof(SettingsFld_ReadCmdRepeatPeriod)-1) == 0) {
  829. ReadCmdRepeatPeriod = str_to_int(p + sizeof(SettingsFld_ReadCmdRepeatPeriod));
  830. } else if(strncmp(p, SettingsFld_Payload, sizeof(SettingsFld_Payload)-1) == 0) {
  831. p += sizeof(SettingsFld_Payload);
  832. payload_fields = 0;
  833. payload_size = 0;
  834. do {
  835. uint8_t b = str_to_int(p);
  836. if(b < 1 || b > 4) {
  837. FURI_LOG_D(TAG, "Wrong payload format (%d)", b);
  838. err = 3;
  839. break;
  840. }
  841. payload_struct[payload_fields++] = b;
  842. payload_size += b;
  843. if(payload_fields == sizeof(payload_struct) - 1) break;
  844. if((p = strchr(p, ',')) == NULL) break;
  845. p++;
  846. } while(1);
  847. FURI_LOG_D(TAG, "Payload fields %d: %d,%d,%d", payload_fields, payload_struct[0], payload_struct[1], payload_struct[2]);
  848. } else if(strncmp(p, SettingsFld_ReadDefault, sizeof(SettingsFld_ReadDefault)-1) == 0) {
  849. ReadDefault = furi_string_alloc_set_str(p + sizeof(SettingsFld_ReadDefault));
  850. } else if(strncmp(p, SettingsFld_WriteStart, sizeof(SettingsFld_WriteStart)-1) == 0) {
  851. WriteStart = furi_string_alloc_set_str(p + sizeof(SettingsFld_WriteStart));
  852. } else if(strncmp(p, SettingsFld_WriteDefault, sizeof(SettingsFld_WriteDefault)-1) == 0) {
  853. WriteDefault = furi_string_alloc_set_str(p + sizeof(SettingsFld_WriteDefault));
  854. } else if(strncmp(p, SettingsFld_Read, sizeof(SettingsFld_Read)-1) == 0) {
  855. p += sizeof(SettingsFld_Read);
  856. if(Read_cmd == NULL) Read_cmd = malloc(sizeof(Read_cmd));
  857. else {
  858. Read_cmd = realloc(Read_cmd, sizeof(Read_cmd) * (Read_cmd_Total + 1));
  859. }
  860. if(Read_cmd == NULL) {
  861. FURI_LOG_D(TAG, "Memory low, err 4");
  862. err = 4;
  863. break;
  864. }
  865. Read_cmd[Read_cmd_Total++] = furi_string_alloc_set_str(p);
  866. } else if(strncmp(p, SettingsFld_ReadBatch, sizeof(SettingsFld_ReadBatch)-1) == 0) {
  867. p += sizeof(SettingsFld_ReadBatch);
  868. if(ReadBatch_cmd == NULL) ReadBatch_cmd = malloc(sizeof(ReadBatch_cmd));
  869. else {
  870. ReadBatch_cmd = realloc(ReadBatch_cmd, sizeof(ReadBatch_cmd) * (ReadBatch_cmd_Total + 1));
  871. }
  872. if(ReadBatch_cmd == NULL) {
  873. FURI_LOG_D(TAG, "Memory low, err 5");
  874. err = 5;
  875. break;
  876. }
  877. ReadBatch_cmd[ReadBatch_cmd_Total++] = furi_string_alloc_set_str(p);
  878. } else if(strncmp(p, SettingsFld_WriteBatch, sizeof(SettingsFld_WriteBatch)-1) == 0) {
  879. p += sizeof(SettingsFld_WriteBatch);
  880. if(WriteBatch_cmd == NULL) WriteBatch_cmd = malloc(sizeof(WriteBatch_cmd));
  881. else {
  882. WriteBatch_cmd = realloc(WriteBatch_cmd, sizeof(WriteBatch_cmd) * (WriteBatch_cmd_Total + 1));
  883. }
  884. if(WriteBatch_cmd == NULL) {
  885. FURI_LOG_D(TAG, "Memory low, err 6");
  886. err = 6;
  887. break;
  888. }
  889. WriteBatch_cmd[WriteBatch_cmd_Total++] = furi_string_alloc_set_str(p);
  890. } else if(strncmp(p, SettingsFld_SetBatch, sizeof(SettingsFld_SetBatch)-1) == 0) {
  891. p += sizeof(SettingsFld_SetBatch);
  892. if(SetBatch_cmd == NULL) SetBatch_cmd = malloc(sizeof(SetBatch_cmd));
  893. else {
  894. SetBatch_cmd = realloc(SetBatch_cmd, sizeof(SetBatch_cmd) * (SetBatch_cmd_Total + 1));
  895. }
  896. if(SetBatch_cmd == NULL) {
  897. FURI_LOG_D(TAG, "Memory low, err 7");
  898. err = 7;
  899. break;
  900. }
  901. SetBatch_cmd[SetBatch_cmd_Total++] = furi_string_alloc_set_str(p);
  902. } else if(strncmp(p, SettingsFld_Listen, sizeof(SettingsFld_Listen)-1) == 0) {
  903. p += sizeof(SettingsFld_Listen);
  904. char *p2 = strchr(p, '=');
  905. if(p2) {
  906. listen_addr_len = ConvertHexToArray(p, listen_addr, (p2 - p) / 2);
  907. p2++;
  908. uint8_t len = strlen(p2);
  909. ListenFields = malloc(len + 1);
  910. if(ListenFields) memcpy(ListenFields, p2, len);
  911. }
  912. }
  913. }
  914. }
  915. furi_string_free(str);
  916. return err;
  917. }
  918. static void save_batch(void)
  919. {
  920. FURI_LOG_D(TAG, "Save Batch");
  921. char *p, *p2;
  922. stream_seek(file_stream, 0, StreamOffsetFromEnd);
  923. FuriHalRtcDateTime dt;
  924. furi_hal_rtc_get_datetime(&dt);
  925. stream_write_format(file_stream, "\n%s ", SettingsFld_WriteBatch);
  926. p = (char*)furi_string_get_cstr(ReadBatch_cmd[view_cmd[rwt_read_batch]]);
  927. p2 = strchr(p, ':');
  928. if(p2 == NULL) p2 = p + strlen(p);
  929. stream_write(file_stream, (uint8_t*)p, p2 - p);
  930. stream_write_format(file_stream, " %02d.%02d.%02d %02d.%02d: ", dt.day, dt.month, dt.year % 100, dt.hour, dt.minute);
  931. for(uint16_t i = 0; i < Log_Total; i++) {
  932. p = (char*) furi_string_get_cstr(Log[i]);
  933. p2 = strchr(p, ':');
  934. if(p2 && *(p2-1) != '*') { // skip string
  935. if(*(p2-1) == ']') { // array
  936. char *p3 = strchr(p, '[');
  937. if(p3 == NULL) p3 = p2;
  938. stream_write(file_stream, (uint8_t*)p, p3 - p);
  939. stream_write_cstring(file_stream, "={");
  940. p = (p2 += 2);
  941. do {
  942. while(is_digit(p2, true) || *p2 == 'x') p2++;
  943. stream_write(file_stream, (uint8_t*)p, p2 - p);
  944. char c = *p2;
  945. if(c == '\0') break;
  946. if(c != ',') {
  947. p2 = strchr(p2, ',');
  948. if(p2 == NULL) break;
  949. }
  950. stream_write_char(file_stream, ',');
  951. p = ++p2;
  952. } while(1);
  953. stream_write_char(file_stream, '}');
  954. } else {
  955. stream_write(file_stream, (uint8_t*)p, p2 - p - (*(p2-2) == '*' ? 2 : 0));
  956. stream_write_char(file_stream, '=');
  957. p2 += 2;
  958. p = strchr(p2, ' ');
  959. if(p == NULL) p = p2 + strlen(p2);
  960. stream_write(file_stream, (uint8_t*)p2, p - p2);
  961. }
  962. if(i < Log_Total - 1) stream_write_char(file_stream, ';');
  963. }
  964. }
  965. }
  966. static void input_callback(InputEvent* input_event, FuriMessageQueue* event_queue) {
  967. furi_assert(event_queue);
  968. PluginEvent event = {.type = EventTypeKey, .input = *input_event};
  969. furi_message_queue_put(event_queue, &event, FuriWaitForever);
  970. }
  971. void display_remove_asterisk(char *fsp, uint8_t vx)
  972. {
  973. char *p2 = strchr(fsp, '*');
  974. if(p2) { // remove '*' or '*n'
  975. int pos = p2 - fsp;
  976. if((pos -= vx) < 0) pos = 0;
  977. char c = *(p2 + 1);
  978. if(*(screen_buf + pos))
  979. memmove(screen_buf + pos, screen_buf + pos + (c == ':' || c == '=' ? 1 : 2), FONT_5x7_SCREEN_WIDTH + 1 + 2 - pos);
  980. }
  981. }
  982. void render_display_list(Canvas* const canvas, FuriString ***fsa, char delim, uint16_t view_pos, uint16_t max_i)
  983. {
  984. uint16_t page = view_pos & ~7;
  985. char *p, *end;
  986. uint16_t y, len;
  987. for(uint8_t i = 0; i < 8 && page + i < max_i; i++) {
  988. y = 14 + i * 7;
  989. p = (char*) furi_string_get_cstr((*fsa)[page + i]);
  990. end = strchr(p, delim);
  991. if(end) {
  992. len = MIN(end - p, view_x);
  993. len = MIN(end - p - len, FONT_5x7_SCREEN_WIDTH);
  994. strncpy(screen_buf, p + view_x, len);
  995. screen_buf[len] = '\0';
  996. display_remove_asterisk(p, MIN(end - p, view_x));
  997. canvas_draw_str(canvas, 5, y, screen_buf);
  998. }
  999. if((view_pos & 7) == i) {
  1000. canvas_draw_str(canvas, 0, y, ">");
  1001. canvas_draw_str(canvas, -1, y, ">");
  1002. }
  1003. }
  1004. }
  1005. void display_edit_ttf_font(Canvas* const canvas, uint8_t start_x, uint8_t start_y)
  1006. {
  1007. screen_buf[0] = *Edit_pos; screen_buf[1] = '\0';
  1008. int n = canvas_string_width(canvas, screen_buf);
  1009. int len = Edit_pos - Edit_start;
  1010. memcpy(screen_buf, Edit_start, len);
  1011. screen_buf[len] = '\0';
  1012. int x = start_x + canvas_string_width(canvas, screen_buf);
  1013. int len2 = strlen(Edit_pos);
  1014. memcpy(screen_buf + len, Edit_pos, len2);
  1015. screen_buf[len + len2] = '\0';
  1016. canvas_draw_str(canvas, start_x, start_y, screen_buf);
  1017. start_y += 1;
  1018. canvas_draw_line(canvas, x + (len ? 1 : 0), start_y, x + n + (*Edit_pos == '1' && len ? 1 : 0), start_y);
  1019. }
  1020. void display_add_status(void)
  1021. {
  1022. if(NRF_ERROR) strcat(screen_buf, "nRF24 ERROR!");
  1023. else if(ERR) snprintf(screen_buf, sizeof(screen_buf), "ERROR %s", ERR_STR);
  1024. else if(send_status == sst_error) strcat(screen_buf, "NO ACK!");
  1025. else if(send_status == sst_timeout) strcat(screen_buf, "TIMEOUT!");
  1026. else if(send_status == sst_none) ;
  1027. else if(send_status == sst_sending) strcat(screen_buf, "sending");
  1028. else if(send_status == sst_receiving) strcat(screen_buf, "receiving");
  1029. else if(send_status == sst_ok &&
  1030. (rw_type == rwt_read_cmd
  1031. || (rw_type == rwt_read_batch && (uint32_t)ReadBatch_cmd_curr == 0xFFFFFFFF)
  1032. || (rw_type == rwt_set_batch && SetBatch_cmd_curr == Log_Total)
  1033. || (rw_type == rwt_write_batch && WriteBatch_cmd_curr == Log_Total)))
  1034. strcat(screen_buf, "OK");
  1035. else strcat(screen_buf, "working");
  1036. }
  1037. static void render_callback(Canvas* const canvas, void* ctx) {
  1038. if(ctx == NULL) return;
  1039. const PluginState* plugin_state = ctx;
  1040. if(furi_mutex_acquire(plugin_state->mutex, 5) != FuriStatusOk) return;
  1041. //canvas_draw_frame(canvas, 0, 0, 128, 64); // border around the edge of the screen
  1042. if(what_doing == 0) {
  1043. canvas_set_font(canvas, FontSecondary); // 8x10 font, 6 lines
  1044. snprintf(screen_buf, sizeof(screen_buf), "%s: %s", addr_len ? "File" : "Open", file_name);
  1045. canvas_draw_str(canvas, 8, 10, screen_buf);
  1046. if(addr_len) {
  1047. if(Edit) {
  1048. if(setup_cursor == 1) display_edit_ttf_font(canvas, 45, 20);
  1049. else if(setup_cursor == 2) display_edit_ttf_font(canvas, 55, 30);
  1050. }
  1051. if(!Edit || setup_cursor != 1) {
  1052. screen_buf[0] = '\0';
  1053. add_to_str_hex_bytes(screen_buf, addr, addr_len);
  1054. canvas_draw_str(canvas, 45, 20, screen_buf);
  1055. }
  1056. if(!Edit || setup_cursor != 2) {
  1057. snprintf(screen_buf, sizeof(screen_buf), "%d", NRF_channel);
  1058. canvas_draw_str(canvas, 55, 30, screen_buf);
  1059. }
  1060. canvas_draw_str(canvas, 8, 20, "Address:");
  1061. snprintf(screen_buf, sizeof(screen_buf), "Rate: %d, Ch:", NRF_rate);
  1062. canvas_draw_str(canvas, 8, 30, screen_buf);
  1063. snprintf(screen_buf, sizeof(screen_buf), "RB: %d, R: %d, WB: %d", ReadBatch_cmd_Total, Read_cmd_Total, WriteBatch_cmd_Total);
  1064. canvas_draw_str(canvas, 8, 40, screen_buf);
  1065. canvas_draw_str(canvas, 0, 64, Info);
  1066. canvas_draw_str(canvas, 0, 10 + setup_cursor * 10, ">");
  1067. } else {
  1068. snprintf(screen_buf, sizeof(screen_buf), "Ver. %s, vad7", VERSION);
  1069. canvas_draw_str(canvas, 10, 60, screen_buf);
  1070. canvas_draw_str(canvas, 0, 10, ">");
  1071. }
  1072. } else if(what_doing == 1){
  1073. if(rw_type == rwt_listen) {
  1074. canvas_set_font(canvas, FontSecondary); // 8x10 font, 6 lines
  1075. canvas_draw_str(canvas, 0, 10, "Listen mode");
  1076. canvas_draw_str(canvas, 0, 25, "Address:");
  1077. if(Edit) display_edit_ttf_font(canvas, 40, 25);
  1078. else if(listen_addr_len) {
  1079. screen_buf[0] = '\0';
  1080. add_to_str_hex_bytes(screen_buf, listen_addr, listen_addr_len);
  1081. canvas_draw_str(canvas, 40, 25, screen_buf);
  1082. }
  1083. snprintf(screen_buf, sizeof(screen_buf), "I: %d +(%d) mA", Current - CurrentStart, CurrentStart);
  1084. canvas_draw_str(canvas, 0, 60, screen_buf);
  1085. } else {
  1086. canvas_set_font(canvas, FontBatteryPercent); // 5x7 font, 9 lines, 25 cols
  1087. if(rw_type == rwt_read_batch) {
  1088. canvas_draw_str(canvas, 0, 7, "Read Batch:");
  1089. render_display_list(canvas, &ReadBatch_cmd, ':', view_cmd[rw_type], ReadBatch_cmd_Total);
  1090. } else if(rw_type == rwt_read_cmd) {
  1091. canvas_draw_str(canvas, 0, 7, "Read Command:");
  1092. render_display_list(canvas, &Read_cmd, '=', view_cmd[rw_type], Read_cmd_Total);
  1093. } else if(rw_type == rwt_write_batch) {
  1094. if(!ask_fill_screen_buf()) strcpy(screen_buf, "Write Batch:");
  1095. canvas_draw_str(canvas, 0, 7, screen_buf);
  1096. render_display_list(canvas, &WriteBatch_cmd, ':', view_cmd[rw_type], WriteBatch_cmd_Total);
  1097. } else if(rw_type == rwt_set_batch) {
  1098. strcpy(screen_buf, "Set: ");
  1099. display_add_status();
  1100. canvas_draw_str(canvas, 0, 7, screen_buf);
  1101. render_display_list(canvas, &SetBatch_cmd, ':', view_cmd[rw_type], SetBatch_cmd_Total);
  1102. }
  1103. }
  1104. } else { // what_doing == 2
  1105. if(rw_type == rwt_listen) {
  1106. canvas_set_font(canvas, FontSecondary); // 8x10 font, 6 lines
  1107. strcpy(screen_buf, "Listen: ");
  1108. if(NRF_ERROR) strcat(screen_buf, "nRF24 ERROR!");
  1109. else if(ListenNew) {
  1110. snprintf(screen_buf + strlen(screen_buf), 16, "%02d:%02d:%02d", ListenLastTime.hour, ListenLastTime.minute, ListenLastTime.second);
  1111. if(ListenPrev) snprintf(screen_buf + strlen(screen_buf), 16, " (%lu)", ListenLast - ListenPrev);
  1112. } else strcat(screen_buf, "receiving");
  1113. snprintf(screen_buf + strlen(screen_buf), 16, " %dmA", Current - CurrentStart);
  1114. canvas_draw_str(canvas, 0, 10, screen_buf);
  1115. if(ListenFields) {
  1116. char *p2, *p = ListenFields;
  1117. uint8_t hex, len, *pld = payload_receive;
  1118. for(uint8_t i = 0; i < 5 && *p; i++) {
  1119. hex = false;
  1120. p2 = strchr(p, ',');
  1121. if(p2 == NULL) p2 = p + strlen(p);
  1122. if(*(p2 - 1) == '#') hex = true;
  1123. memcpy(screen_buf, p, len = p2 - p);
  1124. strcpy(screen_buf + len, ": ");
  1125. if(ListenNew) {
  1126. len = payload_struct[i];
  1127. int32_t n = get_payload_receive_field(pld, len);
  1128. if(hex) {
  1129. strcat(screen_buf, "0x");
  1130. add_to_str_hex_bytes(screen_buf, pld, len);
  1131. } else {
  1132. snprintf(screen_buf + strlen(screen_buf), 20, "%ld", n);
  1133. if(n > 9) {
  1134. strcat(screen_buf, " (");
  1135. add_to_str_hex_bytes(screen_buf, pld, len);
  1136. strcat(screen_buf, ")");
  1137. }
  1138. }
  1139. pld += len;
  1140. }
  1141. canvas_draw_str(canvas, 0, 20 + i * 10, screen_buf);
  1142. if(*p2 == '\0') break;
  1143. p = p2 + 1;
  1144. }
  1145. }
  1146. } else if(rw_type == rwt_read_cmd) { // Read command
  1147. canvas_set_font(canvas, FontSecondary); // 8x10 font, 6 lines
  1148. if(!ask_fill_screen_buf()) {
  1149. strcpy(screen_buf, "Read ");
  1150. strcat(screen_buf, ReadRepeat ? "rep: " : "cmd: ");
  1151. }
  1152. display_add_status();
  1153. canvas_draw_str(canvas, 0, 10, screen_buf);
  1154. if(Log_Total) {
  1155. char *p = (char*)furi_string_get_cstr(Log[Log_Total - 1]);
  1156. uint8_t vx = MIN(view_x, strlen(p));
  1157. strncpy(screen_buf, p + vx, 30);
  1158. display_remove_asterisk(p, vx);
  1159. canvas_draw_str(canvas, 0, 15 + 10, screen_buf);
  1160. }
  1161. } else if(rw_type == rwt_set_batch) {
  1162. canvas_set_font(canvas, FontBatteryPercent); // 5x7 font, 9 lines, 25 cols
  1163. strcpy(screen_buf, "Set: ");
  1164. display_add_status();
  1165. canvas_draw_str(canvas, 0, 7, screen_buf);
  1166. render_display_list(canvas, &SetBatch_cmd, ':', view_cmd[rw_type], SetBatch_cmd_Total);
  1167. } else { // rwt_read_batch, rwt_write_batch
  1168. canvas_set_font(canvas, FontBatteryPercent); // 5x7 font, 9 lines, 25 cols
  1169. if(!ask_fill_screen_buf()) {
  1170. strcpy(screen_buf, rw_type == rwt_read_batch ? "Read Batch: " : "Write: ");
  1171. if(rw_type == rwt_read_batch || send_status != sst_none) {
  1172. display_add_status();
  1173. } else if(rw_type == rwt_write_batch) {
  1174. char *p = (char*)furi_string_get_cstr(WriteBatch_cmd[view_cmd[rwt_write_batch]]);
  1175. char *end = strchr(p, ':');
  1176. if(end) {
  1177. uint8_t len = end - p;
  1178. uint8_t lenb = strlen(screen_buf);
  1179. end = screen_buf + lenb;
  1180. lenb = FONT_5x7_SCREEN_WIDTH - lenb;
  1181. if(len > lenb) {
  1182. if(view_x < len) {
  1183. strncpy(end, p + view_x, len = MIN(lenb, len - view_x));
  1184. end[len] = '\0';
  1185. }
  1186. } else {
  1187. strncpy(end, p, len);
  1188. end[len] = '\0';
  1189. }
  1190. }
  1191. }
  1192. }
  1193. canvas_draw_str(canvas, 0, 7, screen_buf);
  1194. if(Log_Total) {
  1195. char *p;
  1196. uint16_t y, page = view_Batch & ~7;
  1197. uint8_t vx;
  1198. for(uint8_t i = 0; i < 8 && page + i < Log_Total; i++) {
  1199. p = (char*)furi_string_get_cstr(Log[page + i]);
  1200. y = 14 + i * 7;
  1201. vx = MIN(view_x, strlen(p));
  1202. if((view_Batch & 7) == i) {
  1203. canvas_draw_str(canvas, 0, y, ">");
  1204. canvas_draw_str(canvas, -1, y, ">");
  1205. if(Edit) {
  1206. int n = Edit_pos - p - vx - (FONT_5x7_SCREEN_WIDTH - 4);
  1207. if(n > 0) vx += n; // fix out of screen
  1208. int x = 6 + (Edit_pos - p - vx) * 5;
  1209. canvas_draw_line(canvas, x - 1, y, x - 1, y - 1);
  1210. canvas_draw_line(canvas, x - 1, y, n = x + 1 * 5, y);
  1211. canvas_draw_line(canvas, n, y, n, y - 1);
  1212. }
  1213. }
  1214. strncpy(screen_buf, p + vx, FONT_5x7_SCREEN_WIDTH + 2);
  1215. screen_buf[FONT_5x7_SCREEN_WIDTH + 2] = '\0';
  1216. display_remove_asterisk(p, vx);
  1217. canvas_draw_str(canvas, 6, y, screen_buf);
  1218. }
  1219. }
  1220. }
  1221. }
  1222. furi_mutex_release(plugin_state->mutex);
  1223. }
  1224. void work_timer_callback(void* ctx)
  1225. {
  1226. if(ctx == NULL) return;
  1227. if(rw_type == rwt_listen && (pwr_read_timer += WORK_PERIOD) >= POWER_READ_PERIOD) {
  1228. pwr_read_timer = 0;
  1229. update_power();
  1230. }
  1231. if(what_doing == 2) {
  1232. const PluginState* plugin_state = ctx;
  1233. if(furi_mutex_acquire(plugin_state->mutex, 0) != FuriStatusOk) return;
  1234. if(rw_type == rwt_write_batch || rw_type == rwt_set_batch) {
  1235. uint16_t *cmd_curr = rw_type == rwt_set_batch ? &SetBatch_cmd_curr : &WriteBatch_cmd_curr;
  1236. if(ERR == 0 && furi_get_tick() - NRF_time >= delay_between_pkt) {
  1237. if(send_status == sst_ok) {
  1238. if(ERR == 0 && *cmd_curr < Log_Total) {
  1239. if(++(*cmd_curr) < Log_Total) Run_WriteBatch_cmd();
  1240. else { // finished ok
  1241. if(rw_type == rwt_set_batch) what_doing = 1;
  1242. Edited = false;
  1243. }
  1244. }
  1245. } else if(send_status == sst_sending) {
  1246. if(NRF_repeat++ < NRF_resend) nrf24_send_packet();
  1247. else {
  1248. view_Batch = *cmd_curr;
  1249. send_status = sst_error; // error NO_ACK
  1250. }
  1251. }
  1252. }
  1253. if((ERR || send_status == sst_error) && rw_type == rwt_set_batch) {
  1254. what_doing = 1;
  1255. }
  1256. // ReadBatch or ReadCmd
  1257. } else if(send_status == sst_sending) { // sending
  1258. if(furi_get_tick() - NRF_time > delay_between_pkt) {
  1259. if(NRF_repeat++ < NRF_resend) {
  1260. nrf24_resend_read_packet();
  1261. } else send_status = sst_error; // error NO_ACK
  1262. }
  1263. } else if(send_status == sst_receiving) { // receiving
  1264. for(uint8_t i = 0; i < 3; i++) {
  1265. if(nrf24_read_newpacket()) {
  1266. if(rw_type == rwt_listen) {
  1267. ListenPrev = ListenLast;
  1268. furi_hal_rtc_get_datetime(&ListenLastTime);
  1269. ListenLast = furi_hal_rtc_datetime_to_timestamp(&ListenLastTime);
  1270. ListenNew = true;
  1271. } else if(send_status != sst_receiving) break;
  1272. } else {
  1273. if(rw_type != rwt_listen && furi_get_tick() - NRF_time > NRF_READ_TIMEOUT) {
  1274. if(NRF_repeat++ < NRF_resend) {
  1275. send_status = sst_sending;
  1276. nrf24_resend_read_packet();
  1277. } else {
  1278. FURI_LOG_D(TAG, "TIMEOUT: %lu", furi_get_tick() - NRF_time);
  1279. send_status = sst_timeout;
  1280. }
  1281. }
  1282. break;
  1283. }
  1284. }
  1285. } else if(send_status == sst_ok) {
  1286. if(rw_type == rwt_read_batch) {
  1287. if((uint32_t)ReadBatch_cmd_curr != 0xFFFFFFFF && ERR == 0 && furi_get_tick() - NRF_time >= delay_between_pkt) {
  1288. Run_ReadBatch_cmd(NULL);
  1289. }
  1290. }
  1291. }
  1292. furi_mutex_release(plugin_state->mutex);
  1293. }
  1294. }
  1295. void next_rw_type(int8_t add)
  1296. {
  1297. do {
  1298. rw_type += add;
  1299. if(rw_type >= rwt_max) {
  1300. if(add > 0) rw_type = 0; else rw_type = rwt_max - 1;
  1301. }
  1302. if(rw_type == rwt_set_batch && SetBatch_cmd_Total) break;
  1303. if(rw_type == rwt_read_batch && ReadBatch_cmd_Total) break;
  1304. if(rw_type == rwt_read_cmd && Read_cmd_Total) break;
  1305. if(rw_type == rwt_write_batch && WriteBatch_cmd_Total) break;
  1306. } while(rw_type != rwt_listen);
  1307. send_status = sst_none;
  1308. }
  1309. void next_view_cmd(int8_t add)
  1310. {
  1311. if(rw_type == rwt_listen) return;
  1312. uint16_t max = (rw_type == rwt_read_batch ? ReadBatch_cmd_Total :
  1313. rw_type == rwt_read_cmd ? Read_cmd_Total :
  1314. rw_type == rwt_set_batch ? SetBatch_cmd_Total : WriteBatch_cmd_Total);
  1315. if((view_cmd[rw_type] += add) >= max) view_cmd[rw_type] = add > 0 ? 0 : max - 1;
  1316. }
  1317. int32_t nrf24batch_app(void* p) {
  1318. UNUSED(p);
  1319. APP = malloc(sizeof(nRF24Batch));
  1320. FuriMessageQueue* event_queue = furi_message_queue_alloc(8, sizeof(PluginEvent));
  1321. APP->plugin_state = malloc(sizeof(PluginState));
  1322. APP->plugin_state->mutex = furi_mutex_alloc(FuriMutexTypeNormal);
  1323. if(!APP->plugin_state->mutex) {
  1324. furi_message_queue_free(event_queue);
  1325. FURI_LOG_E(TAG, "cannot create mutex");
  1326. free(APP->plugin_state);
  1327. return 255;
  1328. }
  1329. // Set system callbacks
  1330. ViewPort* view_port = view_port_alloc();
  1331. view_port_draw_callback_set(view_port, render_callback, APP->plugin_state);
  1332. view_port_input_callback_set(view_port, input_callback, event_queue);
  1333. // Open GUI and register view_port
  1334. APP->gui = furi_record_open(RECORD_GUI);
  1335. gui_add_view_port(APP->gui, view_port, GuiLayerFullscreen);
  1336. APP->notification = furi_record_open(RECORD_NOTIFICATION);
  1337. APP->storage = furi_record_open(RECORD_STORAGE);
  1338. storage_common_mkdir(APP->storage, SCAN_APP_PATH_FOLDER);
  1339. file_stream = file_stream_alloc(APP->storage);
  1340. FuriTimer *work_timer = furi_timer_alloc(work_timer_callback, FuriTimerTypePeriodic, APP->plugin_state);
  1341. furi_timer_start(work_timer, WORK_PERIOD);
  1342. nrf24_init();
  1343. check_en_power_5V();
  1344. PluginEvent event;
  1345. for(bool processing = true; processing;) {
  1346. FuriStatus event_status = furi_message_queue_get(event_queue, &event, 100);
  1347. furi_mutex_acquire(APP->plugin_state->mutex, FuriWaitForever);
  1348. static FuriLogLevel FuriLogLevel = FuriLogLevelDefault;
  1349. if(furi_log_get_level() != FuriLogLevel) {
  1350. FuriLogLevel = furi_log_get_level();
  1351. if(FuriLogLevel == FuriLogLevelDebug) furi_hal_uart_set_br(FuriHalUartIdUSART1, 1843200);
  1352. }
  1353. if(what_doing == 2 && rw_type == rwt_read_cmd && ReadRepeat && furi_get_tick() - NRF_time > (uint32_t)(ReadCmdRepeatPeriod * 1000)) {
  1354. ERR = 0;
  1355. free_Log();
  1356. Run_Read_cmd(Read_cmd[view_cmd[rwt_read_cmd]]);
  1357. notification_message(APP->notification, &sequence_blink_blue_100);
  1358. }
  1359. if(event_status == FuriStatusOk) {
  1360. // press events
  1361. if(event.type == EventTypeKey) {
  1362. switch(event.input.key) {
  1363. case InputKeyUp:
  1364. if(event.input.type == InputTypeShort || event.input.type == InputTypeRepeat) {
  1365. if(!ask_question) {
  1366. if(Edit) {
  1367. char c = *Edit_pos;
  1368. if(Edit_hex) {
  1369. if(c == '9') *Edit_pos = 'A';
  1370. else if(c < 'F' || c < '9') *Edit_pos = c + 1;
  1371. } else {
  1372. if(c == '-') *Edit_pos = '0';
  1373. else if(c < '9') *Edit_pos = c + 1;
  1374. else {
  1375. c = *(Edit_pos - 1);
  1376. if(Edit_pos > Edit_start && c < '9' && c >= '0') {
  1377. *Edit_pos = '0';
  1378. (*(Edit_pos - 1)) = c + 1;
  1379. }
  1380. }
  1381. }
  1382. } else if(what_doing == 0) {
  1383. if(addr_len) {
  1384. if(setup_cursor > 0) setup_cursor--; else setup_cursor = 2;
  1385. }
  1386. } else if(what_doing == 1) next_view_cmd(-1);
  1387. else if(what_doing == 2) if(view_Batch) view_Batch--;
  1388. }
  1389. }
  1390. break;
  1391. case InputKeyDown:
  1392. if(event.input.type == InputTypeShort || event.input.type == InputTypeRepeat) {
  1393. if(!ask_question) {
  1394. if(Edit) {
  1395. if(*Edit_pos != '-') {
  1396. if(Edit_hex && *Edit_pos == 'A') (*Edit_pos) = '9';
  1397. else if(*Edit_pos > '0') (*Edit_pos)--;
  1398. else if(!Edit_hex) {
  1399. if(Edit_pos > Edit_start) {
  1400. if(*(Edit_pos - 1) > '0' && *(Edit_pos - 1) <= '9') {
  1401. *Edit_pos = '9';
  1402. (*(Edit_pos - 1))--;
  1403. }
  1404. } else Edit_insert_digit('-'); // negative
  1405. }
  1406. }
  1407. } else if(what_doing == 0) {
  1408. if(addr_len) {
  1409. if(setup_cursor < 2) setup_cursor++; else setup_cursor = 0;
  1410. }
  1411. } else if(what_doing == 1) next_view_cmd(+1);
  1412. else if(what_doing == 2) if(view_Batch < Log_Total - 1) view_Batch++;
  1413. }
  1414. }
  1415. break;
  1416. case InputKeyLeft:
  1417. if(event.input.type == InputTypeShort || event.input.type == InputTypeRepeat) {
  1418. if(ask_question) {
  1419. if(event.input.type == InputTypeShort) ask_question_answer ^= 1;
  1420. } else if(Edit) {
  1421. if(Edit_pos > Edit_start) {
  1422. if(is_digit(Edit_pos - 1, Edit_hex)) Edit_pos--;
  1423. else if(*(Edit_pos - 1) == 'x' && *(Edit_pos - 3) == ',') Edit_pos -= 4;
  1424. else if(*(Edit_pos - 1) == ',') Edit_pos -= 2;
  1425. }
  1426. } else if(what_doing == 0) {
  1427. if(addr_len) {
  1428. rw_type = rwt_listen;
  1429. what_doing = 1;
  1430. }
  1431. } else if(what_doing == 1) {
  1432. if(event.input.type == InputTypeShort) next_rw_type(-1); else if(view_x) view_x--;
  1433. } else if(what_doing == 2) if(view_x) view_x--;
  1434. } else if(event.input.type == InputTypeLong) {
  1435. if(!ask_question && view_x == 0 && what_doing == 2 && (rw_type == rwt_write_batch || rw_type == rwt_read_batch)
  1436. && Log_Total && Log[view_Batch] != NULL) {
  1437. ask_question = ask_skip_cmd;
  1438. ask_question_answer = 1;
  1439. }
  1440. }
  1441. break;
  1442. case InputKeyRight:
  1443. if(event.input.type == InputTypeShort || event.input.type == InputTypeRepeat) {
  1444. if(ask_question) {
  1445. ask_question_answer ^= 1;
  1446. } else if(Edit) {
  1447. if(is_digit(Edit_pos + 1, Edit_hex)) Edit_pos++;
  1448. else if(*(Edit_pos + 1) == ',') {
  1449. Edit_pos += 2;
  1450. if(*(Edit_pos + 1) == 'x') Edit_pos += 2;
  1451. }
  1452. } else if(what_doing == 0) {
  1453. if(addr_len) {
  1454. rw_type = rwt_set_batch;
  1455. what_doing = 1;
  1456. }
  1457. } else if(what_doing == 1) {
  1458. if(event.input.type == InputTypeShort) next_rw_type(+1); else view_x++;
  1459. } else if(what_doing == 2) view_x++;
  1460. }
  1461. break;
  1462. case InputKeyOk:
  1463. if(event.input.type == InputTypeShort) {
  1464. if(ask_question) {
  1465. if(ask_question_answer) {
  1466. if(ask_question == ask_save_batch) {
  1467. save_batch();
  1468. } else if(ask_question == ask_write_batch) {
  1469. if(WriteBatch_cmd_Total) {
  1470. if(what_doing == 1) {
  1471. Prepare_Write_cmd(WriteBatch_cmd[view_cmd[rwt_write_batch]]);
  1472. send_status = sst_none;
  1473. Edited = false;
  1474. view_x = 0;
  1475. view_Batch = 0;
  1476. }
  1477. if(Log_Total) {
  1478. ERR = 0;
  1479. WriteBatch_cmd_curr = 0;
  1480. Run_WriteBatch_cmd();
  1481. what_doing = 2;
  1482. }
  1483. }
  1484. } else if(ask_question == ask_skip_cmd) {
  1485. if(rw_type == rwt_write_batch || rw_type == rwt_read_batch) {
  1486. furi_string_free(Log[view_Batch]);
  1487. if(view_Batch < Log_Total - 1) memmove(&Log[view_Batch], &Log[view_Batch + 1], sizeof(Log) * (Log_Total - view_Batch - 1));
  1488. else view_Batch--;
  1489. Log_Total--;
  1490. }
  1491. } else if(ask_question == ask_exit) {
  1492. processing = false;
  1493. } else if(ask_question == ask_return) {
  1494. if(what_doing == 2) {
  1495. ERR = 0;
  1496. send_status = sst_none;
  1497. Edited = false;
  1498. what_doing--;
  1499. }
  1500. }
  1501. }
  1502. ask_question = 0;
  1503. } else if(Edit) { // insert digit
  1504. Edit_insert_digit('0');
  1505. } else if(what_doing == 0) {
  1506. if(setup_cursor == 0) { // open file
  1507. file_stream_close(file_stream);
  1508. if(select_settings_file()) {
  1509. uint8_t err = load_settings_file();
  1510. if(err) snprintf(file_name, sizeof(file_name), "LOAD ERROR #%d", err);
  1511. }
  1512. } else if(setup_cursor == 1) { // change address
  1513. char *ebuf = (char*)payload;
  1514. ebuf[0] = '\0';
  1515. add_to_str_hex_bytes(ebuf, addr, addr_len);
  1516. Edit_hex = true;
  1517. Edit_pos = ebuf + strlen(ebuf) - 1;
  1518. Edit_start = ebuf;
  1519. Edit = 1;
  1520. NRF_INITED = 0;
  1521. } else if(setup_cursor == 2) { // change channel
  1522. char *ebuf = (char*)payload;
  1523. snprintf(ebuf, sizeof(payload), "%d", NRF_channel);
  1524. Edit_hex = false;
  1525. Edit_pos = ebuf + strlen(ebuf) - 1;
  1526. Edit_start = ebuf;
  1527. Edit = 1;
  1528. NRF_INITED = 0;
  1529. }
  1530. } else if(what_doing == 1) {
  1531. if(rw_type == rwt_set_batch) {
  1532. if(SetBatch_cmd_Total) {
  1533. ERR = 0;
  1534. send_status = sst_none;
  1535. Prepare_Write_cmd(SetBatch_cmd[view_cmd[rwt_set_batch]]);
  1536. if(!ERR) {
  1537. SetBatch_cmd_curr = 0;
  1538. Run_WriteBatch_cmd();
  1539. what_doing = 2;
  1540. }
  1541. Edited = false;
  1542. }
  1543. } else if(rw_type == rwt_read_batch) {
  1544. if(ReadBatch_cmd_Total) {
  1545. ERR = 0;
  1546. Run_ReadBatch_cmd(ReadBatch_cmd[view_cmd[rwt_read_batch]]);
  1547. view_x = 0;
  1548. view_Batch = 0;
  1549. what_doing = 2;
  1550. }
  1551. } else if(rw_type == rwt_read_cmd) {
  1552. if(Read_cmd_Total) {
  1553. ERR = 0;
  1554. free_Log();
  1555. Run_Read_cmd(Read_cmd[view_cmd[rwt_read_cmd]]);
  1556. view_x = 0;
  1557. what_doing = 2;
  1558. }
  1559. } else if(rw_type == rwt_write_batch) {
  1560. if(WriteBatch_cmd_Total) {
  1561. ERR = 0;
  1562. Prepare_Write_cmd(WriteBatch_cmd[view_cmd[rwt_write_batch]]);
  1563. send_status = sst_none;
  1564. Edited = false;
  1565. view_x = 0;
  1566. view_Batch = 0;
  1567. what_doing = 2;
  1568. }
  1569. } else if(rw_type == rwt_listen) {
  1570. if(listen_addr_len) {
  1571. free_Log();
  1572. prepare_nrf24();
  1573. if(!NRF_ERROR) {
  1574. nrf24_set_rx_mode(nrf24_HANDLE);
  1575. ListenNew = false;
  1576. send_status = sst_receiving; // receiving
  1577. }
  1578. what_doing = 2;
  1579. }
  1580. }
  1581. } else if(what_doing == 2) {
  1582. if(rw_type == rwt_read_cmd) {
  1583. ERR = 0;
  1584. free_Log();
  1585. Run_Read_cmd(Read_cmd[view_cmd[rwt_read_cmd]]);
  1586. } else if(Log_Total) {
  1587. if(rw_type == rwt_read_batch) {
  1588. ask_question = ask_save_batch;
  1589. ask_question_answer = 0;
  1590. } else if(rw_type == rwt_write_batch) {
  1591. ask_question = ask_write_batch;
  1592. ask_question_answer = 0;
  1593. }
  1594. }
  1595. }
  1596. } else if(event.input.type == InputTypeLong) {
  1597. if(Edit) { // delete
  1598. if(what_doing <= 1) {
  1599. if(strlen(Edit_start) > 1) {
  1600. memmove(Edit_pos, Edit_pos + 1, strlen(Edit_pos));
  1601. if(*Edit_pos == '\0') Edit_pos--;
  1602. }
  1603. } else {
  1604. FuriString *fs = Log[view_Batch];
  1605. if(is_digit(Edit_pos + 1, Edit_hex) || (Edit_pos > Edit_start && is_digit(Edit_pos - 1, Edit_hex))) {
  1606. memmove(Edit_pos, Edit_pos + 1, strlen(Edit_pos));
  1607. if(*Edit_pos == '\0') Edit_pos--;
  1608. furi_string_left(fs, furi_string_size(fs) - 1);
  1609. }
  1610. }
  1611. } else if(what_doing == 1) {
  1612. if(rw_type == rwt_listen) {
  1613. if(listen_addr_len) {
  1614. char *ebuf = (char*)payload;
  1615. ebuf[0] = '\0';
  1616. add_to_str_hex_bytes(ebuf, listen_addr, listen_addr_len);
  1617. Edit_hex = true;
  1618. Edit_pos = ebuf + strlen(ebuf) - 1;
  1619. Edit_start = ebuf;
  1620. Edit = 1;
  1621. NRF_INITED = 0;
  1622. }
  1623. } else if(rw_type == rwt_read_batch) {
  1624. if(ReadBatch_cmd_Total) {
  1625. ERR = 0;
  1626. Run_ReadBatch_cmd(ReadBatch_cmd[view_cmd[rwt_read_batch]]);
  1627. view_x = 0;
  1628. view_Batch = 0;
  1629. what_doing = 2;
  1630. }
  1631. } else if(rw_type == rwt_write_batch) {
  1632. ask_question = ask_write_batch;
  1633. ask_question_answer = 0;
  1634. }
  1635. } else if(what_doing == 2) {
  1636. if(rw_type == rwt_read_cmd) {
  1637. ReadRepeat = !ReadRepeat;
  1638. } else if(Log_Total) {
  1639. if(rw_type == rwt_write_batch) {
  1640. if(!Edit) {
  1641. Edit = 0;
  1642. Edit_hex = 0;
  1643. char *s = (char*)furi_string_get_cstr(Log[view_Batch]);
  1644. char *p = strchr(s, '=');
  1645. if(p) {
  1646. p++;
  1647. if(*p == '{') p++; // array
  1648. if(*(p + 1) == 'x') {
  1649. p += 2;
  1650. Edit_hex = 1; // hex
  1651. }
  1652. if(is_digit(p, Edit_hex)) {
  1653. Edit_start = p;
  1654. while(is_digit(p, Edit_hex)) p++;
  1655. Edit_pos = p - 1;
  1656. Edited = true;
  1657. Edit = 1;
  1658. }
  1659. }
  1660. }
  1661. } else if(rw_type == rwt_read_batch) {
  1662. ask_question = ask_save_batch;
  1663. ask_question_answer = 0;
  1664. }
  1665. }
  1666. }
  1667. }
  1668. break;
  1669. case InputKeyBack:
  1670. if(event.input.type == InputTypeLong) {
  1671. if(what_doing == 2 && Edited) {
  1672. if(!ask_question) ask_question_answer = 1;
  1673. ask_question = ask_exit;
  1674. } else processing = false;
  1675. } else if(event.input.type == InputTypeShort) {
  1676. if(ask_question) ask_question = 0;
  1677. else if(Edit) {
  1678. if(what_doing == 0) {
  1679. if(setup_cursor == 1) {
  1680. addr_len = ConvertHexToArray((char*)payload, addr, 5);
  1681. } else if(setup_cursor == 2) {
  1682. NRF_channel = str_to_int((char*)payload);
  1683. if(NRF_channel > MAX_CHANNEL) NRF_channel = MAX_CHANNEL;
  1684. }
  1685. } else if(what_doing == 1 && rw_type == rwt_listen) {
  1686. listen_addr_len = ConvertHexToArray((char*)payload, listen_addr, 5);
  1687. }
  1688. Edit = 0;
  1689. } else {
  1690. if(what_doing == 2 && Edited) {
  1691. ask_question = ask_return;
  1692. ask_question_answer = 1;
  1693. } else if(what_doing != 0) {
  1694. if(what_doing) what_doing--;
  1695. if(what_doing == 0) rw_type = rwt_read_batch;
  1696. if(what_doing <= 1) view_x = 0;
  1697. ERR = 0;
  1698. send_status = sst_none;
  1699. }
  1700. }
  1701. }
  1702. break;
  1703. default:
  1704. break;
  1705. }
  1706. }
  1707. }
  1708. view_port_update(view_port);
  1709. furi_mutex_release(APP->plugin_state->mutex);
  1710. }
  1711. nrf24_set_idle(nrf24_HANDLE);
  1712. nrf24_deinit();
  1713. if(NRF_BOARD_POWER_5V) furi_hal_power_disable_otg();
  1714. view_port_enabled_set(view_port, false);
  1715. gui_remove_view_port(APP->gui, view_port);
  1716. furi_record_close(RECORD_GUI);
  1717. furi_record_close(RECORD_NOTIFICATION);
  1718. furi_record_close(RECORD_STORAGE);
  1719. if(file_stream) {
  1720. file_stream_close(file_stream);
  1721. stream_free(file_stream);
  1722. }
  1723. view_port_free(view_port);
  1724. furi_message_queue_free(event_queue);
  1725. free_store();
  1726. furi_timer_stop(work_timer);
  1727. furi_timer_free(work_timer);
  1728. furi_mutex_free(APP->plugin_state->mutex);
  1729. free(APP->plugin_state);
  1730. free(APP);
  1731. return 0;
  1732. }