alemi/dashboard
1
0
Fork 0
mirror of https://git.alemi.dev/dashboard.git synced 2024-11-24 16:34:49 +01:00
Code Issues Projects Releases Packages Wiki Activity

fix: fetch data with reliable ordering

Browse source
This commit is contained in:
əlemi 2022-11-08 01:37:20 +01:00
parent 868a1a4e0a
commit a974dbc5bb
Signed by: alemi
GPG key ID: A4895B84D311642C
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/worker/visualizer.rs
View file

@ -124,6 +124,7 @@ impl AppState {
// TODO parallelize all this stuff // TODO parallelize all this stuff
self.panels = entities::panels::Entity::find() self.panels = entities::panels::Entity::find()
.order_by(entities::panels::Column::Position, Order::Asc) .order_by(entities::panels::Column::Position, Order::Asc)
.order_by(entities::panels::Column::Id, Order::Asc)
.all(db).await?; .all(db).await?;
if let Err(e) = self.tx.panels.send(self.panels.clone()) { if let Err(e) = self.tx.panels.send(self.panels.clone()) {
error!(target: "state-manager", "Could not send panels update: {:?}", e); error!(target: "state-manager", "Could not send panels update: {:?}", e);
@ -131,6 +132,7 @@ impl AppState {
self.sources = entities::sources::Entity::find() self.sources = entities::sources::Entity::find()
.order_by(entities::sources::Column::Position, Order::Asc) .order_by(entities::sources::Column::Position, Order::Asc)
.order_by(entities::sources::Column::Id, Order::Asc)
.all(db).await?; .all(db).await?;
if let Err(e) = self.tx.sources.send(self.sources.clone()) { if let Err(e) = self.tx.sources.send(self.sources.clone()) {
error!(target: "state-manager", "Could not send sources update: {:?}", e); error!(target: "state-manager", "Could not send sources update: {:?}", e);
@ -138,6 +140,8 @@ impl AppState {
self.metrics = entities::metrics::Entity::find() self.metrics = entities::metrics::Entity::find()
.order_by(entities::metrics::Column::Position, Order::Asc) .order_by(entities::metrics::Column::Position, Order::Asc)
.order_by(entities::metrics::Column::SourceId, Order::Asc)
.order_by(entities::metrics::Column::Id, Order::Asc)
.all(db).await?; .all(db).await?;
if let Err(e) = self.tx.metrics.send(self.metrics.clone()) { if let Err(e) = self.tx.metrics.send(self.metrics.clone()) {
error!(target: "state-manager", "Could not send metrics update: {:?}", e); error!(target: "state-manager", "Could not send metrics update: {:?}", e);