WebController.php 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926
  1. <?php
  2. /*
  3. * This file is part of Packagist.
  4. *
  5. * (c) Jordi Boggiano <j.boggiano@seld.be>
  6. * Nils Adermann <naderman@naderman.de>
  7. *
  8. * For the full copyright and license information, please view the LICENSE
  9. * file that was distributed with this source code.
  10. */
  11. namespace Packagist\WebBundle\Controller;
  12. use Composer\Console\HtmlOutputFormatter;
  13. use Composer\IO\BufferIO;
  14. use Composer\Factory;
  15. use Composer\Repository\VcsRepository;
  16. use Composer\Package\Loader\ValidatingArrayLoader;
  17. use Composer\Package\Loader\ArrayLoader;
  18. use Doctrine\ORM\NoResultException;
  19. use Packagist\WebBundle\Form\Type\AddMaintainerRequestType;
  20. use Packagist\WebBundle\Form\Model\AddMaintainerRequest;
  21. use Packagist\WebBundle\Form\Type\SearchQueryType;
  22. use Packagist\WebBundle\Form\Model\SearchQuery;
  23. use Packagist\WebBundle\Package\Updater;
  24. use Packagist\WebBundle\Entity\Package;
  25. use Packagist\WebBundle\Entity\Version;
  26. use Pagerfanta\Adapter\FixedAdapter;
  27. use Packagist\WebBundle\Form\Type\PackageType;
  28. use Symfony\Component\HttpFoundation\RedirectResponse;
  29. use Symfony\Component\HttpFoundation\Response;
  30. use Symfony\Component\HttpFoundation\JsonResponse;
  31. use Symfony\Component\HttpFoundation\Request;
  32. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  33. use Symfony\Component\Console\Output\OutputInterface;
  34. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Template;
  35. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
  36. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Method;
  37. use Symfony\Component\Security\Core\Exception\AccessDeniedException;
  38. use Pagerfanta\Pagerfanta;
  39. use Pagerfanta\Adapter\DoctrineORMAdapter;
  40. use Pagerfanta\Adapter\SolariumAdapter;
  41. use Predis\Connection\ConnectionException;
  42. /**
  43. * @author Jordi Boggiano <j.boggiano@seld.be>
  44. */
  45. class WebController extends Controller
  46. {
  47. /**
  48. * @Template()
  49. * @Route("/", name="home")
  50. */
  51. public function indexAction()
  52. {
  53. return array('page' => 'home', 'searchForm' => $this->createSearchForm()->createView());
  54. }
  55. /**
  56. * @Template("PackagistWebBundle:Web:browse.html.twig")
  57. * @Route("/packages/", name="allPackages")
  58. */
  59. public function allAction(Request $req)
  60. {
  61. $filters = array(
  62. 'type' => $req->query->get('type'),
  63. 'tag' => $req->query->get('tag'),
  64. );
  65. $data = $filters;
  66. $page = $req->query->get('page', 1);
  67. $packages = $this->getDoctrine()
  68. ->getRepository('PackagistWebBundle:Package')
  69. ->getFilteredQueryBuilder($filters);
  70. $data['packages'] = $this->setupPager($packages, $page);
  71. $data['meta'] = $this->getPackagesMetadata($data['packages']);
  72. $data['searchForm'] = $this->createSearchForm()->createView();
  73. return $data;
  74. }
  75. /**
  76. * @Template()
  77. * @Route("/explore/", name="browse")
  78. */
  79. public function exploreAction(Request $req)
  80. {
  81. $pkgRepo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  82. $verRepo = $this->getDoctrine()->getRepository('PackagistWebBundle:Version');
  83. $newSubmitted = $pkgRepo->getQueryBuilderForNewestPackages()->setMaxResults(10)->getQuery()->getResult();
  84. $newReleases = $verRepo->getLatestReleases(10);
  85. $randomIds = $this->getDoctrine()->getConnection()->fetchAll('SELECT id FROM package ORDER BY RAND() LIMIT 10');
  86. $random = $pkgRepo->createQueryBuilder('p')->where('p.id IN (:ids)')->setParameter('ids', $randomIds)->getQuery()->getResult();
  87. try {
  88. $popular = array();
  89. $popularIds = $this->get('snc_redis.default')->zrevrange('downloads:trending', 0, 9);
  90. if ($popularIds) {
  91. $popular = $pkgRepo->createQueryBuilder('p')->where('p.id IN (:ids)')->setParameter('ids', $popularIds)->getQuery()->getResult();
  92. usort($popular, function ($a, $b) use ($popularIds) {
  93. return array_search($a->getId(), $popularIds) > array_search($b->getId(), $popularIds) ? 1 : -1;
  94. });
  95. }
  96. } catch (ConnectionException $e) {
  97. $popular = array();
  98. }
  99. $data = array(
  100. 'newlySubmitted' => $newSubmitted,
  101. 'newlyReleased' => $newReleases,
  102. 'random' => $random,
  103. 'popular' => $popular,
  104. 'searchForm' => $this->createSearchForm()->createView(),
  105. );
  106. return $data;
  107. }
  108. /**
  109. * @Template()
  110. * @Route("/explore/popular", name="browse_popular")
  111. */
  112. public function popularAction(Request $req)
  113. {
  114. $redis = $this->get('snc_redis.default');
  115. $popularIds = $redis->zrevrange(
  116. 'downloads:trending',
  117. ($req->get('page', 1) - 1) * 15,
  118. $req->get('page', 1) * 15 - 1
  119. );
  120. $popular = $this->getDoctrine()->getRepository('PackagistWebBundle:Package')
  121. ->createQueryBuilder('p')->where('p.id IN (:ids)')->setParameter('ids', $popularIds)
  122. ->getQuery()->getResult();
  123. usort($popular, function ($a, $b) use ($popularIds) {
  124. return array_search($a->getId(), $popularIds) > array_search($b->getId(), $popularIds) ? 1 : -1;
  125. });
  126. $packages = new Pagerfanta(new FixedAdapter($redis->zcard('downloads:trending'), $popular));
  127. $packages->setMaxPerPage(15);
  128. $packages->setCurrentPage($req->get('page', 1), false, true);
  129. $data = array(
  130. 'packages' => $packages,
  131. 'searchForm' => $this->createSearchForm()->createView(),
  132. );
  133. $data['meta'] = $this->getPackagesMetadata($data['packages']);
  134. return $data;
  135. }
  136. /**
  137. * @Route("/packages/list.json", name="list", defaults={"_format"="json"})
  138. * @Method({"GET"})
  139. */
  140. public function listAction(Request $req)
  141. {
  142. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  143. if ($req->query->get('type')) {
  144. $names = $repo->getPackageNamesByType($req->query->get('type'));
  145. } elseif ($req->query->get('vendor')) {
  146. $names = $repo->getPackageNamesByVendor($req->query->get('vendor'));
  147. } else {
  148. $names = array_keys($repo->getPackageNames());
  149. }
  150. return new JsonResponse(array('packageNames' => $names));
  151. }
  152. /**
  153. * Initializes the pager for a query.
  154. *
  155. * @param \Doctrine\ORM\QueryBuilder $query Query for packages
  156. * @param int $page Pagenumber to retrieve.
  157. * @return \Pagerfanta\Pagerfanta
  158. */
  159. protected function setupPager($query, $page)
  160. {
  161. $paginator = new Pagerfanta(new DoctrineORMAdapter($query, true));
  162. $paginator->setMaxPerPage(15);
  163. $paginator->setCurrentPage($page, false, true);
  164. return $paginator;
  165. }
  166. /**
  167. * @Route("/search/", name="search.ajax")
  168. * @Route("/search.{_format}", requirements={"_format"="(html|json)"}, name="search", defaults={"_format"="html"})
  169. */
  170. public function searchAction(Request $req)
  171. {
  172. $form = $this->createSearchForm();
  173. // transform q=search shortcut
  174. if ($req->query->has('q')) {
  175. $req->query->set('search_query', array('query' => $req->query->get('q')));
  176. }
  177. $typeFilter = $req->query->get('type');
  178. $tagsFilter = $req->query->get('tags');
  179. if ($req->query->has('search_query') || $typeFilter || $tagsFilter) {
  180. /** @var $solarium \Solarium_Client */
  181. $solarium = $this->get('solarium.client');
  182. $select = $solarium->createSelect();
  183. // configure dismax
  184. $dismax = $select->getDisMax();
  185. $dismax->setQueryFields(array('name^4', 'description', 'tags', 'text', 'text_ngram', 'name_split^2'));
  186. $dismax->setPhraseFields(array('description'));
  187. $dismax->setBoostFunctions(array('log(trendiness)^10'));
  188. $dismax->setMinimumMatch(1);
  189. $dismax->setQueryParser('edismax');
  190. // filter by type
  191. if ($typeFilter) {
  192. $filterQueryTerm = sprintf('type:%s', $select->getHelper()->escapeTerm($typeFilter));
  193. $filterQuery = $select->createFilterQuery('type')->setQuery($filterQueryTerm);
  194. $select->addFilterQuery($filterQuery);
  195. }
  196. // filter by tags
  197. if ($tagsFilter) {
  198. $tags = array();
  199. foreach ((array) $tagsFilter as $tag) {
  200. $tags[] = $select->getHelper()->escapeTerm($tag);
  201. }
  202. $filterQueryTerm = sprintf('tags:(%s)', implode(' AND ', $tags));
  203. $filterQuery = $select->createFilterQuery('tags')->setQuery($filterQueryTerm);
  204. $select->addFilterQuery($filterQuery);
  205. }
  206. if ($req->query->has('search_query')) {
  207. $form->bind($req);
  208. if ($form->isValid()) {
  209. $escapedQuery = $select->getHelper()->escapeTerm($form->getData()->getQuery());
  210. $select->setQuery($escapedQuery);
  211. }
  212. }
  213. $paginator = new Pagerfanta(new SolariumAdapter($solarium, $select));
  214. $paginator->setMaxPerPage(15);
  215. $paginator->setCurrentPage($req->query->get('page', 1), false, true);
  216. $metadata = $this->getPackagesMetadata($paginator);
  217. if ($req->getRequestFormat() === 'json') {
  218. try {
  219. $result = array(
  220. 'results' => array(),
  221. 'total' => $paginator->getNbResults(),
  222. );
  223. } catch (\Solarium_Client_HttpException $e) {
  224. return new JsonResponse(array(
  225. 'status' => 'error',
  226. 'message' => 'Could not connect to the search server',
  227. ), 500);
  228. }
  229. foreach ($paginator as $package) {
  230. $url = $this->generateUrl('view_package', array('name' => $package->name), true);
  231. $result['results'][] = array(
  232. 'name' => $package->name,
  233. 'description' => $package->description ?: '',
  234. 'url' => $url,
  235. 'downloads' => $metadata['downloads'][$package->id],
  236. 'favers' => $metadata['favers'][$package->id],
  237. );
  238. }
  239. if ($paginator->hasNextPage()) {
  240. $params = array(
  241. '_format' => 'json',
  242. 'q' => $form->getData()->getQuery(),
  243. 'page' => $paginator->getNextPage()
  244. );
  245. if ($tagsFilter) {
  246. $params['tags'] = (array) $tagsFilter;
  247. }
  248. if ($typeFilter) {
  249. $params['type'] = (array) $typeFilter;
  250. }
  251. $result['next'] = $this->generateUrl('search', $params, true);
  252. }
  253. return new JsonResponse($result);
  254. }
  255. if ($req->isXmlHttpRequest()) {
  256. try {
  257. return $this->render('PackagistWebBundle:Web:list.html.twig', array(
  258. 'packages' => $paginator,
  259. 'meta' => $metadata,
  260. 'noLayout' => true,
  261. ));
  262. } catch (\Twig_Error_Runtime $e) {
  263. if (!$e->getPrevious() instanceof \Solarium_Client_HttpException) {
  264. throw $e;
  265. }
  266. return new JsonResponse(array(
  267. 'status' => 'error',
  268. 'message' => 'Could not connect to the search server',
  269. ), 500);
  270. }
  271. }
  272. return $this->render('PackagistWebBundle:Web:search.html.twig', array(
  273. 'packages' => $paginator,
  274. 'meta' => $metadata,
  275. 'searchForm' => $form->createView(),
  276. ));
  277. } elseif ($req->getRequestFormat() === 'json') {
  278. return new JsonResponse(array('error' => 'Missing search query, example: ?q=example'), 400);
  279. }
  280. return $this->render('PackagistWebBundle:Web:search.html.twig', array('searchForm' => $form->createView()));
  281. }
  282. /**
  283. * @Template()
  284. * @Route("/packages/submit", name="submit")
  285. */
  286. public function submitPackageAction(Request $req)
  287. {
  288. $package = new Package;
  289. $package->setEntityRepository($this->getDoctrine()->getRepository('PackagistWebBundle:Package'));
  290. $package->setRouter($this->get('router'));
  291. $form = $this->createForm(new PackageType, $package);
  292. if ('POST' === $req->getMethod()) {
  293. $form->bind($req);
  294. if ($form->isValid()) {
  295. try {
  296. $user = $this->getUser();
  297. $package->addMaintainer($user);
  298. $em = $this->getDoctrine()->getManager();
  299. $em->persist($package);
  300. $em->flush();
  301. $this->get('session')->getFlashBag()->set('success', $package->getName().' has been added to the package list, the repository will now be crawled.');
  302. return new RedirectResponse($this->generateUrl('view_package', array('name' => $package->getName())));
  303. } catch (\Exception $e) {
  304. $this->get('logger')->crit($e->getMessage(), array('exception', $e));
  305. $this->get('session')->getFlashBag()->set('error', $package->getName().' could not be saved.');
  306. }
  307. }
  308. }
  309. return array('form' => $form->createView(), 'page' => 'submit', 'searchForm' => $this->createSearchForm()->createView());
  310. }
  311. /**
  312. * @Route("/packages/fetch-info", name="submit.fetch_info", defaults={"_format"="json"})
  313. */
  314. public function fetchInfoAction()
  315. {
  316. $package = new Package;
  317. $package->setEntityRepository($this->getDoctrine()->getRepository('PackagistWebBundle:Package'));
  318. $package->setRouter($this->get('router'));
  319. $form = $this->createForm(new PackageType, $package);
  320. $response = array('status' => 'error', 'reason' => 'No data posted.');
  321. $req = $this->getRequest();
  322. if ('POST' === $req->getMethod()) {
  323. $form->bind($req);
  324. if ($form->isValid()) {
  325. list($vendor, $name) = explode('/', $package->getName(), 2);
  326. $existingPackages = $this->getDoctrine()
  327. ->getRepository('PackagistWebBundle:Package')
  328. ->createQueryBuilder('p')
  329. ->where('p.name LIKE ?0')
  330. ->setParameters(array('%/'.$name))
  331. ->getQuery()
  332. ->getResult();
  333. $similar = array();
  334. foreach ($existingPackages as $existingPackage) {
  335. $similar[] = array(
  336. 'name' => $existingPackage->getName(),
  337. 'url' => $this->generateUrl('view_package', array('name' => $existingPackage->getName()), true),
  338. );
  339. }
  340. $response = array('status' => 'success', 'name' => $package->getName(), 'similar' => $similar);
  341. } else {
  342. $errors = array();
  343. if (count($form->getErrors())) {
  344. foreach ($form->getErrors() as $error) {
  345. $errors[] = $error->getMessageTemplate();
  346. }
  347. }
  348. foreach ($form->all() as $child) {
  349. if (count($child->getErrors())) {
  350. foreach ($child->getErrors() as $error) {
  351. $errors[] = $error->getMessageTemplate();
  352. }
  353. }
  354. }
  355. $response = array('status' => 'error', 'reason' => $errors);
  356. }
  357. }
  358. return new Response(json_encode($response));
  359. }
  360. /**
  361. * @Template()
  362. * @Route("/packages/{vendor}/", name="view_vendor", requirements={"vendor"="[A-Za-z0-9_.-]+"})
  363. */
  364. public function viewVendorAction($vendor)
  365. {
  366. $packages = $this->getDoctrine()
  367. ->getRepository('PackagistWebBundle:Package')
  368. ->createQueryBuilder('p')
  369. ->where('p.name LIKE ?0')
  370. ->setParameters(array($vendor.'/%'))
  371. ->getQuery()
  372. ->getResult();
  373. if (!$packages) {
  374. return $this->redirect($this->generateUrl('search', array('q' => $vendor, 'reason' => 'vendor_not_found')));
  375. }
  376. return array(
  377. 'packages' => $packages,
  378. 'meta' => $this->getPackagesMetadata($packages),
  379. 'vendor' => $vendor,
  380. 'paginate' => false,
  381. 'searchForm' => $this->createSearchForm()->createView()
  382. );
  383. }
  384. /**
  385. * @Route(
  386. * "/p/{name}.{_format}",
  387. * name="view_package_alias",
  388. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "_format"="(html|json)"},
  389. * defaults={"_format"="html"}
  390. * )
  391. * @Route(
  392. * "/packages/{name}",
  393. * name="view_package_alias2",
  394. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?/", "_format"="(html|json)"},
  395. * defaults={"_format"="html"}
  396. * )
  397. * @Method({"GET"})
  398. */
  399. public function viewPackageAliasAction(Request $req, $name)
  400. {
  401. return $this->redirect($this->generateUrl('view_package', array('name' => trim($name, '/'), '_format' => $req->getRequestFormat())));
  402. }
  403. /**
  404. * @Template()
  405. * @Route(
  406. * "/packages/{name}.{_format}",
  407. * name="view_package",
  408. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "_format"="(html|json)"},
  409. * defaults={"_format"="html"}
  410. * )
  411. * @Method({"GET"})
  412. */
  413. public function viewPackageAction(Request $req, $name)
  414. {
  415. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  416. try {
  417. /** @var $package Package */
  418. $package = $repo->findOneByName($name);
  419. } catch (NoResultException $e) {
  420. if ('json' === $req->getRequestFormat()) {
  421. return new JsonResponse(array('status' => 'error', 'message' => 'Package not found'), 404);
  422. }
  423. return $this->redirect($this->generateUrl('search', array('q' => $name, 'reason' => 'package_not_found')));
  424. }
  425. if ('json' === $req->getRequestFormat()) {
  426. $data = $package->toArray();
  427. try {
  428. $data['downloads'] = $this->get('packagist.download_manager')->getDownloads($package);
  429. $data['favers'] = $this->get('packagist.favorite_manager')->getFaverCount($package);
  430. } catch (ConnectionException $e) {
  431. $data['downloads'] = null;
  432. $data['favers'] = null;
  433. }
  434. // TODO invalidate cache on update and make the ttl longer
  435. $response = new Response(json_encode(array('package' => $data)), 200);
  436. $response->setSharedMaxAge(3600);
  437. return $response;
  438. }
  439. $version = null;
  440. if (count($package->getVersions())) {
  441. $versionRepo = $this->getDoctrine()->getRepository('PackagistWebBundle:Version');
  442. $version = $versionRepo->getFullVersion($package->getVersions()->first()->getId());
  443. }
  444. $data = array('package' => $package, 'version' => $version);
  445. try {
  446. $data['downloads'] = $this->get('packagist.download_manager')->getDownloads($package);
  447. if ($this->getUser()) {
  448. $data['is_favorite'] = $this->get('packagist.favorite_manager')->isMarked($this->getUser(), $package);
  449. }
  450. } catch (ConnectionException $e) {
  451. $data['downloads'] = array(
  452. 'total' => 'N/A',
  453. 'monthly' => 'N/A',
  454. 'daily' => 'N/A',
  455. );
  456. }
  457. $data['searchForm'] = $this->createSearchForm()->createView();
  458. if ($maintainerForm = $this->createAddMaintainerForm($package)) {
  459. $data['form'] = $maintainerForm->createView();
  460. }
  461. if ($deleteForm = $this->createDeletePackageForm($package)) {
  462. $data['deleteForm'] = $deleteForm->createView();
  463. }
  464. if ($this->getUser() && (
  465. $this->get('security.context')->isGranted('ROLE_DELETE_PACKAGES')
  466. || $package->getMaintainers()->contains($this->getUser())
  467. )) {
  468. $data['deleteVersionCsrfToken'] = $this->get('form.csrf_provider')->generateCsrfToken('delete_version');
  469. }
  470. return $data;
  471. }
  472. /**
  473. * @Template()
  474. * @Route(
  475. * "/versions/{versionId}.{_format}",
  476. * name="view_version",
  477. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "versionId"="[0-9]+", "_format"="(json)"}
  478. * )
  479. * @Method({"GET"})
  480. */
  481. public function viewPackageVersionAction(Request $req, $versionId)
  482. {
  483. /** @var \Packagist\WebBundle\Entity\VersionRepository $repo */
  484. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Version');
  485. $html = $this->renderView(
  486. 'PackagistWebBundle:Web:versionDetails.html.twig',
  487. array('version' => $repo->getFullVersion($versionId))
  488. );
  489. return new JsonResponse(array('content' => $html));
  490. }
  491. /**
  492. * @Template()
  493. * @Route(
  494. * "/versions/{versionId}/delete",
  495. * name="delete_version",
  496. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "versionId"="[0-9]+"}
  497. * )
  498. * @Method({"DELETE"})
  499. */
  500. public function deletePackageVersionAction(Request $req, $versionId)
  501. {
  502. /** @var \Packagist\WebBundle\Entity\VersionRepository $repo */
  503. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Version');
  504. /** @var Version $version */
  505. $version = $repo->getFullVersion($versionId);
  506. $package = $version->getPackage();
  507. if (!$package->getMaintainers()->contains($this->getUser()) && !$this->get('security.context')->isGranted('ROLE_DELETE_PACKAGES')) {
  508. throw new AccessDeniedException;
  509. }
  510. if (!$this->get('form.csrf_provider')->isCsrfTokenValid('delete_version', $req->request->get('_token'))) {
  511. throw new AccessDeniedException;
  512. }
  513. $repo->remove($version);
  514. $this->getDoctrine()->getManager()->flush();
  515. $this->getDoctrine()->getManager()->clear();
  516. return new RedirectResponse($this->generateUrl('view_package', array('name' => $package->getName())));
  517. }
  518. /**
  519. * @Template()
  520. * @Route("/packages/{name}", name="update_package", requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+"}, defaults={"_format" = "json"})
  521. * @Method({"PUT"})
  522. */
  523. public function updatePackageAction($name)
  524. {
  525. $doctrine = $this->getDoctrine();
  526. try {
  527. $package = $doctrine
  528. ->getRepository('PackagistWebBundle:Package')
  529. ->getFullPackageByName($name);
  530. } catch (NoResultException $e) {
  531. return new Response(json_encode(array('status' => 'error', 'message' => 'Package not found',)), 404);
  532. }
  533. $req = $this->getRequest();
  534. $username = $req->request->has('username') ?
  535. $req->request->get('username') :
  536. $req->query->get('username');
  537. $apiToken = $req->request->has('apiToken') ?
  538. $req->request->get('apiToken') :
  539. $req->query->get('apiToken');
  540. $update = $req->request->get('update', $req->query->get('update'));
  541. $autoUpdated = $req->request->get('autoUpdated', $req->query->get('autoUpdated'));
  542. $user = $this->getUser() ?: $doctrine
  543. ->getRepository('PackagistWebBundle:User')
  544. ->findOneBy(array('username' => $username, 'apiToken' => $apiToken));
  545. if (!$user) {
  546. return new Response(json_encode(array('status' => 'error', 'message' => 'Invalid credentials',)), 403);
  547. }
  548. if ($package->getMaintainers()->contains($user) || $this->get('security.context')->isGranted('ROLE_UPDATE_PACKAGES')) {
  549. if (null !== $autoUpdated) {
  550. $package->setAutoUpdated((Boolean) $autoUpdated);
  551. $doctrine->getManager()->flush();
  552. }
  553. if ($update) {
  554. set_time_limit(3600);
  555. $updater = $this->get('packagist.package_updater');
  556. $io = new BufferIO('', OutputInterface::VERBOSITY_VERBOSE, new HtmlOutputFormatter(Factory::createAdditionalStyles()));
  557. $config = Factory::createConfig();
  558. $repository = new VcsRepository(array('url' => $package->getRepository()), $io, $config);
  559. $loader = new ValidatingArrayLoader(new ArrayLoader());
  560. $repository->setLoader($loader);
  561. try {
  562. $updater->update($package, $repository, Updater::UPDATE_TAGS);
  563. } catch (\Exception $e) {
  564. return new Response(json_encode(array(
  565. 'status' => 'error',
  566. 'message' => '['.get_class($e).'] '.$e->getMessage(),
  567. 'details' => '<pre>'.$io->getOutput().'</pre>'
  568. )), 400);
  569. }
  570. }
  571. return new Response('{"status": "success"}', 202);
  572. }
  573. return new Response(json_encode(array('status' => 'error', 'message' => 'Could not find a package that matches this request (does user maintain the package?)',)), 404);
  574. }
  575. /**
  576. * @Template()
  577. * @Route("/packages/{name}", name="delete_package", requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+"})
  578. * @Method({"DELETE"})
  579. */
  580. public function deletePackageAction(Request $req, $name)
  581. {
  582. $doctrine = $this->getDoctrine();
  583. try {
  584. $package = $doctrine
  585. ->getRepository('PackagistWebBundle:Package')
  586. ->findOneByName($name);
  587. } catch (NoResultException $e) {
  588. throw new NotFoundHttpException('The requested package, '.$name.', was not found.');
  589. }
  590. if (!$form = $this->createDeletePackageForm($package)) {
  591. throw new AccessDeniedException;
  592. }
  593. $form->bind($req->request->get('form'));
  594. if ($form->isValid()) {
  595. $versionRepo = $doctrine->getRepository('PackagistWebBundle:Version');
  596. foreach ($package->getVersions() as $version) {
  597. $versionRepo->remove($version);
  598. }
  599. $packageId = $package->getId();
  600. $em = $doctrine->getManager();
  601. $em->remove($package);
  602. $em->flush();
  603. // attempt solr cleanup
  604. try {
  605. $solarium = $this->get('solarium.client');
  606. $update = $solarium->createUpdate();
  607. $update->addDeleteById($packageId);
  608. $update->addCommit();
  609. $solarium->update($update);
  610. } catch (\Solarium_Client_HttpException $e) {}
  611. return new RedirectResponse($this->generateUrl('home'));
  612. }
  613. return new Response('Invalid form input', 400);
  614. }
  615. /**
  616. * @Template("PackagistWebBundle:Web:viewPackage.html.twig")
  617. * @Route("/packages/{name}/maintainers/", name="add_maintainer", requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+"})
  618. */
  619. public function createMaintainerAction(Request $req, $name)
  620. {
  621. /** @var $package Package */
  622. $package = $this->getDoctrine()
  623. ->getRepository('PackagistWebBundle:Package')
  624. ->findOneByName($name);
  625. if (!$package) {
  626. throw new NotFoundHttpException('The requested package, '.$name.', was not found.');
  627. }
  628. if (!$form = $this->createAddMaintainerForm($package)) {
  629. throw new AccessDeniedException('You must be a package\'s maintainer to modify maintainers.');
  630. }
  631. $data = array(
  632. 'package' => $package,
  633. 'form' => $form->createView(),
  634. 'show_maintainer_form' => true,
  635. );
  636. if ('POST' === $req->getMethod()) {
  637. $form->bind($req);
  638. if ($form->isValid()) {
  639. try {
  640. $em = $this->getDoctrine()->getManager();
  641. $user = $form->getData()->getUser();
  642. if (!empty($user)) {
  643. if (!$package->getMaintainers()->contains($user)) {
  644. $package->addMaintainer($user);
  645. }
  646. $em->persist($package);
  647. $em->flush();
  648. $this->get('session')->getFlashBag()->set('success', $user->getUsername().' is now a '.$package->getName().' maintainer.');
  649. return new RedirectResponse($this->generateUrl('view_package', array('name' => $package->getName())));
  650. }
  651. $this->get('session')->getFlashBag()->set('error', 'The user could not be found.');
  652. } catch (\Exception $e) {
  653. $this->get('logger')->crit($e->getMessage(), array('exception', $e));
  654. $this->get('session')->getFlashBag()->set('error', 'The maintainer could not be added.');
  655. }
  656. }
  657. }
  658. $data['searchForm'] = $this->createSearchForm()->createView();
  659. return $data;
  660. }
  661. /**
  662. * @Route("/statistics", name="stats")
  663. * @Template
  664. */
  665. public function statsAction()
  666. {
  667. $packages = $this->getDoctrine()
  668. ->getConnection()
  669. ->fetchAll('SELECT COUNT(*) count, DATE_FORMAT(createdAt, "%Y-%m") month FROM `package` GROUP BY month');
  670. $versions = $this->getDoctrine()
  671. ->getConnection()
  672. ->fetchAll('SELECT COUNT(*) count, DATE_FORMAT(releasedAt, "%Y-%m") month FROM `package_version` GROUP BY month');
  673. $chart = array('versions' => array(), 'packages' => array(), 'months' => array());
  674. // prepare x axis
  675. $date = new \DateTime($packages[0]['month'].'-01');
  676. $now = new \DateTime;
  677. while ($date < $now) {
  678. $chart['months'][] = $month = $date->format('Y-m');
  679. $date->modify('+1month');
  680. }
  681. // prepare data
  682. $count = 0;
  683. foreach ($packages as $dataPoint) {
  684. $count += $dataPoint['count'];
  685. $chart['packages'][$dataPoint['month']] = $count;
  686. }
  687. $count = 0;
  688. foreach ($versions as $dataPoint) {
  689. $count += $dataPoint['count'];
  690. if (in_array($dataPoint['month'], $chart['months'])) {
  691. $chart['versions'][$dataPoint['month']] = $count;
  692. }
  693. }
  694. // fill gaps at the end of the chart
  695. if (count($chart['months']) > count($chart['packages'])) {
  696. $chart['packages'] += array_fill(0, count($chart['months']) - count($chart['packages']), max($chart['packages']));
  697. }
  698. if (count($chart['months']) > count($chart['versions'])) {
  699. $chart['versions'] += array_fill(0, count($chart['months']) - count($chart['versions']), max($chart['versions']));
  700. }
  701. $res = $this->getDoctrine()
  702. ->getConnection()
  703. ->fetchAssoc('SELECT DATE_FORMAT(createdAt, "%Y-%m-%d") createdAt FROM `package` ORDER BY id LIMIT 1');
  704. $downloadsStartDate = $res['createdAt'] > '2012-04-13' ? $res['createdAt'] : '2012-04-13';
  705. try {
  706. $redis = $this->get('snc_redis.default');
  707. $downloads = $redis->get('downloads') ?: 0;
  708. $date = new \DateTime($downloadsStartDate.' 00:00:00');
  709. $yesterday = new \DateTime('-2days 00:00:00');
  710. $dlChart = $dlChartMonthly = array();
  711. while ($date <= $yesterday) {
  712. $dlChart[$date->format('Y-m-d')] = 'downloads:'.$date->format('Ymd');
  713. $dlChartMonthly[$date->format('Y-m')] = 'downloads:'.$date->format('Ym');
  714. $date->modify('+1day');
  715. }
  716. $dlChart = array(
  717. 'labels' => array_keys($dlChartMonthly),
  718. 'values' => $redis->mget(array_values($dlChart))
  719. );
  720. $dlChartMonthly = array(
  721. 'labels' => array_keys($dlChartMonthly),
  722. 'values' => $redis->mget(array_values($dlChartMonthly))
  723. );
  724. } catch (ConnectionException $e) {
  725. $downloads = 'N/A';
  726. $dlChart = $dlChartMonthly = null;
  727. }
  728. return array(
  729. 'chart' => $chart,
  730. 'packages' => max($chart['packages']),
  731. 'versions' => max($chart['versions']),
  732. 'downloads' => $downloads,
  733. 'downloadsChart' => $dlChart,
  734. 'maxDailyDownloads' => !empty($dlChart) ? max($dlChart['values']) : null,
  735. 'downloadsChartMonthly' => $dlChartMonthly,
  736. 'maxMonthlyDownloads' => !empty($dlChartMonthly) ? max($dlChartMonthly['values']) : null,
  737. 'downloadsStartDate' => $downloadsStartDate,
  738. );
  739. }
  740. /**
  741. * @Route("/about-composer")
  742. */
  743. public function aboutComposerFallbackAction()
  744. {
  745. return new RedirectResponse('http://getcomposer.org/', 301);
  746. }
  747. public function render($view, array $parameters = array(), Response $response = null)
  748. {
  749. if (!isset($parameters['searchForm'])) {
  750. $parameters['searchForm'] = $this->createSearchForm()->createView();
  751. }
  752. return parent::render($view, $parameters, $response);
  753. }
  754. private function createAddMaintainerForm($package)
  755. {
  756. if (!$user = $this->getUser()) {
  757. return;
  758. }
  759. if ($this->get('security.context')->isGranted('ROLE_EDIT_PACKAGES') || $package->getMaintainers()->contains($user)) {
  760. $addMaintainerRequest = new AddMaintainerRequest;
  761. return $this->createForm(new AddMaintainerRequestType, $addMaintainerRequest);
  762. }
  763. }
  764. private function createDeletePackageForm(Package $package)
  765. {
  766. if (!$user = $this->getUser()) {
  767. return;
  768. }
  769. // super admins bypass additional checks
  770. if (!$this->get('security.context')->isGranted('ROLE_DELETE_PACKAGES')) {
  771. // non maintainers can not delete
  772. if (!$package->getMaintainers()->contains($user)) {
  773. return;
  774. }
  775. try {
  776. $downloads = $this->get('packagist.download_manager')->getDownloads($package);
  777. } catch (ConnectionException $e) {
  778. return;
  779. }
  780. // more than 50 downloads = established package, do not allow deletion by maintainers
  781. if ($downloads['total'] > 50) {
  782. return;
  783. }
  784. }
  785. return $this->createFormBuilder(array())->getForm();
  786. }
  787. private function createSearchForm()
  788. {
  789. return $this->createForm(new SearchQueryType, new SearchQuery);
  790. }
  791. }