summaryrefslogtreecommitdiff
path: root/rhimport/session_store.go
diff options
context:
space:
mode:
authorChristian Pointner <equinox@helsinki.at>2016-08-04 00:47:07 (GMT)
committerChristian Pointner <equinox@helsinki.at>2016-08-04 00:47:12 (GMT)
commit9d1a296bb18bd343f133326bd2eb4b2b3368bf65 (patch)
tree088a3723aff297157e7cd73e11ca4cea202f1b63 /rhimport/session_store.go
parente3c391263a0bf57db8b7c1566a27de9cdc325647 (diff)
temporary work dir is now handled by session (no support for soure file policy for now)
Diffstat (limited to 'rhimport/session_store.go')
-rw-r--r--rhimport/session_store.go10
1 files changed, 8 insertions, 2 deletions
diff --git a/rhimport/session_store.go b/rhimport/session_store.go
index a9b3e81..181ee9f 100644
--- a/rhimport/session_store.go
+++ b/rhimport/session_store.go
@@ -188,8 +188,14 @@ func (store *sessionStore) new(ctx *Context, refId string) (resp newSessionRespo
if pref := ctx.dbglog.Prefix(); strings.Contains(pref, "%s") {
ctx.dbglog.SetPrefix(fmt.Sprintf(pref, resp.id))
}
- s := &sessionStoreSessionElement{newSession(ctx, func() { store.GetInterface().Remove(ctx.UserName, resp.id) }), refId}
- store.store[ctx.UserName].sessions[resp.id] = s
+
+ s, err := newSession(ctx, func() { store.GetInterface().Remove(ctx.UserName, resp.id) })
+ if err != nil {
+ resp.responsecode = http.StatusInternalServerError
+ resp.errorstring = err.Error()
+ return
+ }
+ store.store[ctx.UserName].sessions[resp.id] = &sessionStoreSessionElement{s, refId}
resp.session = store.store[ctx.UserName].sessions[resp.id].s.getInterface()
store.dbglog.Printf("SessionStore: created session for '%s' -> %s", ctx.UserName, resp.id)
store.store[ctx.UserName].callUpdateHandlerAdd(resp.id, refId)