package executor

import (
	"context"

	"github.com/everything-on-mysql/cassandra-on-mysql/pkg/cql/systemtables"
)

func (e *Executor) currentSchemaVersion(ctx context.Context, user, password string) (string, error) {
	if e == nil || e.systemState == nil {
		return systemtables.CurrentSchemaVersion(), nil
	}
	if err := e.systemState.EnsureSchemaVersion(ctx, user, password); err != nil {
		return "", err
	}
	return e.systemState.SchemaVersion(), nil
}

func (e *Executor) bumpSchemaVersion(ctx context.Context, user, password string) error {
	if e == nil || e.systemState == nil {
		systemtables.BumpSchemaVersion()
		return nil
	}
	_, err := e.systemState.BumpSchemaVersion(ctx, user, password)
	return err
}