Lines Matching refs:self
118 def __init__(self, url, code, msg, headers, args):
119 urllib2.HTTPError.__init__(self, url, code, msg, headers, None)
120 self.args = args
121 self.reason = args["Error"]
127 def __init__(self, host, auth_function, host_override=None, extra_headers={},
142 self.host = host
143 self.host_override = host_override
144 self.auth_function = auth_function
145 self.authenticated = False
146 self.extra_headers = extra_headers
147 self.save_cookies = save_cookies
148 self.opener = self._GetOpener()
149 if self.host_override:
150 logging.info("Server: %s; Host: %s", self.host, self.host_override)
152 logging.info("Server: %s", self.host)
154 def _GetOpener(self):
162 def _CreateRequest(self, url, data=None):
166 if self.host_override:
167 req.add_header("Host", self.host_override)
168 for key, value in self.extra_headers.iteritems():
172 def _GetAuthToken(self, email, password):
187 if self.host.endswith(".google.com"):
190 req = self._CreateRequest(
201 response = self.opener.open(req)
215 def _GetAuthCookie(self, auth_token):
227 req = self._CreateRequest("http://%s/_ah/login?%s" %
228 (self.host, urllib.urlencode(args)))
230 response = self.opener.open(req)
237 self.authenticated = True
239 def _Authenticate(self):
255 credentials = self.auth_function()
257 auth_token = self._GetAuthToken(credentials[0], credentials[1])
288 self._GetAuthCookie(auth_token)
291 def Send(self, request_path, payload=None,
310 if not self.authenticated:
311 self._Authenticate()
320 url = "http://%s%s" % (self.host, request_path)
323 req = self._CreateRequest(url=url, data=payload)
326 f = self.opener.open(req)
334 self._Authenticate()
347 def _Authenticate(self):
349 super(HttpRpcServer, self)._Authenticate()
350 if self.save_cookies:
351 StatusUpdate("Saving authentication cookies to %s" % self.cookie_file)
352 self.cookie_jar.save()
354 def _GetOpener(self):
367 if self.save_cookies:
368 self.cookie_file = os.path.expanduser("~/.codereview_upload_cookies")
369 self.cookie_jar = cookielib.MozillaCookieJar(self.cookie_file)
370 if os.path.exists(self.cookie_file):
372 self.cookie_jar.load()
373 self.authenticated = True
375 self.cookie_file)
381 fd = os.open(self.cookie_file, os.O_CREAT, 0600)
384 os.chmod(self.cookie_file, 0600)
387 self.cookie_jar = cookielib.CookieJar()
388 opener.add_handler(urllib2.HTTPCookieProcessor(self.cookie_jar))
591 def __init__(self, options):
597 self.options = options
599 def GenerateDiff(self, args):
606 "abstract method -- subclass %s must override" % self.__class__)
608 def GetUnknownFiles(self):
611 "abstract method -- subclass %s must override" % self.__class__)
613 def CheckForUnknownFiles(self):
615 unknown_files = self.GetUnknownFiles()
625 def GetBaseFile(self, filename):
639 "abstract method -- subclass %s must override" % self.__class__)
642 def GetBaseFiles(self, diff):
657 files[filename] = self.GetBaseFile(filename)
661 def UploadBaseFiles(self, issue, rpc_server, patch_list, patchset, options,
713 def IsImage(self, filename):
724 def __init__(self, options):
725 super(SubversionVCS, self).__init__(options)
726 if self.options.revision:
727 match = re.match(r"(\d+)(:(\d+))?", self.options.revision)
729 ErrorExit("Invalid Subversion revision %s." % self.options.revision)
730 self.rev_start = match.group(1)
731 self.rev_end = match.group(3)
733 self.rev_start = self.rev_end = None
736 self.svnls_cache = {}
739 required = self.options.download_base or self.options.revision is not None
740 self.svn_base = self._GuessBase(required)
742 def GuessBase(self, required):
744 return self.svn_base
746 def _GuessBase(self, required):
790 def GenerateDiff(self, args):
792 if self.options.revision:
793 cmd += ["-r", self.options.revision]
805 def _CollapseKeywords(self, content, keyword_str):
836 def GetUnknownFiles(self):
844 def ReadFile(self, filename):
854 def GetStatus(self, filename):
856 if not self.options.revision:
875 if dirname not in self.svnls_cache:
876 cmd = ["svn", "list", "-r", self.rev_start, dirname or "."]
882 if self.rev_end:
883 args += ["-r", self.rev_end]
888 self.svnls_cache[dirname] = (old_files, out.splitlines())
889 old_files, new_files = self.svnls_cache[dirname]
898 def GetBaseFile(self, filename):
899 status = self.GetStatus(filename)
914 if is_binary and self.IsImage(filename):
915 new_content = self.ReadFile(filename)
920 if self.options.revision:
921 url = "%s/%s@%s" % (self.svn_base, filename, self.rev_start)
938 if self.IsImage(filename):
941 if not self.rev_end:
942 new_content = self.ReadFile(filename)
944 url = "%s/%s@%s" % (self.svn_base, filename, self.rev_end)
957 if self.rev_start:
960 url = "%s/%s@%s" % (self.svn_base, filename, self.rev_start)
970 if self.rev_start:
971 url = "%s/%s@%s" % (self.svn_base, filename, self.rev_start)
978 base_content = self._CollapseKeywords(base_content, keywords)
988 def __init__(self, options):
989 super(GitVCS, self).__init__(options)
991 self.base_hashes = {}
993 def GenerateDiff(self, extra_args):
997 if self.options.revision:
998 extra_args = [self.options.revision] + extra_args
1015 self.base_hashes[filename] = match.group(1)
1021 def GetUnknownFiles(self):
1026 def GetBaseFile(self, filename):
1027 hash = self.base_hashes[filename]
1045 def __init__(self, options, repo_dir):
1046 super(MercurialVCS, self).__init__(options)
1048 self.repo_dir = os.path.normpath(repo_dir)
1051 assert cwd.startswith(self.repo_dir)
1052 self.subdir = cwd[len(self.repo_dir):].lstrip(r"\/")
1053 if self.options.revision:
1054 self.base_rev = self.options.revision
1056 self.base_rev = RunShell(["hg", "parent", "-q"]).split(':')[1].strip()
1058 def _GetRelPath(self, filename):
1061 assert filename.startswith(self.subdir), filename
1062 return filename[len(self.subdir):].lstrip(r"\/")
1064 def GenerateDiff(self, extra_args):
1067 cmd = ["hg", "diff", "--git", "-r", self.base_rev] + extra_args
1090 def GetUnknownFiles(self):
1093 status = RunShell(["hg", "status", "--rev", self.base_rev, "-u", "."],
1102 def GetBaseFile(self, filename):
1109 oldrelpath = relpath = self._GetRelPath(filename)
1111 out = RunShell(["hg", "status", "-C", "--rev", self.base_rev, relpath])
1125 base_content = RunShell(["hg", "cat", "-r", self.base_rev, oldrelpath],
1133 base_content = RunShell(["hg", "cat", "-r", self.base_rev, oldrelpath],
1135 if not is_binary or not self.IsImage(relpath):