# HG changeset patch
# User Sascha L. Teichmann <teichmann@intevation.de>
# Date 1532244325 -7200
# Node ID 8426a92fda00ce70503c06deb3038a389aa5b195
# Parent  ddc7ef95c247c0bedb642d2033a4686429e900ae
Persistent session store: Implmented Renew.

diff -r ddc7ef95c247 -r 8426a92fda00 auth/persistent.go
--- a/auth/persistent.go	Fri Jul 20 23:06:53 2018 +0200
+++ b/auth/persistent.go	Sun Jul 22 09:25:25 2018 +0200
@@ -80,6 +80,16 @@
 	log.Println("cleanToken: Not implemented, yet.")
 }
 
+func (pcp *PersistentConnectionPool) remove(token string) {
+	err := pcp.db.Update(func(tx *bolt.Tx) error {
+		b := tx.Bucket(sessionsBucket)
+		return b.Delete([]byte(token))
+	})
+	if err != nil {
+		log.Printf("error: %v\n", err)
+	}
+}
+
 func (pcp *PersistentConnectionPool) Delete(token string) bool {
 	res := make(chan bool)
 	pcp.cmds <- func(pcp *PersistentConnectionPool) {
@@ -90,18 +100,26 @@
 		}
 		conn.close()
 		delete(pcp.conns, token)
-		err := pcp.db.Update(func(tx *bolt.Tx) error {
-			b := tx.Bucket(sessionsBucket)
-			return b.Delete([]byte(token))
-		})
-		if err != nil {
-			log.Printf("error: %v\n", err)
-		}
+		pcp.remove(token)
 		res <- true
 	}
 	return <-res
 }
 
+func (pcp *PersistentConnectionPool) store(token string, con *Connection) {
+	err := pcp.db.Update(func(tx *bolt.Tx) error {
+		b := tx.Bucket(sessionsBucket)
+		var buf bytes.Buffer
+		if err := con.serialize(&buf); err != nil {
+			return err
+		}
+		return b.Put([]byte(token), buf.Bytes())
+	})
+	if err != nil {
+		log.Printf("error: %v\n", err)
+	}
+}
+
 func (pcp *PersistentConnectionPool) Add(token string, session *Session) *Connection {
 	res := make(chan *Connection)
 
@@ -112,17 +130,7 @@
 			pcp.conns[token] = con
 		}
 		con.set(session)
-		err := pcp.db.Update(func(tx *bolt.Tx) error {
-			b := tx.Bucket(sessionsBucket)
-			var buf bytes.Buffer
-			if err := con.serialize(&buf); err != nil {
-				return err
-			}
-			return b.Put([]byte(token), buf.Bytes())
-		})
-		if err != nil {
-			log.Printf("error: %v\n", err)
-		}
+		pcp.store(token, con)
 		res <- con
 	}
 
@@ -131,8 +139,32 @@
 }
 
 func (pcp *PersistentConnectionPool) Renew(token string) (string, error) {
-	log.Println("Renew: Not implemented, yet.")
-	return "", nil
+
+	type result struct {
+		newToken string
+		err      error
+	}
+
+	resCh := make(chan result)
+
+	pcp.cmds <- func(cp *PersistentConnectionPool) {
+		con := pcp.conns[token]
+		if con == nil {
+			resCh <- result{err: ErrNoSuchToken}
+		} else {
+			delete(pcp.conns, token)
+			pcp.remove(token)
+			newToken := GenerateSessionKey()
+			// TODO: Ensure that this is not racy!
+			con.session.ExpiresAt = time.Now().Add(maxTokenValid).Unix()
+			pcp.conns[newToken] = con
+			pcp.store(newToken, con)
+			resCh <- result{newToken: newToken}
+		}
+	}
+
+	r := <-resCh
+	return r.newToken, r.err
 }
 
 func (pcp *PersistentConnectionPool) Do(token string, fn func(*sql.DB) error) error {