package db

import (
	"github.com/langgenius/dify-plugin-daemon/internal/db/mysql"
	"github.com/langgenius/dify-plugin-daemon/internal/db/pg"
	"github.com/langgenius/dify-plugin-daemon/internal/types/app"
	"github.com/langgenius/dify-plugin-daemon/internal/types/models"
	"github.com/langgenius/dify-plugin-daemon/internal/utils/log"
)

func autoMigrate() error {
	err := DifyPluginDB.AutoMigrate(
		models.Plugin{},
		models.PluginInstallation{},
		models.PluginDeclaration{},
		models.Endpoint{},
		models.ServerlessRuntime{},
		models.ToolInstallation{},
		models.AIModelInstallation{},
		models.InstallTask{},
		models.TenantStorage{},
		models.AgentStrategyInstallation{},
	)

	if err != nil {
		return err
	}

	// check if "declaration" table exists in Plugin/ServerlessRuntime/ToolInstallation/AIModelInstallation/AgentStrategyInstallation
	// delete the column if exists
	ignoreDeclarationColumn := func(table string) error {
		if DifyPluginDB.Migrator().HasColumn(table, "declaration") {
			// remove NOT NULL constraint on declaration column
			if err := DifyPluginDB.Exec("ALTER TABLE " + table + " ALTER COLUMN declaration DROP NOT NULL").Error; err != nil {
				return err
			}
		}
		return nil
	}

	if err := ignoreDeclarationColumn("plugins"); err != nil {
		return err
	}

	if err := ignoreDeclarationColumn("serverless_runtimes"); err != nil {
		return err
	}

	if err := ignoreDeclarationColumn("tool_installations"); err != nil {
		return err
	}

	if err := ignoreDeclarationColumn("ai_model_installations"); err != nil {
		return err
	}

	if err := ignoreDeclarationColumn("agent_strategy_installations"); err != nil {
		return err
	}

	return nil
}

func Init(config *app.Config) {
	var err error
	if config.DBType == "postgresql" {
		DifyPluginDB, err = pg.InitPluginDB(
			config.DBHost,
			int(config.DBPort),
			config.DBDatabase,
			config.DBDefaultDatabase,
			config.DBUsername,
			config.DBPassword,
			config.DBSslMode,
		)
	} else if config.DBType == "mysql" {
		DifyPluginDB, err = mysql.InitPluginDB(
			config.DBHost,
			int(config.DBPort),
			config.DBDatabase,
			config.DBDefaultDatabase,
			config.DBUsername,
			config.DBPassword,
			config.DBSslMode,
		)
	} else {
		log.Panic("unsupported database type: %v", config.DBType)
	}

	if err != nil {
		log.Panic("failed to init dify plugin db: %v", err)
	}

	err = autoMigrate()
	if err != nil {
		log.Panic("failed to auto migrate: %v", err)
	}

	log.Info("dify plugin db initialized")
}

func Close() {
	db, err := DifyPluginDB.DB()
	if err != nil {
		log.Error("failed to close dify plugin db: %v", err)
		return
	}

	err = db.Close()
	if err != nil {
		log.Error("failed to close dify plugin db: %v", err)
		return
	}

	log.Info("dify plugin db closed")
}