From 73b24388c8e17f4b6bb039cfd31c669004dbab9f Mon Sep 17 00:00:00 2001
From: merdan <merdan.m@gmail.com>
Date: Fri, 9 Sep 2022 11:05:36 +0500
Subject: [PATCH] link parse fx1

---
 controllers/ParseController.go |  7 ++++++-
 main.go                        | 23 +++++++++++++++++++++++
 2 files changed, 29 insertions(+), 1 deletion(-)

diff --git a/controllers/ParseController.go b/controllers/ParseController.go
index 2031915..49b6e88 100644
--- a/controllers/ParseController.go
+++ b/controllers/ParseController.go
@@ -48,7 +48,12 @@ func ParseLink(w http.ResponseWriter, route *http.Request) {
 		return
 	}
 
-	ImportProduct(jsonProduct, baza)
+	err = ImportProduct(jsonProduct, baza)
+
+	if err != nil {
+		helper.Error(err)
+		return
+	}
 
 	w.WriteHeader(http.StatusOK)
 	json.NewEncoder(w).Encode(map[string]string{
diff --git a/main.go b/main.go
index b0001ce..5b1069b 100644
--- a/main.go
+++ b/main.go
@@ -2,14 +2,18 @@ package main
 
 import (
 	"db_service/controllers"
+	helper "db_service/pkg"
 	"github.com/gorilla/mux"
 	"github.com/joho/godotenv"
+	"github.com/leesper/couchdb-golang"
 	"log"
 	"net/http"
 	"os"
 )
 
 func init() {
+	// logging setup
+	helper.Setup()
 
 	log.Println("init function")
 
@@ -18,6 +22,25 @@ func init() {
 	if err != nil {
 		log.Fatal(err.Error())
 	}
+	// initialize couch db
+	err = InitCouchDbServer()
+}
+
+func InitCouchDbServer() error {
+	var err error
+
+	helper.CdbServer, err = couchdb.NewServer(os.Getenv("couch_db_source"))
+	if err != nil {
+		helper.Error(err.Error())
+		return err
+	}
+	version, err := helper.CdbServer.Version()
+	if err != nil {
+		helper.Error("couchdb not initialized. ", err.Error())
+		return err
+	}
+	helper.Info("couchdb running with version " + version)
+	return nil
 }
 
 func main() {