WebController.php 51 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382
  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\Factory;
  14. use Composer\IO\BufferIO;
  15. use Composer\Package\Loader\ArrayLoader;
  16. use Composer\Package\Loader\ValidatingArrayLoader;
  17. use Composer\Repository\VcsRepository;
  18. use Doctrine\ORM\NoResultException;
  19. use Packagist\WebBundle\Entity\Package;
  20. use Packagist\WebBundle\Entity\Version;
  21. use Packagist\WebBundle\Form\Model\MaintainerRequest;
  22. use Packagist\WebBundle\Form\Model\SearchQuery;
  23. use Packagist\WebBundle\Form\Type\AddMaintainerRequestType;
  24. use Packagist\WebBundle\Form\Type\PackageType;
  25. use Packagist\WebBundle\Form\Type\RemoveMaintainerRequestType;
  26. use Packagist\WebBundle\Form\Type\SearchQueryType;
  27. use Packagist\WebBundle\Package\Updater;
  28. use Pagerfanta\Adapter\DoctrineORMAdapter;
  29. use Pagerfanta\Adapter\FixedAdapter;
  30. use Pagerfanta\Adapter\SolariumAdapter;
  31. use Pagerfanta\Pagerfanta;
  32. use Predis\Connection\ConnectionException;
  33. use Symfony\Component\Console\Output\OutputInterface;
  34. use Symfony\Component\HttpFoundation\JsonResponse;
  35. use Symfony\Component\HttpFoundation\RedirectResponse;
  36. use Symfony\Component\HttpFoundation\Request;
  37. use Symfony\Component\HttpFoundation\Response;
  38. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  39. use Symfony\Component\Security\Core\Exception\AccessDeniedException;
  40. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Template;
  41. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Cache;
  42. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
  43. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Method;
  44. /**
  45. * @author Jordi Boggiano <j.boggiano@seld.be>
  46. */
  47. class WebController extends Controller
  48. {
  49. /**
  50. * @Template()
  51. * @Route("/", name="home")
  52. */
  53. public function indexAction()
  54. {
  55. return array('page' => 'home');
  56. }
  57. /**
  58. * @Template("PackagistWebBundle:Web:browse.html.twig")
  59. * @Route("/packages/", name="allPackages")
  60. * @Cache(smaxage=900)
  61. */
  62. public function allAction(Request $req)
  63. {
  64. $filters = array(
  65. 'type' => $req->query->get('type'),
  66. 'tag' => $req->query->get('tag'),
  67. );
  68. $data = $filters;
  69. $page = $req->query->get('page', 1);
  70. $packages = $this->getDoctrine()
  71. ->getRepository('PackagistWebBundle:Package')
  72. ->getFilteredQueryBuilder($filters);
  73. $data['packages'] = $this->setupPager($packages, $page);
  74. $data['meta'] = $this->getPackagesMetadata($data['packages']);
  75. return $data;
  76. }
  77. /**
  78. * @Template()
  79. * @Route("/explore/", name="browse")
  80. */
  81. public function exploreAction(Request $req)
  82. {
  83. $pkgRepo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  84. $verRepo = $this->getDoctrine()->getRepository('PackagistWebBundle:Version');
  85. $newSubmitted = $pkgRepo->getQueryBuilderForNewestPackages()->setMaxResults(10)
  86. ->getQuery()->useResultCache(true, 900, 'new_submitted_packages')->getResult();
  87. $newReleases = $verRepo->getLatestReleases(10);
  88. $randomIds = $this->getDoctrine()->getConnection()->fetchAll('SELECT id FROM package ORDER BY RAND() LIMIT 10');
  89. $random = $pkgRepo->createQueryBuilder('p')->where('p.id IN (:ids)')->setParameter('ids', $randomIds)->getQuery()->getResult();
  90. try {
  91. $popular = array();
  92. $popularIds = $this->get('snc_redis.default')->zrevrange('downloads:trending', 0, 9);
  93. if ($popularIds) {
  94. $popular = $pkgRepo->createQueryBuilder('p')->where('p.id IN (:ids)')->setParameter('ids', $popularIds)
  95. ->getQuery()->useResultCache(true, 900, 'popular_packages')->getResult();
  96. usort($popular, function ($a, $b) use ($popularIds) {
  97. return array_search($a->getId(), $popularIds) > array_search($b->getId(), $popularIds) ? 1 : -1;
  98. });
  99. }
  100. } catch (ConnectionException $e) {
  101. $popular = array();
  102. }
  103. $data = array(
  104. 'newlySubmitted' => $newSubmitted,
  105. 'newlyReleased' => $newReleases,
  106. 'random' => $random,
  107. 'popular' => $popular,
  108. );
  109. return $data;
  110. }
  111. /**
  112. * @Template()
  113. * @Route("/explore/popular.{_format}", name="browse_popular", defaults={"_format"="html"})
  114. * @Cache(smaxage=900)
  115. */
  116. public function popularAction(Request $req)
  117. {
  118. try {
  119. $redis = $this->get('snc_redis.default');
  120. $perPage = $req->query->getInt('per_page', 15);
  121. if ($perPage <= 0 || $perPage > 100) {
  122. if ($req->getRequestFormat() === 'json') {
  123. return new JsonResponse(array(
  124. 'status' => 'error',
  125. 'message' => 'The optional packages per_page parameter must be an integer between 1 and 100 (default: 15)',
  126. ), 400);
  127. }
  128. $perPage = max(0, min(100, $perPage));
  129. }
  130. $popularIds = $redis->zrevrange(
  131. 'downloads:trending',
  132. ($req->get('page', 1) - 1) * $perPage,
  133. $req->get('page', 1) * $perPage - 1
  134. );
  135. $popular = $this->getDoctrine()->getRepository('PackagistWebBundle:Package')
  136. ->createQueryBuilder('p')->where('p.id IN (:ids)')->setParameter('ids', $popularIds)
  137. ->getQuery()->useResultCache(true, 900, 'popular_packages')->getResult();
  138. usort($popular, function ($a, $b) use ($popularIds) {
  139. return array_search($a->getId(), $popularIds) > array_search($b->getId(), $popularIds) ? 1 : -1;
  140. });
  141. $packages = new Pagerfanta(new FixedAdapter($redis->zcard('downloads:trending'), $popular));
  142. $packages->setMaxPerPage($perPage);
  143. $packages->setCurrentPage($req->get('page', 1), false, true);
  144. } catch (ConnectionException $e) {
  145. $packages = new Pagerfanta(new FixedAdapter(0, array()));
  146. }
  147. $data = array(
  148. 'packages' => $packages,
  149. );
  150. $data['meta'] = $this->getPackagesMetadata($data['packages']);
  151. if ($req->getRequestFormat() === 'json') {
  152. $result = array(
  153. 'packages' => array(),
  154. 'total' => $packages->getNbResults(),
  155. );
  156. foreach ($packages as $package) {
  157. $url = $this->generateUrl('view_package', array('name' => $package->getName()), true);
  158. $result['packages'][] = array(
  159. 'name' => $package->getName(),
  160. 'description' => $package->getDescription() ?: '',
  161. 'url' => $url,
  162. 'downloads' => $data['meta']['downloads'][$package->getId()],
  163. 'favers' => $data['meta']['favers'][$package->getId()],
  164. );
  165. }
  166. if ($packages->hasNextPage()) {
  167. $params = array(
  168. '_format' => 'json',
  169. 'page' => $packages->getNextPage()
  170. );
  171. if ($perPage !== 15) {
  172. $params['per_page'] = $perPage;
  173. }
  174. $result['next'] = $this->generateUrl('browse_popular', $params, true);
  175. }
  176. return new JsonResponse($result);
  177. }
  178. return $data;
  179. }
  180. /**
  181. * @Route("/packages/list.json", name="list", defaults={"_format"="json"})
  182. * @Method({"GET"})
  183. * @Cache(smaxage=300)
  184. */
  185. public function listAction(Request $req)
  186. {
  187. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  188. $fields = (array) $req->query->get('fields', array());
  189. $fields = array_intersect($fields, array('repository', 'type'));
  190. if ($fields) {
  191. $filters = array_filter(array(
  192. 'type' => $req->query->get('type'),
  193. 'vendor' => $req->query->get('vendor'),
  194. ));
  195. return new JsonResponse(array('packages' => $repo->getPackagesWithFields($filters, $fields)));
  196. }
  197. if ($req->query->get('type')) {
  198. $names = $repo->getPackageNamesByType($req->query->get('type'));
  199. } elseif ($req->query->get('vendor')) {
  200. $names = $repo->getPackageNamesByVendor($req->query->get('vendor'));
  201. } else {
  202. $names = $repo->getPackageNames();
  203. }
  204. return new JsonResponse(array('packageNames' => $names));
  205. }
  206. public function searchFormAction(Request $req)
  207. {
  208. $form = $this->createForm(new SearchQueryType, new SearchQuery);
  209. $filteredOrderBys = $this->getFilteredOrderedBys($req);
  210. $normalizedOrderBys = $this->getNormalizedOrderBys($filteredOrderBys);
  211. $this->computeSearchQuery($req, $filteredOrderBys);
  212. if ($req->query->has('search_query')) {
  213. $form->bind($req);
  214. }
  215. $orderBysViewModel = $this->getOrderBysViewModel($req, $normalizedOrderBys);
  216. return $this->render('PackagistWebBundle:Web:searchForm.html.twig', array(
  217. 'searchForm' => $form->createView(),
  218. 'orderBys' => $orderBysViewModel
  219. ));
  220. }
  221. /**
  222. * @Route("/search/", name="search.ajax")
  223. * @Route("/search.{_format}", requirements={"_format"="(html|json)"}, name="search", defaults={"_format"="html"})
  224. */
  225. public function searchAction(Request $req)
  226. {
  227. $form = $this->createForm(new SearchQueryType, new SearchQuery);
  228. $filteredOrderBys = $this->getFilteredOrderedBys($req);
  229. $normalizedOrderBys = $this->getNormalizedOrderBys($filteredOrderBys);
  230. $this->computeSearchQuery($req, $filteredOrderBys);
  231. $typeFilter = $req->query->get('type');
  232. $tagsFilter = $req->query->get('tags');
  233. if ($req->query->has('search_query') || $typeFilter || $tagsFilter) {
  234. /** @var $solarium \Solarium_Client */
  235. $solarium = $this->get('solarium.client');
  236. $select = $solarium->createSelect();
  237. // configure dismax
  238. $dismax = $select->getDisMax();
  239. $dismax->setQueryFields(array('name^4', 'description', 'tags', 'text', 'text_ngram', 'name_split^2'));
  240. $dismax->setPhraseFields(array('description'));
  241. $dismax->setBoostFunctions(array('log(trendiness)^10'));
  242. $dismax->setMinimumMatch(1);
  243. $dismax->setQueryParser('edismax');
  244. // filter by type
  245. if ($typeFilter) {
  246. $filterQueryTerm = sprintf('type:"%s"', $select->getHelper()->escapeTerm($typeFilter));
  247. $filterQuery = $select->createFilterQuery('type')->setQuery($filterQueryTerm);
  248. $select->addFilterQuery($filterQuery);
  249. }
  250. // filter by tags
  251. if ($tagsFilter) {
  252. $tags = array();
  253. foreach ((array) $tagsFilter as $tag) {
  254. $tags[] = $select->getHelper()->escapeTerm($tag);
  255. }
  256. $filterQueryTerm = sprintf('tags:("%s")', implode('" AND "', $tags));
  257. $filterQuery = $select->createFilterQuery('tags')->setQuery($filterQueryTerm);
  258. $select->addFilterQuery($filterQuery);
  259. }
  260. if (!empty($filteredOrderBys)) {
  261. $select->addSorts($normalizedOrderBys);
  262. }
  263. if ($req->query->has('search_query')) {
  264. $form->bind($req);
  265. if ($form->isValid()) {
  266. $escapedQuery = $select->getHelper()->escapeTerm($form->getData()->getQuery());
  267. $escapedQuery = preg_replace('/(^| )\\\\-(\S)/', '$1-$2', $escapedQuery);
  268. $escapedQuery = preg_replace('/(^| )\\\\\+(\S)/', '$1+$2', $escapedQuery);
  269. if ((substr_count($escapedQuery, '"') % 2) == 0) {
  270. $escapedQuery = str_replace('\\"', '"', $escapedQuery);
  271. }
  272. $select->setQuery($escapedQuery);
  273. }
  274. }
  275. $paginator = new Pagerfanta(new SolariumAdapter($solarium, $select));
  276. $perPage = $req->query->getInt('per_page', 15);
  277. if ($perPage <= 0 || $perPage > 100) {
  278. if ($req->getRequestFormat() === 'json') {
  279. return JsonResponse::create(array(
  280. 'status' => 'error',
  281. 'message' => 'The optional packages per_page parameter must be an integer between 1 and 100 (default: 15)',
  282. ), 400)->setCallback($req->query->get('callback'));
  283. }
  284. $perPage = max(0, min(100, $perPage));
  285. }
  286. $paginator->setMaxPerPage($perPage);
  287. $paginator->setCurrentPage($req->query->get('page', 1), false, true);
  288. $metadata = array();
  289. foreach ($paginator as $package) {
  290. if (is_numeric($package->id)) {
  291. $metadata['downloads'][$package->id] = $package->downloads;
  292. $metadata['favers'][$package->id] = $package->favers;
  293. }
  294. }
  295. if ($req->getRequestFormat() === 'json') {
  296. try {
  297. $result = array(
  298. 'results' => array(),
  299. 'total' => $paginator->getNbResults(),
  300. );
  301. } catch (\Solarium_Client_HttpException $e) {
  302. return JsonResponse::create(array(
  303. 'status' => 'error',
  304. 'message' => 'Could not connect to the search server',
  305. ), 500)->setCallback($req->query->get('callback'));
  306. }
  307. foreach ($paginator as $package) {
  308. if (ctype_digit((string) $package->id)) {
  309. $url = $this->generateUrl('view_package', array('name' => $package->name), true);
  310. } else {
  311. $url = $this->generateUrl('view_providers', array('name' => $package->name), true);
  312. }
  313. $row = array(
  314. 'name' => $package->name,
  315. 'description' => $package->description ?: '',
  316. 'url' => $url,
  317. 'repository' => $package->repository,
  318. );
  319. if (is_numeric($package->id)) {
  320. $row['downloads'] = $metadata['downloads'][$package->id];
  321. $row['favers'] = $metadata['favers'][$package->id];
  322. } else {
  323. $row['virtual'] = true;
  324. }
  325. $result['results'][] = $row;
  326. }
  327. if ($paginator->hasNextPage()) {
  328. $params = array(
  329. '_format' => 'json',
  330. 'q' => $form->getData()->getQuery(),
  331. 'page' => $paginator->getNextPage()
  332. );
  333. if ($tagsFilter) {
  334. $params['tags'] = (array) $tagsFilter;
  335. }
  336. if ($typeFilter) {
  337. $params['type'] = $typeFilter;
  338. }
  339. if ($perPage !== 15) {
  340. $params['per_page'] = $perPage;
  341. }
  342. $result['next'] = $this->generateUrl('search', $params, true);
  343. }
  344. return JsonResponse::create($result)->setCallback($req->query->get('callback'));
  345. }
  346. if ($req->isXmlHttpRequest()) {
  347. try {
  348. return $this->render('PackagistWebBundle:Web:search.html.twig', array(
  349. 'packages' => $paginator,
  350. 'meta' => $metadata,
  351. 'noLayout' => true,
  352. ));
  353. } catch (\Twig_Error_Runtime $e) {
  354. if (!$e->getPrevious() instanceof \Solarium_Client_HttpException) {
  355. throw $e;
  356. }
  357. return JsonResponse::create(array(
  358. 'status' => 'error',
  359. 'message' => 'Could not connect to the search server',
  360. ), 500)->setCallback($req->query->get('callback'));
  361. }
  362. }
  363. return $this->render('PackagistWebBundle:Web:search.html.twig', array(
  364. 'packages' => $paginator,
  365. 'meta' => $metadata,
  366. ));
  367. } elseif ($req->getRequestFormat() === 'json') {
  368. return JsonResponse::create(array(
  369. 'error' => 'Missing search query, example: ?q=example'
  370. ), 400)->setCallback($req->query->get('callback'));
  371. }
  372. return $this->render('PackagistWebBundle:Web:search.html.twig');
  373. }
  374. /**
  375. * @Template()
  376. * @Route("/packages/submit", name="submit")
  377. */
  378. public function submitPackageAction(Request $req)
  379. {
  380. $package = new Package;
  381. $package->setEntityRepository($this->getDoctrine()->getRepository('PackagistWebBundle:Package'));
  382. $package->setRouter($this->get('router'));
  383. $form = $this->createForm(new PackageType, $package);
  384. $user = $this->getUser();
  385. $package->addMaintainer($user);
  386. if ('POST' === $req->getMethod()) {
  387. $form->bind($req);
  388. if ($form->isValid()) {
  389. try {
  390. $em = $this->getDoctrine()->getManager();
  391. $em->persist($package);
  392. $em->flush();
  393. $this->get('session')->getFlashBag()->set('success', $package->getName().' has been added to the package list, the repository will now be crawled.');
  394. return new RedirectResponse($this->generateUrl('view_package', array('name' => $package->getName())));
  395. } catch (\Exception $e) {
  396. $this->get('logger')->crit($e->getMessage(), array('exception', $e));
  397. $this->get('session')->getFlashBag()->set('error', $package->getName().' could not be saved.');
  398. }
  399. }
  400. }
  401. return array('form' => $form->createView(), 'page' => 'submit');
  402. }
  403. /**
  404. * @Route("/packages/fetch-info", name="submit.fetch_info", defaults={"_format"="json"})
  405. */
  406. public function fetchInfoAction(Request $req)
  407. {
  408. $package = new Package;
  409. $package->setEntityRepository($this->getDoctrine()->getRepository('PackagistWebBundle:Package'));
  410. $package->setRouter($this->get('router'));
  411. $form = $this->createForm(new PackageType, $package);
  412. $user = $this->getUser();
  413. $package->addMaintainer($user);
  414. $response = array('status' => 'error', 'reason' => 'No data posted.');
  415. if ('POST' === $req->getMethod()) {
  416. $form->bind($req);
  417. if ($form->isValid()) {
  418. list(, $name) = explode('/', $package->getName(), 2);
  419. $existingPackages = $this->getDoctrine()
  420. ->getRepository('PackagistWebBundle:Package')
  421. ->createQueryBuilder('p')
  422. ->where('p.name LIKE ?0')
  423. ->setParameters(array('%/'.$name))
  424. ->getQuery()
  425. ->getResult();
  426. $similar = array();
  427. foreach ($existingPackages as $existingPackage) {
  428. $similar[] = array(
  429. 'name' => $existingPackage->getName(),
  430. 'url' => $this->generateUrl('view_package', array('name' => $existingPackage->getName()), true),
  431. );
  432. }
  433. $response = array('status' => 'success', 'name' => $package->getName(), 'similar' => $similar);
  434. } else {
  435. $errors = array();
  436. if (count($form->getErrors())) {
  437. foreach ($form->getErrors() as $error) {
  438. $errors[] = $error->getMessageTemplate();
  439. }
  440. }
  441. foreach ($form->all() as $child) {
  442. if (count($child->getErrors())) {
  443. foreach ($child->getErrors() as $error) {
  444. $errors[] = $error->getMessageTemplate();
  445. }
  446. }
  447. }
  448. $response = array('status' => 'error', 'reason' => $errors);
  449. }
  450. }
  451. return new JsonResponse($response);
  452. }
  453. /**
  454. * @Template()
  455. * @Route("/packages/{vendor}/", name="view_vendor", requirements={"vendor"="[A-Za-z0-9_.-]+"})
  456. */
  457. public function viewVendorAction($vendor)
  458. {
  459. $packages = $this->getDoctrine()
  460. ->getRepository('PackagistWebBundle:Package')
  461. ->createQueryBuilder('p')
  462. ->where('p.name LIKE ?0')
  463. ->setParameters(array($vendor.'/%'))
  464. ->getQuery()
  465. ->getResult();
  466. if (!$packages) {
  467. return $this->redirect($this->generateUrl('search', array('q' => $vendor, 'reason' => 'vendor_not_found')));
  468. }
  469. return array(
  470. 'packages' => $packages,
  471. 'meta' => $this->getPackagesMetadata($packages),
  472. 'vendor' => $vendor,
  473. 'paginate' => false
  474. );
  475. }
  476. /**
  477. * @Route(
  478. * "/p/{name}.{_format}",
  479. * name="view_package_alias",
  480. * requirements={"name"="[A-Za-z0-9_.-]+(/[A-Za-z0-9_.-]+?)?", "_format"="(json)"},
  481. * defaults={"_format"="html"}
  482. * )
  483. * @Route(
  484. * "/packages/{name}",
  485. * name="view_package_alias2",
  486. * requirements={"name"="[A-Za-z0-9_.-]+(/[A-Za-z0-9_.-]+?)?/"},
  487. * defaults={"_format"="html"}
  488. * )
  489. * @Method({"GET"})
  490. */
  491. public function viewPackageAliasAction(Request $req, $name)
  492. {
  493. $format = $req->getRequestFormat();
  494. if ($format === 'html') {
  495. $format = null;
  496. }
  497. if (false === strpos(trim($name, '/'), '/')) {
  498. return $this->redirect($this->generateUrl('view_vendor', array('vendor' => $name, '_format' => $format)));
  499. }
  500. return $this->redirect($this->generateUrl('view_package', array('name' => trim($name, '/'), '_format' => $format)));
  501. }
  502. /**
  503. * @Template()
  504. * @Route(
  505. * "/providers/{name}",
  506. * name="view_providers",
  507. * requirements={"name"="[A-Za-z0-9/_.-]+?"},
  508. * defaults={"_format"="html"}
  509. * )
  510. * @Method({"GET"})
  511. */
  512. public function viewProvidersAction(Request $req, $name)
  513. {
  514. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  515. $providers = $repo->findProviders($name);
  516. if (!$providers) {
  517. return $this->redirect($this->generateUrl('search', array('q' => $name, 'reason' => 'package_not_found')));
  518. }
  519. return $this->render('PackagistWebBundle:Web:providers.html.twig', array(
  520. 'name' => $name,
  521. 'packages' => $providers,
  522. 'meta' => $this->getPackagesMetadata($providers),
  523. 'paginate' => false
  524. ));
  525. }
  526. /**
  527. * @Template()
  528. * @Route(
  529. * "/packages/{name}.{_format}",
  530. * name="view_package",
  531. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "_format"="(json)"},
  532. * defaults={"_format"="html"}
  533. * )
  534. * @Method({"GET"})
  535. */
  536. public function viewPackageAction(Request $req, $name)
  537. {
  538. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  539. try {
  540. /** @var $package Package */
  541. $package = $repo->findOneByName($name);
  542. } catch (NoResultException $e) {
  543. if ('json' === $req->getRequestFormat()) {
  544. return new JsonResponse(array('status' => 'error', 'message' => 'Package not found'), 404);
  545. }
  546. if ($providers = $repo->findProviders($name)) {
  547. return $this->redirect($this->generateUrl('view_providers', array('name' => $name)));
  548. }
  549. return $this->redirect($this->generateUrl('search', array('q' => $name, 'reason' => 'package_not_found')));
  550. }
  551. if ('json' === $req->getRequestFormat()) {
  552. $data = $package->toArray();
  553. try {
  554. $data['downloads'] = $this->get('packagist.download_manager')->getDownloads($package);
  555. $data['favers'] = $this->get('packagist.favorite_manager')->getFaverCount($package);
  556. } catch (ConnectionException $e) {
  557. $data['downloads'] = null;
  558. $data['favers'] = null;
  559. }
  560. // TODO invalidate cache on update and make the ttl longer
  561. $response = new JsonResponse(array('package' => $data));
  562. $response->setSharedMaxAge(3600);
  563. return $response;
  564. }
  565. $version = null;
  566. $versions = $package->getVersions();
  567. if (is_object($versions)) {
  568. $versions = $versions->toArray();
  569. }
  570. usort($versions, function ($a, $b) {
  571. $aVersion = $a->getNormalizedVersion();
  572. $bVersion = $b->getNormalizedVersion();
  573. $aVersion = preg_replace('{^dev-.*}', '0.0.0-alpha', $aVersion);
  574. $bVersion = preg_replace('{^dev-.*}', '0.0.0-alpha', $bVersion);
  575. // equal versions are sorted by date
  576. if ($aVersion === $bVersion) {
  577. return $b->getReleasedAt() > $a->getReleasedAt() ? 1 : -1;
  578. }
  579. // the rest is sorted by version
  580. return version_compare($bVersion, $aVersion);
  581. });
  582. if (count($versions)) {
  583. $versionRepo = $this->getDoctrine()->getRepository('PackagistWebBundle:Version');
  584. $version = $versionRepo->getFullVersion(reset($versions)->getId());
  585. }
  586. $expandedVersion = reset($versions);
  587. foreach ($versions as $v) {
  588. if (!$v->isDevelopment()) {
  589. $expandedVersion = $v;
  590. break;
  591. }
  592. }
  593. $expandedVersion = $versionRepo->getFullVersion($expandedVersion->getId());
  594. $data = array(
  595. 'package' => $package,
  596. 'version' => $version,
  597. 'versions' => $versions,
  598. 'expandedVersion' => $expandedVersion,
  599. );
  600. try {
  601. $data['downloads'] = $this->get('packagist.download_manager')->getDownloads($package);
  602. if ($this->getUser()) {
  603. $data['is_favorite'] = $this->get('packagist.favorite_manager')->isMarked($this->getUser(), $package);
  604. }
  605. } catch (ConnectionException $e) {
  606. }
  607. if ($maintainerForm = $this->createAddMaintainerForm($package)) {
  608. $data['addMaintainerForm'] = $maintainerForm->createView();
  609. }
  610. if ($removeMaintainerForm = $this->createRemoveMaintainerForm($package)) {
  611. $data['removeMaintainerForm'] = $removeMaintainerForm->createView();
  612. }
  613. if ($deleteForm = $this->createDeletePackageForm($package)) {
  614. $data['deleteForm'] = $deleteForm->createView();
  615. }
  616. if ($this->getUser() && (
  617. $this->get('security.context')->isGranted('ROLE_DELETE_PACKAGES')
  618. || $package->getMaintainers()->contains($this->getUser())
  619. )) {
  620. $data['deleteVersionCsrfToken'] = $this->get('security.csrf.token_manager')->getToken('delete_version');
  621. }
  622. return $data;
  623. }
  624. /**
  625. * @Template()
  626. * @Route(
  627. * "/packages/{name}/downloads.{_format}",
  628. * name="package_downloads_full",
  629. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "_format"="(json)"}
  630. * )
  631. * @Method({"GET"})
  632. */
  633. public function viewPackageDownloadsAction(Request $req, $name)
  634. {
  635. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Package');
  636. try {
  637. /** @var $package Package */
  638. $package = $repo->findOneByName($name);
  639. } catch (NoResultException $e) {
  640. if ('json' === $req->getRequestFormat()) {
  641. return new JsonResponse(array('status' => 'error', 'message' => 'Package not found'), 404);
  642. }
  643. if ($providers = $repo->findProviders($name)) {
  644. return $this->redirect($this->generateUrl('view_providers', array('name' => $name)));
  645. }
  646. return $this->redirect($this->generateUrl('search', array('q' => $name, 'reason' => 'package_not_found')));
  647. }
  648. $versions = $package->getVersions();
  649. $data = array(
  650. 'name' => $package->getName(),
  651. );
  652. try {
  653. $data['downloads']['total'] = $this->get('packagist.download_manager')->getDownloads($package);
  654. $data['favers'] = $this->get('packagist.favorite_manager')->getFaverCount($package);
  655. } catch (ConnectionException $e) {
  656. $data['downloads']['total'] = null;
  657. $data['favers'] = null;
  658. }
  659. foreach ($versions as $version) {
  660. try {
  661. $data['downloads']['versions'][$version->getVersion()] = $this->get('packagist.download_manager')->getDownloads($package, $version);
  662. } catch (ConnectionException $e) {
  663. $data['downloads']['versions'][$version->getVersion()] = null;
  664. }
  665. }
  666. $response = new Response(json_encode(array('package' => $data)), 200);
  667. $response->setSharedMaxAge(3600);
  668. return $response;
  669. }
  670. /**
  671. * @Template()
  672. * @Route(
  673. * "/versions/{versionId}.{_format}",
  674. * name="view_version",
  675. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "versionId"="[0-9]+", "_format"="(json)"}
  676. * )
  677. * @Method({"GET"})
  678. */
  679. public function viewPackageVersionAction(Request $req, $versionId)
  680. {
  681. /** @var \Packagist\WebBundle\Entity\VersionRepository $repo */
  682. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Version');
  683. $html = $this->renderView(
  684. 'PackagistWebBundle:Web:versionDetails.html.twig',
  685. array('version' => $repo->getFullVersion($versionId))
  686. );
  687. return new JsonResponse(array('content' => $html));
  688. }
  689. /**
  690. * @Template()
  691. * @Route(
  692. * "/versions/{versionId}/delete",
  693. * name="delete_version",
  694. * requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+?", "versionId"="[0-9]+"}
  695. * )
  696. * @Method({"DELETE"})
  697. */
  698. public function deletePackageVersionAction(Request $req, $versionId)
  699. {
  700. /** @var \Packagist\WebBundle\Entity\VersionRepository $repo */
  701. $repo = $this->getDoctrine()->getRepository('PackagistWebBundle:Version');
  702. /** @var Version $version */
  703. $version = $repo->getFullVersion($versionId);
  704. $package = $version->getPackage();
  705. if (!$package->getMaintainers()->contains($this->getUser()) && !$this->get('security.context')->isGranted('ROLE_DELETE_PACKAGES')) {
  706. throw new AccessDeniedException;
  707. }
  708. if (!$this->get('form.csrf_provider')->isCsrfTokenValid('delete_version', $req->request->get('_token'))) {
  709. throw new AccessDeniedException;
  710. }
  711. $repo->remove($version);
  712. $this->getDoctrine()->getManager()->flush();
  713. $this->getDoctrine()->getManager()->clear();
  714. return new RedirectResponse($this->generateUrl('view_package', array('name' => $package->getName())));
  715. }
  716. /**
  717. * @Template()
  718. * @Route("/packages/{name}", name="update_package", requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+"}, defaults={"_format" = "json"})
  719. * @Method({"PUT"})
  720. */
  721. public function updatePackageAction($name)
  722. {
  723. $doctrine = $this->getDoctrine();
  724. try {
  725. $package = $doctrine
  726. ->getRepository('PackagistWebBundle:Package')
  727. ->getPackageByName($name);
  728. } catch (NoResultException $e) {
  729. return new Response(json_encode(array('status' => 'error', 'message' => 'Package not found',)), 404);
  730. }
  731. $req = $this->getRequest();
  732. $username = $req->request->has('username') ?
  733. $req->request->get('username') :
  734. $req->query->get('username');
  735. $apiToken = $req->request->has('apiToken') ?
  736. $req->request->get('apiToken') :
  737. $req->query->get('apiToken');
  738. $update = $req->request->get('update', $req->query->get('update'));
  739. $autoUpdated = $req->request->get('autoUpdated', $req->query->get('autoUpdated'));
  740. $updateEqualRefs = $req->request->get('updateAll', $req->query->get('updateAll'));
  741. $user = $this->getUser() ?: $doctrine
  742. ->getRepository('PackagistWebBundle:User')
  743. ->findOneBy(array('username' => $username, 'apiToken' => $apiToken));
  744. if (!$user) {
  745. return new Response(json_encode(array('status' => 'error', 'message' => 'Invalid credentials',)), 403);
  746. }
  747. if ($package->getMaintainers()->contains($user) || $this->get('security.context')->isGranted('ROLE_UPDATE_PACKAGES')) {
  748. $req->getSession()->save();
  749. if (null !== $autoUpdated) {
  750. $package->setAutoUpdated((Boolean) $autoUpdated);
  751. $doctrine->getManager()->flush();
  752. }
  753. if ($update) {
  754. set_time_limit(3600);
  755. $updater = $this->get('packagist.package_updater');
  756. $io = new BufferIO('', OutputInterface::VERBOSITY_VERBOSE, new HtmlOutputFormatter(Factory::createAdditionalStyles()));
  757. $config = Factory::createConfig();
  758. $io->loadConfiguration($config);
  759. $repository = new VcsRepository(array('url' => $package->getRepository()), $io, $config);
  760. $loader = new ValidatingArrayLoader(new ArrayLoader());
  761. $repository->setLoader($loader);
  762. try {
  763. $updater->update($package, $repository, $updateEqualRefs ? Updater::UPDATE_EQUAL_REFS : 0);
  764. } catch (\Exception $e) {
  765. return new Response(json_encode(array(
  766. 'status' => 'error',
  767. 'message' => '['.get_class($e).'] '.$e->getMessage(),
  768. 'details' => '<pre>'.$io->getOutput().'</pre>'
  769. )), 400);
  770. }
  771. }
  772. return new Response('{"status": "success"}', 202);
  773. }
  774. return new JsonResponse(array('status' => 'error', 'message' => 'Could not find a package that matches this request (does user maintain the package?)',), 404);
  775. }
  776. /**
  777. * @Template()
  778. * @Route("/packages/{name}", name="delete_package", requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+"})
  779. * @Method({"DELETE"})
  780. */
  781. public function deletePackageAction(Request $req, $name)
  782. {
  783. $doctrine = $this->getDoctrine();
  784. try {
  785. $package = $doctrine
  786. ->getRepository('PackagistWebBundle:Package')
  787. ->findOneByName($name);
  788. } catch (NoResultException $e) {
  789. throw new NotFoundHttpException('The requested package, '.$name.', was not found.');
  790. }
  791. if (!$form = $this->createDeletePackageForm($package)) {
  792. throw new AccessDeniedException;
  793. }
  794. $form->bind($req->request->get('form'));
  795. if ($form->isValid()) {
  796. $req->getSession()->save();
  797. $versionRepo = $doctrine->getRepository('PackagistWebBundle:Version');
  798. foreach ($package->getVersions() as $version) {
  799. $versionRepo->remove($version);
  800. }
  801. $packageId = $package->getId();
  802. $em = $doctrine->getManager();
  803. $em->remove($package);
  804. $em->flush();
  805. // attempt solr cleanup
  806. try {
  807. $solarium = $this->get('solarium.client');
  808. $update = $solarium->createUpdate();
  809. $update->addDeleteById($packageId);
  810. $update->addCommit();
  811. $solarium->update($update);
  812. } catch (\Solarium_Client_HttpException $e) {}
  813. return new RedirectResponse($this->generateUrl('home'));
  814. }
  815. return new Response('Invalid form input', 400);
  816. }
  817. /**
  818. * @Template("PackagistWebBundle:Web:viewPackage.html.twig")
  819. * @Route("/packages/{name}/maintainers/", name="add_maintainer", requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+"})
  820. */
  821. public function createMaintainerAction(Request $req, $name)
  822. {
  823. /** @var $package Package */
  824. $package = $this->getDoctrine()
  825. ->getRepository('PackagistWebBundle:Package')
  826. ->findOneByName($name);
  827. if (!$package) {
  828. throw new NotFoundHttpException('The requested package, '.$name.', was not found.');
  829. }
  830. if (!$form = $this->createAddMaintainerForm($package)) {
  831. throw new AccessDeniedException('You must be a package\'s maintainer to modify maintainers.');
  832. }
  833. $data = array(
  834. 'package' => $package,
  835. 'versions' => null,
  836. 'expandedVersion' => null,
  837. 'version' => null,
  838. 'addMaintainerForm' => $form->createView(),
  839. 'show_add_maintainer_form' => true,
  840. );
  841. if ('POST' === $req->getMethod()) {
  842. $form->bind($req);
  843. if ($form->isValid()) {
  844. try {
  845. $em = $this->getDoctrine()->getManager();
  846. $user = $form->getData()->getUser();
  847. if (!empty($user)) {
  848. if (!$package->getMaintainers()->contains($user)) {
  849. $package->addMaintainer($user);
  850. $this->get('packagist.package_manager')->notifyNewMaintainer($user, $package);
  851. }
  852. $em->persist($package);
  853. $em->flush();
  854. $this->get('session')->getFlashBag()->set('success', $user->getUsername().' is now a '.$package->getName().' maintainer.');
  855. return new RedirectResponse($this->generateUrl('view_package', array('name' => $package->getName())));
  856. }
  857. $this->get('session')->getFlashBag()->set('error', 'The user could not be found.');
  858. } catch (\Exception $e) {
  859. $this->get('logger')->crit($e->getMessage(), array('exception', $e));
  860. $this->get('session')->getFlashBag()->set('error', 'The maintainer could not be added.');
  861. }
  862. }
  863. }
  864. return $data;
  865. }
  866. /**
  867. * @Template("PackagistWebBundle:Web:viewPackage.html.twig")
  868. * @Route("/packages/{name}/maintainers/delete", name="remove_maintainer", requirements={"name"="[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+"})
  869. */
  870. public function removeMaintainerAction(Request $req, $name)
  871. {
  872. /** @var $package Package */
  873. $package = $this->getDoctrine()
  874. ->getRepository('PackagistWebBundle:Package')
  875. ->findOneByName($name);
  876. if (!$package) {
  877. throw new NotFoundHttpException('The requested package, '.$name.', was not found.');
  878. }
  879. if (!$removeMaintainerForm = $this->createRemoveMaintainerForm($package)) {
  880. throw new AccessDeniedException('You must be a package\'s maintainer to modify maintainers.');
  881. }
  882. $data = array(
  883. 'package' => $package,
  884. 'versions' => null,
  885. 'expandedVersion' => null,
  886. 'version' => null,
  887. 'removeMaintainerForm' => $removeMaintainerForm->createView(),
  888. 'show_remove_maintainer_form' => true,
  889. );
  890. if ('POST' === $req->getMethod()) {
  891. $removeMaintainerForm->bind($req);
  892. if ($removeMaintainerForm->isValid()) {
  893. try {
  894. $em = $this->getDoctrine()->getManager();
  895. $user = $removeMaintainerForm->getData()->getUser();
  896. if (!empty($user)) {
  897. if ($package->getMaintainers()->contains($user)) {
  898. $package->getMaintainers()->removeElement($user);
  899. }
  900. $em->persist($package);
  901. $em->flush();
  902. $this->get('session')->getFlashBag()->set('success', $user->getUsername().' is no longer a '.$package->getName().' maintainer.');
  903. return new RedirectResponse($this->generateUrl('view_package', array('name' => $package->getName())));
  904. }
  905. $this->get('session')->getFlashBag()->set('error', 'The user could not be found.');
  906. } catch (\Exception $e) {
  907. $this->get('logger')->crit($e->getMessage(), array('exception', $e));
  908. $this->get('session')->getFlashBag()->set('error', 'The maintainer could not be removed.');
  909. }
  910. }
  911. }
  912. return $data;
  913. }
  914. /**
  915. * @Route("/statistics", name="stats")
  916. * @Template
  917. */
  918. public function statsAction()
  919. {
  920. $packages = $this->getDoctrine()
  921. ->getConnection()
  922. ->fetchAll('SELECT COUNT(*) count, DATE_FORMAT(createdAt, "%Y-%m") month FROM `package` GROUP BY month');
  923. $versions = $this->getDoctrine()
  924. ->getConnection()
  925. ->fetchAll('SELECT COUNT(*) count, DATE_FORMAT(releasedAt, "%Y-%m") month FROM `package_version` GROUP BY month');
  926. $chart = array('versions' => array(), 'packages' => array(), 'months' => array());
  927. // prepare x axis
  928. $date = new \DateTime($packages[0]['month'].'-01');
  929. $now = new \DateTime;
  930. while ($date < $now) {
  931. $chart['months'][] = $month = $date->format('Y-m');
  932. $date->modify('+1month');
  933. }
  934. // prepare data
  935. $count = 0;
  936. foreach ($packages as $dataPoint) {
  937. $count += $dataPoint['count'];
  938. $chart['packages'][$dataPoint['month']] = $count;
  939. }
  940. $count = 0;
  941. foreach ($versions as $dataPoint) {
  942. $count += $dataPoint['count'];
  943. if (in_array($dataPoint['month'], $chart['months'])) {
  944. $chart['versions'][$dataPoint['month']] = $count;
  945. }
  946. }
  947. // fill gaps at the end of the chart
  948. if (count($chart['months']) > count($chart['packages'])) {
  949. $chart['packages'] += array_fill(0, count($chart['months']) - count($chart['packages']), !empty($chart['packages']) ? max($chart['packages']) : 0);
  950. }
  951. if (count($chart['months']) > count($chart['versions'])) {
  952. $chart['versions'] += array_fill(0, count($chart['months']) - count($chart['versions']), !empty($chart['versions']) ? max($chart['versions']) : 0);
  953. }
  954. $res = $this->getDoctrine()
  955. ->getConnection()
  956. ->fetchAssoc('SELECT DATE_FORMAT(createdAt, "%Y-%m-%d") createdAt FROM `package` ORDER BY id LIMIT 1');
  957. $downloadsStartDate = $res['createdAt'] > '2012-04-13' ? $res['createdAt'] : '2012-04-13';
  958. try {
  959. $redis = $this->get('snc_redis.default');
  960. $downloads = $redis->get('downloads') ?: 0;
  961. $date = new \DateTime($downloadsStartDate.' 00:00:00');
  962. $yesterday = new \DateTime('-2days 00:00:00');
  963. $dailyGraphStart = new \DateTime('-32days 00:00:00'); // 30 days before yesterday
  964. $dlChart = $dlChartMonthly = array();
  965. while ($date <= $yesterday) {
  966. if ($date > $dailyGraphStart) {
  967. $dlChart[$date->format('Y-m-d')] = 'downloads:'.$date->format('Ymd');
  968. }
  969. $dlChartMonthly[$date->format('Y-m')] = 'downloads:'.$date->format('Ym');
  970. $date->modify('+1day');
  971. }
  972. $dlChart = array(
  973. 'labels' => array_keys($dlChart),
  974. 'values' => $redis->mget(array_values($dlChart))
  975. );
  976. $dlChartMonthly = array(
  977. 'labels' => array_keys($dlChartMonthly),
  978. 'values' => $redis->mget(array_values($dlChartMonthly))
  979. );
  980. } catch (ConnectionException $e) {
  981. $downloads = 'N/A';
  982. $dlChart = $dlChartMonthly = null;
  983. }
  984. return array(
  985. 'chart' => $chart,
  986. 'packages' => !empty($chart['packages']) ? max($chart['packages']) : 0,
  987. 'versions' => !empty($chart['versions']) ? max($chart['versions']) : 0,
  988. 'downloads' => $downloads,
  989. 'downloadsChart' => $dlChart,
  990. 'maxDailyDownloads' => !empty($dlChart) ? max($dlChart['values']) : null,
  991. 'downloadsChartMonthly' => $dlChartMonthly,
  992. 'maxMonthlyDownloads' => !empty($dlChartMonthly) ? max($dlChartMonthly['values']) : null,
  993. 'downloadsStartDate' => $downloadsStartDate,
  994. );
  995. }
  996. /**
  997. * @Route("/about-composer")
  998. */
  999. public function aboutComposerFallbackAction()
  1000. {
  1001. return new RedirectResponse('http://getcomposer.org/', 301);
  1002. }
  1003. private function createAddMaintainerForm($package)
  1004. {
  1005. if (!$user = $this->getUser()) {
  1006. return;
  1007. }
  1008. if ($this->get('security.context')->isGranted('ROLE_EDIT_PACKAGES') || $package->getMaintainers()->contains($user)) {
  1009. $maintainerRequest = new MaintainerRequest;
  1010. return $this->createForm(new AddMaintainerRequestType, $maintainerRequest);
  1011. }
  1012. }
  1013. private function createRemoveMaintainerForm(Package $package)
  1014. {
  1015. if (!($user = $this->getUser()) || 1 == $package->getMaintainers()->count()) {
  1016. return;
  1017. }
  1018. if ($this->get('security.context')->isGranted('ROLE_EDIT_PACKAGES') || $package->getMaintainers()->contains($user)) {
  1019. $maintainerRequest = new MaintainerRequest;
  1020. return $this->createForm(new RemoveMaintainerRequestType(), $maintainerRequest, array('package'=>$package, 'excludeUser'=>$user));
  1021. }
  1022. }
  1023. private function createDeletePackageForm(Package $package)
  1024. {
  1025. if (!$user = $this->getUser()) {
  1026. return;
  1027. }
  1028. // super admins bypass additional checks
  1029. if (!$this->get('security.context')->isGranted('ROLE_DELETE_PACKAGES')) {
  1030. // non maintainers can not delete
  1031. if (!$package->getMaintainers()->contains($user)) {
  1032. return;
  1033. }
  1034. try {
  1035. $downloads = $this->get('packagist.download_manager')->getTotalDownloads($package);
  1036. } catch (ConnectionException $e) {
  1037. return;
  1038. }
  1039. // more than 100 downloads = established package, do not allow deletion by maintainers
  1040. if ($downloads > 100) {
  1041. return;
  1042. }
  1043. }
  1044. return $this->createFormBuilder(array())->getForm();
  1045. }
  1046. /**
  1047. * Initializes the pager for a query.
  1048. *
  1049. * @param \Doctrine\ORM\QueryBuilder $query Query for packages
  1050. * @param int $page Pagenumber to retrieve.
  1051. * @return \Pagerfanta\Pagerfanta
  1052. */
  1053. protected function setupPager($query, $page)
  1054. {
  1055. $paginator = new Pagerfanta(new DoctrineORMAdapter($query, true));
  1056. $paginator->setMaxPerPage(15);
  1057. $paginator->setCurrentPage($page, false, true);
  1058. return $paginator;
  1059. }
  1060. /**
  1061. * @param array $orderBys
  1062. *
  1063. * @return array
  1064. */
  1065. protected function getFilteredOrderedBys(Request $req)
  1066. {
  1067. $orderBys = $req->query->get('orderBys', array());
  1068. if (!$orderBys) {
  1069. $orderBys = $req->query->get('search_query');
  1070. $orderBys = isset($orderBys['orderBys']) ? $orderBys['orderBys'] : array();
  1071. }
  1072. if ($orderBys) {
  1073. $allowedSorts = array(
  1074. 'downloads' => 1,
  1075. 'favers' => 1
  1076. );
  1077. $allowedOrders = array(
  1078. 'asc' => 1,
  1079. 'desc' => 1,
  1080. );
  1081. $filteredOrderBys = array();
  1082. foreach ($orderBys as $orderBy) {
  1083. if (isset($orderBy['sort'])
  1084. && isset($allowedSorts[$orderBy['sort']])
  1085. && isset($orderBy['order'])
  1086. && isset($allowedOrders[$orderBy['order']])) {
  1087. $filteredOrderBys[] = $orderBy;
  1088. }
  1089. }
  1090. } else {
  1091. $filteredOrderBys = array();
  1092. }
  1093. return $filteredOrderBys;
  1094. }
  1095. /**
  1096. * @param array $orderBys
  1097. *
  1098. * @return array
  1099. */
  1100. protected function getNormalizedOrderBys(array $orderBys)
  1101. {
  1102. $normalizedOrderBys = array();
  1103. foreach ($orderBys as $sort) {
  1104. $normalizedOrderBys[$sort['sort']] = $sort['order'];
  1105. }
  1106. return $normalizedOrderBys;
  1107. }
  1108. protected function getOrderBysViewModel(Request $req, $normalizedOrderBys)
  1109. {
  1110. $makeDefaultArrow = function ($sort) use ($normalizedOrderBys) {
  1111. if (isset($normalizedOrderBys[$sort])) {
  1112. if (strtolower($normalizedOrderBys[$sort]) === 'asc') {
  1113. $val = 'glyphicon-arrow-up';
  1114. } else {
  1115. $val = 'glyphicon-arrow-down';
  1116. }
  1117. } else {
  1118. $val = '';
  1119. }
  1120. return $val;
  1121. };
  1122. $makeDefaultHref = function ($sort) use ($req, $normalizedOrderBys) {
  1123. if (isset($normalizedOrderBys[$sort])) {
  1124. if (strtolower($normalizedOrderBys[$sort]) === 'asc') {
  1125. $order = 'desc';
  1126. } else {
  1127. $order = 'asc';
  1128. }
  1129. } else {
  1130. $order = 'desc';
  1131. }
  1132. $query = $req->query->get('search_query');
  1133. $query = isset($query['query']) ? $query['query'] : '';
  1134. return '?' . http_build_query(array(
  1135. 'q' => $query,
  1136. 'orderBys' => array(
  1137. array(
  1138. 'sort' => $sort,
  1139. 'order' => $order
  1140. )
  1141. )
  1142. ));
  1143. };
  1144. return array(
  1145. 'downloads' => array(
  1146. 'title' => 'Sort by downloads',
  1147. 'class' => 'glyphicon-arrow-down',
  1148. 'arrowClass' => $makeDefaultArrow('downloads'),
  1149. 'href' => $makeDefaultHref('downloads')
  1150. ),
  1151. 'favers' => array(
  1152. 'title' => 'Sort by favorites',
  1153. 'class' => 'glyphicon-star',
  1154. 'arrowClass' => $makeDefaultArrow('favers'),
  1155. 'href' => $makeDefaultHref('favers')
  1156. ),
  1157. );
  1158. }
  1159. private function computeSearchQuery(Request $req, array $filteredOrderBys)
  1160. {
  1161. // transform q=search shortcut
  1162. if ($req->query->has('q') || $req->query->has('orderBys')) {
  1163. $searchQuery = array();
  1164. $q = $req->query->get('q');
  1165. if ($q !== null) {
  1166. $searchQuery['query'] = $q;
  1167. }
  1168. if (!empty($filteredOrderBys)) {
  1169. $searchQuery['orderBys'] = $filteredOrderBys;
  1170. }
  1171. $req->query->set(
  1172. 'search_query',
  1173. $searchQuery
  1174. );
  1175. }
  1176. }
  1177. }