Removes Tx, because I get 'busy buffer' error. (crawler)

1 files changed, 3 insertions, 21 deletions

diff --git a/crawler/scrape.go b/crawler/scrape.go
index 18aa4b9..d7797ca 100644
--- a/crawler/scrape.go
+++ b/crawler/scrape.go
@@ -16,9 +16,7 @@ func (app *App) ScrapeHTML(shops []Shop) {
 
 	}
 
-	/*
-		Wait until all go routines finished
-	*/
+	// Wait until all go routines finished
 	for i := 0; i < count; i++ {
 		<-wait
 	}
@@ -27,9 +25,7 @@ func (app *App) ScrapeHTML(shops []Shop) {
 func (app *App) Scrape(shop Shop, wait chan bool) {
 	var W []Angebot
 	var err error
-	txFailed := false
 
-	Tx, err := app.DB.Beginx()
 	if err != nil {
 		Fatal(err, "scrape.go: Starting transaction failed. Shop: "+shop.Name)
 	}
@@ -45,29 +41,15 @@ func (app *App) Scrape(shop Shop, wait chan bool) {
 		}
 	}
 
-	err = app.save_offer(Tx, W)
+	err = app.save_offer(W)
 	if err != nil {
-		txFailed = true
 		Warn(err, "Saving offers failed. Shop: "+shop.Name)
 	}
-	err = app.remove_expired(Tx, W, shop)
+	err = app.remove_expired(W, shop)
 	if err != nil {
-		txFailed = true
 		Warn(err, "Removing expired offers failed. Shop: "+shop.Name)
 	}
 
-	if txFailed {
-		err = Tx.Rollback()
-		if err != nil {
-			Fatal(err, "scrape.go: Rollback transaction failed")
-		}
-	} else {
-		err = Tx.Commit()
-		if err != nil {
-			Fatal(err, "scrape.go: Committing transaction failed")
-		}
-	}
-
 	wait <- true
 }