use Amp\Mysql\MysqlConfig;
use Amp\Sync\LocalMutex;
use BenChallis\SqlMigrations\ClassDiscovery\PhpNamespace;
use BenChallis\SqlMigrations\ClassDiscovery\ReadableDirectory;
use BenChallis\SqlMigrations\Migration\Discovery\RevisionDiscovererFactory;
use BenChallis\SqlMigrations\Migration\Metadata\MySql\MySqlMetadataStore;
use BenChallis\SqlMigrations\Migration\Metadata\MySql\MySqlSchemaManager;
use BenChallis\SqlMigrations\Migration\Metadata\SchemaUpdatingMetadataStore;
use BenChallis\SqlMigrations\Migration\MigrationCollector;
use BenChallis\SqlMigrations\Migration\MigrationsFactory;
use BenChallis\SqlMigrations\Migration\Migrator;
use function Amp\Mysql\connect;

$connection = connect(MysqlConfig::fromAuthority(DB_HOST, DB_USER, DB_PASS, DB_DATABASE));
$metadata = new SchemaUpdatingMetadataStore(
    new MySqlSchemaManager(DB_DATABASE), 
    $connection, 
    new MySqlMetadataStore($connection)
);

$migrations = MigrationsFactory::create(
    $metadata,
    new MigrationCollector(
        $metadata, 
        RevisionDiscovererFactory::create(ReadableDirectory::fromString(__DIR__.'/vendor')),
    ),
    PhpNamespace::fromString('App\Migrations'),
);

$migrator = new Migrator($migrations, $connection);

$migrator->migrate(new LocalMutex()); // You'll want to use a distributed (i.e. Redis) lock instead here.