update_task_worker

#include "update_task.h" #include "update_task_i.h" #include <furi.h> #include <furi_hal.h> #include <storage/storage.h> #include <desktop/helpers/slideshow_filename.h> #include <toolbox/path.h> #include <update_util/dfu_file.h> #include <update_util/lfs_backup.h> #include <update_util/update_operation.h> #include <update_util/resources/manifest.h> #include <toolbox/tar/tar_archive.h> #include <toolbox/crc32_calc.h> #define TAG "UpdWorkerBackup" static bool update_task_pre_update(UpdateTask* update_task) { bool success = false; FuriString* backup_file_path; backup_file_path = furi_string_alloc(); path_concat( furi_string_get_cstr(update_task->update_path), LFS_BACKUP_DEFAULT_FILENAME, backup_file_path); update_task_set_progress(update_task, UpdateTaskStageLfsBackup, 0); /* to avoid bootloops */ furi_hal_rtc_set_boot_mode(FuriHalRtcBootModeNormal); if((success = lfs_backup_create(update_task->storage, furi_string_get_cstr(backup_file_path)))) { furi_hal_rtc_set_boot_mode(FuriHalRtcBootModeUpdate); } furi_string_free(backup_file_path); return success; } typedef struct { UpdateTask* update_task; int32_t total_files, processed_files; } TarUnpackProgress; static bool update_task_resource_unpack_cb(const char* name, bool is_directory, void* context) { UNUSED(name); UNUSED(is_directory); TarUnpackProgress* unpack_progress = context; unpack_progress->processed_files++; update_task_set_progress( unpack_progress->update_task, UpdateTaskStageProgress, (unpack_progress->processed_files * 100) / (unpack_progress->total_files)); return true; } static void update_task_cleanup_resources(UpdateTask* update_task) { ResourceManifestReader* manifest_reader = resource_manifest_reader_alloc(update_task->storage); do { FURI_LOG_D(TAG, "Cleaning up old manifest"); if(!resource_manifest_reader_open(manifest_reader, EXT_PATH("Manifest"))) { FURI_LOG_W(TAG, "No existing manifest"); break; } ResourceManifestEntry* entry_ptr = NULL; /* Iterate over manifest and calculate entries count */ uint32_t n_file_entries = 1, n_dir_entries = 1; while((entry_ptr = resource_manifest_reader_next(manifest_reader))) { if(entry_ptr->type == ResourceManifestEntryTypeFile) { n_file_entries++; } else if(entry_ptr->type == ResourceManifestEntryTypeDirectory) { n_dir_entries++; } } FURI_LOG_I( TAG, "Found %li files and %li directories in old manifest", n_file_entries, n_dir_entries); resource_manifest_rewind(manifest_reader); uint32_t n_processed_file_entries = 0, n_processed_dir_entries = 0; update_task_set_progress(update_task, UpdateTaskStageResourcesFileCleanup, 0); while((entry_ptr = resource_manifest_reader_next(manifest_reader))) { if(entry_ptr->type == ResourceManifestEntryTypeFile) { update_task_set_progress( update_task, UpdateTaskStageProgress, (n_processed_file_entries++ * 100) / n_file_entries); FuriString* file_path = furi_string_alloc(); path_concat( STORAGE_EXT_PATH_PREFIX, furi_string_get_cstr(entry_ptr->name), file_path); FURI_LOG_D(TAG, "Removing %s", furi_string_get_cstr(file_path)); FS_Error result = storage_common_remove(update_task->storage, furi_string_get_cstr(file_path)); if(result != FSE_OK && result != FSE_EXIST) { FURI_LOG_E( TAG, "%s remove failed, cause %s", furi_string_get_cstr(file_path), storage_error_get_desc(result)); } furi_string_free(file_path); } else if(entry_ptr->type == ResourceManifestEntryTypeDirectory) { n_dir_entries++; } } update_task_set_progress(update_task, UpdateTaskStageResourcesDirCleanup, 0); while((entry_ptr = resource_manifest_reader_previous(manifest_reader))) { if(entry_ptr->type == ResourceManifestEntryTypeDirectory) { update_task_set_progress( update_task, UpdateTaskStageProgress, (n_processed_dir_entries++ * 100) / n_dir_entries); FuriString* folder_path = furi_string_alloc(); do { path_concat( STORAGE_EXT_PATH_PREFIX, furi_string_get_cstr(entry_ptr->name), folder_path); FURI_LOG_D(TAG, "Removing folder %s", furi_string_get_cstr(folder_path)); FS_Error result = storage_common_remove( update_task->storage, furi_string_get_cstr(folder_path)); if(result != FSE_OK && result != FSE_EXIST) { FURI_LOG_E( TAG, "%s remove failed, cause %s", furi_string_get_cstr(folder_path), storage_error_get_desc(result)); } } while(false); furi_string_free(folder_path); } } } while(false); resource_manifest_reader_free(manifest_reader); } static bool update_task_post_update(UpdateTask* update_task) { bool success = false; FuriString* file_path; file_path = furi_string_alloc(); TarArchive* archive = tar_archive_alloc(update_task->storage); do { path_concat( furi_string_get_cstr(update_task->update_path), LFS_BACKUP_DEFAULT_FILENAME, file_path); update_task_set_progress(update_task, UpdateTaskStageLfsRestore, 0); CHECK_RESULT(lfs_backup_unpack(update_task->storage, furi_string_get_cstr(file_path))); if(update_task->state.groups & UpdateTaskStageGroupResources) { TarUnpackProgress progress = { .update_task = update_task, .total_files = 1, .processed_files = 0, }; path_concat( furi_string_get_cstr(update_task->update_path), furi_string_get_cstr(update_task->manifest->resource_bundle), file_path); tar_archive_set_file_callback(archive, update_task_resource_unpack_cb, &progress); CHECK_RESULT( tar_archive_open(archive, furi_string_get_cstr(file_path), TAR_OPEN_MODE_READ_HS)); update_task_cleanup_resources(update_task); update_task_set_progress(update_task, UpdateTaskStageResourcesFileUnpack, 0); FURI_LOG_I(TAG, "Counting resources to unpack"); progress.total_files = tar_archive_get_entries_count(archive); FURI_LOG_I(TAG, "Total files to unpack: %li", progress.total_files); CHECK_RESULT(tar_archive_unpack_to(archive, STORAGE_EXT_PATH_PREFIX, NULL)); } if(update_task->state.groups & UpdateTaskStageGroupSplashscreen) { update_task_set_progress(update_task, UpdateTaskStageSplashscreenInstall, 0); FuriString* tmp_path; tmp_path = furi_string_alloc_set(update_task->update_path); path_append(tmp_path, furi_string_get_cstr(update_task->manifest->splash_file)); if(storage_common_copy( update_task->storage, furi_string_get_cstr(tmp_path), INT_PATH(SLIDESHOW_FILE_NAME)) != FSE_OK) { // actually, not critical } furi_string_free(tmp_path); update_task_set_progress(update_task, UpdateTaskStageSplashscreenInstall, 100); } success = true; } while(false); tar_archive_free(archive); furi_string_free(file_path); return success; } int32_t update_task_worker_backup_restore(void* context) { furi_assert(context); UpdateTask* update_task = context; FuriHalRtcBootMode boot_mode = update_task->boot_mode; if((boot_mode != FuriHalRtcBootModePreUpdate) && (boot_mode != FuriHalRtcBootModePostUpdate)) { /* no idea how we got here. Do nothing */ return UPDATE_TASK_NOERR; } bool success = false; do { if(!update_task_parse_manifest(update_task)) { break; } if(boot_mode == FuriHalRtcBootModePreUpdate) { success = update_task_pre_update(update_task); } else if(boot_mode == FuriHalRtcBootModePostUpdate) { //-V547 success = update_task_post_update(update_task); if(success) { update_operation_disarm(); } } } while(false); if(!success) { update_task_set_progress(update_task, UpdateTaskStageError, 0); return UPDATE_TASK_FAILED; } update_task_set_progress(update_task, UpdateTaskStageCompleted, 100); return UPDATE_TASK_NOERR; }

↑ V576 Incorrect format. Consider checking the fourth actual argument of the 'furi_log_print_format' function. The SIGNED argument of memsize type is expected.

↑ V576 Incorrect format. Consider checking the fifth actual argument of the 'furi_log_print_format' function. The SIGNED argument of memsize type is expected.