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