nrf24batch.c 57 KB

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