page.js 35 KB

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