unleashed-firmware/applications/plugins/protoview/signal_file.c

/* Copyright (C) 2023 Salvatore Sanfilippo -- All Rights Reserved
 * Copyright (C) 2023 Maciej Wojtasik -- All Rights Reserved
 * See the LICENSE file for information about the license. */

#include "app.h"
#include <stream/stream.h>
#include <flipper_format/flipper_format_i.h>

/* ========================= Signal file operations ========================= */

/* This function saves the current logical signal on disk. What is saved here
 * is not the signal as level and duration as we received it from CC1101,
 * but it's logical representation stored in the app->msg_info bitmap, where
 * each 1 or 0 means a puls or gap for the specified short pulse duration time
 * (te). */
bool save_signal(ProtoViewApp* app, const char* filename) {
    /* We have a message at all? */
    if(app->msg_info == NULL || app->msg_info->pulses_count == 0) return false;

    Storage* storage = furi_record_open(RECORD_STORAGE);
    FlipperFormat* file = flipper_format_file_alloc(storage);
    Stream* stream = flipper_format_get_raw_stream(file);
    FuriString* file_content = NULL;
    bool success = true;

    if(flipper_format_file_open_always(file, filename)) {
        /* Write the file header. */
        FuriString* file_content = furi_string_alloc();
        const char* preset_id = ProtoViewModulations[app->modulation].id;

        furi_string_printf(
            file_content,
            "Filetype: Flipper SubGhz RAW File\n"
            "Version: 1\n"
            "Frequency: %ld\n"
            "Preset: %s\n",
            app->frequency,
            preset_id ? preset_id : "FuriHalSubGhzPresetCustom");

        /* For custom modulations, we need to emit a set of registers. */
        if(preset_id == NULL) {
            FuriString* custom = furi_string_alloc();
            uint8_t* regs = ProtoViewModulations[app->modulation].custom;
            furi_string_printf(
                custom,
                "Custom_preset_module: CC1101\n"
                "Custom_preset_data: ");
            for(int j = 0; regs[j]; j += 2) {
                furi_string_cat_printf(custom, "%02X %02X ", (int)regs[j], (int)regs[j + 1]);
            }
            size_t len = furi_string_size(file_content);
            furi_string_set_char(custom, len - 1, '\n');
            furi_string_cat(file_content, custom);
            furi_string_free(custom);
        }

        /* We always save raw files. */
        furi_string_cat_printf(
            file_content,
            "Protocol: RAW\n"
            "RAW_Data: -10000\n"); // Start with 10 ms of gap

        /* Write header. */
        size_t len = furi_string_size(file_content);
        if(stream_write(stream, (uint8_t*)furi_string_get_cstr(file_content), len) != len) {
            FURI_LOG_W(TAG, "Short write to file");
            success = false;
            goto write_err;
        }
        furi_string_reset(file_content);

        /* Write raw data sections. The Flipper subghz parser can't handle
         * too much data on a single line, so we generate a new one
         * every few samples. */
        uint32_t this_line_samples = 0;
        uint32_t max_line_samples = 100;
        uint32_t idx = 0; // Iindex in the signal bitmap.
        ProtoViewMsgInfo* i = app->msg_info;
        while(idx < i->pulses_count) {
            bool level = bitmap_get(i->bits, i->bits_bytes, idx);
            uint32_t te_times = 1;
            idx++;
            /* Count the duration of the current pulse/gap. */
            while(idx < i->pulses_count && bitmap_get(i->bits, i->bits_bytes, idx) == level) {
                te_times++;
                idx++;
            }
            // Invariant: after the loop 'idx' is at the start of the
            // next gap or pulse.

            int32_t dur = (int32_t)i->short_pulse_dur * te_times;
            if(level == 0) dur = -dur; /* Negative is gap in raw files. */

            /* Emit the sample. If this is the first sample of the line,
             * also emit the RAW_Data: field. */
            if(this_line_samples == 0) furi_string_cat_printf(file_content, "RAW_Data: ");
            furi_string_cat_printf(file_content, "%d ", (int)dur);
            this_line_samples++;

            /* Store the current set of samples on disk, when we reach a
             * given number or the end of the signal. */
            bool end_reached = (idx == i->pulses_count);
            if(this_line_samples == max_line_samples || end_reached) {
                /* If that's the end, terminate the signal with a long
                 * gap. */
                if(end_reached) furi_string_cat_printf(file_content, "-10000 ");

                /* We always have a trailing space in the last sample. Make it
                 * a newline. */
                size_t len = furi_string_size(file_content);
                furi_string_set_char(file_content, len - 1, '\n');

                if(stream_write(stream, (uint8_t*)furi_string_get_cstr(file_content), len) !=
                   len) {
                    FURI_LOG_W(TAG, "Short write to file");
                    success = false;
                    goto write_err;
                }

                /* Prepare for next line. */
                furi_string_reset(file_content);
                this_line_samples = 0;
            }
        }
    } else {
        success = false;
        FURI_LOG_W(TAG, "Unable to open file");
    }

write_err:
    furi_record_close(RECORD_STORAGE);
    flipper_format_free(file);
    if(file_content != NULL) furi_string_free(file_content);
    return success;
}