Skip to content

Commit

Permalink
Make the CVS Spam app (#2352)
Browse files Browse the repository at this point in the history
  • Loading branch information
@RocketGod-git
RocketGod-git authored Nov 8, 2024
1 parent 09dff44 commit b8a6459
Show file tree
Hide file tree
Showing 7 changed files with 474 additions and 1 deletion.
313 changes: 313 additions & 0 deletions firmware/application/external/cvs_spam/cvs_spam.cpp
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,313 @@
// CVS Spam app by RocketGod (@rocketgod-git) https://betaskynet.com
// Original .cu8 files by @jimilinuxguy https://github.com/jimilinuxguy/customer-assistance-buttons-sdr
// If you can read this, you're a nerd. :P
// Come join us at https://discord.gg/thepiratesreborn

#include "cvs_spam.hpp"
#include "io_file.hpp"
#include "metadata_file.hpp"
#include "oversample.hpp"
#include "io_convert.hpp"

using namespace portapack;

namespace ui::external_app::cvs_spam {

void CVSSpamView::file_error(const std::filesystem::path& path, const std::string& error_details) {
nav_.display_modal("Error",
"File error:\n" + path.string() + "\n" + error_details);
}

void CVSSpamView::refresh_list() {
file_list.clear();
current_page = page;
uint32_t count = 0;

for (const auto& entry : std::filesystem::directory_iterator(cvsfiles_dir, u"*")) {
if (std::filesystem::is_regular_file(entry.status())) {
auto filename = entry.path().filename().string();
auto extension = entry.path().extension().string();
std::transform(extension.begin(), extension.end(), extension.begin(), ::tolower);

if (extension == ".c16" || extension == ".cu8") {
if (count >= (page - 1) * 50 && count < page * 50) {
file_list.push_back(entry.path());
if (file_list.size() == 50) {
page++;
break;
}
}
count++;
}
}
}

if (file_list.empty()) {
if (page == 1) {
menu_view.hidden(true);
text_empty.hidden(false);
} else {
page = 1;
refresh_list();
return;
}
} else {
menu_view.hidden(false);
text_empty.hidden(true);
menu_view.clear();
for (const auto& file : file_list) {
menu_view.add_item({file.filename().string(),
ui::Theme::getInstance()->fg_green->foreground,
nullptr,
[this](KeyEvent key) {
if (key == KeyEvent::Select) {
start_tx(menu_view.highlighted_index());
}
}});
}
page_info.set("Page " + std::to_string(current_page));
menu_view.set_highlighted(0);
}

if (file_list.size() < 50) {
page = 1;
}
}

void CVSSpamView::start_tx(const uint32_t id) {
if (is_active()) {
stop_tx();
return;
}

const uint32_t sample_rate = 500000;

current_file = cvsfiles_dir / file_list[id].filename();

File capture_file;
auto open_error = capture_file.open(current_file);
if (open_error) {
file_error(current_file,
"Cannot open file.\n"
"Initial file check failed.\n"
"Path: " +
cvsfiles_dir.string() +
"\n"
"Error: " +
std::to_string(static_cast<uint32_t>(open_error)));
return;
}

auto metadata_path = get_metadata_path(current_file);
auto metadata = read_metadata_file(metadata_path);
if (!metadata) {
metadata = capture_metadata{transmitter_model.target_frequency(), sample_rate};
}

auto file_size = capture_file.size();
capture_file.close();

replay_thread.reset();
transmitter_model.disable();
ready_signal = false;

baseband::set_sample_rate(metadata->sample_rate, get_oversample_rate(metadata->sample_rate));

auto reader = std::make_unique<FileConvertReader>();
if (auto error = reader->open(current_file)) {
file_error(current_file,
"Cannot read C16 data.\n"
"Check file format/perms.\n"
"Rate: " +
to_string_dec_uint(metadata->sample_rate) +
"\n"
"Size: " +
to_string_dec_uint(file_size) +
"\n"
"Error: " +
std::to_string(static_cast<uint32_t>(error)));
return;
}

progressbar.set_value(0);

transmitter_model.set_sampling_rate(get_actual_sample_rate(metadata->sample_rate));
transmitter_model.set_baseband_bandwidth(metadata->sample_rate <= 500000 ? 1750000 : 2500000);
transmitter_model.set_target_frequency(metadata->center_frequency);
transmitter_model.enable();

chThdSleepMilliseconds(100);

replay_thread = std::make_unique<ReplayThread>(
std::move(reader),
read_size,
buffer_count,
&ready_signal,
[](uint32_t return_code) {
ReplayThreadDoneMessage message{return_code};
EventDispatcher::send_message(message);
});
}

void CVSSpamView::start_chaos_tx() {
if (is_active()) {
stop_tx();
return;
}

const std::filesystem::path chaos_file_path = cvsfiles_dir / "chaos.c16";
const uint32_t sample_rate = 500000;

File capture_file;
auto open_error = capture_file.open(chaos_file_path);
if (open_error) {
file_error(chaos_file_path,
"Cannot open CHAOS.C16.\n"
"Initial file check failed.\n"
"Path: " +
cvsfiles_dir.string() +
"\n"
"Error: " +
std::to_string(static_cast<uint32_t>(open_error)));
return;
}

auto metadata_path = get_metadata_path(chaos_file_path);
auto metadata = read_metadata_file(metadata_path);
if (!metadata) {
metadata = capture_metadata{transmitter_model.target_frequency(), sample_rate};
}

auto file_size = capture_file.size();
capture_file.close();

replay_thread.reset();
transmitter_model.disable();
ready_signal = false;

baseband::set_sample_rate(metadata->sample_rate, get_oversample_rate(metadata->sample_rate));

auto reader = std::make_unique<FileConvertReader>();
if (auto error = reader->open(chaos_file_path)) {
file_error(chaos_file_path,
"Cannot read CHAOS.C16.\n"
"Check file format/perms.\n"
"Rate: " +
to_string_dec_uint(metadata->sample_rate) +
"\n"
"Size: " +
to_string_dec_uint(file_size) +
"\n"
"Error: " +
std::to_string(static_cast<uint32_t>(error)));
return;
}

progressbar.set_value(0);

transmitter_model.set_sampling_rate(get_actual_sample_rate(metadata->sample_rate));
transmitter_model.set_baseband_bandwidth(metadata->sample_rate <= 500000 ? 1750000 : 2500000);
transmitter_model.set_target_frequency(metadata->center_frequency);
transmitter_model.enable();

chThdSleepMilliseconds(100);

replay_thread = std::make_unique<ReplayThread>(
std::move(reader),
read_size,
buffer_count,
&ready_signal,
[](uint32_t return_code) {
ReplayThreadDoneMessage message{return_code};
EventDispatcher::send_message(message);
});
}

void CVSSpamView::on_tx_progress(const uint32_t progress) {
if (is_active()) {
progressbar.set_value(progress % 100);
progressbar.set_style(Theme::getInstance()->fg_red);
}
}

void CVSSpamView::focus() {
menu_view.focus();
}

bool CVSSpamView::is_active() const {
return (bool)replay_thread;
}

void CVSSpamView::stop_tx() {
replay_thread.reset();
transmitter_model.disable();
audio::output::stop();
ready_signal = false;
thread_sync_complete = false;
progressbar.set_value(0);
chThdSleepMilliseconds(50);
}

CVSSpamView::CVSSpamView(NavigationView& nav)
: nav_{nav},
current_file{} {
baseband::run_image(portapack::spi_flash::image_tag_replay);

add_children({&menu_view,
&text_empty,
&button_prev_page,
&button_next_page,
&page_info,
&button_send,
&button_chaos,
&button_stop,
&progressbar});

button_send.set_style(Theme::getInstance()->fg_magenta);
button_chaos.set_style(Theme::getInstance()->fg_yellow);
button_stop.set_style(Theme::getInstance()->fg_red);

transmitter_model.set_sampling_rate(1536000);
transmitter_model.set_baseband_bandwidth(1750000);
transmitter_model.set_rf_amp(true);
transmitter_model.set_tx_gain(47);
transmitter_model.set_channel_bandwidth(1750000);

refresh_list();

button_prev_page.on_select = [this](Button&) {
if (is_active()) return;
if (current_page == 1) return;
if (current_page == 2) page = 1;
page = current_page - 1;
refresh_list();
};

button_next_page.on_select = [this](Button&) {
if (is_active()) return;
refresh_list();
};

button_send.on_select = [this](Button&) {
if (!file_list.empty()) {
start_tx(menu_view.highlighted_index());
}
};

button_chaos.on_select = [this](Button&) {
start_chaos_tx();
};

button_stop.on_select = [this](Button&) {
if (is_active()) {
stop_tx();
}
};
}

CVSSpamView::~CVSSpamView() {
stop_tx();
baseband::shutdown();
}

} // namespace ui::external_app::cvs_spam
Loading

0 comments on commit b8a6459

Please sign in to comment.