+294

Cargo.lock

reviewed

··· 386 386 checksum = "b35204fbdc0b3f4446b89fc1ac2cf84a8a68971995d0bf2e925ec7cd960f9cb3" 387 387 388 388 [[package]] 389 389 + name = "cairo-rs" 390 390 + version = "0.21.5" 391 391 + source = "registry+https://github.com/rust-lang/crates.io-index" 392 392 + checksum = "b01fe135c0bd16afe262b6dea349bd5ea30e6de50708cec639aae7c5c14cc7e4" 393 393 + dependencies = [ 394 394 + "bitflags 2.10.0", 395 395 + "cairo-sys-rs", 396 396 + "glib", 397 397 + "libc", 398 398 + ] 399 399 + 400 400 + [[package]] 401 401 + name = "cairo-sys-rs" 402 402 + version = "0.21.5" 403 403 + source = "registry+https://github.com/rust-lang/crates.io-index" 404 404 + checksum = "06c28280c6b12055b5e39e4554271ae4e6630b27c0da9148c4cf6485fc6d245c" 405 405 + dependencies = [ 406 406 + "glib-sys", 407 407 + "libc", 408 408 + "system-deps", 409 409 + ] 410 410 + 411 411 + [[package]] 389 412 name = "cc" 390 413 version = "1.2.52" 391 414 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 785 808 checksum = "37909eebbb50d72f9059c3b6d82c0463f2ff062c9e95845c43a6c9c0355411be" 786 809 787 810 [[package]] 811 811 + name = "field-offset" 812 812 + version = "0.3.6" 813 813 + source = "registry+https://github.com/rust-lang/crates.io-index" 814 814 + checksum = "38e2275cc4e4fc009b0669731a1e5ab7ebf11f469eaede2bab9309a5b4d6057f" 815 815 + dependencies = [ 816 816 + "memoffset", 817 817 + "rustc_version", 818 818 + ] 819 819 + 820 820 + [[package]] 788 821 name = "find-msvc-tools" 789 822 version = "0.1.7" 790 823 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 967 1000 ] 968 1001 969 1002 [[package]] 1003 1003 + name = "gdk-pixbuf" 1004 1004 + version = "0.21.5" 1005 1005 + source = "registry+https://github.com/rust-lang/crates.io-index" 1006 1006 + checksum = "debb0d39e3cdd84626edfd54d6e4a6ba2da9a0ef2e796e691c4e9f8646fda00c" 1007 1007 + dependencies = [ 1008 1008 + "gdk-pixbuf-sys", 1009 1009 + "gio", 1010 1010 + "glib", 1011 1011 + "libc", 1012 1012 + ] 1013 1013 + 1014 1014 + [[package]] 1015 1015 + name = "gdk-pixbuf-sys" 1016 1016 + version = "0.21.5" 1017 1017 + source = "registry+https://github.com/rust-lang/crates.io-index" 1018 1018 + checksum = "bd95ad50b9a3d2551e25dd4f6892aff0b772fe5372d84514e9d0583af60a0ce7" 1019 1019 + dependencies = [ 1020 1020 + "gio-sys", 1021 1021 + "glib-sys", 1022 1022 + "gobject-sys", 1023 1023 + "libc", 1024 1024 + "system-deps", 1025 1025 + ] 1026 1026 + 1027 1027 + [[package]] 1028 1028 + name = "gdk4" 1029 1029 + version = "0.10.3" 1030 1030 + source = "registry+https://github.com/rust-lang/crates.io-index" 1031 1031 + checksum = "756564212bbe4a4ce05d88ffbd2582581ac6003832d0d32822d0825cca84bfbf" 1032 1032 + dependencies = [ 1033 1033 + "cairo-rs", 1034 1034 + "gdk-pixbuf", 1035 1035 + "gdk4-sys", 1036 1036 + "gio", 1037 1037 + "glib", 1038 1038 + "libc", 1039 1039 + "pango", 1040 1040 + ] 1041 1041 + 1042 1042 + [[package]] 1043 1043 + name = "gdk4-sys" 1044 1044 + version = "0.10.3" 1045 1045 + source = "registry+https://github.com/rust-lang/crates.io-index" 1046 1046 + checksum = "a6d4e5b3ccf591826a4adcc83f5f57b4e59d1925cb4bf620b0d645f79498b034" 1047 1047 + dependencies = [ 1048 1048 + "cairo-sys-rs", 1049 1049 + "gdk-pixbuf-sys", 1050 1050 + "gio-sys", 1051 1051 + "glib-sys", 1052 1052 + "gobject-sys", 1053 1053 + "libc", 1054 1054 + "pango-sys", 1055 1055 + "pkg-config", 1056 1056 + "system-deps", 1057 1057 + ] 1058 1058 + 1059 1059 + [[package]] 970 1060 name = "generic-array" 971 1061 version = "0.14.7" 972 1062 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 997 1087 "libc", 998 1088 "r-efi", 999 1089 "wasip2", 1090 1090 + ] 1091 1091 + 1092 1092 + [[package]] 1093 1093 + name = "gio" 1094 1094 + version = "0.21.5" 1095 1095 + source = "registry+https://github.com/rust-lang/crates.io-index" 1096 1096 + checksum = "c5ff48bf600c68b476e61dc6b7c762f2f4eb91deef66583ba8bb815c30b5811a" 1097 1097 + dependencies = [ 1098 1098 + "futures-channel", 1099 1099 + "futures-core", 1100 1100 + "futures-io", 1101 1101 + "futures-util", 1102 1102 + "gio-sys", 1103 1103 + "glib", 1104 1104 + "libc", 1105 1105 + "pin-project-lite", 1106 1106 + "smallvec", 1000 1107 ] 1001 1108 1002 1109 [[package]] ··· 1086 1193 ] 1087 1194 1088 1195 [[package]] 1196 1196 + name = "graphene-rs" 1197 1197 + version = "0.21.5" 1198 1198 + source = "registry+https://github.com/rust-lang/crates.io-index" 1199 1199 + checksum = "2730030ac9db663fd8bfe1e7093742c1cafb92db9c315c9417c29032341fe2f9" 1200 1200 + dependencies = [ 1201 1201 + "glib", 1202 1202 + "graphene-sys", 1203 1203 + "libc", 1204 1204 + ] 1205 1205 + 1206 1206 + [[package]] 1207 1207 + name = "graphene-sys" 1208 1208 + version = "0.21.5" 1209 1209 + source = "registry+https://github.com/rust-lang/crates.io-index" 1210 1210 + checksum = "915e32091ea9ad241e4b044af62b7351c2d68aeb24f489a0d7f37a0fc484fd93" 1211 1211 + dependencies = [ 1212 1212 + "glib-sys", 1213 1213 + "libc", 1214 1214 + "pkg-config", 1215 1215 + "system-deps", 1216 1216 + ] 1217 1217 + 1218 1218 + [[package]] 1219 1219 + name = "gsk4" 1220 1220 + version = "0.10.3" 1221 1221 + source = "registry+https://github.com/rust-lang/crates.io-index" 1222 1222 + checksum = "e755de9d8c5896c5beaa028b89e1969d067f1b9bf1511384ede971f5983aa153" 1223 1223 + dependencies = [ 1224 1224 + "cairo-rs", 1225 1225 + "gdk4", 1226 1226 + "glib", 1227 1227 + "graphene-rs", 1228 1228 + "gsk4-sys", 1229 1229 + "libc", 1230 1230 + "pango", 1231 1231 + ] 1232 1232 + 1233 1233 + [[package]] 1234 1234 + name = "gsk4-sys" 1235 1235 + version = "0.10.3" 1236 1236 + source = "registry+https://github.com/rust-lang/crates.io-index" 1237 1237 + checksum = "7ce91472391146f482065f1041876d8f869057b195b95399414caa163d72f4f7" 1238 1238 + dependencies = [ 1239 1239 + "cairo-sys-rs", 1240 1240 + "gdk4-sys", 1241 1241 + "glib-sys", 1242 1242 + "gobject-sys", 1243 1243 + "graphene-sys", 1244 1244 + "libc", 1245 1245 + "pango-sys", 1246 1246 + "system-deps", 1247 1247 + ] 1248 1248 + 1249 1249 + [[package]] 1250 1250 + name = "gtk4" 1251 1251 + version = "0.10.3" 1252 1252 + source = "registry+https://github.com/rust-lang/crates.io-index" 1253 1253 + checksum = "acb21d53cfc6f7bfaf43549731c43b67ca47d87348d81c8cfc4dcdd44828e1a4" 1254 1254 + dependencies = [ 1255 1255 + "cairo-rs", 1256 1256 + "field-offset", 1257 1257 + "futures-channel", 1258 1258 + "gdk-pixbuf", 1259 1259 + "gdk4", 1260 1260 + "gio", 1261 1261 + "glib", 1262 1262 + "graphene-rs", 1263 1263 + "gsk4", 1264 1264 + "gtk4-macros", 1265 1265 + "gtk4-sys", 1266 1266 + "libc", 1267 1267 + "pango", 1268 1268 + ] 1269 1269 + 1270 1270 + [[package]] 1271 1271 + name = "gtk4-macros" 1272 1272 + version = "0.10.3" 1273 1273 + source = "registry+https://github.com/rust-lang/crates.io-index" 1274 1274 + checksum = "3ccfb5a14a3d941244815d5f8101fa12d4577b59cc47245778d8d907b0003e42" 1275 1275 + dependencies = [ 1276 1276 + "proc-macro-crate", 1277 1277 + "proc-macro2", 1278 1278 + "quote", 1279 1279 + "syn 2.0.114", 1280 1280 + ] 1281 1281 + 1282 1282 + [[package]] 1283 1283 + name = "gtk4-sys" 1284 1284 + version = "0.10.3" 1285 1285 + source = "registry+https://github.com/rust-lang/crates.io-index" 1286 1286 + checksum = "842577fe5a1ee15d166cd3afe804ce0cab6173bc789ca32e21308834f20088dd" 1287 1287 + dependencies = [ 1288 1288 + "cairo-sys-rs", 1289 1289 + "gdk-pixbuf-sys", 1290 1290 + "gdk4-sys", 1291 1291 + "gio-sys", 1292 1292 + "glib-sys", 1293 1293 + "gobject-sys", 1294 1294 + "graphene-sys", 1295 1295 + "gsk4-sys", 1296 1296 + "libc", 1297 1297 + "pango-sys", 1298 1298 + "system-deps", 1299 1299 + ] 1300 1300 + 1301 1301 + [[package]] 1089 1302 name = "hashbrown" 1090 1303 version = "0.14.5" 1091 1304 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 1409 1622 ] 1410 1623 1411 1624 [[package]] 1625 1625 + name = "libadwaita" 1626 1626 + version = "0.8.1" 1627 1627 + source = "registry+https://github.com/rust-lang/crates.io-index" 1628 1628 + checksum = "fb09e12bf8f73342b3315c839d0a7668cc0ccebd78490c49fec48bab15d5484b" 1629 1629 + dependencies = [ 1630 1630 + "gdk4", 1631 1631 + "gio", 1632 1632 + "glib", 1633 1633 + "gtk4", 1634 1634 + "libadwaita-sys", 1635 1635 + "libc", 1636 1636 + "pango", 1637 1637 + ] 1638 1638 + 1639 1639 + [[package]] 1640 1640 + name = "libadwaita-sys" 1641 1641 + version = "0.8.1" 1642 1642 + source = "registry+https://github.com/rust-lang/crates.io-index" 1643 1643 + checksum = "6d7f94227ba87eb596fecada2491f04e357d507324142f77bf76d9e6be4a3e31" 1644 1644 + dependencies = [ 1645 1645 + "gdk4-sys", 1646 1646 + "gio-sys", 1647 1647 + "glib-sys", 1648 1648 + "gobject-sys", 1649 1649 + "gtk4-sys", 1650 1650 + "libc", 1651 1651 + "pango-sys", 1652 1652 + "system-deps", 1653 1653 + ] 1654 1654 + 1655 1655 + [[package]] 1412 1656 name = "libc" 1413 1657 version = "0.2.180" 1414 1658 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 1547 1791 version = "2.7.6" 1548 1792 source = "registry+https://github.com/rust-lang/crates.io-index" 1549 1793 checksum = "f52b00d39961fc5b2736ea853c9cc86238e165017a493d1d5c8eac6bdc4cc273" 1794 1794 + 1795 1795 + [[package]] 1796 1796 + name = "memoffset" 1797 1797 + version = "0.9.1" 1798 1798 + source = "registry+https://github.com/rust-lang/crates.io-index" 1799 1799 + checksum = "488016bfae457b036d996092f6cb448677611ce4449e970ceaf42695203f218a" 1800 1800 + dependencies = [ 1801 1801 + "autocfg", 1802 1802 + ] 1550 1803 1551 1804 [[package]] 1552 1805 name = "metaflac" ··· 1721 1974 checksum = "04744f49eae99ab78e0d5c0b603ab218f515ea8cfe5a456d7629ad883a3b6e7d" 1722 1975 1723 1976 [[package]] 1977 1977 + name = "pango" 1978 1978 + version = "0.21.5" 1979 1979 + source = "registry+https://github.com/rust-lang/crates.io-index" 1980 1980 + checksum = "52d1d85e2078077a065bb7fc072783d5bcd4e51b379f22d67107d0a16937eb69" 1981 1981 + dependencies = [ 1982 1982 + "gio", 1983 1983 + "glib", 1984 1984 + "libc", 1985 1985 + "pango-sys", 1986 1986 + ] 1987 1987 + 1988 1988 + [[package]] 1989 1989 + name = "pango-sys" 1990 1990 + version = "0.21.5" 1991 1991 + source = "registry+https://github.com/rust-lang/crates.io-index" 1992 1992 + checksum = "b4f06627d36ed5ff303d2df65211fc2e52ba5b17bf18dd80ff3d9628d6e06cfd" 1993 1993 + dependencies = [ 1994 1994 + "glib-sys", 1995 1995 + "gobject-sys", 1996 1996 + "libc", 1997 1997 + "system-deps", 1998 1998 + ] 1999 1999 + 2000 2000 + [[package]] 1724 2001 name = "parking" 1725 2002 version = "2.2.1" 1726 2003 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 2131 2408 checksum = "357703d41365b4b27c590e3ed91eabb1b663f07c4c084095e60cbed4362dff0d" 2132 2409 2133 2410 [[package]] 2411 2411 + name = "rustc_version" 2412 2412 + version = "0.4.1" 2413 2413 + source = "registry+https://github.com/rust-lang/crates.io-index" 2414 2414 + checksum = "cfcb3a22ef46e85b45de6ee7e79d063319ebb6594faafcf1c225ea92ab6e9b92" 2415 2415 + dependencies = [ 2416 2416 + "semver", 2417 2417 + ] 2418 2418 + 2419 2419 + [[package]] 2134 2420 name = "rustix" 2135 2421 version = "0.37.28" 2136 2422 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 2190 2476 version = "1.2.0" 2191 2477 source = "registry+https://github.com/rust-lang/crates.io-index" 2192 2478 checksum = "94143f37725109f92c262ed2cf5e59bce7498c01bcc1502d7b9afe439a4e9f49" 2479 2479 + 2480 2480 + [[package]] 2481 2481 + name = "semver" 2482 2482 + version = "1.0.27" 2483 2483 + source = "registry+https://github.com/rust-lang/crates.io-index" 2484 2484 + checksum = "d767eb0aabc880b29956c35734170f26ed551a859dbd361d140cdbeca61ab1e2" 2193 2485 2194 2486 [[package]] 2195 2487 name = "serde" ··· 2859 3151 "fs_extra", 2860 3152 "futures", 2861 3153 "glib", 3154 3154 + "gtk4", 2862 3155 "indicatif", 2863 3156 "infer", 3157 3157 + "libadwaita", 2864 3158 "libc", 2865 3159 "lofty", 2866 3160 "log",

+2

Cargo.toml

reviewed

··· 53 53 infer = "0.19.0" 54 54 sysinfo = "0.37.2" 55 55 lofty = "0.22.4" 56 56 + gtk4 = { version = "0.10.3", features = ["v4_20"] } 57 57 + libadwaita = { version = "0.8.1", features = ["v1_6"] } 56 58 57 59 # Re-enable those and compile with "gui" feature when you're ready 58 60 # to tackle GUI again.

+1

src/db/instance.rs

reviewed

··· 11 11 12 12 static DATABASE_DEFAULT_NAME: &str = "tunz.db"; 13 13 14 14 + #[derive(Clone)] 14 15 pub struct Instance { 15 16 pool: SqlitePool, 16 17 }

+710

src/gtkgui/gtkgui.rs

reviewed

··· 1 1 + use std::cell::RefCell; 2 2 + use std::rc::Rc; 3 3 + 4 4 + use anyhow::Result; 5 5 + use glib::BoxedAnyObject; 6 6 + use gtk::{ 7 7 + ColumnView, ColumnViewColumn, CustomSorter, FileDialog, Label, ListItem, MenuButton, Ordering, 8 8 + PolicyType, ScrolledWindow, SignalListItemFactory, SortListModel, SortType, StringList, gio, 9 9 + }; 10 10 + use gtk4 as gtk; 11 11 + use libadwaita as adw; 12 12 + use libadwaita::prelude::*; 13 13 + 14 14 + use crate::db::{self, Instance}; 15 15 + use crate::ffmpeg::{Codec, SamplingRate}; 16 16 + use crate::model::Track; 17 17 + 18 18 + pub async fn run() -> Result<()> { 19 19 + let app = adw::Application::builder() 20 20 + .application_id("industries.geesawra.tunz") 21 21 + .build(); 22 22 + 23 23 + app.connect_activate(build_ui); 24 24 + 25 25 + app.run(); 26 26 + 27 27 + Ok(()) 28 28 + } 29 29 + 30 30 + fn build_ui(app: &adw::Application) { 31 31 + let manager = adw::StyleManager::default(); 32 32 + manager.set_color_scheme(adw::ColorScheme::Default); 33 33 + 34 34 + let db_state = Rc::new(RefCell::new(None)); 35 35 + 36 36 + // Setup Actions 37 37 + setup_actions(app, db_state.clone()); 38 38 + 39 39 + let window = adw::ApplicationWindow::builder() 40 40 + .application(app) 41 41 + .title("Tunz Library") 42 42 + .default_width(800) 43 43 + .default_height(600) 44 44 + .build(); 45 45 + 46 46 + let store = gtk::gio::ListStore::new::<BoxedAnyObject>(); 47 47 + 48 48 + // Initially Create SortListModel without a sorter 49 49 + let sort_model = SortListModel::new(Some(store.clone()), None::<gtk::Sorter>); 50 50 + let selection_model = gtk::NoSelection::new(Some(sort_model.clone())); 51 51 + 52 52 + let column_view = ColumnView::new(Some(selection_model)); 53 53 + column_view.set_vexpand(true); 54 54 + column_view.set_hexpand(true); 55 55 + 56 56 + let title_col = add_column( 57 57 + &column_view, 58 58 + "Title", 59 59 + |t: &Track| t.title.clone(), 60 60 + |a, b| a.title.cmp(&b.title).into(), 61 61 + Some(200), 62 62 + true, 63 63 + ); 64 64 + add_column( 65 65 + &column_view, 66 66 + "Artist", 67 67 + |t: &Track| t.artist.clone(), 68 68 + |a, b| a.artist.cmp(&b.artist).into(), 69 69 + Some(200), 70 70 + true, 71 71 + ); 72 72 + add_column( 73 73 + &column_view, 74 74 + "Album", 75 75 + |t: &Track| t.album.clone(), 76 76 + |a, b| a.album.cmp(&b.album).into(), 77 77 + Some(200), 78 78 + true, 79 79 + ); 80 80 + add_column( 81 81 + &column_view, 82 82 + "Format", 83 83 + |t: &Track| t.extension.to_uppercase(), 84 84 + |a, b| a.extension.cmp(&b.extension).into(), 85 85 + Some(50), 86 86 + true, 87 87 + ); 88 88 + 89 89 + // Set the sorter on the model to use the column view's sorter 90 90 + if let Some(sorter) = column_view.sorter() { 91 91 + sort_model.set_sorter(Some(&sorter)); 92 92 + } 93 93 + 94 94 + // Default sort: Ascending by Title 95 95 + column_view.sort_by_column(Some(&title_col), SortType::Ascending); 96 96 + 97 97 + let scrolled_window = ScrolledWindow::builder() 98 98 + .hscrollbar_policy(PolicyType::Automatic) 99 99 + .min_content_width(360) 100 100 + .vexpand(true) 101 101 + .hexpand(true) 102 102 + .child(&column_view) 103 103 + .build(); 104 104 + 105 105 + let header_bar = adw::HeaderBar::new(); 106 106 + 107 107 + // Menu Setup 108 108 + let menu = gio::Menu::new(); 109 109 + menu.append(Some("Sources"), Some("app.sources")); 110 110 + menu.append(Some("Update"), Some("app.update")); 111 111 + menu.append(Some("Sync"), Some("app.sync")); 112 112 + menu.append(Some("Quit"), Some("app.quit")); 113 113 + 114 114 + let menu_button = MenuButton::builder() 115 115 + .icon_name("open-menu-symbolic") 116 116 + .menu_model(&menu) 117 117 + .build(); 118 118 + 119 119 + header_bar.pack_end(&menu_button); 120 120 + 121 121 + let toolbar_view = adw::ToolbarView::builder() 122 122 + .content(&scrolled_window) 123 123 + .build(); 124 124 + 125 125 + toolbar_view.add_top_bar(&header_bar); 126 126 + 127 127 + window.set_content(Some(&toolbar_view)); 128 128 + window.present(); 129 129 + 130 130 + let window_weak = window.downgrade(); 131 131 + glib::MainContext::default().spawn_local(async move { 132 132 + let db_dir = db::default_database_dir(); 133 133 + let db_dir_str = db_dir.to_str().expect("Invalid path"); 134 134 + 135 135 + match Instance::new(db_dir_str, false).await { 136 136 + Ok(instance) => { 137 137 + *db_state.borrow_mut() = Some(instance.clone()); 138 138 + 139 139 + match instance.tracks_iter().await { 140 140 + Ok(rx) => { 141 141 + let mut buffer = Vec::new(); 142 142 + let batch_size = 1000; 143 143 + 144 144 + while let Ok(res_track) = rx.recv().await { 145 145 + if let Ok(track) = res_track { 146 146 + buffer.push(BoxedAnyObject::new(track)); 147 147 + if buffer.len() >= batch_size { 148 148 + store.splice(store.n_items(), 0, &buffer); 149 149 + buffer.clear(); 150 150 + } 151 151 + } 152 152 + } 153 153 + if !buffer.is_empty() { 154 154 + store.splice(store.n_items(), 0, &buffer); 155 155 + } 156 156 + } 157 157 + Err(e) => { 158 158 + if let Some(window) = window_weak.upgrade() { 159 159 + show_error_dialog(&window, &format!("Failed to fetch tracks: {}", e)); 160 160 + } 161 161 + } 162 162 + } 163 163 + } 164 164 + Err(e) => { 165 165 + if let Some(window) = window_weak.upgrade() { 166 166 + show_error_dialog(&window, &format!("Failed to open database: {}", e)); 167 167 + } 168 168 + } 169 169 + } 170 170 + }); 171 171 + } 172 172 + 173 173 + fn setup_actions(app: &adw::Application, db_state: Rc<RefCell<Option<Instance>>>) { 174 174 + let action_quit = gio::SimpleAction::new("quit", None); 175 175 + let app_weak = app.downgrade(); 176 176 + action_quit.connect_activate(move |_, _| { 177 177 + if let Some(app) = app_weak.upgrade() { 178 178 + app.quit(); 179 179 + } 180 180 + }); 181 181 + app.add_action(&action_quit); 182 182 + 183 183 + let action_sources = gio::SimpleAction::new("sources", None); 184 184 + let app_weak = app.downgrade(); 185 185 + let db_state_clone = db_state.clone(); 186 186 + action_sources.connect_activate(move |_, _| { 187 187 + if let Some(app) = app_weak.upgrade() { 188 188 + if let Some(window) = app.active_window() { 189 189 + show_sources_dialog(&window, db_state_clone.clone()); 190 190 + } 191 191 + } 192 192 + }); 193 193 + app.add_action(&action_sources); 194 194 + 195 195 + let action_update = gio::SimpleAction::new("update", None); 196 196 + action_update.connect_activate(|_, _| { 197 197 + println!("Update clicked"); 198 198 + }); 199 199 + app.add_action(&action_update); 200 200 + 201 201 + let action_sync = gio::SimpleAction::new("sync", None); 202 202 + let app_weak = app.downgrade(); 203 203 + let db_state_clone = db_state.clone(); 204 204 + action_sync.connect_activate(move |_, _| { 205 205 + if let Some(app) = app_weak.upgrade() { 206 206 + if let Some(window) = app.active_window() { 207 207 + show_sync_dialog(&window, db_state_clone.clone()); 208 208 + } 209 209 + } 210 210 + }); 211 211 + app.add_action(&action_sync); 212 212 + } 213 213 + 214 214 + fn show_sources_dialog(parent: &impl IsA<gtk::Window>, db_state: Rc<RefCell<Option<Instance>>>) { 215 215 + let dialog = adw::Window::builder() 216 216 + .transient_for(parent) 217 217 + .modal(true) 218 218 + .title("Sources") 219 219 + .default_width(500) 220 220 + .default_height(400) 221 221 + .build(); 222 222 + 223 223 + let header_bar = adw::HeaderBar::new(); 224 224 + 225 225 + let clamp = adw::Clamp::new(); 226 226 + clamp.set_maximum_size(600); 227 227 + clamp.set_margin_top(24); 228 228 + clamp.set_margin_bottom(24); 229 229 + clamp.set_margin_start(12); 230 230 + clamp.set_margin_end(12); 231 231 + 232 232 + let scrolled = ScrolledWindow::builder() 233 233 + .child(&clamp) 234 234 + .vexpand(true) 235 235 + .build(); 236 236 + 237 237 + let toolbar_view = adw::ToolbarView::builder().content(&scrolled).build(); 238 238 + 239 239 + toolbar_view.add_top_bar(&header_bar); 240 240 + 241 241 + dialog.set_content(Some(&toolbar_view)); 242 242 + 243 243 + // Load sources 244 244 + let clamp_weak = clamp.downgrade(); 245 245 + let dialog_weak = dialog.downgrade(); 246 246 + let db_state_clone = db_state.clone(); 247 247 + glib::MainContext::default().spawn_local(async move { 248 248 + if let (Some(clamp), Some(dialog)) = (clamp_weak.upgrade(), dialog_weak.upgrade()) { 249 249 + refresh_sources_list(&clamp, &dialog, db_state_clone).await; 250 250 + } 251 251 + }); 252 252 + 253 253 + dialog.present(); 254 254 + } 255 255 + 256 256 + async fn refresh_sources_list( 257 257 + clamp: &adw::Clamp, 258 258 + window: &impl IsA<gtk::Window>, 259 259 + db_state: Rc<RefCell<Option<Instance>>>, 260 260 + ) { 261 261 + let group = adw::PreferencesGroup::new(); 262 262 + group.set_title("Configured Sources"); 263 263 + 264 264 + let instance = { db_state.borrow().clone() }; 265 265 + if let Some(instance) = instance { 266 266 + match instance.directories().await { 267 267 + Ok(dirs) => { 268 268 + for dir in dirs { 269 269 + let row = adw::ActionRow::builder().title(&dir).build(); 270 270 + group.add(&row); 271 271 + } 272 272 + } 273 273 + Err(e) => { 274 274 + show_error_dialog(window, &format!("Failed to load directories: {}", e)); 275 275 + } 276 276 + } 277 277 + } 278 278 + 279 279 + // Add "Add Source..." row 280 280 + let add_row = adw::ActionRow::builder() 281 281 + .title("Add Source...") 282 282 + .activatable(true) 283 283 + .build(); 284 284 + add_row.add_prefix(&gtk::Image::from_icon_name("list-add-symbolic")); 285 285 + 286 286 + // We need to keep window alive for callback, but we can't clone `&impl IsA<gtk::Window>`. 287 287 + // We can't downgrade `&impl IsA<gtk::Window>` directly without knowing it's an Object. 288 288 + // IsA<T> implies IsA<Object>. 289 289 + let window_obj = window.as_ref(); // &Object 290 290 + let window_weak = window_obj.downgrade(); 291 291 + let clamp_weak = clamp.downgrade(); 292 292 + let db_state_clone = db_state.clone(); 293 293 + 294 294 + add_row.connect_activated(move |_| { 295 295 + let window_weak = window_weak.clone(); 296 296 + let clamp_weak = clamp_weak.clone(); 297 297 + let db_state_clone = db_state_clone.clone(); 298 298 + 299 299 + glib::MainContext::default().spawn_local(async move { 300 300 + // Upgrade to gtk::Window to use with FileDialog 301 301 + if let Some(window_obj) = window_weak.upgrade() { 302 302 + // We need to cast back to Window? No, FileDialog accepts &impl IsA<Window>. 303 303 + // Upgrade returns T where T is the Object type. Downgrade on &impl IsA<Window> might return WeakRef<Object>. 304 304 + // We can cast Object to Window. 305 305 + let dialog = window_obj.downcast::<gtk::Window>().ok(); 306 306 + if let Some(dialog) = dialog { 307 307 + let file_dialog = FileDialog::builder() 308 308 + .title("Select Source Directory") 309 309 + .modal(true) 310 310 + .build(); 311 311 + 312 312 + if let Ok(file) = file_dialog.select_folder_future(Some(&dialog)).await { 313 313 + if let Some(path) = file.path() { 314 314 + let path_str = path.to_string_lossy().to_string(); 315 315 + // Add to DB 316 316 + let instance = { db_state_clone.borrow().clone() }; 317 317 + if let Some(instance) = instance { 318 318 + if let Err(e) = instance.insert_directory(path_str).await { 319 319 + show_error_dialog( 320 320 + &dialog, 321 321 + &format!("Failed to insert directory: {}", e), 322 322 + ); 323 323 + } else { 324 324 + if let Some(clamp) = clamp_weak.upgrade() { 325 325 + refresh_sources_list(&clamp, &dialog, db_state_clone).await; 326 326 + } 327 327 + } 328 328 + } 329 329 + } 330 330 + } 331 331 + } 332 332 + } 333 333 + }); 334 334 + }); 335 335 + 336 336 + group.add(&add_row); 337 337 + 338 338 + clamp.set_child(Some(&group)); 339 339 + } 340 340 + 341 341 + fn show_sync_dialog( 342 342 + parent: &impl IsA<gtk::Window>, 343 343 + _source_db_state: Rc<RefCell<Option<Instance>>>, 344 344 + ) { 345 345 + let dialog = adw::Window::builder() 346 346 + .transient_for(parent) 347 347 + .modal(true) 348 348 + .title("Sync") 349 349 + .default_width(500) 350 350 + .default_height(400) 351 351 + .build(); 352 352 + 353 353 + let header_bar = adw::HeaderBar::new(); 354 354 + let start_button = gtk::Button::builder() 355 355 + .label("Start") 356 356 + .css_classes(["suggested-action"]) 357 357 + .sensitive(false) 358 358 + .build(); 359 359 + header_bar.pack_end(&start_button); 360 360 + 361 361 + let page = adw::PreferencesPage::new(); 362 362 + let group = adw::PreferencesGroup::new(); 363 363 + group.set_title("Sync Configuration"); 364 364 + 365 365 + // Destination Database State 366 366 + let dest_db_state = Rc::new(RefCell::new(None)); 367 367 + 368 368 + // Destination 369 369 + let dest_row = adw::ActionRow::builder() 370 370 + .title("Destination") 371 371 + .subtitle("Select destination folder...") 372 372 + .activatable(true) 373 373 + .build(); 374 374 + 375 375 + // iPod 376 376 + let ipod_row = adw::SwitchRow::builder() 377 377 + .title("iPod Mode") 378 378 + .subtitle("Transcodes files to high-quality AAC (iTunes Plus equivalent) and updates the iPod database.") 379 379 + .sensitive(false) 380 380 + .build(); 381 381 + 382 382 + // Transcoding 383 383 + let transcode_row = adw::ActionRow::builder() 384 384 + .title("Transcoding Settings") 385 385 + .activatable(true) 386 386 + .sensitive(false) 387 387 + .build(); 388 388 + transcode_row.add_prefix(&gtk::Image::from_icon_name("emblem-system-symbolic")); 389 389 + 390 390 + // Callbacks 391 391 + let dialog_weak = dialog.downgrade(); 392 392 + let dest_row_weak = dest_row.downgrade(); 393 393 + let dest_db_state_clone = dest_db_state.clone(); 394 394 + let start_button_weak = start_button.downgrade(); 395 395 + let ipod_row_weak = ipod_row.downgrade(); 396 396 + let transcode_row_weak = transcode_row.downgrade(); 397 397 + 398 398 + dest_row.connect_activated(move |_| { 399 399 + let dialog_weak = dialog_weak.clone(); 400 400 + let dest_row_weak = dest_row_weak.clone(); 401 401 + let dest_db_state_clone = dest_db_state_clone.clone(); 402 402 + let start_button_weak = start_button_weak.clone(); 403 403 + let ipod_row_weak = ipod_row_weak.clone(); 404 404 + let transcode_row_weak = transcode_row_weak.clone(); 405 405 + 406 406 + glib::MainContext::default().spawn_local(async move { 407 407 + if let Some(dialog) = dialog_weak.upgrade() { 408 408 + let file_dialog = FileDialog::builder() 409 409 + .title("Select Destination Directory") 410 410 + .modal(true) 411 411 + .build(); 412 412 + if let Ok(file) = file_dialog.select_folder_future(Some(&dialog)).await { 413 413 + if let Some(path) = file.path() { 414 414 + let path_str = path.to_string_lossy().to_string(); 415 415 + if let Some(row) = dest_row_weak.upgrade() { 416 416 + row.set_subtitle(&path_str); 417 417 + } 418 418 + 419 419 + // Initialize Destination DB 420 420 + match Instance::new(&path_str, true).await { 421 421 + Ok(inst) => { 422 422 + *dest_db_state_clone.borrow_mut() = Some(inst); 423 423 + if let Some(btn) = start_button_weak.upgrade() { 424 424 + btn.set_sensitive(true); 425 425 + } 426 426 + if let Some(row) = ipod_row_weak.upgrade() { 427 427 + row.set_sensitive(true); 428 428 + } 429 429 + if let Some(row) = transcode_row_weak.upgrade() { 430 430 + row.set_sensitive(true); 431 431 + } 432 432 + } 433 433 + Err(e) => { 434 434 + show_error_dialog( 435 435 + &dialog, 436 436 + &format!("Failed to open destination DB: {}", e), 437 437 + ); 438 438 + } 439 439 + } 440 440 + } 441 441 + } 442 442 + } 443 443 + }); 444 444 + }); 445 445 + 446 446 + group.add(&dest_row); 447 447 + group.add(&ipod_row); 448 448 + 449 449 + let dest_db_state_clone = dest_db_state.clone(); 450 450 + let dialog_weak = dialog.downgrade(); 451 451 + transcode_row.connect_activated(move |_| { 452 452 + if let Some(dialog) = dialog_weak.upgrade() { 453 453 + show_transcoding_dialog(&dialog, dest_db_state_clone.clone()); 454 454 + } 455 455 + }); 456 456 + group.add(&transcode_row); 457 457 + 458 458 + page.add(&group); 459 459 + 460 460 + let toolbar_view = adw::ToolbarView::builder().content(&page).build(); 461 461 + 462 462 + toolbar_view.add_top_bar(&header_bar); 463 463 + 464 464 + dialog.set_content(Some(&toolbar_view)); 465 465 + dialog.present(); 466 466 + } 467 467 + 468 468 + fn show_transcoding_dialog( 469 469 + parent: &impl IsA<gtk::Window>, 470 470 + db_state: Rc<RefCell<Option<Instance>>>, 471 471 + ) { 472 472 + let dialog = adw::Window::builder() 473 473 + .transient_for(parent) 474 474 + .modal(true) 475 475 + .title("Transcoding Settings") 476 476 + .default_width(400) 477 477 + .default_height(350) 478 478 + .build(); 479 479 + 480 480 + let header_bar = adw::HeaderBar::new(); 481 481 + let save_button = gtk::Button::builder() 482 482 + .label("Save") 483 483 + .css_classes(["suggested-action"]) 484 484 + .build(); 485 485 + header_bar.pack_end(&save_button); 486 486 + 487 487 + let page = adw::PreferencesPage::new(); 488 488 + let group = adw::PreferencesGroup::new(); 489 489 + group.set_title("Settings"); 490 490 + 491 491 + // Codec 492 492 + let codec_model = StringList::new(&["AAC", "MP3", "OGG", "Opus"]); 493 493 + let codec_row = adw::ComboRow::builder() 494 494 + .title("Codec") 495 495 + .model(&codec_model) 496 496 + .build(); 497 497 + group.add(&codec_row); 498 498 + 499 499 + // Bitrate Mode 500 500 + let mode_model = StringList::new(&["Constant Bitrate (CBR)", "Variable Bitrate (VBR)"]); 501 501 + let mode_row = adw::ComboRow::builder() 502 502 + .title("Bitrate Mode") 503 503 + .model(&mode_model) 504 504 + .build(); 505 505 + group.add(&mode_row); 506 506 + 507 507 + // Bitrate Value 508 508 + let value_row = adw::EntryRow::builder().title("Bitrate Value").build(); 509 509 + group.add(&value_row); 510 510 + 511 511 + // Sampling Rate 512 512 + let rate_model = StringList::new(&["44100", "48000"]); 513 513 + let rate_row = adw::ComboRow::builder() 514 514 + .title("Sampling Rate") 515 515 + .model(&rate_model) 516 516 + .build(); 517 517 + group.add(&rate_row); 518 518 + 519 519 + page.add(&group); 520 520 + 521 521 + let toolbar_view = adw::ToolbarView::builder().content(&page).build(); 522 522 + 523 523 + toolbar_view.add_top_bar(&header_bar); 524 524 + 525 525 + dialog.set_content(Some(&toolbar_view)); 526 526 + 527 527 + // Load settings 528 528 + let db_state_clone = db_state.clone(); 529 529 + let codec_row_weak = codec_row.downgrade(); 530 530 + let mode_row_weak = mode_row.downgrade(); 531 531 + let value_row_weak = value_row.downgrade(); 532 532 + let rate_row_weak = rate_row.downgrade(); 533 533 + 534 534 + glib::MainContext::default().spawn_local(async move { 535 535 + let instance = { db_state_clone.borrow().clone() }; 536 536 + if let Some(instance) = instance { 537 537 + if let Ok(Some(settings)) = instance.get_transcoding_settings().await { 538 538 + if let Some(row) = codec_row_weak.upgrade() { 539 539 + let idx = match settings.codec { 540 540 + Codec::AAC => 0, 541 541 + Codec::MP3 => 1, 542 542 + Codec::OGG => 2, 543 543 + Codec::Opus => 3, 544 544 + }; 545 545 + row.set_selected(idx); 546 546 + } 547 547 + 548 548 + let bitrate_str = settings.bitrate.to_string(); 549 549 + if let Some(row) = mode_row_weak.upgrade() { 550 550 + if bitrate_str.starts_with("vbr") { 551 551 + row.set_selected(1); 552 552 + } else { 553 553 + row.set_selected(0); 554 554 + } 555 555 + } 556 556 + if let Some(row) = value_row_weak.upgrade() { 557 557 + let parts: Vec<&str> = bitrate_str.split(':').collect(); 558 558 + if parts.len() > 1 { 559 559 + let val = parts[1].trim_end_matches('k'); 560 560 + row.set_text(val); 561 561 + } 562 562 + } 563 563 + 564 564 + if let Some(row) = rate_row_weak.upgrade() { 565 565 + let idx = match settings.sampling_rate { 566 566 + Some(SamplingRate::Rate441K) => 0, 567 567 + Some(SamplingRate::Rate48K) => 1, 568 568 + _ => 0, 569 569 + }; 570 570 + row.set_selected(idx); 571 571 + } 572 572 + } 573 573 + } 574 574 + }); 575 575 + 576 576 + // Save handler 577 577 + let db_state_clone = db_state.clone(); 578 578 + let dialog_weak = dialog.downgrade(); 579 579 + save_button.connect_clicked(move |_| { 580 580 + let codec_idx = codec_row.selected(); 581 581 + let mode_idx = mode_row.selected(); 582 582 + let val = value_row.text().to_string(); 583 583 + let rate_idx = rate_row.selected(); 584 584 + let db_state_clone = db_state_clone.clone(); 585 585 + let dialog_weak = dialog_weak.clone(); 586 586 + 587 587 + glib::MainContext::default().spawn_local(async move { 588 588 + let codec = match codec_idx { 589 589 + 0 => "aac", 590 590 + 1 => "mp3", 591 591 + 2 => "ogg", 592 592 + 3 => "opus", 593 593 + _ => "aac", 594 594 + } 595 595 + .to_string(); 596 596 + 597 597 + let bitrate = if mode_idx == 1 { 598 598 + format!("vbr:{}", val) 599 599 + } else { 600 600 + if val.ends_with('k') { 601 601 + format!("cbr:{}", val) 602 602 + } else { 603 603 + format!("cbr:{}k", val) 604 604 + } 605 605 + }; 606 606 + 607 607 + let rate = match rate_idx { 608 608 + 0 => "44100", 609 609 + 1 => "48000", 610 610 + _ => "44100", 611 611 + } 612 612 + .to_string(); 613 613 + 614 614 + let instance = { db_state_clone.borrow().clone() }; 615 615 + if let Some(instance) = instance { 616 616 + if let Err(e) = instance 617 617 + .set_transcoding_settings(Some(codec), Some(bitrate), Some(rate)) 618 618 + .await 619 619 + { 620 620 + if let Some(dialog) = dialog_weak.upgrade() { 621 621 + show_error_dialog(&dialog, &format!("Failed to save settings: {}", e)); 622 622 + } 623 623 + } else { 624 624 + if let Some(dialog) = dialog_weak.upgrade() { 625 625 + dialog.close(); 626 626 + } 627 627 + } 628 628 + } 629 629 + }); 630 630 + }); 631 631 + 632 632 + dialog.present(); 633 633 + } 634 634 + 635 635 + fn show_error_dialog(parent: &impl IsA<gtk::Window>, message: &str) { 636 636 + let dialog = adw::AlertDialog::builder() 637 637 + .heading("Error") 638 638 + .body(message) 639 639 + .build(); 640 640 + dialog.add_response("ok", "OK"); 641 641 + dialog.present(Some(parent.as_ref())); 642 642 + } 643 643 + 644 644 + fn add_column<F, C>( 645 645 + column_view: &ColumnView, 646 646 + title: &str, 647 647 + getter: F, 648 648 + comparator: C, 649 649 + fixed_width: Option<i32>, 650 650 + expand: bool, 651 651 + ) -> ColumnViewColumn 652 652 + where 653 653 + F: Fn(&Track) -> String + 'static + Clone, 654 654 + C: Fn(&Track, &Track) -> Ordering + 'static + Clone, 655 655 + { 656 656 + let factory = SignalListItemFactory::new(); 657 657 + let getter = Rc::new(getter); 658 658 + 659 659 + factory.connect_setup(move |_, list_item| { 660 660 + let list_item = list_item 661 661 + .downcast_ref::<ListItem>() 662 662 + .expect("Needs to be ListItem"); 663 663 + let label = Label::new(None); 664 664 + label.set_xalign(0.0); 665 665 + label.set_hexpand(false); 666 666 + label.set_ellipsize(gtk::pango::EllipsizeMode::End); 667 667 + list_item.set_child(Some(&label)); 668 668 + }); 669 669 + 670 670 + let getter_clone = getter.clone(); 671 671 + factory.connect_bind(move |_, list_item| { 672 672 + let list_item = list_item 673 673 + .downcast_ref::<ListItem>() 674 674 + .expect("Needs to be ListItem"); 675 675 + let label = list_item 676 676 + .child() 677 677 + .and_downcast::<Label>() 678 678 + .expect("ListItem child is not a Label"); 679 679 + let item = list_item 680 680 + .item() 681 681 + .and_downcast::<BoxedAnyObject>() 682 682 + .expect("ListItem item is not a BoxedAnyObject"); 683 683 + let track = item.borrow::<Track>(); 684 684 + label.set_label(&getter_clone(&track)); 685 685 + }); 686 686 + 687 687 + let column = ColumnViewColumn::builder() 688 688 + .title(title) 689 689 + .factory(&factory) 690 690 + .build(); 691 691 + 692 692 + if let Some(width) = fixed_width { 693 693 + column.set_fixed_width(width); 694 694 + } 695 695 + 696 696 + column.set_expand(expand); 697 697 + column.set_resizable(true); 698 698 + 699 699 + let sorter = CustomSorter::new(move |a, b| { 700 700 + let a = a.downcast_ref::<BoxedAnyObject>().unwrap(); 701 701 + let b = b.downcast_ref::<BoxedAnyObject>().unwrap(); 702 702 + let track_a = a.borrow::<Track>(); 703 703 + let track_b = b.borrow::<Track>(); 704 704 + comparator(&track_a, &track_b) 705 705 + }); 706 706 + column.set_sorter(Some(&sorter)); 707 707 + 708 708 + column_view.append_column(&column); 709 709 + column 710 710 + }

+2

src/gtkgui/mod.rs

reviewed

··· 1 1 + mod gtkgui; 2 2 + pub use gtkgui::run;

+5

src/main.rs

reviewed

··· 6 6 mod filter; 7 7 mod fs; 8 8 mod gpod; 9 9 + mod gtkgui; 9 10 mod gui; 10 11 mod model; 11 12 ··· 20 21 if std::env::args().count() == 1 { 21 22 return gui::run().await; 22 23 } 24 24 + } 25 25 + 26 26 + if std::env::args().count() == 1 { 27 27 + return gtkgui::run().await; 23 28 } 24 29 25 30 let c = cli::Cli::parse();