#

# Copyright 21 May 2005 - (c) 2005 Jake Edge <jake@edge2.net>

# Copyright 2005-2007 Matt Mackall <mpm@selenic.com>

#

# This software may be used and distributed according to the terms of the

# GNU General Public License version 2 or any later version.

import os, mimetypes, re, cgi, copy

import webutil

from mercurial import error, encoding, archival, templater, templatefilters

from mercurial.node import short, hex, nullid

from mercurial.util import binary

from common import paritygen, staticfile, get_contact, ErrorResponse

from common import HTTP_OK, HTTP_FORBIDDEN, HTTP_NOT_FOUND

from mercurial import graphmod, patch

from mercurial import help as helpmod

from mercurial import scmutil

from mercurial.i18n import _

# __all__ is populated with the allowed commands. Be sure to add to it if

# you're adding a new command, or the new command won't work.

__all__ = [

   'log', 'rawfile', 'file', 'changelog', 'shortlog', 'changeset', 'rev',

   'manifest', 'tags', 'bookmarks', 'branches', 'summary', 'filediff', 'diff',

   'comparison', 'annotate', 'filelog', 'archive', 'static', 'graph', 'help',

]

def log(web, req, tmpl):

    if 'file' in req.form and req.form['file'][0]:

        return filelog(web, req, tmpl)

    else:

        return changelog(web, req, tmpl)

def rawfile(web, req, tmpl):

    guessmime = web.configbool('web', 'guessmime', False)

    path = webutil.cleanpath(web.repo, req.form.get('file', [''])[0])

    if not path:

        content = manifest(web, req, tmpl)

        req.respond(HTTP_OK, web.ctype)

        return content

    try:

        fctx = webutil.filectx(web.repo, req)

    except error.LookupError, inst:

        try:

            content = manifest(web, req, tmpl)

            req.respond(HTTP_OK, web.ctype)

            return content

        except ErrorResponse:

            raise inst

    path = fctx.path()

    text = fctx.data()

    mt = 'application/binary'

    if guessmime:

        mt = mimetypes.guess_type(path)[0]

        if mt is None:

            mt = binary(text) and 'application/binary' or 'text/plain'

    if mt.startswith('text/'):

        mt += '; charset="%s"' % encoding.encoding

    req.respond(HTTP_OK, mt, path, body=text)

    return []

def _filerevision(web, tmpl, fctx):

    f = fctx.path()

    text = fctx.data()

    parity = paritygen(web.stripecount)

    if binary(text):

        mt = mimetypes.guess_type(f)[0] or 'application/octet-stream'

        text = '(binary:%s)' % mt

    def lines():

        for lineno, t in enumerate(text.splitlines(True)):

            yield {"line": t,

                   "lineid": "l%d" % (lineno + 1),

                   "linenumber": "% 6d" % (lineno + 1),

                   "parity": parity.next()}

    return tmpl("filerevision",

                file=f,

                path=webutil.up(f),

                text=lines(),

                rev=fctx.rev(),

                node=fctx.hex(),

                author=fctx.user(),

                date=fctx.date(),

                desc=fctx.description(),

                extra=fctx.extra(),

                branch=webutil.nodebranchnodefault(fctx),

                parent=webutil.parents(fctx),

                child=webutil.children(fctx),

                rename=webutil.renamelink(fctx),

                permissions=fctx.manifest().flags(f))

def file(web, req, tmpl):

    path = webutil.cleanpath(web.repo, req.form.get('file', [''])[0])

    if not path:

        return manifest(web, req, tmpl)

    try:

        return _filerevision(web, tmpl, webutil.filectx(web.repo, req))

    except error.LookupError, inst:

        try:

            return manifest(web, req, tmpl)

        except ErrorResponse:

            raise inst

def _search(web, req, tmpl):

    def changelist(**map):

        count = 0

        lower = encoding.lower

        qw = lower(query).split()

        def revgen():

            cl = web.repo.changelog

            for i in xrange(len(web.repo) - 1, 0, -100):

                l = []

                for j in cl.revs(max(0, i - 100), i + 1):

                    ctx = web.repo[j]

                    l.append(ctx)

                l.reverse()

                for e in l:

                    yield e

        for ctx in revgen():

            miss = 0

            for q in qw:

                if not (q in lower(ctx.user()) or

                        q in lower(ctx.description()) or

                        q in lower(" ".join(ctx.files()))):

                    miss = 1

                    break

            if miss:

                continue

            count += 1

            n = ctx.node()

            showtags = webutil.showtag(web.repo, tmpl, 'changelogtag', n)

            files = webutil.listfilediffs(tmpl, ctx.files(), n, web.maxfiles)

            yield tmpl('searchentry',

                       parity=parity.next(),

                       author=ctx.user(),

                       parent=webutil.parents(ctx),

                       child=webutil.children(ctx),

                       changelogtag=showtags,

                       desc=ctx.description(),

                       extra=ctx.extra(),

                       date=ctx.date(),

                       files=files,

                       rev=ctx.rev(),

                       node=hex(n),

                       tags=webutil.nodetagsdict(web.repo, n),

                       bookmarks=webutil.nodebookmarksdict(web.repo, n),

                       inbranch=webutil.nodeinbranch(web.repo, ctx),

                       branches=webutil.nodebranchdict(web.repo, ctx))

            if count >= revcount:

                break

    query = req.form['rev'][0]

    revcount = web.maxchanges

    if 'revcount' in req.form:

        revcount = int(req.form.get('revcount', [revcount])[0])

        revcount = max(revcount, 1)

        tmpl.defaults['sessionvars']['revcount'] = revcount

    lessvars = copy.copy(tmpl.defaults['sessionvars'])

    lessvars['revcount'] = max(revcount / 2, 1)

    lessvars['rev'] = query

    morevars = copy.copy(tmpl.defaults['sessionvars'])

    morevars['revcount'] = revcount * 2

    morevars['rev'] = query

    tip = web.repo['tip']

    parity = paritygen(web.stripecount)

    return tmpl('search', query=query, node=tip.hex(),

                entries=changelist, archives=web.archivelist("tip"),

                morevars=morevars, lessvars=lessvars)

def changelog(web, req, tmpl, shortlog=False):

    query = ''

    if 'node' in req.form:

        ctx = webutil.changectx(web.repo, req)

    else:

        if 'rev' in req.form:

            query = req.form['rev'][0]

            hi = query

        else:

            hi = 'tip'

        try:

            ctx = web.repo[hi]

        except (error.RepoError, error.LookupError):

            return _search(web, req, tmpl) # XXX redirect to 404 page?

    def changelist(latestonly, **map):

        l = [] # build a list in forward order for efficiency

        revs = []

        if start < end:

            revs = web.repo.changelog.revs(start, end - 1)

        if latestonly:

            for r in revs:

                pass

            revs = (r,)

        for i in revs:

            ctx = web.repo[i]

            n = ctx.node()

            showtags = webutil.showtag(web.repo, tmpl, 'changelogtag', n)

            files = webutil.listfilediffs(tmpl, ctx.files(), n, web.maxfiles)

            l.append({"parity": parity.next(),

                      "author": ctx.user(),

                      "parent": webutil.parents(ctx, i - 1),

                      "child": webutil.children(ctx, i + 1),

                      "changelogtag": showtags,

                      "desc": ctx.description(),

                      "extra": ctx.extra(),

                      "date": ctx.date(),

                      "files": files,

                      "rev": i,

                      "node": hex(n),

                      "tags": webutil.nodetagsdict(web.repo, n),

                      "bookmarks": webutil.nodebookmarksdict(web.repo, n),

                      "inbranch": webutil.nodeinbranch(web.repo, ctx),

                      "branches": webutil.nodebranchdict(web.repo, ctx)

                     })

        for e in reversed(l):

            yield e

    revcount = shortlog and web.maxshortchanges or web.maxchanges

    if 'revcount' in req.form:

        revcount = int(req.form.get('revcount', [revcount])[0])

        revcount = max(revcount, 1)

        tmpl.defaults['sessionvars']['revcount'] = revcount

    lessvars = copy.copy(tmpl.defaults['sessionvars'])

    lessvars['revcount'] = max(revcount / 2, 1)

    morevars = copy.copy(tmpl.defaults['sessionvars'])

    morevars['revcount'] = revcount * 2

    count = len(web.repo)

    pos = ctx.rev()

    start = max(0, pos - revcount + 1)

    end = pos + 1

    parity = paritygen(web.stripecount, offset=start - end)

    changenav = webutil.revnav(web.repo).gen(pos, revcount, count)

    return tmpl(shortlog and 'shortlog' or 'changelog', changenav=changenav,

                node=ctx.hex(), rev=pos, changesets=count,

                entries=lambda **x: changelist(latestonly=False, **x),

                latestentry=lambda **x: changelist(latestonly=True, **x),

                archives=web.archivelist("tip"), revcount=revcount,

                morevars=morevars, lessvars=lessvars, query=query)

def shortlog(web, req, tmpl):

    return changelog(web, req, tmpl, shortlog = True)

def changeset(web, req, tmpl):

    ctx = webutil.changectx(web.repo, req)

    basectx = webutil.basechangectx(web.repo, req)

    if basectx is None:

        basectx = ctx.p1()

    showtags = webutil.showtag(web.repo, tmpl, 'changesettag', ctx.node())

    showbookmarks = webutil.showbookmark(web.repo, tmpl, 'changesetbookmark',

                                         ctx.node())

    showbranch = webutil.nodebranchnodefault(ctx)

    files = []

    parity = paritygen(web.stripecount)

    for blockno, f in enumerate(ctx.files()):

        template = f in ctx and 'filenodelink' or 'filenolink'

        files.append(tmpl(template,

                          node=ctx.hex(), file=f, blockno=blockno + 1,

                          parity=parity.next()))

    style = web.config('web', 'style', 'paper')

    if 'style' in req.form:

        style = req.form['style'][0]

    parity = paritygen(web.stripecount)

    diffs = webutil.diffs(web.repo, tmpl, ctx, basectx, None, parity, style)

    parity = paritygen(web.stripecount)

    diffstatgen = webutil.diffstatgen(ctx, basectx)

    diffstat = webutil.diffstat(tmpl, ctx, diffstatgen, parity)

    return tmpl('changeset',

                diff=diffs,

                rev=ctx.rev(),

                node=ctx.hex(),

                parent=webutil.parents(ctx),

                child=webutil.children(ctx),

                basenode=basectx.hex(),

                changesettag=showtags,

                changesetbookmark=showbookmarks,

                changesetbranch=showbranch,

                author=ctx.user(),

                desc=ctx.description(),

                extra=ctx.extra(),

                date=ctx.date(),

                files=files,

                diffsummary=lambda **x: webutil.diffsummary(diffstatgen),

                diffstat=diffstat,

                archives=web.archivelist(ctx.hex()),

                tags=webutil.nodetagsdict(web.repo, ctx.node()),

                bookmarks=webutil.nodebookmarksdict(web.repo, ctx.node()),

                branch=webutil.nodebranchnodefault(ctx),

                inbranch=webutil.nodeinbranch(web.repo, ctx),

                branches=webutil.nodebranchdict(web.repo, ctx))

rev = changeset

def decodepath(path):

    """Hook for mapping a path in the repository to a path in the

    working copy.

    Extensions (e.g., largefiles) can override this to remap files in

    the virtual file system presented by the manifest command below."""

    return path

def manifest(web, req, tmpl):

    ctx = webutil.changectx(web.repo, req)

    path = webutil.cleanpath(web.repo, req.form.get('file', [''])[0])

    mf = ctx.manifest()

    node = ctx.node()

    files = {}

    dirs = {}

    parity = paritygen(web.stripecount)

    if path and path[-1] != "/":

        path += "/"

    l = len(path)

    abspath = "/" + path

    for full, n in mf.iteritems():

        # the virtual path (working copy path) used for the full

        # (repository) path

        f = decodepath(full)

        if f[:l] != path:

            continue

        remain = f[l:]

        elements = remain.split('/')

        if len(elements) == 1:

            files[remain] = full

        else:

            h = dirs # need to retain ref to dirs (root)

            for elem in elements[0:-1]:

                if elem not in h:

                    h[elem] = {}

                h = h[elem]

                if len(h) > 1:

                    break

            h[None] = None # denotes files present

    if mf and not files and not dirs:

        raise ErrorResponse(HTTP_NOT_FOUND, 'path not found: ' + path)

    def filelist(**map):

        for f in sorted(files):

            full = files[f]

            fctx = ctx.filectx(full)

            yield {"file": full,

                   "parity": parity.next(),

                   "basename": f,

                   "date": fctx.date(),

                   "size": fctx.size(),

                   "permissions": mf.flags(full)}

    def dirlist(**map):

        for d in sorted(dirs):

            emptydirs = []

            h = dirs[d]

            while isinstance(h, dict) and len(h) == 1:

                k, v = h.items()[0]

                if v:

                    emptydirs.append(k)

                h = v

            path = "%s%s" % (abspath, d)

            yield {"parity": parity.next(),

                   "path": path,

                   "emptydirs": "/".join(emptydirs),

                   "basename": d}

    return tmpl("manifest",

                rev=ctx.rev(),

                node=hex(node),

                path=abspath,

                up=webutil.up(abspath),

                upparity=parity.next(),

                fentries=filelist,

                dentries=dirlist,

                archives=web.archivelist(hex(node)),

                tags=webutil.nodetagsdict(web.repo, node),

                bookmarks=webutil.nodebookmarksdict(web.repo, node),

                inbranch=webutil.nodeinbranch(web.repo, ctx),

                branches=webutil.nodebranchdict(web.repo, ctx))

def tags(web, req, tmpl):

    i = list(reversed(web.repo.tagslist()))

    parity = paritygen(web.stripecount)

    def entries(notip, latestonly, **map):

        t = i

        if notip:

            t = [(k, n) for k, n in i if k != "tip"]

        if latestonly:

            t = t[:1]

        for k, n in t:

            yield {"parity": parity.next(),

                   "tag": k,

                   "date": web.repo[n].date(),

                   "node": hex(n)}

    return tmpl("tags",

                node=hex(web.repo.changelog.tip()),

                entries=lambda **x: entries(False, False, **x),

                entriesnotip=lambda **x: entries(True, False, **x),

                latestentry=lambda **x: entries(True, True, **x))

def bookmarks(web, req, tmpl):

    i = [b for b in web.repo._bookmarks.items() if b[1] in web.repo]

    parity = paritygen(web.stripecount)

    def entries(latestonly, **map):

        if latestonly:

            t = [min(i)]

        else:

            t = sorted(i)

        for k, n in t:

            yield {"parity": parity.next(),

                   "bookmark": k,

                   "date": web.repo[n].date(),

                   "node": hex(n)}

    return tmpl("bookmarks",

                node=hex(web.repo.changelog.tip()),

                entries=lambda **x: entries(latestonly=False, **x),

                latestentry=lambda **x: entries(latestonly=True, **x))

def branches(web, req, tmpl):

    tips = []

    heads = web.repo.heads()

    parity = paritygen(web.stripecount)

    sortkey = lambda ctx: (not ctx.closesbranch(), ctx.rev())

    def entries(limit, **map):

        count = 0

        if not tips:

            for t, n in web.repo.branchtags().iteritems():

                tips.append(web.repo[n])

        for ctx in sorted(tips, key=sortkey, reverse=True):

            if limit > 0 and count >= limit:

                return

            count += 1

            if not web.repo.branchheads(ctx.branch()):

                status = 'closed'

            elif ctx.node() not in heads:

                status = 'inactive'

            else:

                status = 'open'

            yield {'parity': parity.next(),

                   'branch': ctx.branch(),

                   'status': status,

                   'node': ctx.hex(),

                   'date': ctx.date()}

    return tmpl('branches', node=hex(web.repo.changelog.tip()),

                entries=lambda **x: entries(0, **x),

                latestentry=lambda **x: entries(1, **x))