page.js 40 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330
  1. const { isCreatablePage } = require('@commons/util/path-utils');
  2. const { serializePageSecurely } = require('../models/serializers/page-serializer');
  3. const { serializeRevisionSecurely } = require('../models/serializers/revision-serializer');
  4. const { serializeUserSecurely } = require('../models/serializers/user-serializer');
  5. /**
  6. * @swagger
  7. * tags:
  8. * name: Pages
  9. */
  10. /**
  11. * @swagger
  12. *
  13. * components:
  14. * schemas:
  15. * Page:
  16. * description: Page
  17. * type: object
  18. * properties:
  19. * _id:
  20. * type: string
  21. * description: page ID
  22. * example: 5e07345972560e001761fa63
  23. * __v:
  24. * type: number
  25. * description: DB record version
  26. * example: 0
  27. * commentCount:
  28. * type: number
  29. * description: count of comments
  30. * example: 3
  31. * createdAt:
  32. * type: string
  33. * description: date created at
  34. * example: 2010-01-01T00:00:00.000Z
  35. * creator:
  36. * $ref: '#/components/schemas/User'
  37. * extended:
  38. * type: object
  39. * description: extend data
  40. * example: {}
  41. * grant:
  42. * type: number
  43. * description: grant
  44. * example: 1
  45. * grantedUsers:
  46. * type: array
  47. * description: granted users
  48. * items:
  49. * type: string
  50. * description: user ID
  51. * example: ["5ae5fccfc5577b0004dbd8ab"]
  52. * lastUpdateUser:
  53. * $ref: '#/components/schemas/User'
  54. * liker:
  55. * type: array
  56. * description: granted users
  57. * items:
  58. * type: string
  59. * description: user ID
  60. * example: []
  61. * path:
  62. * type: string
  63. * description: page path
  64. * example: /
  65. * redirectTo:
  66. * type: string
  67. * description: redirect path
  68. * example: ""
  69. * revision:
  70. * $ref: '#/components/schemas/Revision'
  71. * status:
  72. * type: string
  73. * description: status
  74. * enum:
  75. * - 'wip'
  76. * - 'published'
  77. * - 'deleted'
  78. * - 'deprecated'
  79. * example: published
  80. * updatedAt:
  81. * type: string
  82. * description: date updated at
  83. * example: 2010-01-01T00:00:00.000Z
  84. *
  85. * UpdatePost:
  86. * description: UpdatePost
  87. * type: object
  88. * properties:
  89. * _id:
  90. * type: string
  91. * description: update post ID
  92. * example: 5e0734e472560e001761fa68
  93. * __v:
  94. * type: number
  95. * description: DB record version
  96. * example: 0
  97. * pathPattern:
  98. * type: string
  99. * description: path pattern
  100. * example: /test
  101. * patternPrefix:
  102. * type: string
  103. * description: patternPrefix prefix
  104. * example: /
  105. * patternPrefix2:
  106. * type: string
  107. * description: path
  108. * example: test
  109. * channel:
  110. * type: string
  111. * description: channel
  112. * example: general
  113. * provider:
  114. * type: string
  115. * description: provider
  116. * enum:
  117. * - slack
  118. * example: slack
  119. * creator:
  120. * $ref: '#/components/schemas/User'
  121. * createdAt:
  122. * type: string
  123. * description: date created at
  124. * example: 2010-01-01T00:00:00.000Z
  125. */
  126. /* eslint-disable no-use-before-define */
  127. module.exports = function(crowi, app) {
  128. const debug = require('debug')('growi:routes:page');
  129. const logger = require('@alias/logger')('growi:routes:page');
  130. const swig = require('swig-templates');
  131. const pathUtils = require('growi-commons').pathUtils;
  132. const Page = crowi.model('Page');
  133. const User = crowi.model('User');
  134. const PageTagRelation = crowi.model('PageTagRelation');
  135. const GlobalNotificationSetting = crowi.model('GlobalNotificationSetting');
  136. const ShareLink = crowi.model('ShareLink');
  137. const ApiResponse = require('../util/apiResponse');
  138. const getToday = require('../util/getToday');
  139. const { configManager, xssService } = crowi;
  140. const interceptorManager = crowi.getInterceptorManager();
  141. const globalNotificationService = crowi.getGlobalNotificationService();
  142. const userNotificationService = crowi.getUserNotificationService();
  143. const XssOption = require('../../lib/service/xss/xssOption');
  144. const Xss = require('../../lib/service/xss/index');
  145. const initializedConfig = {
  146. isEnabledXssPrevention: configManager.getConfig('markdown', 'markdown:xss:isEnabledPrevention'),
  147. tagWhiteList: xssService.getTagWhiteList(),
  148. attrWhiteList: xssService.getAttrWhiteList(),
  149. };
  150. const xssOption = new XssOption(initializedConfig);
  151. const xss = new Xss(xssOption);
  152. const actions = {};
  153. function getPathFromRequest(req) {
  154. return pathUtils.normalizePath(req.params[0] || '');
  155. }
  156. function isUserPage(path) {
  157. if (path.match(/^\/user\/[^/]+\/?$/)) {
  158. return true;
  159. }
  160. return false;
  161. }
  162. function generatePager(offset, limit, totalCount) {
  163. let prev = null;
  164. if (offset > 0) {
  165. prev = offset - limit;
  166. if (prev < 0) {
  167. prev = 0;
  168. }
  169. }
  170. let next = offset + limit;
  171. if (totalCount < next) {
  172. next = null;
  173. }
  174. return {
  175. prev,
  176. next,
  177. offset,
  178. };
  179. }
  180. function addRenderVarsForPage(renderVars, page) {
  181. renderVars.page = page;
  182. renderVars.revision = page.revision;
  183. renderVars.pageIdOnHackmd = page.pageIdOnHackmd;
  184. renderVars.revisionHackmdSynced = page.revisionHackmdSynced;
  185. renderVars.hasDraftOnHackmd = page.hasDraftOnHackmd;
  186. if (page.creator != null) {
  187. renderVars.page.creator = renderVars.page.creator.toObject();
  188. }
  189. if (page.revision.author != null) {
  190. renderVars.revision.author = renderVars.revision.author.toObject();
  191. }
  192. if (page.deleteUser != null) {
  193. renderVars.page.deleteUser = renderVars.page.deleteUser.toObject();
  194. }
  195. }
  196. function addRenderVarsForPresentation(renderVars, page) {
  197. // sanitize page.revision.body
  198. if (crowi.configManager.getConfig('markdown', 'markdown:xss:isEnabledPrevention')) {
  199. const preventXssRevision = xss.process(page.revision.body);
  200. page.revision.body = preventXssRevision;
  201. }
  202. renderVars.page = page;
  203. renderVars.revision = page.revision;
  204. }
  205. async function addRenderVarsForUserPage(renderVars, page) {
  206. const userData = await User.findUserByUsername(User.getUsernameByPath(page.path));
  207. if (userData != null) {
  208. renderVars.pageUser = serializeUserSecurely(userData);
  209. }
  210. }
  211. function addRenderVarsForScope(renderVars, page) {
  212. renderVars.grant = page.grant;
  213. renderVars.grantedGroupId = page.grantedGroup ? page.grantedGroup.id : null;
  214. renderVars.grantedGroupName = page.grantedGroup ? page.grantedGroup.name : null;
  215. }
  216. async function addRenderVarsForDescendants(renderVars, path, requestUser, offset, limit, isRegExpEscapedFromPath) {
  217. const SEENER_THRESHOLD = 10;
  218. const queryOptions = {
  219. offset,
  220. limit,
  221. includeTrashed: path.startsWith('/trash/'),
  222. isRegExpEscapedFromPath,
  223. };
  224. const result = await Page.findListWithDescendants(path, requestUser, queryOptions);
  225. if (result.pages.length > limit) {
  226. result.pages.pop();
  227. }
  228. renderVars.viewConfig = {
  229. seener_threshold: SEENER_THRESHOLD,
  230. };
  231. renderVars.pager = generatePager(result.offset, result.limit, result.totalCount);
  232. renderVars.pages = result.pages;
  233. }
  234. function replacePlaceholdersOfTemplate(template, req) {
  235. if (req.user == null) {
  236. return '';
  237. }
  238. const definitions = {
  239. pagepath: getPathFromRequest(req),
  240. username: req.user.name,
  241. today: getToday(),
  242. };
  243. const compiledTemplate = swig.compile(template);
  244. return compiledTemplate(definitions);
  245. }
  246. async function showPageForPresentation(req, res, next) {
  247. const path = getPathFromRequest(req);
  248. const { revisionId } = req.query;
  249. let page = await Page.findByPathAndViewer(path, req.user);
  250. if (page == null) {
  251. next();
  252. }
  253. const renderVars = {};
  254. // populate
  255. page = await page.populateDataToMakePresentation(revisionId);
  256. if (page != null) {
  257. addRenderVarsForPresentation(renderVars, page);
  258. }
  259. return res.render('page_presentation', renderVars);
  260. }
  261. async function showTopPage(req, res, next) {
  262. const portalPath = req.path;
  263. const revisionId = req.query.revision;
  264. const view = 'layout-growi/page_list';
  265. const renderVars = { path: portalPath };
  266. let portalPage = await Page.findByPathAndViewer(portalPath, req.user);
  267. portalPage.initLatestRevisionField(revisionId);
  268. // add user to seen users
  269. if (req.user != null) {
  270. portalPage = await portalPage.seen(req.user);
  271. }
  272. // populate
  273. portalPage = await portalPage.populateDataToShowRevision();
  274. addRenderVarsForPage(renderVars, portalPage);
  275. const sharelinksNumber = await ShareLink.countDocuments({ relatedPage: portalPage._id });
  276. renderVars.sharelinksNumber = sharelinksNumber;
  277. const limit = 50;
  278. const offset = parseInt(req.query.offset) || 0;
  279. await addRenderVarsForDescendants(renderVars, portalPath, req.user, offset, limit);
  280. await interceptorManager.process('beforeRenderPage', req, res, renderVars);
  281. return res.render(view, renderVars);
  282. }
  283. async function showPageForGrowiBehavior(req, res, next) {
  284. const path = getPathFromRequest(req);
  285. const revisionId = req.query.revision;
  286. let page = await Page.findByPathAndViewer(path, req.user);
  287. if (page == null) {
  288. // check the page is forbidden or just does not exist.
  289. req.isForbidden = await Page.count({ path }) > 0;
  290. return next();
  291. }
  292. if (page.redirectTo) {
  293. debug(`Redirect to '${page.redirectTo}'`);
  294. return res.redirect(`${encodeURI(page.redirectTo)}?redirectFrom=${encodeURIComponent(path)}`);
  295. }
  296. logger.debug('Page is found when processing pageShowForGrowiBehavior', page._id, page.path);
  297. const limit = 50;
  298. const offset = parseInt(req.query.offset) || 0;
  299. const renderVars = {};
  300. let view = 'layout-growi/page';
  301. page.initLatestRevisionField(revisionId);
  302. // add user to seen users
  303. if (req.user != null) {
  304. page = await page.seen(req.user);
  305. }
  306. // populate
  307. page = await page.populateDataToShowRevision();
  308. addRenderVarsForPage(renderVars, page);
  309. addRenderVarsForScope(renderVars, page);
  310. await addRenderVarsForDescendants(renderVars, path, req.user, offset, limit, true);
  311. const sharelinksNumber = await ShareLink.countDocuments({ relatedPage: page._id });
  312. renderVars.sharelinksNumber = sharelinksNumber;
  313. if (isUserPage(page.path)) {
  314. // change template
  315. view = 'layout-growi/user_page';
  316. await addRenderVarsForUserPage(renderVars, page);
  317. }
  318. await interceptorManager.process('beforeRenderPage', req, res, renderVars);
  319. return res.render(view, renderVars);
  320. }
  321. actions.showTopPage = function(req, res) {
  322. return showTopPage(req, res);
  323. };
  324. /**
  325. * Redirect to the page without trailing slash
  326. */
  327. actions.showPageWithEndOfSlash = function(req, res, next) {
  328. return res.redirect(pathUtils.removeTrailingSlash(req.path));
  329. };
  330. /**
  331. * switch action
  332. * - presentation mode
  333. * - by behaviorType
  334. */
  335. actions.showPage = async function(req, res, next) {
  336. // presentation mode
  337. if (req.query.presentation) {
  338. return showPageForPresentation(req, res, next);
  339. }
  340. // delegate to showPageForGrowiBehavior
  341. return showPageForGrowiBehavior(req, res, next);
  342. };
  343. actions.showSharedPage = async function(req, res, next) {
  344. const { linkId } = req.params;
  345. const revisionId = req.query.revision;
  346. const shareLink = await ShareLink.findOne({ _id: linkId }).populate('relatedPage');
  347. if (shareLink == null || shareLink.relatedPage == null) {
  348. // page or sharelink are not found
  349. return res.render('layout-growi/not_found_shared_page');
  350. }
  351. const renderVars = {};
  352. renderVars.sharelink = shareLink;
  353. // check if share link is expired
  354. if (shareLink.isExpired()) {
  355. // page is not found
  356. return res.render('layout-growi/expired_shared_page', renderVars);
  357. }
  358. let page = shareLink.relatedPage;
  359. // presentation mode
  360. if (req.query.presentation) {
  361. page = await page.populateDataToMakePresentation(revisionId);
  362. // populate
  363. addRenderVarsForPage(renderVars, page);
  364. return res.render('page_presentation', renderVars);
  365. }
  366. page.initLatestRevisionField(revisionId);
  367. // populate
  368. page = await page.populateDataToShowRevision();
  369. addRenderVarsForPage(renderVars, page);
  370. addRenderVarsForScope(renderVars, page);
  371. await interceptorManager.process('beforeRenderPage', req, res, renderVars);
  372. return res.render('layout-growi/shared_page', renderVars);
  373. };
  374. /**
  375. * switch action by behaviorType
  376. */
  377. /* eslint-disable no-else-return */
  378. actions.trashPageListShowWrapper = function(req, res) {
  379. // redirect to '/trash'
  380. return res.redirect('/trash');
  381. };
  382. /* eslint-enable no-else-return */
  383. /**
  384. * switch action by behaviorType
  385. */
  386. /* eslint-disable no-else-return */
  387. actions.trashPageShowWrapper = function(req, res) {
  388. // Crowi behavior for '/trash/*'
  389. return actions.deletedPageListShow(req, res);
  390. };
  391. /* eslint-enable no-else-return */
  392. /**
  393. * switch action by behaviorType
  394. */
  395. /* eslint-disable no-else-return */
  396. actions.deletedPageListShowWrapper = function(req, res) {
  397. const path = `/trash${getPathFromRequest(req)}`;
  398. return res.redirect(path);
  399. };
  400. /* eslint-enable no-else-return */
  401. actions.notFound = async function(req, res) {
  402. const path = getPathFromRequest(req);
  403. let view;
  404. const renderVars = { path };
  405. if (!isCreatablePage(path)) {
  406. view = 'layout-growi/not_creatable';
  407. }
  408. else if (req.isForbidden) {
  409. view = 'layout-growi/forbidden';
  410. }
  411. else {
  412. view = 'layout-growi/not_found';
  413. // retrieve templates
  414. if (req.user != null) {
  415. const template = await Page.findTemplate(path);
  416. if (template.templateBody) {
  417. const body = replacePlaceholdersOfTemplate(template.templateBody, req);
  418. const tags = template.templateTags;
  419. renderVars.template = body;
  420. renderVars.templateTags = tags;
  421. }
  422. }
  423. // add scope variables by ancestor page
  424. const ancestor = await Page.findAncestorByPathAndViewer(path, req.user);
  425. if (ancestor != null) {
  426. await ancestor.populate('grantedGroup').execPopulate();
  427. addRenderVarsForScope(renderVars, ancestor);
  428. }
  429. }
  430. const limit = 50;
  431. const offset = parseInt(req.query.offset) || 0;
  432. await addRenderVarsForDescendants(renderVars, path, req.user, offset, limit, true);
  433. return res.render(view, renderVars);
  434. };
  435. actions.deletedPageListShow = async function(req, res) {
  436. // normalizePath makes '/trash/' -> '/trash'
  437. const path = pathUtils.normalizePath(`/trash${getPathFromRequest(req)}`);
  438. const limit = 50;
  439. const offset = parseInt(req.query.offset) || 0;
  440. const queryOptions = {
  441. offset,
  442. limit,
  443. includeTrashed: true,
  444. };
  445. const renderVars = {
  446. page: null,
  447. path,
  448. pages: [],
  449. };
  450. const result = await Page.findListWithDescendants(path, req.user, queryOptions);
  451. if (result.pages.length > limit) {
  452. result.pages.pop();
  453. }
  454. renderVars.pager = generatePager(result.offset, result.limit, result.totalCount);
  455. renderVars.pages = result.pages;
  456. res.render('layout-growi/page_list', renderVars);
  457. };
  458. /**
  459. * redirector
  460. */
  461. actions.redirector = async function(req, res) {
  462. const id = req.params.id;
  463. const page = await Page.findByIdAndViewer(id, req.user);
  464. if (page != null) {
  465. return res.redirect(encodeURI(page.path));
  466. }
  467. return res.redirect('/');
  468. };
  469. const api = {};
  470. actions.api = api;
  471. /**
  472. * @swagger
  473. *
  474. * /pages.list:
  475. * get:
  476. * tags: [Pages, CrowiCompatibles]
  477. * operationId: listPages
  478. * summary: /pages.list
  479. * description: Get list of pages
  480. * parameters:
  481. * - in: query
  482. * name: path
  483. * schema:
  484. * $ref: '#/components/schemas/Page/properties/path'
  485. * - in: query
  486. * name: user
  487. * schema:
  488. * $ref: '#/components/schemas/User/properties/username'
  489. * - in: query
  490. * name: limit
  491. * schema:
  492. * $ref: '#/components/schemas/V1PaginateResult/properties/meta/properties/limit'
  493. * - in: query
  494. * name: offset
  495. * schema:
  496. * $ref: '#/components/schemas/V1PaginateResult/properties/meta/properties/offset'
  497. * responses:
  498. * 200:
  499. * description: Succeeded to get list of pages.
  500. * content:
  501. * application/json:
  502. * schema:
  503. * properties:
  504. * ok:
  505. * $ref: '#/components/schemas/V1Response/properties/ok'
  506. * pages:
  507. * type: array
  508. * items:
  509. * $ref: '#/components/schemas/Page'
  510. * description: page list
  511. * 403:
  512. * $ref: '#/components/responses/403'
  513. * 500:
  514. * $ref: '#/components/responses/500'
  515. */
  516. /**
  517. * @api {get} /pages.list List pages by user
  518. * @apiName ListPage
  519. * @apiGroup Page
  520. *
  521. * @apiParam {String} path
  522. * @apiParam {String} user
  523. */
  524. api.list = async function(req, res) {
  525. const username = req.query.user || null;
  526. const path = req.query.path || null;
  527. const limit = +req.query.limit || 50;
  528. const offset = parseInt(req.query.offset) || 0;
  529. const queryOptions = { offset, limit: limit + 1 };
  530. // Accepts only one of these
  531. if (username === null && path === null) {
  532. return res.json(ApiResponse.error('Parameter user or path is required.'));
  533. }
  534. if (username !== null && path !== null) {
  535. return res.json(ApiResponse.error('Parameter user or path is required.'));
  536. }
  537. try {
  538. let result = null;
  539. if (path == null) {
  540. const user = await User.findUserByUsername(username);
  541. if (user === null) {
  542. throw new Error('The user not found.');
  543. }
  544. result = await Page.findListByCreator(user, req.user, queryOptions);
  545. }
  546. else {
  547. result = await Page.findListByStartWith(path, req.user, queryOptions);
  548. }
  549. if (result.pages.length > limit) {
  550. result.pages.pop();
  551. }
  552. result.pages.forEach((page) => {
  553. if (page.lastUpdateUser != null && page.lastUpdateUser instanceof User) {
  554. page.lastUpdateUser = serializeUserSecurely(page.lastUpdateUser);
  555. }
  556. });
  557. return res.json(ApiResponse.success(result));
  558. }
  559. catch (err) {
  560. return res.json(ApiResponse.error(err));
  561. }
  562. };
  563. // TODO If everything that depends on this route, delete it too
  564. api.create = async function(req, res) {
  565. const body = req.body.body || null;
  566. let pagePath = req.body.path || null;
  567. const grant = req.body.grant || null;
  568. const grantUserGroupId = req.body.grantUserGroupId || null;
  569. const overwriteScopesOfDescendants = req.body.overwriteScopesOfDescendants || null;
  570. const isSlackEnabled = !!req.body.isSlackEnabled; // cast to boolean
  571. const slackChannels = req.body.slackChannels || null;
  572. const socketClientId = req.body.socketClientId || undefined;
  573. const pageTags = req.body.pageTags || undefined;
  574. if (body === null || pagePath === null) {
  575. return res.json(ApiResponse.error('Parameters body and path are required.'));
  576. }
  577. // check whether path starts slash
  578. pagePath = pathUtils.addHeadingSlash(pagePath);
  579. // check page existence
  580. const isExist = await Page.count({ path: pagePath }) > 0;
  581. if (isExist) {
  582. return res.json(ApiResponse.error('Page exists', 'already_exists'));
  583. }
  584. const options = { socketClientId };
  585. if (grant != null) {
  586. options.grant = grant;
  587. options.grantUserGroupId = grantUserGroupId;
  588. }
  589. const createdPage = await Page.create(pagePath, body, req.user, options);
  590. let savedTags;
  591. if (pageTags != null) {
  592. await PageTagRelation.updatePageTags(createdPage.id, pageTags);
  593. savedTags = await PageTagRelation.listTagNamesByPage(createdPage.id);
  594. }
  595. const result = {
  596. page: serializePageSecurely(createdPage),
  597. revision: serializeRevisionSecurely(createdPage.revision),
  598. tags: savedTags,
  599. };
  600. res.json(ApiResponse.success(result));
  601. // update scopes for descendants
  602. if (overwriteScopesOfDescendants) {
  603. Page.applyScopesToDescendantsAsyncronously(createdPage, req.user);
  604. }
  605. // global notification
  606. try {
  607. await globalNotificationService.fire(GlobalNotificationSetting.EVENT.PAGE_CREATE, createdPage, req.user);
  608. }
  609. catch (err) {
  610. logger.error('Create notification failed', err);
  611. }
  612. // user notification
  613. if (isSlackEnabled) {
  614. try {
  615. const results = await userNotificationService.fire(createdPage, req.user, slackChannels, 'create');
  616. results.forEach((result) => {
  617. if (result.status === 'rejected') {
  618. logger.error('Create user notification failed', result.reason);
  619. }
  620. });
  621. }
  622. catch (err) {
  623. logger.error('Create user notification failed', err);
  624. }
  625. }
  626. };
  627. /**
  628. * @swagger
  629. *
  630. * /pages.update:
  631. * post:
  632. * tags: [Pages, CrowiCompatibles]
  633. * operationId: updatePage
  634. * summary: /pages.update
  635. * description: Update page
  636. * requestBody:
  637. * content:
  638. * application/json:
  639. * schema:
  640. * properties:
  641. * body:
  642. * $ref: '#/components/schemas/Revision/properties/body'
  643. * page_id:
  644. * $ref: '#/components/schemas/Page/properties/_id'
  645. * revision_id:
  646. * $ref: '#/components/schemas/Revision/properties/_id'
  647. * grant:
  648. * $ref: '#/components/schemas/Page/properties/grant'
  649. * required:
  650. * - body
  651. * - page_id
  652. * - revision_id
  653. * responses:
  654. * 200:
  655. * description: Succeeded to update page.
  656. * content:
  657. * application/json:
  658. * schema:
  659. * properties:
  660. * ok:
  661. * $ref: '#/components/schemas/V1Response/properties/ok'
  662. * page:
  663. * $ref: '#/components/schemas/Page'
  664. * revision:
  665. * $ref: '#/components/schemas/Revision'
  666. * 403:
  667. * $ref: '#/components/responses/403'
  668. * 500:
  669. * $ref: '#/components/responses/500'
  670. */
  671. /**
  672. * @api {post} /pages.update Update page
  673. * @apiName UpdatePage
  674. * @apiGroup Page
  675. *
  676. * @apiParam {String} body
  677. * @apiParam {String} page_id
  678. * @apiParam {String} revision_id
  679. * @apiParam {String} grant
  680. *
  681. * In the case of the page exists:
  682. * - If revision_id is specified => update the page,
  683. * - If revision_id is not specified => force update by the new contents.
  684. */
  685. api.update = async function(req, res) {
  686. const pageBody = req.body.body || null;
  687. const pageId = req.body.page_id || null;
  688. const revisionId = req.body.revision_id || null;
  689. const grant = req.body.grant || null;
  690. const grantUserGroupId = req.body.grantUserGroupId || null;
  691. const overwriteScopesOfDescendants = req.body.overwriteScopesOfDescendants || null;
  692. const isSlackEnabled = !!req.body.isSlackEnabled; // cast to boolean
  693. const slackChannels = req.body.slackChannels || null;
  694. const isSyncRevisionToHackmd = !!req.body.isSyncRevisionToHackmd; // cast to boolean
  695. const socketClientId = req.body.socketClientId || undefined;
  696. const pageTags = req.body.pageTags || undefined;
  697. if (pageId === null || pageBody === null || revisionId === null) {
  698. return res.json(ApiResponse.error('page_id, body and revision_id are required.'));
  699. }
  700. // check page existence
  701. const isExist = await Page.count({ _id: pageId }) > 0;
  702. if (!isExist) {
  703. return res.json(ApiResponse.error(`Page('${pageId}' is not found or forbidden`, 'notfound_or_forbidden'));
  704. }
  705. // check revision
  706. let page = await Page.findByIdAndViewer(pageId, req.user);
  707. if (page != null && revisionId != null && !page.isUpdatable(revisionId)) {
  708. return res.json(ApiResponse.error('Posted param "revisionId" is outdated.', 'outdated'));
  709. }
  710. const options = { isSyncRevisionToHackmd, socketClientId };
  711. if (grant != null) {
  712. options.grant = grant;
  713. options.grantUserGroupId = grantUserGroupId;
  714. }
  715. const Revision = crowi.model('Revision');
  716. const previousRevision = await Revision.findById(revisionId);
  717. try {
  718. page = await Page.updatePage(page, pageBody, previousRevision.body, req.user, options);
  719. }
  720. catch (err) {
  721. logger.error('error on _api/pages.update', err);
  722. return res.json(ApiResponse.error(err));
  723. }
  724. let savedTags;
  725. if (pageTags != null) {
  726. await PageTagRelation.updatePageTags(pageId, pageTags);
  727. savedTags = await PageTagRelation.listTagNamesByPage(pageId);
  728. }
  729. const result = {
  730. page: serializePageSecurely(page),
  731. revision: serializeRevisionSecurely(page.revision),
  732. tags: savedTags,
  733. };
  734. res.json(ApiResponse.success(result));
  735. // update scopes for descendants
  736. if (overwriteScopesOfDescendants) {
  737. Page.applyScopesToDescendantsAsyncronously(page, req.user);
  738. }
  739. // global notification
  740. try {
  741. await globalNotificationService.fire(GlobalNotificationSetting.EVENT.PAGE_EDIT, page, req.user);
  742. }
  743. catch (err) {
  744. logger.error('Edit notification failed', err);
  745. }
  746. // user notification
  747. if (isSlackEnabled) {
  748. try {
  749. const results = await userNotificationService.fire(page, req.user, slackChannels, 'update', { previousRevision });
  750. results.forEach((result) => {
  751. if (result.status === 'rejected') {
  752. logger.error('Create user notification failed', result.reason);
  753. }
  754. });
  755. }
  756. catch (err) {
  757. logger.error('Create user notification failed', err);
  758. }
  759. }
  760. };
  761. /**
  762. * @swagger
  763. *
  764. * /pages.get:
  765. * get:
  766. * tags: [Pages, CrowiCompatibles]
  767. * operationId: getPage
  768. * summary: /pages.get
  769. * description: Get page data
  770. * parameters:
  771. * - in: query
  772. * name: page_id
  773. * schema:
  774. * $ref: '#/components/schemas/Page/properties/_id'
  775. * - in: query
  776. * name: path
  777. * schema:
  778. * $ref: '#/components/schemas/Page/properties/path'
  779. * - in: query
  780. * name: revision_id
  781. * schema:
  782. * $ref: '#/components/schemas/Revision/properties/_id'
  783. * responses:
  784. * 200:
  785. * description: Succeeded to get page data.
  786. * content:
  787. * application/json:
  788. * schema:
  789. * properties:
  790. * ok:
  791. * $ref: '#/components/schemas/V1Response/properties/ok'
  792. * page:
  793. * $ref: '#/components/schemas/Page'
  794. * 403:
  795. * $ref: '#/components/responses/403'
  796. * 500:
  797. * $ref: '#/components/responses/500'
  798. */
  799. /**
  800. * @api {get} /pages.get Get page data
  801. * @apiName GetPage
  802. * @apiGroup Page
  803. *
  804. * @apiParam {String} page_id
  805. * @apiParam {String} path
  806. * @apiParam {String} revision_id
  807. */
  808. api.get = async function(req, res) {
  809. const pagePath = req.query.path || null;
  810. const pageId = req.query.page_id || null; // TODO: handling
  811. if (!pageId && !pagePath) {
  812. return res.json(ApiResponse.error(new Error('Parameter path or page_id is required.')));
  813. }
  814. let page;
  815. try {
  816. if (pageId) { // prioritized
  817. page = await Page.findByIdAndViewer(pageId, req.user);
  818. }
  819. else if (pagePath) {
  820. page = await Page.findByPathAndViewer(pagePath, req.user);
  821. }
  822. if (page == null) {
  823. throw new Error(`Page '${pageId || pagePath}' is not found or forbidden`, 'notfound_or_forbidden');
  824. }
  825. page.initLatestRevisionField();
  826. // populate
  827. page = await page.populateDataToShowRevision();
  828. }
  829. catch (err) {
  830. return res.json(ApiResponse.error(err));
  831. }
  832. const result = {};
  833. result.page = page; // TODO consider to use serializePageSecurely method -- 2018.08.06 Yuki Takei
  834. return res.json(ApiResponse.success(result));
  835. };
  836. /**
  837. * @swagger
  838. *
  839. * /pages.exist:
  840. * get:
  841. * tags: [Pages]
  842. * operationId: getPageExistence
  843. * summary: /pages.exist
  844. * description: Get page existence
  845. * parameters:
  846. * - in: query
  847. * name: pagePaths
  848. * schema:
  849. * type: string
  850. * description: Page path list in JSON Array format
  851. * example: '["/", "/user/unknown"]'
  852. * responses:
  853. * 200:
  854. * description: Succeeded to get page existence.
  855. * content:
  856. * application/json:
  857. * schema:
  858. * properties:
  859. * ok:
  860. * $ref: '#/components/schemas/V1Response/properties/ok'
  861. * pages:
  862. * type: string
  863. * description: Properties of page path and existence
  864. * example: '{"/": true, "/user/unknown": false}'
  865. * 403:
  866. * $ref: '#/components/responses/403'
  867. * 500:
  868. * $ref: '#/components/responses/500'
  869. */
  870. /**
  871. * @api {get} /pages.exist Get if page exists
  872. * @apiName GetPage
  873. * @apiGroup Page
  874. *
  875. * @apiParam {String} pages (stringified JSON)
  876. */
  877. api.exist = async function(req, res) {
  878. const pagePaths = JSON.parse(req.query.pagePaths || '[]');
  879. const pages = {};
  880. await Promise.all(pagePaths.map(async(path) => {
  881. // check page existence
  882. const isExist = await Page.count({ path }) > 0;
  883. pages[path] = isExist;
  884. return;
  885. }));
  886. const result = { pages };
  887. return res.json(ApiResponse.success(result));
  888. };
  889. /**
  890. * @swagger
  891. *
  892. * /pages.getPageTag:
  893. * get:
  894. * tags: [Pages]
  895. * operationId: getPageTag
  896. * summary: /pages.getPageTag
  897. * description: Get page tag
  898. * parameters:
  899. * - in: query
  900. * name: pageId
  901. * schema:
  902. * $ref: '#/components/schemas/Page/properties/_id'
  903. * responses:
  904. * 200:
  905. * description: Succeeded to get page tags.
  906. * content:
  907. * application/json:
  908. * schema:
  909. * properties:
  910. * ok:
  911. * $ref: '#/components/schemas/V1Response/properties/ok'
  912. * tags:
  913. * $ref: '#/components/schemas/Tags'
  914. * 403:
  915. * $ref: '#/components/responses/403'
  916. * 500:
  917. * $ref: '#/components/responses/500'
  918. */
  919. /**
  920. * @api {get} /pages.getPageTag get page tags
  921. * @apiName GetPageTag
  922. * @apiGroup Page
  923. *
  924. * @apiParam {String} pageId
  925. */
  926. api.getPageTag = async function(req, res) {
  927. const result = {};
  928. try {
  929. result.tags = await PageTagRelation.listTagNamesByPage(req.query.pageId);
  930. }
  931. catch (err) {
  932. return res.json(ApiResponse.error(err));
  933. }
  934. return res.json(ApiResponse.success(result));
  935. };
  936. /**
  937. * @swagger
  938. *
  939. * /pages.updatePost:
  940. * get:
  941. * tags: [Pages, CrowiCompatibles]
  942. * operationId: getUpdatePostPage
  943. * summary: /pages.updatePost
  944. * description: Get UpdatePost setting list
  945. * parameters:
  946. * - in: query
  947. * name: path
  948. * schema:
  949. * $ref: '#/components/schemas/Page/properties/path'
  950. * responses:
  951. * 200:
  952. * description: Succeeded to get UpdatePost setting list.
  953. * content:
  954. * application/json:
  955. * schema:
  956. * properties:
  957. * ok:
  958. * $ref: '#/components/schemas/V1Response/properties/ok'
  959. * updatePost:
  960. * $ref: '#/components/schemas/UpdatePost'
  961. * 403:
  962. * $ref: '#/components/responses/403'
  963. * 500:
  964. * $ref: '#/components/responses/500'
  965. */
  966. /**
  967. * @api {get} /pages.updatePost
  968. * @apiName Get UpdatePost setting list
  969. * @apiGroup Page
  970. *
  971. * @apiParam {String} path
  972. */
  973. api.getUpdatePost = function(req, res) {
  974. const path = req.query.path;
  975. const UpdatePost = crowi.model('UpdatePost');
  976. if (!path) {
  977. return res.json(ApiResponse.error({}));
  978. }
  979. UpdatePost.findSettingsByPath(path)
  980. .then((data) => {
  981. // eslint-disable-next-line no-param-reassign
  982. data = data.map((e) => {
  983. return e.channel;
  984. });
  985. debug('Found updatePost data', data);
  986. const result = { updatePost: data };
  987. return res.json(ApiResponse.success(result));
  988. })
  989. .catch((err) => {
  990. debug('Error occured while get setting', err);
  991. return res.json(ApiResponse.error({}));
  992. });
  993. };
  994. /**
  995. * @api {post} /pages.remove Remove page
  996. * @apiName RemovePage
  997. * @apiGroup Page
  998. *
  999. * @apiParam {String} page_id Page Id.
  1000. * @apiParam {String} revision_id
  1001. */
  1002. api.remove = async function(req, res) {
  1003. const pageId = req.body.page_id;
  1004. const previousRevision = req.body.revision_id || null;
  1005. const socketClientId = req.body.socketClientId || undefined;
  1006. // get completely flag
  1007. const isCompletely = (req.body.completely != null);
  1008. // get recursively flag
  1009. const isRecursively = (req.body.recursively != null);
  1010. const options = { socketClientId };
  1011. const page = await Page.findByIdAndViewer(pageId, req.user);
  1012. if (page == null) {
  1013. return res.json(ApiResponse.error(`Page '${pageId}' is not found or forbidden`, 'notfound_or_forbidden'));
  1014. }
  1015. debug('Delete page', page._id, page.path);
  1016. try {
  1017. if (isCompletely) {
  1018. if (!req.user.canDeleteCompletely(page.creator)) {
  1019. return res.json(ApiResponse.error('You can not delete completely', 'user_not_admin'));
  1020. }
  1021. await crowi.pageService.deleteCompletely(page, req.user, options, isRecursively);
  1022. }
  1023. else {
  1024. if (!page.isUpdatable(previousRevision)) {
  1025. return res.json(ApiResponse.error('Someone could update this page, so couldn\'t delete.', 'outdated'));
  1026. }
  1027. await crowi.pageService.deletePage(page, req.user, options, isRecursively);
  1028. }
  1029. }
  1030. catch (err) {
  1031. logger.error('Error occured while get setting', err);
  1032. return res.json(ApiResponse.error('Failed to delete page.', err.message));
  1033. }
  1034. debug('Page deleted', page.path);
  1035. const result = {};
  1036. result.page = page; // TODO consider to use serializePageSecurely method -- 2018.08.06 Yuki Takei
  1037. res.json(ApiResponse.success(result));
  1038. try {
  1039. // global notification
  1040. await globalNotificationService.fire(GlobalNotificationSetting.EVENT.PAGE_DELETE, page, req.user);
  1041. }
  1042. catch (err) {
  1043. logger.error('Delete notification failed', err);
  1044. }
  1045. };
  1046. /**
  1047. * @api {post} /pages.revertRemove Revert removed page
  1048. * @apiName RevertRemovePage
  1049. * @apiGroup Page
  1050. *
  1051. * @apiParam {String} page_id Page Id.
  1052. */
  1053. api.revertRemove = async function(req, res, options) {
  1054. const pageId = req.body.page_id;
  1055. const socketClientId = req.body.socketClientId || undefined;
  1056. // get recursively flag
  1057. const isRecursively = (req.body.recursively != null);
  1058. let page;
  1059. try {
  1060. page = await Page.findByIdAndViewer(pageId, req.user);
  1061. if (page == null) {
  1062. throw new Error(`Page '${pageId}' is not found or forbidden`, 'notfound_or_forbidden');
  1063. }
  1064. page = await crowi.pageService.revertDeletedPage(page, req.user, { socketClientId }, isRecursively);
  1065. }
  1066. catch (err) {
  1067. logger.error('Error occured while get setting', err);
  1068. return res.json(ApiResponse.error('Failed to revert deleted page.'));
  1069. }
  1070. const result = {};
  1071. result.page = page; // TODO consider to use serializePageSecurely method -- 2018.08.06 Yuki Takei
  1072. return res.json(ApiResponse.success(result));
  1073. };
  1074. /**
  1075. * @swagger
  1076. *
  1077. * /pages.duplicate:
  1078. * post:
  1079. * tags: [Pages]
  1080. * operationId: duplicatePage
  1081. * summary: /pages.duplicate
  1082. * description: Duplicate page
  1083. * requestBody:
  1084. * content:
  1085. * application/json:
  1086. * schema:
  1087. * properties:
  1088. * page_id:
  1089. * $ref: '#/components/schemas/Page/properties/_id'
  1090. * new_path:
  1091. * $ref: '#/components/schemas/Page/properties/path'
  1092. * required:
  1093. * - page_id
  1094. * responses:
  1095. * 200:
  1096. * description: Succeeded to duplicate page.
  1097. * content:
  1098. * application/json:
  1099. * schema:
  1100. * properties:
  1101. * ok:
  1102. * $ref: '#/components/schemas/V1Response/properties/ok'
  1103. * page:
  1104. * $ref: '#/components/schemas/Page'
  1105. * tags:
  1106. * $ref: '#/components/schemas/Tags'
  1107. * 403:
  1108. * $ref: '#/components/responses/403'
  1109. * 500:
  1110. * $ref: '#/components/responses/500'
  1111. */
  1112. /**
  1113. * @api {post} /pages.duplicate Duplicate page
  1114. * @apiName DuplicatePage
  1115. * @apiGroup Page
  1116. *
  1117. * @apiParam {String} page_id Page Id.
  1118. * @apiParam {String} new_path New path name.
  1119. */
  1120. api.duplicate = async function(req, res) {
  1121. const pageId = req.body.page_id;
  1122. let newPagePath = pathUtils.normalizePath(req.body.new_path);
  1123. const page = await Page.findByIdAndViewer(pageId, req.user);
  1124. if (page == null) {
  1125. return res.json(ApiResponse.error(`Page '${pageId}' is not found or forbidden`, 'notfound_or_forbidden'));
  1126. }
  1127. // check whether path starts slash
  1128. newPagePath = pathUtils.addHeadingSlash(newPagePath);
  1129. await page.populateDataToShowRevision();
  1130. const originTags = await page.findRelatedTagsById();
  1131. req.body.path = newPagePath;
  1132. req.body.body = page.revision.body;
  1133. req.body.grant = page.grant;
  1134. req.body.grantedUsers = page.grantedUsers;
  1135. req.body.grantUserGroupId = page.grantedGroup;
  1136. req.body.pageTags = originTags;
  1137. return api.create(req, res);
  1138. };
  1139. /**
  1140. * @api {post} /pages.unlink Remove the redirecting page
  1141. * @apiName UnlinkPage
  1142. * @apiGroup Page
  1143. *
  1144. * @apiParam {String} page_id Page Id.
  1145. * @apiParam {String} revision_id
  1146. */
  1147. api.unlink = async function(req, res) {
  1148. const path = req.body.path;
  1149. try {
  1150. await Page.removeRedirectOriginPageByPath(path);
  1151. logger.debug('Redirect Page deleted', path);
  1152. }
  1153. catch (err) {
  1154. logger.error('Error occured while get setting', err);
  1155. return res.json(ApiResponse.error('Failed to delete redirect page.'));
  1156. }
  1157. const result = { path };
  1158. return res.json(ApiResponse.success(result));
  1159. };
  1160. return actions;
  1161. };