test(gpodder_sqlite): start device tests

gpodder_sqlite/.env

@@ -1 +1 @@
-DATABASE_URL=data/otter.sqlite3
+DATABASE_URL=otter.sqlite3

gpodder_sqlite/.gitignore

@@ -0,0 +1 @@
+otter.sqlite3

gpodder_sqlite/diesel.toml

@@ -2,7 +2,7 @@
 # see https://diesel.rs/guides/configuring-diesel-cli
 
 [print_schema]
-file = "src/db/schema.rs"
+file = "src/schema.rs"
 custom_type_derives = ["diesel::query_builder::QueryId", "Clone"]
 sqlite_integer_primary_key_is_bigint = true
 

gpodder_sqlite/src/repository/device.rs

@@ -1,7 +1,7 @@
 use std::collections::HashSet;
 
 use chrono::{DateTime, Utc};
-use diesel::{alias, dsl::not, prelude::*};
+use diesel::{alias, dsl::not, prelude::*, sqlite::Sqlite};
 use gpodder::AuthErr;
 
 use super::SqliteRepository;
@@ -70,6 +70,8 @@ impl gpodder::DeviceRepository for SqliteRepository {
         patch: gpodder::DevicePatch,
     ) -> Result<(), gpodder::AuthErr> {
         (|| {
+            let conn = &mut self.pool.get()?;
+
             if let Some(mut device) = devices::table
                 .select(Device::as_select())
                 .filter(
@@ -77,7 +79,7 @@ impl gpodder::DeviceRepository for SqliteRepository {
                         .eq(user.id)
                         .and(devices::device_id.eq(device_id)),
                 )
-                .get_result(&mut self.pool.get()?)
+                .get_result(conn)
                 .optional()?
             {
                 if let Some(caption) = patch.caption {
@@ -93,7 +95,7 @@ impl gpodder::DeviceRepository for SqliteRepository {
                         devices::caption.eq(&device.caption),
                         devices::type_.eq(&device.type_),
                     ))
-                    .execute(&mut self.pool.get()?)?;
+                    .execute(conn)?;
             } else {
                 let device = NewDevice {
                     device_id: device_id.to_string(),
@@ -104,7 +106,7 @@ impl gpodder::DeviceRepository for SqliteRepository {
 
                 diesel::insert_into(devices::table)
                     .values(device)
-                    .execute(&mut self.pool.get()?)?;
+                    .execute(conn)?;
             }
 
             Ok::<_, DbError>(())

gpodder_sqlite/tests/auth_test.rs

@@ -104,7 +104,7 @@ fn test_refresh_session() {
 }
 
 #[test]
-fn remove_old_sessions() {
+fn test_remove_old_sessions() {
     let (store, users) = common::setup();
 
     let now = chrono::Utc::now().trunc_subsecs(0);

gpodder_sqlite/tests/device_test.rs

@@ -0,0 +1,41 @@
+mod common;
+
+use gpodder::{DevicePatch, DeviceRepository, DeviceType};
+
+#[test]
+fn test_insert_devices() {
+    let (store, users) = common::setup();
+
+    store.devices_for_user(&users[0]).unwrap();
+
+    store
+        .update_device_info(
+            &users[0],
+            "device1",
+            DevicePatch {
+                caption: Some("caption1".to_string()),
+                r#type: Some(DeviceType::Other),
+            },
+        )
+        .expect("update info shouldn't fail");
+
+    store
+        .update_device_info(
+            &users[1],
+            "device2",
+            DevicePatch {
+                caption: Some("caption2".to_string()),
+                r#type: Some(DeviceType::Laptop),
+            },
+        )
+        .expect("update info shouldn't fail");
+
+    let devices = store.devices_for_user(&users[0]);
+    assert!(matches!(devices, Ok(_)));
+
+    let devices = devices.unwrap();
+    assert_eq!(devices.len(), 1);
+
+    assert_eq!(devices[0].caption, "caption1");
+    assert_eq!(devices[0].r#type, DeviceType::Other);
+}