backend/admins/users.go

@@ -43,7 +43,7 @@ func GetUsersHandler(env *web.Env, w http.ResponseWriter, r *http.Request) error
 
 	// Fill the users with the polochons
 	for _, u := range users {
-		if !u.PolochonID.Valid {
+		if u.PolochonID.Valid == false {
 			continue
 		}
 		u.Polochon = polochonMap[u.PolochonID.String]

backend/events/channel.go

@@ -44,19 +44,19 @@ func (c *Channel) writer() {
 	for {
 		select {
 		case <-pingTicker.C:
-			_ = c.conn.SetWriteDeadline(time.Now().Add(writeWait))
+			c.conn.SetWriteDeadline(time.Now().Add(writeWait))
 			if err := c.conn.WriteMessage(websocket.PingMessage, nil); err != nil {
 				c.log.Warnf("error writing message: %s", err)
 				return
 			}
 		case e := <-c.serverEventStream:
-			_ = c.conn.SetWriteDeadline(time.Now().Add(writeWait))
+			c.conn.SetWriteDeadline(time.Now().Add(writeWait))
 			if err := c.conn.WriteJSON(e); err != nil {
 				c.log.Warnf("error writing JSON message: %s", err)
 				return
 			}
 		case err := <-c.serverErrorStream:
-			_ = c.conn.SetWriteDeadline(time.Now().Add(writeWait))
+			c.conn.SetWriteDeadline(time.Now().Add(writeWait))
 			if err := c.conn.WriteJSON(err); err != nil {
 				c.log.Warnf("error writing JSON error: %s", err)
 				return
@@ -71,7 +71,7 @@ func (c *Channel) writer() {
 // go routine reading messages from the websocket connection
 func (c *Channel) reader() {
 	// Read loop
-	_ = c.conn.SetReadDeadline(time.Now().Add(pongWait))
+	c.conn.SetReadDeadline(time.Now().Add(pongWait))
 	for {
 		msg := ClientMessage{}
 

backend/events/handlers.go

@@ -51,7 +51,7 @@ func WsHandler(env *web.Env, w http.ResponseWriter, r *http.Request) error {
 
 	// The pong handler only postpone the read deadline
 	ws.SetPongHandler(func(string) error {
-		_ = ws.SetReadDeadline(time.Now().Add(pongWait))
+		ws.SetReadDeadline(time.Now().Add(pongWait))
 		return nil
 	})
 

backend/events/polochons.go

@@ -101,10 +101,7 @@ func (p *PolochonEventers) Unsubscribe(chanl *Channel) {
 		return
 	}
 
-	if err := tn.Unsubscribe(chanl); err != nil {
+	tn.Unsubscribe(chanl)
-		p.log.Errorf("failed to unsubscribe eventer:  %s", err.Error())
-		return
-	}
 
 	if len(tn.Subscribers()) == 0 {
 		p.log.Debugf("empty subscribers for this polochon, delete it")

backend/main.go

@@ -21,12 +21,6 @@ import (
 )
 
 func main() {
-	if err := run(); err != nil {
-		fmt.Fprintf(os.Stderr, "error while running the app: %s\n", err.Error())
-	}
-}
-
-func run() error {
 	var cfgPath string
 	cfgPath = os.Getenv("CONFIG_FILE")
 	if cfgPath == "" {
@@ -41,13 +35,13 @@ func run() error {
 	log := logrus.NewEntry(logger)
 	cf, err := config.Load(cfgPath, log)
 	if err != nil {
-		return err
+		log.Panic(err)
 	}
 
 	// Connect to the database
 	db, err := sqlx.Connect("postgres", cf.PGDSN)
 	if err != nil {
-		return err
+		log.Panic(err)
 	}
 	backend := &models.Backend{Database: db}
 
@@ -82,22 +76,16 @@ func run() error {
 	if cf.PeriodicRefresh.Enabled {
 		// Refresh the library every 6h
 		env.Log.Debugf("Running refresh cron every %s", cf.PeriodicRefresh.Interval)
-		if err := c.AddFunc(fmt.Sprintf("@every %s", cf.PeriodicRefresh.Interval), func() {
+		c.AddFunc(fmt.Sprintf("@every %s", cf.PeriodicRefresh.Interval), func() {
 			env.Log.Infof("Running refresh cron!")
 			extmedias.Refresh(env)
-		}); err != nil {
+		})
-			return err
-		}
 
 		env.Log.Debugf("Running Imdb refresh cron every 24h")
-		if err := c.AddFunc(fmt.Sprintf("@every 24h"), func() {
+		c.AddFunc(fmt.Sprintf("@every 24h"), func() {
 			env.Log.Infof("Running IMDB refresh cron!")
-			if err := ratings.Refresh(env); err != nil {
+			ratings.Refresh(env)
-				env.Log.Errorf("failed to refresh ratings: %s", err.Error())
+		})
-			}
-		}); err != nil {
-			return err
-		}
 	}
 
 	// Start the cron
@@ -118,9 +106,5 @@ func run() error {
 	// Compress responses
 	n.Use(gzip.Gzip(gzip.DefaultCompression))
 	n.UseHandler(env.Router)
-
+	n.Run(":" + cf.Port)
-	addr := ":" + cf.Port
-	env.Log.Infof("listening on %s", addr)
-
-	return http.ListenAndServe(addr, n)
 }

backend/models/imdb_ratings.go

@@ -7,6 +7,8 @@ import (
 )
 
 const (
+	getRatingQueryByImdbID = ` SELECT * FROM imdb_ratings WHERE imdb_id=$1;`
+
 	upsertRatingQuery = `INSERT INTO imdb_ratings (imdb_id, rating, votes) VALUES (:imdb_id, :rating, :votes)
 	ON CONFLICT (imdb_id)
 	DO UPDATE

backend/models/polochons.go

@@ -15,6 +15,7 @@ const (
 		polochons (name, url, token, admin_id)
 	VALUES ($1, $2, $3, $4)
 	RETURNING id;`
+	getPolochonQuery          = `SELECT * FROM polochons WHERE name=$1;`
 	getPolochonByIDQuery      = `SELECT * FROM polochons WHERE id=$1;`
 	getPolochonsByUserIDQuery = `SELECT * FROM polochons WHERE admin_id=$1 ORDER BY created_at DESC;`
 	updatePolochonQuery       = `UPDATE polochons SET
@@ -93,9 +94,7 @@ func (p *Polochon) Update(ex *sqlx.DB) error {
 		return err
 	}
 	for rows.Next() {
-		if err := rows.StructScan(p); err != nil {
+		rows.StructScan(p)
-			return err
-		}
 	}
 	return nil
 }

backend/models/users.go

@@ -136,9 +136,7 @@ func (u *User) Update(ex *sqlx.DB) error {
 		return err
 	}
 	for rows.Next() {
-		if err := rows.StructScan(u); err != nil {
+		rows.StructScan(u)
-			return err
-		}
 	}
 	return nil
 }

backend/polochons/handlers.go

@@ -272,10 +272,9 @@ func GetMovieWishlistHandler(env *web.Env, w http.ResponseWriter, r *http.Reques
 
 		// Add the movie to the wishlist
 		for _, imdbID := range moviesWishlist.List() {
-			err := wishlist.AddMovie(&polochon.WishedMovie{ImdbID: imdbID})
+			wishlist.AddMovie(&polochon.WishedMovie{
-			if err != nil {
+				ImdbID: imdbID,
-				return env.RenderError(w, err)
+			})
-			}
 		}
 	}
 
@@ -311,14 +310,11 @@ func GetShowWishlistHandler(env *web.Env, w http.ResponseWriter, r *http.Request
 
 		// Add the show to the wishlist
 		for _, show := range moviesWishlist.List() {
-			err := wishlist.AddShow(&polochon.WishedShow{
+			wishlist.AddShow(&polochon.WishedShow{
 				ImdbID:  show.ImdbID,
 				Season:  show.Season,
 				Episode: show.Episode,
 			})
-			if err != nil {
-				return env.RenderError(w, err)
-			}
 		}
 	}
 

backend/tokens/tokens.go

@@ -12,6 +12,7 @@ import (
 
 const (
 	addTokenQuery      = `INSERT INTO tokens (token, username, ip, description) VALUES ($1, $2, $3, $4);`
+	getTokenQuery      = `SELECT * FROM tokens WHERE token=$1;`
 	getUserTokenQuery  = `SELECT * FROM tokens WHERE username=$1 and token=$2;`
 	getUserTokensQuery = `SELECT * FROM tokens WHERE username=$1;`
 	deleteTokenQuery   = `DELETE FROM tokens WHERE username=$1 AND token=$2;`
@@ -99,9 +100,7 @@ func (t *Token) Update(db *sqlx.DB) error {
 		return err
 	}
 	for rows.Next() {
-		if err := rows.StructScan(t); err != nil {
+		rows.StructScan(t)
-			return err
-		}
 	}
 	return nil
 }

backend/web/env.go

@@ -21,6 +21,7 @@ type Env struct {
 	Render     *render.Render
 	Auth       *auth.Authorizer
 	Config     *config.Config
+	loginRoute string
 }
 
 // EnvParams represents parameters for NewEnv