path: root/src/helsinki.at/rhimport/session_store.go

//
//  rhimportd
//
//  The Radio Helsinki Rivendell Import Daemon
//
//
//  Copyright (C) 2015 Christian Pointner <equinox@helsinki.at>
//
//  This file is part of rhimportd.
//
//  rhimportd is free software: you can redistribute it and/or modify
//  it under the terms of the GNU General Public License as published by
//  the Free Software Foundation, either version 3 of the License, or
//  any later version.
//
//  rhimportd is distributed in the hope that it will be useful,
//  but WITHOUT ANY WARRANTY; without even the implied warranty of
//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//  GNU General Public License for more details.
//
//  You should have received a copy of the GNU General Public License
//  along with rhimportd. If not, see <http://www.gnu.org/licenses/>.
//

package rhimport

import (
	"crypto/rand"
	"encoding/base64"
	"fmt"
	"net/http"
)

type newSessionResponse struct {
	id           string
	session      *SessionChan
	responsecode int
	errorstring  string
}

type newSessionRequest struct {
	ctx      *ImportContext
	refId    string
	response chan newSessionResponse
}

type getSessionResponse struct {
	session      *SessionChan
	refId        string
	responsecode int
	errorstring  string
}

type getSessionRequest struct {
	user     string
	id       string
	refId    string
	response chan getSessionResponse
}

type listSessionsResponse struct {
	sessions     map[string]string
	responsecode int
	errorstring  string
}

type listSessionsRequest struct {
	user     string
	password string
	trusted  bool
	response chan listSessionsResponse
}

type removeSessionResponse struct {
	responsecode int
	errorstring  string
}

type removeSessionRequest struct {
	user     string
	id       string
	response chan removeSessionResponse
}

type SessionStoreElement struct {
	s     *Session
	refId string
}

type SessionStore struct {
	store      map[string]map[string]*SessionStoreElement
	conf       *Config
	rddb       *RdDbChan
	quit       chan bool
	done       chan bool
	newChan    chan newSessionRequest
	getChan    chan getSessionRequest
	listChan   chan listSessionsRequest
	removeChan chan removeSessionRequest
}

func generateSessionId() (string, error) {
	var b [32]byte
	if _, err := rand.Read(b[:]); err != nil {
		return "", err
	}
	return base64.RawStdEncoding.EncodeToString(b[:]), nil
}

func (self *SessionStore) new(ctx *ImportContext, refId string) (resp newSessionResponse) {
	resp.responsecode = http.StatusOK
	resp.errorstring = "OK"
	if !ctx.Trusted {
		if ok, err := self.rddb.CheckPassword(ctx.UserName, ctx.Password); err != nil {
			resp.responsecode = http.StatusInternalServerError
			resp.errorstring = err.Error()
			return
		} else if !ok {
			resp.responsecode = http.StatusUnauthorized
			resp.errorstring = "invalid username and/or password"
			return
		}
	}
	if id, err := generateSessionId(); err != nil {
		resp.responsecode = http.StatusInternalServerError
		resp.errorstring = err.Error()
	} else {
		resp.id = id
		if _, exists := self.store[ctx.UserName]; !exists {
			self.store[ctx.UserName] = make(map[string]*SessionStoreElement)
		}
		ctx.conf = self.conf
		ctx.rddb = self.rddb
		s := &SessionStoreElement{newSession(ctx, func() { self.GetInterface().Remove(ctx.UserName, resp.id) }), refId}
		self.store[ctx.UserName][resp.id] = s
		resp.session = self.store[ctx.UserName][resp.id].s.getInterface()
		rhdl.Printf("SessionStore: created session for '%s' -> %s", ctx.UserName, resp.id)
	}
	return
}

func (self *SessionStore) get(user, id string) (resp getSessionResponse) {
	resp.responsecode = http.StatusOK
	resp.errorstring = "OK"
	if session, exists := self.store[user][id]; exists {
		resp.session = session.s.getInterface()
		resp.refId = session.refId
	} else {
		resp.responsecode = http.StatusNotFound
		resp.errorstring = fmt.Sprintf("SessionStore: session '%s/%s' not found", user, id)
	}
	return
}

func (self *SessionStore) list(user, password string, trusted bool) (resp listSessionsResponse) {
	resp.responsecode = http.StatusOK
	resp.errorstring = "OK"
	if !trusted {
		if ok, err := self.rddb.CheckPassword(user, password); err != nil {
			resp.responsecode = http.StatusInternalServerError
			resp.errorstring = err.Error()
			return
		} else if !ok {
			resp.responsecode = http.StatusUnauthorized
			resp.errorstring = "invalid username and/or password"
			return
		}
	}
	resp.sessions = make(map[string]string)
	if sessions, exists := self.store[user]; exists {
		for id, e := range sessions {
			resp.sessions[id] = e.refId
		}
	}
	return
}

func (self *SessionStore) remove(user, id string) (resp removeSessionResponse) {
	resp.responsecode = http.StatusOK
	resp.errorstring = "OK"
	if session, exists := self.store[user][id]; exists {
		go session.s.cleanup() // cleanup could take a while -> don't block all the other stuff
		delete(self.store[user], id)
		rhdl.Printf("SessionStore: removed session '%s/%s'", user, id)
		if userstore, exists := self.store[user]; exists {
			if len(userstore) == 0 {
				delete(self.store, user)
				rhdl.Printf("SessionStore: removed user '%s'", user)
			}
		}
	} else {
		resp.responsecode = http.StatusNotFound
		resp.errorstring = fmt.Sprintf("SessionStore: session '%s/%s' not found", user, id)
	}
	return
}

func (self *SessionStore) dispatchRequests() {
	defer func() { self.done <- true }()
	for {
		select {
		case <-self.quit:
			return
		case req := <-self.newChan:
			req.response <- self.new(req.ctx, req.refId)
		case req := <-self.getChan:
			req.response <- self.get(req.user, req.id)
		case req := <-self.listChan:
			req.response <- self.list(req.user, req.password, req.trusted)
		case req := <-self.removeChan:
			req.response <- self.remove(req.user, req.id)
		}
	}
}

// *********************************************************
// Public Interface

type SessionStoreChan struct {
	newChan    chan<- newSessionRequest
	getChan    chan<- getSessionRequest
	listChan   chan listSessionsRequest
	removeChan chan<- removeSessionRequest
}

func (self *SessionStoreChan) New(ctx *ImportContext, refId string) (string, *SessionChan, int, string) {
	resCh := make(chan newSessionResponse)
	req := newSessionRequest{}
	req.ctx = ctx
	req.refId = refId
	req.response = resCh
	self.newChan <- req

	res := <-resCh
	return res.id, res.session, res.responsecode, res.errorstring
}

func (self *SessionStoreChan) Get(user, id string) (*SessionChan, string, int, string) {
	resCh := make(chan getSessionResponse)
	req := getSessionRequest{}
	req.user = user
	req.id = id
	req.response = resCh
	self.getChan <- req

	res := <-resCh
	return res.session, res.refId, res.responsecode, res.errorstring
}

func (self *SessionStoreChan) List(user, password string, trusted bool) (map[string]string, int, string) {
	resCh := make(chan listSessionsResponse)
	req := listSessionsRequest{}
	req.user = user
	req.password = password
	req.trusted = trusted
	req.response = resCh
	self.listChan <- req

	res := <-resCh
	return res.sessions, res.responsecode, res.errorstring
}

func (self *SessionStoreChan) Remove(user, id string) (int, string) {
	resCh := make(chan removeSessionResponse)
	req := removeSessionRequest{}
	req.user = user
	req.id = id
	req.response = resCh
	self.removeChan <- req

	res := <-resCh
	return res.responsecode, res.errorstring
}

func (self *SessionStore) GetInterface() *SessionStoreChan {
	ch := &SessionStoreChan{}
	ch.newChan = self.newChan
	ch.getChan = self.getChan
	ch.listChan = self.listChan
	ch.removeChan = self.removeChan
	return ch
}

func (self *SessionStore) Cleanup() {
	self.quit <- true
	<-self.done
	close(self.quit)
	close(self.done)
	close(self.newChan)
	close(self.getChan)
	close(self.listChan)
	close(self.removeChan)
}

func NewSessionStore(conf *Config, rddb *RdDbChan) (store *SessionStore, err error) {
	store = new(SessionStore)
	store.conf = conf
	store.rddb = rddb
	store.quit = make(chan bool)
	store.done = make(chan bool)
	store.store = make(map[string]map[string]*SessionStoreElement)
	store.newChan = make(chan newSessionRequest, 10)
	store.getChan = make(chan getSessionRequest, 10)
	store.listChan = make(chan listSessionsRequest, 10)
	store.removeChan = make(chan removeSessionRequest, 10)

	go store.dispatchRequests()
	return
}