forked from firka/student-legacy
108 lines
3.4 KiB
Dart
108 lines
3.4 KiB
Dart
import 'package:filcnaplo/database/struct.dart';
|
|
import 'package:filcnaplo/models/settings.dart';
|
|
import 'package:sqflite/sqflite.dart';
|
|
|
|
Future<Database> initDB() async {
|
|
// await deleteDatabase('app.db'); // for debugging
|
|
var db = await openDatabase('app.db');
|
|
|
|
var settingsDB = await createSettingsTable(db);
|
|
|
|
// Create table Users
|
|
var usersDB = await createUsersTable(db);
|
|
await db.execute("CREATE TABLE IF NOT EXISTS user_data ("
|
|
"id TEXT NOT NULL, grades TEXT, timetable TEXT, exams TEXT, homework TEXT, messages TEXT, notes TEXT, events TEXT, absences TEXT)");
|
|
|
|
if ((await db.rawQuery("SELECT COUNT(*) FROM settings"))[0].values.first == 0) {
|
|
// Set default values for table Settings
|
|
await db.insert("settings", SettingsProvider.defaultSettings().toMap());
|
|
}
|
|
|
|
// Migrate Databases
|
|
await migrateDB(db, "settings", settingsDB.struct.keys, SettingsProvider.defaultSettings().toMap(), createSettingsTable);
|
|
await migrateDB(db, "users", usersDB.struct.keys, {"role": 0}, createUsersTable);
|
|
|
|
return db;
|
|
}
|
|
|
|
Future<DatabaseStruct> createSettingsTable(Database db) async {
|
|
var settingsDB = DatabaseStruct({
|
|
"language": String, "start_page": int, "rounding": int, "theme": int, "accent_color": int, "news": int, "news_state": int, "developer_mode": int,
|
|
"update_channel": int, "config": String, // general
|
|
"grade_color1": int, "grade_color2": int, "grade_color3": int, "grade_color4": int, "grade_color5": int, // grade colors
|
|
"vibration_strength": int, "ab_weeks": int, "swap_ab_weeks": int,
|
|
"notifications": int, "notifications_bitfield": int, "notification_poll_interval": int, // notifications
|
|
"x_filc_id": String,
|
|
});
|
|
|
|
// Create table Settings
|
|
await db.execute("CREATE TABLE IF NOT EXISTS settings ($settingsDB)");
|
|
|
|
return settingsDB;
|
|
}
|
|
|
|
Future<DatabaseStruct> createUsersTable(Database db) async {
|
|
var usersDB = DatabaseStruct(
|
|
{"id": String, "name": String, "username": String, "password": String, "institute_code": String, "student": String, "role": int});
|
|
|
|
// Create table Users
|
|
await db.execute("CREATE TABLE IF NOT EXISTS users ($usersDB)");
|
|
|
|
return usersDB;
|
|
}
|
|
|
|
Future<void> migrateDB(
|
|
Database db,
|
|
String table,
|
|
Iterable<String> keys,
|
|
Map<String, Object?> defaultValues,
|
|
Future<DatabaseStruct> Function(Database) create,
|
|
) async {
|
|
var originalRows = await db.query(table);
|
|
|
|
if (originalRows.length == 0) {
|
|
await db.execute("drop table $table");
|
|
await create(db);
|
|
return;
|
|
}
|
|
|
|
List<Map<String, dynamic>> migrated = [];
|
|
|
|
await Future.forEach<Map<String, Object?>>(originalRows, (original) async {
|
|
bool migrationRequired = keys.any((key) => !original.containsKey(key) || original[key] == null);
|
|
|
|
if (migrationRequired) {
|
|
print("INFO: Migrating $table");
|
|
var copy = Map<String, dynamic>.from(original);
|
|
|
|
// Fill missing columns
|
|
keys.forEach((key) {
|
|
if (!keys.contains(key)) {
|
|
print("DEBUG: dropping $key");
|
|
copy.remove(key);
|
|
}
|
|
|
|
if (!original.containsKey(key) || original[key] == null) {
|
|
print("DEBUG: migrating $key");
|
|
copy[key] = defaultValues[key];
|
|
}
|
|
});
|
|
|
|
migrated.add(copy);
|
|
}
|
|
});
|
|
|
|
if (migrated.length > 0) {
|
|
// Delete table
|
|
await db.execute("drop table $table");
|
|
|
|
// Recreate table
|
|
await create(db);
|
|
await Future.forEach(migrated, (Map<String, dynamic> copy) async {
|
|
await db.insert(table, copy);
|
|
});
|
|
|
|
print("INFO: Database migrated");
|
|
}
|
|
}
|