repo

var (
	ErrUserAlreadyExists = errors.New("user already exists")
	ErrUserNotFound      = errors.New("user not found")
	UserRepo             = NewUserRepo(PostgresDB)
)

var MongoDBClient = func() *mongo.Client {
	client, err := mongo.Connect(context.TODO(), options.Client().ApplyURI(env.MONGODB_URL))
	if err != nil {
		panic("could not connect to mongodb: " + err.Error())
	}
	util.RegisterCleanUp("mongodb connection", func() error {
		return client.Disconnect(context.TODO())
	})
	return client
}()

var PostgresDB = func() *sql.DB {
	db, err := sql.Open("postgres", env.DB_URL)
	if err != nil {
		panic("could not connect to PostgreSQL database: " + err.Error())
	}
	util.RegisterCleanUp("postgres connection", func() error { return db.Close() })
	return db
}()

var RedisClient = func() *redis.Client {
	client := redis.NewClient(&redis.Options{
		Addr:     env.REDIS_HOST + ":" + env.REDIS_PORT,
		Username: env.REDIS_USERNAME,
		Password: env.REDIS_PASSWORD,
	})
	util.RegisterCleanUp("redis connection", func() error { return client.Close() })
	return client
}()

var SQLiteDB = func() *sql.DB {
	db, err := sql.Open("sqlite", "sqlite.db")
	if err != nil {
		panic("could not open SQLite database: " + err.Error())
	}
	util.RegisterCleanUp("sqlite connection", func() error { return db.Close() })
	return db
}()