105 lines
2.0 KiB
Go
105 lines
2.0 KiB
Go
// Copyright 2023 wanderer <a_mirre at utb dot cz>
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
package db
|
|
|
|
import (
|
|
"context"
|
|
|
|
"git.dotya.ml/mirre-mt/pcmt/ent"
|
|
"git.dotya.ml/mirre-mt/pcmt/ent/migrate"
|
|
"git.dotya.ml/mirre-mt/pcmt/slogging"
|
|
"golang.org/x/exp/slog"
|
|
)
|
|
|
|
// CtxKey serves as a key to context values for this package.
|
|
type CtxKey struct{}
|
|
|
|
// DropAll deletes an re-creates the whole db.
|
|
func DropAll(ctx context.Context, client *ent.Client) error {
|
|
slogger := ctx.Value(CtxKey{}).(*slogging.Slogger)
|
|
log := *slogger
|
|
|
|
log.Logger = log.Logger.With(
|
|
slog.Group("pcmt extra", slog.String("module", "modules/db")),
|
|
)
|
|
|
|
err := client.Schema.
|
|
Create(
|
|
ctx,
|
|
migrate.WithDropIndex(true),
|
|
migrate.WithDropColumn(true),
|
|
)
|
|
if err != nil {
|
|
log.Errorf("failed to recreate schema resources: %v", err)
|
|
return err
|
|
}
|
|
|
|
return err
|
|
}
|
|
|
|
// IsSetUp deletes the whole db.
|
|
func IsSetUp(ctx context.Context, client *ent.Client) (bool, error) {
|
|
slogger := ctx.Value(CtxKey{}).(*slogging.Slogger)
|
|
log := *slogger
|
|
|
|
log.Logger = log.Logger.With(
|
|
slog.Group("pcmt extra", slog.String("module", "modules/db")),
|
|
)
|
|
|
|
is, err := client.Setup.
|
|
Query().
|
|
Only(ctx)
|
|
|
|
if is != nil {
|
|
log.Debug("apparently the db is already set up")
|
|
} else {
|
|
log.Debug("apparently the db was not yet set up")
|
|
}
|
|
|
|
switch {
|
|
case ent.IsNotFound(err) && is == nil:
|
|
return false, nil
|
|
|
|
case ent.IsNotSingular(err):
|
|
return true, err
|
|
|
|
case err != nil:
|
|
return false, err
|
|
|
|
case err == nil && is != nil:
|
|
return true, nil
|
|
}
|
|
|
|
return false, nil
|
|
}
|
|
|
|
// SetUp creates the set-up record indicating that the DB has been set up.
|
|
func SetUp(ctx context.Context, client *ent.Client) error {
|
|
isSetup, err := IsSetUp(ctx, client)
|
|
|
|
switch {
|
|
case err == nil && isSetup:
|
|
return nil
|
|
|
|
case err != nil && isSetup:
|
|
return err
|
|
|
|
case err != nil && !isSetup:
|
|
err = DropAll(ctx, client)
|
|
if err != nil {
|
|
return nil
|
|
}
|
|
|
|
// create a set-up record.
|
|
_, err = client.Setup.
|
|
Create().
|
|
Save(ctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
return err
|
|
}
|