signal_to_timeline.rs
This commit is contained in:
parent
1881d62c56
commit
48dad951a5
|
@ -85,7 +85,8 @@ pub(super) async fn load_signal_and_get_timeline(
|
||||||
waveform.load_signals_multi_threaded(&[signal_ref]);
|
waveform.load_signals_multi_threaded(&[signal_ref]);
|
||||||
let signal = waveform.get_signal(signal_ref).unwrap();
|
let signal = waveform.get_signal(signal_ref).unwrap();
|
||||||
let time_table = waveform.time_table();
|
let time_table = waveform.time_table();
|
||||||
let timeline = signal_to_timeline(signal, time_table, screen_width, block_height, var_format);
|
let timeline =
|
||||||
|
shared::signal_to_timeline(signal, time_table, screen_width, block_height, var_format);
|
||||||
timeline
|
timeline
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -94,75 +95,3 @@ pub(super) async fn unload_signal(signal_ref: wellen::SignalRef) {
|
||||||
let waveform = waveform_lock.as_mut().unwrap_throw();
|
let waveform = waveform_lock.as_mut().unwrap_throw();
|
||||||
waveform.unload_signals(&[signal_ref]);
|
waveform.unload_signals(&[signal_ref]);
|
||||||
}
|
}
|
||||||
|
|
||||||
// @TODO keep in sync with the same method in `src-tauri/src/lib.rs`
|
|
||||||
fn signal_to_timeline(
|
|
||||||
signal: &wellen::Signal,
|
|
||||||
time_table: &[wellen::Time],
|
|
||||||
screen_width: u32,
|
|
||||||
block_height: u32,
|
|
||||||
var_format: shared::VarFormat,
|
|
||||||
) -> shared::Timeline {
|
|
||||||
const MIN_BLOCK_WIDTH: u32 = 3;
|
|
||||||
// Courier New, 16px, sync with `label_style` in `pixi_canvas.rs`
|
|
||||||
const LETTER_WIDTH: f64 = 9.61;
|
|
||||||
const LETTER_HEIGHT: u32 = 18;
|
|
||||||
const LABEL_X_PADDING: u32 = 10;
|
|
||||||
|
|
||||||
let Some(last_time) = time_table.last().copied() else {
|
|
||||||
return shared::Timeline::default();
|
|
||||||
};
|
|
||||||
|
|
||||||
let last_time = last_time as f64;
|
|
||||||
let screen_width = screen_width as f64;
|
|
||||||
|
|
||||||
let mut x_value_pairs = signal
|
|
||||||
.iter_changes()
|
|
||||||
.map(|(index, value)| {
|
|
||||||
let index = index as usize;
|
|
||||||
let time = time_table[index] as f64;
|
|
||||||
let x = time / last_time * screen_width;
|
|
||||||
(x, value)
|
|
||||||
})
|
|
||||||
.peekable();
|
|
||||||
|
|
||||||
// @TODO parallelize?
|
|
||||||
let mut blocks = Vec::new();
|
|
||||||
while let Some((block_x, value)) = x_value_pairs.next() {
|
|
||||||
let next_block_x = if let Some((next_block_x, _)) = x_value_pairs.peek() {
|
|
||||||
*next_block_x
|
|
||||||
} else {
|
|
||||||
screen_width
|
|
||||||
};
|
|
||||||
|
|
||||||
let block_width = (next_block_x - block_x) as u32;
|
|
||||||
if block_width < MIN_BLOCK_WIDTH {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
// @TODO cache?
|
|
||||||
let value = var_format.format(value);
|
|
||||||
|
|
||||||
let value_width = (value.chars().count() as f64 * LETTER_WIDTH) as u32;
|
|
||||||
// @TODO Ellipsis instead of hiding?
|
|
||||||
let label = if (value_width + (2 * LABEL_X_PADDING)) <= block_width {
|
|
||||||
Some(shared::TimeLineBlockLabel {
|
|
||||||
text: value,
|
|
||||||
x: (block_width - value_width) / 2,
|
|
||||||
y: (block_height - LETTER_HEIGHT) / 2,
|
|
||||||
})
|
|
||||||
} else {
|
|
||||||
None
|
|
||||||
};
|
|
||||||
|
|
||||||
let block = shared::TimelineBlock {
|
|
||||||
x: block_x as u32,
|
|
||||||
width: block_width,
|
|
||||||
height: block_height,
|
|
||||||
label,
|
|
||||||
};
|
|
||||||
blocks.push(block);
|
|
||||||
}
|
|
||||||
|
|
||||||
shared::Timeline { blocks }
|
|
||||||
}
|
|
||||||
|
|
|
@ -3,6 +3,9 @@ use moonlight::*;
|
||||||
mod var_format;
|
mod var_format;
|
||||||
pub use var_format::VarFormat;
|
pub use var_format::VarFormat;
|
||||||
|
|
||||||
|
mod signal_to_timeline;
|
||||||
|
pub use signal_to_timeline::signal_to_timeline;
|
||||||
|
|
||||||
pub mod wellen_helpers;
|
pub mod wellen_helpers;
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug, Default)]
|
#[derive(Serialize, Deserialize, Debug, Default)]
|
||||||
|
|
72
shared/src/signal_to_timeline.rs
Normal file
72
shared/src/signal_to_timeline.rs
Normal file
|
@ -0,0 +1,72 @@
|
||||||
|
use crate::*;
|
||||||
|
|
||||||
|
pub fn signal_to_timeline(
|
||||||
|
signal: &wellen::Signal,
|
||||||
|
time_table: &[wellen::Time],
|
||||||
|
screen_width: u32,
|
||||||
|
block_height: u32,
|
||||||
|
var_format: VarFormat,
|
||||||
|
) -> Timeline {
|
||||||
|
const MIN_BLOCK_WIDTH: u32 = 3;
|
||||||
|
// Courier New, 16px, sync with `label_style` in `pixi_canvas.rs`
|
||||||
|
const LETTER_WIDTH: f64 = 9.61;
|
||||||
|
const LETTER_HEIGHT: u32 = 18;
|
||||||
|
const LABEL_X_PADDING: u32 = 10;
|
||||||
|
|
||||||
|
let Some(last_time) = time_table.last().copied() else {
|
||||||
|
return Timeline::default();
|
||||||
|
};
|
||||||
|
|
||||||
|
let last_time = last_time as f64;
|
||||||
|
let screen_width = screen_width as f64;
|
||||||
|
|
||||||
|
let mut x_value_pairs = signal
|
||||||
|
.iter_changes()
|
||||||
|
.map(|(index, value)| {
|
||||||
|
let index = index as usize;
|
||||||
|
let time = time_table[index] as f64;
|
||||||
|
let x = time / last_time * screen_width;
|
||||||
|
(x, value)
|
||||||
|
})
|
||||||
|
.peekable();
|
||||||
|
|
||||||
|
// @TODO parallelize?
|
||||||
|
let mut blocks = Vec::new();
|
||||||
|
while let Some((block_x, value)) = x_value_pairs.next() {
|
||||||
|
let next_block_x = if let Some((next_block_x, _)) = x_value_pairs.peek() {
|
||||||
|
*next_block_x
|
||||||
|
} else {
|
||||||
|
screen_width
|
||||||
|
};
|
||||||
|
|
||||||
|
let block_width = (next_block_x - block_x) as u32;
|
||||||
|
if block_width < MIN_BLOCK_WIDTH {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
// @TODO cache?
|
||||||
|
let value = var_format.format(value);
|
||||||
|
|
||||||
|
let value_width = (value.chars().count() as f64 * LETTER_WIDTH) as u32;
|
||||||
|
// @TODO Ellipsis instead of hiding?
|
||||||
|
let label = if (value_width + (2 * LABEL_X_PADDING)) <= block_width {
|
||||||
|
Some(TimeLineBlockLabel {
|
||||||
|
text: value,
|
||||||
|
x: (block_width - value_width) / 2,
|
||||||
|
y: (block_height - LETTER_HEIGHT) / 2,
|
||||||
|
})
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
};
|
||||||
|
|
||||||
|
let block = TimelineBlock {
|
||||||
|
x: block_x as u32,
|
||||||
|
width: block_width,
|
||||||
|
height: block_height,
|
||||||
|
label,
|
||||||
|
};
|
||||||
|
blocks.push(block);
|
||||||
|
}
|
||||||
|
|
||||||
|
Timeline { blocks }
|
||||||
|
}
|
|
@ -54,7 +54,8 @@ async fn load_signal_and_get_timeline(
|
||||||
waveform.load_signals_multi_threaded(&[signal_ref]);
|
waveform.load_signals_multi_threaded(&[signal_ref]);
|
||||||
let signal = waveform.get_signal(signal_ref).unwrap();
|
let signal = waveform.get_signal(signal_ref).unwrap();
|
||||||
let time_table = waveform.time_table();
|
let time_table = waveform.time_table();
|
||||||
let timeline = signal_to_timeline(signal, time_table, screen_width, block_height, var_format);
|
let timeline =
|
||||||
|
shared::signal_to_timeline(signal, time_table, screen_width, block_height, var_format);
|
||||||
Ok(serde_json::to_value(timeline).unwrap())
|
Ok(serde_json::to_value(timeline).unwrap())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -88,75 +89,3 @@ pub fn run() {
|
||||||
.run(tauri::generate_context!())
|
.run(tauri::generate_context!())
|
||||||
.expect("error while running tauri application");
|
.expect("error while running tauri application");
|
||||||
}
|
}
|
||||||
|
|
||||||
// @TODO keep in sync with the same method in `frontend/src/platform/browser.rs`
|
|
||||||
fn signal_to_timeline(
|
|
||||||
signal: &wellen::Signal,
|
|
||||||
time_table: &[wellen::Time],
|
|
||||||
screen_width: u32,
|
|
||||||
block_height: u32,
|
|
||||||
var_format: shared::VarFormat,
|
|
||||||
) -> shared::Timeline {
|
|
||||||
const MIN_BLOCK_WIDTH: u32 = 3;
|
|
||||||
// Courier New, 16px, sync with `label_style` in `pixi_canvas.rs`
|
|
||||||
const LETTER_WIDTH: f64 = 9.61;
|
|
||||||
const LETTER_HEIGHT: u32 = 18;
|
|
||||||
const LABEL_X_PADDING: u32 = 10;
|
|
||||||
|
|
||||||
let Some(last_time) = time_table.last().copied() else {
|
|
||||||
return shared::Timeline::default();
|
|
||||||
};
|
|
||||||
|
|
||||||
let last_time = last_time as f64;
|
|
||||||
let screen_width = screen_width as f64;
|
|
||||||
|
|
||||||
let mut x_value_pairs = signal
|
|
||||||
.iter_changes()
|
|
||||||
.map(|(index, value)| {
|
|
||||||
let index = index as usize;
|
|
||||||
let time = time_table[index] as f64;
|
|
||||||
let x = time / last_time * screen_width;
|
|
||||||
(x, value)
|
|
||||||
})
|
|
||||||
.peekable();
|
|
||||||
|
|
||||||
// @TODO parallelize?
|
|
||||||
let mut blocks = Vec::new();
|
|
||||||
while let Some((block_x, value)) = x_value_pairs.next() {
|
|
||||||
let next_block_x = if let Some((next_block_x, _)) = x_value_pairs.peek() {
|
|
||||||
*next_block_x
|
|
||||||
} else {
|
|
||||||
screen_width
|
|
||||||
};
|
|
||||||
|
|
||||||
let block_width = (next_block_x - block_x) as u32;
|
|
||||||
if block_width < MIN_BLOCK_WIDTH {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
// @TODO cache?
|
|
||||||
let value = var_format.format(value);
|
|
||||||
|
|
||||||
let value_width = (value.chars().count() as f64 * LETTER_WIDTH) as u32;
|
|
||||||
// @TODO Ellipsis instead of hiding?
|
|
||||||
let label = if (value_width + (2 * LABEL_X_PADDING)) <= block_width {
|
|
||||||
Some(shared::TimeLineBlockLabel {
|
|
||||||
text: value,
|
|
||||||
x: (block_width - value_width) / 2,
|
|
||||||
y: (block_height - LETTER_HEIGHT) / 2,
|
|
||||||
})
|
|
||||||
} else {
|
|
||||||
None
|
|
||||||
};
|
|
||||||
|
|
||||||
let block = shared::TimelineBlock {
|
|
||||||
x: block_x as u32,
|
|
||||||
width: block_width,
|
|
||||||
height: block_height,
|
|
||||||
label,
|
|
||||||
};
|
|
||||||
blocks.push(block);
|
|
||||||
}
|
|
||||||
|
|
||||||
shared::Timeline { blocks }
|
|
||||||
}
|
|
||||||
|
|
Loading…
Reference in a new issue