import 'dart:typed_data'; import 'package:disk_space/disk_space.dart'; import 'package:ext_storage/ext_storage.dart'; import 'package:flutter/services.dart'; import 'package:path_provider/path_provider.dart'; import 'package:random_string/random_string.dart'; import 'package:sqflite/sqflite.dart'; import 'package:path/path.dart' as p; import 'package:dio/dio.dart'; import 'package:filesize/filesize.dart'; import 'package:permission_handler/permission_handler.dart'; import 'package:flutter_local_notifications/flutter_local_notifications.dart'; import 'dart:io'; import 'dart:async'; import 'deezer.dart'; import '../settings.dart'; import 'definitions.dart'; import '../ui/cached_image.dart'; DownloadManager downloadManager = DownloadManager(); MethodChannel platformChannel = const MethodChannel('f.f.freezer/native'); class DownloadManager { Database db; List queue = []; String _offlinePath; Future _download; FlutterLocalNotificationsPlugin flutterLocalNotificationsPlugin; bool _cancelNotifications = true; bool stopped = true; Future init() async { //Prepare DB String dir = await getDatabasesPath(); String path = p.join(dir, 'offline.db'); db = await openDatabase( path, version: 1, onCreate: (Database db, int version) async { Batch b = db.batch(); //Create tables b.execute(""" CREATE TABLE downloads ( id INTEGER PRIMARY KEY AUTOINCREMENT, path TEXT, url TEXT, private INTEGER, state INTEGER, trackId TEXT)"""); b.execute("""CREATE TABLE tracks ( id TEXT PRIMARY KEY, title TEXT, album TEXT, artists TEXT, duration INTEGER, albumArt TEXT, trackNumber INTEGER, offline INTEGER, lyrics TEXT, favorite INTEGER)"""); b.execute("""CREATE TABLE albums ( id TEXT PRIMARY KEY, title TEXT, artists TEXT, tracks TEXT, art TEXT, fans INTEGER, offline INTEGER, library INTEGER)"""); b.execute("""CREATE TABLE artists ( id TEXT PRIMARY KEY, name TEXT, albums TEXT, topTracks TEXT, picture TEXT, fans INTEGER, albumCount INTEGER, offline INTEGER, library INTEGER)"""); b.execute("""CREATE TABLE playlists ( id TEXT PRIMARY KEY, title TEXT, tracks TEXT, image TEXT, duration INTEGER, userId TEXT, userName TEXT, fans INTEGER, library INTEGER, description TEXT)"""); await b.commit(); } ); //Prepare folders (/sdcard/Android/data/freezer/data/) _offlinePath = p.join((await getExternalStorageDirectory()).path, 'offline/'); await Directory(_offlinePath).create(recursive: true); //Notifications await _prepareNotifications(); //Restore List downloads = await db.rawQuery("SELECT * FROM downloads INNER JOIN tracks ON tracks.id = downloads.trackId WHERE downloads.state = 0"); downloads.forEach((download) => queue.add(Download.fromSQL(download, parseTrack: true))); } //Initialize flutter local notification plugin Future _prepareNotifications() async { flutterLocalNotificationsPlugin = FlutterLocalNotificationsPlugin(); AndroidInitializationSettings androidInitializationSettings = AndroidInitializationSettings('@drawable/ic_logo'); InitializationSettings initializationSettings = InitializationSettings(androidInitializationSettings, null); await flutterLocalNotificationsPlugin.initialize(initializationSettings); } //Show download progress notification, if now/total = null, show intermediate Future _startProgressNotification() async { _cancelNotifications = false; Timer.periodic(Duration(milliseconds: 500), (timer) async { //Cancel notifications if (_cancelNotifications) { flutterLocalNotificationsPlugin.cancel(10); timer.cancel(); return; } //Not downloading if (this.queue.length <= 0) return; Download d = queue[0]; //Prepare and show notification AndroidNotificationDetails androidNotificationDetails = AndroidNotificationDetails( 'download', 'Download', 'Download', importance: Importance.Default, priority: Priority.Default, showProgress: true, maxProgress: d.total??1, progress: d.received??1, playSound: false, enableVibration: false, autoCancel: true, //ongoing: true, //Allow dismissing indeterminate: (d.total == null || d.total == d.received), onlyAlertOnce: true ); NotificationDetails notificationDetails = NotificationDetails(androidNotificationDetails, null); await downloadManager.flutterLocalNotificationsPlugin.show( 10, 'Downloading: ${d.track.title}', (d.state == DownloadState.POST) ? 'Post processing...' : '${filesize(d.received)} / ${filesize(d.total)} (${queue.length} in queue)', notificationDetails ); }); } //Update queue, start new download void updateQueue() async { if (_download == null && queue.length > 0 && !stopped) { _download = queue[0].download( onDone: () async { //On download finished await db.rawUpdate('UPDATE downloads SET state = 1 WHERE trackId = ?', [queue[0].track.id]); queue.removeAt(0); _download = null; //Remove notification if no more downloads if (queue.length == 0) { _cancelNotifications = true; } updateQueue(); } ).catchError((e, st) async { if (stopped) return; print('Download error: $e\n$st'); //Catch download errors _download = null; _cancelNotifications = true; queue[0].state = DownloadState.NONE; //Shift to end queue.add(queue[0]); queue.removeAt(0); //Show error await _showError(); }); //Show download progress notifications if (_cancelNotifications == null || _cancelNotifications) _startProgressNotification(); } } //Stop downloading and end my life Future stop() async { stopped = true; if (_download != null) { await queue[0].stop(); } _download = null; } //Start again downloads Future start() async { if (_download != null) return; stopped = false; updateQueue(); } //Show error notification Future _showError() async { AndroidNotificationDetails androidNotificationDetails = AndroidNotificationDetails( 'downloadError', 'Download Error', 'Download Error' ); NotificationDetails notificationDetails = NotificationDetails(androidNotificationDetails, null); flutterLocalNotificationsPlugin.show( 11, 'Error while downloading!', 'Please restart downloads in the library', notificationDetails ); } //Returns all offline tracks Future> allOfflineTracks() async { List data = await db.query('tracks', where: 'offline == 1'); List tracks = []; //Load track data for (var t in data) { tracks.add(await getTrack(t['id'])); } return tracks; } //Get all offline playlists Future> getOfflinePlaylists() async { List data = await db.query('playlists'); List playlists = []; //Load playlists for (var p in data) { playlists.add(await getPlaylist(p['id'])); } return playlists; } //Get playlist metadata with tracks Future getPlaylist(String id) async { if (id == null) return null; List data = await db.query('playlists', where: 'id == ?', whereArgs: [id]); if (data.length == 0) return null; //Load playlist tracks Playlist p = Playlist.fromSQL(data[0]); for (int i=0; i getFavorites() async { return await getPlaylist('FAVORITES'); } Future> getOfflineAlbums({List albumsData}) async { //Load albums if (albumsData == null) { albumsData = await db.query('albums', where: 'offline == 1'); } List albums = albumsData.map((alb) => Album.fromSQL(alb)).toList(); for(int i=0; i((a) => Artist.fromSQL(a)).toList(); } return albums; } //Get track with metadata from db Future getTrack(String id, {Album album, List artists}) async { List tracks = await db.query('tracks', where: 'id == ?', whereArgs: [id]); if (tracks.length == 0) return null; Track t = Track.fromSQL(tracks[0]); //Load album from DB t.album = album ?? Album.fromSQL((await db.query('albums', where: 'id == ?', whereArgs: [t.album.id]))[0]); if (artists != null) { t.artists = artists; return t; } //Load artists from DB for (int i=0; i 0) return; //and in playlists counter = await db.rawQuery('SELECT COUNT(*) FROM playlists WHERE tracks LIKE "%$id%"'); if (counter[0]['COUNT(*)'] > 0) return; //Remove file List download = await db.query('downloads', where: 'trackId == ?', whereArgs: [id]); await File(download[0]['path']).delete(); //Delete from db await db.delete('tracks', where: 'id == ?', whereArgs: [id]); await db.delete('downloads', where: 'trackId == ?', whereArgs: [id]); } //Delete offline album Future removeOfflineAlbum(String id) async { List data = await db.rawQuery('SELECT * FROM albums WHERE id == ? AND offline == 1', [id]); if (data.length == 0) return; Map album = Map.from(data[0]); //make writable //Remove DB album['offline'] = 0; await db.update('albums', album, where: 'id == ?', whereArgs: [id]); //Get track ids List tracks = album['tracks'].split(','); for (String t in tracks) { //Remove tracks await removeOfflineTrack(t); } } Future removeOfflinePlaylist(String id) async { List data = await db.query('playlists', where: 'id == ?', whereArgs: [id]); if (data.length == 0) return; Playlist p = Playlist.fromSQL(data[0]); //Remove db await db.delete('playlists', where: 'id == ?', whereArgs: [id]); //Remove tracks for(Track t in p.tracks) { await removeOfflineTrack(t.id); } } //Get path to offline track Future getOfflineTrackPath(String id) async { List tracks = await db.rawQuery('SELECT path FROM downloads WHERE state == 1 AND trackId == ?', [id]); if (tracks.length < 1) { return null; } Download d = Download.fromSQL(tracks[0]); return d.path; } Future addOfflineTrack(Track track, {private = true, forceStart = true}) async { //Paths String path = p.join(_offlinePath, track.id); if (track.playbackDetails == null) { //Get track from API if download info missing track = await deezerAPI.track(track.id); } if (!private) { //Check permissions if (!(await Permission.storage.request().isGranted)) { return; } //If saving to external //Save just extension to path, will be generated before download path = 'mp3'; if (settings.downloadQuality == AudioQuality.FLAC) { path = 'flac'; } } else { //Load lyrics for private try { Lyrics l = await deezerAPI.lyrics(track.id); track.lyrics = l; } catch (e) {} } Download download = Download(track: track, path: path, private: private); //Database Batch b = db.batch(); b.insert('downloads', download.toSQL()); b.insert('tracks', track.toSQL(off: false), conflictAlgorithm: ConflictAlgorithm.ignore); if (private) { //Duplicate check List duplicate = await db.rawQuery('SELECT * FROM downloads WHERE trackId == ?', [track.id]); if (duplicate.length != 0) return; //Save art //await imagesDatabase.getImage(track.albumArt.full); imagesDatabase.saveImage(track.albumArt.full); //Save to db b.insert('tracks', track.toSQL(off: true), conflictAlgorithm: ConflictAlgorithm.replace); b.insert('albums', track.album.toSQL(), conflictAlgorithm: ConflictAlgorithm.ignore); track.artists.forEach((art) => b.insert('artists', art.toSQL(), conflictAlgorithm: ConflictAlgorithm.ignore)); } await b.commit(); queue.add(download); if (forceStart) start(); } Future addOfflineAlbum(Album album, {private = true}) async { //Get full album from API if tracks are missing if (album.tracks == null || album.tracks.length == 0) { album = await deezerAPI.album(album.id); } //Update album in database if (private) { await db.insert('albums', album.toSQL(off: true), conflictAlgorithm: ConflictAlgorithm.replace); } //Save all tracks for (Track track in album.tracks) { await addOfflineTrack(track, private: private, forceStart: false); } start(); } //Add offline playlist, can be also used as update Future addOfflinePlaylist(Playlist playlist, {private = true}) async { //Load full playlist if missing tracks if (playlist.tracks == null || playlist.tracks.length != playlist.trackCount) { playlist = await deezerAPI.fullPlaylist(playlist.id); } playlist.library = true; //To DB if (private) { await db.insert('playlists', playlist.toSQL(), conflictAlgorithm: ConflictAlgorithm.replace); } //Download all tracks for (Track t in playlist.tracks) { await addOfflineTrack(t, private: private, forceStart: false); } start(); } Future checkOffline({Album album, Track track, Playlist playlist}) async { //Check if album/track (TODO: Artist, playlist) is offline if (track != null) { List res = await db.query('tracks', where: 'id == ? AND offline == 1', whereArgs: [track.id]); if (res.length == 0) return false; return true; } if (album != null) { List res = await db.query('albums', where: 'id == ? AND offline == 1', whereArgs: [album.id]); if (res.length == 0) return false; return true; } if (playlist != null && playlist.id != null) { List res = await db.query('playlists', where: 'id == ?', whereArgs: [playlist.id]); if (res.length == 0) return false; return true; } return false; } //Offline search Future search(String query) async { SearchResults results = SearchResults( tracks: [], albums: [], artists: [], playlists: [] ); //Tracks List tracksData = await db.rawQuery('SELECT * FROM tracks WHERE offline == 1 AND title like "%$query%"'); for (Map trackData in tracksData) { results.tracks.add(await getTrack(trackData['id'])); } //Albums List albumsData = await db.rawQuery('SELECT * FROM albums WHERE offline == 1 AND title like "%$query%"'); results.albums = await getOfflineAlbums(albumsData: albumsData); //Artists //TODO: offline artists //Playlists List playlists = await db.rawQuery('SELECT * FROM playlists WHERE title like "%$query%"'); for (Map playlist in playlists) { results.playlists.add(await getPlaylist(playlist['id'])); } return results; } Future> getFinishedDownloads() async { //Fetch from db List data = await db.rawQuery("SELECT * FROM downloads INNER JOIN tracks ON tracks.id = downloads.trackId WHERE downloads.state = 1"); List downloads = data.map((d) => Download.fromSQL(d, parseTrack: true)).toList(); return downloads; } //Get stats for library screen Future> getStats() async { //Get offline counts int trackCount = (await db.rawQuery('SELECT COUNT(*) FROM tracks WHERE offline == 1'))[0]['COUNT(*)']; int albumCount = (await db.rawQuery('SELECT COUNT(*) FROM albums WHERE offline == 1'))[0]['COUNT(*)']; int playlistCount = (await db.rawQuery('SELECT COUNT(*) FROM albums WHERE offline == 1'))[0]['COUNT(*)']; //Free space double diskSpace = await DiskSpace.getFreeDiskSpace; //Used space List offlineStat = await Directory(_offlinePath).list().toList(); int offlineSize = 0; for (var fs in offlineStat) { offlineSize += (await fs.stat()).size; } //Return as a list, maybe refactor in future if feature stays return ([ trackCount.toString(), albumCount.toString(), playlistCount.toString(), filesize(offlineSize), filesize((diskSpace * 1000000).floor()) ]); } //Delete download from db Future removeDownload(Download download) async { await db.delete('downloads', where: 'trackId == ?', whereArgs: [download.track.id]); queue.removeWhere((d) => d.track.id == download.track.id); //TODO: remove files for downloaded } //Delete queue Future clearQueue() async { while (queue.length > 0) { if (queue.length == 1) { if (_download != null) break; await removeDownload(queue[0]); return; } await removeDownload(queue[1]); } } //Remove non-private downloads Future cleanDownloadHistory() async { await db.delete('downloads', where: 'private == 0'); } } class Download { Track track; String path; String url; bool private; DownloadState state; String _cover; //For canceling IOSink _outSink; CancelToken _cancel; StreamSubscription _progressSub; int received = 0; int total = 1; Download({this.track, this.path, this.url, this.private, this.state = DownloadState.NONE}); //Stop download Future stop() async { if (_cancel != null) _cancel.cancel(); //if (_outSink != null) _outSink.close(); if (_progressSub != null) _progressSub.cancel(); received = 0; total = 1; state = DownloadState.NONE; } Future download({onDone}) async { Dio dio = Dio(); //TODO: Check for internet before downloading Map rawTrackPublic = {}; Map rawAlbumPublic = {}; if (!this.private && !(this.path.endsWith('.mp3') || this.path.endsWith('.flac'))) { String ext = this.path; //Get track details Map _rawTrackData = await deezerAPI.callApi('song.getListData', params: {'sng_ids': [track.id]}); Map rawTrack = _rawTrackData['results']['data'][0]; this.track = Track.fromPrivateJson(rawTrack); //RAW Public API call (for genre and other tags) try {rawTrackPublic = await deezerAPI.callPublicApi('track/${this.track.id}');} catch (e) {rawTrackPublic = {};} try {rawAlbumPublic = await deezerAPI.callPublicApi('album/${this.track.album.id}');} catch (e) {rawAlbumPublic = {};} //Get path if public RegExp sanitize = RegExp(r'[\/\\\?\%\*\:\|\"\<\>]'); //Download path this.path = settings.downloadPath ?? (await ExtStorage.getExternalStoragePublicDirectory(ExtStorage.DIRECTORY_MUSIC)); if (settings.artistFolder) this.path = p.join(this.path, track.artists[0].name.replaceAll(sanitize, '')); if (settings.albumFolder) { String folderName = track.album.title.replaceAll(sanitize, ''); //Add disk number if (settings.albumDiscFolder) folderName += ' - Disk ${track.diskNumber}'; this.path = p.join(this.path, folderName); } //Make dirs await Directory(this.path).create(recursive: true); //Grab cover _cover = p.join(this.path, 'cover.jpg'); if (!settings.albumFolder) _cover = p.join(this.path, randomAlpha(12) + '_cover.jpg'); if (!await File(_cover).exists()) { try { await dio.download( this.track.albumArt.full, _cover, ); } catch (e) {print('Error downloading cover');} } //Create filename String _filename = settings.downloadFilename; //Feats filter String feats = ''; if (track.artists.length > 1) feats = "feat. ${track.artists.sublist(1).map((a) => a.name).join(', ')}"; //Filters Map vars = { '%artists%': track.artistString.replaceAll(sanitize, ''), '%artist%': track.artists[0].name.replaceAll(sanitize, ''), '%title%': track.title.replaceAll(sanitize, ''), '%album%': track.album.title.replaceAll(sanitize, ''), '%trackNumber%': track.trackNumber.toString(), '%0trackNumber%': track.trackNumber.toString().padLeft(2, '0'), '%feats%': feats }; //Replace vars.forEach((key, value) { _filename = _filename.replaceAll(key, value); }); _filename += '.$ext'; this.path = p.join(this.path, _filename); } //Check if file exists if (await File(this.path).exists() && !settings.overwriteDownload) { this.state = DownloadState.DONE; onDone(); return; } //Download this.state = DownloadState.DOWNLOADING; //Create download file File downloadFile = File(this.path + '.ENC'); //Get start position int start = 0; if (await downloadFile.exists()) { FileStat stat = await downloadFile.stat(); start = stat.size; } else { //Create file if doesnt exist await downloadFile.create(recursive: true); } //Quality fallback if (this.url == null) await _fallback(); //Download _cancel = CancelToken(); Response response = await dio.get( this.url, options: Options( responseType: ResponseType.stream, headers: { 'Range': 'bytes=$start-' }, ), cancelToken: _cancel ); //Size this.total = int.parse(response.headers['Content-Length'][0]) + start; this.received = start; //Save _outSink = downloadFile.openWrite(mode: FileMode.append); Stream _data = response.data.stream.asBroadcastStream(); _progressSub = _data.listen((Uint8List c) { this.received += c.length; }); //Pipe to file try { await _outSink.addStream(_data); } catch (e) { await _outSink.close(); throw Exception('Download error'); } await _outSink.close(); _cancel = null; this.state = DownloadState.POST; //Decrypt await platformChannel.invokeMethod('decryptTrack', {'id': track.id, 'path': path}); //Tag if (!private) { //Tag track in native String year; if (rawTrackPublic['release_date'] != null && rawTrackPublic['release_date'].length >= 4) year = rawTrackPublic['release_date'].substring(0, 4); await platformChannel.invokeMethod('tagTrack', { 'path': path, 'title': track.title, 'album': track.album.title, 'artists': track.artistString, 'artist': track.artists[0].name, 'cover': _cover, 'trackNumber': track.trackNumber, 'diskNumber': track.diskNumber, 'genres': ((rawAlbumPublic['genres']??{})['data']??[]).map((g) => g['name']).toList(), 'year': year, 'bpm': rawTrackPublic['bpm'], 'explicit': (track.explicit??false) ? "1":"0", 'label': rawAlbumPublic['label'], 'albumTracks': rawAlbumPublic['nb_tracks'], 'date': rawTrackPublic['release_date'], 'albumArtist': (rawAlbumPublic['artist']??{})['name'] }); //Rescan android library await platformChannel.invokeMethod('rescanLibrary', { 'path': path }); } //Remove encrypted await File(path + '.ENC').delete(); if (!settings.albumFolder) await File(_cover).delete(); //Get lyrics Lyrics lyrics; try { lyrics = await deezerAPI.lyrics(track.id); } catch (e) {} if (lyrics != null && lyrics.lyrics != null) { //Create .LRC file String lrcPath = p.join(p.dirname(path), p.basenameWithoutExtension(path)) + '.lrc'; File lrcFile = File(lrcPath); String lrcData = ''; //Generate file lrcData += '[ar:${track.artistString}]\r\n'; lrcData += '[al:${track.album.title}]\r\n'; lrcData += '[ti:${track.title}]\r\n'; for (Lyric l in lyrics.lyrics) { if (l.lrcTimestamp != null && l.lrcTimestamp != '' && l.text != null) lrcData += '${l.lrcTimestamp}${l.text}\r\n'; } lrcFile.writeAsString(lrcData); } this.state = DownloadState.DONE; onDone(); return; } Future _fallback({fallback}) async { //Get quality AudioQuality quality = private ? settings.offlineQuality : settings.downloadQuality; if (fallback == AudioQuality.MP3_320) quality = AudioQuality.MP3_128; if (fallback == AudioQuality.FLAC) { quality = AudioQuality.MP3_320; if (this.path.toLowerCase().endsWith('flac')) this.path = this.path.substring(0, this.path.length - 4) + 'mp3'; } //No more fallback if (quality == AudioQuality.MP3_128) { url = track.getUrl(settings.getQualityInt(quality)); return; } //Check int q = settings.getQualityInt(quality); try { Response res = await Dio().head(track.getUrl(q)); if (res.statusCode == 200 || res.statusCode == 206) { this.url = track.getUrl(q); return; } } catch (e) {} //Fallback return _fallback(fallback: quality); } //JSON Map toSQL() => { 'trackId': track.id, 'path': path, 'url': url, 'state': state == DownloadState.DONE ? 1:0, 'private': private?1:0 }; factory Download.fromSQL(Map data, {parseTrack = false}) => Download( track: parseTrack?Track.fromSQL(data):Track(id: data['trackId']), path: data['path'], url: data['url'], state: data['state'] == 1 ? DownloadState.DONE:DownloadState.NONE, private: data['private'] == 1 ); } enum DownloadState { NONE, DOWNLOADING, POST, DONE }