page.js 35 KB

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