summaryrefslogtreecommitdiffstats
path: root/modules/source.py
blob: d586795a1f981bcdf532439ba934e9502d9bcb99 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
import os
import commands

from os.path import isdir, join
from base.vars import FEDORA_DIR
from base.module import Module


# Hack-filled at the moment.

UPDATE, CLONE, COMMIT, LOG, DIFF = range(5)
scm_cmds = {
    'git' : ('update', 'clone', 'log', 'diff'),
    'hg'  : ('update', 'clone', 'log', 'diff'),
    'cvs' : ('update', 'checkout', 'log', 'diff'),
}
scms = {
    'cvs.fedoraproject.org' : 'cvs -d :ext:cvs.fedoraproject.org:/cvs/pkgs %(command)s %(module)s',
    'git.fedorahosted.org'  : 'git %(command)s ssh+git://git.fedorahosted.org/git/%(module)s',
    'hg.fedorahosted.org'   : 'hg %(command)s ssh://hg.fedorahosted.org//hg/%(module)s',
}


class CannotFindPackage(Exception):
    pass

#FIXME: use this?
class SCM(object):
    cmds = dict(update='update', clone='clone', log='log', diff='diff')

class Source(Module):

    def __init__(self, name, branch='devel'):
        self.name = name
        self.branch = branch
        self.scm = None
        self.__path = None
        self.__checkout()

    def __set_path(self, p):
        """ Set our path and make it our current working directory """
        if isdir(join(p, self.branch)):
            p = join(p, self.branch)
        print p
        self.__path = p
        os.chdir(p)

    def __get_path(self):
        return self.__path

    path = property(__get_path, __set_path)

    def __checkout(self):
        """ Find where this package lives """

        # Look in FEDORA_DIR/<scm>/<pkg>
        for scm in scms.keys():
            scmdir = join(FEDORA_DIR, scm, self.name)
            if isdir(scmdir):
                self.scm = scm
                self.path = scmdir
                return

        # Find this module in our scms
        for scm in scms.keys():
            scmdir = join(FEDORA_DIR, scm)
            if not isdir(scmdir):
                print "Creating %s" % scmdir
                os.mkdir(scmdir)
            os.chdir(scmdir)
            cmd = scms[scm] % {
                    'command' : scm_cmds[scm.split('.')[0]][CLONE],
                    'module'  : self.name
            }
            print "Running %s" % cmd
            status, output = commands.getstatusoutput(cmd)
            if status == 0:
                self.scm = scm
                self.path = join(scmdir, self.name)
                return

        raise CannotFindPackage

    def spec(self):
        """ View the RPM spec file for this project """
        editor = os.getenv('EDITOR', 'vi')
        os.system("%s %s.spec" % (editor, self.name))

    def sh(self):
        """ Drop into a shell """
        os.system("bash")

    def update(self):
        self.scm.update()
        cmd = scms[self.scm] % {
                'command' : scm_cmds[self.scm.split('.')[0]][UPDATE],
                'module'  : '' 
        }
        print "Executing `%s`" % cmd
        status, output = commands.getstatusoutput(cmd)
        print output

    def log(self, item=''):
        """ Show the history of this package """
        cmd = scms[self.scm] % {
                'command' : scm_cmds[self.scm.split('.')[0]][LOG],
                'module'  : item
        }
        print "Executing `%s | less`" % cmd
        os.system("%s | less" % cmd)

    def diff(self, item=''):
        cmd = scms[self.scm] % {
                'command' : scm_cmds[self.scm.split('.')[0]][DIFF],
                'module'  : item
        }
        print "Executing `%s | colordiff | less -R`" % cmd
        os.system("%s | colordiff | less -R" % cmd)

    def build(self):
        raise NotImplementedError

    def srpm(self):
        raise NotImplementedError

    def qa(self):
        raise NotImplementedError

    def audit(self):
        raise NotImplementedError

    def bugs(self):
        raise NotImplementedError

__all__ = ['Source']