PackageController.php 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128
  1. <?php
  2. namespace Packagist\WebBundle\Controller;
  3. use Composer\Factory;
  4. use Composer\IO\BufferIO;
  5. use Composer\Package\Loader\ArrayLoader;
  6. use Composer\Package\Loader\ValidatingArrayLoader;
  7. use Composer\Repository\VcsRepository;
  8. use Doctrine\ORM\NoResultException;
  9. use Packagist\WebBundle\Entity\PackageRepository;
  10. use Packagist\WebBundle\Entity\VersionRepository;
  11. use Packagist\WebBundle\Form\Model\MaintainerRequest;
  12. use Packagist\WebBundle\Form\Type\AbandonedType;
  13. use Packagist\WebBundle\Entity\Package;
  14. use Packagist\WebBundle\Entity\Version;
  15. use Packagist\WebBundle\Form\Type\AddMaintainerRequestType;
  16. use Packagist\WebBundle\Form\Type\PackageType;
  17. use Packagist\WebBundle\Form\Type\RemoveMaintainerRequestType;
  18. use Predis\Connection\ConnectionException;
  19. use Symfony\Component\HttpFoundation\RedirectResponse;
  20. use Symfony\Component\HttpFoundation\Request;
  21. use Symfony\Component\HttpFoundation\JsonResponse;
  22. use Symfony\Component\HttpFoundation\Response;
  23. use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
  24. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  25. use Symfony\Component\Security\Core\Exception\AccessDeniedException;
  26. use Composer\Package\Version\VersionParser;
  27. use DateTimeImmutable;
  28. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Cache;
  29. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Method;
  30. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
  31. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Template;
  32. use Pagerfanta\Adapter\FixedAdapter;
  33. use Pagerfanta\Pagerfanta;
  34. class PackageController extends Controller
  35. {
  36. /**
  37. * @Template("PackagistWebBundle:Package:browse.html.twig")
  38. * @Route("/packages/", name="allPackages")
  39. * @Cache(smaxage=900)
  40. */
  41. public function allAction(Request $req)
  42. {
  43. $filters = array(
  44. 'type' => $req->query->get('type'),
  45. 'tag' => $req->query->get('tag'),
  46. );
  47. $data = $filters;
  48. $page = $req->query->get('page', 1);
  49. $packages = $this->getDoctrine()
  50. ->getRepository('PackagistWebBundle:Package')
  51. ->getFilteredQueryBuilder($filters);
  52. $data['packages'] = $this->setupPager($packages, $page);
  53. $data['meta'] = $this->getPackagesMetadata($data['packages']);
  54. return $data;
  55. }
  56. /**
  57. * @Route("/packages/list.json", name="list", defaults={"_format"="json"})
  58. * @Method({"GET"})
  59. * @Cache(smaxage=300)
  60. */
  61. public function listAction(Request $req)
  62. {
  63. /** @var PackageRepository $repo */
  64. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  65. $fields = (array) $req->query->get('fields', array());
  66. $fields = array_intersect($fields, array('repository', 'type'));
  67. if ($fields) {
  68. $filters = array_filter(array(
  69. 'type' => $req->query->get('type'),
  70. 'vendor' => $req->query->get('vendor'),
  71. ));
  72. return new JsonResponse(array('packages' => $repo->getPackagesWithFields($filters, $fields)));
  73. }
  74. if ($req->query->get('type')) {
  75. $names = $repo->getPackageNamesByType($req->query->get('type'));
  76. } elseif ($req->query->get('vendor')) {
  77. $names = $repo->getPackageNamesByVendor($req->query->get('vendor'));
  78. } else {
  79. $names = $repo->getPackageNames();
  80. }
  81. return new JsonResponse(array('packageNames' => $names));
  82. }
  83. /**
  84. * @Template()
  85. * @Route("/packages/submit", name="submit")
  86. */
  87. public function submitPackageAction(Request $req)
  88. {
  89. $package = new Package;
  90. $package->setEntityRepository($this->getDoctrine()->getRepository('PackagistWebBundle:Package'));
  91. $package->setRouter($this->get('router'));
  92. $form = $this->createForm(new PackageType(), $package);
  93. $user = $this->getUser();
  94. $package->addMaintainer($user);
  95. if ('POST' === $req->getMethod()) {
  96. $form->bind($req);
  97. if ($form->isValid()) {
  98. try {
  99. $em = $this->getDoctrine()->getManager();
  100. $em->persist($package);
  101. $em->flush();
  102. $this->get('session')->getFlashBag()->set('success', $package->getName().' has been added to the package list, the repository will now be crawled.');
  103. return new RedirectResponse($this->generateUrl('view_package', array('name' => $package->getName())));
  104. } catch (\Exception $e) {
  105. $this->get('logger')->crit($e->getMessage(), array('exception', $e));
  106. $this->get('session')->getFlashBag()->set('error', $package->getName().' could not be saved.');
  107. }
  108. }
  109. }
  110. return array('form' => $form->createView(), 'page' => 'submit');
  111. }
  112. /**
  113. * @Route("/packages/fetch-info", name="submit.fetch_info", defaults={"_format"="json"})
  114. */
  115. public function fetchInfoAction(Request $req)
  116. {
  117. $package = new Package;
  118. $package->setEntityRepository($this->getDoctrine()->getRepository('PackagistWebBundle:Package'));
  119. $package->setRouter($this->get('router'));
  120. $form = $this->createForm(new PackageType, $package);
  121. $user = $this->getUser();
  122. $package->addMaintainer($user);
  123. $response = array('status' => 'error', 'reason' => 'No data posted.');
  124. if ('POST' === $req->getMethod()) {
  125. $form->bind($req);
  126. if ($form->isValid()) {
  127. list(, $name) = explode('/', $package->getName(), 2);
  128. $existingPackages = $this->getDoctrine()
  129. ->getRepository('PackagistWebBundle:Package')
  130. ->createQueryBuilder('p')
  131. ->where('p.name LIKE ?0')
  132. ->setParameters(array('%/'.$name))
  133. ->getQuery()
  134. ->getResult();
  135. $similar = array();
  136. /** @var Package $existingPackage */
  137. foreach ($existingPackages as $existingPackage) {
  138. $similar[] = array(
  139. 'name' => $existingPackage->getName(),
  140. 'url' => $this->generateUrl('view_package', array('name' => $existingPackage->getName()), true),
  141. );
  142. }
  143. $response = array('status' => 'success', 'name' => $package->getName(), 'similar' => $similar);
  144. } else {
  145. $errors = array();
  146. if (count($form->getErrors())) {
  147. foreach ($form->getErrors() as $error) {
  148. $errors[] = $error->getMessageTemplate();
  149. }
  150. }
  151. foreach ($form->all() as $child) {
  152. if (count($child->getErrors())) {
  153. foreach ($child->getErrors() as $error) {
  154. $errors[] = $error->getMessageTemplate();
  155. }
  156. }
  157. }
  158. $response = array('status' => 'error', 'reason' => $errors);
  159. }
  160. }
  161. return new JsonResponse($response);
  162. }
  163. /**
  164. * @Template()
  165. * @Route("/packages/{vendor}/", name="view_vendor", requirements={"vendor"="[A-Za-z0-9_.-]+"})
  166. */
  167. public function viewVendorAction($vendor)
  168. {
  169. $packages = $this->getDoctrine()
  170. ->getRepository('PackagistWebBundle:Package')
  171. ->createQueryBuilder('p')
  172. ->where('p.name LIKE ?0')
  173. ->setParameters(array($vendor.'/%'))
  174. ->getQuery()
  175. ->getResult();
  176. if (!$packages) {
  177. return $this->redirect($this->generateUrl('search', array('q' => $vendor, 'reason' => 'vendor_not_found')));
  178. }
  179. return array(
  180. 'packages' => $packages,
  181. 'meta' => $this->getPackagesMetadata($packages),
  182. 'vendor' => $vendor,
  183. 'paginate' => false,
  184. );
  185. }
  186. /**
  187. * @Route(
  188. * "/p/{name}.{_format}",
  189. * name="view_package_alias",
  190. * requirements={"name"="[A-Za-z0-9_.-]+(/[A-Za-z0-9_.-]+?)?", "_format"="(json)"},
  191. * defaults={"_format"="html"}
  192. * )
  193. * @Route(
  194. * "/packages/{name}",
  195. * name="view_package_alias2",
  196. * requirements={"name"="[A-Za-z0-9_.-]+(/[A-Za-z0-9_.-]+?)?/"},
  197. * defaults={"_format"="html"}
  198. * )
  199. * @Method({"GET"})
  200. */
  201. public function viewPackageAliasAction(Request $req, $name)
  202. {
  203. $format = $req->getRequestFormat();
  204. if ($format === 'html') {
  205. $format = null;
  206. }
  207. if (false === strpos(trim($name, '/'), '/')) {
  208. return $this->redirect($this->generateUrl('view_vendor', array('vendor' => $name, '_format' => $format)));
  209. }
  210. return $this->redirect($this->generateUrl('view_package', array('name' => trim($name, '/'), '_format' => $format)));
  211. }
  212. /**
  213. * @Template()
  214. * @Route(
  215. * "/providers/{name}",
  216. * name="view_providers",
  217. * requirements={"name"="[A-Za-z0-9/_.-]+?"},
  218. * defaults={"_format"="html"}
  219. * )
  220. * @Method({"GET"})
  221. */
  222. public function viewProvidersAction(Request $req, $name)
  223. {
  224. /** @var PackageRepository $repo */
  225. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  226. $providers = $repo->findProviders($name);
  227. if (!$providers) {
  228. return $this->redirect($this->generateUrl('search', array('q' => $name, 'reason' => 'package_not_found')));
  229. }
  230. return $this->render('PackagistWebBundle:Web:providers.html.twig', array(
  231. 'name' => $name,
  232. 'packages' => $providers,
  233. 'meta' => $this->getPackagesMetadata($providers),
  234. 'paginate' => false,
  235. ));
  236. }
  237. /**
  238. * @Template()
  239. * @Route(
  240. * "/packages/{name}.{_format}",
  241. * name="view_package",
  242. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "_format"="(json)"},
  243. * defaults={"_format"="html"}
  244. * )
  245. * @Method({"GET"})
  246. */
  247. public function viewPackageAction(Request $req, $name)
  248. {
  249. /** @var PackageRepository $repo */
  250. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  251. try {
  252. /** @var Package $package */
  253. $package = $repo->findOneByName($name);
  254. } catch (NoResultException $e) {
  255. if ('json' === $req->getRequestFormat()) {
  256. return new JsonResponse(array('status' => 'error', 'message' => 'Package not found'), 404);
  257. }
  258. if ($providers = $repo->findProviders($name)) {
  259. return $this->redirect($this->generateUrl('view_providers', array('name' => $name)));
  260. }
  261. return $this->redirect($this->generateUrl('search', array('q' => $name, 'reason' => 'package_not_found')));
  262. }
  263. if ('json' === $req->getRequestFormat()) {
  264. $data = $package->toArray();
  265. try {
  266. $data['downloads'] = $this->get('packagist.download_manager')->getDownloads($package);
  267. $data['favers'] = $this->get('packagist.favorite_manager')->getFaverCount($package);
  268. } catch (ConnectionException $e) {
  269. $data['downloads'] = null;
  270. $data['favers'] = null;
  271. }
  272. // TODO invalidate cache on update and make the ttl longer
  273. $response = new JsonResponse(array('package' => $data));
  274. $response->setSharedMaxAge(3600);
  275. return $response;
  276. }
  277. $version = null;
  278. $expandedVersion = null;
  279. $versions = $package->getVersions();
  280. if (is_object($versions)) {
  281. $versions = $versions->toArray();
  282. }
  283. usort($versions, Package::class.'::sortVersions');
  284. if (count($versions)) {
  285. /** @var VersionRepository $versionRepo */
  286. $versionRepo = $this->getDoctrine()->getRepository('PackagistWebBundle:Version');
  287. $version = $versionRepo->getFullVersion(reset($versions)->getId());
  288. $expandedVersion = reset($versions);
  289. foreach ($versions as $v) {
  290. if (!$v->isDevelopment()) {
  291. $expandedVersion = $v;
  292. break;
  293. }
  294. }
  295. $expandedVersion = $versionRepo->getFullVersion($expandedVersion->getId());
  296. }
  297. $data = array(
  298. 'package' => $package,
  299. 'version' => $version,
  300. 'versions' => $versions,
  301. 'expandedVersion' => $expandedVersion,
  302. );
  303. try {
  304. $data['downloads'] = $this->get('packagist.download_manager')->getDownloads($package);
  305. if ($this->getUser()) {
  306. $data['is_favorite'] = $this->get('packagist.favorite_manager')->isMarked($this->getUser(), $package);
  307. }
  308. } catch (ConnectionException $e) {
  309. }
  310. $data['dependents'] = $repo->getDependentCount($package->getName());
  311. if ($maintainerForm = $this->createAddMaintainerForm($package)) {
  312. $data['addMaintainerForm'] = $maintainerForm->createView();
  313. }
  314. if ($removeMaintainerForm = $this->createRemoveMaintainerForm($package)) {
  315. $data['removeMaintainerForm'] = $removeMaintainerForm->createView();
  316. }
  317. if ($deleteForm = $this->createDeletePackageForm($package)) {
  318. $data['deleteForm'] = $deleteForm->createView();
  319. }
  320. if ($this->getUser() && (
  321. $this->isGranted('ROLE_DELETE_PACKAGES')
  322. || $package->getMaintainers()->contains($this->getUser())
  323. )) {
  324. $data['deleteVersionCsrfToken'] = $this->get('security.csrf.token_manager')->getToken('delete_version');
  325. }
  326. return $data;
  327. }
  328. /**
  329. * @Template()
  330. * @Route(
  331. * "/packages/{name}/downloads.{_format}",
  332. * name="package_downloads_full",
  333. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "_format"="(json)"}
  334. * )
  335. * @Method({"GET"})
  336. */
  337. public function viewPackageDownloadsAction(Request $req, $name)
  338. {
  339. /** @var PackageRepository $repo */
  340. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  341. try {
  342. /** @var $package Package */
  343. $package = $repo->findOneByName($name);
  344. } catch (NoResultException $e) {
  345. if ('json' === $req->getRequestFormat()) {
  346. return new JsonResponse(array('status' => 'error', 'message' => 'Package not found'), 404);
  347. }
  348. if ($providers = $repo->findProviders($name)) {
  349. return $this->redirect($this->generateUrl('view_providers', array('name' => $name)));
  350. }
  351. return $this->redirect($this->generateUrl('search', array('q' => $name, 'reason' => 'package_not_found')));
  352. }
  353. $versions = $package->getVersions();
  354. $data = array(
  355. 'name' => $package->getName(),
  356. );
  357. try {
  358. $data['downloads']['total'] = $this->get('packagist.download_manager')->getDownloads($package);
  359. $data['favers'] = $this->get('packagist.favorite_manager')->getFaverCount($package);
  360. } catch (ConnectionException $e) {
  361. $data['downloads']['total'] = null;
  362. $data['favers'] = null;
  363. }
  364. foreach ($versions as $version) {
  365. try {
  366. $data['downloads']['versions'][$version->getVersion()] = $this->get('packagist.download_manager')->getDownloads($package, $version);
  367. } catch (ConnectionException $e) {
  368. $data['downloads']['versions'][$version->getVersion()] = null;
  369. }
  370. }
  371. $response = new Response(json_encode(array('package' => $data)), 200);
  372. $response->setSharedMaxAge(3600);
  373. return $response;
  374. }
  375. /**
  376. * @Template()
  377. * @Route(
  378. * "/versions/{versionId}.{_format}",
  379. * name="view_version",
  380. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "versionId"="[0-9]+", "_format"="(json)"}
  381. * )
  382. * @Method({"GET"})
  383. */
  384. public function viewPackageVersionAction(Request $req, $versionId)
  385. {
  386. /** @var VersionRepository $repo */
  387. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Version');
  388. $html = $this->renderView(
  389. 'PackagistWebBundle:Web:versionDetails.html.twig',
  390. array('version' => $repo->getFullVersion($versionId))
  391. );
  392. return new JsonResponse(array('content' => $html));
  393. }
  394. /**
  395. * @Template()
  396. * @Route(
  397. * "/versions/{versionId}/delete",
  398. * name="delete_version",
  399. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "versionId"="[0-9]+"}
  400. * )
  401. * @Method({"DELETE"})
  402. */
  403. public function deletePackageVersionAction(Request $req, $versionId)
  404. {
  405. /** @var VersionRepository $repo */
  406. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Version');
  407. /** @var Version $version */
  408. $version = $repo->getFullVersion($versionId);
  409. $package = $version->getPackage();
  410. if (!$package->getMaintainers()->contains($this->getUser()) && !$this->isGranted('ROLE_DELETE_PACKAGES')) {
  411. throw new AccessDeniedException;
  412. }
  413. if (!$this->get('form.csrf_provider')->isCsrfTokenValid('delete_version', $req->request->get('_token'))) {
  414. throw new AccessDeniedException;
  415. }
  416. $repo->remove($version);
  417. $this->getDoctrine()->getManager()->flush();
  418. $this->getDoctrine()->getManager()->clear();
  419. return new Response('', 204);
  420. }
  421. /**
  422. * @Template()
  423. * @Route("/packages/{name}", name="update_package", requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+"}, defaults={"_format" = "json"})
  424. * @Method({"PUT"})
  425. */
  426. public function updatePackageAction($name)
  427. {
  428. $doctrine = $this->getDoctrine();
  429. try {
  430. /** @var Package $package */
  431. $package = $doctrine
  432. ->getRepository('PackagistWebBundle:Package')
  433. ->getPackageByName($name);
  434. } catch (NoResultException $e) {
  435. return new Response(json_encode(array('status' => 'error', 'message' => 'Package not found',)), 404);
  436. }
  437. $req = $this->getRequest();
  438. $username = $req->request->has('username') ?
  439. $req->request->get('username') :
  440. $req->query->get('username');
  441. $apiToken = $req->request->has('apiToken') ?
  442. $req->request->get('apiToken') :
  443. $req->query->get('apiToken');
  444. $update = $req->request->get('update', $req->query->get('update'));
  445. $autoUpdated = $req->request->get('autoUpdated', $req->query->get('autoUpdated'));
  446. $updateEqualRefs = $req->request->get('updateAll', $req->query->get('updateAll'));
  447. $user = $this->getUser() ?: $doctrine
  448. ->getRepository('PackagistWebBundle:User')
  449. ->findOneBy(array('username' => $username, 'apiToken' => $apiToken));
  450. if (!$user) {
  451. return new Response(json_encode(array('status' => 'error', 'message' => 'Invalid credentials',)), 403);
  452. }
  453. if ($package->getMaintainers()->contains($user) || $this->isGranted('ROLE_UPDATE_PACKAGES')) {
  454. $req->getSession()->save();
  455. if (null !== $autoUpdated) {
  456. $package->setAutoUpdated((Boolean) $autoUpdated);
  457. $doctrine->getManager()->flush();
  458. }
  459. if ($update) {
  460. set_time_limit(3600);
  461. $updater = $this->get('packagist.package_updater');
  462. $io = new BufferIO('', OutputInterface::VERBOSITY_VERY_VERBOSE, new HtmlOutputFormatter(Factory::createAdditionalStyles()));
  463. $config = Factory::createConfig();
  464. $io->loadConfiguration($config);
  465. $repository = new VcsRepository(array('url' => $package->getRepository()), $io, $config);
  466. $loader = new ValidatingArrayLoader(new ArrayLoader());
  467. $repository->setLoader($loader);
  468. try {
  469. $updater->update($io, $config, $package, $repository, $updateEqualRefs ? Updater::UPDATE_EQUAL_REFS : 0);
  470. } catch (\Exception $e) {
  471. return new Response(json_encode(array(
  472. 'status' => 'error',
  473. 'message' => '['.get_class($e).'] '.$e->getMessage(),
  474. 'details' => '<pre>'.$io->getOutput().'</pre>',
  475. )), 400);
  476. }
  477. }
  478. return new Response('{"status": "success"}', 202);
  479. }
  480. return new JsonResponse(array('status' => 'error', 'message' => 'Could not find a package that matches this request (does user maintain the package?)',), 404);
  481. }
  482. /**
  483. * @Template()
  484. * @Route("/packages/{name}", name="delete_package", requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+"})
  485. * @Method({"DELETE"})
  486. */
  487. public function deletePackageAction(Request $req, $name)
  488. {
  489. $doctrine = $this->getDoctrine();
  490. try {
  491. /** @var Package $package */
  492. $package = $doctrine
  493. ->getRepository('PackagistWebBundle:Package')
  494. ->findOneByName($name);
  495. } catch (NoResultException $e) {
  496. throw new NotFoundHttpException('The requested package, '.$name.', was not found.');
  497. }
  498. if (!$form = $this->createDeletePackageForm($package)) {
  499. throw new AccessDeniedException;
  500. }
  501. $form->bind($req->request->get('form'));
  502. if ($form->isValid()) {
  503. $req->getSession()->save();
  504. /** @var VersionRepository $versionRepo */
  505. $versionRepo = $doctrine->getRepository('PackagistWebBundle:Version');
  506. foreach ($package->getVersions() as $version) {
  507. $versionRepo->remove($version);
  508. }
  509. $packageId = $package->getId();
  510. $em = $doctrine->getManager();
  511. $em->remove($package);
  512. $em->flush();
  513. // attempt solr cleanup
  514. try {
  515. /** @var \Solarium_Client $solarium */
  516. $solarium = $this->get('solarium.client');
  517. $update = $solarium->createUpdate();
  518. $update->addDeleteById($packageId);
  519. $update->addCommit();
  520. $solarium->update($update);
  521. } catch (\Solarium_Client_HttpException $e) {}
  522. return new Response('', 204);
  523. }
  524. return new Response('Invalid form input', 400);
  525. }
  526. /**
  527. * @Template("PackagistWebBundle:Web:viewPackage.html.twig")
  528. * @Route("/packages/{name}/maintainers/", name="add_maintainer", requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+"})
  529. */
  530. public function createMaintainerAction(Request $req, $name)
  531. {
  532. /** @var $package Package */
  533. $package = $this->getDoctrine()
  534. ->getRepository('PackagistWebBundle:Package')
  535. ->findOneByName($name);
  536. if (!$package) {
  537. throw new NotFoundHttpException('The requested package, '.$name.', was not found.');
  538. }
  539. if (!$form = $this->createAddMaintainerForm($package)) {
  540. throw new AccessDeniedException('You must be a package\'s maintainer to modify maintainers.');
  541. }
  542. $data = array(
  543. 'package' => $package,
  544. 'versions' => null,
  545. 'expandedVersion' => null,
  546. 'version' => null,
  547. 'addMaintainerForm' => $form->createView(),
  548. 'show_add_maintainer_form' => true,
  549. );
  550. if ('POST' === $req->getMethod()) {
  551. $form->bind($req);
  552. if ($form->isValid()) {
  553. try {
  554. $em = $this->getDoctrine()->getManager();
  555. $user = $form->getData()->getUser();
  556. if (!empty($user)) {
  557. if (!$package->getMaintainers()->contains($user)) {
  558. $package->addMaintainer($user);
  559. $this->get('packagist.package_manager')->notifyNewMaintainer($user, $package);
  560. }
  561. $em->persist($package);
  562. $em->flush();
  563. $this->get('session')->getFlashBag()->set('success', $user->getUsername().' is now a '.$package->getName().' maintainer.');
  564. return new RedirectResponse($this->generateUrl('view_package', array('name' => $package->getName())));
  565. }
  566. $this->get('session')->getFlashBag()->set('error', 'The user could not be found.');
  567. } catch (\Exception $e) {
  568. $this->get('logger')->crit($e->getMessage(), array('exception', $e));
  569. $this->get('session')->getFlashBag()->set('error', 'The maintainer could not be added.');
  570. }
  571. }
  572. }
  573. return $data;
  574. }
  575. /**
  576. * @Template("PackagistWebBundle:Web:viewPackage.html.twig")
  577. * @Route("/packages/{name}/maintainers/delete", name="remove_maintainer", requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+"})
  578. */
  579. public function removeMaintainerAction(Request $req, $name)
  580. {
  581. /** @var $package Package */
  582. $package = $this->getDoctrine()
  583. ->getRepository('PackagistWebBundle:Package')
  584. ->findOneByName($name);
  585. if (!$package) {
  586. throw new NotFoundHttpException('The requested package, '.$name.', was not found.');
  587. }
  588. if (!$removeMaintainerForm = $this->createRemoveMaintainerForm($package)) {
  589. throw new AccessDeniedException('You must be a package\'s maintainer to modify maintainers.');
  590. }
  591. $data = array(
  592. 'package' => $package,
  593. 'versions' => null,
  594. 'expandedVersion' => null,
  595. 'version' => null,
  596. 'removeMaintainerForm' => $removeMaintainerForm->createView(),
  597. 'show_remove_maintainer_form' => true,
  598. );
  599. if ('POST' === $req->getMethod()) {
  600. $removeMaintainerForm->bind($req);
  601. if ($removeMaintainerForm->isValid()) {
  602. try {
  603. $em = $this->getDoctrine()->getManager();
  604. $user = $removeMaintainerForm->getData()->getUser();
  605. if (!empty($user)) {
  606. if ($package->getMaintainers()->contains($user)) {
  607. $package->getMaintainers()->removeElement($user);
  608. }
  609. $em->persist($package);
  610. $em->flush();
  611. $this->get('session')->getFlashBag()->set('success', $user->getUsername().' is no longer a '.$package->getName().' maintainer.');
  612. return new RedirectResponse($this->generateUrl('view_package', array('name' => $package->getName())));
  613. }
  614. $this->get('session')->getFlashBag()->set('error', 'The user could not be found.');
  615. } catch (\Exception $e) {
  616. $this->get('logger')->crit($e->getMessage(), array('exception', $e));
  617. $this->get('session')->getFlashBag()->set('error', 'The maintainer could not be removed.');
  618. }
  619. }
  620. }
  621. return $data;
  622. }
  623. /**
  624. * @Template()
  625. * @Route(
  626. * "/packages/{name}/edit",
  627. * name="edit_package",
  628. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?"}
  629. * )
  630. */
  631. public function editAction(Request $req, Package $package)
  632. {
  633. if (!$package->getMaintainers()->contains($this->getUser()) && !$this->isGranted('ROLE_EDIT_PACKAGES')) {
  634. throw new AccessDeniedException;
  635. }
  636. $form = $this->createFormBuilder($package, array("validation_groups" => array("Update")))
  637. ->add("repository", "text")
  638. ->getForm();
  639. if ($req->isMethod("POST")) {
  640. $form->bind($req);
  641. if ($form->isValid()) {
  642. // Force updating of packages once the package is viewed after the redirect.
  643. $package->setCrawledAt(null);
  644. $em = $this->getDoctrine()->getManager();
  645. $em->persist($package);
  646. $em->flush();
  647. $this->get("session")->getFlashBag()->set("success", "Changes saved.");
  648. return $this->redirect(
  649. $this->generateUrl("view_package", array("name" => $package->getName()))
  650. );
  651. }
  652. }
  653. return array(
  654. "package" => $package, "form" => $form->createView()
  655. );
  656. }
  657. /**
  658. * @Route(
  659. * "/packages/{name}/abandon",
  660. * name="abandon_package",
  661. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?"}
  662. * )
  663. * @Template()
  664. */
  665. public function abandonAction(Request $request, Package $package)
  666. {
  667. if (!$package->getMaintainers()->contains($this->getUser()) && !$this->isGranted('ROLE_EDIT_PACKAGES')) {
  668. throw new AccessDeniedException;
  669. }
  670. $form = $this->createForm(new AbandonedType());
  671. if ($request->getMethod() === 'POST') {
  672. $form->bind($request->request->get('package'));
  673. if ($form->isValid()) {
  674. $package->setAbandoned(true);
  675. $package->setReplacementPackage(str_replace('https://packagist.org/packages/', '', $form->get('replacement')->getData()));
  676. $package->setIndexedAt(null);
  677. $em = $this->getDoctrine()->getManager();
  678. $em->flush();
  679. return $this->redirect($this->generateUrl('view_package', array('name' => $package->getName())));
  680. }
  681. }
  682. return array(
  683. 'package' => $package,
  684. 'form' => $form->createView()
  685. );
  686. }
  687. /**
  688. * @Route(
  689. * "/packages/{name}/unabandon",
  690. * name="unabandon_package",
  691. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?"}
  692. * )
  693. */
  694. public function unabandonAction(Package $package)
  695. {
  696. if (!$package->getMaintainers()->contains($this->getUser()) && !$this->isGranted('ROLE_EDIT_PACKAGES')) {
  697. throw new AccessDeniedException;
  698. }
  699. $package->setAbandoned(false);
  700. $package->setReplacementPackage(null);
  701. $package->setIndexedAt(null);
  702. $em = $this->getDoctrine()->getManager();
  703. $em->flush();
  704. return $this->redirect($this->generateUrl('view_package', array('name' => $package->getName())));
  705. }
  706. /**
  707. * @Route(
  708. * "/packages/{name}/stats.{_format}",
  709. * name="view_package_stats",
  710. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "_format"="(json)"},
  711. * defaults={"_format"="html"}
  712. * )
  713. * @Template()
  714. */
  715. public function statsAction(Request $req, Package $package)
  716. {
  717. $versions = $package->getVersions()->toArray();
  718. usort($versions, Package::class.'::sortVersions');
  719. $date = $this->guessStatsStartDate($package);
  720. $data = [
  721. 'downloads' => $this->get('packagist.download_manager')->getDownloads($package),
  722. 'versions' => $versions,
  723. 'average' => $this->guessStatsAverage($date),
  724. 'date' => $date->format('Y-m-d'),
  725. ];
  726. if ($req->getRequestFormat() === 'json') {
  727. $data['versions'] = array_map(function ($version) {
  728. /** @var Version $version */
  729. return $version->getVersion();
  730. }, $data['versions']);
  731. return new JsonResponse($data);
  732. }
  733. $data['package'] = $package;
  734. $expandedVersion = reset($versions);
  735. foreach ($versions as $v) {
  736. /** @var Version $v */
  737. if (!$v->isDevelopment()) {
  738. $expandedVersion = $v;
  739. break;
  740. }
  741. }
  742. $data['expandedId'] = $expandedVersion ? $expandedVersion->getId() : false;
  743. return $data;
  744. }
  745. /**
  746. * @Route(
  747. * "/packages/{name}/dependents",
  748. * name="view_package_dependents",
  749. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?"}
  750. * )
  751. * @Template()
  752. */
  753. public function dependentsAction(Request $req, $name)
  754. {
  755. $page = $req->query->get('page', 1);
  756. /** @var PackageRepository $repo */
  757. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  758. $depCount = $repo->getDependentCount($name);
  759. $packages = $repo->getDependents($name, ($page - 1) * 15, 15);
  760. $paginator = new Pagerfanta(new FixedAdapter($depCount, $packages));
  761. $paginator->setMaxPerPage(15);
  762. $paginator->setCurrentPage($page, false, true);
  763. $data['packages'] = $paginator;
  764. $data['meta'] = $this->getPackagesMetadata($data['packages']);
  765. $data['name'] = $name;
  766. return $data;
  767. }
  768. /**
  769. * @Route(
  770. * "/packages/{name}/stats/all.json",
  771. * name="package_stats",
  772. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?"}
  773. * )
  774. */
  775. public function overallStatsAction(Request $req, Package $package, Version $version = null)
  776. {
  777. if ($from = $req->query->get('from')) {
  778. $from = new DateTimeImmutable($from);
  779. } else {
  780. $from = $this->guessStatsStartDate($version ?: $package);
  781. }
  782. if ($to = $req->query->get('to')) {
  783. $to = new DateTimeImmutable($to);
  784. } else {
  785. $to = new DateTimeImmutable('-2days 00:00:00');
  786. }
  787. $average = $req->query->get('average', $this->guessStatsAverage($from, $to));
  788. $datePoints = $this->createDatePoints($from, $to, $average, $package, $version);
  789. $redis = $this->get('snc_redis.default');
  790. if ($average === 'Daily') {
  791. $datePoints = array_map(function ($vals) {
  792. return $vals[0];
  793. }, $datePoints);
  794. $datePoints = array(
  795. 'labels' => array_keys($datePoints),
  796. 'values' => $redis->mget(array_values($datePoints))
  797. );
  798. } else {
  799. $datePoints = array(
  800. 'labels' => array_keys($datePoints),
  801. 'values' => array_values(array_map(function ($vals) use ($redis) {
  802. return array_sum($redis->mget(array_values($vals)));
  803. }, $datePoints))
  804. );
  805. }
  806. $datePoints['average'] = $average;
  807. if ($average !== 'daily') {
  808. $dividers = [
  809. 'monthly' => 30.41,
  810. 'weekly' => 7,
  811. ];
  812. $divider = $dividers[$average];
  813. $datePoints['values'] = array_map(function ($val) use ($divider) {
  814. return ceil($val / $divider);
  815. }, $datePoints['values']);
  816. }
  817. if (empty($datePoints['labels']) && empty($datePoints['values'])) {
  818. $datePoints['labels'][] = date('Y-m-d');
  819. $datePoints['values'][] = 0;
  820. }
  821. $response = new JsonResponse($datePoints);
  822. $response->setSharedMaxAge(1800);
  823. return $response;
  824. }
  825. /**
  826. * @Route(
  827. * "/packages/{name}/stats/{version}.json",
  828. * name="version_stats",
  829. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "version"=".+?"}
  830. * )
  831. */
  832. public function versionStatsAction(Request $req, Package $package, $version)
  833. {
  834. $normalizer = new VersionParser;
  835. $normVersion = $normalizer->normalize($version);
  836. $version = $this->getDoctrine()->getRepository('PackagistWebBundle:Version')->findOneBy([
  837. 'package' => $package,
  838. 'normalizedVersion' => $normVersion
  839. ]);
  840. if (!$version) {
  841. throw new NotFoundHttpException();
  842. }
  843. return $this->overallStatsAction($req, $package, $version);
  844. }
  845. private function createAddMaintainerForm($package)
  846. {
  847. if (!$user = $this->getUser()) {
  848. return;
  849. }
  850. if ($this->isGranted('ROLE_EDIT_PACKAGES') || $package->getMaintainers()->contains($user)) {
  851. $maintainerRequest = new MaintainerRequest();
  852. return $this->createForm(new AddMaintainerRequestType(), $maintainerRequest);
  853. }
  854. }
  855. private function createRemoveMaintainerForm(Package $package)
  856. {
  857. if (!($user = $this->getUser()) || 1 == $package->getMaintainers()->count()) {
  858. return;
  859. }
  860. if ($this->isGranted('ROLE_EDIT_PACKAGES') || $package->getMaintainers()->contains($user)) {
  861. $maintainerRequest = new MaintainerRequest();
  862. return $this->createForm(new RemoveMaintainerRequestType(), $maintainerRequest, array('package'=>$package));
  863. }
  864. }
  865. private function createDeletePackageForm(Package $package)
  866. {
  867. if (!$user = $this->getUser()) {
  868. return;
  869. }
  870. // super admins bypass additional checks
  871. if (!$this->isGranted('ROLE_DELETE_PACKAGES')) {
  872. // non maintainers can not delete
  873. if (!$package->getMaintainers()->contains($user)) {
  874. return;
  875. }
  876. try {
  877. $downloads = $this->get('packagist.download_manager')->getTotalDownloads($package);
  878. } catch (ConnectionException $e) {
  879. return;
  880. }
  881. // more than 100 downloads = established package, do not allow deletion by maintainers
  882. if ($downloads > 100) {
  883. return;
  884. }
  885. }
  886. return $this->createFormBuilder(array())->getForm();
  887. }
  888. private function createDatePoints(DateTimeImmutable $from, DateTimeImmutable $to, $average, Package $package, Version $version = null)
  889. {
  890. $interval = $this->getStatsInterval($average);
  891. $dateKey = $average === 'monthly' ? 'Ym' : 'Ymd';
  892. $dateFormat = $average === 'monthly' ? 'Y-m' : 'Y-m-d';
  893. $dateJump = $average === 'monthly' ? '+1month' : '+1day';
  894. if ($average === 'monthly') {
  895. $to = new DateTimeImmutable('last day of '.$to->format('Y-m'));
  896. }
  897. $nextDataPointLabel = $from->format($dateFormat);
  898. $nextDataPoint = $from->modify($interval);
  899. $datePoints = [];
  900. while ($from <= $to) {
  901. $datePoints[$nextDataPointLabel][] = 'dl:'.$package->getId().($version ? '-' . $version->getId() : '').':'.$from->format($dateKey);
  902. $from = $from->modify($dateJump);
  903. if ($from >= $nextDataPoint) {
  904. $nextDataPointLabel = $from->format($dateFormat);
  905. $nextDataPoint = $from->modify($interval);
  906. }
  907. }
  908. return $datePoints;
  909. }
  910. private function guessStatsStartDate($packageOrVersion)
  911. {
  912. if ($packageOrVersion instanceof Package) {
  913. $date = DateTimeImmutable::createFromMutable($packageOrVersion->getCreatedAt());
  914. } elseif ($packageOrVersion instanceof Version) {
  915. $date = DateTimeImmutable::createFromMutable($packageOrVersion->getReleasedAt());
  916. } else {
  917. throw new \LogicException('Version or Package expected');
  918. }
  919. $statsRecordDate = new DateTimeImmutable('2012-04-13 00:00:00');
  920. if ($date < $statsRecordDate) {
  921. $date = $statsRecordDate;
  922. }
  923. return $date->setTime(0, 0, 0);
  924. }
  925. private function guessStatsAverage(DateTimeImmutable $from, DateTimeImmutable $to = null)
  926. {
  927. if ($to === null) {
  928. $to = new DateTimeImmutable('-2 days');
  929. }
  930. if ($from < $to->modify('-48months')) {
  931. $average = 'monthly';
  932. } elseif ($from < $to->modify('-7months')) {
  933. $average = 'weekly';
  934. } else {
  935. $average = 'daily';
  936. }
  937. return $average;
  938. }
  939. private function getStatsInterval($average)
  940. {
  941. $intervals = [
  942. 'monthly' => '+1month',
  943. 'weekly' => '+7days',
  944. 'daily' => '+1day',
  945. ];
  946. if (!isset($intervals[$average])) {
  947. throw new BadRequestHttpException();
  948. }
  949. return $intervals[$average];
  950. }
  951. }