list.py 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319
  1. from __future__ import absolute_import
  2. import json
  3. import logging
  4. from pip._vendor import six
  5. from pip._internal.cli import cmdoptions
  6. from pip._internal.cli.req_command import IndexGroupCommand
  7. from pip._internal.cli.status_codes import SUCCESS
  8. from pip._internal.exceptions import CommandError
  9. from pip._internal.index.collector import LinkCollector
  10. from pip._internal.index.package_finder import PackageFinder
  11. from pip._internal.models.selection_prefs import SelectionPreferences
  12. from pip._internal.utils.misc import (
  13. dist_is_editable,
  14. get_installed_distributions,
  15. tabulate,
  16. write_output,
  17. )
  18. from pip._internal.utils.packaging import get_installer
  19. from pip._internal.utils.parallel import map_multithread
  20. from pip._internal.utils.typing import MYPY_CHECK_RUNNING
  21. if MYPY_CHECK_RUNNING:
  22. from optparse import Values
  23. from typing import List, Set, Tuple, Iterator
  24. from pip._internal.network.session import PipSession
  25. from pip._vendor.pkg_resources import Distribution
  26. logger = logging.getLogger(__name__)
  27. class ListCommand(IndexGroupCommand):
  28. """
  29. List installed packages, including editables.
  30. Packages are listed in a case-insensitive sorted order.
  31. """
  32. usage = """
  33. %prog [options]"""
  34. def add_options(self):
  35. # type: () -> None
  36. self.cmd_opts.add_option(
  37. '-o', '--outdated',
  38. action='store_true',
  39. default=False,
  40. help='List outdated packages')
  41. self.cmd_opts.add_option(
  42. '-u', '--uptodate',
  43. action='store_true',
  44. default=False,
  45. help='List uptodate packages')
  46. self.cmd_opts.add_option(
  47. '-e', '--editable',
  48. action='store_true',
  49. default=False,
  50. help='List editable projects.')
  51. self.cmd_opts.add_option(
  52. '-l', '--local',
  53. action='store_true',
  54. default=False,
  55. help=('If in a virtualenv that has global access, do not list '
  56. 'globally-installed packages.'),
  57. )
  58. self.cmd_opts.add_option(
  59. '--user',
  60. dest='user',
  61. action='store_true',
  62. default=False,
  63. help='Only output packages installed in user-site.')
  64. self.cmd_opts.add_option(cmdoptions.list_path())
  65. self.cmd_opts.add_option(
  66. '--pre',
  67. action='store_true',
  68. default=False,
  69. help=("Include pre-release and development versions. By default, "
  70. "pip only finds stable versions."),
  71. )
  72. self.cmd_opts.add_option(
  73. '--format',
  74. action='store',
  75. dest='list_format',
  76. default="columns",
  77. choices=('columns', 'freeze', 'json'),
  78. help="Select the output format among: columns (default), freeze, "
  79. "or json",
  80. )
  81. self.cmd_opts.add_option(
  82. '--not-required',
  83. action='store_true',
  84. dest='not_required',
  85. help="List packages that are not dependencies of "
  86. "installed packages.",
  87. )
  88. self.cmd_opts.add_option(
  89. '--exclude-editable',
  90. action='store_false',
  91. dest='include_editable',
  92. help='Exclude editable package from output.',
  93. )
  94. self.cmd_opts.add_option(
  95. '--include-editable',
  96. action='store_true',
  97. dest='include_editable',
  98. help='Include editable package from output.',
  99. default=True,
  100. )
  101. index_opts = cmdoptions.make_option_group(
  102. cmdoptions.index_group, self.parser
  103. )
  104. self.parser.insert_option_group(0, index_opts)
  105. self.parser.insert_option_group(0, self.cmd_opts)
  106. def _build_package_finder(self, options, session):
  107. # type: (Values, PipSession) -> PackageFinder
  108. """
  109. Create a package finder appropriate to this list command.
  110. """
  111. link_collector = LinkCollector.create(session, options=options)
  112. # Pass allow_yanked=False to ignore yanked versions.
  113. selection_prefs = SelectionPreferences(
  114. allow_yanked=False,
  115. allow_all_prereleases=options.pre,
  116. )
  117. return PackageFinder.create(
  118. link_collector=link_collector,
  119. selection_prefs=selection_prefs,
  120. )
  121. def run(self, options, args):
  122. # type: (Values, List[str]) -> int
  123. if options.outdated and options.uptodate:
  124. raise CommandError(
  125. "Options --outdated and --uptodate cannot be combined.")
  126. cmdoptions.check_list_path_option(options)
  127. packages = get_installed_distributions(
  128. local_only=options.local,
  129. user_only=options.user,
  130. editables_only=options.editable,
  131. include_editables=options.include_editable,
  132. paths=options.path,
  133. )
  134. # get_not_required must be called firstly in order to find and
  135. # filter out all dependencies correctly. Otherwise a package
  136. # can't be identified as requirement because some parent packages
  137. # could be filtered out before.
  138. if options.not_required:
  139. packages = self.get_not_required(packages, options)
  140. if options.outdated:
  141. packages = self.get_outdated(packages, options)
  142. elif options.uptodate:
  143. packages = self.get_uptodate(packages, options)
  144. self.output_package_listing(packages, options)
  145. return SUCCESS
  146. def get_outdated(self, packages, options):
  147. # type: (List[Distribution], Values) -> List[Distribution]
  148. return [
  149. dist for dist in self.iter_packages_latest_infos(packages, options)
  150. if dist.latest_version > dist.parsed_version
  151. ]
  152. def get_uptodate(self, packages, options):
  153. # type: (List[Distribution], Values) -> List[Distribution]
  154. return [
  155. dist for dist in self.iter_packages_latest_infos(packages, options)
  156. if dist.latest_version == dist.parsed_version
  157. ]
  158. def get_not_required(self, packages, options):
  159. # type: (List[Distribution], Values) -> List[Distribution]
  160. dep_keys = set() # type: Set[Distribution]
  161. for dist in packages:
  162. dep_keys.update(requirement.key for requirement in dist.requires())
  163. # Create a set to remove duplicate packages, and cast it to a list
  164. # to keep the return type consistent with get_outdated and
  165. # get_uptodate
  166. return list({pkg for pkg in packages if pkg.key not in dep_keys})
  167. def iter_packages_latest_infos(self, packages, options):
  168. # type: (List[Distribution], Values) -> Iterator[Distribution]
  169. with self._build_session(options) as session:
  170. finder = self._build_package_finder(options, session)
  171. def latest_info(dist):
  172. # type: (Distribution) -> Distribution
  173. typ = 'unknown'
  174. all_candidates = finder.find_all_candidates(dist.key)
  175. if not options.pre:
  176. # Remove prereleases
  177. all_candidates = [candidate for candidate in all_candidates
  178. if not candidate.version.is_prerelease]
  179. evaluator = finder.make_candidate_evaluator(
  180. project_name=dist.project_name,
  181. )
  182. best_candidate = evaluator.sort_best_candidate(all_candidates)
  183. if best_candidate is None:
  184. return None
  185. remote_version = best_candidate.version
  186. if best_candidate.link.is_wheel:
  187. typ = 'wheel'
  188. else:
  189. typ = 'sdist'
  190. # This is dirty but makes the rest of the code much cleaner
  191. dist.latest_version = remote_version
  192. dist.latest_filetype = typ
  193. return dist
  194. for dist in map_multithread(latest_info, packages):
  195. if dist is not None:
  196. yield dist
  197. def output_package_listing(self, packages, options):
  198. # type: (List[Distribution], Values) -> None
  199. packages = sorted(
  200. packages,
  201. key=lambda dist: dist.project_name.lower(),
  202. )
  203. if options.list_format == 'columns' and packages:
  204. data, header = format_for_columns(packages, options)
  205. self.output_package_listing_columns(data, header)
  206. elif options.list_format == 'freeze':
  207. for dist in packages:
  208. if options.verbose >= 1:
  209. write_output("%s==%s (%s)", dist.project_name,
  210. dist.version, dist.location)
  211. else:
  212. write_output("%s==%s", dist.project_name, dist.version)
  213. elif options.list_format == 'json':
  214. write_output(format_for_json(packages, options))
  215. def output_package_listing_columns(self, data, header):
  216. # type: (List[List[str]], List[str]) -> None
  217. # insert the header first: we need to know the size of column names
  218. if len(data) > 0:
  219. data.insert(0, header)
  220. pkg_strings, sizes = tabulate(data)
  221. # Create and add a separator.
  222. if len(data) > 0:
  223. pkg_strings.insert(1, " ".join(map(lambda x: '-' * x, sizes)))
  224. for val in pkg_strings:
  225. write_output(val)
  226. def format_for_columns(pkgs, options):
  227. # type: (List[Distribution], Values) -> Tuple[List[List[str]], List[str]]
  228. """
  229. Convert the package data into something usable
  230. by output_package_listing_columns.
  231. """
  232. running_outdated = options.outdated
  233. # Adjust the header for the `pip list --outdated` case.
  234. if running_outdated:
  235. header = ["Package", "Version", "Latest", "Type"]
  236. else:
  237. header = ["Package", "Version"]
  238. data = []
  239. if options.verbose >= 1 or any(dist_is_editable(x) for x in pkgs):
  240. header.append("Location")
  241. if options.verbose >= 1:
  242. header.append("Installer")
  243. for proj in pkgs:
  244. # if we're working on the 'outdated' list, separate out the
  245. # latest_version and type
  246. row = [proj.project_name, proj.version]
  247. if running_outdated:
  248. row.append(proj.latest_version)
  249. row.append(proj.latest_filetype)
  250. if options.verbose >= 1 or dist_is_editable(proj):
  251. row.append(proj.location)
  252. if options.verbose >= 1:
  253. row.append(get_installer(proj))
  254. data.append(row)
  255. return data, header
  256. def format_for_json(packages, options):
  257. # type: (List[Distribution], Values) -> str
  258. data = []
  259. for dist in packages:
  260. info = {
  261. 'name': dist.project_name,
  262. 'version': six.text_type(dist.version),
  263. }
  264. if options.verbose >= 1:
  265. info['location'] = dist.location
  266. info['installer'] = get_installer(dist)
  267. if options.outdated:
  268. info['latest_version'] = six.text_type(dist.latest_version)
  269. info['latest_filetype'] = dist.latest_filetype
  270. data.append(info)
  271. return json.dumps(data)