nrf24batch.c 58 KB

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