mirror of
https://github.com/optim-enterprises-bv/databunker.git
synced 2025-11-02 19:07:46 +00:00
delete session command
This commit is contained in:
@@ -221,6 +221,7 @@ func (e mainEnv) setupRouter() *httprouter.Router {
|
|||||||
|
|
||||||
router.GET("/v1/session/:session", e.getSession)
|
router.GET("/v1/session/:session", e.getSession)
|
||||||
router.POST("/v1/session/:session", e.createSession)
|
router.POST("/v1/session/:session", e.createSession)
|
||||||
|
router.DELETE("/v1/session/:session", e.deleteSession)
|
||||||
//router.POST("/v1/sessions/:mode/:address", e.newUserSession)
|
//router.POST("/v1/sessions/:mode/:address", e.newUserSession)
|
||||||
router.GET("/v1/sessions/:mode/:address", e.getUserSessions)
|
router.GET("/v1/sessions/:mode/:address", e.getUserSessions)
|
||||||
|
|
||||||
|
|||||||
@@ -61,8 +61,25 @@ func (e mainEnv) createSession(w http.ResponseWriter, r *http.Request, ps httpro
|
|||||||
w.Header().Set("Content-Type", "application/json; charset=utf-8")
|
w.Header().Set("Content-Type", "application/json; charset=utf-8")
|
||||||
w.WriteHeader(200)
|
w.WriteHeader(200)
|
||||||
fmt.Fprintf(w, `{"status":"ok","session":"%s"}`, session)
|
fmt.Fprintf(w, `{"status":"ok","session":"%s"}`, session)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (e mainEnv) deleteSession(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
|
||||||
|
session := ps.ByName("session")
|
||||||
|
event := audit("delete session", session, "session", session)
|
||||||
|
defer func() { event.submit(e.db) }()
|
||||||
|
if enforceUUID(w, session, event) == false {
|
||||||
|
//returnError(w, r, "bad session format", nil, event)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
authResult := e.enforceAdmin(w, r)
|
||||||
|
if authResult == "" {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
e.db.deleteSession(session)
|
||||||
|
w.Header().Set("Content-Type", "application/json; charset=utf-8")
|
||||||
|
w.WriteHeader(200)
|
||||||
|
fmt.Fprintf(w, `{"status":"ok"}`)
|
||||||
|
}
|
||||||
|
|
||||||
func (e mainEnv) newUserSession(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
|
func (e mainEnv) newUserSession(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
|
||||||
address := ps.ByName("address")
|
address := ps.ByName("address")
|
||||||
|
|||||||
@@ -109,3 +109,9 @@ func (dbobj dbcon) getUserSessionsByToken(userTOKEN string, offset int32, limit
|
|||||||
|
|
||||||
return results, count, err
|
return results, count, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (dbobj dbcon) deleteSession(sessionUUID string) (bool, error) {
|
||||||
|
dbobj.store.DeleteRecord(storage.TblName.Sessions, "session", sessionUUID)
|
||||||
|
return true, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user