Code

Ported the remaining functions that parsed p4 shell output over to the p4 python...
[git.git] / contrib / fast-import / p4-fast-export.py
1 #!/usr/bin/python
2 #
3 # p4-fast-export.py
4 #
5 # Author: Simon Hausmann <hausmann@kde.org>
6 # License: MIT <http://www.opensource.org/licenses/mit-license.php>
7 #
8 # TODO:
9 #       - support integrations (at least p4i)
10 #       - support incremental imports
11 #       - create tags
12 #       - instead of reading all files into a variable try to pipe from
13 #       - support p4 submit (hah!)
14 #       - don't hardcode the import to master
15 #
16 import os, string, sys, time
17 import marshal, popen2
19 if len(sys.argv) != 2:
20     print "usage: %s //depot/path[@revRange]" % sys.argv[0]
21     print "\n    example:"
22     print "    %s //depot/my/project/ -- to import everything"
23     print "    %s //depot/my/project/@1,6 -- to import only from revision 1 to 6"
24     print ""
25     print "    (a ... is not needed in the path p4 specification, it's added implicitly)"
26     print ""
27     sys.exit(1)
29 prefix = sys.argv[1]
30 changeRange = ""
31 try:
32     atIdx = prefix.index("@")
33     changeRange = prefix[atIdx:]
34     prefix = prefix[0:atIdx]
35 except ValueError:
36     changeRange = ""
38 if not prefix.endswith("/"):
39     prefix += "/"
41 def p4CmdList(cmd):
42     pipe = os.popen("p4 -G %s" % cmd, "rb")
43     result = []
44     try:
45         while True:
46             entry = marshal.load(pipe)
47             result.append(entry)
48     except EOFError:
49         pass
50     pipe.close()
51     return result
53 def p4Cmd(cmd):
54     list = p4CmdList(cmd)
55     result = {}
56     for entry in list:
57         result.update(entry)
58     return result;
60 def p4FileSize(path):
61     return int(p4Cmd("fstat -Ol \"%s\"" % path)["fileSize"])
63 def getUserMap():
64     users = {}
66     for output in p4CmdList("users"):
67         if not output.has_key("User"):
68             continue
69         users[output["User"]] = output["FullName"] + " <" + output["Email"] + ">"
70     return users
72 users = getUserMap()
74 output = os.popen("p4 changes %s...%s" % (prefix, changeRange)).readlines()
76 changes = []
77 for line in output:
78     changeNum = line.split(" ")[1]
79     changes.append(changeNum)
81 changes.reverse()
83 sys.stderr.write("\n")
85 tz = - time.timezone / 36
87 gitOutput, gitStream, gitError = popen2.popen3("git-fast-import")
89 cnt = 1
90 for change in changes:
91     description = p4Cmd("describe %s" % change)
93     sys.stdout.write("\rimporting revision %s (%s%%)" % (change, cnt * 100 / len(changes)))
94     cnt = cnt + 1
96     epoch = description["time"]
97     author = description["user"]
99     gitStream.write("commit refs/heads/master\n")
100     if author in users:
101         gitStream.write("committer %s %s %s\n" % (users[author], epoch, tz))
102     else:
103         gitStream.write("committer %s <a@b> %s %s\n" % (author, epoch, tz))
104     gitStream.write("data <<EOT\n")
105     gitStream.write(description["desc"])
106     gitStream.write("EOT\n\n")
108     fnum = 0
109     while description.has_key("depotFile%s" % fnum):
110         path = description["depotFile%s" % fnum]
111         if not path.startswith(prefix):
112             print "\nchanged files: ignoring path %s outside of %s in change %s" % (path, prefix, change)
113             fnum = fnum + 1
114             continue
116         rev = description["rev%s" % fnum]
117         depotPath = path + "#" + rev
118         relPath = path[len(prefix):]
119         action = description["action%s" % fnum]
121         if action == "delete":
122             gitStream.write("D %s\n" % relPath)
123         else:
124             fileSize = p4FileSize(depotPath)
125             mode = 644
126             if description["type%s" % fnum].startswith("x"):
127                 mode = 755
129             gitStream.write("M %s inline %s\n" % (mode, relPath))
130             gitStream.write("data %s\n" % fileSize)
131             gitStream.write(os.popen("p4 print -q \"%s\"" % depotPath).read())
132             gitStream.write("\n")
134         fnum = fnum + 1
136     gitStream.write("\n")
138 gitStream.close()
139 gitOutput.close()
140 gitError.close()
142 print ""