db

var ErrNotFound = errors.New("object not found")

var NewAnalyzerDAO = func(config *shared.AppConfig) (AnalyzerDAO, error) {
	client, err := NewDBClient(config)
	if err != nil {
		return nil, err
	}
	err = client.AutoMigrate(analyzer.Analyzer{})
	if err != nil {
		return nil, err
	}

	dao := &blobAnalyzerDAO{client: client, config: config}

	dao.preloadDefaultAnalyzersSilently(context.Background(), analyzersDataFile)

	return dao, nil
}

var NewAnalyzerRuleDAO = func(config *shared.AppConfig) (AnalyzerRuleDAO, error) {
	shared.LogInfof("init NewAnalyzerRuleDAO")
	client, err := NewDBClient(config)
	if err != nil {
		return nil, err
	}
	err = client.AutoMigrate(analyzer.Rule{})
	if err != nil {
		return nil, err
	}

	dao := &blobAnalyzerRuleDAO{client: client, config: config}

	err = dao.preloadDefaultAnalyzerRulesSilently(context.Background(), "internal/data", "rules")
	shared.LogInfof("preloading rules")
	if err != nil {
		shared.LogWarnf("failed to preload rules: %s", err.Error())
	} else {
		shared.LogInfof("preloaded rules")
	}

	return dao, nil
}

var NewOrganizationDAO = func(config *shared.AppConfig) (OrganizationDAO, error) {
	client, err := NewDBClient(config)
	if err != nil {
		return nil, err
	}
	err = client.AutoMigrate(models.Organization{})
	if err != nil {
		return nil, err
	}

	dao := &blobOrganizationDAO{client: client, config: config}
	return dao, nil
}

var NewServiceDAO = func(config *shared.AppConfig) (ServiceDAO, error) {
	client, err := NewDBClient(config)
	if err != nil {
		return nil, err
	}
	err = client.AutoMigrate(models.Service{})
	if err != nil {
		return nil, err
	}

	dao := &blobServiceDAO{client: client, config: config}
	return dao, nil
}

var NewSpecAnalysisDAO = func(config *shared.AppConfig) (SpecAnalysisDAO, error) {
	client, err := NewDBClient(config)
	if err != nil {
		return nil, err
	}
	err = client.AutoMigrate(models.SpecAnalysis{})
	if err != nil {
		return nil, err
	}

	dao := &blobSpecAnalysisDAO{client: client, config: config}
	return dao, nil
}

var NewSpecDAO = func(config *shared.AppConfig) (SpecDAO, error) {
	client, err := NewDBClient(config)
	if err != nil {
		return nil, err
	}
	err = client.AutoMigrate(models.Spec{})
	if err != nil {
		return nil, err
	}

	dao := &blobSpecDAO{client: client, config: config}
	return dao, nil
}

var NewSpecDiffDAO = func(config *shared.AppConfig) (SpecDiffDAO, error) {
	client, err := NewDBClient(config)
	if err != nil {
		return nil, err
	}
	err = client.AutoMigrate(models.SpecDiff{})
	if err != nil {
		return nil, err
	}

	dao := &blobSpecDiffDAO{client: client, config: config}
	return dao, nil
}