Aegis/app/src/main/java/me/impy/aegis/db/DatabaseManager.java

package me.impy.aegis.db;

import android.content.Context;
import android.os.Environment;

import org.json.JSONObject;

import java.io.DataInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.List;
import java.util.UUID;

import me.impy.aegis.BuildConfig;

public class DatabaseManager {
    private static final String FILENAME = "aegis.json";
    private static final String FILENAME_EXPORT = "aegis_export.json";
    private static final String FILENAME_EXPORT_PLAIN = "aegis_export_plain.json";

    private Database _db;
    private DatabaseFile _file;
    private DatabaseFileCredentials _creds;
    private boolean _encrypt;

    private Context _context;

    public DatabaseManager(Context context) {
        _context = context;
    }

    public boolean fileExists() {
        File file = new File(_context.getFilesDir(), FILENAME);
        return file.exists() && file.isFile();
    }

    public void load() throws DatabaseManagerException {
        assertState(true, false);

        try (FileInputStream file = _context.openFileInput(FILENAME)) {
            byte[] fileBytes = new byte[(int) file.getChannel().size()];
            DataInputStream stream = new DataInputStream(file);
            stream.readFully(fileBytes);
            stream.close();

            _file = DatabaseFile.fromBytes(fileBytes);
            _encrypt = _file.isEncrypted();
            if (!isEncryptionEnabled()) {
                JSONObject obj = _file.getContent();
                _db = Database.fromJson(obj);
            }
        } catch (IOException | DatabaseFileException | DatabaseException e) {
            throw new DatabaseManagerException(e);
        }
    }

    public void lock() {
        assertState(false, true);
        _creds = null;
        _db = null;
    }

    public void unlock(DatabaseFileCredentials creds) throws DatabaseManagerException {
        assertState(true, true);

        try {
            JSONObject obj = _file.getContent(creds);
            _db = Database.fromJson(obj);
            _creds = creds;
        } catch (DatabaseFileException | DatabaseException e) {
            throw new DatabaseManagerException(e);
        }
    }

    public static void save(Context context, DatabaseFile file) throws DatabaseManagerException {
        byte[] bytes = file.toBytes();
        try (FileOutputStream stream = context.openFileOutput(FILENAME, Context.MODE_PRIVATE)) {
            stream.write(bytes);
        } catch (IOException e) {
            throw new DatabaseManagerException(e);
        }
    }

    public void save() throws DatabaseManagerException {
        assertState(false, true);

        try {
            JSONObject obj = _db.toJson();
            if (isEncryptionEnabled()) {
                _file.setContent(obj, _creds);
            } else {
                _file.setContent(obj);
            }
            save(_context, _file);
        } catch (DatabaseFileException e) {
            throw new DatabaseManagerException(e);
        }
    }

    public String export(boolean encrypt) throws DatabaseManagerException {
        assertState(false, true);

        try {
            DatabaseFile dbFile = new DatabaseFile();
            if (encrypt && isEncryptionEnabled()) {
                dbFile.setContent(_db.toJson(), _creds);
            } else {
                dbFile.setContent(_db.toJson());
            }

            String dirName = !BuildConfig.DEBUG ? "Aegis" : "AegisDebug";
            File dir = new File(Environment.getExternalStorageDirectory(), dirName);
            if (!dir.exists() && !dir.mkdirs()) {
                throw new IOException("error creating external storage directory");
            }

            byte[] bytes = dbFile.toBytes();
            File file = new File(dir.getAbsolutePath(), encrypt ? FILENAME_EXPORT : FILENAME_EXPORT_PLAIN);
            try (FileOutputStream stream = new FileOutputStream(file)) {
                stream.write(bytes);
            }

            return file.getAbsolutePath();
        } catch (IOException | DatabaseFileException e) {
            throw new DatabaseManagerException(e);
        }
    }

    public void addEntry(DatabaseEntry entry) {
        assertState(false, true);
        _db.addEntry(entry);
    }

    public void removeEntry(DatabaseEntry entry) {
        assertState(false, true);
        _db.removeEntry(entry);
    }

    public void replaceEntry(DatabaseEntry entry) {
        assertState(false, true);
        _db.replaceEntry(entry);
    }

    public void swapEntries(DatabaseEntry entry1, DatabaseEntry entry2) {
        assertState(false, true);
        _db.swapEntries(entry1, entry2);
    }

    public List<DatabaseEntry> getEntries() {
        assertState(false, true);
        return _db.getEntries();
    }

    public DatabaseEntry getEntryByUUID(UUID uuid) {
        assertState(false, true);
        return _db.getEntryByUUID(uuid);
    }

    public DatabaseFileCredentials getCredentials() {
        assertState(false, true);
        return _creds;
    }

    public void setCredentials(DatabaseFileCredentials creds) {
        assertState(false, true);
        _creds = creds;
    }

    public DatabaseFile.Header getFileHeader() {
        assertLoaded(true);
        return _file.getHeader();
    }

    public boolean isEncryptionEnabled() {
        assertLoaded(true);
        return _encrypt;
    }

    public void enableEncryption(DatabaseFileCredentials creds) throws DatabaseManagerException {
        assertState(false, true);
        _creds = creds;
        _encrypt = true;
        save();
    }

    public void disableEncryption() throws DatabaseManagerException {
        assertState(false, true);
        _creds = null;
        _encrypt = false;
        save();
    }

    public boolean isLoaded() {
        return _file != null;
    }

    public boolean isLocked() {
        return _db == null;
    }

    private void assertState(boolean locked, boolean loaded) {
        assertLoaded(loaded);

        if (isLocked() && !locked) {
            throw new AssertionError("database file has not been unlocked yet");
        } else if (!isLocked() && locked) {
            throw new AssertionError("database file has already been unlocked");
        }
    }

    private void assertLoaded(boolean loaded) {
        if (isLoaded() && !loaded) {
            throw new AssertionError("database file has already been loaded");
        } else if (!isLoaded() && loaded) {
            throw new AssertionError("database file has not been loaded yet");
        }
    }
}