nrf24batch.c 58 KB

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