Compare commits
2 commits
480311b03e
...
f9b5ce4577
Author | SHA1 | Date | |
---|---|---|---|
f9b5ce4577 | |||
f5dbdf96d5 |
18 changed files with 483 additions and 75 deletions
|
@ -119,6 +119,7 @@ if(DEFINED ANDROID_NDK)
|
|||
set(USE_SPEEX OFF CACHE BOOL "" FORCE)
|
||||
set(USE_G719 OFF CACHE BOOL "" FORCE)
|
||||
set(USE_VORBIS OFF CACHE BOOL "" FORCE)
|
||||
set(BUILD_FMT ON CACHE BOOL "" FORCE)
|
||||
endif()
|
||||
if (BUILD_SDL)
|
||||
set(SDL_SHARED OFF CACHE BOOL "" FORCE)
|
||||
|
|
5
add-mime-types.sh
Executable file
5
add-mime-types.sh
Executable file
|
@ -0,0 +1,5 @@
|
|||
#!/bin/sh
|
||||
OLDDIR="$(pwd)"
|
||||
cd "$(dirname "$0")"
|
||||
xdg-mime install assets/zsm-mime.xml
|
||||
cd "$OLDDIR"
|
|
@ -7,7 +7,7 @@ GenericName=Looping audio player
|
|||
Exec=looper -n %f
|
||||
Icon=looper
|
||||
StartupWMClass=looper;com.complecwaft.Looper;com.complecwaft.Looper.GTK
|
||||
MimeType=audio/x-wav;audio/ogg;audio/x-vorbis+ogg;audio/x-opus+ogg;audio/mpeg;audio/flac;audio/xm;audio/x-mod;
|
||||
MimeType=audio/x-wav;audio/ogg;audio/x-vorbis+ogg;audio/x-opus+ogg;audio/mpeg;audio/flac;audio/xm;audio/x-mod;audio/x-zsound;
|
||||
Categories=Audio;AudioVideo;
|
||||
Terminal=false
|
||||
SingleMainWindow=true
|
||||
|
|
11
assets/zsm-mime.xml
Normal file
11
assets/zsm-mime.xml
Normal file
|
@ -0,0 +1,11 @@
|
|||
<?xml version="1.0"?>
|
||||
<mime-info xmlns='http://www.freedesktop.org/standards/shared-mime-info'>
|
||||
<mime-type type="audio/x-zsound">
|
||||
<comment>ZSound file for the Commander X16</comment>
|
||||
<glob pattern="*.zsm"/>
|
||||
<magic priority="50">
|
||||
<match type="string" value="zm" offset="0" />
|
||||
</magic>
|
||||
</mime-type>
|
||||
</mime-info>
|
||||
|
10
backends/playback/zsm/properties.inc
Normal file
10
backends/playback/zsm/properties.inc
Normal file
|
@ -0,0 +1,10 @@
|
|||
#define BOOL_PROPERTY(name, default_value) _PROPERTY(name, bool, default_value)
|
||||
#define DOUBLE_PROPERTY(name, default_value) _PROPERTY(name, double, default_value)
|
||||
BOOL_PROPERTY(pcm_enable, true)
|
||||
BOOL_PROPERTY(psg_enable, true)
|
||||
BOOL_PROPERTY(fm_enable, true)
|
||||
DOUBLE_PROPERTY(pcm_volume, 1.0)
|
||||
DOUBLE_PROPERTY(psg_volume, 1.0)
|
||||
DOUBLE_PROPERTY(fm_volume, 1.0)
|
||||
#undef BOOL_PROPERTY
|
||||
#undef DOUBLE_PROPERTY
|
|
@ -6,14 +6,37 @@ extern "C" {
|
|||
#include "x16emu/vera_psg.h"
|
||||
#include "x16emu/ymglue.h"
|
||||
}
|
||||
#include <ipc/common.pb.h>
|
||||
#include <exception>
|
||||
#include <filesystem>
|
||||
#include "file_backend.hpp"
|
||||
#include <stddef.h>
|
||||
#include <string.h>
|
||||
#include <file_backend.hpp>
|
||||
#include <util.hpp>
|
||||
#define HZ (AUDIO_SAMPLERATE)
|
||||
#define BUFFERS 32
|
||||
#define _PROPERTY(name, type, default_value) \
|
||||
type ZsmBackend::name() { \
|
||||
std::optional<google::protobuf::Any> value_maybe = get(#name); \
|
||||
if (value_maybe.has_value()) { \
|
||||
return resolve_value<type>(value_maybe.value()); \
|
||||
} \
|
||||
return default_value; \
|
||||
}
|
||||
|
||||
#include "properties.inc"
|
||||
#undef _PROPERTY
|
||||
std::vector<Property> ZsmBackend::get_property_list() {
|
||||
std::vector<Property> properties;
|
||||
properties.push_back(make_property(PropertyType::Boolean, "Enable PCM channel", "pcm_enable"));
|
||||
properties.push_back(make_property(PropertyType::Boolean, "Enable PSG channels", "psg_enable"));
|
||||
properties.push_back(make_property(PropertyType::Boolean, "Enable FM channels", "fm_enable"));
|
||||
properties.push_back(make_property(PropertyType::Double, "Volume of PCM channel", "pcm_volume", make_hint(0.0, 1.0)));
|
||||
properties.push_back(make_property(PropertyType::Double, "Volume of PSG channels", "psg_volume", make_hint(0.0, 1.0)));
|
||||
properties.push_back(make_property(PropertyType::Double, "Volume of FM channels", "fm_volume", make_hint(0.0, 1.0)));
|
||||
return properties;
|
||||
}
|
||||
void ZsmBackend::load(const char *filename) {
|
||||
memset(&spec, 0, sizeof(spec));
|
||||
spec.format = AUDIO_S16SYS;
|
||||
|
@ -115,6 +138,22 @@ void ZsmBackend::load(const char *filename) {
|
|||
loop_start = this->loop_pos;
|
||||
fm_stream = SDL_NewAudioStream(AUDIO_S16SYS, 2, YM_FREQ, AUDIO_S16SYS, 2, PSG_FREQ);
|
||||
DEBUG.writefln("fm_stream: %ld -> %ld", YM_FREQ, PSG_FREQ);
|
||||
#define _PROPERTY(name, type, default_value) \
|
||||
{ \
|
||||
std::string type_str = #type; \
|
||||
google::protobuf::Any value; \
|
||||
if (type_str == "bool") { \
|
||||
BooleanProperty value_b; \
|
||||
value_b.set_value(default_value); \
|
||||
value.PackFrom(value_b); \
|
||||
} else if (type_str == "double") { \
|
||||
DoubleProperty value_d; \
|
||||
value_d.set_value(default_value); \
|
||||
value.PackFrom(value_d); \
|
||||
} \
|
||||
property_defaults[#name] = value; \
|
||||
}
|
||||
#include "properties.inc"
|
||||
}
|
||||
extern SDL_AudioSpec obtained;
|
||||
void ZsmBackend::switch_stream(int idx) {
|
||||
|
@ -167,7 +206,7 @@ void ZsmBackend::tick(bool step) {
|
|||
for (uint8_t i = 0; i < cmd.fm_write.len; i++) {
|
||||
YM_write_reg(cmd.fm_write.regs[i].reg, cmd.fm_write.regs[i].val);
|
||||
while (YM_read_status()) {
|
||||
size_t clocksToAddForYm = 64;
|
||||
size_t clocksToAddForYm = 1;
|
||||
ticks_remaining -= clocksToAddForYm;
|
||||
if (ticks_remaining < 0) {
|
||||
delayTicks -= 1;
|
||||
|
@ -385,3 +424,61 @@ double ZsmBackend::get_position() {
|
|||
int ZsmBackend::get_stream_idx() {
|
||||
return 0;
|
||||
}
|
||||
|
||||
void ZsmBackend::audio_step(size_t samples) {
|
||||
if (samples == 0) return;
|
||||
while (remain != 0 && pcm_fifo_avail() < samples) {
|
||||
if (pcm_read_rate() == 0) break;
|
||||
if ((--remain) == 0) {
|
||||
if (islooped) {
|
||||
cur = loop;
|
||||
remain = loop_rem;
|
||||
} else {
|
||||
break;
|
||||
}
|
||||
}
|
||||
size_t oldpos = file->get_pos();
|
||||
uint8_t sample = audio_sample[cur++];
|
||||
pcm_write_fifo(sample);
|
||||
}
|
||||
samples *= 2;
|
||||
int16_t *psg_ptr = psg_buf.get_item_sized<int16_t>(samples);
|
||||
int16_t *pcm_ptr = pcm_buf.get_item_sized<int16_t>(samples);
|
||||
psg_render(psg_ptr, samples / 2);
|
||||
pcm_render(pcm_ptr, samples / 2);
|
||||
int16_t *out_ptr = out_buf.get_item_sized<int16_t>(samples);
|
||||
// The exact amount of samples needed for the stream.
|
||||
double ratio = ((double)YM_FREQ) / ((double)PSG_FREQ);
|
||||
size_t needed_samples = ((size_t)std::floor(samples * ratio)) / 2;
|
||||
int16_t *ym_ptr = ym_buf.get_item_sized<int16_t>(needed_samples * 2);
|
||||
YM_stream_update(ym_ptr, needed_samples);
|
||||
assert(SDL_AudioStreamPut(fm_stream, ym_ptr, needed_samples * 2 * sizeof(int16_t)) == 0);
|
||||
while (SDL_AudioStreamAvailable(fm_stream) < ((samples + 2) * sizeof(int16_t))) {
|
||||
YM_stream_update(ym_ptr, 1);
|
||||
assert(SDL_AudioStreamPut(fm_stream, ym_ptr, 2 * sizeof(int16_t)) == 0);
|
||||
}
|
||||
int16_t *ym_resample_ptr = ym_resample_buf.get_item_sized<int16_t>(samples);
|
||||
ssize_t ym_resample_len = SDL_AudioStreamGet(fm_stream, ym_resample_ptr, (samples + 2) * sizeof(int16_t));
|
||||
assert(ym_resample_len >= 0);
|
||||
ym_resample_len /= sizeof(int16_t);
|
||||
for (size_t i = 0; i < samples / 2; i++) {
|
||||
size_t j = i * 2;
|
||||
int16_t psg[2] = {(int16_t)(psg_ptr[j] >> 1), (int16_t)(psg_ptr[j + 1] >> 1)};
|
||||
int16_t pcm[2] = {(int16_t)(pcm_ptr[j] >> 2), (int16_t)(pcm_ptr[j + 1] >> 2)};
|
||||
if (!pcm_enable()) memset(pcm, 0, sizeof(pcm));
|
||||
if (!psg_enable()) memset(psg, 0, sizeof(psg));
|
||||
pcm[0] *= pcm_volume();
|
||||
pcm[1] *= pcm_volume();
|
||||
psg[0] *= psg_volume();
|
||||
psg[1] *= psg_volume();
|
||||
int16_t vera[2] = {(int16_t)(psg[0] + pcm[0]), (int16_t)(psg[1] + pcm[1])};
|
||||
int16_t fm[2] = {ym_resample_ptr[j], ym_resample_ptr[j + 1]};
|
||||
if (!fm_enable()) memset(fm, 0, sizeof(fm));
|
||||
fm[0] *= fm_volume();
|
||||
fm[1] *= fm_volume();
|
||||
int16_t mix[2] = {(int16_t)(vera[0] + (fm[0] >> 1)), (int16_t)(vera[1] + (fm[1] >> 1))};
|
||||
out_ptr[j++] = mix[0];
|
||||
out_ptr[j++] = mix[1];
|
||||
}
|
||||
audio_buf.push(out_ptr, samples);
|
||||
}
|
||||
|
|
|
@ -93,57 +93,13 @@ class ZsmBackend : public PlaybackBackend {
|
|||
SDL_AudioStream *fm_stream;
|
||||
std::vector<pcm_instrument*> instruments;
|
||||
uint8_t *audio_sample = nullptr;
|
||||
int16_t combine_audio(int16_t a, int16_t b) {
|
||||
return (int16_t)((((int32_t)a) + ((int32_t)b)) >> 1);
|
||||
}
|
||||
void audio_step(size_t samples) {
|
||||
if (samples == 0) return;
|
||||
while (remain != 0 && pcm_fifo_avail() < samples) {
|
||||
if (pcm_read_rate() == 0) break;
|
||||
if ((--remain) == 0) {
|
||||
if (islooped) {
|
||||
cur = loop;
|
||||
remain = loop_rem;
|
||||
} else {
|
||||
break;
|
||||
}
|
||||
}
|
||||
size_t oldpos = file->get_pos();
|
||||
uint8_t sample = audio_sample[cur++];
|
||||
pcm_write_fifo(sample);
|
||||
}
|
||||
samples *= 2;
|
||||
int16_t *psg_ptr = psg_buf.get_item_sized<int16_t>(samples);
|
||||
int16_t *pcm_ptr = pcm_buf.get_item_sized<int16_t>(samples);
|
||||
psg_render(psg_ptr, samples / 2);
|
||||
pcm_render(pcm_ptr, samples / 2);
|
||||
int16_t *out_ptr = out_buf.get_item_sized<int16_t>(samples);
|
||||
// The exact amount of samples needed for the stream.
|
||||
double ratio = ((double)YM_FREQ) / ((double)PSG_FREQ);
|
||||
size_t needed_samples = ((size_t)std::floor(samples * ratio)) / 2;
|
||||
int16_t *ym_ptr = ym_buf.get_item_sized<int16_t>(needed_samples * 2);
|
||||
YM_stream_update(ym_ptr, needed_samples);
|
||||
assert(SDL_AudioStreamPut(fm_stream, ym_ptr, needed_samples * 2 * sizeof(int16_t)) == 0);
|
||||
while (SDL_AudioStreamAvailable(fm_stream) < ((samples + 2) * sizeof(int16_t))) {
|
||||
YM_stream_update(ym_ptr, 1);
|
||||
assert(SDL_AudioStreamPut(fm_stream, ym_ptr, 2 * sizeof(int16_t)) == 0);
|
||||
}
|
||||
int16_t *ym_resample_ptr = ym_resample_buf.get_item_sized<int16_t>(samples);
|
||||
ssize_t ym_resample_len = SDL_AudioStreamGet(fm_stream, ym_resample_ptr, (samples + 2) * sizeof(int16_t));
|
||||
assert(ym_resample_len >= 0);
|
||||
ym_resample_len /= sizeof(int16_t);
|
||||
for (size_t i = 0; i < samples / 2; i++) {
|
||||
size_t j = i * 2;
|
||||
int16_t psg[2] = {psg_ptr[j] >> 1, psg_ptr[j + 1] >> 1};
|
||||
int16_t pcm[2] = {pcm_ptr[j] >> 1, pcm_ptr[j + 1] >> 1};
|
||||
int16_t vera[2] = {psg[0] + pcm[0], psg[1] + pcm[1]};
|
||||
int16_t fm[2] = {ym_resample_ptr[j], ym_resample_ptr[j + 1]};
|
||||
int16_t mix[2] = {vera[0] + (fm[0] >> 1), vera[1] + (fm[1] >> 1)};
|
||||
out_ptr[j++] = mix[0];
|
||||
out_ptr[j++] = mix[1];
|
||||
}
|
||||
audio_buf.push(out_ptr, samples);
|
||||
}
|
||||
bool pcm_enable();
|
||||
bool psg_enable();
|
||||
bool fm_enable();
|
||||
double pcm_volume();
|
||||
double psg_volume();
|
||||
double fm_volume();
|
||||
void audio_step(size_t samples);
|
||||
inline void *reserve(size_t len) {
|
||||
return (void*)audio_buf.reserve(len);
|
||||
}
|
||||
|
@ -177,6 +133,7 @@ class ZsmBackend : public PlaybackBackend {
|
|||
inline std::string get_name() override {
|
||||
return "ZSM player";
|
||||
}
|
||||
std::vector<Property> get_property_list() override;
|
||||
void seek(double position) override;
|
||||
void load(const char *filename) override;
|
||||
void switch_stream(int idx) override;
|
||||
|
|
|
@ -4,6 +4,7 @@
|
|||
#include <assets/assets.h>
|
||||
#include <filesystem>
|
||||
#include <options.hpp>
|
||||
#include "imgui/imgui.h"
|
||||
#include "ui_backend.hpp"
|
||||
#include "thirdparty/CLI11.hpp"
|
||||
#include <web_functions.hpp>
|
||||
|
@ -78,7 +79,7 @@ void MainLoop::Init() {
|
|||
delete theme;
|
||||
theme = newTheme;
|
||||
} catch (std::exception _) {
|
||||
|
||||
|
||||
}
|
||||
#else
|
||||
if (exists(themePath)) {
|
||||
|
@ -141,6 +142,9 @@ void MainLoop::FileLoaded() {
|
|||
SetWindowTitle("Looper");
|
||||
}
|
||||
streams = playback->get_streams();
|
||||
properties = playback->get_property_list();
|
||||
boolean_properties.clear();
|
||||
double_properties.clear();
|
||||
}
|
||||
void MainLoop::GuiFunction() {
|
||||
#if defined(__EMSCRIPTEN__)||defined(__ANDROID__)
|
||||
|
@ -195,6 +199,9 @@ void MainLoop::GuiFunction() {
|
|||
show_demo_window = !show_demo_window;
|
||||
set_option<double>("ui.imgui.demo_window", show_demo_window);
|
||||
}
|
||||
if (ImGui::MenuItem(_TR_CTX("Main menu | Debug", "Edit properties"), nullptr, property_editor)) {
|
||||
property_editor = !property_editor;
|
||||
}
|
||||
ImGui::EndMenu();
|
||||
}
|
||||
if (ImGui::BeginMenu(_TRI_CTX(ICON_FK_INFO_CIRCLE, "Main menu", "Help"))) {
|
||||
|
@ -257,9 +264,9 @@ void MainLoop::GuiFunction() {
|
|||
}
|
||||
ImGui::SameLine();
|
||||
const int NEXT_SLIDER_COUNT = 1;
|
||||
|
||||
|
||||
double seek_bar_width = -(ImGui::GetFontSize() * (1 + (8 * NEXT_SLIDER_COUNT))) - ((ImGui::GetStyle().ItemSpacing.x + ImGui::GetStyle().FramePadding.x) * (NEXT_SLIDER_COUNT + 1));
|
||||
|
||||
|
||||
if (lengthKnown) {
|
||||
ImGui::SetNextItemWidth(seek_bar_width);
|
||||
uint8_t components = TimeToComponentCount(playback->GetLength());
|
||||
|
@ -297,11 +304,100 @@ void MainLoop::GuiFunction() {
|
|||
ImGui::PopItemWidth();
|
||||
}
|
||||
ImGui::End();
|
||||
if (property_editor) {
|
||||
ImGui::SetNextWindowDockID(dockid);
|
||||
ImGui::Begin("Property Editor", &property_editor);
|
||||
{
|
||||
for (auto property : properties) {
|
||||
ImGui::PushID(property.path().c_str());
|
||||
bool valid = false;
|
||||
switch (property.type()) {
|
||||
case PropertyType::Double: {
|
||||
std::optional<double> min;
|
||||
std::optional<double> max;
|
||||
double value = 0.0;
|
||||
if (double_properties.contains(property.path())) {
|
||||
value = double_properties[property.path()];
|
||||
} else {
|
||||
auto value_to_resolve = playback->get_property(property.path());
|
||||
if (value_to_resolve.has_value()) {
|
||||
value = resolve_value<double>(value_to_resolve.value());
|
||||
}
|
||||
double_properties[property.path()] = value;
|
||||
}
|
||||
if (property.has_hint() && property.hint().has_range()) {
|
||||
auto range = property.hint().range();
|
||||
if (range.has_min() && range.has_max()) {
|
||||
float flt = (float)value;
|
||||
if (ImGui::SliderFloat(property.path().c_str(), &flt, (float)range.min(), (float)range.max())) {
|
||||
double_properties[property.path()] = flt;
|
||||
}
|
||||
valid = true;
|
||||
} else {
|
||||
if (range.has_min()) min = range.min();
|
||||
if (range.has_max()) max = range.max();
|
||||
}
|
||||
}
|
||||
if (!valid) {
|
||||
ImGui::InputDouble(property.path().c_str(), &value);
|
||||
if (min.has_value() && value < min) {
|
||||
value = min.value();
|
||||
}
|
||||
if (max.has_value() && value > max) {
|
||||
value = max.value();
|
||||
}
|
||||
double_properties[property.path()] = value;
|
||||
valid = true;
|
||||
}
|
||||
} break;
|
||||
case PropertyType::Boolean: {
|
||||
bool value = false;
|
||||
if (boolean_properties.contains(property.path())) {
|
||||
value = boolean_properties[property.path()];
|
||||
} else {
|
||||
auto value_to_resolve = playback->get_property(property.path());
|
||||
if (value_to_resolve.has_value()) {
|
||||
value = resolve_value<bool>(value_to_resolve.value());
|
||||
}
|
||||
boolean_properties[property.path()] = value;
|
||||
}
|
||||
if (ImGui::Checkbox(property.path().c_str(), &value)) {
|
||||
boolean_properties[property.path()] = value;
|
||||
}
|
||||
valid = true;
|
||||
} break;
|
||||
}
|
||||
if (valid) {
|
||||
ImGui::SameLine();
|
||||
if (ImGui::Button("Set")) {
|
||||
switch (property.type()) {
|
||||
case PropertyType::Double: {
|
||||
DoubleProperty property_d;
|
||||
property_d.set_value(double_properties[property.path()]);
|
||||
google::protobuf::Any value;
|
||||
value.PackFrom(property_d);
|
||||
playback->set_property(property.path(), value);
|
||||
} break;
|
||||
case PropertyType::Boolean: {
|
||||
BooleanProperty property_b;
|
||||
property_b.set_value(boolean_properties[property.path()]);
|
||||
google::protobuf::Any value;
|
||||
value.PackFrom(property_b);
|
||||
playback->set_property(property.path(), value);
|
||||
} break;
|
||||
}
|
||||
}
|
||||
}
|
||||
ImGui::PopID();
|
||||
}
|
||||
}
|
||||
ImGui::End();
|
||||
}
|
||||
if (prefs_window) {
|
||||
ImGui::SetNextWindowDockID(dockid);
|
||||
ImGui::Begin(_TRI_CTX(ICON_FK_COG, "Window title, window opened by menu item", "Preferences..."), &prefs_window);
|
||||
{
|
||||
|
||||
|
||||
static std::string set_backend_name = cur_backend->get_name();
|
||||
static std::string set_backend_id = cur_backend->get_id();
|
||||
if (restart_needed) {
|
||||
|
@ -442,7 +538,7 @@ void MainLoop::GuiFunction() {
|
|||
ImGui::EndTable();
|
||||
}
|
||||
}
|
||||
ImGui::EndChildFrame();
|
||||
ImGui::EndChildFrame();
|
||||
ImGui::SetNextItemWidth(ImGui::GetWindowWidth() - (ImGui::GetStyle().WindowPadding.x * 2));
|
||||
if (ImGui::ColorEdit4("##AccentColor", &accent_color.x, ImGuiColorEditFlags_InputHSV|ImGuiColorEditFlags_DisplayHSV|ImGuiColorEditFlags_Float)) {
|
||||
set_option<double>("ui.imgui.accent_color.h", accent_color.x);
|
||||
|
|
|
@ -12,7 +12,7 @@
|
|||
#include <cmath>
|
||||
#include <cstdlib>
|
||||
#include <string>
|
||||
|
||||
#include <map>
|
||||
#include <SDL.h>
|
||||
#include <SDL_image.h>
|
||||
#include <filesystem>
|
||||
|
@ -46,12 +46,16 @@ class MainLoop : public RendererBackend {
|
|||
bool theme_editor = false;
|
||||
bool about_window = false;
|
||||
bool debug_mode = false;
|
||||
bool property_editor = false;
|
||||
bool restart_needed = false;
|
||||
bool stopped = true;
|
||||
std::vector<UIBackend*> backends;
|
||||
UIBackend *cur_backend;
|
||||
friend class ImGuiUIBackend;
|
||||
std::atomic_bool exit_flag;
|
||||
std::map<std::string, bool> boolean_properties;
|
||||
std::map<std::string, double> double_properties;
|
||||
std::vector<Property> properties;
|
||||
std::vector<PlaybackStream> streams;
|
||||
public:
|
||||
Playback *playback;
|
||||
|
|
|
@ -21,6 +21,42 @@ message StringProperty {
|
|||
message DoubleProperty {
|
||||
double value = 1;
|
||||
};
|
||||
message BooleanProperty {
|
||||
bool value = 1;
|
||||
};
|
||||
message BytesProperty {
|
||||
bytes value = 1;
|
||||
};
|
||||
message PropertyHintRange {
|
||||
optional double min = 1;
|
||||
optional double max = 2;
|
||||
};
|
||||
message PropertyHintEnum {
|
||||
repeated string data = 1;
|
||||
};
|
||||
message PropertyHint {
|
||||
oneof hint {
|
||||
PropertyHintRange range = 1;
|
||||
fixed64 max_length = 2;
|
||||
PropertyHintEnum enum = 3;
|
||||
};
|
||||
};
|
||||
enum PropertyType {
|
||||
Double = 0;
|
||||
Boolean = 1;
|
||||
String = 2;
|
||||
Bytes = 3;
|
||||
Stream = 4;
|
||||
AudioSpec = 5;
|
||||
StreamID = 6;
|
||||
}
|
||||
message Property {
|
||||
PropertyType type = 1;
|
||||
optional PropertyId id = 5;
|
||||
optional string path = 2;
|
||||
optional string name = 4;
|
||||
optional PropertyHint hint = 3;
|
||||
};
|
||||
message StreamId {
|
||||
uint64 id = 504;
|
||||
};
|
||||
|
@ -32,9 +68,6 @@ message Stream {
|
|||
message StreamList {
|
||||
repeated Stream streams = 500;
|
||||
}
|
||||
message Position {
|
||||
double pos = 508;
|
||||
};
|
||||
enum EndianID {
|
||||
LITTLE = 0;
|
||||
BIG = 1;
|
||||
|
|
|
@ -31,6 +31,9 @@ message SimpleAckResponse {
|
|||
message InitCommand {
|
||||
string filename = 1;
|
||||
uint64 idx = 2;
|
||||
};
|
||||
message GetPropertyListCommand {
|
||||
|
||||
};
|
||||
message RPCCall {
|
||||
uint64 cmdid = 1;
|
||||
|
@ -41,8 +44,12 @@ message RPCCall {
|
|||
ResetProperty reset = 5;
|
||||
QuitCmd quit = 6;
|
||||
InitCommand init = 7;
|
||||
GetPropertyListCommand get_property_list = 8;
|
||||
};
|
||||
};
|
||||
message PropertyList {
|
||||
repeated Property list = 1;
|
||||
}
|
||||
message RPCResponse {
|
||||
uint64 cmdid = 1;
|
||||
oneof response {
|
||||
|
@ -51,5 +58,6 @@ message RPCResponse {
|
|||
PropertyData data = 4;
|
||||
ResetResponse reset = 5;
|
||||
ErrorResponse err = 6;
|
||||
PropertyList property_list = 7;
|
||||
};
|
||||
};
|
||||
|
|
19
playback.cpp
19
playback.cpp
|
@ -669,3 +669,22 @@ std::vector<PlaybackStream> PlaybackInstance::get_streams() {
|
|||
int PlaybackInstance::get_current_stream() {
|
||||
return current_stream;
|
||||
}
|
||||
|
||||
void PlaybackInstance::set_property(std::string path, google::protobuf::Any value) {
|
||||
if (this->process != nullptr) {
|
||||
this->process->set_property(path, value);
|
||||
}
|
||||
}
|
||||
std::optional<google::protobuf::Any> PlaybackInstance::get_property(std::string path) {
|
||||
if (this->process != nullptr) {
|
||||
return this->process->get_property(path);
|
||||
}
|
||||
return {};
|
||||
}
|
||||
std::optional<google::protobuf::Any> PlaybackInstance::reset_property(std::string path) {
|
||||
return {};
|
||||
}
|
||||
std::vector<Property> PlaybackInstance::get_property_list() {
|
||||
if (process == nullptr) return {};
|
||||
return process->get_property_list();
|
||||
}
|
||||
|
|
18
playback.h
18
playback.h
|
@ -23,6 +23,8 @@ extern "C" {
|
|||
#include "playback_backend.hpp"
|
||||
#include "config.hpp"
|
||||
#include "playback_process.hpp"
|
||||
#include <google/protobuf/any.h>
|
||||
#include <ipc/internal.pb.h>
|
||||
using namespace soundtouch;
|
||||
using std::span;
|
||||
using std::optional;
|
||||
|
@ -195,6 +197,15 @@ class Playback {
|
|||
}
|
||||
virtual void DeinitLoopFunction() {
|
||||
|
||||
}
|
||||
virtual void set_property(std::string path, google::protobuf::Any value) {
|
||||
|
||||
}
|
||||
virtual std::optional<google::protobuf::Any> get_property(std::string path) {
|
||||
return {};
|
||||
}
|
||||
virtual std::optional<google::protobuf::Any> reset_property(std::string path) {
|
||||
return {};
|
||||
}
|
||||
bool loop_started = false;
|
||||
virtual void start_loop() {
|
||||
|
@ -210,6 +221,9 @@ class Playback {
|
|||
LoopFunction();
|
||||
}
|
||||
}
|
||||
virtual std::vector<Property> get_property_list() {
|
||||
return {};
|
||||
}
|
||||
|
||||
static Playback *Create(bool *daemon_found, bool daemon = false);
|
||||
};
|
||||
|
@ -320,6 +334,10 @@ public:
|
|||
void InitLoopFunction() override;
|
||||
void DeinitLoopFunction() override;
|
||||
void LoopFunction() override;
|
||||
void set_property(std::string path, google::protobuf::Any) override;
|
||||
std::optional<google::protobuf::Any> get_property(std::string path) override;
|
||||
std::optional<google::protobuf::Any> reset_property(std::string path) override;
|
||||
std::vector<Property> get_property_list() override;
|
||||
float volume;
|
||||
float speed;
|
||||
float tempo;
|
||||
|
|
|
@ -77,6 +77,9 @@ class PlaybackBackend {
|
|||
inline double get_rate() {
|
||||
return this->rate;
|
||||
}
|
||||
inline virtual std::vector<Property> get_property_list() {
|
||||
return std::vector<Property>();
|
||||
}
|
||||
inline virtual bool set(std::string path, google::protobuf::Any value) {properties[path] = value; return true;}
|
||||
inline virtual std::optional<google::protobuf::Any> get(std::string path) {return properties.contains(path) ? properties[path] : std::optional<google::protobuf::Any>();}
|
||||
inline virtual std::optional<google::protobuf::Any> reset(std::string path) {
|
||||
|
|
|
@ -296,6 +296,17 @@ MaybeError PlaybackProcessServiceImpl::Quit(const QuitCmd *request) {
|
|||
cur_backend_lock.get_unsafe()->cleanup();
|
||||
return MaybeError();
|
||||
}
|
||||
PropertyList PlaybackProcessServiceImpl::GetPropertyList(const GetPropertyListCommand *cmd) {
|
||||
std::vector<Property> list;
|
||||
{
|
||||
list = cur_backend_lock.lock()->get_property_list();
|
||||
}
|
||||
PropertyList output;
|
||||
for (auto el : list) {
|
||||
output.add_list()->CopyFrom(el);
|
||||
}
|
||||
return output;
|
||||
}
|
||||
MaybeError PlaybackProcessServiceImpl::Init(const InitCommand *cmd) {
|
||||
MaybeError ret;
|
||||
MaybeError *response = &ret;
|
||||
|
@ -485,6 +496,9 @@ RPCResponse PlaybackProcess::handle_command(RPCCall &call) {
|
|||
} else {
|
||||
resp.mutable_render()->CopyFrom(output.output());
|
||||
}
|
||||
} else if (call.has_get_property_list()) {
|
||||
PropertyList output = impl.GetPropertyList(&call.get_property_list());
|
||||
resp.mutable_property_list()->CopyFrom(output);
|
||||
}
|
||||
if (!resp.has_ack()) {
|
||||
delete ack;
|
||||
|
@ -618,6 +632,31 @@ std::vector<PlaybackStream> PlaybackProcess::get_playback_streams() {
|
|||
delete list;
|
||||
return output;
|
||||
}
|
||||
bool PlaybackProcess::set_property(std::string path, google::protobuf::Any value) {
|
||||
SetProperty set_property;
|
||||
set_property.set_id(PropertyId::BackendSpecific);
|
||||
set_property.mutable_value()->CopyFrom(value);
|
||||
set_property.set_path(path);
|
||||
RPCCall call;
|
||||
call.mutable_set()->CopyFrom(set_property);
|
||||
RPCResponse output = SendCommand(&call);
|
||||
if (output.has_err()) {
|
||||
return false;
|
||||
}
|
||||
return true;
|
||||
}
|
||||
std::optional<google::protobuf::Any> PlaybackProcess::get_property(std::string path) {
|
||||
GetProperty get_property;
|
||||
get_property.set_id(PropertyId::BackendSpecific);
|
||||
get_property.set_path(path);
|
||||
RPCCall call;
|
||||
call.mutable_get()->CopyFrom(get_property);
|
||||
RPCResponse output = SendCommand(&call);
|
||||
if (output.has_err()) {
|
||||
return {};
|
||||
}
|
||||
return output.data().value();
|
||||
}
|
||||
size_t PlaybackProcess::render(void *buf, size_t maxlen) {
|
||||
RenderCommand rend_cmd = RenderCommand();
|
||||
rend_cmd.set_len(maxlen);
|
||||
|
@ -676,3 +715,18 @@ double PlaybackProcess::get_cached_rate() {
|
|||
void PlaybackProcess::set_rate(double value) {
|
||||
set_property_double(PropertyId::PlaybackRate, value);
|
||||
}
|
||||
std::vector<Property> PlaybackProcess::get_property_list() {
|
||||
RPCCall call;
|
||||
GetPropertyListCommand cmd;
|
||||
call.mutable_get_property_list()->CopyFrom(cmd);
|
||||
RPCResponse resp = SendCommand(&call);
|
||||
if (resp.has_property_list()) {
|
||||
std::vector<Property> output;
|
||||
for (size_t i = 0; i < resp.property_list().list_size(); i++) {
|
||||
output.push_back(resp.property_list().list(i));
|
||||
}
|
||||
return output;
|
||||
} else {
|
||||
return std::vector<Property>();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -30,13 +30,8 @@ class PlaybackProcessServiceImpl {
|
|||
ResetResponse Reset(const ResetProperty *request);
|
||||
MaybeError Quit(const QuitCmd *request);
|
||||
MaybeError Init(const InitCommand *cmd);
|
||||
PropertyList GetPropertyList(const GetPropertyListCommand *cmd);
|
||||
};
|
||||
template<class T>
|
||||
inline T *resolve_any(google::protobuf::Any value) {
|
||||
T *output = new T();
|
||||
value.UnpackTo(output);
|
||||
return output;
|
||||
}
|
||||
//#define DEBUG_PRINT_IPC
|
||||
void print_ipc_message(const google::protobuf::Message &msg, size_t level = 0);
|
||||
class PlaybackProcess {
|
||||
|
@ -124,6 +119,7 @@ class PlaybackProcess {
|
|||
|
||||
std::optional<google::protobuf::Any> get_property(std::string path);
|
||||
bool set_property(std::string path, google::protobuf::Any value);
|
||||
std::vector<Property> get_property_list();
|
||||
PlaybackProcess(std::string filename, int idx = 0);
|
||||
~PlaybackProcess();
|
||||
};
|
||||
|
|
25
util.cpp
25
util.cpp
|
@ -179,4 +179,27 @@ int NotSDL_ConvertAudioSamples(const SDL_AudioSpec *src_spec, const Uint8 *src_d
|
|||
|
||||
SDL_FreeAudioStream(stream);
|
||||
return retval;
|
||||
}
|
||||
}
|
||||
PropertyHint make_hint(double min, double max) {
|
||||
PropertyHint output;
|
||||
auto range = output.mutable_range();
|
||||
range->set_min(min);
|
||||
range->set_max(max);
|
||||
return output;
|
||||
}
|
||||
Property make_property(PropertyType type, std::string name, PropertyId id, std::optional<std::string> path, std::optional<PropertyHint> hint) {
|
||||
Property output;
|
||||
output.set_id(id);
|
||||
output.set_name(name);
|
||||
output.set_type(type);
|
||||
if (path.has_value()) output.set_path(path.value());
|
||||
if (hint.has_value()) output.mutable_hint()->CopyFrom(hint.value());
|
||||
return output;
|
||||
}
|
||||
Property make_property(PropertyType type, std::string name, std::string path, std::optional<PropertyHint> hint) {
|
||||
return make_property(type, name, PropertyId::BackendSpecific, path, hint)
|
||||
}
|
||||
Property make_property(PropertyType type, std::string name, PropertyId id, std::optional<PropertyHint> hint) {
|
||||
return make_property(type, name, id, {}, hint)
|
||||
|
||||
}
|
||||
|
|
85
util.hpp
85
util.hpp
|
@ -17,6 +17,7 @@
|
|||
#include <cassert>
|
||||
#include <SDL.h>
|
||||
#include "log.hpp"
|
||||
#include <ipc/common.pb.h>
|
||||
namespace fs = std::filesystem;
|
||||
std::string PadZeros(std::string input, size_t required_length);
|
||||
uint8_t TimeToComponentCount(double time_code);
|
||||
|
@ -333,6 +334,9 @@ class DynPtr {
|
|||
DynPtr(size_t len) : DynPtr() {
|
||||
resize(len);
|
||||
}
|
||||
DynPtr(std::string input) : DynPtr(input.length()) {
|
||||
memcpy(this->ptr, input.data(), input.length());
|
||||
}
|
||||
/// @brief Gets the pointer, but does not reallocate it.
|
||||
/// @param T The type of pointer to return. May be void to return void*.
|
||||
/// @returns The pointer, owned by the DynPtr object.
|
||||
|
@ -382,11 +386,11 @@ public:
|
|||
void resize(size_t new_capacity) {
|
||||
std::vector<T> new_buffer(new_capacity);
|
||||
size_t new_count = std::min(count, new_capacity);
|
||||
|
||||
|
||||
for (size_t i = 0; i < new_count; ++i) {
|
||||
new_buffer[i] = buffer[(head + i) % buffer.size()];
|
||||
}
|
||||
|
||||
|
||||
buffer = std::move(new_buffer);
|
||||
head = 0;
|
||||
tail = new_count;
|
||||
|
@ -413,7 +417,7 @@ public:
|
|||
if (count + length > buffer.size()) {
|
||||
resize(std::max(buffer.size() * 2, count + length));
|
||||
}
|
||||
|
||||
|
||||
for (size_t i = 0; i < length; ++i) {
|
||||
buffer[tail] = values[i];
|
||||
tail = (tail + 1) % buffer.size();
|
||||
|
@ -445,11 +449,11 @@ public:
|
|||
if (count + length > buffer.size()) {
|
||||
resize(std::max(buffer.size() * 2, count + length));
|
||||
}
|
||||
|
||||
|
||||
T* start = &buffer[tail];
|
||||
tail = (tail + length) % buffer.size();
|
||||
count += length;
|
||||
|
||||
|
||||
return start;
|
||||
}
|
||||
|
||||
|
@ -484,4 +488,73 @@ public:
|
|||
void blocking_write(int fd, const void *buf, const size_t len);
|
||||
void blocking_read(int fd, void *buf, const size_t len);
|
||||
int NotSDL_ConvertAudioSamples(const SDL_AudioSpec *src_spec, const Uint8 *src_data, int src_len,
|
||||
const SDL_AudioSpec *dst_spec, Uint8 **dst_data, int *dst_len);
|
||||
const SDL_AudioSpec *dst_spec, Uint8 **dst_data, int *dst_len);
|
||||
|
||||
template<class T>
|
||||
inline T *resolve_any(google::protobuf::Any value) {
|
||||
T *output = new T();
|
||||
value.UnpackTo(output);
|
||||
return output;
|
||||
}
|
||||
template<class T>
|
||||
inline T resolve_value(google::protobuf::Any value) {
|
||||
throw std::exception();
|
||||
}
|
||||
template<>
|
||||
inline bool resolve_value<bool>(google::protobuf::Any value) {
|
||||
BooleanProperty *property = resolve_any<BooleanProperty>(value);
|
||||
bool output = property->value();
|
||||
delete property;
|
||||
return output;
|
||||
}
|
||||
template<>
|
||||
inline std::string resolve_value<std::string>(google::protobuf::Any value) {
|
||||
StringProperty *property = resolve_any<StringProperty>(value);
|
||||
std::string output = property->value();
|
||||
delete property;
|
||||
return output;
|
||||
}
|
||||
template<>
|
||||
inline DynPtr resolve_value<DynPtr>(google::protobuf::Any value) {
|
||||
BytesProperty *property = resolve_any<BytesProperty>(value);
|
||||
std::string output = property->value();
|
||||
delete property;
|
||||
return DynPtr(output);
|
||||
}
|
||||
|
||||
template<>
|
||||
inline double resolve_value(google::protobuf::Any value) {
|
||||
DoubleProperty *property = resolve_any<DoubleProperty>(value);
|
||||
double output = property->value();
|
||||
delete property;
|
||||
return output;
|
||||
}
|
||||
template<class T>
|
||||
inline google::protobuf::Any value_to_any(T value) {
|
||||
google::protobuf::Any output;
|
||||
output.PackFrom(value);
|
||||
return output;
|
||||
}
|
||||
template<>
|
||||
inline google::protobuf::Any value_to_any<double>(double value) {
|
||||
DoubleProperty output;
|
||||
output.set_value(value);
|
||||
return value_to_any<DoubleProperty>(output);
|
||||
}
|
||||
|
||||
template<>
|
||||
inline google::protobuf::Any value_to_any<bool>(bool value) {
|
||||
BooleanProperty output;
|
||||
output.set_value(value);
|
||||
return value_to_any<BooleanProperty>(output);
|
||||
}
|
||||
|
||||
template<>
|
||||
inline google::protobuf::Any value_to_any<std::string>(std::string value) {
|
||||
StringProperty output;
|
||||
output.set_value(value);
|
||||
return value_to_any<StringProperty>(output);
|
||||
}
|
||||
Property make_property(PropertyType type, std::string name, PropertyId id, std::optional<PropertyHint> hint);
|
||||
Property make_property(PropertyType type, std::string name, std::string path, std::optional<PropertyHint> hint = {});
|
||||
Property make_property(PropertyType type, std::string name, PropertyId id = PropertyId::BackendSpecific, std::optional<std::string> path = {}, std::optional<PropertyHint> hint = {});
|
||||
|
|
Loading…
Reference in a new issue