import crypto from 'crypto';

const TABLE_NAME = 'strapi_database_schema';
var createSchemaStorage = ((db)=>{
    const hasSchemaTable = ()=>db.getSchemaConnection().hasTable(TABLE_NAME);
    const createSchemaTable = ()=>{
        return db.getSchemaConnection().createTable(TABLE_NAME, (t)=>{
            t.increments('id');
            t.json('schema');
            t.datetime('time', {
                useTz: false
            });
            t.string('hash');
        });
    };
    const checkTableExists = async ()=>{
        if (!await hasSchemaTable()) {
            await createSchemaTable();
        }
    };
    return {
        async read () {
            await checkTableExists();
            // NOTE: We get the ID first before fetching the exact entry for performance on MySQL/MariaDB
            // See: https://github.com/strapi/strapi/issues/20312
            const getSchemaID = await db.getConnection().select('id').from(TABLE_NAME).orderBy('time', 'DESC').first();
            if (!getSchemaID) {
                return null;
            }
            const res = await db.getConnection().select('*').from(TABLE_NAME).where({
                id: getSchemaID.id
            }).first();
            if (!res) {
                return null;
            }
            const parsedSchema = typeof res.schema === 'object' ? res.schema : JSON.parse(res.schema);
            return {
                ...res,
                schema: parsedSchema
            };
        },
        hashSchema (schema) {
            return crypto.createHash('sha256').update(JSON.stringify(schema)).digest('hex');
        },
        async add (schema) {
            await checkTableExists();
            // NOTE: we can remove this to add history
            await db.getConnection(TABLE_NAME).delete();
            const time = new Date();
            await db.getConnection().insert({
                schema: JSON.stringify(schema),
                hash: this.hashSchema(schema),
                time
            }).into(TABLE_NAME);
        },
        async clear () {
            await checkTableExists();
            await db.getConnection(TABLE_NAME).truncate();
        }
    };
});

export { createSchemaStorage as default };
//# sourceMappingURL=storage.mjs.map