page.js 33 KB

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