Skip to content

Commit c73b705

Browse files
authored
Merge pull request #103 from paritytech/dp-fix-warnings
Fix a few warnings
2 parents 5c943db + 2b99d6b commit c73b705

File tree

3 files changed

+6
-11
lines changed

3 files changed

+6
-11
lines changed

sqlx-data.json

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -334,8 +334,8 @@
334334
]
335335
}
336336
},
337-
"f1a15dd2b69242061774eb65c073174b671182a43ca6839246f5b6e6039ae46b": {
338-
"query": "SELECT missing_num\n FROM (SELECT MAX(block_num) AS max_num FROM blocks) max, \n GENERATE_SERIES($1, max_num) AS missing_num\n WHERE\n NOT EXISTS (SELECT id FROM blocks WHERE block_num = missing_num)\n ORDER BY missing_num ASC\n LIMIT $2\n ",
337+
"5f87852941e1c1850206ced095d9f6e66ff7060dad484232bb01955c4159118d": {
338+
"query": "SELECT missing_num\n FROM (SELECT MAX(block_num) AS max_num FROM blocks) max,\n GENERATE_SERIES($1, max_num) AS missing_num\n WHERE\n NOT EXISTS (SELECT id FROM blocks WHERE block_num = missing_num)\n ORDER BY missing_num ASC\n LIMIT $2\n ",
339339
"describe": {
340340
"columns": [
341341
{
@@ -355,4 +355,4 @@
355355
]
356356
}
357357
}
358-
}
358+
}

src/database/listener.rs

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -221,12 +221,7 @@ impl Listener {
221221
mod tests {
222222
use super::*;
223223
use futures::{SinkExt, StreamExt};
224-
use once_cell::sync::Lazy;
225-
use sqlx::{Connection, Executor};
226-
use std::sync::{
227-
atomic::{AtomicUsize, Ordering},
228-
Arc,
229-
};
224+
use sqlx::Connection;
230225

231226
#[test]
232227
fn should_get_notifications() {
@@ -235,7 +230,7 @@ mod tests {
235230
smol::block_on(async move {
236231
let (tx, mut rx) = futures::channel::mpsc::channel(5);
237232

238-
let listener = Builder::new(&crate::DATABASE_URL, move |_, _| {
233+
let _listener = Builder::new(&crate::DATABASE_URL, move |_, _| {
239234
let mut tx1 = tx.clone();
240235
async move {
241236
log::info!("Hello");

src/database/queries.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ pub(crate) async fn missing_blocks_min_max(
6767
Ok(sqlx::query_as!(
6868
Series,
6969
"SELECT missing_num
70-
FROM (SELECT MAX(block_num) AS max_num FROM blocks) max,
70+
FROM (SELECT MAX(block_num) AS max_num FROM blocks) max,
7171
GENERATE_SERIES($1, max_num) AS missing_num
7272
WHERE
7373
NOT EXISTS (SELECT id FROM blocks WHERE block_num = missing_num)

0 commit comments

Comments
 (0)