Method DedicatedDB

api/pkg/di/container.go:252–290

DedicatedDB creates an instance of gorm.DB if it has not been created already

()

// DedicatedDB creates an instance of gorm.DB if it has not been created already
func (container *Container) DedicatedDB() (db *gorm.DB) {
	container.logger.Debug(fmt.Sprintf("creating %T", db))
	if container.dedicatedDB != nil {
		return container.dedicatedDB
	}

	config := &gorm.Config{
		TranslateError: true,
	}
	if isLocal() {
		config = &gorm.Config{Logger: container.GormLogger()}
	}

	db, err := container.connect(os.Getenv("DATABASE_URL_DEDICATED"), config)
	if err != nil {
		container.logger.Fatal(err)
	}

	if err = db.Use(tracing.NewPlugin()); err != nil {
		container.logger.Fatal(stacktrace.Propagate(err, "cannot use GORM tracing plugin"))
	}

	container.dedicatedDB = db
	if os.Getenv("DATABASE_MIGRATION_SKIP") != "" {
		container.logger.Debug(fmt.Sprintf("skipping migrations for [%T]", db))
		return container.dedicatedDB
	}

	container.logger.Debug(fmt.Sprintf("Running migrations for dedicated [%T]", db))
	if err = db.AutoMigrate(&entities.Heartbeat{}); err != nil {
		container.logger.Fatal(stacktrace.Propagate(err, fmt.Sprintf("cannot migrate %T", &entities.Heartbeat{})))
	}

	if err = db.AutoMigrate(&entities.HeartbeatMonitor{}); err != nil {
		container.logger.Fatal(stacktrace.Propagate(err, fmt.Sprintf("cannot migrate %T", &entities.HeartbeatMonitor{})))
	}

	return container.dedicatedDB
}

// MongoDB creates a *mongo.Database connection to MongoDB Atlas
func (container *Container) MongoDB() *mongoDriver.Database {