database

var Migrate action.Action = func(ctx context.Context) error {
	l := logger.WithField("func", "Migrate")

	l.Info("running database migration")
	dbClient, err := bun.New(ctx)
	if err != nil {
		l.Errorf("db: %s", err.Error())

		return err
	}
	defer func() {
		err := dbClient.Close(ctx)
		if err != nil {
			l.Errorf("closing db: %s", err.Error())
		}
	}()

	err = dbClient.DoMigration(ctx)
	if err != nil {
		l.Errorf("migration: %s", err.Error())

		return err
	}

	return nil
}