tweaks

mobile_verifier/migrations/15_speedtests_one_to_one.sql

@@ -1,13 +1,13 @@
 
 CREATE TABLE speedtests_migration (
-       id TEXT NOT NULL,
+       pubkey text NOT NULL,
        upload_speed bigint,
        download_speed bigint,
        latency integer,
-       timestamp TIMESTAMP NOT NULL
+       timestamp timestamptz NOT NULL
 );
 
-insert into speedtests_migration (id, upload_speed, download_speed, latency, timestamp)
+insert into speedtests_migration (pubkey, upload_speed, download_speed, latency, timestamp)
 select id, (st).upload_speed, (st).download_speed, (st).latency, (st).timestamp
 from (select id, unnest(speedtests) as st from speedtests) as tmp;
 

mobile_verifier/src/speedtests.rs

@@ -19,10 +19,10 @@ pub type EpochSpeedTests = HashMap<PublicKeyBinary, Vec<Speedtest>>;
 #[sqlx(type_name = "speedtest")]
 pub struct Speedtest {
     pub pubkey: PublicKeyBinary,
-    pub timestamp: DateTime<Utc>,
     pub upload_speed: i64,
     pub download_speed: i64,
     pub latency: i32,
+    pub timestamp: DateTime<Utc>,
 }
 
 impl Speedtest {
@@ -89,6 +89,10 @@ impl SpeedtestDaemon {
         &self,
         file_info_stream: FileInfoStream<CellSpeedtestIngestReport>,
     ) -> anyhow::Result<()> {
+        tracing::info!(
+            "Processing speedtest file {}",
+            file_info_stream.file_info.key
+        );
         let mut transaction = self.pool.begin().await?;
         // process the speedtest reports from the file, if valid insert to the db
         // collect a list of pubkeys from valid reports