Compare commits

...

3 Commits

Author SHA1 Message Date
austinried
aaab1d1278 refactor artist to use coverArt
fix cover art image caching
2025-11-09 17:11:35 +09:00
austinried
42ff02f88e don't need these prints now 2025-11-09 17:04:53 +09:00
austinried
d18ca13f48 artist list with images 2025-11-09 15:48:20 +09:00
20 changed files with 297 additions and 108 deletions

View File

@ -2,32 +2,66 @@
import { SubsonicClient } from "./util/subsonic.ts"; import { SubsonicClient } from "./util/subsonic.ts";
import { sleep } from "./util/util.ts"; import { sleep } from "./util/util.ts";
async function getArtistId(
client: SubsonicClient,
artist: string,
): Promise<string> {
const { xml } = await client.get("getArtists");
return xml.querySelector(
`artist[name='${artist.replaceAll("'", "\\'")}']`,
)?.id!;
}
async function getAlbumId(
client: SubsonicClient,
album: string,
): Promise<string> {
const { xml } = await client.get("getAlbumList2", [
["type", "newest"],
]);
return xml.querySelector(
`album[name='${album.replaceAll("'", "\\'")}']`,
)?.id!;
}
async function getSongId( async function getSongId(
client: SubsonicClient, client: SubsonicClient,
album: string, album: string,
track: number, track: number,
): Promise<string> { ): Promise<string> {
const { xml: albumsXml } = await client.get("getAlbumList2", [ const albumId = await getAlbumId(client, album);
["type", "newest"],
]);
const albumId = albumsXml.querySelector(
`album[name='${album.replaceAll("'", "\\'")}']`,
)?.id;
const { xml: songsXml } = await client.get("getAlbum", [["id", albumId!]]); const { xml } = await client.get("getAlbum", [["id", albumId!]]);
return songsXml.querySelector(`song[track='${track}']`)?.id!; return xml.querySelector(`song[track='${track}']`)?.id!;
} }
async function scrobbleTrack( async function scrobbleTrack(
client: SubsonicClient, client: SubsonicClient,
songId: string, album: string,
track: number,
) { ) {
const songId = await getSongId(client, album, track);
await client.get("scrobble", [ await client.get("scrobble", [
["id", songId!], ["id", songId!],
["submission", "true"], ["submission", "true"],
]); ]);
} }
async function starAlbum(client: SubsonicClient, album: string) {
const albumId = await getAlbumId(client, album);
await client.get("star", [["albumId", albumId]]);
}
async function starArtist(client: SubsonicClient, artist: string) {
const artistId = await getArtistId(client, artist);
await client.get("star", [["artistId", artistId]]);
}
async function createPlaylist( async function createPlaylist(
client: SubsonicClient, client: SubsonicClient,
name: string, name: string,
@ -44,17 +78,11 @@ async function createPlaylist(
} }
async function setupTestData(client: SubsonicClient) { async function setupTestData(client: SubsonicClient) {
await scrobbleTrack( await scrobbleTrack(client, "Retroconnaissance EP", 1);
client,
await getSongId(client, "Retroconnaissance EP", 1),
);
await sleep(1_000); await sleep(1_000);
await scrobbleTrack( await scrobbleTrack(client, "Retroconnaissance EP", 2);
client,
await getSongId(client, "Retroconnaissance EP", 2),
);
await sleep(1_000); await sleep(1_000);
await scrobbleTrack(client, await getSongId(client, "Kosmonaut", 1)); await scrobbleTrack(client, "Kosmonaut", 1);
await createPlaylist(client, "Playlist 1", [ await createPlaylist(client, "Playlist 1", [
{ album: "Retroconnaissance EP", track: 2 }, { album: "Retroconnaissance EP", track: 2 },
@ -65,6 +93,9 @@ async function setupTestData(client: SubsonicClient) {
{ album: "I Don't Know What I'm Doing", track: 10 }, { album: "I Don't Know What I'm Doing", track: 10 },
{ album: "I Don't Know What I'm Doing", track: 11 }, { album: "I Don't Know What I'm Doing", track: 11 },
]); ]);
await starAlbum(client, "Kosmonaut");
await starArtist(client, "Ugress");
} }
async function setupNavidrome() { async function setupNavidrome() {

View File

@ -10,7 +10,7 @@ import '../state/database.dart';
import '../state/settings.dart'; import '../state/settings.dart';
import 'list_items.dart'; import 'list_items.dart';
const kPageSize = 30; const kPageSize = 60;
class AlbumsGrid extends HookConsumerWidget { class AlbumsGrid extends HookConsumerWidget {
const AlbumsGrid({super.key}); const AlbumsGrid({super.key});

View File

@ -0,0 +1,81 @@
import 'package:drift/drift.dart';
import 'package:flutter/material.dart';
import 'package:go_router/go_router.dart';
import 'package:hooks_riverpod/hooks_riverpod.dart';
import 'package:infinite_scroll_pagination/infinite_scroll_pagination.dart';
import '../../sources/models.dart';
import '../hooks/use_paging_controller.dart';
import '../state/database.dart';
import '../state/settings.dart';
import 'list_items.dart';
const kPageSize = 30;
typedef _ArtistItem = ({Artist artist, int? albumCount});
class ArtistsList extends HookConsumerWidget {
const ArtistsList({super.key});
@override
Widget build(BuildContext context, WidgetRef ref) {
final db = ref.watch(databaseProvider);
final sourceId = ref.watch(sourceIdProvider);
final controller = usePagingController<int, _ArtistItem>(
getNextPageKey: (state) =>
state.lastPageIsEmpty ? null : state.nextIntPageKey,
fetchPage: (pageKey) async {
final albumCount = db.albums.id.count();
final query =
db.artists.select().join([
leftOuterJoin(
db.albums,
db.albums.artistId.equalsExp(db.artists.id),
),
])
..addColumns([albumCount])
..where(
db.artists.sourceId.equals(sourceId) &
db.albums.sourceId.equals(sourceId),
)
..groupBy([db.artists.sourceId, db.artists.id])
..orderBy([OrderingTerm.asc(db.artists.name)])
..limit(kPageSize, offset: (pageKey - 1) * kPageSize);
return (await query.get())
.map(
(row) => (
artist: row.readTable(db.artists),
albumCount: row.read(albumCount),
),
)
.toList();
},
);
return PagingListener(
controller: controller,
builder: (context, state, fetchNextPage) {
return PagedSliverList(
state: state,
fetchNextPage: fetchNextPage,
builderDelegate: PagedChildBuilderDelegate<_ArtistItem>(
itemBuilder: (context, item, index) {
final (:artist, :albumCount) = item;
return ArtistListTile(
artist: artist,
albumCount: albumCount,
onTap: () async {
context.push('/artist/${artist.id}');
},
);
},
),
);
},
);
}
}

View File

@ -1,4 +1,3 @@
import 'package:cached_network_image/cached_network_image.dart';
import 'package:flutter/material.dart'; import 'package:flutter/material.dart';
import 'package:hooks_riverpod/hooks_riverpod.dart'; import 'package:hooks_riverpod/hooks_riverpod.dart';
@ -33,19 +32,26 @@ class AlbumGridTile extends HookConsumerWidget {
} }
class ArtistListTile extends StatelessWidget { class ArtistListTile extends StatelessWidget {
const ArtistListTile({super.key}); const ArtistListTile({
super.key,
required this.artist,
this.albumCount,
this.onTap,
});
final Artist artist;
final int? albumCount;
final void Function()? onTap;
@override @override
Widget build(BuildContext context) { Widget build(BuildContext context) {
return ListTile( return ListTile(
leading: CircleClip( leading: CircleClip(
child: CachedNetworkImage( child: CoverArtImage(coverArt: artist.coverArt),
imageUrl: 'https://placehold.net/400x400.png',
placeholder: (context, url) => CircularProgressIndicator(),
errorWidget: (context, url, error) => Icon(Icons.error),
),
), ),
title: Text('Some Artist'), title: Text(artist.name),
subtitle: albumCount != null ? Text('$albumCount albums') : null,
onTap: onTap,
); );
} }
} }

View File

@ -3,7 +3,7 @@ import 'package:go_router/go_router.dart';
import 'package:hooks_riverpod/hooks_riverpod.dart'; import 'package:hooks_riverpod/hooks_riverpod.dart';
import 'package:material_symbols_icons/symbols.dart'; import 'package:material_symbols_icons/symbols.dart';
import '../lists/albums_grid.dart'; import '../lists/artists_list.dart';
import '../state/services.dart'; import '../state/services.dart';
import '../util/custom_scroll_fix.dart'; import '../util/custom_scroll_fix.dart';
@ -210,7 +210,7 @@ class _NewWidgetState extends State<NewWidget>
), ),
SliverPadding( SliverPadding(
padding: const EdgeInsets.all(8.0), padding: const EdgeInsets.all(8.0),
sliver: AlbumsGrid(), sliver: ArtistsList(),
), ),
], ],
); );

View File

@ -1,6 +1,6 @@
import 'package:hooks_riverpod/hooks_riverpod.dart'; import 'package:hooks_riverpod/hooks_riverpod.dart';
import '../../services/sync_services.dart'; import '../../services/sync_service.dart';
import 'database.dart'; import 'database.dart';
import 'settings.dart'; import 'settings.dart';
import 'source.dart'; import 'source.dart';

View File

@ -119,14 +119,14 @@ class CustomScrollController extends ScrollController {
ScrollContext context, ScrollContext context,
ScrollPosition? oldPosition, ScrollPosition? oldPosition,
) { ) {
debugPrint('$debugLabel-createScrollPosition: $isActive'); // debugPrint('$debugLabel-createScrollPosition: $isActive');
return parent.createScrollPosition(physics, context, oldPosition); return parent.createScrollPosition(physics, context, oldPosition);
} }
@override @override
void attach(ScrollPosition position) { void attach(ScrollPosition position) {
debugPrint('$debugLabel-attach: $isActive'); // debugPrint('$debugLabel-attach: $isActive');
super.attach(position); super.attach(position);
if (isActive && !parent.positions.contains(position)) { if (isActive && !parent.positions.contains(position)) {
@ -136,7 +136,7 @@ class CustomScrollController extends ScrollController {
@override @override
void detach(ScrollPosition position) { void detach(ScrollPosition position) {
debugPrint('$debugLabel-detach: $isActive'); // debugPrint('$debugLabel-detach: $isActive');
if (parent.positions.contains(position)) { if (parent.positions.contains(position)) {
parent.detach(position); parent.detach(position);
@ -146,7 +146,7 @@ class CustomScrollController extends ScrollController {
} }
void forceDetach() { void forceDetach() {
debugPrint('$debugLabel-forceDetach: $isActive'); // debugPrint('$debugLabel-forceDetach: $isActive');
for (final position in positions) { for (final position in positions) {
if (parent.positions.contains(position)) { if (parent.positions.contains(position)) {
@ -156,7 +156,7 @@ class CustomScrollController extends ScrollController {
} }
void forceAttach() { void forceAttach() {
debugPrint('$debugLabel-forceAttach: $isActive'); // debugPrint('$debugLabel-forceAttach: $isActive');
for (final position in positions) { for (final position in positions) {
if (!parent.positions.contains(position)) { if (!parent.positions.contains(position)) {
@ -167,7 +167,7 @@ class CustomScrollController extends ScrollController {
@override @override
void dispose() { void dispose() {
debugPrint('$debugLabel-dispose: $isActive'); // debugPrint('$debugLabel-dispose: $isActive');
forceDetach(); forceDetach();
super.dispose(); super.dispose();

View File

@ -437,6 +437,7 @@ extension ArtistToDb on models.Artist {
id: id, id: id,
name: name, name: name,
starred: Value(starred), starred: Value(starred),
coverArt: Value(coverArt),
); );
} }

View File

@ -708,8 +708,19 @@ class Artists extends Table with TableInfo<Artists, models.Artist> {
requiredDuringInsert: false, requiredDuringInsert: false,
$customConstraints: '', $customConstraints: '',
); );
static const VerificationMeta _coverArtMeta = const VerificationMeta(
'coverArt',
);
late final GeneratedColumn<String> coverArt = GeneratedColumn<String>(
'cover_art',
aliasedName,
true,
type: DriftSqlType.string,
requiredDuringInsert: false,
$customConstraints: '',
);
@override @override
List<GeneratedColumn> get $columns => [sourceId, id, name, starred]; List<GeneratedColumn> get $columns => [sourceId, id, name, starred, coverArt];
@override @override
String get aliasedName => _alias ?? actualTableName; String get aliasedName => _alias ?? actualTableName;
@override @override
@ -749,6 +760,12 @@ class Artists extends Table with TableInfo<Artists, models.Artist> {
starred.isAcceptableOrUnknown(data['starred']!, _starredMeta), starred.isAcceptableOrUnknown(data['starred']!, _starredMeta),
); );
} }
if (data.containsKey('cover_art')) {
context.handle(
_coverArtMeta,
coverArt.isAcceptableOrUnknown(data['cover_art']!, _coverArtMeta),
);
}
return context; return context;
} }
@ -770,6 +787,10 @@ class Artists extends Table with TableInfo<Artists, models.Artist> {
DriftSqlType.dateTime, DriftSqlType.dateTime,
data['${effectivePrefix}starred'], data['${effectivePrefix}starred'],
), ),
coverArt: attachedDatabase.typeMapping.read(
DriftSqlType.string,
data['${effectivePrefix}cover_art'],
),
); );
} }
@ -792,12 +813,14 @@ class ArtistsCompanion extends UpdateCompanion<models.Artist> {
final Value<String> id; final Value<String> id;
final Value<String> name; final Value<String> name;
final Value<DateTime?> starred; final Value<DateTime?> starred;
final Value<String?> coverArt;
final Value<int> rowid; final Value<int> rowid;
const ArtistsCompanion({ const ArtistsCompanion({
this.sourceId = const Value.absent(), this.sourceId = const Value.absent(),
this.id = const Value.absent(), this.id = const Value.absent(),
this.name = const Value.absent(), this.name = const Value.absent(),
this.starred = const Value.absent(), this.starred = const Value.absent(),
this.coverArt = const Value.absent(),
this.rowid = const Value.absent(), this.rowid = const Value.absent(),
}); });
ArtistsCompanion.insert({ ArtistsCompanion.insert({
@ -805,6 +828,7 @@ class ArtistsCompanion extends UpdateCompanion<models.Artist> {
required String id, required String id,
required String name, required String name,
this.starred = const Value.absent(), this.starred = const Value.absent(),
this.coverArt = const Value.absent(),
this.rowid = const Value.absent(), this.rowid = const Value.absent(),
}) : sourceId = Value(sourceId), }) : sourceId = Value(sourceId),
id = Value(id), id = Value(id),
@ -814,6 +838,7 @@ class ArtistsCompanion extends UpdateCompanion<models.Artist> {
Expression<String>? id, Expression<String>? id,
Expression<String>? name, Expression<String>? name,
Expression<DateTime>? starred, Expression<DateTime>? starred,
Expression<String>? coverArt,
Expression<int>? rowid, Expression<int>? rowid,
}) { }) {
return RawValuesInsertable({ return RawValuesInsertable({
@ -821,6 +846,7 @@ class ArtistsCompanion extends UpdateCompanion<models.Artist> {
if (id != null) 'id': id, if (id != null) 'id': id,
if (name != null) 'name': name, if (name != null) 'name': name,
if (starred != null) 'starred': starred, if (starred != null) 'starred': starred,
if (coverArt != null) 'cover_art': coverArt,
if (rowid != null) 'rowid': rowid, if (rowid != null) 'rowid': rowid,
}); });
} }
@ -830,6 +856,7 @@ class ArtistsCompanion extends UpdateCompanion<models.Artist> {
Value<String>? id, Value<String>? id,
Value<String>? name, Value<String>? name,
Value<DateTime?>? starred, Value<DateTime?>? starred,
Value<String?>? coverArt,
Value<int>? rowid, Value<int>? rowid,
}) { }) {
return ArtistsCompanion( return ArtistsCompanion(
@ -837,6 +864,7 @@ class ArtistsCompanion extends UpdateCompanion<models.Artist> {
id: id ?? this.id, id: id ?? this.id,
name: name ?? this.name, name: name ?? this.name,
starred: starred ?? this.starred, starred: starred ?? this.starred,
coverArt: coverArt ?? this.coverArt,
rowid: rowid ?? this.rowid, rowid: rowid ?? this.rowid,
); );
} }
@ -856,6 +884,9 @@ class ArtistsCompanion extends UpdateCompanion<models.Artist> {
if (starred.present) { if (starred.present) {
map['starred'] = Variable<DateTime>(starred.value); map['starred'] = Variable<DateTime>(starred.value);
} }
if (coverArt.present) {
map['cover_art'] = Variable<String>(coverArt.value);
}
if (rowid.present) { if (rowid.present) {
map['rowid'] = Variable<int>(rowid.value); map['rowid'] = Variable<int>(rowid.value);
} }
@ -869,6 +900,7 @@ class ArtistsCompanion extends UpdateCompanion<models.Artist> {
..write('id: $id, ') ..write('id: $id, ')
..write('name: $name, ') ..write('name: $name, ')
..write('starred: $starred, ') ..write('starred: $starred, ')
..write('coverArt: $coverArt, ')
..write('rowid: $rowid') ..write('rowid: $rowid')
..write(')')) ..write(')'))
.toString(); .toString();
@ -2864,6 +2896,7 @@ typedef $ArtistsCreateCompanionBuilder =
required String id, required String id,
required String name, required String name,
Value<DateTime?> starred, Value<DateTime?> starred,
Value<String?> coverArt,
Value<int> rowid, Value<int> rowid,
}); });
typedef $ArtistsUpdateCompanionBuilder = typedef $ArtistsUpdateCompanionBuilder =
@ -2872,6 +2905,7 @@ typedef $ArtistsUpdateCompanionBuilder =
Value<String> id, Value<String> id,
Value<String> name, Value<String> name,
Value<DateTime?> starred, Value<DateTime?> starred,
Value<String?> coverArt,
Value<int> rowid, Value<int> rowid,
}); });
@ -2902,6 +2936,11 @@ class $ArtistsFilterComposer extends Composer<_$SubtracksDatabase, Artists> {
column: $table.starred, column: $table.starred,
builder: (column) => ColumnFilters(column), builder: (column) => ColumnFilters(column),
); );
ColumnFilters<String> get coverArt => $composableBuilder(
column: $table.coverArt,
builder: (column) => ColumnFilters(column),
);
} }
class $ArtistsOrderingComposer extends Composer<_$SubtracksDatabase, Artists> { class $ArtistsOrderingComposer extends Composer<_$SubtracksDatabase, Artists> {
@ -2931,6 +2970,11 @@ class $ArtistsOrderingComposer extends Composer<_$SubtracksDatabase, Artists> {
column: $table.starred, column: $table.starred,
builder: (column) => ColumnOrderings(column), builder: (column) => ColumnOrderings(column),
); );
ColumnOrderings<String> get coverArt => $composableBuilder(
column: $table.coverArt,
builder: (column) => ColumnOrderings(column),
);
} }
class $ArtistsAnnotationComposer class $ArtistsAnnotationComposer
@ -2953,6 +2997,9 @@ class $ArtistsAnnotationComposer
GeneratedColumn<DateTime> get starred => GeneratedColumn<DateTime> get starred =>
$composableBuilder(column: $table.starred, builder: (column) => column); $composableBuilder(column: $table.starred, builder: (column) => column);
GeneratedColumn<String> get coverArt =>
$composableBuilder(column: $table.coverArt, builder: (column) => column);
} }
class $ArtistsTableManager class $ArtistsTableManager
@ -2990,12 +3037,14 @@ class $ArtistsTableManager
Value<String> id = const Value.absent(), Value<String> id = const Value.absent(),
Value<String> name = const Value.absent(), Value<String> name = const Value.absent(),
Value<DateTime?> starred = const Value.absent(), Value<DateTime?> starred = const Value.absent(),
Value<String?> coverArt = const Value.absent(),
Value<int> rowid = const Value.absent(), Value<int> rowid = const Value.absent(),
}) => ArtistsCompanion( }) => ArtistsCompanion(
sourceId: sourceId, sourceId: sourceId,
id: id, id: id,
name: name, name: name,
starred: starred, starred: starred,
coverArt: coverArt,
rowid: rowid, rowid: rowid,
), ),
createCompanionCallback: createCompanionCallback:
@ -3004,12 +3053,14 @@ class $ArtistsTableManager
required String id, required String id,
required String name, required String name,
Value<DateTime?> starred = const Value.absent(), Value<DateTime?> starred = const Value.absent(),
Value<String?> coverArt = const Value.absent(),
Value<int> rowid = const Value.absent(), Value<int> rowid = const Value.absent(),
}) => ArtistsCompanion.insert( }) => ArtistsCompanion.insert(
sourceId: sourceId, sourceId: sourceId,
id: id, id: id,
name: name, name: name,
starred: starred, starred: starred,
coverArt: coverArt,
rowid: rowid, rowid: rowid,
), ),
withReferenceMapper: (p0) => p0 withReferenceMapper: (p0) => p0

View File

@ -65,6 +65,7 @@ CREATE TABLE artists(
id TEXT NOT NULL, id TEXT NOT NULL,
name TEXT NOT NULL COLLATE NOCASE, name TEXT NOT NULL COLLATE NOCASE,
starred DATETIME, starred DATETIME,
cover_art TEXT,
PRIMARY KEY (source_id, id), PRIMARY KEY (source_id, id),
FOREIGN KEY (source_id) REFERENCES sources (id) ON DELETE CASCADE FOREIGN KEY (source_id) REFERENCES sources (id) ON DELETE CASCADE
) WITH Artist; ) WITH Artist;

View File

@ -1,10 +1,9 @@
import 'package:cached_network_image/cached_network_image.dart'; import 'package:cached_network_image/cached_network_image.dart';
import 'package:flutter/material.dart'; import 'package:flutter/material.dart';
import 'package:flutter_hooks/flutter_hooks.dart';
import 'package:hooks_riverpod/hooks_riverpod.dart'; import 'package:hooks_riverpod/hooks_riverpod.dart';
import 'package:material_symbols_icons/symbols.dart'; import 'package:material_symbols_icons/symbols.dart';
import 'package:octo_image/octo_image.dart';
import '../app/state/settings.dart';
import '../app/state/source.dart'; import '../app/state/source.dart';
class CoverArtImage extends HookConsumerWidget { class CoverArtImage extends HookConsumerWidget {
@ -20,30 +19,39 @@ class CoverArtImage extends HookConsumerWidget {
@override @override
Widget build(BuildContext context, WidgetRef ref) { Widget build(BuildContext context, WidgetRef ref) {
final source = ref.watch(sourceProvider); final source = ref.watch(sourceProvider);
final sourceId = ref.watch(sourceIdProvider);
final imageProviderKeys = [source, coverArt, thumbnail]; final imageUrl = coverArt != null
final buildImageProvider = useCallback( ? source.coverArtUri(coverArt!, thumbnail: thumbnail).toString()
() => CachedNetworkImageProvider( : 'https://placehold.net/400x400.png';
coverArt != null
? source.coverArtUri(coverArt!, thumbnail: thumbnail).toString() return BaseImage(
: 'https://placehold.net/400x400.png', imageUrl: imageUrl,
), // can't use the URL because of token auth, which is a cache-buster
imageProviderKeys, cacheKey: '$sourceId$coverArt$thumbnail',
); );
}
}
final imageProvider = useState(buildImageProvider()); class BaseImage extends HookConsumerWidget {
useEffect( const BaseImage({
() { super.key,
imageProvider.value = buildImageProvider(); required this.imageUrl,
return; this.cacheKey,
}, this.fit = BoxFit.cover,
imageProviderKeys, });
);
return OctoImage( final String imageUrl;
image: imageProvider.value, final String? cacheKey;
placeholderBuilder: (context) => Icon(Symbols.album_rounded), final BoxFit fit;
errorBuilder: (context, error, trace) => Icon(Icons.error),
@override
Widget build(BuildContext context, WidgetRef ref) {
return CachedNetworkImage(
imageUrl: imageUrl,
cacheKey: cacheKey,
placeholder: (context, url) => Icon(Symbols.cached_rounded),
errorWidget: (context, url, error) => Icon(Icons.error),
fit: BoxFit.cover, fit: BoxFit.cover,
fadeOutDuration: Duration(milliseconds: 100), fadeOutDuration: Duration(milliseconds: 100),
fadeInDuration: Duration(milliseconds: 200), fadeInDuration: Duration(milliseconds: 200),

View File

@ -22,9 +22,12 @@ void main() async {
.insertOnConflictUpdate( .insertOnConflictUpdate(
SubsonicSettingsCompanion.insert( SubsonicSettingsCompanion.insert(
sourceId: Value(1), sourceId: Value(1),
address: Uri.parse('http://10.0.2.2:4533'), address: Uri.parse('http://demo.subsonic.org'),
username: 'admin', username: 'guest1',
password: 'password', password: 'guest',
// address: Uri.parse('http://10.0.2.2:4533'),
// username: 'admin',
// password: 'password',
useTokenAuth: Value(true), useTokenAuth: Value(true),
), ),
); );

View File

@ -8,8 +8,7 @@ abstract class Artist with _$Artist {
required String id, required String id,
required String name, required String name,
DateTime? starred, DateTime? starred,
Uri? smallImage, String? coverArt,
Uri? largeImage,
}) = _Artist; }) = _Artist;
} }

View File

@ -14,7 +14,7 @@ T _$identity<T>(T value) => value;
/// @nodoc /// @nodoc
mixin _$Artist { mixin _$Artist {
String get id; String get name; DateTime? get starred; Uri? get smallImage; Uri? get largeImage; String get id; String get name; DateTime? get starred; String? get coverArt;
/// Create a copy of Artist /// Create a copy of Artist
/// with the given fields replaced by the non-null parameter values. /// with the given fields replaced by the non-null parameter values.
@JsonKey(includeFromJson: false, includeToJson: false) @JsonKey(includeFromJson: false, includeToJson: false)
@ -25,16 +25,16 @@ $ArtistCopyWith<Artist> get copyWith => _$ArtistCopyWithImpl<Artist>(this as Art
@override @override
bool operator ==(Object other) { bool operator ==(Object other) {
return identical(this, other) || (other.runtimeType == runtimeType&&other is Artist&&(identical(other.id, id) || other.id == id)&&(identical(other.name, name) || other.name == name)&&(identical(other.starred, starred) || other.starred == starred)&&(identical(other.smallImage, smallImage) || other.smallImage == smallImage)&&(identical(other.largeImage, largeImage) || other.largeImage == largeImage)); return identical(this, other) || (other.runtimeType == runtimeType&&other is Artist&&(identical(other.id, id) || other.id == id)&&(identical(other.name, name) || other.name == name)&&(identical(other.starred, starred) || other.starred == starred)&&(identical(other.coverArt, coverArt) || other.coverArt == coverArt));
} }
@override @override
int get hashCode => Object.hash(runtimeType,id,name,starred,smallImage,largeImage); int get hashCode => Object.hash(runtimeType,id,name,starred,coverArt);
@override @override
String toString() { String toString() {
return 'Artist(id: $id, name: $name, starred: $starred, smallImage: $smallImage, largeImage: $largeImage)'; return 'Artist(id: $id, name: $name, starred: $starred, coverArt: $coverArt)';
} }
@ -45,7 +45,7 @@ abstract mixin class $ArtistCopyWith<$Res> {
factory $ArtistCopyWith(Artist value, $Res Function(Artist) _then) = _$ArtistCopyWithImpl; factory $ArtistCopyWith(Artist value, $Res Function(Artist) _then) = _$ArtistCopyWithImpl;
@useResult @useResult
$Res call({ $Res call({
String id, String name, DateTime? starred, Uri? smallImage, Uri? largeImage String id, String name, DateTime? starred, String? coverArt
}); });
@ -62,14 +62,13 @@ class _$ArtistCopyWithImpl<$Res>
/// Create a copy of Artist /// Create a copy of Artist
/// with the given fields replaced by the non-null parameter values. /// with the given fields replaced by the non-null parameter values.
@pragma('vm:prefer-inline') @override $Res call({Object? id = null,Object? name = null,Object? starred = freezed,Object? smallImage = freezed,Object? largeImage = freezed,}) { @pragma('vm:prefer-inline') @override $Res call({Object? id = null,Object? name = null,Object? starred = freezed,Object? coverArt = freezed,}) {
return _then(_self.copyWith( return _then(_self.copyWith(
id: null == id ? _self.id : id // ignore: cast_nullable_to_non_nullable id: null == id ? _self.id : id // ignore: cast_nullable_to_non_nullable
as String,name: null == name ? _self.name : name // ignore: cast_nullable_to_non_nullable as String,name: null == name ? _self.name : name // ignore: cast_nullable_to_non_nullable
as String,starred: freezed == starred ? _self.starred : starred // ignore: cast_nullable_to_non_nullable as String,starred: freezed == starred ? _self.starred : starred // ignore: cast_nullable_to_non_nullable
as DateTime?,smallImage: freezed == smallImage ? _self.smallImage : smallImage // ignore: cast_nullable_to_non_nullable as DateTime?,coverArt: freezed == coverArt ? _self.coverArt : coverArt // ignore: cast_nullable_to_non_nullable
as Uri?,largeImage: freezed == largeImage ? _self.largeImage : largeImage // ignore: cast_nullable_to_non_nullable as String?,
as Uri?,
)); ));
} }
@ -154,10 +153,10 @@ return $default(_that);case _:
/// } /// }
/// ``` /// ```
@optionalTypeArgs TResult maybeWhen<TResult extends Object?>(TResult Function( String id, String name, DateTime? starred, Uri? smallImage, Uri? largeImage)? $default,{required TResult orElse(),}) {final _that = this; @optionalTypeArgs TResult maybeWhen<TResult extends Object?>(TResult Function( String id, String name, DateTime? starred, String? coverArt)? $default,{required TResult orElse(),}) {final _that = this;
switch (_that) { switch (_that) {
case _Artist() when $default != null: case _Artist() when $default != null:
return $default(_that.id,_that.name,_that.starred,_that.smallImage,_that.largeImage);case _: return $default(_that.id,_that.name,_that.starred,_that.coverArt);case _:
return orElse(); return orElse();
} }
@ -175,10 +174,10 @@ return $default(_that.id,_that.name,_that.starred,_that.smallImage,_that.largeIm
/// } /// }
/// ``` /// ```
@optionalTypeArgs TResult when<TResult extends Object?>(TResult Function( String id, String name, DateTime? starred, Uri? smallImage, Uri? largeImage) $default,) {final _that = this; @optionalTypeArgs TResult when<TResult extends Object?>(TResult Function( String id, String name, DateTime? starred, String? coverArt) $default,) {final _that = this;
switch (_that) { switch (_that) {
case _Artist(): case _Artist():
return $default(_that.id,_that.name,_that.starred,_that.smallImage,_that.largeImage);case _: return $default(_that.id,_that.name,_that.starred,_that.coverArt);case _:
throw StateError('Unexpected subclass'); throw StateError('Unexpected subclass');
} }
@ -195,10 +194,10 @@ return $default(_that.id,_that.name,_that.starred,_that.smallImage,_that.largeIm
/// } /// }
/// ``` /// ```
@optionalTypeArgs TResult? whenOrNull<TResult extends Object?>(TResult? Function( String id, String name, DateTime? starred, Uri? smallImage, Uri? largeImage)? $default,) {final _that = this; @optionalTypeArgs TResult? whenOrNull<TResult extends Object?>(TResult? Function( String id, String name, DateTime? starred, String? coverArt)? $default,) {final _that = this;
switch (_that) { switch (_that) {
case _Artist() when $default != null: case _Artist() when $default != null:
return $default(_that.id,_that.name,_that.starred,_that.smallImage,_that.largeImage);case _: return $default(_that.id,_that.name,_that.starred,_that.coverArt);case _:
return null; return null;
} }
@ -210,14 +209,13 @@ return $default(_that.id,_that.name,_that.starred,_that.smallImage,_that.largeIm
class _Artist implements Artist { class _Artist implements Artist {
const _Artist({required this.id, required this.name, this.starred, this.smallImage, this.largeImage}); const _Artist({required this.id, required this.name, this.starred, this.coverArt});
@override final String id; @override final String id;
@override final String name; @override final String name;
@override final DateTime? starred; @override final DateTime? starred;
@override final Uri? smallImage; @override final String? coverArt;
@override final Uri? largeImage;
/// Create a copy of Artist /// Create a copy of Artist
/// with the given fields replaced by the non-null parameter values. /// with the given fields replaced by the non-null parameter values.
@ -229,16 +227,16 @@ _$ArtistCopyWith<_Artist> get copyWith => __$ArtistCopyWithImpl<_Artist>(this, _
@override @override
bool operator ==(Object other) { bool operator ==(Object other) {
return identical(this, other) || (other.runtimeType == runtimeType&&other is _Artist&&(identical(other.id, id) || other.id == id)&&(identical(other.name, name) || other.name == name)&&(identical(other.starred, starred) || other.starred == starred)&&(identical(other.smallImage, smallImage) || other.smallImage == smallImage)&&(identical(other.largeImage, largeImage) || other.largeImage == largeImage)); return identical(this, other) || (other.runtimeType == runtimeType&&other is _Artist&&(identical(other.id, id) || other.id == id)&&(identical(other.name, name) || other.name == name)&&(identical(other.starred, starred) || other.starred == starred)&&(identical(other.coverArt, coverArt) || other.coverArt == coverArt));
} }
@override @override
int get hashCode => Object.hash(runtimeType,id,name,starred,smallImage,largeImage); int get hashCode => Object.hash(runtimeType,id,name,starred,coverArt);
@override @override
String toString() { String toString() {
return 'Artist(id: $id, name: $name, starred: $starred, smallImage: $smallImage, largeImage: $largeImage)'; return 'Artist(id: $id, name: $name, starred: $starred, coverArt: $coverArt)';
} }
@ -249,7 +247,7 @@ abstract mixin class _$ArtistCopyWith<$Res> implements $ArtistCopyWith<$Res> {
factory _$ArtistCopyWith(_Artist value, $Res Function(_Artist) _then) = __$ArtistCopyWithImpl; factory _$ArtistCopyWith(_Artist value, $Res Function(_Artist) _then) = __$ArtistCopyWithImpl;
@override @useResult @override @useResult
$Res call({ $Res call({
String id, String name, DateTime? starred, Uri? smallImage, Uri? largeImage String id, String name, DateTime? starred, String? coverArt
}); });
@ -266,14 +264,13 @@ class __$ArtistCopyWithImpl<$Res>
/// Create a copy of Artist /// Create a copy of Artist
/// with the given fields replaced by the non-null parameter values. /// with the given fields replaced by the non-null parameter values.
@override @pragma('vm:prefer-inline') $Res call({Object? id = null,Object? name = null,Object? starred = freezed,Object? smallImage = freezed,Object? largeImage = freezed,}) { @override @pragma('vm:prefer-inline') $Res call({Object? id = null,Object? name = null,Object? starred = freezed,Object? coverArt = freezed,}) {
return _then(_Artist( return _then(_Artist(
id: null == id ? _self.id : id // ignore: cast_nullable_to_non_nullable id: null == id ? _self.id : id // ignore: cast_nullable_to_non_nullable
as String,name: null == name ? _self.name : name // ignore: cast_nullable_to_non_nullable as String,name: null == name ? _self.name : name // ignore: cast_nullable_to_non_nullable
as String,starred: freezed == starred ? _self.starred : starred // ignore: cast_nullable_to_non_nullable as String,starred: freezed == starred ? _self.starred : starred // ignore: cast_nullable_to_non_nullable
as DateTime?,smallImage: freezed == smallImage ? _self.smallImage : smallImage // ignore: cast_nullable_to_non_nullable as DateTime?,coverArt: freezed == coverArt ? _self.coverArt : coverArt // ignore: cast_nullable_to_non_nullable
as Uri?,largeImage: freezed == largeImage ? _self.largeImage : largeImage // ignore: cast_nullable_to_non_nullable as String?,
as Uri?,
)); ));
} }

View File

@ -2,12 +2,11 @@ import 'package:xml/xml.dart';
import '../models.dart'; import '../models.dart';
Artist mapArtist(XmlElement e, XmlElement? info) => Artist( Artist mapArtist(XmlElement e) => Artist(
id: e.getAttribute('id')!, id: e.getAttribute('id')!,
name: e.getAttribute('name')!, name: e.getAttribute('name')!,
starred: DateTime.tryParse(e.getAttribute('starred').toString()), starred: DateTime.tryParse(e.getAttribute('starred').toString()),
smallImage: Uri.tryParse(info?.getElement('smallImageUrl')?.innerText ?? ''), coverArt: e.getAttribute('coverArt'),
largeImage: Uri.tryParse(info?.getElement('largeImageUrl')?.innerText ?? ''),
); );
Album mapAlbum( Album mapAlbum(

View File

@ -42,19 +42,13 @@ class SubsonicSource implements MusicSource {
@override @override
Stream<Artist> allArtists() async* { Stream<Artist> allArtists() async* {
final getArtistsRes = await _pool.withResource( final res = await _pool.withResource(
() => client.get('getArtists'), () => client.get('getArtists'),
); );
yield* _pool.forEach(getArtistsRes.xml.findAllElements('artist'), ( yield* Stream.fromIterable(
artist, res.xml.findAllElements('artist').map(mapArtist),
) async { );
final res = await client.get('getArtistInfo2', {
'id': artist.getAttribute('id')!,
});
return mapArtist(artist, res.xml.getElement('artistInfo2'));
});
} }
@override @override

View File

@ -1,5 +1,5 @@
import 'package:subtracks/database/database.dart'; import 'package:subtracks/database/database.dart';
import 'package:subtracks/services/sync_services.dart'; import 'package:subtracks/services/sync_service.dart';
import 'package:subtracks/sources/subsonic/source.dart'; import 'package:subtracks/sources/subsonic/source.dart';
import 'package:test/test.dart'; import 'package:test/test.dart';

View File

@ -5,7 +5,7 @@ import 'package:test/test.dart';
import '../util/subsonic.dart'; import '../util/subsonic.dart';
void main() { void main() {
groupByTestServer((client) { groupByTestServer((server, client) {
late SubsonicSource source; late SubsonicSource source;
setUp(() async { setUp(() async {
@ -29,7 +29,7 @@ void main() {
expect(kosmo.created.compareTo(DateTime.now()), lessThan(0)); expect(kosmo.created.compareTo(DateTime.now()), lessThan(0));
expect(kosmo.coverArt?.length, greaterThan(0)); expect(kosmo.coverArt?.length, greaterThan(0));
expect(kosmo.year, equals(2006)); expect(kosmo.year, equals(2006));
expect(kosmo.starred, isNull); expect(kosmo.starred?.compareTo(DateTime.now()), lessThan(0));
expect(kosmo.genre, equals('Electronic')); expect(kosmo.genre, equals('Electronic'));
final retro = items.firstWhere( final retro = items.firstWhere(
@ -39,6 +39,9 @@ void main() {
(a) => a.name == "I Don't Know What I'm Doing", (a) => a.name == "I Don't Know What I'm Doing",
); );
expect(retro.starred, isNull);
expect(dunno.starred, isNull);
expect(kosmo.recentRank, equals(0)); expect(kosmo.recentRank, equals(0));
expect(kosmo.frequentRank, equals(1)); expect(kosmo.frequentRank, equals(1));
@ -53,6 +56,19 @@ void main() {
final items = await source.allArtists().toList(); final items = await source.allArtists().toList();
expect(items.length, equals(2)); expect(items.length, equals(2));
final brad = items.firstWhere((a) => a.name == 'Brad Sucks');
expect(brad.id.length, greaterThan(0));
expect(brad.starred, isNull);
if (![Servers.gonic].contains(server)) {
expect(brad.coverArt?.length, greaterThan(0));
}
final ugress = items.firstWhere((a) => a.name == 'Ugress');
expect(ugress.starred?.compareTo(DateTime.now()), lessThan(0));
}); });
test('allSongs', () async { test('allSongs', () async {

View File

@ -23,12 +23,14 @@ Map<Servers, SubsonicClient> testServerClients() => {
), ),
}; };
void groupByTestServer(void Function(SubsonicClient client) callback) { void groupByTestServer(
void Function(Servers server, SubsonicClient client) callback,
) {
final clients = testServerClients(); final clients = testServerClients();
for (final MapEntry(key: server, value: client) in clients.entries) { for (final MapEntry(key: server, value: client) in clients.entries) {
group(server.name, () { group(server.name, () {
callback(client); callback(server, client);
}); });
} }
} }