page.js 34 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237
  1. module.exports = function(crowi, app) {
  2. 'use strict';
  3. var debug = require('debug')('growi:routes:page')
  4. , logger = require('@alias/logger')('growi:routes:page')
  5. , Page = crowi.model('Page')
  6. , User = crowi.model('User')
  7. , Config = crowi.model('Config')
  8. , config = crowi.getConfig()
  9. , Revision = crowi.model('Revision')
  10. , Bookmark = crowi.model('Bookmark')
  11. , UserGroupRelation = crowi.model('UserGroupRelation')
  12. , PageGroupRelation = crowi.model('PageGroupRelation')
  13. , UpdatePost = crowi.model('UpdatePost')
  14. , ApiResponse = require('../util/apiResponse')
  15. , interceptorManager = crowi.getInterceptorManager()
  16. , pagePathUtil = require('../util/pagePathUtil')
  17. , swig = require('swig-templates')
  18. , getToday = require('../util/getToday')
  19. , actions = {};
  20. // register page events
  21. var pageEvent = crowi.event('page');
  22. pageEvent.on('update', function(page, user) {
  23. crowi.getIo().sockets.emit('page edited', {page, user});
  24. });
  25. function getPathFromRequest(req) {
  26. var path = '/' + (req.params[0] || '');
  27. return path.replace(/\.md$/, '');
  28. }
  29. function isUserPage(path) {
  30. if (path.match(/^\/user\/[^\/]+\/?$/)) {
  31. return true;
  32. }
  33. return false;
  34. }
  35. // TODO: total とかでちゃんと計算する
  36. function generatePager(options) {
  37. var next = null,
  38. prev = null,
  39. offset = parseInt(options.offset, 10),
  40. limit = parseInt(options.limit, 10),
  41. length = options.length || 0;
  42. if (offset > 0) {
  43. prev = offset - limit;
  44. if (prev < 0) {
  45. prev = 0;
  46. }
  47. }
  48. if (length < limit) {
  49. next = null;
  50. }
  51. else {
  52. next = offset + limit;
  53. }
  54. return {
  55. prev: prev,
  56. next: next,
  57. offset: offset,
  58. };
  59. }
  60. /**
  61. * switch action by behaviorType
  62. */
  63. actions.pageListShowWrapper = function(req, res) {
  64. const behaviorType = Config.behaviorType(config);
  65. if (!behaviorType || 'crowi' === behaviorType) {
  66. return actions.pageListShow(req, res);
  67. }
  68. else {
  69. return actions.pageListShowForCrowiPlus(req, res);
  70. }
  71. };
  72. /**
  73. * switch action by behaviorType
  74. */
  75. actions.pageShowWrapper = function(req, res) {
  76. const behaviorType = Config.behaviorType(config);
  77. if (!behaviorType || 'crowi' === behaviorType) {
  78. return actions.pageShow(req, res);
  79. }
  80. else {
  81. return actions.pageShowForCrowiPlus(req, res);
  82. }
  83. };
  84. /**
  85. * switch action by behaviorType
  86. */
  87. actions.trashPageListShowWrapper = function(req, res) {
  88. const behaviorType = Config.behaviorType(config);
  89. if (!behaviorType || 'crowi' === behaviorType) {
  90. // Crowi behavior for '/trash/*'
  91. return actions.deletedPageListShow(req, res);
  92. }
  93. else {
  94. // redirect to '/trash'
  95. return res.redirect('/trash');
  96. }
  97. };
  98. /**
  99. * switch action by behaviorType
  100. */
  101. actions.trashPageShowWrapper = function(req, res) {
  102. const behaviorType = Config.behaviorType(config);
  103. if (!behaviorType || 'crowi' === behaviorType) {
  104. // redirect to '/trash/'
  105. return res.redirect('/trash/');
  106. }
  107. else {
  108. // Crowi behavior for '/trash/*'
  109. return actions.deletedPageListShow(req, res);
  110. }
  111. };
  112. /**
  113. * switch action by behaviorType
  114. */
  115. actions.deletedPageListShowWrapper = function(req, res) {
  116. const behaviorType = Config.behaviorType(config);
  117. if (!behaviorType || 'crowi' === behaviorType) {
  118. // Crowi behavior for '/trash/*'
  119. return actions.deletedPageListShow(req, res);
  120. }
  121. else {
  122. const path = '/trash' + getPathFromRequest(req);
  123. return res.redirect(path);
  124. }
  125. };
  126. actions.pageListShow = function(req, res) {
  127. var path = getPathFromRequest(req);
  128. var limit = 50;
  129. var offset = parseInt(req.query.offset) || 0;
  130. var SEENER_THRESHOLD = 10;
  131. // add slash if root
  132. path = path + (path == '/' ? '' : '/');
  133. debug('Page list show', path);
  134. // index page
  135. var pagerOptions = {
  136. offset: offset,
  137. limit: limit
  138. };
  139. var queryOptions = {
  140. offset: offset,
  141. limit: limit + 1,
  142. isPopulateRevisionBody: Config.isEnabledTimeline(config),
  143. };
  144. var renderVars = {
  145. page: null,
  146. path: path,
  147. isPortal: false,
  148. pages: [],
  149. tree: [],
  150. };
  151. Page.hasPortalPage(path, req.user, req.query.revision)
  152. .then(function(portalPage) {
  153. renderVars.page = portalPage;
  154. renderVars.isPortal = (portalPage != null);
  155. if (portalPage) {
  156. renderVars.revision = portalPage.revision;
  157. return Revision.findRevisionList(portalPage.path, {});
  158. }
  159. else {
  160. return Promise.resolve([]);
  161. }
  162. })
  163. .then(function(tree) {
  164. renderVars.tree = tree;
  165. return Page.findListByStartWith(path, req.user, queryOptions);
  166. })
  167. .then(function(pageList) {
  168. if (pageList.length > limit) {
  169. pageList.pop();
  170. }
  171. pagerOptions.length = pageList.length;
  172. renderVars.viewConfig = {
  173. seener_threshold: SEENER_THRESHOLD,
  174. };
  175. renderVars.pager = generatePager(pagerOptions);
  176. renderVars.pages = pagePathUtil.encodePagesPath(pageList);
  177. })
  178. .then(() => {
  179. return PageGroupRelation.findByPage(renderVars.page);
  180. })
  181. .then((pageGroupRelation) => {
  182. if (pageGroupRelation != null) {
  183. renderVars.pageRelatedGroup = pageGroupRelation.relatedGroup;
  184. }
  185. })
  186. .then(() => {
  187. res.render('customlayout-selector/page_list', renderVars);
  188. }).catch(function(err) {
  189. debug('Error on rendering pageListShow', err);
  190. });
  191. };
  192. actions.pageListShowForCrowiPlus = function(req, res) {
  193. var path = getPathFromRequest(req);
  194. // omit the slash of the last
  195. path = path.replace((/\/$/), '');
  196. // redirect
  197. return res.redirect(path);
  198. };
  199. actions.pageShowForCrowiPlus = function(req, res) {
  200. var path = getPathFromRequest(req);
  201. var limit = 50;
  202. var offset = parseInt(req.query.offset) || 0;
  203. var SEENER_THRESHOLD = 10;
  204. // index page
  205. var pagerOptions = {
  206. offset: offset,
  207. limit: limit
  208. };
  209. var queryOptions = {
  210. offset: offset,
  211. limit: limit + 1,
  212. isPopulateRevisionBody: Config.isEnabledTimeline(config),
  213. includeDeletedPage: path.startsWith('/trash/'),
  214. };
  215. var renderVars = {
  216. path: path,
  217. page: null,
  218. revision: {},
  219. author: false,
  220. pages: [],
  221. tree: [],
  222. pageRelatedGroup: null,
  223. template: null,
  224. slack: '',
  225. };
  226. var pageTeamplate = 'customlayout-selector/page';
  227. var isRedirect = false;
  228. Page.findPage(path, req.user, req.query.revision)
  229. .then(function(page) {
  230. debug('Page found', page._id, page.path);
  231. // redirect
  232. if (page.redirectTo) {
  233. debug(`Redirect to '${page.redirectTo}'`);
  234. isRedirect = true;
  235. return res.redirect(encodeURI(page.redirectTo + '?redirectFrom=' + pagePathUtil.encodePagePath(page.path)));
  236. }
  237. renderVars.page = page;
  238. if (page) {
  239. renderVars.path = page.path;
  240. renderVars.revision = page.revision;
  241. renderVars.author = page.revision.author;
  242. return Revision.findRevisionList(page.path, {})
  243. .then(function(tree) {
  244. renderVars.tree = tree;
  245. })
  246. .then(() => {
  247. return PageGroupRelation.findByPage(renderVars.page);
  248. })
  249. .then((pageGroupRelation) => {
  250. if (pageGroupRelation != null) {
  251. renderVars.pageRelatedGroup = pageGroupRelation.relatedGroup;
  252. }
  253. })
  254. .then(() => {
  255. return getSlackChannels(page);
  256. })
  257. .then((channels) => {
  258. renderVars.slack = channels;
  259. })
  260. .then(function() {
  261. var userPage = isUserPage(page.path);
  262. var userData = null;
  263. if (userPage) {
  264. // change template
  265. pageTeamplate = 'customlayout-selector/user_page';
  266. return User.findUserByUsername(User.getUsernameByPath(page.path))
  267. .then(function(data) {
  268. if (data === null) {
  269. throw new Error('The user not found.');
  270. }
  271. userData = data;
  272. renderVars.pageUser = userData;
  273. return Bookmark.findByUser(userData, {limit: 10, populatePage: true, requestUser: req.user});
  274. }).then(function(bookmarkList) {
  275. renderVars.bookmarkList = bookmarkList;
  276. return Page.findListByCreator(userData, {limit: 10}, req.user);
  277. }).then(function(createdList) {
  278. renderVars.createdList = createdList;
  279. return Promise.resolve();
  280. }).catch(function(err) {
  281. debug('Error on finding user related entities', err);
  282. // pass
  283. });
  284. }
  285. });
  286. }
  287. })
  288. // page is not found or user is forbidden
  289. .catch(function(err) {
  290. let isForbidden = false;
  291. if (err.name === 'UserHasNoGrantException') {
  292. isForbidden = true;
  293. }
  294. if (isForbidden) {
  295. pageTeamplate = 'customlayout-selector/forbidden';
  296. return;
  297. }
  298. else {
  299. pageTeamplate = 'customlayout-selector/not_found';
  300. // look for templates
  301. return Page.findTemplate(path)
  302. .then(template => {
  303. if (template) {
  304. template = replacePlaceholders(template, req);
  305. }
  306. renderVars.template = template;
  307. });
  308. }
  309. })
  310. // get list pages
  311. .then(function() {
  312. if (!isRedirect) {
  313. Page.findListWithDescendants(path, req.user, queryOptions)
  314. .then(function(pageList) {
  315. if (pageList.length > limit) {
  316. pageList.pop();
  317. }
  318. pagerOptions.length = pageList.length;
  319. renderVars.viewConfig = {
  320. seener_threshold: SEENER_THRESHOLD,
  321. };
  322. renderVars.pager = generatePager(pagerOptions);
  323. renderVars.pages = pagePathUtil.encodePagesPath(pageList);
  324. return;
  325. })
  326. .then(function() {
  327. return interceptorManager.process('beforeRenderPage', req, res, renderVars);
  328. })
  329. .then(function() {
  330. res.render(req.query.presentation ? 'page_presentation' : pageTeamplate, renderVars);
  331. })
  332. .catch(function(err) {
  333. console.log(err);
  334. debug('Error on rendering pageListShowForCrowiPlus', err);
  335. });
  336. }
  337. });
  338. };
  339. const getSlackChannels = async page => {
  340. if (page.extended.slack) {
  341. return page.extended.slack;
  342. }
  343. else {
  344. const data = await UpdatePost.findSettingsByPath(page.path);
  345. const channels = data.map(e => e.channel).join(', ');
  346. return channels;
  347. }
  348. };
  349. const replacePlaceholders = (template, req) => {
  350. const definitions = {
  351. pagepath: getPathFromRequest(req),
  352. username: req.user.name,
  353. today: getToday(),
  354. };
  355. const compiledTemplate = swig.compile(template);
  356. return compiledTemplate(definitions);
  357. };
  358. actions.deletedPageListShow = function(req, res) {
  359. var path = '/trash' + getPathFromRequest(req);
  360. var limit = 50;
  361. var offset = parseInt(req.query.offset) || 0;
  362. // index page
  363. var pagerOptions = {
  364. offset: offset,
  365. limit: limit
  366. };
  367. var queryOptions = {
  368. offset: offset,
  369. limit: limit + 1,
  370. includeDeletedPage: true,
  371. };
  372. var renderVars = {
  373. page: null,
  374. path: path,
  375. pages: [],
  376. };
  377. Page.findListWithDescendants(path, req.user, queryOptions)
  378. .then(function(pageList) {
  379. if (pageList.length > limit) {
  380. pageList.pop();
  381. }
  382. pagerOptions.length = pageList.length;
  383. renderVars.pager = generatePager(pagerOptions);
  384. renderVars.pages = pagePathUtil.encodePagesPath(pageList);
  385. res.render('customlayout-selector/page_list', renderVars);
  386. }).catch(function(err) {
  387. debug('Error on rendering deletedPageListShow', err);
  388. });
  389. };
  390. actions.search = function(req, res) {
  391. // spec: ?q=query&sort=sort_order&author=author_filter
  392. var query = req.query.q;
  393. var search = require('../util/search')(crowi);
  394. search.searchPageByKeyword(query)
  395. .then(function(pages) {
  396. debug('pages', pages);
  397. if (pages.hits.total <= 0) {
  398. return Promise.resolve([]);
  399. }
  400. var ids = pages.hits.hits.map(function(page) {
  401. return page._id;
  402. });
  403. return Page.findListByPageIds(ids);
  404. }).then(function(pages) {
  405. res.render('customlayout-selector/page_list', {
  406. path: '/',
  407. pages: pagePathUtil.encodePagesPath(pages),
  408. pager: generatePager({offset: 0, limit: 50})
  409. });
  410. }).catch(function(err) {
  411. debug('search error', err);
  412. });
  413. };
  414. function renderPage(pageData, req, res) {
  415. // create page
  416. if (!pageData) {
  417. const path = getPathFromRequest(req);
  418. return Page.findTemplate(path)
  419. .then(template => {
  420. if (template) {
  421. template = replacePlaceholders(template, req);
  422. }
  423. return res.render('customlayout-selector/not_found', {
  424. author: {},
  425. page: false,
  426. template,
  427. });
  428. });
  429. }
  430. if (pageData.redirectTo) {
  431. return res.redirect(encodeURI(pageData.redirectTo + '?redirectFrom=' + pagePathUtil.encodePagePath(pageData.path)));
  432. }
  433. var renderVars = {
  434. path: pageData.path,
  435. page: pageData,
  436. revision: pageData.revision || {},
  437. author: pageData.revision.author || false,
  438. slack: '',
  439. };
  440. var userPage = isUserPage(pageData.path);
  441. var userData = null;
  442. Revision.findRevisionList(pageData.path, {})
  443. .then(function(tree) {
  444. renderVars.tree = tree;
  445. })
  446. .then(() => {
  447. return PageGroupRelation.findByPage(renderVars.page);
  448. })
  449. .then((pageGroupRelation) => {
  450. if (pageGroupRelation != null) {
  451. renderVars.pageRelatedGroup = pageGroupRelation.relatedGroup;
  452. }
  453. })
  454. .then(() => {
  455. return getSlackChannels(pageData);
  456. })
  457. .then(channels => {
  458. renderVars.slack = channels;
  459. })
  460. .then(function() {
  461. if (userPage) {
  462. return User.findUserByUsername(User.getUsernameByPath(pageData.path))
  463. .then(function(data) {
  464. if (data === null) {
  465. throw new Error('The user not found.');
  466. }
  467. userData = data;
  468. renderVars.pageUser = userData;
  469. return Bookmark.findByUser(userData, {limit: 10, populatePage: true, requestUser: req.user});
  470. }).then(function(bookmarkList) {
  471. renderVars.bookmarkList = bookmarkList;
  472. return Page.findListByCreator(userData, {limit: 10}, req.user);
  473. }).then(function(createdList) {
  474. renderVars.createdList = createdList;
  475. return Promise.resolve();
  476. }).catch(function(err) {
  477. debug('Error on finding user related entities', err);
  478. // pass
  479. });
  480. }
  481. else {
  482. return Promise.resolve();
  483. }
  484. }).then(function() {
  485. return interceptorManager.process('beforeRenderPage', req, res, renderVars);
  486. }).then(function() {
  487. var defaultPageTeamplate = 'customlayout-selector/page';
  488. if (userData) {
  489. defaultPageTeamplate = 'customlayout-selector/user_page';
  490. }
  491. res.render(req.query.presentation ? 'page_presentation' : defaultPageTeamplate, renderVars);
  492. }).catch(function(err) {
  493. debug('Error: renderPage()', err);
  494. if (err) {
  495. res.redirect('/');
  496. }
  497. });
  498. }
  499. actions.pageShow = function(req, res) {
  500. var path = path || getPathFromRequest(req);
  501. // FIXME: せっかく getPathFromRequest になってるのにここが生 params[0] だとダサイ
  502. var isMarkdown = req.params[0].match(/.+\.md$/) || false;
  503. res.locals.path = path;
  504. Page.findPage(path, req.user, req.query.revision)
  505. .then(function(page) {
  506. debug('Page found', page._id, page.path);
  507. if (isMarkdown) {
  508. res.set('Content-Type', 'text/plain');
  509. return res.send(page.revision.body);
  510. }
  511. return renderPage(page, req, res);
  512. }).catch(function(err) {
  513. const normalizedPath = Page.normalizePath(path);
  514. if (normalizedPath !== path) {
  515. return res.redirect(normalizedPath);
  516. }
  517. // pageShow は /* にマッチしてる最後の砦なので、creatableName でない routing は
  518. // これ以前に定義されているはずなので、こうしてしまって問題ない。
  519. if (!Page.isCreatableName(path)) {
  520. // 削除済みページの場合 /trash 以下に移動しているので creatableName になっていないので、表示を許可
  521. debug('Page is not creatable name.', path);
  522. res.redirect('/');
  523. return ;
  524. }
  525. if (req.query.revision) {
  526. return res.redirect(pagePathUtil.encodePagePath(path));
  527. }
  528. if (isMarkdown) {
  529. return res.redirect('/');
  530. }
  531. Page.hasPortalPage(path + '/', req.user)
  532. .then(function(page) {
  533. if (page) {
  534. return res.redirect(pagePathUtil.encodePagePath(path) + '/');
  535. }
  536. else {
  537. var fixed = Page.fixToCreatableName(path);
  538. if (fixed !== path) {
  539. debug('fixed page name', fixed);
  540. res.redirect(pagePathUtil.encodePagePath(fixed));
  541. return ;
  542. }
  543. // if guest user
  544. if (!req.user) {
  545. res.redirect('/');
  546. }
  547. // render editor
  548. debug('Catch pageShow', err);
  549. return renderPage(null, req, res);
  550. }
  551. }).catch(function(err) {
  552. debug('Error on rendering pageShow (redirect to portal)', err);
  553. });
  554. });
  555. };
  556. actions.pageEdit = function(req, res) {
  557. if (!req.form.isValid) {
  558. req.flash('dangerMessage', 'Request is invalid.');
  559. return res.redirect(req.headers.referer);
  560. }
  561. var pageForm = req.form.pageForm;
  562. var path = pageForm.path;
  563. var body = pageForm.body;
  564. var currentRevision = pageForm.currentRevision;
  565. var grant = pageForm.grant;
  566. var grantUserGroupId = pageForm.grantUserGroupId;
  567. // TODO: make it pluggable
  568. var notify = pageForm.notify || {};
  569. debug('notify: ', notify);
  570. var redirectPath = pagePathUtil.encodePagePath(path);
  571. var pageData = {};
  572. var updateOrCreate;
  573. var previousRevision = false;
  574. // set to render
  575. res.locals.pageForm = pageForm;
  576. // 削除済みページはここで編集不可判定される
  577. if (!Page.isCreatableName(path)) {
  578. res.redirect(redirectPath);
  579. return ;
  580. }
  581. var ignoreNotFound = true;
  582. Page.findPage(path, req.user, null, ignoreNotFound)
  583. .then(function(data) {
  584. pageData = data;
  585. if (data && !data.isUpdatable(currentRevision)) {
  586. debug('Conflict occured');
  587. req.flash('dangerMessage', 'Conflict occured');
  588. return res.redirect(req.headers.referer);
  589. }
  590. if (data) {
  591. previousRevision = data.revision;
  592. return Page.updatePage(data, body, req.user, { grant, grantUserGroupId });
  593. }
  594. else {
  595. // new page
  596. updateOrCreate = 'create';
  597. return Page.create(path, body, req.user, { grant, grantUserGroupId });
  598. }
  599. }).then(function(data) {
  600. // data is a saved page data with revision.
  601. pageData = data;
  602. if (!data) {
  603. throw new Error('Data not found');
  604. }
  605. // TODO: move to events
  606. if (notify.slack) {
  607. if (notify.slack.on && notify.slack.channel) {
  608. data.updateSlackChannel(notify.slack.channel)
  609. .catch(err => {
  610. logger.error('Error occured in updating slack channels: ', err);
  611. });
  612. if (crowi.slack) {
  613. const promises = notify.slack.channel.split(',').map(function(chan) {
  614. return crowi.slack.postPage(pageData, req.user, chan, updateOrCreate, previousRevision);
  615. });
  616. Promise.all(promises)
  617. .catch(err => {
  618. logger.error('Error occured in sending slack notification: ', err);
  619. });
  620. }
  621. }
  622. }
  623. return res.redirect(redirectPath);
  624. });
  625. };
  626. var api = actions.api = {};
  627. /**
  628. * redirector
  629. */
  630. api.redirector = function(req, res) {
  631. var id = req.params.id;
  632. Page.findPageById(id)
  633. .then(function(pageData) {
  634. if (pageData.grant == Page.GRANT_RESTRICTED && !pageData.isGrantedFor(req.user)) {
  635. return Page.pushToGrantedUsers(pageData, req.user);
  636. }
  637. return Promise.resolve(pageData);
  638. }).then(function(page) {
  639. return res.redirect(pagePathUtil.encodePagePath(page.path));
  640. }).catch(function(err) {
  641. return res.redirect('/');
  642. });
  643. };
  644. /**
  645. * @api {get} /pages.list List pages by user
  646. * @apiName ListPage
  647. * @apiGroup Page
  648. *
  649. * @apiParam {String} path
  650. * @apiParam {String} user
  651. */
  652. api.list = function(req, res) {
  653. var username = req.query.user || null;
  654. var path = req.query.path || null;
  655. var limit = 50;
  656. var offset = parseInt(req.query.offset) || 0;
  657. var pagerOptions = { offset: offset, limit: limit };
  658. var queryOptions = { offset: offset, limit: limit + 1};
  659. // Accepts only one of these
  660. if (username === null && path === null) {
  661. return res.json(ApiResponse.error('Parameter user or path is required.'));
  662. }
  663. if (username !== null && path !== null) {
  664. return res.json(ApiResponse.error('Parameter user or path is required.'));
  665. }
  666. var pageFetcher;
  667. if (path === null) {
  668. pageFetcher = User.findUserByUsername(username)
  669. .then(function(user) {
  670. if (user === null) {
  671. throw new Error('The user not found.');
  672. }
  673. return Page.findListByCreator(user, queryOptions, req.user);
  674. });
  675. }
  676. else {
  677. pageFetcher = Page.findListByStartWith(path, req.user, queryOptions);
  678. }
  679. pageFetcher
  680. .then(function(pages) {
  681. if (pages.length > limit) {
  682. pages.pop();
  683. }
  684. pagerOptions.length = pages.length;
  685. var result = {};
  686. result.pages = pagePathUtil.encodePagesPath(pages);
  687. return res.json(ApiResponse.success(result));
  688. }).catch(function(err) {
  689. return res.json(ApiResponse.error(err));
  690. });
  691. };
  692. /**
  693. * @api {post} /pages.create Create new page
  694. * @apiName CreatePage
  695. * @apiGroup Page
  696. *
  697. * @apiParam {String} body
  698. * @apiParam {String} path
  699. * @apiParam {String} grant
  700. */
  701. api.create = function(req, res) {
  702. var body = req.body.body || null;
  703. var pagePath = req.body.path || null;
  704. var grant = req.body.grant || null;
  705. var grantUserGroupId = req.body.grantUserGroupId || null;
  706. if (body === null || pagePath === null) {
  707. return res.json(ApiResponse.error('Parameters body and path are required.'));
  708. }
  709. var ignoreNotFound = true;
  710. Page.findPage(pagePath, req.user, null, ignoreNotFound)
  711. .then(function(data) {
  712. if (data !== null) {
  713. throw new Error('Page exists');
  714. }
  715. return Page.create(pagePath, body, req.user, { grant: grant, grantUserGroupId: grantUserGroupId});
  716. }).then(function(data) {
  717. if (!data) {
  718. throw new Error('Failed to create page.');
  719. }
  720. var result = { page: data.toObject() };
  721. result.page.lastUpdateUser = User.filterToPublicFields(data.lastUpdateUser);
  722. result.page.creator = User.filterToPublicFields(data.creator);
  723. return res.json(ApiResponse.success(result));
  724. }).catch(function(err) {
  725. return res.json(ApiResponse.error(err));
  726. });
  727. };
  728. /**
  729. * @api {post} /pages.update Update page
  730. * @apiName UpdatePage
  731. * @apiGroup Page
  732. *
  733. * @apiParam {String} body
  734. * @apiParam {String} page_id
  735. * @apiParam {String} revision_id
  736. * @apiParam {String} grant
  737. *
  738. * In the case of the page exists:
  739. * - If revision_id is specified => update the page,
  740. * - If revision_id is not specified => force update by the new contents.
  741. */
  742. api.update = function(req, res) {
  743. var pageBody = req.body.body || null;
  744. var pageId = req.body.page_id || null;
  745. var revisionId = req.body.revision_id || null;
  746. var grant = req.body.grant || null;
  747. var grantUserGroupId = req.body.grantUserGroupId || null;
  748. if (pageId === null || pageBody === null) {
  749. return res.json(ApiResponse.error('page_id and body are required.'));
  750. }
  751. Page.findPageByIdAndGrantedUser(pageId, req.user)
  752. .then(function(pageData) {
  753. if (pageData && revisionId !== null && !pageData.isUpdatable(revisionId)) {
  754. throw new Error('Revision error.');
  755. }
  756. var grantOption = {};
  757. if (grant != null) {
  758. grantOption.grant = grant;
  759. }
  760. if (grantUserGroupId != null) {
  761. grantOption.grantUserGroupId = grantUserGroupId;
  762. }
  763. return Page.updatePage(pageData, pageBody, req.user, grantOption);
  764. }).then(function(pageData) {
  765. var result = {
  766. page: pageData.toObject(),
  767. };
  768. result.page.lastUpdateUser = User.filterToPublicFields(result.page.lastUpdateUser);
  769. return res.json(ApiResponse.success(result));
  770. }).catch(function(err) {
  771. debug('error on _api/pages.update', err);
  772. return res.json(ApiResponse.error(err));
  773. });
  774. };
  775. /**
  776. * @api {get} /pages.get Get page data
  777. * @apiName GetPage
  778. * @apiGroup Page
  779. *
  780. * @apiParam {String} page_id
  781. * @apiParam {String} path
  782. * @apiParam {String} revision_id
  783. */
  784. api.get = function(req, res) {
  785. const pagePath = req.query.path || null;
  786. const pageId = req.query.page_id || null; // TODO: handling
  787. const revisionId = req.query.revision_id || null;
  788. if (!pageId && !pagePath) {
  789. return res.json(ApiResponse.error(new Error('Parameter path or page_id is required.')));
  790. }
  791. let pageFinder;
  792. if (pageId) { // prioritized
  793. pageFinder = Page.findPageByIdAndGrantedUser(pageId, req.user);
  794. }
  795. else if (pagePath) {
  796. pageFinder = Page.findPage(pagePath, req.user, revisionId);
  797. }
  798. pageFinder.then(function(pageData) {
  799. var result = {};
  800. result.page = pageData;
  801. return res.json(ApiResponse.success(result));
  802. }).catch(function(err) {
  803. return res.json(ApiResponse.error(err));
  804. });
  805. };
  806. /**
  807. * @api {post} /pages.seen Mark as seen user
  808. * @apiName SeenPage
  809. * @apiGroup Page
  810. *
  811. * @apiParam {String} page_id Page Id.
  812. */
  813. api.seen = function(req, res) {
  814. var pageId = req.body.page_id;
  815. if (!pageId) {
  816. return res.json(ApiResponse.error('page_id required'));
  817. }
  818. Page.findPageByIdAndGrantedUser(pageId, req.user)
  819. .then(function(page) {
  820. return page.seen(req.user);
  821. }).then(function(user) {
  822. var result = {};
  823. result.seenUser = user;
  824. return res.json(ApiResponse.success(result));
  825. }).catch(function(err) {
  826. debug('Seen user update error', err);
  827. return res.json(ApiResponse.error(err));
  828. });
  829. };
  830. /**
  831. * @api {post} /likes.add Like page
  832. * @apiName LikePage
  833. * @apiGroup Page
  834. *
  835. * @apiParam {String} page_id Page Id.
  836. */
  837. api.like = function(req, res) {
  838. var id = req.body.page_id;
  839. Page.findPageByIdAndGrantedUser(id, req.user)
  840. .then(function(pageData) {
  841. return pageData.like(req.user);
  842. }).then(function(data) {
  843. var result = {page: data};
  844. return res.json(ApiResponse.success(result));
  845. }).catch(function(err) {
  846. debug('Like failed', err);
  847. return res.json(ApiResponse.error({}));
  848. });
  849. };
  850. /**
  851. * @api {post} /likes.remove Unlike page
  852. * @apiName UnlikePage
  853. * @apiGroup Page
  854. *
  855. * @apiParam {String} page_id Page Id.
  856. */
  857. api.unlike = function(req, res) {
  858. var id = req.body.page_id;
  859. Page.findPageByIdAndGrantedUser(id, req.user)
  860. .then(function(pageData) {
  861. return pageData.unlike(req.user);
  862. }).then(function(data) {
  863. var result = {page: data};
  864. return res.json(ApiResponse.success(result));
  865. }).catch(function(err) {
  866. debug('Unlike failed', err);
  867. return res.json(ApiResponse.error({}));
  868. });
  869. };
  870. /**
  871. * @api {get} /pages.updatePost
  872. * @apiName Get UpdatePost setting list
  873. * @apiGroup Page
  874. *
  875. * @apiParam {String} path
  876. */
  877. api.getUpdatePost = function(req, res) {
  878. var path = req.query.path;
  879. var UpdatePost = crowi.model('UpdatePost');
  880. if (!path) {
  881. return res.json(ApiResponse.error({}));
  882. }
  883. UpdatePost.findSettingsByPath(path)
  884. .then(function(data) {
  885. data = data.map(function(e) {
  886. return e.channel;
  887. });
  888. debug('Found updatePost data', data);
  889. var result = {updatePost: data};
  890. return res.json(ApiResponse.success(result));
  891. }).catch(function(err) {
  892. debug('Error occured while get setting', err);
  893. return res.json(ApiResponse.error({}));
  894. });
  895. };
  896. /**
  897. * @api {post} /pages.remove Remove page
  898. * @apiName RemovePage
  899. * @apiGroup Page
  900. *
  901. * @apiParam {String} page_id Page Id.
  902. * @apiParam {String} revision_id
  903. */
  904. api.remove = function(req, res) {
  905. var pageId = req.body.page_id;
  906. var previousRevision = req.body.revision_id || null;
  907. // get completely flag
  908. const isCompletely = (req.body.completely !== undefined);
  909. // get recursively flag
  910. const isRecursively = (req.body.recursively !== undefined);
  911. Page.findPageByIdAndGrantedUser(pageId, req.user)
  912. .then(function(pageData) {
  913. debug('Delete page', pageData._id, pageData.path);
  914. if (isCompletely) {
  915. if (isRecursively) {
  916. return Page.completelyDeletePageRecursively(pageData, req.user);
  917. }
  918. else {
  919. return Page.completelyDeletePage(pageData, req.user);
  920. }
  921. }
  922. // else
  923. if (!pageData.isUpdatable(previousRevision)) {
  924. throw new Error('Someone could update this page, so couldn\'t delete.');
  925. }
  926. if (isRecursively) {
  927. return Page.deletePageRecursively(pageData, req.user);
  928. }
  929. else {
  930. return Page.deletePage(pageData, req.user);
  931. }
  932. }).then(function(data) {
  933. debug('Page deleted', data.path);
  934. var result = {};
  935. result.page = data;
  936. return res.json(ApiResponse.success(result));
  937. }).catch(function(err) {
  938. debug('Error occured while get setting', err, err.stack);
  939. return res.json(ApiResponse.error('Failed to delete page.'));
  940. });
  941. };
  942. /**
  943. * @api {post} /pages.revertRemove Revert removed page
  944. * @apiName RevertRemovePage
  945. * @apiGroup Page
  946. *
  947. * @apiParam {String} page_id Page Id.
  948. */
  949. api.revertRemove = function(req, res) {
  950. var pageId = req.body.page_id;
  951. // get recursively flag
  952. const isRecursively = (req.body.recursively !== undefined);
  953. Page.findPageByIdAndGrantedUser(pageId, req.user)
  954. .then(function(pageData) {
  955. if (isRecursively) {
  956. return Page.revertDeletedPageRecursively(pageData, req.user);
  957. }
  958. else {
  959. return Page.revertDeletedPage(pageData, req.user);
  960. }
  961. }).then(function(data) {
  962. debug('Complete to revert deleted page', data.path);
  963. var result = {};
  964. result.page = data;
  965. return res.json(ApiResponse.success(result));
  966. }).catch(function(err) {
  967. debug('Error occured while get setting', err, err.stack);
  968. return res.json(ApiResponse.error('Failed to revert deleted page.'));
  969. });
  970. };
  971. /**
  972. * @api {post} /pages.rename Rename page
  973. * @apiName RenamePage
  974. * @apiGroup Page
  975. *
  976. * @apiParam {String} page_id Page Id.
  977. * @apiParam {String} path
  978. * @apiParam {String} revision_id
  979. * @apiParam {String} new_path
  980. * @apiParam {Bool} create_redirect
  981. */
  982. api.rename = function(req, res) {
  983. var pageId = req.body.page_id;
  984. var previousRevision = req.body.revision_id || null;
  985. var newPagePath = Page.normalizePath(req.body.new_path);
  986. var options = {
  987. createRedirectPage: req.body.create_redirect || 0,
  988. moveUnderTrees: req.body.move_trees || 0,
  989. };
  990. var isRecursiveMove = req.body.move_recursively || 0;
  991. var page = {};
  992. if (!Page.isCreatableName(newPagePath)) {
  993. return res.json(ApiResponse.error(`このページ名は作成できません (${newPagePath})`));
  994. }
  995. Page.findPageByPath(newPagePath)
  996. .then(function(page) {
  997. if (page != null) {
  998. // if page found, cannot cannot rename to that path
  999. return res.json(ApiResponse.error(`このページ名は作成できません (${newPagePath})。ページが存在します。`));
  1000. }
  1001. Page.findPageById(pageId)
  1002. .then(function(pageData) {
  1003. page = pageData;
  1004. if (!pageData.isUpdatable(previousRevision)) {
  1005. throw new Error('Someone could update this page, so couldn\'t delete.');
  1006. }
  1007. if (isRecursiveMove) {
  1008. return Page.renameRecursively(pageData, newPagePath, req.user, options);
  1009. }
  1010. else {
  1011. return Page.rename(pageData, newPagePath, req.user, options);
  1012. }
  1013. })
  1014. .then(function() {
  1015. var result = {};
  1016. result.page = page;
  1017. return res.json(ApiResponse.success(result));
  1018. })
  1019. .catch(function(err) {
  1020. return res.json(ApiResponse.error('Failed to update page.'));
  1021. });
  1022. });
  1023. };
  1024. /**
  1025. * @api {post} /pages.duplicate Duplicate page
  1026. * @apiName DuplicatePage
  1027. * @apiGroup Page
  1028. *
  1029. * @apiParam {String} page_id Page Id.
  1030. * @apiParam {String} new_path
  1031. */
  1032. api.duplicate = function(req, res) {
  1033. var pageId = req.body.page_id;
  1034. var newPagePath = Page.normalizePath(req.body.new_path);
  1035. Page.findPageById(pageId)
  1036. .then(function(pageData) {
  1037. req.body.path = newPagePath;
  1038. req.body.body = pageData.revision.body;
  1039. req.body.grant = pageData.grant;
  1040. return api.create(req, res);
  1041. });
  1042. };
  1043. /**
  1044. * @api {post} /pages.unlink Remove the redirecting page
  1045. * @apiName UnlinkPage
  1046. * @apiGroup Page
  1047. *
  1048. * @apiParam {String} page_id Page Id.
  1049. * @apiParam {String} revision_id
  1050. */
  1051. api.unlink = function(req, res) {
  1052. var pageId = req.body.page_id;
  1053. Page.findPageByIdAndGrantedUser(pageId, req.user)
  1054. .then(function(pageData) {
  1055. debug('Unlink page', pageData._id, pageData.path);
  1056. return Page.removeRedirectOriginPageByPath(pageData.path)
  1057. .then(() => pageData);
  1058. }).then(function(data) {
  1059. debug('Redirect Page deleted', data.path);
  1060. var result = {};
  1061. result.page = data;
  1062. return res.json(ApiResponse.success(result));
  1063. }).catch(function(err) {
  1064. debug('Error occured while get setting', err, err.stack);
  1065. return res.json(ApiResponse.error('Failed to delete redirect page.'));
  1066. });
  1067. };
  1068. return actions;
  1069. };