page.js 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961
  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] = '公開';
  279. grantLabels[GRANT_RESTRICTED] = 'リンクを知っている人のみ';
  280. //grantLabels[GRANT_SPECIFIED] = '特定ユーザーのみ';
  281. grantLabels[GRANT_OWNER] = '自分のみ';
  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. /\/{2,}/, // avoid miss in renaming
  323. /.+\/edit$/,
  324. /.+\.md$/,
  325. /^\/(installer|register|login|logout|admin|me|files|trash|paste|comments)(\/.*|$)/,
  326. ];
  327. var isCreatable = true;
  328. forbiddenPages.forEach(function(page) {
  329. var pageNameReg = new RegExp(page);
  330. if (name.match(pageNameReg)) {
  331. isCreatable = false;
  332. return ;
  333. }
  334. });
  335. return isCreatable;
  336. };
  337. pageSchema.statics.fixToCreatableName = function(path) {
  338. return path
  339. .replace(/\/\//g, '/')
  340. ;
  341. };
  342. pageSchema.statics.updateRevision = function(pageId, revisionId, cb) {
  343. this.update({_id: pageId}, {revision: revisionId}, {}, function(err, data) {
  344. cb(err, data);
  345. });
  346. };
  347. pageSchema.statics.findUpdatedList = function(offset, limit, cb) {
  348. this
  349. .find({})
  350. .sort({updatedAt: -1})
  351. .skip(offset)
  352. .limit(limit)
  353. .exec(function(err, data) {
  354. cb(err, data);
  355. });
  356. };
  357. pageSchema.statics.findPageById = function(id) {
  358. var Page = this;
  359. return new Promise(function(resolve, reject) {
  360. Page.findOne({_id: id}, function(err, pageData) {
  361. if (err) {
  362. return reject(err);
  363. }
  364. if (pageData == null) {
  365. return reject(new Error('Page not found'));
  366. }
  367. return Page.populatePageData(pageData, null).then(resolve);
  368. });
  369. });
  370. };
  371. pageSchema.statics.findPageByIdAndGrantedUser = function(id, userData) {
  372. var Page = this;
  373. return new Promise(function(resolve, reject) {
  374. Page.findPageById(id)
  375. .then(function(pageData) {
  376. if (userData && !pageData.isGrantedFor(userData)) {
  377. return reject(new Error('Page is not granted for the user')); //PAGE_GRANT_ERROR, null);
  378. }
  379. return resolve(pageData);
  380. }).catch(function(err) {
  381. return reject(err);
  382. });
  383. });
  384. };
  385. // find page and check if granted user
  386. pageSchema.statics.findPage = function(path, userData, revisionId, ignoreNotFound) {
  387. var self = this;
  388. return new Promise(function(resolve, reject) {
  389. self.findOne({path: path}, function(err, pageData) {
  390. if (err) {
  391. return reject(err);
  392. }
  393. if (pageData === null) {
  394. if (ignoreNotFound) {
  395. return resolve(null);
  396. }
  397. var pageNotFoundError = new Error('Page Not Found')
  398. pageNotFoundError.name = 'Crowi:Page:NotFound';
  399. return reject(pageNotFoundError);
  400. }
  401. if (!pageData.isGrantedFor(userData)) {
  402. return reject(new Error('Page is not granted for the user')); //PAGE_GRANT_ERROR, null);
  403. }
  404. self.populatePageData(pageData, revisionId || null).then(resolve).catch(reject);
  405. });
  406. });
  407. };
  408. // find page by path
  409. pageSchema.statics.findPageByPath = function(path) {
  410. var Page = this;
  411. return new Promise(function(resolve, reject) {
  412. Page.findOne({path: path}, function(err, pageData) {
  413. if (err || pageData === null) {
  414. return reject(err);
  415. }
  416. return resolve(pageData);
  417. });
  418. });
  419. };
  420. pageSchema.statics.findListByPageIds = function(ids, options) {
  421. var Page = this;
  422. var User = crowi.model('User');
  423. var options = options || {}
  424. , limit = options.limit || 50
  425. , offset = options.skip || 0
  426. ;
  427. return new Promise(function(resolve, reject) {
  428. Page
  429. .find({ _id: { $in: ids }, grant: GRANT_PUBLIC })
  430. //.sort({createdAt: -1}) // TODO optionize
  431. .skip(offset)
  432. .limit(limit)
  433. .populate([
  434. {path: 'creator', model: 'User', select: User.USER_PUBLIC_FIELDS},
  435. {path: 'revision', model: 'Revision'},
  436. ])
  437. .exec(function(err, pages) {
  438. if (err) {
  439. return reject(err);
  440. }
  441. Page.populate(pages, {path: 'revision.author', model: 'User', select: User.USER_PUBLIC_FIELDS}, function(err, data) {
  442. if (err) {
  443. return reject(err);
  444. }
  445. return resolve(data);
  446. });
  447. });
  448. });
  449. };
  450. pageSchema.statics.findListByCreator = function(user, option, currentUser) {
  451. var Page = this;
  452. var User = crowi.model('User');
  453. var limit = option.limit || 50;
  454. var offset = option.offset || 0;
  455. var conditions = { creator: user._id, redirectTo: null };
  456. if (!user.equals(currentUser._id)) {
  457. conditions.grant = GRANT_PUBLIC;
  458. }
  459. return new Promise(function(resolve, reject) {
  460. Page
  461. .find(conditions)
  462. .sort({createdAt: -1})
  463. .skip(offset)
  464. .limit(limit)
  465. .populate('revision')
  466. .exec()
  467. .then(function(pages) {
  468. return Page.populate(pages, {path: 'revision.author', model: 'User', select: User.USER_PUBLIC_FIELDS}).then(resolve);
  469. });
  470. });
  471. };
  472. /**
  473. * Bulk get (for internal only)
  474. */
  475. pageSchema.statics.getStreamOfFindAll = function(options) {
  476. var Page = this
  477. , options = options || {}
  478. , publicOnly = options.publicOnly || true
  479. , criteria = {redirectTo: null,}
  480. ;
  481. if (publicOnly) {
  482. criteria.grant = GRANT_PUBLIC;
  483. }
  484. return this.find(criteria)
  485. .populate([
  486. {path: 'creator', model: 'User'},
  487. {path: 'revision', model: 'Revision'},
  488. ])
  489. .sort({updatedAt: -1})
  490. .stream();
  491. };
  492. /**
  493. * findListByStartWith
  494. *
  495. * If `path` has `/` at the end, returns '{path}/*' and '{path}' self.
  496. * If `path` doesn't have `/` at the end, returns '{path}*'
  497. * e.g.
  498. */
  499. pageSchema.statics.findListByStartWith = function(path, userData, option) {
  500. var Page = this;
  501. var User = crowi.model('User');
  502. var pathCondition = [];
  503. var includeDeletedPage = option.includeDeletedPage || false
  504. if (!option) {
  505. option = {sort: 'updatedAt', desc: -1, offset: 0, limit: 50};
  506. }
  507. var opt = {
  508. sort: option.sort || 'updatedAt',
  509. desc: option.desc || -1,
  510. offset: option.offset || 0,
  511. limit: option.limit || 50
  512. };
  513. var sortOpt = {};
  514. sortOpt[opt.sort] = opt.desc;
  515. var queryReg = new RegExp('^' + path);
  516. var sliceOption = option.revisionSlice || {$slice: 1};
  517. pathCondition.push({path: queryReg});
  518. if (path.match(/\/$/)) {
  519. debug('Page list by ending with /, so find also upper level page');
  520. pathCondition.push({path: path.substr(0, path.length -1)});
  521. }
  522. return new Promise(function(resolve, reject) {
  523. // FIXME: might be heavy
  524. var q = Page.find({
  525. redirectTo: null,
  526. $or: [
  527. {grant: null},
  528. {grant: GRANT_PUBLIC},
  529. {grant: GRANT_RESTRICTED, grantedUsers: userData._id},
  530. {grant: GRANT_SPECIFIED, grantedUsers: userData._id},
  531. {grant: GRANT_OWNER, grantedUsers: userData._id},
  532. ],})
  533. .populate('revision')
  534. .and({
  535. $or: pathCondition
  536. })
  537. .sort(sortOpt)
  538. .skip(opt.offset)
  539. .limit(opt.limit);
  540. if (!includeDeletedPage) {
  541. q.and({
  542. $or: [
  543. {status: null},
  544. {status: STATUS_PUBLISHED},
  545. ],
  546. });
  547. }
  548. q.exec()
  549. .then(function(pages) {
  550. Page.populate(pages, {path: 'revision.author', model: 'User', select: User.USER_PUBLIC_FIELDS})
  551. .then(resolve)
  552. .catch(reject);
  553. })
  554. });
  555. };
  556. pageSchema.statics.updatePageProperty = function(page, updateData) {
  557. var Page = this;
  558. return new Promise(function(resolve, reject) {
  559. // TODO foreach して save
  560. Page.update({_id: page._id}, {$set: updateData}, function(err, data) {
  561. if (err) {
  562. return reject(err);
  563. }
  564. return resolve(data);
  565. });
  566. });
  567. };
  568. pageSchema.statics.updateGrant = function(page, grant, userData) {
  569. var Page = this;
  570. return new Promise(function(resolve, reject) {
  571. page.grant = grant;
  572. if (grant == GRANT_PUBLIC) {
  573. page.grantedUsers = [];
  574. } else {
  575. page.grantedUsers = [];
  576. page.grantedUsers.push(userData._id);
  577. }
  578. page.save(function(err, data) {
  579. debug('Page.updateGrant, saved grantedUsers.', err, data);
  580. if (err) {
  581. return reject(err);
  582. }
  583. return resolve(data);
  584. });
  585. });
  586. };
  587. // Instance method でいいのでは
  588. pageSchema.statics.pushToGrantedUsers = function(page, userData) {
  589. return new Promise(function(resolve, reject) {
  590. if (!page.grantedUsers || !Array.isArray(page.grantedUsers)) {
  591. page.grantedUsers = [];
  592. }
  593. page.grantedUsers.push(userData);
  594. page.save(function(err, data) {
  595. if (err) {
  596. return reject(err);
  597. }
  598. return resolve(data);
  599. });
  600. });
  601. };
  602. pageSchema.statics.pushRevision = function(pageData, newRevision, user) {
  603. var isCreate = false;
  604. if (pageData.revision === undefined) {
  605. debug('pushRevision on Create');
  606. isCreate = true;
  607. }
  608. return new Promise(function(resolve, reject) {
  609. newRevision.save(function(err, newRevision) {
  610. if (err) {
  611. debug('Error on saving revision', err);
  612. return reject(err);
  613. }
  614. debug('Successfully saved new revision', newRevision);
  615. pageData.revision = newRevision;
  616. pageData.lastUpdateUser = user;
  617. pageData.updatedAt = Date.now();
  618. pageData.save(function(err, data) {
  619. if (err) {
  620. // todo: remove new revision?
  621. debug('Error on save page data (after push revision)', err);
  622. return reject(err);
  623. }
  624. resolve(data);
  625. if (!isCreate) {
  626. debug('pushRevision on Update');
  627. }
  628. });
  629. });
  630. });
  631. };
  632. pageSchema.statics.create = function(path, body, user, options) {
  633. var Page = this
  634. , Revision = crowi.model('Revision')
  635. , format = options.format || 'markdown'
  636. , grant = options.grant || GRANT_PUBLIC
  637. , redirectTo = options.redirectTo || null;
  638. // force public
  639. if (isPortalPath(path)) {
  640. grant = GRANT_PUBLIC;
  641. }
  642. return new Promise(function(resolve, reject) {
  643. Page.findOne({path: path}, function(err, pageData) {
  644. if (pageData) {
  645. return reject(new Error('Cannot create new page to existed path'));
  646. }
  647. var newPage = new Page();
  648. newPage.path = path;
  649. newPage.creator = user;
  650. newPage.lastUpdateUser = user;
  651. newPage.createdAt = Date.now();
  652. newPage.updatedAt = Date.now();
  653. newPage.redirectTo = redirectTo;
  654. newPage.grant = grant;
  655. newPage.status = STATUS_PUBLISHED;
  656. newPage.grantedUsers = [];
  657. newPage.grantedUsers.push(user);
  658. newPage.save(function (err, newPage) {
  659. if (err) {
  660. return reject(err);
  661. }
  662. var newRevision = Revision.prepareRevision(newPage, body, user, {format: format});
  663. Page.pushRevision(newPage, newRevision, user).then(function(data) {
  664. resolve(data);
  665. pageEvent.emit('create', data, user);
  666. }).catch(function(err) {
  667. debug('Push Revision Error on create page', err);
  668. return reject(err);
  669. });
  670. });
  671. });
  672. });
  673. };
  674. pageSchema.statics.updatePage = function(pageData, body, user, options) {
  675. var Page = this
  676. , Revision = crowi.model('Revision')
  677. , grant = options.grant || null
  678. ;
  679. // update existing page
  680. var newRevision = Revision.prepareRevision(pageData, body, user);
  681. return new Promise(function(resolve, reject) {
  682. Page.pushRevision(pageData, newRevision, user)
  683. .then(function(revision) {
  684. if (grant != pageData.grant) {
  685. return Page.updateGrant(pageData, grant, user).then(function(data) {
  686. debug('Page grant update:', data);
  687. resolve(data);
  688. pageEvent.emit('update', data, user);
  689. });
  690. } else {
  691. resolve(pageData);
  692. pageEvent.emit('update', pageData, user);
  693. }
  694. }).catch(function(err) {
  695. debug('Error on update', err);
  696. debug('Error on update', err.stack);
  697. });
  698. });
  699. };
  700. pageSchema.statics.deletePage = function(pageData, user, options) {
  701. var Page = this
  702. , newPath = Page.getDeletedPageName(pageData.path)
  703. ;
  704. if (Page.isDeletableName(pageData.path)) {
  705. return new Promise(function(resolve, reject) {
  706. Page.updatePageProperty(pageData, {status: STATUS_DELETED, lastUpdateUser: user})
  707. .then(function(data) {
  708. pageData.status = STATUS_DELETED;
  709. // ページ名が /trash/ 以下に存在する場合、おかしなことになる
  710. // が、 /trash 以下にページが有るのは、個別に作っていたケースのみ。
  711. // 一応しばらく前から uncreatable pages になっているのでこれでいいことにする
  712. debug('Deleted the page, and rename it', pageData.path, newPath);
  713. return Page.rename(pageData, newPath, user, {createRedirectPage: true})
  714. }).then(function(pageData) {
  715. resolve(pageData);
  716. }).catch(reject);
  717. });
  718. } else {
  719. return Promise.reject('Page is not deletable.');
  720. }
  721. };
  722. pageSchema.statics.revertDeletedPage = function(pageData, user, options) {
  723. var Page = this
  724. , newPath = Page.getRevertDeletedPageName(pageData.path)
  725. ;
  726. // 削除時、元ページの path には必ず redirectTo 付きで、ページが作成される。
  727. // そのため、そいつは削除してOK
  728. // が、redirectTo ではないページが存在している場合それは何かがおかしい。(データ補正が必要)
  729. return new Promise(function(resolve, reject) {
  730. Page.findPageByPath(newPath)
  731. .then(function(originPageData) {
  732. if (originPageData.redirectTo !== pageData.path) {
  733. throw new Error('The new page of to revert is exists and the redirect path of the page is not the deleted page.');
  734. }
  735. return Page.completelyDeletePage(originPageData);
  736. }).then(function(done) {
  737. return Page.updatePageProperty(pageData, {status: STATUS_PUBLISHED, lastUpdateUser: user})
  738. }).then(function(done) {
  739. pageData.status = STATUS_PUBLISHED;
  740. debug('Revert deleted the page, and rename again it', pageData, newPath);
  741. return Page.rename(pageData, newPath, user, {})
  742. }).then(function(done) {
  743. pageData.path = newPath;
  744. resolve(pageData);
  745. }).catch(reject);
  746. });
  747. };
  748. /**
  749. * This is danger.
  750. */
  751. pageSchema.statics.completelyDeletePage = function(pageData, user, options) {
  752. // Delete Bookmarks, Attachments, Revisions, Pages and emit delete
  753. var Bookmark = crowi.model('Bookmark')
  754. , Attachment = crowi.model('Attachment')
  755. , Comment = crowi.model('Comment')
  756. , Revision = crowi.model('Revision')
  757. , Page = this
  758. , pageId = pageData._id
  759. ;
  760. debug('Completely delete', pageData.path);
  761. return new Promise(function(resolve, reject) {
  762. Bookmark.removeBookmarksByPageId(pageId)
  763. .then(function(done) {
  764. }).then(function(done) {
  765. return Attachment.removeAttachmentsByPageId(pageId);
  766. }).then(function(done) {
  767. return Comment.removeCommentsByPageId(pageId);
  768. }).then(function(done) {
  769. return Revision.removeRevisionsByPath(pageData.path);
  770. }).then(function(done) {
  771. return Page.removePageById(pageId);
  772. }).then(function(done) {
  773. pageEvent.emit('delete', pageData, user); // update as renamed page
  774. resolve();
  775. }).catch(reject);
  776. });
  777. };
  778. pageSchema.statics.removePageById = function(pageId) {
  779. var Page = this;
  780. return new Promise(function(resolve, reject) {
  781. Page.remove({_id: pageId}, function(err, done) {
  782. debug('Remove phisiaclly, the page', pageId, err, done);
  783. if (err) {
  784. return reject(err);
  785. }
  786. resolve(done);
  787. });
  788. });
  789. };
  790. pageSchema.statics.rename = function(pageData, newPagePath, user, options) {
  791. var Page = this
  792. , Revision = crowi.model('Revision')
  793. , path = pageData.path
  794. , createRedirectPage = options.createRedirectPage || 0
  795. , moveUnderTrees = options.moveUnderTrees || 0;
  796. return new Promise(function(resolve, reject) {
  797. // pageData の path を変更
  798. Page.updatePageProperty(pageData, {updatedAt: Date.now(), path: newPagePath, lastUpdateUser: user})
  799. .then(function(data) {
  800. // reivisions の path を変更
  801. return Revision.updateRevisionListByPath(path, {path: newPagePath}, {})
  802. }).then(function(data) {
  803. pageData.path = newPagePath;
  804. if (createRedirectPage) {
  805. var body = 'redirect ' + newPagePath;
  806. Page.create(path, body, user, {redirectTo: newPagePath}).then(resolve).catch(reject);
  807. } else {
  808. resolve(data);
  809. }
  810. pageEvent.emit('update', pageData, user); // update as renamed page
  811. });
  812. });
  813. };
  814. pageSchema.statics.getHistories = function() {
  815. // TODO
  816. return;
  817. };
  818. pageSchema.statics.GRANT_PUBLIC = GRANT_PUBLIC;
  819. pageSchema.statics.GRANT_RESTRICTED = GRANT_RESTRICTED;
  820. pageSchema.statics.GRANT_SPECIFIED = GRANT_SPECIFIED;
  821. pageSchema.statics.GRANT_OWNER = GRANT_OWNER;
  822. pageSchema.statics.PAGE_GRANT_ERROR = PAGE_GRANT_ERROR;
  823. return mongoose.model('Page', pageSchema);
  824. };