import 'dart:io';

import 'package:fmassive/gym_sets.dart';
import 'package:fmassive/main.dart';
import 'package:fmassive/plans.dart';
import 'package:moor/ffi.dart';
import 'package:moor/moor.dart';
import 'package:path/path.dart';
import 'package:sqflite/sqflite.dart';

import 'settings.dart';

part 'database.g.dart';

@UseMoor(tables: [Settings, GymSets, Plans])
class MyDatabase extends _$MyDatabase {
  MyDatabase() : super(_openConnection());

  @override
  int get schemaVersion => 2;

  @override
  MigrationStrategy get migration => MigrationStrategy(
        onCreate: (Migrator m) async {
          print('Creating...');
          await m.createAll();
          var data = await (db.select(db.settings)..limit(1)).get();
          if (data.isEmpty) await db.into(db.settings).insert(defaultSettings);
        },
        onUpgrade: (Migrator m, int from, int to) async {
          if (from == 1) {
            await m.create(db.gymSets);
            await db.customInsert('''
              INSERT INTO gym_sets(id, name, reps, weight, created, unit, hidden, image, sets, minutes, seconds, steps) 
                SELECT id, name, reps, weight, created, unit, hidden, image, sets, minutes, seconds, steps FROM sets
            ''');
            await m.addColumn(settings, settings.darkColor);
            await db.customStatement('''
              UPDATE settings SET dark_color = darkColor
            ''');
            await m.addColumn(settings, settings.lightColor);
            await db.customStatement('''
              UPDATE settings SET light_color = lightColor
            ''');
            await m.addColumn(settings, settings.showDate);
            await db.customStatement('''
              UPDATE settings SET show_date = showDate
            ''');
            await m.addColumn(settings, settings.showSets);
            await db.customStatement('''
              UPDATE settings SET show_sets = showSets
            ''');
            await m.addColumn(settings, settings.showUnit);
            await db.customStatement('''
              UPDATE settings SET show_unit = showUnit
            ''');
          }
        },
      );
}

LazyDatabase _openConnection() {
  return LazyDatabase(() async {
    final dbFolder = await getDatabasesPath();
    final file = File(join(dbFolder, 'massive.db'));
    return VmDatabase(file, logStatements: true);
  });
}