package com.topjohnwu.magisk.database;

import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;

import com.topjohnwu.magisk.module.Repo;
import com.topjohnwu.magisk.utils.Logger;
import com.topjohnwu.magisk.utils.ValueSortedMap;

import java.util.Collection;

public class RepoDatabaseHelper extends SQLiteOpenHelper {

    private static final int DATABASE_VER = 1;
    private static final String TABLE_NAME = "repos";

    public RepoDatabaseHelper(Context context) {
        super(context, "repo.db", null, DATABASE_VER);
    }

    @Override
    public void onCreate(SQLiteDatabase db) {
        onUpgrade(db, 0, DATABASE_VER);
    }

    @Override
    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
        if (oldVersion == 0) {
            db.execSQL(
                    "CREATE TABLE IF NOT EXISTS " + TABLE_NAME + " " +
                    "(id TEXT, name TEXT, version TEXT, versionCode INT, " +
                    "author TEXT, description TEXT, repo_name TEXT, last_update INT, " +
                    "PRIMARY KEY(id))");
        }
        // No upgrades yet
    }

    public void addRepoMap(ValueSortedMap<String, Repo> map) {
        SQLiteDatabase db = getWritableDatabase();
        Collection<Repo> list = map.values();
        for (Repo repo : list) {
            db.replace(TABLE_NAME, null, repo.getContentValues());
        }
        db.close();
    }

    public void clearRepo() {
        SQLiteDatabase db = getWritableDatabase();
        db.delete(TABLE_NAME, null, null);
        db.close();
    }

    public void removeRepo(ValueSortedMap<String, Repo> map) {
        SQLiteDatabase db = getWritableDatabase();
        Collection<Repo> list = map.values();
        for (Repo repo : list) {
            db.delete(TABLE_NAME, "id=?", new String[] { repo.getId() });
        }
        db.close();
    }

    public ValueSortedMap<String, Repo> getRepoMap() {
        ValueSortedMap<String, Repo> ret = new ValueSortedMap<>();
        SQLiteDatabase db = getReadableDatabase();
        Repo repo;
        try (Cursor c = db.query(TABLE_NAME, null, null, null, null, null, null)) {
            while (c.moveToNext()) {
                repo = new Repo(c);
                Logger.dev("Load from cache: " + repo.getId());
                ret.put(repo.getId(), repo);
            }
        }
        db.close();
        return ret;
    }
}