tsacdop-podcast-app-android/lib/local_storage/sqflite_localpodcast.dart

511 lines
18 KiB
Dart
Raw Normal View History

2020-02-09 13:29:09 +01:00
import 'package:sqflite/sqflite.dart';
import 'dart:async';
import 'dart:io' as io;
import 'package:path/path.dart';
import 'package:intl/intl.dart';
import 'package:flutter_downloader/flutter_downloader.dart';
import 'package:path_provider/path_provider.dart';
import 'package:dio/dio.dart';
import 'package:tsacdop/class/podcastlocal.dart';
import 'package:tsacdop/class/episodebrief.dart';
import 'package:tsacdop/webfeed/webfeed.dart';
2020-02-09 13:29:09 +01:00
class DBHelper {
static Database _db;
Future<Database> get database async {
if (_db != null) return _db;
_db = await initDb();
return _db;
}
initDb() async {
io.Directory documentsDirectory = await getApplicationDocumentsDirectory();
String path = join(documentsDirectory.path, "podcasts.db");
Database theDb = await openDatabase(path, version: 1, onCreate: _onCreate);
return theDb;
}
void _onCreate(Database db, int version) async {
await db
.execute("""CREATE TABLE PodcastLocal(id TEXT PRIMARY KEY,title TEXT,
imageUrl TEXT,rssUrl TEXT UNIQUE,primaryColor TEXT,author TEXT,
description TEXT, add_date INTEGER, imagePath TEXT)""");
2020-02-09 13:29:09 +01:00
await db
.execute("""CREATE TABLE Episodes(id INTEGER PRIMARY KEY,title TEXT,
enclosure_url TEXT UNIQUE, enclosure_length INTEGER, pubDate TEXT,
description TEXT, feed_id TEXT, feed_link TEXT, milliseconds INTEGER,
2020-02-09 13:29:09 +01:00
duration INTEGER DEFAULT 0, explicit INTEGER DEFAULT 0, liked INTEGER DEFAULT 0,
downloaded TEXT DEFAULT 'ND', download_date INTEGER DEFAULT 0)""");
}
Future<List<PodcastLocal>> getPodcastLocal(List<String> podcasts) async {
var dbClient = await database;
List<PodcastLocal> podcastLocal = List();
await Future.forEach(podcasts, (s) async {
List<Map> list;
list = await dbClient.rawQuery(
'SELECT id, title, imageUrl, rssUrl, primaryColor, author, imagePath FROM PodcastLocal WHERE id = ?',
[s]);
podcastLocal.add(PodcastLocal(
list.first['title'],
list.first['imageUrl'],
list.first['rssUrl'],
list.first['primaryColor'],
list.first['author'],
list.first['id'],
list.first['imagePath']));
});
return podcastLocal;
}
Future<List<PodcastLocal>> getPodcastLocalAll() async {
2020-02-09 13:29:09 +01:00
var dbClient = await database;
List<Map> list = await dbClient.rawQuery(
'SELECT id, title, imageUrl, rssUrl, primaryColor, author, imagePath FROM PodcastLocal ORDER BY add_date DESC');
2020-02-09 13:29:09 +01:00
List<PodcastLocal> podcastLocal = List();
2020-02-09 13:29:09 +01:00
for (int i = 0; i < list.length; i++) {
podcastLocal.add(PodcastLocal(
list[i]['title'],
list[i]['imageUrl'],
list[i]['rssUrl'],
list[i]['primaryColor'],
list[i]['author'],
list[i]['id'],
list[i]['imagePath']));
2020-02-09 13:29:09 +01:00
}
return podcastLocal;
}
Future<bool> checkPodcast(String url) async {
var dbClient = await database;
List<Map> list = await dbClient
.rawQuery('SELECT id FROM PodcastLocal WHERE rssUrl = ?', [url]);
return list.length == 0;
}
2020-02-09 13:29:09 +01:00
Future savePodcastLocal(PodcastLocal podcastLocal) async {
print('podcast saved in sqllite');
2020-02-09 13:29:09 +01:00
int _milliseconds = DateTime.now().millisecondsSinceEpoch;
var dbClient = await database;
await dbClient.transaction((txn) async {
return await txn.rawInsert(
"""INSERT OR IGNORE INTO PodcastLocal (id, title, imageUrl, rssUrl,
primaryColor, author, description, add_date, imagePath) VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?)""",
2020-02-09 13:29:09 +01:00
[
podcastLocal.id,
2020-02-09 13:29:09 +01:00
podcastLocal.title,
podcastLocal.imageUrl,
podcastLocal.rssUrl,
podcastLocal.primaryColor,
podcastLocal.author,
podcastLocal.description,
_milliseconds,
podcastLocal.imagePath
2020-02-09 13:29:09 +01:00
]);
});
}
Future delPodcastLocal(String id) async {
2020-02-09 13:29:09 +01:00
var dbClient = await database;
await dbClient.rawDelete('DELETE FROM PodcastLocal WHERE id =?', [id]);
2020-02-09 13:29:09 +01:00
List<Map> list = await dbClient.rawQuery(
"""SELECT downloaded FROM Episodes WHERE downloaded != 'ND' AND feed_id = ?""",
[id]);
2020-02-11 14:01:57 +01:00
for (int i = 0; i < list.length; i++) {
if (list[i] != null)
FlutterDownloader.remove(
taskId: list[i]['downloaded'], shouldDeleteContent: true);
print('Removed all download tasks');
2020-02-09 13:29:09 +01:00
}
await dbClient.rawDelete('DELETE FROM Episodes WHERE feed_id=?', [id]);
2020-02-09 13:29:09 +01:00
}
2020-02-11 14:01:57 +01:00
DateTime _parsePubDate(String pubDate) {
if (pubDate == null) return DateTime.now();
print(pubDate);
2020-02-11 14:01:57 +01:00
DateTime date;
RegExp yyyy = RegExp(r'[1-2][0-9]{3}');
RegExp hhmm = RegExp(r'[0-2][0-9]\:[0-5][0-9]');
RegExp ddmmm = RegExp(r'[0-3][0-9]\s[A-Z][a-z]{2}');
RegExp mmDd = RegExp(r'([0-1]|\s)[0-9]\-[0-3][0-9]');
2020-02-09 13:29:09 +01:00
try {
date = DateFormat('EEE, dd MMM yyyy HH:mm:ss Z', 'en_US').parse(pubDate);
2020-02-09 13:29:09 +01:00
} catch (e) {
try {
date = DateFormat('dd MMM yyyy HH:mm:ss Z', 'en_US').parse(pubDate);
} catch (e) {
try {
date = DateFormat('EEE, dd MMM yyyy HH:mm Z', 'en_US').parse(pubDate);
} catch (e) {
//parse date using regex, bug in parse maonth/day
String year = yyyy.stringMatch(pubDate);
String time = hhmm.stringMatch(pubDate);
String month = ddmmm.stringMatch(pubDate);
if (year != null && time != null && month != null) {
date = DateFormat('dd MMM yyyy HH:mm', 'en_US')
.parse(month + year + time);
} else if(year!=null && time!=null && month == null){
String month = mmDd.stringMatch(pubDate);
date = DateFormat('mm-dd yyyy HH:mm', 'en_US')
.parse(month +' ' + year +' '+ time);
} else {date = DateTime.now();}
}
}
2020-02-09 13:29:09 +01:00
}
2020-02-11 14:01:57 +01:00
return date;
2020-02-09 13:29:09 +01:00
}
int getExplicit(bool b) {
int result;
if (b == true) {
result = 1;
return result;
} else {
result = 0;
return result;
}
}
bool isXimalaya(String input) {
RegExp ximalaya = RegExp(r"ximalaya.com");
return ximalaya.hasMatch(input);
}
Future<int> savePodcastRss(RssFeed _p, String id) async {
int _result = _p.items.length;
var dbClient = await database;
String _description, _url;
for (int i = 0; i < _result; i++) {
print(_p.items[i].title);
if (_p.items[i].itunes.summary != null) {
_p.items[i].itunes.summary.contains('<')
? _description = _p.items[i].itunes.summary
: _description = _p.items[i].description;
} else {
_description = _p.items[i].description;
}
isXimalaya(_p.items[i].enclosure.url)
? _url = _p.items[i].enclosure.url.split('=').last
: _url = _p.items[i].enclosure.url;
final _title = _p.items[i].itunes.title ?? _p.items[i].title;
final _length = _p.items[i].enclosure.length;
final _pubDate = _p.items[i].pubDate;
print(_pubDate);
final _date = _parsePubDate(_pubDate);
final _milliseconds = _date.millisecondsSinceEpoch;
final _duration = _p.items[i].itunes.duration?.inMinutes ?? 0;
final _explicit = getExplicit(_p.items[i].itunes.explicit);
if (_url != null) {
await dbClient.transaction((txn) {
return txn.rawInsert(
"""INSERT OR IGNORE INTO Episodes(title, enclosure_url, enclosure_length, pubDate,
description, feed_id, milliseconds, duration, explicit) VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?)""",
[
_title,
_url,
_length,
_pubDate,
_description,
id,
_milliseconds,
_duration,
_explicit,
]);
});
}
}
return _result;
}
Future<int> updatePodcastRss(PodcastLocal podcastLocal) async {
Response response = await Dio().get(podcastLocal.rssUrl);
var _p = RssFeed.parse(response.data);
String _url, _description;
2020-02-09 13:29:09 +01:00
int _result = _p.items.length;
var dbClient = await database;
int _count = Sqflite.firstIntValue(await dbClient.rawQuery(
'SELECT COUNT(*) FROM Episodes WHERE feed_id = ?', [podcastLocal.id]));
2020-02-09 13:29:09 +01:00
print(_count);
if (_count == _result) {
_result = 0;
return _result;
} else {
for (int i = 0; i < (_result - _count); i++) {
print(_p.items[i].title);
if (_p.items[i].itunes.summary != null) {
_p.items[i].itunes.summary.contains('<')
? _description = _p.items[i].itunes.summary
: _description = _p.items[i].description;
} else {
_description = _p.items[i].description;
}
2020-02-09 13:29:09 +01:00
isXimalaya(_p.items[i].enclosure.url)
? _url = _p.items[i].enclosure.url.split('=').last
: _url = _p.items[i].enclosure.url;
final _title = _p.items[i].itunes.title ?? _p.items[i].title;
2020-02-09 13:29:09 +01:00
final _length = _p.items[i].enclosure.length;
final _pubDate = _p.items[i].pubDate;
2020-02-11 14:01:57 +01:00
final _date = _parsePubDate(_pubDate);
2020-02-09 13:29:09 +01:00
final _milliseconds = _date.millisecondsSinceEpoch;
final _duration = _p.items[i].itunes.duration?.inMinutes ?? 0;
2020-02-09 13:29:09 +01:00
final _explicit = getExplicit(_p.items[i].itunes.explicit);
if (_url != null) {
2020-02-09 13:29:09 +01:00
await dbClient.transaction((txn) {
return txn.rawInsert(
"""INSERT OR IGNORE INTO Episodes(title, enclosure_url, enclosure_length, pubDate,
description, feed_id, milliseconds, duration, explicit) VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?)""",
2020-02-09 13:29:09 +01:00
[
_title,
_url,
_length,
_pubDate,
_description,
podcastLocal.id,
2020-02-09 13:29:09 +01:00
_milliseconds,
_duration,
_explicit,
]);
});
}
}
return _result - _count;
2020-02-09 13:29:09 +01:00
}
}
Future<List<EpisodeBrief>> getRssItem(String id) async {
2020-02-09 13:29:09 +01:00
var dbClient = await database;
List<EpisodeBrief> episodes = [];
2020-02-09 13:29:09 +01:00
List<Map> list = await dbClient
.rawQuery("""SELECT E.title, E.enclosure_url, E.enclosure_length,
E.milliseconds, P.imagePath, P.title as feedTitle, E.duration, E.explicit, E.liked,
E.downloaded, P.primaryColor
FROM Episodes E INNER JOIN PodcastLocal P ON E.feed_id = P.id
WHERE P.id = ? ORDER BY E.milliseconds DESC""", [id]);
2020-02-09 13:29:09 +01:00
for (int x = 0; x < list.length; x++) {
episodes.add(EpisodeBrief(
list[x]['title'],
list[x]['enclosure_url'],
list[x]['enclosure_length'],
list[x]['milliseconds'],
list[x]['feedTitle'],
2020-02-09 13:29:09 +01:00
list[x]['primaryColor'],
list[x]['liked'],
list[x]['downloaded'],
list[x]['duration'],
list[x]['explicit'],
list[x]['imagePath']));
2020-02-09 13:29:09 +01:00
}
return episodes;
}
Future<List<EpisodeBrief>> getRssItemTop(String id) async {
2020-02-09 13:29:09 +01:00
var dbClient = await database;
List<EpisodeBrief> episodes = List();
List<Map> list = await dbClient
.rawQuery("""SELECT E.title, E.enclosure_url, E.enclosure_length,
E.milliseconds, P.imagePath, P.title as feed_title, E.duration, E.explicit, E.liked,
E.downloaded, P.primaryColor
FROM Episodes E INNER JOIN PodcastLocal P ON E.feed_id = P.id
where E.feed_id = ? ORDER BY E.milliseconds DESC LIMIT 3""", [id]);
2020-02-09 13:29:09 +01:00
for (int x = 0; x < list.length; x++) {
episodes.add(EpisodeBrief(
list[x]['title'],
list[x]['enclosure_url'],
list[x]['enclosure_length'],
list[x]['milliseconds'],
2020-02-09 13:29:09 +01:00
list[x]['feed_title'],
list[x]['primaryColor'],
list[x]['liked'],
list[x]['downloaded'],
list[x]['duration'],
list[x]['explicit'],
list[x]['imagePath']));
2020-02-09 13:29:09 +01:00
}
return episodes;
}
Future<EpisodeBrief> getRssItemDownload(String url) async {
var dbClient = await database;
EpisodeBrief episode;
List<Map> list = await dbClient.rawQuery(
"""SELECT E.title, E.enclosure_url, E.enclosure_length,
E.milliseconds, P.imagePath, P.title as feed_title, E.duration, E.explicit, E.liked,
E.downloaded, P.primaryColor
FROM Episodes E INNER JOIN PodcastLocal P ON E.feed_id = P.id
2020-02-09 13:29:09 +01:00
where E.enclosure_url = ? ORDER BY E.milliseconds DESC LIMIT 3""",
[url]);
if (list != null)
episode = EpisodeBrief(
list.first['title'],
list.first['enclosure_url'],
list.first['enclosure_length'],
list.first['milliseconds'],
2020-02-09 13:29:09 +01:00
list.first['feed_title'],
list.first['primaryColor'],
list.first['liked'],
list.first['downloaded'],
list.first['duration'],
list.first['explicit'],
list.first['imagePath']);
2020-02-09 13:29:09 +01:00
return episode;
}
Future<List<EpisodeBrief>> getRecentRssItem() async {
var dbClient = await database;
List<EpisodeBrief> episodes = List();
List<Map> list = await dbClient
.rawQuery("""SELECT E.title, E.enclosure_url, E.enclosure_length,
E.milliseconds, P.title as feed_title, E.duration, E.explicit, E.liked,
E.downloaded, P.imagePath, P.primaryColor
FROM Episodes E INNER JOIN PodcastLocal P ON E.feed_id = P.id
2020-02-09 13:29:09 +01:00
ORDER BY E.milliseconds DESC LIMIT 99""");
for (int x = 0; x < list.length; x++) {
episodes.add(EpisodeBrief(
list[x]['title'],
list[x]['enclosure_url'],
list[x]['enclosure_length'],
list[x]['milliseconds'],
2020-02-09 13:29:09 +01:00
list[x]['feed_title'],
list[x]['primaryColor'],
list[x]['liked'],
list[x]['doanloaded'],
list[x]['duration'],
list[x]['explicit'],
list[x]['imagePath']));
2020-02-09 13:29:09 +01:00
}
return episodes;
}
Future<List<EpisodeBrief>> getLikedRssItem() async {
var dbClient = await database;
List<EpisodeBrief> episodes = List();
List<Map> list = await dbClient.rawQuery(
"""SELECT E.title, E.enclosure_url, E.enclosure_length, E.milliseconds, P.imagePath,
P.title as feed_title, E.duration, E.explicit, E.liked, E.downloaded,
P.primaryColor FROM Episodes E INNER JOIN PodcastLocal P ON E.feed_id = P.id
2020-02-09 13:29:09 +01:00
WHERE E.liked = 1 ORDER BY E.milliseconds DESC LIMIT 99""");
for (int x = 0; x < list.length; x++) {
episodes.add(EpisodeBrief(
list[x]['title'],
list[x]['enclosure_url'],
list[x]['enclosure_length'],
list[x]['milliseconds'],
2020-02-09 13:29:09 +01:00
list[x]['feed_title'],
list[x]['primaryColor'],
list[x]['liked'],
list[x]['downloaded'],
list[x]['duration'],
list[x]['explicit'],
list[x]['imagePath']));
2020-02-09 13:29:09 +01:00
}
return episodes;
}
Future<int> setLiked(String url) async {
2020-02-09 13:29:09 +01:00
var dbClient = await database;
int count = await dbClient.rawUpdate(
"UPDATE Episodes SET liked = 1 WHERE enclosure_url= ?", [url]);
2020-02-09 13:29:09 +01:00
print('liked');
return count;
}
Future<int> setUniked(String url) async {
2020-02-09 13:29:09 +01:00
var dbClient = await database;
int count = await dbClient.rawUpdate(
"UPDATE Episodes SET liked = 0 WHERE enclosure_url = ?", [url]);
2020-02-09 13:29:09 +01:00
print('unliked');
return count;
}
Future<int> saveDownloaded(String url, String id) async {
var dbClient = await database;
int _milliseconds = DateTime.now().millisecondsSinceEpoch;
int count = await dbClient.rawUpdate(
"UPDATE Episodes SET downloaded = ?, download_date = ? WHERE enclosure_url = ?",
[id, _milliseconds, url]);
return count;
}
Future<int> delDownloaded(String url) async {
var dbClient = await database;
int count = await dbClient.rawUpdate(
"UPDATE Episodes SET downloaded = 'ND' WHERE enclosure_url = ?", [url]);
print('Deleted ' + url);
return count;
}
Future<List<EpisodeBrief>> getDownloadedRssItem() async {
var dbClient = await database;
List<EpisodeBrief> episodes = List();
List<Map> list = await dbClient.rawQuery(
"""SELECT E.title, E.enclosure_url, E.enclosure_length, E.milliseconds, P.imagePath,
P.title as feed_title, E.duration, E.explicit, E.liked, E.downloaded,
P.primaryColor FROM Episodes E INNER JOIN PodcastLocal P ON E.feed_id = P.id
2020-02-09 13:29:09 +01:00
WHERE E.downloaded != 'ND' ORDER BY E.download_date DESC LIMIT 99""");
for (int x = 0; x < list.length; x++) {
episodes.add(EpisodeBrief(
list[x]['title'],
list[x]['enclosure_url'],
list[x]['enclosure_length'],
list[x]['milliseconds'],
2020-02-09 13:29:09 +01:00
list[x]['feed_title'],
list[x]['primaryColor'],
list[x]['liked'],
list[x]['downloaded'],
list[x]['duration'],
list[x]['explicit'],
list[x]['imagePath']));
2020-02-09 13:29:09 +01:00
}
return episodes;
}
Future<String> getDescription(String url) async {
2020-02-09 13:29:09 +01:00
var dbClient = await database;
List<Map> list = await dbClient.rawQuery(
'SELECT description FROM Episodes WHERE enclosure_url = ?', [url]);
2020-02-09 13:29:09 +01:00
String description = list[0]['description'];
return description;
}
Future<String> getFeedDescription(String id) async {
2020-02-09 13:29:09 +01:00
var dbClient = await database;
List<Map> list = await dbClient.rawQuery(
'SELECT description FROM PodcastLocal WHERE id = ?', [id]);
2020-02-09 13:29:09 +01:00
String description = list[0]['description'];
return description;
}
Future<EpisodeBrief> getRssItemWithUrl(String url) async {
var dbClient = await database;
EpisodeBrief episode;
List<Map> list = await dbClient.rawQuery(
"""SELECT E.title, E.enclosure_url, E.enclosure_length, E.milliseconds, P.imagePath,
P.title as feed_title, E.duration, E.explicit, E.liked, E.downloaded,
P.primaryColor FROM Episodes E INNER JOIN PodcastLocal P ON E.feed_id = P.id
WHERE E.enclosure_url = ?""", [url]);
episode = EpisodeBrief(
list.first['title'],
list.first['enclosure_url'],
list.first['enclosure_length'],
list.first['milliseconds'],
list.first['feed_title'],
list.first['primaryColor'],
list.first['liked'],
list.first['downloaded'],
list.first['duration'],
list.first['explicit'],
list.first['imagePath']);
return episode;
}
2020-02-09 13:29:09 +01:00
}