load_rcextensions

log = logging.getLogger(__name__)

# CUSTOM ANALYZER wordsplit + lowercase filter

ANALYZER = RegexTokenizer(expression=r"\w+") | LowercaseFilter()

#INDEX SCHEMA DEFINITION

SCHEMA = Schema(

    fileid=ID(unique=True),

    owner=TEXT(),

    repository=TEXT(stored=True),

    path=TEXT(stored=True),

    content=FieldType(format=Characters(), analyzer=ANALYZER,

                      scorable=True, stored=True),

    modtime=STORED(),

    extension=TEXT(stored=True)

)

IDX_NAME = 'HG_INDEX'

FORMATTER = HtmlFormatter('span', between='\n<span class="break">...</span>\n')

FRAGMENTER = ContextFragmenter(200)

CHGSETS_SCHEMA = Schema(

    revision=NUMERIC(unique=True, stored=True),

    last=BOOLEAN(),

    owner=TEXT(),

    repository=ID(unique=True, stored=True),

    author=TEXT(stored=True),

    message=FieldType(format=Characters(), analyzer=ANALYZER,

                      scorable=True, stored=True),

    parents=TEXT(),

    added=TEXT(),

    removed=TEXT(),

    changed=TEXT(),

)

CHGSET_IDX_NAME = 'CHGSET_INDEX'

class MakeIndex(BasePasterCommand):

    max_args = 1

    min_args = 1

    usage = "CONFIG_FILE"

    summary = "Creates index for full text search given configuration file"

    group_name = "RhodeCode"

    takes_config_file = -1

    def __iter__(self):

        """

        Allows Iteration over results,and lazy generate content

        *Requires* implementation of ``__getitem__`` method.

        """

        for docid in self.doc_ids:

            yield self.get_full_content(docid)

    def __getitem__(self, key):

        """

        Slicing of resultWrapper

        """

        i, j = key.start, key.stop

        slices = []

        for docid in self.doc_ids[i:j]:

            slices.append(self.get_full_content(docid))

        return slices

    def get_full_content(self, docid):

        res = self.searcher.stored_fields(docid[0])

        log.debug('result: %s' % res)

        if self.search_type == 'content':

            content_short = self.get_short_content(res, docid[1])

            res.update({'content_short': content_short,

        elif self.search_type == 'message':

            res.update({'message_hl': self.highlight(res['message'])})

        log.debug('result: %s' % res)

        return res

    def get_short_content(self, res, chunks):

        return ''.join([res['content'][chunk[0]:chunk[1]] for chunk in chunks])

    def get_chunks(self):

        """

        Smart function that implements chunking the content

        but not overlap chunks so it doesn't highlight the same

        close occurrences twice.

        :param matcher:

        :param size:

        """

        memory = [(0, 0)]

        if self.matcher.supports('positions'): 

            for span in self.matcher.spans():

                start = span.startchar or 0

        p = safe_unicode(path)

        writer.add_document(

            fileid=p,

            owner=unicode(repo.contact),

            repository=safe_unicode(repo_name),

            path=p,

            content=u_content,

            modtime=self.get_node_mtime(node),

            extension=node.extension

        )

        return indexed, indexed_w_content

    def index_changesets(self, writer, repo_name, repo, start_rev=0):

        """

        Add all changeset in the vcs repo starting at start_rev

        to the index writer

        """

        log.debug('indexing changesets in %s[%d:]' % (repo_name, start_rev))

        indexed=0

        for cs in repo[start_rev:]:

            writer.add_document(

                owner=unicode(repo.contact),

                repository=safe_unicode(repo_name),

                author=cs.author,

                message=cs.message,

                revision=cs.revision,

                last=cs.last,

                added=u' '.join([node.path for node in cs.added]).lower(),

                removed=u' '.join([node.path for node in cs.removed]).lower(),

                changed=u' '.join([node.path for node in cs.changed]).lower(),

                parents=u' '.join([cs.raw_id for cs in cs.parents]),

            )

            indexed += 1

        log.debug('indexed %d changesets for repo %s' % (indexed, repo_name))

    def index_files(self, file_idx_writer, repo_name, repo):

        i_cnt = iwc_cnt = 0

        log.debug('building index for [%s]' % repo.path)

        for idx_path in self.get_paths(repo):

            i, iwc = self.add_doc(file_idx_writer, idx_path, repo, repo_name)

            i_cnt += i

            iwc_cnt += iwc

        log.debug('added %s files %s with content for repo %s' % (i_cnt + iwc_cnt, iwc_cnt, repo.path))

        with idx.searcher() as searcher:

            writer = idx.writer()

            writer_is_dirty = False

            try:

                for repo_name, repo in self.repo_paths.items():

                    # skip indexing if there aren't any revs in the repo

                    revs = repo.revisions

                    if len(revs) < 1:

                        continue

                    qp = QueryParser('repository', schema=CHGSETS_SCHEMA)

                    q = qp.parse(u"last:t AND %s" % repo_name)

                    results = searcher.search(q, sortedby='revision')

                    last_rev = 0

                    if len(results) > 0:

                        last_rev = results[0]['revision']

                    # there are new changesets to index or a new repo to index

                    if last_rev == 0 or len(revs) > last_rev + 1:

                        # delete the docs in the index for the previous last changeset(s)

                        for hit in results:

                            writer.delete_by_query(q)

                        # index from the previous last changeset + all new ones

                        self.index_changesets(writer, repo_name, repo, last_rev)

                        writer_is_dirty = True

            finally:

                if writer_is_dirty:

                    log.debug('>> COMMITING CHANGES TO CHANGESET INDEX<<')

                    writer.commit(merge=True)

                    log.debug('>> COMMITTED CHANGES TO CHANGESET INDEX<<')

                else:

                    writer.cancel

    def update_file_index(self):

        log.debug((u'STARTING INCREMENTAL INDEXING UPDATE FOR EXTENSIONS %s '

                   'AND REPOS %s') % (INDEX_EXTENSIONS, self.repo_paths.keys()))

        idx = open_dir(self.index_location, indexname=self.indexname)

        # The set of all paths in the index

        indexed_paths = set()

        # The set of all paths we need to re-index

        to_index = set()

##commit highligthing

%for cnt,sr in enumerate(c.formated_results):

    %if h.HasRepoPermissionAny('repository.write','repository.read','repository.admin')(sr['repository'],'search results check'):

    <div class="table">

        <div id="body${cnt}" class="codeblock">

            <div class="code-header">

                </div>

            </div>

            <div class="left">

                <div class="author">

                    <div class="gravatar">

                        <img alt="gravatar" src="${h.gravatar_url(h.email(sr['author']),20)}"/>

                    </div>

                    <span>${h.person(sr['author'])}</span><br/>

                    <span><a href="mailto:${h.email_or_none(sr['author'])}">${h.email_or_none(sr['author'])}</a></span><br/>

                </div>

                %if sr['message_hl']:

                <div class="search-code-body">

                    <pre>${h.literal(sr['message_hl'])}</pre>

                </div>

                %else:

                <div class="message">${h.urlify_commit(sr['message'], sr['repository'])}</div>

                %endif

            </div>

        </div>

    </div>

    %else:

        %if cnt == 0:

        <div class="table">

            <div id="body${cnt}" class="codeblock">