mirror of https://github.com/M66B/FairEmail.git
376 lines
18 KiB
376 lines
18 KiB
package eu.faircode.email;
|
|
|
|
import android.content.Context;
|
|
import android.database.Cursor;
|
|
import android.text.TextUtils;
|
|
import android.util.Log;
|
|
|
|
import org.json.JSONArray;
|
|
import org.json.JSONException;
|
|
import org.json.JSONObject;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
|
|
import javax.mail.Address;
|
|
import javax.mail.internet.InternetAddress;
|
|
|
|
import androidx.room.Database;
|
|
import androidx.room.Room;
|
|
import androidx.room.RoomDatabase;
|
|
import androidx.room.TypeConverter;
|
|
import androidx.room.TypeConverters;
|
|
import androidx.room.migration.Migration;
|
|
import androidx.sqlite.db.SupportSQLiteDatabase;
|
|
import io.requery.android.database.sqlite.RequerySQLiteOpenHelperFactory;
|
|
|
|
/*
|
|
This file is part of FairEmail.
|
|
|
|
FairEmail is free software: you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation, either version 3 of the License, or
|
|
(at your option) any later version.
|
|
|
|
FairEmail is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with FairEmail. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
Copyright 2018 by Marcel Bokhorst (M66B)
|
|
*/
|
|
|
|
// https://developer.android.com/topic/libraries/architecture/room.html
|
|
|
|
@Database(
|
|
version = 22,
|
|
entities = {
|
|
EntityIdentity.class,
|
|
EntityAccount.class,
|
|
EntityFolder.class,
|
|
EntityMessage.class,
|
|
EntityAttachment.class,
|
|
EntityOperation.class,
|
|
EntityAnswer.class,
|
|
EntityLog.class
|
|
}
|
|
)
|
|
|
|
@TypeConverters({DB.Converters.class})
|
|
public abstract class DB extends RoomDatabase {
|
|
public abstract DaoIdentity identity();
|
|
|
|
public abstract DaoAccount account();
|
|
|
|
public abstract DaoFolder folder();
|
|
|
|
public abstract DaoMessage message();
|
|
|
|
public abstract DaoAttachment attachment();
|
|
|
|
public abstract DaoOperation operation();
|
|
|
|
public abstract DaoAnswer answer();
|
|
|
|
public abstract DaoLog log();
|
|
|
|
private static DB sInstance;
|
|
|
|
private static final String DB_NAME = "fairemail";
|
|
|
|
public static synchronized DB getInstance(Context context) {
|
|
if (sInstance == null) {
|
|
sInstance = migrate(Room
|
|
.databaseBuilder(context.getApplicationContext(), DB.class, DB_NAME)
|
|
.openHelperFactory(new RequerySQLiteOpenHelperFactory())
|
|
.setJournalMode(JournalMode.WRITE_AHEAD_LOGGING));
|
|
|
|
Log.i(Helper.TAG, "sqlite version=" + exec(sInstance, "SELECT sqlite_version() AS sqlite_version"));
|
|
Log.i(Helper.TAG, "sqlite sync=" + exec(sInstance, "PRAGMA synchronous"));
|
|
Log.i(Helper.TAG, "sqlite journal=" + exec(sInstance, "PRAGMA journal_mode"));
|
|
}
|
|
|
|
return sInstance;
|
|
}
|
|
|
|
private static String exec(DB db, String command) {
|
|
Cursor cursor = null;
|
|
try {
|
|
cursor = db.query(command, new Object[0]);
|
|
if (cursor.moveToNext())
|
|
return cursor.getString(0);
|
|
else
|
|
return null;
|
|
} finally {
|
|
if (cursor != null)
|
|
cursor.close();
|
|
}
|
|
}
|
|
|
|
private static DB migrate(RoomDatabase.Builder<DB> builder) {
|
|
// https://www.sqlite.org/lang_altertable.html
|
|
return builder
|
|
.addCallback(new Callback() {
|
|
@Override
|
|
public void onOpen(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "Database version=" + db.getVersion());
|
|
super.onOpen(db);
|
|
}
|
|
})
|
|
.addMigrations(new Migration(1, 2) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `folder` RENAME COLUMN `after` TO `sync_days`");
|
|
db.execSQL("ALTER TABLE `folder` ADD COLUMN `keep_days` INTEGER NOT NULL DEFAULT 30");
|
|
db.execSQL("UPDATE `folder` SET keep_days = sync_days");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(2, 3) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `identity` ADD COLUMN `signature` TEXT");
|
|
db.execSQL("UPDATE `identity` SET signature =" +
|
|
" (SELECT account.signature FROM account WHERE account.id = identity.account)");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(3, 4) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `message` ADD COLUMN `forwarding` INTEGER" +
|
|
" REFERENCES `message`(`id`) ON UPDATE NO ACTION ON DELETE SET NULL");
|
|
db.execSQL("CREATE INDEX `index_message_forwarding` ON `message` (`forwarding`)");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(4, 5) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `account` ADD COLUMN `last_connected` INTEGER");
|
|
db.execSQL("ALTER TABLE `message` ADD COLUMN `last_attempt` INTEGER");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(5, 6) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `account` ADD COLUMN `notify` INTEGER NOT NULL DEFAULT 0");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(6, 7) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `message` ADD COLUMN `answered` INTEGER NOT NULL DEFAULT 0");
|
|
db.execSQL("ALTER TABLE `message` ADD COLUMN `ui_answered` INTEGER NOT NULL DEFAULT 0");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(7, 8) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `message` ADD COLUMN `keywords` TEXT");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(8, 9) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `folder` ADD COLUMN `keywords` TEXT");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(9, 10) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `message` ADD COLUMN `ui_browsed` INTEGER NOT NULL DEFAULT 0");
|
|
db.execSQL("CREATE INDEX `index_message_ui_browsed` ON `message` (`ui_browsed`)");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(10, 11) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `operation` ADD COLUMN `error` TEXT");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(11, 12) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("DROP INDEX `index_operation_folder`");
|
|
db.execSQL("DROP INDEX `index_operation_message`");
|
|
db.execSQL("DROP TABLE `operation`");
|
|
db.execSQL("CREATE TABLE `operation`" +
|
|
" (`id` INTEGER PRIMARY KEY AUTOINCREMENT" +
|
|
", `folder` INTEGER NOT NULL" +
|
|
", `message` INTEGER" +
|
|
", `name` TEXT NOT NULL" +
|
|
", `args` TEXT NOT NULL" +
|
|
", `created` INTEGER NOT NULL" +
|
|
", `error` TEXT" +
|
|
", FOREIGN KEY(`folder`) REFERENCES `folder`(`id`) ON UPDATE NO ACTION ON DELETE CASCADE" +
|
|
", FOREIGN KEY(`message`) REFERENCES `message`(`id`) ON UPDATE NO ACTION ON DELETE CASCADE)");
|
|
db.execSQL("CREATE INDEX `index_operation_folder` ON `operation` (`folder`)");
|
|
db.execSQL("CREATE INDEX `index_operation_message` ON `operation` (`message`)");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(12, 13) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("CREATE INDEX `index_message_ui_flagged` ON `message` (`ui_flagged`)");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(13, 14) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `folder` ADD COLUMN `level` INTEGER NOT NULL DEFAULT 0");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(14, 15) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `folder` ADD COLUMN `sync_state` TEXT");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(15, 16) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `folder` ADD COLUMN `poll` INTEGER NOT NULL DEFAULT 0");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(16, 17) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("DELETE FROM `message` WHERE ui_found");
|
|
db.execSQL("DROP INDEX `index_message_folder_uid_ui_found`");
|
|
db.execSQL("DROP INDEX `index_message_msgid_folder_ui_found`");
|
|
db.execSQL("CREATE UNIQUE INDEX `index_message_folder_uid` ON `message` (`folder`, `uid`)");
|
|
db.execSQL("CREATE UNIQUE INDEX `index_message_msgid_folder` ON `message` (`msgid`, `folder`)");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(17, 18) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `account` ADD COLUMN `tbd` INTEGER");
|
|
db.execSQL("ALTER TABLE `identity` ADD COLUMN `tbd` INTEGER");
|
|
db.execSQL("ALTER TABLE `folder` ADD COLUMN `tbd` INTEGER");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(18, 19) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `identity` ADD COLUMN `delivery_receipt` INTEGER NOT NULL DEFAULT 0");
|
|
db.execSQL("ALTER TABLE `identity` ADD COLUMN `read_receipt` INTEGER NOT NULL DEFAULT 0");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(19, 20) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `folder` ADD COLUMN `notify` INTEGER NOT NULL DEFAULT 0");
|
|
db.execSQL("UPDATE `folder` SET notify = unified");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(20, 21) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `identity` ADD COLUMN `display` TEXT");
|
|
db.execSQL("ALTER TABLE `identity` ADD COLUMN `bcc` TEXT");
|
|
}
|
|
})
|
|
.addMigrations(new Migration(21, 22) {
|
|
@Override
|
|
public void migrate(SupportSQLiteDatabase db) {
|
|
Log.i(Helper.TAG, "DB migration from version " + startVersion + " to " + endVersion);
|
|
db.execSQL("ALTER TABLE `folder` ADD COLUMN `initialize` INTEGER NOT NULL DEFAULT 1");
|
|
db.execSQL("UPDATE `folder` SET sync_days = 1");
|
|
}
|
|
})
|
|
.build();
|
|
}
|
|
|
|
public static class Converters {
|
|
@TypeConverter
|
|
public static String[] toStringArray(String value) {
|
|
if (value == null)
|
|
return new String[0];
|
|
else
|
|
return TextUtils.split(value, " ");
|
|
}
|
|
|
|
@TypeConverter
|
|
public static String fromStringArray(String[] value) {
|
|
if (value == null || value.length == 0)
|
|
return null;
|
|
else
|
|
return TextUtils.join(" ", value);
|
|
}
|
|
|
|
@TypeConverter
|
|
public static String encodeAddresses(Address[] addresses) {
|
|
if (addresses == null)
|
|
return null;
|
|
JSONArray jaddresses = new JSONArray();
|
|
for (Address address : addresses)
|
|
try {
|
|
if (address instanceof InternetAddress) {
|
|
String a = ((InternetAddress) address).getAddress();
|
|
String p = ((InternetAddress) address).getPersonal();
|
|
JSONObject jaddress = new JSONObject();
|
|
if (a != null)
|
|
jaddress.put("address", a);
|
|
if (p != null)
|
|
jaddress.put("personal", p);
|
|
jaddresses.put(jaddress);
|
|
} else {
|
|
JSONObject jaddress = new JSONObject();
|
|
jaddress.put("address", address.toString());
|
|
jaddresses.put(jaddress);
|
|
}
|
|
} catch (JSONException ex) {
|
|
Log.e(Helper.TAG, ex + "\n" + Log.getStackTraceString(ex));
|
|
}
|
|
return jaddresses.toString();
|
|
}
|
|
|
|
@TypeConverter
|
|
public static Address[] decodeAddresses(String json) {
|
|
if (json == null)
|
|
return null;
|
|
List<Address> result = new ArrayList<>();
|
|
try {
|
|
JSONArray jaddresses = new JSONArray(json);
|
|
for (int i = 0; i < jaddresses.length(); i++) {
|
|
JSONObject jaddress = (JSONObject) jaddresses.get(i);
|
|
if (jaddress.has("personal"))
|
|
result.add(new InternetAddress(
|
|
jaddress.getString("address"),
|
|
jaddress.getString("personal")));
|
|
else
|
|
result.add(new InternetAddress(
|
|
jaddress.getString("address")));
|
|
}
|
|
} catch (Throwable ex) {
|
|
// Compose can store invalid addresses
|
|
Log.w(Helper.TAG, ex + "\n" + Log.getStackTraceString(ex));
|
|
}
|
|
return result.toArray(new Address[0]);
|
|
}
|
|
}
|
|
}
|
|
|