page.js 35 KB

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