page.js 31 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070
  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. , Bookmark = crowi.model('Bookmark')
  11. , UpdatePost = crowi.model('UpdatePost')
  12. , ApiResponse = require('../util/apiResponse')
  13. , interceptorManager = crowi.getInterceptorManager()
  14. , swig = require('swig-templates')
  15. , getToday = require('../util/getToday')
  16. , globalNotificationService = crowi.getGlobalNotificationService()
  17. , actions = {};
  18. const PORTAL_STATUS_NOT_EXISTS = 0;
  19. const PORTAL_STATUS_EXISTS = 1;
  20. const PORTAL_STATUS_FORBIDDEN = 2;
  21. // register page events
  22. const pageEvent = crowi.event('page');
  23. pageEvent.on('create', function(page, user, socketClientId) {
  24. page = serializeToObj(page);
  25. crowi.getIo().sockets.emit('page:create', {page, user, socketClientId});
  26. });
  27. pageEvent.on('update', function(page, user, socketClientId) {
  28. page = serializeToObj(page);
  29. crowi.getIo().sockets.emit('page:update', {page, user, socketClientId});
  30. });
  31. pageEvent.on('delete', function(page, user, socketClientId) {
  32. page = serializeToObj(page);
  33. crowi.getIo().sockets.emit('page:delete', {page, user, socketClientId});
  34. });
  35. function serializeToObj(page) {
  36. const returnObj = page.toObject();
  37. if (page.revisionHackmdSynced != null && page.revisionHackmdSynced._id != null) {
  38. returnObj.revisionHackmdSynced = page.revisionHackmdSynced._id;
  39. }
  40. return returnObj;
  41. }
  42. function getPathFromRequest(req) {
  43. const path = '/' + (req.params[0] || '');
  44. return path.replace(/\.md$/, '');
  45. }
  46. function isUserPage(path) {
  47. if (path.match(/^\/user\/[^/]+\/?$/)) {
  48. return true;
  49. }
  50. return false;
  51. }
  52. function generatePager(offset, limit, totalCount) {
  53. let next = null,
  54. prev = null;
  55. if (offset > 0) {
  56. prev = offset - limit;
  57. if (prev < 0) {
  58. prev = 0;
  59. }
  60. }
  61. if (totalCount < limit) {
  62. next = null;
  63. }
  64. else {
  65. next = offset + limit;
  66. }
  67. return {
  68. prev: prev,
  69. next: next,
  70. offset: offset,
  71. };
  72. }
  73. // user notification
  74. // TODO create '/service/user-notification' module
  75. async function notifyToSlackByUser(page, user, slackChannels, updateOrCreate, previousRevision) {
  76. await page.updateSlackChannel(slackChannels)
  77. .catch(err => {
  78. logger.error('Error occured in updating slack channels: ', err);
  79. });
  80. if (crowi.slack) {
  81. const promises = slackChannels.split(',').map(function(chan) {
  82. return crowi.slack.postPage(page, user, chan, updateOrCreate, previousRevision);
  83. });
  84. Promise.all(promises)
  85. .catch(err => {
  86. logger.error('Error occured in sending slack notification: ', err);
  87. });
  88. }
  89. }
  90. function addRendarVarsForPage(renderVars, page) {
  91. renderVars.page = page;
  92. renderVars.path = page.path;
  93. renderVars.revision = page.revision;
  94. renderVars.author = page.revision.author;
  95. renderVars.pageIdOnHackmd = page.pageIdOnHackmd;
  96. renderVars.revisionHackmdSynced = page.revisionHackmdSynced;
  97. renderVars.hasDraftOnHackmd = page.hasDraftOnHackmd;
  98. }
  99. async function addRenderVarsForUserPage(renderVars, page, requestUser) {
  100. const userData = await User.findUserByUsername(User.getUsernameByPath(page.path));
  101. if (userData != null) {
  102. renderVars.pageUser = userData;
  103. renderVars.bookmarkList = await Bookmark.findByUser(userData, {limit: 10, populatePage: true, requestUser: requestUser});
  104. renderVars.createdList = await Page.findListByCreator(userData, {limit: 10}, requestUser);
  105. }
  106. }
  107. async function addRenderVarsForSlack(renderVars, page) {
  108. renderVars.slack = await getSlackChannels(page);
  109. }
  110. async function addRenderVarsForDescendants(renderVars, path, requestUser, offset, limit, isRegExpEscapedFromPath) {
  111. const SEENER_THRESHOLD = 10;
  112. const queryOptions = {
  113. offset: offset,
  114. limit: limit + 1,
  115. includeTrashed: path.startsWith('/trash/'),
  116. isRegExpEscapedFromPath,
  117. };
  118. const result = await Page.findListWithDescendants(path, requestUser, queryOptions);
  119. if (result.pages.length > limit) {
  120. result.pages.pop();
  121. }
  122. renderVars.viewConfig = {
  123. seener_threshold: SEENER_THRESHOLD,
  124. };
  125. renderVars.pager = generatePager(result.offset, result.limit, result.totalCount);
  126. renderVars.pages = pagePathUtils.encodePagesPath(result.pages);
  127. }
  128. function replacePlaceholdersOfTemplate(template, req) {
  129. const definitions = {
  130. pagepath: getPathFromRequest(req),
  131. username: req.user.name,
  132. today: getToday(),
  133. };
  134. const compiledTemplate = swig.compile(template);
  135. return compiledTemplate(definitions);
  136. }
  137. async function showPageForPresentation(req, res, next) {
  138. let path = getPathFromRequest(req);
  139. const revisionId = req.query.revision;
  140. let page = await Page.findByPathAndViewer(path, req.user);
  141. if (page == null) {
  142. next();
  143. }
  144. const renderVars = {};
  145. // populate
  146. page = await page.populateDataToMakePresentation(revisionId);
  147. addRendarVarsForPage(renderVars, page);
  148. return res.render('page_presentation', renderVars);
  149. }
  150. async function showPageListForCrowiBehavior(req, res, next) {
  151. const path = Page.addSlashOfEnd(getPathFromRequest(req));
  152. const revisionId = req.query.revision;
  153. // check whether this page has portal page
  154. const portalPageStatus = await getPortalPageState(path, req.user);
  155. const renderVars = { path };
  156. if (portalPageStatus === PORTAL_STATUS_FORBIDDEN) {
  157. // inject to req
  158. req.isForbidden = true;
  159. return next();
  160. }
  161. else if (portalPageStatus === PORTAL_STATUS_EXISTS) {
  162. let portalPage = await Page.findByPathAndViewer(path, req.user);
  163. portalPage.initLatestRevisionField(revisionId);
  164. // populate
  165. portalPage = await portalPage.populateDataToShowRevision();
  166. addRendarVarsForPage(renderVars, portalPage);
  167. await addRenderVarsForSlack(renderVars, portalPage);
  168. }
  169. const limit = 50;
  170. const offset = parseInt(req.query.offset) || 0;
  171. await addRenderVarsForDescendants(renderVars, path, req.user, offset, limit);
  172. await interceptorManager.process('beforeRenderPage', req, res, renderVars);
  173. return res.render('customlayout-selector/page_list', renderVars);
  174. }
  175. async function showPageForGrowiBehavior(req, res, next) {
  176. const path = getPathFromRequest(req);
  177. const revisionId = req.query.revision;
  178. let page = await Page.findByPathAndViewer(path, req.user);
  179. if (page == null) {
  180. // check the page is forbidden or just does not exist.
  181. req.isForbidden = await Page.count({path}) > 0;
  182. return next();
  183. }
  184. else if (page.redirectTo) {
  185. debug(`Redirect to '${page.redirectTo}'`);
  186. return res.redirect(encodeURI(page.redirectTo + '?redirectFrom=' + pagePathUtils.encodePagePath(page.path)));
  187. }
  188. logger.debug('Page is found when processing pageShowForGrowiBehavior', page._id, page.path);
  189. const limit = 50;
  190. const offset = parseInt(req.query.offset) || 0;
  191. const renderVars = {};
  192. let view = 'customlayout-selector/page';
  193. page.initLatestRevisionField(revisionId);
  194. // populate
  195. page = await page.populateDataToShowRevision();
  196. addRendarVarsForPage(renderVars, page);
  197. await addRenderVarsForSlack(renderVars, page);
  198. await addRenderVarsForDescendants(renderVars, path, req.user, offset, limit);
  199. if (isUserPage(page.path)) {
  200. // change template
  201. view = 'customlayout-selector/user_page';
  202. await addRenderVarsForUserPage(renderVars, page, req.user);
  203. }
  204. await interceptorManager.process('beforeRenderPage', req, res, renderVars);
  205. return res.render(view, renderVars);
  206. }
  207. const getSlackChannels = async page => {
  208. if (page.extended.slack) {
  209. return page.extended.slack;
  210. }
  211. else {
  212. const data = await UpdatePost.findSettingsByPath(page.path);
  213. const channels = data.map(e => e.channel).join(', ');
  214. return channels;
  215. }
  216. };
  217. /**
  218. *
  219. * @param {string} path
  220. * @param {User} user
  221. * @returns {number} PORTAL_STATUS_NOT_EXISTS(0) or PORTAL_STATUS_EXISTS(1) or PORTAL_STATUS_FORBIDDEN(2)
  222. */
  223. async function getPortalPageState(path, user) {
  224. const portalPath = Page.addSlashOfEnd(path);
  225. let page = await Page.findByPathAndViewer(portalPath, user);
  226. if (page == null) {
  227. // check the page is forbidden or just does not exist.
  228. const isForbidden = await Page.count({ path: portalPath }) > 0;
  229. return isForbidden ? PORTAL_STATUS_FORBIDDEN : PORTAL_STATUS_NOT_EXISTS;
  230. }
  231. return PORTAL_STATUS_EXISTS;
  232. }
  233. actions.showTopPage = function(req, res) {
  234. return showPageListForCrowiBehavior(req, res);
  235. };
  236. /**
  237. * switch action by behaviorType
  238. */
  239. actions.showPageWithEndOfSlash = function(req, res, next) {
  240. const behaviorType = Config.behaviorType(config);
  241. if (!behaviorType || 'crowi' === behaviorType) {
  242. return showPageListForCrowiBehavior(req, res, next);
  243. }
  244. else {
  245. let path = getPathFromRequest(req); // end of slash should be omitted
  246. // redirect and showPage action will be triggered
  247. return res.redirect(path);
  248. }
  249. };
  250. /**
  251. * switch action
  252. * - presentation mode
  253. * - by behaviorType
  254. */
  255. actions.showPage = async function(req, res, next) {
  256. // presentation mode
  257. if (req.query.presentation) {
  258. return showPageForPresentation(req, res, next);
  259. }
  260. const behaviorType = Config.behaviorType(config);
  261. // check whether this page has portal page
  262. if (!behaviorType || 'crowi' === behaviorType) {
  263. const portalPagePath = Page.addSlashOfEnd(getPathFromRequest(req));
  264. let hasPortalPage = await Page.count({ path: portalPagePath }) > 0;
  265. if (hasPortalPage) {
  266. logger.debug('The portal page is found', portalPagePath);
  267. return res.redirect(portalPagePath);
  268. }
  269. }
  270. // delegate to showPageForGrowiBehavior
  271. return showPageForGrowiBehavior(req, res, next);
  272. };
  273. /**
  274. * switch action by behaviorType
  275. */
  276. actions.trashPageListShowWrapper = function(req, res) {
  277. const behaviorType = Config.behaviorType(config);
  278. if (!behaviorType || 'crowi' === behaviorType) {
  279. // Crowi behavior for '/trash/*'
  280. return actions.deletedPageListShow(req, res);
  281. }
  282. else {
  283. // redirect to '/trash'
  284. return res.redirect('/trash');
  285. }
  286. };
  287. /**
  288. * switch action by behaviorType
  289. */
  290. actions.trashPageShowWrapper = function(req, res) {
  291. const behaviorType = Config.behaviorType(config);
  292. if (!behaviorType || 'crowi' === behaviorType) {
  293. // redirect to '/trash/'
  294. return res.redirect('/trash/');
  295. }
  296. else {
  297. // Crowi behavior for '/trash/*'
  298. return actions.deletedPageListShow(req, res);
  299. }
  300. };
  301. /**
  302. * switch action by behaviorType
  303. */
  304. actions.deletedPageListShowWrapper = function(req, res) {
  305. const behaviorType = Config.behaviorType(config);
  306. if (!behaviorType || 'crowi' === behaviorType) {
  307. // Crowi behavior for '/trash/*'
  308. return actions.deletedPageListShow(req, res);
  309. }
  310. else {
  311. const path = '/trash' + getPathFromRequest(req);
  312. return res.redirect(path);
  313. }
  314. };
  315. actions.notFound = async function(req, res) {
  316. const path = getPathFromRequest(req);
  317. let view;
  318. const renderVars = { path };
  319. if (req.isForbidden) {
  320. view = 'customlayout-selector/forbidden';
  321. }
  322. else {
  323. view = 'customlayout-selector/not_found';
  324. // retrieve templates
  325. let template = await Page.findTemplate(path);
  326. if (template != null) {
  327. template = replacePlaceholdersOfTemplate(template, req);
  328. renderVars.template = template;
  329. }
  330. }
  331. const limit = 50;
  332. const offset = parseInt(req.query.offset) || 0;
  333. await addRenderVarsForDescendants(renderVars, path, req.user, offset, limit);
  334. return res.render(view, renderVars);
  335. };
  336. actions.deletedPageListShow = async function(req, res) {
  337. const path = '/trash' + getPathFromRequest(req);
  338. const limit = 50;
  339. const offset = parseInt(req.query.offset) || 0;
  340. const queryOptions = {
  341. offset: offset,
  342. limit: limit + 1,
  343. includeTrashed: true,
  344. };
  345. const renderVars = {
  346. page: null,
  347. path: path,
  348. pages: [],
  349. };
  350. const result = await Page.findListWithDescendants(path, req.user, queryOptions);
  351. if (result.pages.length > limit) {
  352. result.pages.pop();
  353. }
  354. renderVars.pager = generatePager(result.offset, result.limit, result.totalCount);
  355. renderVars.pages = pagePathUtils.encodePagesPath(result.pages);
  356. res.render('customlayout-selector/page_list', renderVars);
  357. };
  358. /**
  359. * redirector
  360. */
  361. actions.redirector = async function(req, res) {
  362. const id = req.params.id;
  363. const page = await Page.findByIdAndViewer(id, req.user);
  364. if (page != null) {
  365. return res.redirect(pagePathUtils.encodePagePath(page.path));
  366. }
  367. return res.redirect('/');
  368. };
  369. const api = actions.api = {};
  370. /**
  371. * @api {get} /pages.list List pages by user
  372. * @apiName ListPage
  373. * @apiGroup Page
  374. *
  375. * @apiParam {String} path
  376. * @apiParam {String} user
  377. */
  378. api.list = async function(req, res) {
  379. const username = req.query.user || null;
  380. const path = req.query.path || null;
  381. const limit = + req.query.limit || 50;
  382. const offset = parseInt(req.query.offset) || 0;
  383. const queryOptions = { offset, limit: limit + 1 };
  384. // Accepts only one of these
  385. if (username === null && path === null) {
  386. return res.json(ApiResponse.error('Parameter user or path is required.'));
  387. }
  388. if (username !== null && path !== null) {
  389. return res.json(ApiResponse.error('Parameter user or path is required.'));
  390. }
  391. try {
  392. let result = null;
  393. if (path == null) {
  394. const user = await User.findUserByUsername(username);
  395. if (user === null) {
  396. throw new Error('The user not found.');
  397. }
  398. result = await Page.findListByCreator(user, req.user, queryOptions);
  399. }
  400. else {
  401. result = await Page.findListByStartWith(path, req.user, queryOptions);
  402. }
  403. if (result.pages.length > limit) {
  404. result.pages.pop();
  405. }
  406. result.pages = pagePathUtils.encodePagesPath(result.pages);
  407. return res.json(ApiResponse.success(result));
  408. }
  409. catch (err) {
  410. return res.json(ApiResponse.error(err));
  411. }
  412. };
  413. /**
  414. * @api {post} /pages.create Create new page
  415. * @apiName CreatePage
  416. * @apiGroup Page
  417. *
  418. * @apiParam {String} body
  419. * @apiParam {String} path
  420. * @apiParam {String} grant
  421. */
  422. api.create = async function(req, res) {
  423. const body = req.body.body || null;
  424. const pagePath = req.body.path || null;
  425. const grant = req.body.grant || null;
  426. const grantUserGroupId = req.body.grantUserGroupId || null;
  427. const isSlackEnabled = !!req.body.isSlackEnabled; // cast to boolean
  428. const slackChannels = req.body.slackChannels || null;
  429. const socketClientId = req.body.socketClientId || undefined;
  430. if (body === null || pagePath === null) {
  431. return res.json(ApiResponse.error('Parameters body and path are required.'));
  432. }
  433. // check page existence
  434. const isExist = await Page.count({path: pagePath}) > 0;
  435. if (isExist) {
  436. return res.json(ApiResponse.error('Page exists', 'already_exists'));
  437. }
  438. const options = {grant, grantUserGroupId, socketClientId};
  439. const createdPage = await Page.create(pagePath, body, req.user, options);
  440. const result = { page: serializeToObj(createdPage) };
  441. result.page.lastUpdateUser = User.filterToPublicFields(createdPage.lastUpdateUser);
  442. result.page.creator = User.filterToPublicFields(createdPage.creator);
  443. res.json(ApiResponse.success(result));
  444. // global notification
  445. try {
  446. await globalNotificationService.notifyPageCreate(createdPage);
  447. }
  448. catch (err) {
  449. logger.error(err);
  450. }
  451. // user notification
  452. if (isSlackEnabled && slackChannels != null) {
  453. await notifyToSlackByUser(createdPage, req.user, slackChannels, 'create', false);
  454. }
  455. };
  456. /**
  457. * @api {post} /pages.update Update page
  458. * @apiName UpdatePage
  459. * @apiGroup Page
  460. *
  461. * @apiParam {String} body
  462. * @apiParam {String} page_id
  463. * @apiParam {String} revision_id
  464. * @apiParam {String} grant
  465. *
  466. * In the case of the page exists:
  467. * - If revision_id is specified => update the page,
  468. * - If revision_id is not specified => force update by the new contents.
  469. */
  470. api.update = async function(req, res) {
  471. const pageBody = req.body.body || null;
  472. const pageId = req.body.page_id || null;
  473. const revisionId = req.body.revision_id || null;
  474. const grant = req.body.grant || null;
  475. const grantUserGroupId = req.body.grantUserGroupId || null;
  476. const isSlackEnabled = !!req.body.isSlackEnabled; // cast to boolean
  477. const slackChannels = req.body.slackChannels || null;
  478. const isSyncRevisionToHackmd = !!req.body.isSyncRevisionToHackmd; // cast to boolean
  479. const socketClientId = req.body.socketClientId || undefined;
  480. if (pageId === null || pageBody === null) {
  481. return res.json(ApiResponse.error('page_id and body are required.'));
  482. }
  483. // check page existence
  484. const isExist = await Page.count({_id: pageId}) > 0;
  485. if (!isExist) {
  486. return res.json(ApiResponse.error(`Page('${pageId}' is not found or forbidden`, 'notfound_or_forbidden'));
  487. }
  488. // check revision
  489. let page = await Page.findByIdAndViewer(pageId, req.user);
  490. if (page != null && revisionId != null && !page.isUpdatable(revisionId)) {
  491. return res.json(ApiResponse.error('Posted param "revisionId" is outdated.', 'outdated'));
  492. }
  493. const options = {isSyncRevisionToHackmd, socketClientId};
  494. if (grant != null) {
  495. options.grant = grant;
  496. }
  497. if (grantUserGroupId != null) {
  498. options.grantUserGroupId = grantUserGroupId;
  499. }
  500. try {
  501. page = await Page.updatePage(page, pageBody, req.user, options);
  502. }
  503. catch (err) {
  504. logger.error('error on _api/pages.update', err);
  505. return res.json(ApiResponse.error(err));
  506. }
  507. const result = { page: serializeToObj(page) };
  508. result.page.lastUpdateUser = User.filterToPublicFields(page.lastUpdateUser);
  509. res.json(ApiResponse.success(result));
  510. // global notification
  511. try {
  512. await globalNotificationService.notifyPageEdit(page);
  513. }
  514. catch (err) {
  515. logger.error(err);
  516. }
  517. // user notification
  518. if (isSlackEnabled && slackChannels != null) {
  519. const Revision = crowi.model('Revision');
  520. const previousRevision = await Revision.findById(page.revision);
  521. await notifyToSlackByUser(page, req.user, slackChannels, 'update', previousRevision);
  522. }
  523. };
  524. /**
  525. * @api {get} /pages.get Get page data
  526. * @apiName GetPage
  527. * @apiGroup Page
  528. *
  529. * @apiParam {String} page_id
  530. * @apiParam {String} path
  531. * @apiParam {String} revision_id
  532. */
  533. api.get = async function(req, res) {
  534. const pagePath = req.query.path || null;
  535. const pageId = req.query.page_id || null; // TODO: handling
  536. if (!pageId && !pagePath) {
  537. return res.json(ApiResponse.error(new Error('Parameter path or page_id is required.')));
  538. }
  539. let page;
  540. try {
  541. if (pageId) { // prioritized
  542. page = await Page.findByIdAndViewer(pageId, req.user);
  543. }
  544. else if (pagePath) {
  545. page = await Page.findByPathAndViewer(pagePath, req.user);
  546. }
  547. if (page == null) {
  548. throw new Error(`Page '${pageId || pagePath}' is not found or forbidden`, 'notfound_or_forbidden');
  549. }
  550. page.initLatestRevisionField();
  551. // populate
  552. page = await page.populateDataToShowRevision();
  553. }
  554. catch (err) {
  555. return res.json(ApiResponse.error(err));
  556. }
  557. const result = {};
  558. result.page = page; // TODO consider to use serializeToObj method -- 2018.08.06 Yuki Takei
  559. return res.json(ApiResponse.success(result));
  560. };
  561. /**
  562. * @api {post} /pages.seen Mark as seen user
  563. * @apiName SeenPage
  564. * @apiGroup Page
  565. *
  566. * @apiParam {String} page_id Page Id.
  567. */
  568. api.seen = async function(req, res) {
  569. const pageId = req.body.page_id;
  570. if (!pageId) {
  571. return res.json(ApiResponse.error('page_id required'));
  572. }
  573. else if (!req.user) {
  574. return res.json(ApiResponse.error('user required'));
  575. }
  576. let page;
  577. try {
  578. page = await Page.findByIdAndViewer(pageId, req.user);
  579. if (req.user != null) {
  580. page = await page.seen(req.user);
  581. }
  582. }
  583. catch (err) {
  584. debug('Seen user update error', err);
  585. return res.json(ApiResponse.error(err));
  586. }
  587. const result = {};
  588. result.seenUser = page.seenUsers;
  589. return res.json(ApiResponse.success(result));
  590. };
  591. /**
  592. * @api {post} /likes.add Like page
  593. * @apiName LikePage
  594. * @apiGroup Page
  595. *
  596. * @apiParam {String} page_id Page Id.
  597. */
  598. api.like = async function(req, res) {
  599. const pageId = req.body.page_id;
  600. if (!pageId) {
  601. return res.json(ApiResponse.error('page_id required'));
  602. }
  603. else if (!req.user) {
  604. return res.json(ApiResponse.error('user required'));
  605. }
  606. let page;
  607. try {
  608. page = await Page.findByIdAndViewer(pageId, req.user);
  609. if (page == null) {
  610. throw new Error(`Page '${pageId}' is not found or forbidden`);
  611. }
  612. page = await page.like(req.user);
  613. }
  614. catch (err) {
  615. debug('Seen user update error', err);
  616. return res.json(ApiResponse.error(err));
  617. }
  618. const result = { page };
  619. result.seenUser = page.seenUsers;
  620. res.json(ApiResponse.success(result));
  621. try {
  622. // global notification
  623. globalNotificationService.notifyPageLike(page, req.user);
  624. }
  625. catch (err) {
  626. logger.error('Like failed', err);
  627. }
  628. };
  629. /**
  630. * @api {post} /likes.remove Unlike page
  631. * @apiName UnlikePage
  632. * @apiGroup Page
  633. *
  634. * @apiParam {String} page_id Page Id.
  635. */
  636. api.unlike = async function(req, res) {
  637. const pageId = req.body.page_id;
  638. if (!pageId) {
  639. return res.json(ApiResponse.error('page_id required'));
  640. }
  641. else if (req.user == null) {
  642. return res.json(ApiResponse.error('user required'));
  643. }
  644. let page;
  645. try {
  646. page = await Page.findByIdAndViewer(pageId, req.user);
  647. if (page == null) {
  648. throw new Error(`Page '${pageId}' is not found or forbidden`);
  649. }
  650. page = await page.unlike(req.user);
  651. }
  652. catch (err) {
  653. debug('Seen user update error', err);
  654. return res.json(ApiResponse.error(err));
  655. }
  656. const result = { page };
  657. result.seenUser = page.seenUsers;
  658. return res.json(ApiResponse.success(result));
  659. };
  660. /**
  661. * @api {get} /pages.updatePost
  662. * @apiName Get UpdatePost setting list
  663. * @apiGroup Page
  664. *
  665. * @apiParam {String} path
  666. */
  667. api.getUpdatePost = function(req, res) {
  668. const path = req.query.path;
  669. const UpdatePost = crowi.model('UpdatePost');
  670. if (!path) {
  671. return res.json(ApiResponse.error({}));
  672. }
  673. UpdatePost.findSettingsByPath(path)
  674. .then(function(data) {
  675. data = data.map(function(e) {
  676. return e.channel;
  677. });
  678. debug('Found updatePost data', data);
  679. const result = {updatePost: data};
  680. return res.json(ApiResponse.success(result));
  681. }).catch(function(err) {
  682. debug('Error occured while get setting', err);
  683. return res.json(ApiResponse.error({}));
  684. });
  685. };
  686. /**
  687. * @api {post} /pages.remove Remove page
  688. * @apiName RemovePage
  689. * @apiGroup Page
  690. *
  691. * @apiParam {String} page_id Page Id.
  692. * @apiParam {String} revision_id
  693. */
  694. api.remove = async function(req, res) {
  695. const pageId = req.body.page_id;
  696. const previousRevision = req.body.revision_id || null;
  697. const socketClientId = req.body.socketClientId || undefined;
  698. // get completely flag
  699. const isCompletely = (req.body.completely != null);
  700. // get recursively flag
  701. const isRecursively = (req.body.recursively != null);
  702. const options = {socketClientId};
  703. let page = await Page.findByIdAndViewer(pageId, req.user);
  704. if (page == null) {
  705. return res.json(ApiResponse.error(`Page '${pageId}' is not found or forbidden`, 'notfound_or_forbidden'));
  706. }
  707. debug('Delete page', page._id, page.path);
  708. try {
  709. if (isCompletely) {
  710. if (isRecursively) {
  711. page = await Page.completelyDeletePageRecursively(page, req.user, options);
  712. }
  713. else {
  714. page = await Page.completelyDeletePage(page, req.user, options);
  715. }
  716. }
  717. else {
  718. if (!page.isUpdatable(previousRevision)) {
  719. throw new Error('Someone could update this page, so couldn\'t delete.', 'outdated');
  720. }
  721. if (isRecursively) {
  722. page = await Page.deletePageRecursively(page, req.user, options);
  723. }
  724. else {
  725. page = await Page.deletePage(page, req.user, options);
  726. }
  727. }
  728. }
  729. catch (err) {
  730. logger.error('Error occured while get setting', err);
  731. return res.json(ApiResponse.error('Failed to delete page.'));
  732. }
  733. debug('Page deleted', page.path);
  734. const result = {};
  735. result.page = page; // TODO consider to use serializeToObj method -- 2018.08.06 Yuki Takei
  736. res.json(ApiResponse.success(result));
  737. // global notification
  738. return globalNotificationService.notifyPageDelete(page);
  739. };
  740. /**
  741. * @api {post} /pages.revertRemove Revert removed page
  742. * @apiName RevertRemovePage
  743. * @apiGroup Page
  744. *
  745. * @apiParam {String} page_id Page Id.
  746. */
  747. api.revertRemove = async function(req, res, options) {
  748. const pageId = req.body.page_id;
  749. const socketClientId = req.body.socketClientId || undefined;
  750. // get recursively flag
  751. const isRecursively = (req.body.recursively !== undefined);
  752. let page;
  753. try {
  754. page = await Page.findByIdAndViewer(pageId, req.user);
  755. if (page == null) {
  756. throw new Error(`Page '${pageId}' is not found or forbidden`, 'notfound_or_forbidden');
  757. }
  758. if (isRecursively) {
  759. page = await Page.revertDeletedPageRecursively(page, req.user, {socketClientId});
  760. }
  761. else {
  762. page = await Page.revertDeletedPage(page, req.user, {socketClientId});
  763. }
  764. }
  765. catch (err) {
  766. logger.error('Error occured while get setting', err);
  767. return res.json(ApiResponse.error('Failed to revert deleted page.'));
  768. }
  769. const result = {};
  770. result.page = page; // TODO consider to use serializeToObj method -- 2018.08.06 Yuki Takei
  771. return res.json(ApiResponse.success(result));
  772. };
  773. /**
  774. * @api {post} /pages.rename Rename page
  775. * @apiName RenamePage
  776. * @apiGroup Page
  777. *
  778. * @apiParam {String} page_id Page Id.
  779. * @apiParam {String} path
  780. * @apiParam {String} revision_id
  781. * @apiParam {String} new_path
  782. * @apiParam {Bool} create_redirect
  783. */
  784. api.rename = async function(req, res) {
  785. const pageId = req.body.page_id;
  786. const previousRevision = req.body.revision_id || null;
  787. const newPagePath = Page.normalizePath(req.body.new_path);
  788. const options = {
  789. createRedirectPage: req.body.create_redirect || 0,
  790. moveUnderTrees: req.body.move_trees || 0,
  791. socketClientId: +req.body.socketClientId || undefined,
  792. };
  793. const isRecursiveMove = req.body.move_recursively || 0;
  794. if (!Page.isCreatableName(newPagePath)) {
  795. return res.json(ApiResponse.error(`Could not use the path '${newPagePath})'`, 'invalid_path'));
  796. }
  797. const isExist = await Page.count({ path: newPagePath }) > 0;
  798. if (isExist) {
  799. // if page found, cannot cannot rename to that path
  800. return res.json(ApiResponse.error(`'new_path=${newPagePath}' already exists`, 'already_exists'));
  801. }
  802. let page;
  803. try {
  804. page = await Page.findByIdAndViewer(pageId, req.user);
  805. if (page == null) {
  806. throw new Error(`Page '${pageId}' is not found or forbidden`, 'notfound_or_forbidden');
  807. }
  808. if (!page.isUpdatable(previousRevision)) {
  809. throw new Error('Someone could update this page, so couldn\'t delete.', 'outdated');
  810. }
  811. if (isRecursiveMove) {
  812. page = await Page.renameRecursively(page, newPagePath, req.user, options);
  813. }
  814. else {
  815. page = await Page.rename(page, newPagePath, req.user, options);
  816. }
  817. }
  818. catch (err) {
  819. logger.error(err);
  820. return res.json(ApiResponse.error('Failed to update page.'));
  821. }
  822. const result = {};
  823. result.page = page; // TODO consider to use serializeToObj method -- 2018.08.06 Yuki Takei
  824. res.json(ApiResponse.success(result));
  825. // global notification
  826. globalNotificationService.notifyPageMove(page, req.body.path, req.user);
  827. return page;
  828. };
  829. /**
  830. * @api {post} /pages.duplicate Duplicate page
  831. * @apiName DuplicatePage
  832. * @apiGroup Page
  833. *
  834. * @apiParam {String} page_id Page Id.
  835. * @apiParam {String} new_path
  836. */
  837. api.duplicate = async function(req, res) {
  838. const pageId = req.body.page_id;
  839. const newPagePath = Page.normalizePath(req.body.new_path);
  840. const page = await Page.findByIdAndViewer(pageId, req.user);
  841. if (page == null) {
  842. return res.json(ApiResponse.error(`Page '${pageId}' is not found or forbidden`, 'notfound_or_forbidden'));
  843. }
  844. await page.populateDataToShowRevision();
  845. req.body.path = newPagePath;
  846. req.body.body = page.revision.body;
  847. req.body.grant = page.grant;
  848. return api.create(req, res);
  849. };
  850. /**
  851. * @api {post} /pages.unlink Remove the redirecting page
  852. * @apiName UnlinkPage
  853. * @apiGroup Page
  854. *
  855. * @apiParam {String} page_id Page Id.
  856. * @apiParam {String} revision_id
  857. */
  858. api.unlink = async function(req, res) {
  859. const path = req.body.path;
  860. try {
  861. await Page.removeRedirectOriginPageByPath(path);
  862. logger.debug('Redirect Page deleted', path);
  863. }
  864. catch (err) {
  865. logger.error('Error occured while get setting', err);
  866. return res.json(ApiResponse.error('Failed to delete redirect page.'));
  867. }
  868. const result = { path };
  869. return res.json(ApiResponse.success(result));
  870. };
  871. api.recentCreated = async function(req, res) {
  872. const pageId = req.query.page_id;
  873. if (pageId == null) {
  874. return res.json(ApiResponse.error('param \'pageId\' must not be null'));
  875. }
  876. const page = await Page.findById(pageId);
  877. if (page == null) {
  878. return res.json(ApiResponse.error(`Page (id='${pageId}') does not exist`));
  879. }
  880. if (!isUserPage(page.path)) {
  881. return res.json(ApiResponse.error(`Page (id='${pageId}') is not a user home`));
  882. }
  883. const limit = + req.query.limit || 50;
  884. const offset = + req.query.offset || 0;
  885. const queryOptions = { offset: offset, limit: limit };
  886. try {
  887. let result = await Page.findListByCreator(page.creator, req.user, queryOptions);
  888. result.pages = pagePathUtils.encodePagesPath(result.pages);
  889. return res.json(ApiResponse.success(result));
  890. }
  891. catch (err) {
  892. return res.json(ApiResponse.error(err));
  893. }
  894. };
  895. return actions;
  896. };