page.js 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960
  1. module.exports = function(crowi) {
  2. var debug = require('debug')('crowi:models:page')
  3. , mongoose = require('mongoose')
  4. , ObjectId = mongoose.Schema.Types.ObjectId
  5. , GRANT_PUBLIC = 1
  6. , GRANT_RESTRICTED = 2
  7. , GRANT_SPECIFIED = 3
  8. , GRANT_OWNER = 4
  9. , PAGE_GRANT_ERROR = 1
  10. , STATUS_WIP = 'wip'
  11. , STATUS_PUBLISHED = 'published'
  12. , STATUS_DELETED = 'deleted'
  13. , STATUS_DEPRECATED = 'deprecated'
  14. , pageEvent = crowi.event('page')
  15. , pageSchema;
  16. function isPortalPath(path) {
  17. if (path.match(/.*\/$/)) {
  18. return true;
  19. }
  20. return false;
  21. }
  22. pageSchema = new mongoose.Schema({
  23. path: { type: String, required: true, index: true, unique: true },
  24. revision: { type: ObjectId, ref: 'Revision' },
  25. redirectTo: { type: String, index: true },
  26. status: { type: String, default: STATUS_PUBLISHED, index: true },
  27. grant: { type: Number, default: GRANT_PUBLIC, index: true },
  28. grantedUsers: [{ type: ObjectId, ref: 'User' }],
  29. creator: { type: ObjectId, ref: 'User', index: true },
  30. // lastUpdateUser: this schema is from 1.5.x (by deletion feature), and null is default.
  31. // the last update user on the screen is by revesion.author for B.C.
  32. lastUpdateUser: { type: ObjectId, ref: 'User', index: true },
  33. liker: [{ type: ObjectId, ref: 'User', index: true }],
  34. seenUsers: [{ type: ObjectId, ref: 'User', index: true }],
  35. commentCount: { type: Number, default: 0 },
  36. extended: {
  37. type: String,
  38. default: '{}',
  39. get: function(data) {
  40. try {
  41. return JSON.parse(data);
  42. } catch(e) {
  43. return data;
  44. }
  45. },
  46. set: function(data) {
  47. return JSON.stringify(data);
  48. }
  49. },
  50. createdAt: { type: Date, default: Date.now },
  51. updatedAt: Date
  52. }, {
  53. toJSON: {getters: true},
  54. toObject: {getters: true}
  55. });
  56. pageEvent.on('create', pageEvent.onCreate);
  57. pageEvent.on('update', pageEvent.onUpdate);
  58. pageSchema.methods.isWIP = function() {
  59. return this.status === STATUS_WIP;
  60. };
  61. pageSchema.methods.isPublished = function() {
  62. // null: this is for B.C.
  63. return this.status === null || this.status === STATUS_PUBLISHED;
  64. };
  65. pageSchema.methods.isDeleted = function() {
  66. return this.status === STATUS_DELETED;
  67. };
  68. pageSchema.methods.isDeprecated = function() {
  69. return this.status === STATUS_DEPRECATED;
  70. };
  71. pageSchema.methods.isPublic = function() {
  72. if (!this.grant || this.grant == GRANT_PUBLIC) {
  73. return true;
  74. }
  75. return false;
  76. };
  77. pageSchema.methods.isPortal = function() {
  78. return isPortalPath(this.path);
  79. };
  80. pageSchema.methods.isCreator = function(userData) {
  81. if (this.populated('creator') && this.creator._id.toString() === userData._id.toString()) {
  82. return true;
  83. } else if (this.creator.toString() === userData._id.toString()) {
  84. return true
  85. }
  86. return false;
  87. };
  88. pageSchema.methods.isGrantedFor = function(userData) {
  89. if (this.isPublic() || this.isCreator(userData)) {
  90. return true;
  91. }
  92. if (this.grantedUsers.indexOf(userData._id) >= 0) {
  93. return true;
  94. }
  95. return false;
  96. };
  97. pageSchema.methods.isLatestRevision = function() {
  98. // populate されていなくて判断できない
  99. if (!this.latestRevision || !this.revision) {
  100. return true;
  101. }
  102. return (this.latestRevision == this.revision._id.toString());
  103. };
  104. pageSchema.methods.isUpdatable = function(previousRevision) {
  105. var revision = this.latestRevision || this.revision;
  106. if (revision != previousRevision) {
  107. return false;
  108. }
  109. return true;
  110. };
  111. pageSchema.methods.isLiked = function(userData) {
  112. return this.liker.some(function(likedUser) {
  113. return likedUser == userData._id.toString();
  114. });
  115. };
  116. pageSchema.methods.like = function(userData) {
  117. var self = this,
  118. Page = self;
  119. return new Promise(function(resolve, reject) {
  120. var added = self.liker.addToSet(userData._id);
  121. if (added.length > 0) {
  122. self.save(function(err, data) {
  123. if (err) {
  124. return reject(err);
  125. }
  126. debug('liker updated!', added);
  127. return resolve(data);
  128. });
  129. } else {
  130. debug('liker not updated');
  131. return reject(self);
  132. }
  133. });
  134. };
  135. pageSchema.methods.unlike = function(userData, callback) {
  136. var self = this,
  137. Page = self;
  138. return new Promise(function(resolve, reject) {
  139. var beforeCount = self.liker.length;
  140. self.liker.pull(userData._id);
  141. if (self.liker.length != beforeCount) {
  142. self.save(function(err, data) {
  143. if (err) {
  144. return reject(err);
  145. }
  146. return resolve(data);
  147. });
  148. } else {
  149. debug('liker not updated');
  150. return reject(self);
  151. }
  152. });
  153. };
  154. pageSchema.methods.isSeenUser = function(userData) {
  155. var self = this,
  156. Page = self;
  157. return this.seenUsers.some(function(seenUser) {
  158. return seenUser.equals(userData._id);
  159. });
  160. };
  161. pageSchema.methods.seen = function(userData) {
  162. var self = this,
  163. Page = self;
  164. if (this.isSeenUser(userData)) {
  165. debug('seenUsers not updated');
  166. return Promise.resolve(this);
  167. }
  168. return new Promise(function(resolve, reject) {
  169. if (!userData || !userData._id) {
  170. reject(new Error('User data is not valid'));
  171. }
  172. var added = self.seenUsers.addToSet(userData);
  173. self.save(function(err, data) {
  174. if (err) {
  175. return reject(err);
  176. }
  177. debug('seenUsers updated!', added);
  178. return resolve(self);
  179. });
  180. });
  181. };
  182. pageSchema.methods.getSlackChannel = function() {
  183. var extended = this.get('extended');
  184. if (!extended) {
  185. return '';
  186. }
  187. return extended.slack || '';
  188. };
  189. pageSchema.methods.updateSlackChannel = function(slackChannel) {
  190. var extended = this.extended;
  191. extended.slack = slackChannel;
  192. return this.updateExtended(extended);
  193. };
  194. pageSchema.methods.updateExtended = function(extended) {
  195. var page = this;
  196. page.extended = extended;
  197. return new Promise(function(resolve, reject) {
  198. return page.save(function(err, doc) {
  199. if (err) {
  200. return reject(err);
  201. }
  202. return resolve(doc);
  203. });
  204. });
  205. };
  206. pageSchema.statics.populatePageData = function(pageData, revisionId) {
  207. var Page = crowi.model('Page');
  208. var User = crowi.model('User');
  209. pageData.latestRevision = pageData.revision;
  210. if (revisionId) {
  211. pageData.revision = revisionId;
  212. }
  213. pageData.likerCount = pageData.liker.length || 0;
  214. pageData.seenUsersCount = pageData.seenUsers.length || 0;
  215. return new Promise(function(resolve, reject) {
  216. pageData.populate([
  217. {path: 'lastUpdateUser', model: 'User', select: User.USER_PUBLIC_FIELDS},
  218. {path: 'creator', model: 'User', select: User.USER_PUBLIC_FIELDS},
  219. {path: 'revision', model: 'Revision'},
  220. //{path: 'liker', options: { limit: 11 }},
  221. //{path: 'seenUsers', options: { limit: 11 }},
  222. ], function (err, pageData) {
  223. Page.populate(pageData, {path: 'revision.author', model: 'User', select: User.USER_PUBLIC_FIELDS}, function(err, data) {
  224. if (err) {
  225. return reject(err);
  226. }
  227. return resolve(data);
  228. });
  229. });
  230. });
  231. };
  232. pageSchema.statics.populatePageListToAnyObjects = function(pageIdObjectArray) {
  233. var Page = this;
  234. var pageIdMappings = {};
  235. var pageIds = pageIdObjectArray.map(function(page, idx) {
  236. if (!page._id) {
  237. throw new Error('Pass the arg of populatePageListToAnyObjects() must have _id on each element.');
  238. }
  239. pageIdMappings[String(page._id)] = idx;
  240. return page._id;
  241. });
  242. return new Promise(function(resolve, reject) {
  243. Page.findListByPageIds(pageIds, {limit: 100}) // limit => if the pagIds is greater than 100, ignore
  244. .then(function(pages) {
  245. pages.forEach(function(page) {
  246. Object.assign(pageIdObjectArray[pageIdMappings[String(page._id)]], page._doc);
  247. });
  248. resolve(pageIdObjectArray);
  249. });
  250. });
  251. };
  252. pageSchema.statics.updateCommentCount = function (page, num)
  253. {
  254. var self = this;
  255. return new Promise(function(resolve, reject) {
  256. self.update({_id: page}, {commentCount: num}, {}, function(err, data) {
  257. if (err) {
  258. debug('Update commentCount Error', err);
  259. return reject(err);
  260. }
  261. return resolve(data);
  262. });
  263. });
  264. };
  265. pageSchema.statics.hasPortalPage = function (path, user, revisionId) {
  266. var self = this;
  267. return new Promise(function(resolve, reject) {
  268. self.findPage(path, user, revisionId)
  269. .then(function(page) {
  270. resolve(page);
  271. }).catch(function(err) {
  272. resolve(null); // check only has portal page, through error
  273. });
  274. });
  275. };
  276. pageSchema.statics.getGrantLabels = function() {
  277. var grantLabels = {};
  278. grantLabels[GRANT_PUBLIC] = 'Public'; // 公開
  279. grantLabels[GRANT_RESTRICTED] = 'Anyone with the link'; // リンクを知っている人のみ
  280. //grantLabels[GRANT_SPECIFIED] = 'Specified users only'; // 特定ユーザーのみ
  281. grantLabels[GRANT_OWNER] = 'Just me'; // 自分のみ
  282. return grantLabels;
  283. };
  284. pageSchema.statics.normalizePath = function(path) {
  285. if (!path.match(/^\//)) {
  286. path = '/' + path;
  287. }
  288. return path;
  289. };
  290. pageSchema.statics.getUserPagePath = function(user) {
  291. return '/user/' + user.username;
  292. };
  293. pageSchema.statics.getDeletedPageName = function(path) {
  294. if (path.match('\/')) {
  295. path = path.substr(1);
  296. }
  297. return '/trash/' + path;
  298. };
  299. pageSchema.statics.getRevertDeletedPageName = function(path) {
  300. return path.replace('\/trash', '');
  301. };
  302. pageSchema.statics.isDeletableName = function(path) {
  303. var notDeletable = [
  304. /^\/user\/[^\/]+$/, // user page
  305. ];
  306. for (var i = 0; i < notDeletable.length; i++) {
  307. var pattern = notDeletable[i];
  308. if (path.match(pattern)) {
  309. return false;
  310. }
  311. }
  312. return true;
  313. };
  314. pageSchema.statics.isCreatableName = function(name) {
  315. var forbiddenPages = [
  316. /\^|\$|\*|\+|\#/,
  317. /^\/_.*/, // /_api/* and so on
  318. /^\/\-\/.*/,
  319. /^\/_r\/.*/,
  320. /^\/user\/[^\/]+\/(bookmarks|comments|activities|pages|recent-create|recent-edit)/, // reserved
  321. /^\/?https?:\/\/.+$/, // avoid miss in renaming
  322. /.+\/edit$/,
  323. /.+\.md$/,
  324. /^\/(installer|register|login|logout|admin|me|files|trash|paste|comments)(\/.*|$)/,
  325. ];
  326. var isCreatable = true;
  327. forbiddenPages.forEach(function(page) {
  328. var pageNameReg = new RegExp(page);
  329. if (name.match(pageNameReg)) {
  330. isCreatable = false;
  331. return ;
  332. }
  333. });
  334. return isCreatable;
  335. };
  336. pageSchema.statics.fixToCreatableName = function(path) {
  337. return path
  338. .replace(/\/\//g, '/')
  339. ;
  340. };
  341. pageSchema.statics.updateRevision = function(pageId, revisionId, cb) {
  342. this.update({_id: pageId}, {revision: revisionId}, {}, function(err, data) {
  343. cb(err, data);
  344. });
  345. };
  346. pageSchema.statics.findUpdatedList = function(offset, limit, cb) {
  347. this
  348. .find({})
  349. .sort({updatedAt: -1})
  350. .skip(offset)
  351. .limit(limit)
  352. .exec(function(err, data) {
  353. cb(err, data);
  354. });
  355. };
  356. pageSchema.statics.findPageById = function(id) {
  357. var Page = this;
  358. return new Promise(function(resolve, reject) {
  359. Page.findOne({_id: id}, function(err, pageData) {
  360. if (err) {
  361. return reject(err);
  362. }
  363. if (pageData == null) {
  364. return reject(new Error('Page not found'));
  365. }
  366. return Page.populatePageData(pageData, null).then(resolve);
  367. });
  368. });
  369. };
  370. pageSchema.statics.findPageByIdAndGrantedUser = function(id, userData) {
  371. var Page = this;
  372. return new Promise(function(resolve, reject) {
  373. Page.findPageById(id)
  374. .then(function(pageData) {
  375. if (userData && !pageData.isGrantedFor(userData)) {
  376. return reject(new Error('Page is not granted for the user')); //PAGE_GRANT_ERROR, null);
  377. }
  378. return resolve(pageData);
  379. }).catch(function(err) {
  380. return reject(err);
  381. });
  382. });
  383. };
  384. // find page and check if granted user
  385. pageSchema.statics.findPage = function(path, userData, revisionId, ignoreNotFound) {
  386. var self = this;
  387. return new Promise(function(resolve, reject) {
  388. self.findOne({path: path}, function(err, pageData) {
  389. if (err) {
  390. return reject(err);
  391. }
  392. if (pageData === null) {
  393. if (ignoreNotFound) {
  394. return resolve(null);
  395. }
  396. var pageNotFoundError = new Error('Page Not Found')
  397. pageNotFoundError.name = 'Crowi:Page:NotFound';
  398. return reject(pageNotFoundError);
  399. }
  400. if (!pageData.isGrantedFor(userData)) {
  401. return reject(new Error('Page is not granted for the user')); //PAGE_GRANT_ERROR, null);
  402. }
  403. self.populatePageData(pageData, revisionId || null).then(resolve).catch(reject);
  404. });
  405. });
  406. };
  407. // find page by path
  408. pageSchema.statics.findPageByPath = function(path) {
  409. var Page = this;
  410. return new Promise(function(resolve, reject) {
  411. Page.findOne({path: path}, function(err, pageData) {
  412. if (err || pageData === null) {
  413. return reject(err);
  414. }
  415. return resolve(pageData);
  416. });
  417. });
  418. };
  419. pageSchema.statics.findListByPageIds = function(ids, options) {
  420. var Page = this;
  421. var User = crowi.model('User');
  422. var options = options || {}
  423. , limit = options.limit || 50
  424. , offset = options.skip || 0
  425. ;
  426. return new Promise(function(resolve, reject) {
  427. Page
  428. .find({ _id: { $in: ids }, grant: GRANT_PUBLIC })
  429. //.sort({createdAt: -1}) // TODO optionize
  430. .skip(offset)
  431. .limit(limit)
  432. .populate([
  433. {path: 'creator', model: 'User', select: User.USER_PUBLIC_FIELDS},
  434. {path: 'revision', model: 'Revision'},
  435. ])
  436. .exec(function(err, pages) {
  437. if (err) {
  438. return reject(err);
  439. }
  440. Page.populate(pages, {path: 'revision.author', model: 'User', select: User.USER_PUBLIC_FIELDS}, function(err, data) {
  441. if (err) {
  442. return reject(err);
  443. }
  444. return resolve(data);
  445. });
  446. });
  447. });
  448. };
  449. pageSchema.statics.findListByCreator = function(user, option, currentUser) {
  450. var Page = this;
  451. var User = crowi.model('User');
  452. var limit = option.limit || 50;
  453. var offset = option.offset || 0;
  454. var conditions = { creator: user._id, redirectTo: null };
  455. if (!user.equals(currentUser._id)) {
  456. conditions.grant = GRANT_PUBLIC;
  457. }
  458. return new Promise(function(resolve, reject) {
  459. Page
  460. .find(conditions)
  461. .sort({createdAt: -1})
  462. .skip(offset)
  463. .limit(limit)
  464. .populate('revision')
  465. .exec()
  466. .then(function(pages) {
  467. return Page.populate(pages, {path: 'revision.author', model: 'User', select: User.USER_PUBLIC_FIELDS}).then(resolve);
  468. });
  469. });
  470. };
  471. /**
  472. * Bulk get (for internal only)
  473. */
  474. pageSchema.statics.getStreamOfFindAll = function(options) {
  475. var Page = this
  476. , options = options || {}
  477. , publicOnly = options.publicOnly || true
  478. , criteria = {redirectTo: null,}
  479. ;
  480. if (publicOnly) {
  481. criteria.grant = GRANT_PUBLIC;
  482. }
  483. return this.find(criteria)
  484. .populate([
  485. {path: 'creator', model: 'User'},
  486. {path: 'revision', model: 'Revision'},
  487. ])
  488. .sort({updatedAt: -1})
  489. .cursor();
  490. };
  491. /**
  492. * findListByStartWith
  493. *
  494. * If `path` has `/` at the end, returns '{path}/*' and '{path}' self.
  495. * If `path` doesn't have `/` at the end, returns '{path}*'
  496. * e.g.
  497. */
  498. pageSchema.statics.findListByStartWith = function(path, userData, option) {
  499. var Page = this;
  500. var User = crowi.model('User');
  501. var pathCondition = [];
  502. var includeDeletedPage = option.includeDeletedPage || false
  503. if (!option) {
  504. option = {sort: 'updatedAt', desc: -1, offset: 0, limit: 50};
  505. }
  506. var opt = {
  507. sort: option.sort || 'updatedAt',
  508. desc: option.desc || -1,
  509. offset: option.offset || 0,
  510. limit: option.limit || 50
  511. };
  512. var sortOpt = {};
  513. sortOpt[opt.sort] = opt.desc;
  514. var queryReg = new RegExp('^' + path);
  515. var sliceOption = option.revisionSlice || {$slice: 1};
  516. pathCondition.push({path: queryReg});
  517. if (path.match(/\/$/)) {
  518. debug('Page list by ending with /, so find also upper level page');
  519. pathCondition.push({path: path.substr(0, path.length -1)});
  520. }
  521. return new Promise(function(resolve, reject) {
  522. // FIXME: might be heavy
  523. var q = Page.find({
  524. redirectTo: null,
  525. $or: [
  526. {grant: null},
  527. {grant: GRANT_PUBLIC},
  528. {grant: GRANT_RESTRICTED, grantedUsers: userData._id},
  529. {grant: GRANT_SPECIFIED, grantedUsers: userData._id},
  530. {grant: GRANT_OWNER, grantedUsers: userData._id},
  531. ],})
  532. .populate('revision')
  533. .and({
  534. $or: pathCondition
  535. })
  536. .sort(sortOpt)
  537. .skip(opt.offset)
  538. .limit(opt.limit);
  539. if (!includeDeletedPage) {
  540. q.and({
  541. $or: [
  542. {status: null},
  543. {status: STATUS_PUBLISHED},
  544. ],
  545. });
  546. }
  547. q.exec()
  548. .then(function(pages) {
  549. Page.populate(pages, {path: 'revision.author', model: 'User', select: User.USER_PUBLIC_FIELDS})
  550. .then(resolve)
  551. .catch(reject);
  552. })
  553. });
  554. };
  555. pageSchema.statics.updatePageProperty = function(page, updateData) {
  556. var Page = this;
  557. return new Promise(function(resolve, reject) {
  558. // TODO foreach して save
  559. Page.update({_id: page._id}, {$set: updateData}, function(err, data) {
  560. if (err) {
  561. return reject(err);
  562. }
  563. return resolve(data);
  564. });
  565. });
  566. };
  567. pageSchema.statics.updateGrant = function(page, grant, userData) {
  568. var Page = this;
  569. return new Promise(function(resolve, reject) {
  570. page.grant = grant;
  571. if (grant == GRANT_PUBLIC) {
  572. page.grantedUsers = [];
  573. } else {
  574. page.grantedUsers = [];
  575. page.grantedUsers.push(userData._id);
  576. }
  577. page.save(function(err, data) {
  578. debug('Page.updateGrant, saved grantedUsers.', err, data);
  579. if (err) {
  580. return reject(err);
  581. }
  582. return resolve(data);
  583. });
  584. });
  585. };
  586. // Instance method でいいのでは
  587. pageSchema.statics.pushToGrantedUsers = function(page, userData) {
  588. return new Promise(function(resolve, reject) {
  589. if (!page.grantedUsers || !Array.isArray(page.grantedUsers)) {
  590. page.grantedUsers = [];
  591. }
  592. page.grantedUsers.push(userData);
  593. page.save(function(err, data) {
  594. if (err) {
  595. return reject(err);
  596. }
  597. return resolve(data);
  598. });
  599. });
  600. };
  601. pageSchema.statics.pushRevision = function(pageData, newRevision, user) {
  602. var isCreate = false;
  603. if (pageData.revision === undefined) {
  604. debug('pushRevision on Create');
  605. isCreate = true;
  606. }
  607. return new Promise(function(resolve, reject) {
  608. newRevision.save(function(err, newRevision) {
  609. if (err) {
  610. debug('Error on saving revision', err);
  611. return reject(err);
  612. }
  613. debug('Successfully saved new revision', newRevision);
  614. pageData.revision = newRevision;
  615. pageData.lastUpdateUser = user;
  616. pageData.updatedAt = Date.now();
  617. pageData.save(function(err, data) {
  618. if (err) {
  619. // todo: remove new revision?
  620. debug('Error on save page data (after push revision)', err);
  621. return reject(err);
  622. }
  623. resolve(data);
  624. if (!isCreate) {
  625. debug('pushRevision on Update');
  626. }
  627. });
  628. });
  629. });
  630. };
  631. pageSchema.statics.create = function(path, body, user, options) {
  632. var Page = this
  633. , Revision = crowi.model('Revision')
  634. , format = options.format || 'markdown'
  635. , grant = options.grant || GRANT_PUBLIC
  636. , redirectTo = options.redirectTo || null;
  637. // force public
  638. if (isPortalPath(path)) {
  639. grant = GRANT_PUBLIC;
  640. }
  641. return new Promise(function(resolve, reject) {
  642. Page.findOne({path: path}, function(err, pageData) {
  643. if (pageData) {
  644. return reject(new Error('Cannot create new page to existed path'));
  645. }
  646. var newPage = new Page();
  647. newPage.path = path;
  648. newPage.creator = user;
  649. newPage.lastUpdateUser = user;
  650. newPage.createdAt = Date.now();
  651. newPage.updatedAt = Date.now();
  652. newPage.redirectTo = redirectTo;
  653. newPage.grant = grant;
  654. newPage.status = STATUS_PUBLISHED;
  655. newPage.grantedUsers = [];
  656. newPage.grantedUsers.push(user);
  657. newPage.save(function (err, newPage) {
  658. if (err) {
  659. return reject(err);
  660. }
  661. var newRevision = Revision.prepareRevision(newPage, body, user, {format: format});
  662. Page.pushRevision(newPage, newRevision, user).then(function(data) {
  663. resolve(data);
  664. pageEvent.emit('create', data, user);
  665. }).catch(function(err) {
  666. debug('Push Revision Error on create page', err);
  667. return reject(err);
  668. });
  669. });
  670. });
  671. });
  672. };
  673. pageSchema.statics.updatePage = function(pageData, body, user, options) {
  674. var Page = this
  675. , Revision = crowi.model('Revision')
  676. , grant = options.grant || null
  677. ;
  678. // update existing page
  679. var newRevision = Revision.prepareRevision(pageData, body, user);
  680. return new Promise(function(resolve, reject) {
  681. Page.pushRevision(pageData, newRevision, user)
  682. .then(function(revision) {
  683. if (grant != pageData.grant) {
  684. return Page.updateGrant(pageData, grant, user).then(function(data) {
  685. debug('Page grant update:', data);
  686. resolve(data);
  687. pageEvent.emit('update', data, user);
  688. });
  689. } else {
  690. resolve(pageData);
  691. pageEvent.emit('update', pageData, user);
  692. }
  693. }).catch(function(err) {
  694. debug('Error on update', err);
  695. debug('Error on update', err.stack);
  696. });
  697. });
  698. };
  699. pageSchema.statics.deletePage = function(pageData, user, options) {
  700. var Page = this
  701. , newPath = Page.getDeletedPageName(pageData.path)
  702. ;
  703. if (Page.isDeletableName(pageData.path)) {
  704. return new Promise(function(resolve, reject) {
  705. Page.updatePageProperty(pageData, {status: STATUS_DELETED, lastUpdateUser: user})
  706. .then(function(data) {
  707. pageData.status = STATUS_DELETED;
  708. // ページ名が /trash/ 以下に存在する場合、おかしなことになる
  709. // が、 /trash 以下にページが有るのは、個別に作っていたケースのみ。
  710. // 一応しばらく前から uncreatable pages になっているのでこれでいいことにする
  711. debug('Deleted the page, and rename it', pageData.path, newPath);
  712. return Page.rename(pageData, newPath, user, {createRedirectPage: true})
  713. }).then(function(pageData) {
  714. resolve(pageData);
  715. }).catch(reject);
  716. });
  717. } else {
  718. return Promise.reject('Page is not deletable.');
  719. }
  720. };
  721. pageSchema.statics.revertDeletedPage = function(pageData, user, options) {
  722. var Page = this
  723. , newPath = Page.getRevertDeletedPageName(pageData.path)
  724. ;
  725. // 削除時、元ページの path には必ず redirectTo 付きで、ページが作成される。
  726. // そのため、そいつは削除してOK
  727. // が、redirectTo ではないページが存在している場合それは何かがおかしい。(データ補正が必要)
  728. return new Promise(function(resolve, reject) {
  729. Page.findPageByPath(newPath)
  730. .then(function(originPageData) {
  731. if (originPageData.redirectTo !== pageData.path) {
  732. throw new Error('The new page of to revert is exists and the redirect path of the page is not the deleted page.');
  733. }
  734. return Page.completelyDeletePage(originPageData);
  735. }).then(function(done) {
  736. return Page.updatePageProperty(pageData, {status: STATUS_PUBLISHED, lastUpdateUser: user})
  737. }).then(function(done) {
  738. pageData.status = STATUS_PUBLISHED;
  739. debug('Revert deleted the page, and rename again it', pageData, newPath);
  740. return Page.rename(pageData, newPath, user, {})
  741. }).then(function(done) {
  742. pageData.path = newPath;
  743. resolve(pageData);
  744. }).catch(reject);
  745. });
  746. };
  747. /**
  748. * This is danger.
  749. */
  750. pageSchema.statics.completelyDeletePage = function(pageData, user, options) {
  751. // Delete Bookmarks, Attachments, Revisions, Pages and emit delete
  752. var Bookmark = crowi.model('Bookmark')
  753. , Attachment = crowi.model('Attachment')
  754. , Comment = crowi.model('Comment')
  755. , Revision = crowi.model('Revision')
  756. , Page = this
  757. , pageId = pageData._id
  758. ;
  759. debug('Completely delete', pageData.path);
  760. return new Promise(function(resolve, reject) {
  761. Bookmark.removeBookmarksByPageId(pageId)
  762. .then(function(done) {
  763. }).then(function(done) {
  764. return Attachment.removeAttachmentsByPageId(pageId);
  765. }).then(function(done) {
  766. return Comment.removeCommentsByPageId(pageId);
  767. }).then(function(done) {
  768. return Revision.removeRevisionsByPath(pageData.path);
  769. }).then(function(done) {
  770. return Page.removePageById(pageId);
  771. }).then(function(done) {
  772. pageEvent.emit('delete', pageData, user); // update as renamed page
  773. resolve();
  774. }).catch(reject);
  775. });
  776. };
  777. pageSchema.statics.removePageById = function(pageId) {
  778. var Page = this;
  779. return new Promise(function(resolve, reject) {
  780. Page.remove({_id: pageId}, function(err, done) {
  781. debug('Remove phisiaclly, the page', pageId, err, done);
  782. if (err) {
  783. return reject(err);
  784. }
  785. resolve(done);
  786. });
  787. });
  788. };
  789. pageSchema.statics.rename = function(pageData, newPagePath, user, options) {
  790. var Page = this
  791. , Revision = crowi.model('Revision')
  792. , path = pageData.path
  793. , createRedirectPage = options.createRedirectPage || 0
  794. , moveUnderTrees = options.moveUnderTrees || 0;
  795. return new Promise(function(resolve, reject) {
  796. // pageData の path を変更
  797. Page.updatePageProperty(pageData, {updatedAt: Date.now(), path: newPagePath, lastUpdateUser: user})
  798. .then(function(data) {
  799. // reivisions の path を変更
  800. return Revision.updateRevisionListByPath(path, {path: newPagePath}, {})
  801. }).then(function(data) {
  802. pageData.path = newPagePath;
  803. if (createRedirectPage) {
  804. var body = 'redirect ' + newPagePath;
  805. Page.create(path, body, user, {redirectTo: newPagePath}).then(resolve).catch(reject);
  806. } else {
  807. resolve(data);
  808. }
  809. pageEvent.emit('update', pageData, user); // update as renamed page
  810. });
  811. });
  812. };
  813. pageSchema.statics.getHistories = function() {
  814. // TODO
  815. return;
  816. };
  817. pageSchema.statics.GRANT_PUBLIC = GRANT_PUBLIC;
  818. pageSchema.statics.GRANT_RESTRICTED = GRANT_RESTRICTED;
  819. pageSchema.statics.GRANT_SPECIFIED = GRANT_SPECIFIED;
  820. pageSchema.statics.GRANT_OWNER = GRANT_OWNER;
  821. pageSchema.statics.PAGE_GRANT_ERROR = PAGE_GRANT_ERROR;
  822. return mongoose.model('Page', pageSchema);
  823. };