basic session handling works now

1 files changed, 14 insertions, 17 deletions

diff --git a/src/helsinki.at/rhimportd/main.go b/src/helsinki.at/rhimportd/main.go
index 4b6ddf4..b90df0a 100644
--- a/src/helsinki.at/rhimportd/main.go
+++ b/src/helsinki.at/rhimportd/main.go
@@ -26,7 +26,6 @@ package main
 
 import (
 	"flag"
-	"fmt"
 	"log"
 	"os"
 	"os/signal"
@@ -53,31 +52,29 @@ func session_test(conf *rhimport.Config, rddb *rhimport.RdDbChan) {
 
 	store := sessions.GetInterface()
 
-	ctx := rhimport.NewImportContext(conf, rddb, "hugo")
+	ctx := rhimport.NewImportContext(conf, rddb, "heslinki")
+	ctx.Trusted = true
+	ctx.ShowId = 10002
+	ctx.SourceUri = "fake://10"
+
 	id, session, err := store.New(ctx)
 	if err != nil {
-		rhl.Printf("Error SessionStore.New(): %s", err)
+		rhl.Printf("MAIN: Error SessionStore.New(): %s", err)
 		return
 	}
 
-	fmt.Printf("\n\nSESSION_STORE: %+v\n\n", sessions)
-
+	rhl.Printf("MAIN: calling run for heslinki/%s", id)
 	session.Run()
 
-	fmt.Printf("\n\nSESSION_STORE: %+v\n\n", sessions)
-
+	rhl.Printf("MAIN: waiting for 2 secondes")
 	time.Sleep(5 * time.Second)
 
-	store.Remove("hugo", id)
-	fmt.Printf("\n\nSESSION_STORE: %+v\n\n", sessions)
-
-	time.Sleep(6 * time.Second)
-
-	fmt.Printf("\n\nSESSION_STORE: %+v\n\n", sessions)
-
-	store.Remove("hugo", id)
+	rhl.Printf("MAIN: calling remove for heslinki/%s", id)
+	if err = store.Remove("heslinki", id); err != nil {
+		rhl.Printf("MAIN: Error SessionStore.Remove(): %s", err)
+	}
 
-	fmt.Printf("\n\nSESSION_STORE: %+v\n\n", sessions)
+	rhl.Printf("MAIN: remove done")
 }
 
 func main() {
@@ -108,7 +105,7 @@ func main() {
 	}
 	defer rddb.Cleanup()
 
-	//	go session_test(conf, rddb.GetInterface())
+	go session_test(conf, rddb.GetInterface())
 
 	var wg sync.WaitGroup