diff --git a/go.mod b/go.mod
index e0605ec..73ee4bc 100644
--- a/go.mod
+++ b/go.mod
@@ -4,6 +4,7 @@ go 1.19
 
 require (
 	github.com/gosimple/slug v1.13.1
+	github.com/joho/godotenv v1.5.1
 	github.com/leesper/couchdb-golang v1.2.1
 	gorm.io/driver/mysql v1.5.0
 	gorm.io/gorm v1.25.0
diff --git a/go.sum b/go.sum
index e8dc9c1..8bd6540 100644
--- a/go.sum
+++ b/go.sum
@@ -8,6 +8,8 @@ github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD
 github.com/jinzhu/inflection v1.0.0/go.mod h1:h+uFLlag+Qp1Va5pdKtLDYj+kHp5pxUVkryuEj+Srlc=
 github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=
 github.com/jinzhu/now v1.1.5/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=
+github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
+github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
 github.com/leesper/couchdb-golang v1.2.1 h1:FqSaTxxT2mVRLbxGQVkZakRRoSzWhPmV8UEKYjA/GWc=
 github.com/leesper/couchdb-golang v1.2.1/go.mod h1:OU3FDAM3mazHx15oi8Hm+egTMneBUqepwnh0LuBSH54=
 gorm.io/driver/mysql v1.5.0 h1:6hSAT5QcyIaty0jfnff0z0CLDjyRgZ8mlMHLqSt7uXM=
diff --git a/main.go b/main.go
index feadddc..c670f14 100644
--- a/main.go
+++ b/main.go
@@ -2,13 +2,32 @@ package main
 
 import (
 	"fmt"
+	"github.com/joho/godotenv"
+	"gorm.io/driver/mysql"
+	"gorm.io/gorm"
 	"log"
 	"os"
+	"os/signal"
 	"sarga_updater/bagisto_models"
+	helper "sarga_updater/helpers"
 	"sarga_updater/repositories"
+	"syscall"
 	"time"
 )
 
+func init() {
+	// logging setup
+	helper.Setup()
+
+	log.Println("init function")
+
+	// init .env
+	err := godotenv.Load()
+	if err != nil {
+		log.Fatal(err)
+	}
+}
+
 func main() {
 
 	fmt.Println("main started")
@@ -17,7 +36,7 @@ func main() {
 	dsn := os.Getenv("BAZA")
 	log.Println("DSN => ", dsn)
 	// Connect to the database
-	/*db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})
+	db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})
 	if err != nil {
 		log.Fatalf("Error connecting to database: %s", err)
 	}
@@ -48,7 +67,7 @@ func main() {
 	err = sqlDB.Close()
 	if err != nil {
 		log.Fatalf("Error closing database connection: %s", err)
-	}*/
+	}
 }
 
 func worker(importer *repositories.Importer, stopCh <-chan struct{}, updatePeriod time.Duration) {