#===============================================================================

from pylons_app.lib.auth import HasPermissionAny, HasPermissionAll, \

HasRepoPermissionAny, HasRepoPermissionAll

#===============================================================================

# GRAVATAR URL

#===============================================================================

import hashlib

import urllib

from pylons import request

def gravatar_url(email_address, size=30):

    ssl_enabled = 'https' == request.environ.get('HTTP_X_URL_SCHEME')

    default = 'identicon'

    baseurl_nossl = "http://www.gravatar.com/avatar/"

    baseurl_ssl = "https://secure.gravatar.com/avatar/"

    baseurl = baseurl_ssl if ssl_enabled else baseurl_nossl

    # construct the url

    gravatar_url = baseurl + hashlib.md5(email_address.lower()).hexdigest() + "?"

    gravatar_url += urllib.urlencode({'d':default, 's':str(size)})

    return gravatar_url

# 

# You should have received a copy of the GNU General Public License

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

# MA  02110-1301, USA.

"""

Created on Jan 26, 2010

@author: marcink

A deamon will read from task table and run tasks

"""

import sys

import os

from os.path import dirname as dn

from os.path import join as jn

#to get the pylons_app import

project_path = dn(dn(dn(dn(os.path.realpath(__file__)))))

sys.path.append(project_path)

from pidlock import LockHeld, DaemonLock

import traceback

from pylons_app.config.environment import load_environment

from pylons_app.model.hg_model import HgModel

from whoosh.index import create_in, open_dir

from shutil import rmtree

from pylons_app.lib.indexers import ANALYZER, INDEX_EXTENSIONS, IDX_LOCATION, \

SCHEMA, IDX_NAME

import logging

import logging.config

logging.config.fileConfig(jn(project_path, 'development.ini'))

log = logging.getLogger('whooshIndexer')

def scan_paths(root_location):

    return HgModel.repo_scan('/', root_location, None, True)

class WhooshIndexingDaemon(object):

    """Deamon for atomic jobs"""

    def __init__(self, indexname='HG_INDEX', repo_location=None):

        self.indexname = indexname

        self.repo_location = repo_location

    def get_paths(self, root_dir):

        """recursive walk in root dir and return a set of all path in that dir

        excluding files in .hg dir"""

        index_paths_ = set()

        for path, dirs, files in os.walk(root_dir):

            if path.find('.hg') == -1:

                for f in files:

                    index_paths_.add(jn(path, f))

        return index_paths_

    def add_doc(self, writer, path, repo):

        """Adding doc to writer"""

        ext = unicode(path.split('/')[-1].split('.')[-1].lower())

        #we just index the content of choosen files

        if ext in INDEX_EXTENSIONS:

            log.debug('    >> %s [WITH CONTENT]' % path)

            fobj = open(path, 'rb')

            content = fobj.read()

            fobj.close()

        else:

            log.debug('    >> %s' % path)

            #just index file name without it's content

            u_content = u''

        try:

            os.stat(path)

            writer.add_document(owner=unicode(repo.contact),

                            repository=u"%s" % repo.name,

                            path=u"%s" % path,

                            content=u_content,

                            modtime=os.path.getmtime(path),

                            extension=ext)             

        except OSError, e:

            import errno

            if e.errno == errno.ENOENT:

                log.debug('path %s does not exist or is a broken symlink' % path)

            else:

                raise e                 

    def build_index(self):