Parcourir la source

Merge pull request #21 from frux-c/tag-id-detail

Bug fixes mainly
Abel Chaka il y a 1 an
Parent
commit
a53413bd51
10 fichiers modifiés avec 261 ajouts et 64 suppressions
  1. 93 0
      scenes/uhf_scene_settings.c
  2. 19 7
      uhf_app.c
  3. 19 21
      uhf_buffer.c
  4. 3 1
      uhf_buffer.h
  5. 15 1
      uhf_module.c
  6. 11 0
      uhf_module.h
  7. 1 1
      uhf_tag.h
  8. 54 0
      uhf_tag_i.h
  9. 28 23
      uhf_uart.c
  10. 18 10
      uhf_worker.c

+ 93 - 0
scenes/uhf_scene_settings.c

@@ -1,6 +1,8 @@
 #include "../uhf_app_i.h"
 #include "../uhf_module.h"
 
+char* yes_no[] = {"No", "Yes"};
+
 void uhf_settings_set_module_baudrate(VariableItem* item) {
     M100Module* module = variable_item_get_context(item);
     uint8_t index = variable_item_get_current_value_index(item);
@@ -38,6 +40,50 @@ void uhf_settings_set_module_working_region(VariableItem* item) {
     variable_item_set_current_value_text(item, WORKING_REGIONS_STR[index]);
 }
 
+void uhf_settings_set_epc_write_mask(VariableItem* item){
+    M100Module* uhf_module = variable_item_get_context(item);
+    uint8_t index = variable_item_get_current_value_index(item);
+    variable_item_set_current_value_text(item, yes_no[index]);
+    if(index){
+        m100_enable_write_mask(uhf_module, WRITE_EPC);
+        return;
+    }
+    m100_disable_write_mask(uhf_module, WRITE_EPC);
+}
+
+void uhf_settings_set_tid_write_mask(VariableItem* item){
+    M100Module* uhf_module = variable_item_get_context(item);
+    uint8_t index = variable_item_get_current_value_index(item);
+    variable_item_set_current_value_text(item, yes_no[index]);
+    if(index){
+        m100_enable_write_mask(uhf_module, WRITE_TID);
+        return;
+    }
+    m100_disable_write_mask(uhf_module, WRITE_TID);
+}
+
+void uhf_settings_set_user_write_mask(VariableItem* item){
+    M100Module* uhf_module = variable_item_get_context(item);
+    uint8_t index = variable_item_get_current_value_index(item);
+    variable_item_set_current_value_text(item, yes_no[index]);
+    if(index){
+        m100_enable_write_mask(uhf_module, WRITE_USER);
+        return;
+    }
+    m100_disable_write_mask(uhf_module, WRITE_USER);
+}
+
+void uhf_settings_set_rfu_write_mask(VariableItem* item){
+    M100Module* uhf_module = variable_item_get_context(item);
+    uint8_t index = variable_item_get_current_value_index(item);
+    variable_item_set_current_value_text(item, yes_no[index]);
+    if(index){
+        m100_enable_write_mask(uhf_module, WRITE_RFU);
+        return;
+    }
+    m100_disable_write_mask(uhf_module, WRITE_RFU);
+}
+
 uint8_t uhf_settings_get_module_baudrate_index(M100Module* module) {
     for(uint8_t i = 0; i < BAUD_RATES_COUNT; i++) {
         if(BAUD_RATES[i] == module->uart->baudrate) {
@@ -71,6 +117,7 @@ void uhf_scene_settings_on_enter(void* ctx) {
     VariableItem* item;
     VariableItemList* variable_item_list = uhf_app->variable_item_list;
 
+    // Add baudrate item
     uint8_t value_index = uhf_settings_get_module_baudrate_index(uhf_module);
     char text_buf[10];
     snprintf(text_buf, sizeof(text_buf), "%lu", uhf_module->uart->baudrate);
@@ -84,6 +131,7 @@ void uhf_scene_settings_on_enter(void* ctx) {
     variable_item_set_current_value_text(item, text_buf);
     variable_item_set_current_value_index(item, value_index);
 
+    // Add power item
     value_index = uhf_settings_get_module_power_index(uhf_module);
     item = variable_item_list_add(
         variable_item_list,
@@ -95,6 +143,7 @@ void uhf_scene_settings_on_enter(void* ctx) {
     variable_item_set_current_value_text(item, text_buf);
     variable_item_set_current_value_index(item, value_index);
 
+    // Add working region item
     value_index = uhf_settings_get_module_working_region_index(uhf_module);
     item = variable_item_list_add(
         variable_item_list,
@@ -106,6 +155,50 @@ void uhf_scene_settings_on_enter(void* ctx) {
     variable_item_set_current_value_index(item, value_index);
 
     view_dispatcher_switch_to_view(uhf_app->view_dispatcher, UHFViewVariableItemList);
+
+    
+    // Add write modes
+    value_index = m100_is_write_mask_enabled(uhf_module, WRITE_EPC)? 1: 0;
+    item = variable_item_list_add(
+        variable_item_list,
+        "Write EPC:",
+        2,
+        uhf_settings_set_epc_write_mask,
+        uhf_module);
+    variable_item_set_current_value_text(item, yes_no[value_index]);
+    variable_item_set_current_value_index(item, value_index);
+
+    value_index = m100_is_write_mask_enabled(uhf_module, WRITE_TID)? 1: 0;
+    item = variable_item_list_add(
+        variable_item_list,
+        "Write TID:",
+        2,
+        uhf_settings_set_tid_write_mask,
+        uhf_module);
+    variable_item_set_current_value_text(item, yes_no[value_index]);
+    variable_item_set_current_value_index(item, value_index);
+
+    value_index = m100_is_write_mask_enabled(uhf_module, WRITE_USER)? 1: 0;
+    item = variable_item_list_add(
+        variable_item_list,
+        "Write User:",
+        2,
+        uhf_settings_set_user_write_mask,
+        uhf_module);
+    variable_item_set_current_value_text(item, yes_no[value_index]);
+    variable_item_set_current_value_index(item, value_index);
+
+    value_index = m100_is_write_mask_enabled(uhf_module, WRITE_RFU)? 1: 0;
+    item = variable_item_list_add(
+        variable_item_list,
+        "Write RFU:",
+        2,
+        uhf_settings_set_rfu_write_mask,
+        uhf_module);
+    variable_item_set_current_value_text(item, yes_no[value_index]);
+    variable_item_set_current_value_index(item, value_index);
+
+
 }
 
 bool uhf_scene_settings_on_event(void* ctx, SceneManagerEvent event) {

+ 19 - 7
uhf_app.c

@@ -1,4 +1,5 @@
 #include "uhf_app_i.h"
+#include "expansion/expansion.h"
 
 char* convertToHexString(uint8_t* array, size_t length) {
     if(array == NULL || length == 0) {
@@ -130,6 +131,10 @@ void uhf_free(UHFApp* uhf_app) {
     view_dispatcher_remove_view(uhf_app->view_dispatcher, UHFViewWidget);
     widget_free(uhf_app->widget);
 
+    // Variable Item List
+    view_dispatcher_remove_view(uhf_app->view_dispatcher, UHFViewVariableItemList);
+    variable_item_list_free(uhf_app->variable_item_list);
+
     // Tag
     uhf_tag_wrapper_free(uhf_app->worker->uhf_tag_wrapper);
 
@@ -150,9 +155,6 @@ void uhf_free(UHFApp* uhf_app) {
     furi_record_close(RECORD_GUI);
     uhf_app->gui = NULL;
 
-    // Variable Item List
-    variable_item_list_free(uhf_app->variable_item_list);
-
     // Notifications
     furi_record_close(RECORD_NOTIFICATION);
     uhf_app->notifications = NULL;
@@ -194,15 +196,25 @@ void uhf_show_loading_popup(void* ctx, bool show) {
 
 int32_t uhf_app_main(void* ctx) {
     UNUSED(ctx);
+    Expansion* expansion = furi_record_open(RECORD_EXPANSION);
+    expansion_disable(expansion);
+    bool is_5v_enabled_by_app = false;
+    // enable 5v pin if not enabled
+    if(!furi_hal_power_is_otg_enabled()) {
+        furi_hal_power_enable_otg();
+        is_5v_enabled_by_app = true;
+    }
     UHFApp* uhf_app = uhf_alloc();
-    // enable 5v pin
-    furi_hal_power_enable_otg();
     // enter app
     scene_manager_next_scene(uhf_app->scene_manager, UHFSceneModuleInfo);
     view_dispatcher_run(uhf_app->view_dispatcher);
-    // disable 5v pin
-    furi_hal_power_disable_otg();
+    // disable 5v pin if enabled by app
+    if(is_5v_enabled_by_app) {
+        furi_hal_power_disable_otg();
+    }
     // exit app
     uhf_free(uhf_app);
+    expansion_enable(expansion);
+    furi_record_close(RECORD_EXPANSION);
     return 0;
 }

+ 19 - 21
uhf_buffer.c

@@ -11,40 +11,39 @@ Buffer* uhf_buffer_alloc(size_t initial_capacity) {
     }
     buf->size = 0;
     buf->capacity = initial_capacity;
+    buf->head = 0;
+    buf->tail = 0;
     return buf;
 }
 
 bool uhf_buffer_append_single(Buffer* buf, uint8_t data) {
     if(buf->closed) return false;
-    if(buf->size + 1 > buf->capacity) {
-        size_t new_capacity = buf->capacity * 2;
-        uint8_t* new_data = (uint8_t*)realloc(buf->data, sizeof(uint8_t) * new_capacity);
-        if(!new_data) return false;
-        buf->data = new_data;
-        buf->capacity = new_capacity;
+    buf->data[buf->tail] = data;
+    buf->tail = (buf->tail + 1) % buf->capacity;
+    if(buf->size < buf->capacity) {
+        buf->size++;
+    } else {
+        buf->head = (buf->head + 1) % buf->capacity;
     }
-    buf->data[buf->size++] = data;
     return true;
 }
 
 bool uhf_buffer_append(Buffer* buf, uint8_t* data, size_t data_size) {
     if(buf->closed) return false;
-    if(buf->size + data_size > buf->capacity) {
-        size_t new_capacity = buf->capacity * 2;
-        uint8_t* new_data = (uint8_t*)realloc(buf->data, new_capacity);
-        if(!new_data) return false;
-
-        buf->data = new_data;
-        buf->capacity = new_capacity;
+    for(size_t i = 0; i < data_size; i++) {
+        buf->data[buf->tail] = data[i];
+        buf->tail = (buf->tail + 1) % buf->capacity;
+        if(buf->size < buf->capacity) {
+            buf->size++;
+        } else {
+            buf->head = (buf->head + 1) % buf->capacity;
+        }
     }
-
-    memcpy((void*)&buf->data[buf->size], data, data_size);
-    buf->size += data_size;
     return true;
 }
 
 uint8_t* uhf_buffer_get_data(Buffer* buf) {
-    return buf->data;
+    return &buf->data[buf->head];
 }
 
 size_t uhf_buffer_get_size(Buffer* buf) {
@@ -60,9 +59,8 @@ void uhf_buffer_close(Buffer* buf) {
 }
 
 void uhf_buffer_reset(Buffer* buf) {
-    for(size_t i = 0; i < MAX_BUFFER_SIZE; i++) {
-        buf->data[i] = 0;
-    }
+    buf->head = 0;
+    buf->tail = 0;
     buf->size = 0;
     buf->closed = false;
 }

+ 3 - 1
uhf_buffer.h

@@ -5,10 +5,12 @@
 
 #define MAX_BUFFER_SIZE 200
 
-typedef struct Buffer {
+typedef struct {
     uint8_t* data;
     size_t size;
     size_t capacity;
+    size_t head;
+    size_t tail;
     bool closed;
 } Buffer;
 

+ 15 - 1
uhf_module.c

@@ -12,7 +12,8 @@ static M100ResponseType setup_and_send_rx(M100Module* module, uint8_t* cmd, size
     // send cmd
     uhf_uart_send_wait(uart, cmd, cmd_length);
     // wait for response by polling
-    while(!uhf_is_buffer_closed(buffer) && !uhf_uart_tick(uart)) {}
+    while(!uhf_is_buffer_closed(buffer) && !uhf_uart_tick(uart)) {
+    }
     // reset tick
     uhf_uart_tick_reset(uart);
     // Validation Checks
@@ -45,6 +46,7 @@ M100Module* m100_module_alloc() {
     module->region = DEFAULT_WORKING_REGION;
     module->info = m100_module_info_alloc();
     module->uart = uhf_uart_alloc();
+    module->write_mask = WRITE_EPC; // default to write epc only
     return module;
 }
 
@@ -182,6 +184,18 @@ M100ResponseType m100_set_select(M100Module* module, UHFTag* uhf_tag) {
     return M100SuccessResponse;
 }
 
+void m100_enable_write_mask(M100Module* module, WriteMask mask) {
+    module->write_mask |= mask;
+}
+
+void m100_disable_write_mask(M100Module* module, WriteMask mask) {
+    module->write_mask &= ~mask;
+}
+
+bool m100_is_write_mask_enabled(M100Module* module, WriteMask mask) {
+    return (module->write_mask & mask) == mask;
+}
+
 UHFTag* m100_get_select_param(M100Module* module) {
     uhf_buffer_reset(module->uart->buffer);
     // furi_hal_uart_set_irq_cb(FuriHalUartIdLPUART1, rx_callback, module->uart->buffer);

+ 11 - 0
uhf_module.h

@@ -30,12 +30,20 @@ typedef enum {
     M100ChecksumFail
 } M100ResponseType;
 
+typedef enum {
+    WRITE_EPC = 1 << 0,
+    WRITE_TID = 1 << 1,
+    WRITE_USER = 1 << 2,
+    WRITE_RFU = 1 << 3
+} WriteMask;
+
 typedef struct {
     M100ModuleInfo* info;
     WorkingRegion region;
     uint16_t region_frequency;
     uint16_t transmitting_power;
     uint16_t max_transmitting_power;
+    uint16_t write_mask;
     bool freq_hopping;
     UHFUart* uart;
 } M100Module;
@@ -79,3 +87,6 @@ M100ResponseType m100_write_label_data_storage(
     uint32_t access_pwd);
 
 uint32_t m100_get_baudrate(M100Module* module);
+void m100_enable_write_mask(M100Module* module, WriteMask mask);
+void m100_disable_write_mask(M100Module* module, WriteMask mask);
+bool m100_is_write_mask_enabled(M100Module* module, WriteMask mask);

+ 1 - 1
uhf_tag.h

@@ -4,7 +4,7 @@
 #include <stdbool.h>
 #include <stddef.h>
 
-#define MAX_BANK_SIZE 256
+#define MAX_BANK_SIZE 200
 // storage enum
 typedef enum { ReservedBank, EPCBank, TIDBank, UserBank } BankType;
 

+ 54 - 0
uhf_tag_i.h

@@ -0,0 +1,54 @@
+#pragma once
+
+#include <stdint.h>
+#include <stddef.h>
+
+typedef enum {
+    MANUFACTURER_UNKNOWN = 0,
+    MANUFACTURER_ALIEN,
+    MANUFACTURER_IMPINJ,
+    MANUFACTURER_NXP,
+} Manufacturer;
+
+typedef enum {
+    TAG_TYPE_UNKNOWN = 0,
+    TAG_TYPE_EPC_CLASS1_GEN2,
+    TAG_TYPE_ISO18000_6C,
+} TagType;
+
+typedef enum {
+    TAG_PROTOCOL_UNKNOWN = 0,
+    TAG_PROTOCOL_GEN2,
+    TAG_PROTOCOL_ISO18000_6C,
+} TagProtocol;
+
+typedef enum {
+    TAG_MEMORY_UNKNOWN = 0,
+    TAG_MEMORY_EPC,
+    TAG_MEMORY_TID,
+    TAG_MEMORY_USER,
+} TagMemory;
+
+typedef enum {
+    TAG_LOCK_UNKNOWN = 0,
+    TAG_LOCK_UNLOCKED,
+    TAG_LOCK_LOCKED,
+} TagLock;
+
+typedef enum {
+    TAG_KILL_UNKNOWN = 0,
+    TAG_KILL_UNLOCKED,
+    TAG_KILL_LOCKED,
+} TagKill;
+
+typedef enum {
+    TAG_PASSWORD_UNKNOWN = 0,
+    TAG_PASSWORD_UNLOCKED,
+    TAG_PASSWORD_LOCKED,
+} TagPassword;
+
+typedef enum {
+    TAG_EAS_UNKNOWN = 0,
+    TAG_EAS_DISABLED,
+    TAG_EAS_ENABLED,
+} TagEAS;

+ 28 - 23
uhf_uart.c

@@ -30,21 +30,25 @@
 //     return 0;
 // }
 
-void uhf_uart_default_rx_callback(FuriHalSerialHandle *handle, FuriHalSerialRxEvent event, void* ctx) {
+void uhf_uart_default_rx_callback(
+    FuriHalSerialHandle* handle,
+    FuriHalSerialRxEvent event,
+    void* ctx) {
     UHFUart* uart = (UHFUart*)ctx;
     // FURI_LOG_E("UHF_UART", "UHF UART RX CALLBACK");
-    if((event & FuriHalSerialRxEventData) == FuriHalSerialRxEventData){
+    if((event & FuriHalSerialRxEventData) == FuriHalSerialRxEventData) {
         uint8_t data = furi_hal_serial_async_rx(handle);
         // if(data == UHF_UART_FRAME_START){
         //     uhf_buffer_reset(uart->buffer);
         // }
-        if(uhf_is_buffer_closed(uart->buffer)){
+        if(uhf_is_buffer_closed(uart->buffer)) {
             return;
         }
-        if(data == UHF_UART_FRAME_END){
+        if(data == UHF_UART_FRAME_END) {
             uhf_buffer_append_single(uart->buffer, data);
             uhf_buffer_close(uart->buffer);
-            FURI_LOG_E("UHF_UART", "UHF Total length read = %u", uhf_buffer_get_size(uart->buffer));
+            FURI_LOG_E(
+                "UHF_UART", "UHF Total length read = %u", uhf_buffer_get_size(uart->buffer));
         }
         uhf_buffer_append_single(uart->buffer, data);
         uhf_uart_tick_reset(uart);
@@ -53,30 +57,27 @@ void uhf_uart_default_rx_callback(FuriHalSerialHandle *handle, FuriHalSerialRxEv
     }
 }
 
-UHFUart* uhf_uart_alloc(){
-    UHFUart *uart = (UHFUart*)malloc(sizeof(UHFUart));
+UHFUart* uhf_uart_alloc() {
+    UHFUart* uart = (UHFUart*)malloc(sizeof(UHFUart));
     uart->bus = FuriHalBusUSART1;
     uart->handle = furi_hal_serial_control_acquire(FuriHalSerialIdUsart);
-    // uart->rx_buff_stream = furi_stream_buffer_alloc(UHF_UART_RX_BUFFER_SIZE, 1);
+    furi_check(uart->handle, "UHF UART HANDLE IS NULL");
     uart->init_by_app = !furi_hal_bus_is_enabled(uart->bus);
     uart->tick = UHF_UART_WAIT_TICK;
     uart->baudrate = UHF_UART_DEFAULT_BAUDRATE;
     // expansion_disable();
-    if(uart->init_by_app){
+    if(uart->init_by_app) {
         FURI_LOG_E("UHF_UART", "UHF UART INIT BY APP");
         furi_hal_serial_init(uart->handle, uart->baudrate);
-    }
-    else{
+    } else {
         FURI_LOG_E("UHF_UART", "UHF UART INIT BY HAL");
     }
     uart->buffer = uhf_buffer_alloc(UHF_UART_RX_BUFFER_SIZE);
-    // uart->thread = furi_thread_alloc_ex("UHFUartWorker", UHF_UART_WORKER_STACK_SIZE, uhf_uart_worker_callback, uart);
-    // furi_thread_start(uart->thread);
     furi_hal_serial_async_rx_start(uart->handle, uhf_uart_default_rx_callback, uart, false);
     return uart;
-}   
+}
 
-void uhf_uart_free(UHFUart* uart){
+void uhf_uart_free(UHFUart* uart) {
     furi_assert(uart);
     // furi_assert(uart->thread);
     // furi_thread_flags_set(furi_thread_get_id(uart->thread), UHFUartWorkerExitingFlag);
@@ -84,39 +85,43 @@ void uhf_uart_free(UHFUart* uart){
     // furi_thread_free(uart->thread);
     // furi_stream_buffer_free(uart->rx_buff_stream);
     uhf_buffer_free(uart->buffer);
-    if(uart->init_by_app){
+    if(uart->init_by_app) {
         furi_hal_serial_deinit(uart->handle);
     }
     furi_hal_serial_control_release(uart->handle);
     free(uart);
 }
 
-void uhf_uart_set_receive_byte_callback(UHFUart* uart, FuriHalSerialAsyncRxCallback callback, void *ctx, bool report_errors){
+void uhf_uart_set_receive_byte_callback(
+    UHFUart* uart,
+    FuriHalSerialAsyncRxCallback callback,
+    void* ctx,
+    bool report_errors) {
     furi_hal_serial_async_rx_start(uart->handle, callback, ctx, report_errors);
 }
 
-void uhf_uart_send(UHFUart* uart, uint8_t* data, size_t size){
+void uhf_uart_send(UHFUart* uart, uint8_t* data, size_t size) {
     furi_hal_serial_tx(uart->handle, data, size);
 }
 
-void uhf_uart_send_wait(UHFUart* uart, uint8_t* data, size_t size){
+void uhf_uart_send_wait(UHFUart* uart, uint8_t* data, size_t size) {
     uhf_uart_send(uart, data, size);
     furi_hal_serial_tx_wait_complete(uart->handle);
     // furi_thread_flags_set(furi_thread_get_id(uart->thread), UHFUartWorkerWaitingDataFlag);
 }
 
-void uhf_uart_set_baudrate(UHFUart* uart, uint32_t baudrate){
+void uhf_uart_set_baudrate(UHFUart* uart, uint32_t baudrate) {
     furi_hal_serial_set_br(uart->handle, baudrate);
     uart->baudrate = baudrate;
 }
 
-bool uhf_uart_tick(UHFUart* uart){
-    if(uart->tick > 0){
+bool uhf_uart_tick(UHFUart* uart) {
+    if(uart->tick > 0) {
         uart->tick--;
     }
     return uart->tick == 0;
 }
 
-void uhf_uart_tick_reset(UHFUart* uart){
+void uhf_uart_tick_reset(UHFUart* uart) {
     uart->tick = UHF_UART_WAIT_TICK;
 }

+ 18 - 10
uhf_worker.c

@@ -15,13 +15,13 @@ UHFTag* send_polling_command(UHFWorker* uhf_worker) {
     // read epc bank
     UHFTag* uhf_tag = uhf_tag_alloc();
     M100ResponseType status;
-    do{
+    do {
         if(uhf_worker->state == UHFWorkerStateStop) {
             uhf_tag_free(uhf_tag);
             return NULL;
         }
         status = m100_single_poll(uhf_worker->module, uhf_tag);
-    }while(status != M100SuccessResponse);
+    } while(status != M100SuccessResponse);
     return uhf_tag;
 }
 
@@ -48,7 +48,8 @@ UHFWorkerEvent read_single_card(UHFWorker* uhf_worker) {
     if(uhf_tag == NULL) return UHFWorkerEventAborted;
     uhf_tag_wrapper_set_tag(uhf_worker->uhf_tag_wrapper, uhf_tag);
     // set select
-    while(m100_set_select(uhf_worker->module, uhf_tag) != M100SuccessResponse){}
+    while(m100_set_select(uhf_worker->module, uhf_tag) != M100SuccessResponse) {
+    }
     // read tid
     UHFWorkerEvent event;
     event = read_bank_till_max_length(uhf_worker, uhf_tag, TIDBank);
@@ -64,23 +65,29 @@ UHFWorkerEvent write_single_card(UHFWorker* uhf_worker) {
     if(uhf_tag_des == NULL) return UHFWorkerEventAborted;
     UHFTag* uhf_tag_from = uhf_worker->uhf_tag_wrapper->uhf_tag;
     M100ResponseType rp_type;
-    do{
+    do {
         rp_type = m100_set_select(uhf_worker->module, uhf_tag_des);
         if(uhf_worker->state == UHFWorkerStateStop) return UHFWorkerEventAborted;
         if(rp_type == M100SuccessResponse) break;
-    }while(true);
-    do {
+    } while(true);
+    while(m100_is_write_mask_enabled(uhf_worker->module, WRITE_USER)) {
         rp_type = m100_write_label_data_storage(
             uhf_worker->module, uhf_tag_from, uhf_tag_des, UserBank, 0, 0);
         if(uhf_worker->state == UHFWorkerStateStop) return UHFWorkerEventAborted;
         if(rp_type == M100SuccessResponse) break;
-    } while(true);
-    do {
+    }
+    while(m100_is_write_mask_enabled(uhf_worker->module, WRITE_TID)) {
+        rp_type = m100_write_label_data_storage(
+            uhf_worker->module, uhf_tag_from, uhf_tag_des, TIDBank, 0, 0);
+        if(uhf_worker->state == UHFWorkerStateStop) return UHFWorkerEventAborted;
+        if(rp_type == M100SuccessResponse) break;
+    }
+    while(m100_is_write_mask_enabled(uhf_worker->module, WRITE_EPC)) {
         rp_type = m100_write_label_data_storage(
             uhf_worker->module, uhf_tag_from, uhf_tag_des, EPCBank, 0, 0);
         if(uhf_worker->state == UHFWorkerStateStop) return UHFWorkerEventAborted;
         if(rp_type == M100SuccessResponse) break;
-    } while(true);
+    }
     return UHFWorkerEventSuccess;
 }
 
@@ -101,7 +108,8 @@ int32_t uhf_worker_task(void* ctx) {
 
 UHFWorker* uhf_worker_alloc() {
     UHFWorker* uhf_worker = (UHFWorker*)malloc(sizeof(UHFWorker));
-    uhf_worker->thread = furi_thread_alloc_ex("UHFWorker", UHF_WORKER_STACK_SIZE, uhf_worker_task, uhf_worker);
+    uhf_worker->thread =
+        furi_thread_alloc_ex("UHFWorker", UHF_WORKER_STACK_SIZE, uhf_worker_task, uhf_worker);
     uhf_worker->module = m100_module_alloc();
     uhf_worker->callback = NULL;
     uhf_worker->ctx = NULL;