diff options
Diffstat (limited to 'src/helsinki.at/rhimportd/main.go')
| -rw-r--r-- | src/helsinki.at/rhimportd/main.go | 31 |
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 |