#
# Copyright 2008, BlueDynamics Alliance, Austria - http://bluedynamics.com
#
# GNU General Public Licence Version 2 or later

__author__ = """Jens Klein <jens@bluedynamics.com>"""              
__docformat__ = 'plaintext'

import logging
import random
import AccessControl
from zope.app.traversing.browser.absoluteurl import absoluteURL
from zope.security.interfaces import Unauthorized
from Products.PloneFlashUpload import utils
from Products.PloneFlashUpload import ticket as pfuticket
try:
    import cmemcache as memcache
except ImportError:
    import memcache

logger = logging.getLogger('PloneFlashUpload')
logger.info('PATCHING PloneFlashUpload!')

def _getCache():
    servers = ('127.0.0.1:11211',) # XXX hardcoded
    client = memcache.Client(servers)
    return client
    

def _issueTicket(ident):
    """ issues a timelimit ticket 
    """
    ticket = str(random.random())
    sm = AccessControl.getSecurityManager()
    user = sm.getUser()
    if user is None:
        raise Unauthorized('No currently authenticated user')
    cache = _getCache()
    kw = {'ticket':ticket}
    cache.set(ident+ticket, user.getUserName())
    return ticket

pfuticket.issueTicket = _issueTicket

def _validateTicket(ident, ticket):
    """validates a ticket
    """
    cache = _getCache()
    username = cache.get(ident+ticket)
    return username is not None

pfuticket.validateTicket = _validateTicket

def _ticketOwner(ident, ticket):
    """Return username of the owner of the ticket.
    """
    cache = _getCache()
    username = cache.get(ident+ticket)
    return username

pfuticket.ticketOwner = _ticketOwner

def _invalidateTicket(ident, ticket):
    """invalidates a ticket
    """
    cache = _getCache()
    username = cache.delete(ident+ticket)
    return username

pfuticket.invalidateTicket = _invalidateTicket