Add pool

cmd/eksterd/http.go

@@ -516,28 +516,29 @@ func (h *mainHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 
 			sess, err := loadSession(sessionVar, conn)
 
+			if err != nil {
+				http.Redirect(w, r, "/", 302)
+				return
+			}
+
 			sess.AuthorizationEndpoint = endpoints.AuthorizationEndpoint
 			sess.Me = meURL.String()
 			sess.State = state
 			sess.RedirectURI = redirectURI
 			sess.LoggedIn = false
-			saveSession(sessionVar, &sess, conn)
 
-			authenticationURL := indieauth.CreateAuthenticationURL(*authURL, meURL.String(), ClientID, redirectURI, state)
+			err = saveSession(sessionVar, &sess, conn)
-
+			if err != nil {
-			http.Redirect(w, r, authenticationURL, 302)
-			return
-		} else if r.URL.Path == "/session/logout" {
-			c, err := r.Cookie("session")
-
-			if err == http.ErrNoCookie {
 				http.Redirect(w, r, "/", 302)
 				return
 			}
 
-			sessionVar := c.Value
+			authenticationURL := indieauth.CreateAuthenticationURL(*authURL, meURL.String(), ClientID, redirectURI, state)
-			conn.Do("DEL", "session:"+sessionVar)
+			http.Redirect(w, r, authenticationURL, 302)
-			http.Redirect(w, r, "/", 302)
+
+			return
+		} else if r.URL.Path == "/session/logout" {
+			httpSessionLogout(r, w, conn)
 			return
 		} else if r.URL.Path == "/auth/approve" {
 			// create a code
@@ -668,3 +669,16 @@ func (h *mainHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 
 	http.NotFound(w, r)
 }
+
+func httpSessionLogout(r *http.Request, w http.ResponseWriter, conn redis.Conn) {
+	c, err := r.Cookie("session")
+	if err == http.ErrNoCookie {
+		http.Redirect(w, r, "/", 302)
+		return
+	}
+	if err == nil {
+		sessionVar := c.Value
+		_, _ = conn.Do("DEL", "session:"+sessionVar)
+	}
+	http.Redirect(w, r, "/", 302)
+}

cmd/eksterd/main.go

@@ -126,6 +126,7 @@ func NewApp(options AppOptions) (*App, error) {
 
 	http.Handle("/micropub", &micropubHandler{
 		Backend: app.backend,
+		pool:    options.pool,
 	})
 
 	handler, broker := server.NewMicrosubHandler(app.backend)