users.js 63 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531
  1. import { ReactiveCache } from '/imports/reactiveCache';
  2. import { SyncedCron } from 'meteor/percolate:synced-cron';
  3. import { TAPi18n } from '/imports/i18n';
  4. import ImpersonatedUsers from './impersonatedUsers';
  5. import { Index, MongoDBEngine } from 'meteor/easy:search';
  6. // Sandstorm context is detected using the METEOR_SETTINGS environment variable
  7. // in the package definition.
  8. const isSandstorm =
  9. Meteor.settings && Meteor.settings.public && Meteor.settings.public.sandstorm;
  10. Users = Meteor.users;
  11. const allowedSortValues = [
  12. '-modifiedAt',
  13. 'modifiedAt',
  14. '-title',
  15. 'title',
  16. '-sort',
  17. 'sort',
  18. ];
  19. const defaultSortBy = allowedSortValues[0];
  20. /**
  21. * A User in wekan
  22. */
  23. Users.attachSchema(
  24. new SimpleSchema({
  25. username: {
  26. /**
  27. * the username of the user
  28. */
  29. type: String,
  30. optional: true,
  31. // eslint-disable-next-line consistent-return
  32. autoValue() {
  33. if (this.isInsert && !this.isSet) {
  34. const name = this.field('profile.fullname');
  35. if (name.isSet) {
  36. return name.value.toLowerCase().replace(/\s/g, '');
  37. }
  38. }
  39. },
  40. },
  41. orgs: {
  42. /**
  43. * the list of organizations that a user belongs to
  44. */
  45. type: [Object],
  46. optional: true,
  47. },
  48. 'orgs.$.orgId': {
  49. /**
  50. * The uniq ID of the organization
  51. */
  52. type: String,
  53. },
  54. 'orgs.$.orgDisplayName': {
  55. /**
  56. * The display name of the organization
  57. */
  58. type: String,
  59. },
  60. teams: {
  61. /**
  62. * the list of teams that a user belongs to
  63. */
  64. type: [Object],
  65. optional: true,
  66. },
  67. 'teams.$.teamId': {
  68. /**
  69. * The uniq ID of the team
  70. */
  71. type: String,
  72. },
  73. 'teams.$.teamDisplayName': {
  74. /**
  75. * The display name of the team
  76. */
  77. type: String,
  78. },
  79. emails: {
  80. /**
  81. * the list of emails attached to a user
  82. */
  83. type: [Object],
  84. optional: true,
  85. },
  86. 'emails.$.address': {
  87. /**
  88. * The email address
  89. */
  90. type: String,
  91. regEx: SimpleSchema.RegEx.Email,
  92. },
  93. 'emails.$.verified': {
  94. /**
  95. * Has the email been verified
  96. */
  97. type: Boolean,
  98. },
  99. createdAt: {
  100. /**
  101. * creation date of the user
  102. */
  103. type: Date,
  104. // eslint-disable-next-line consistent-return
  105. autoValue() {
  106. if (this.isInsert) {
  107. return new Date();
  108. } else if (this.isUpsert) {
  109. return {
  110. $setOnInsert: new Date(),
  111. };
  112. } else {
  113. this.unset();
  114. }
  115. },
  116. },
  117. modifiedAt: {
  118. type: Date,
  119. denyUpdate: false,
  120. // eslint-disable-next-line consistent-return
  121. autoValue() {
  122. if (this.isInsert || this.isUpsert || this.isUpdate) {
  123. return new Date();
  124. } else {
  125. this.unset();
  126. }
  127. },
  128. },
  129. profile: {
  130. /**
  131. * profile settings
  132. */
  133. type: Object,
  134. optional: true,
  135. // eslint-disable-next-line consistent-return
  136. autoValue() {
  137. if (this.isInsert && !this.isSet) {
  138. return {
  139. boardView: 'board-view-swimlanes',
  140. };
  141. }
  142. },
  143. },
  144. 'profile.avatarUrl': {
  145. /**
  146. * URL of the avatar of the user
  147. */
  148. type: String,
  149. optional: true,
  150. },
  151. 'profile.emailBuffer': {
  152. /**
  153. * list of email buffers of the user
  154. */
  155. type: [String],
  156. optional: true,
  157. },
  158. 'profile.fullname': {
  159. /**
  160. * full name of the user
  161. */
  162. type: String,
  163. optional: true,
  164. },
  165. 'profile.showDesktopDragHandles': {
  166. /**
  167. * does the user want to show desktop drag handles?
  168. */
  169. type: Boolean,
  170. optional: true,
  171. },
  172. 'profile.hideCheckedItems': {
  173. /**
  174. * does the user want to hide checked checklist items?
  175. */
  176. type: Boolean,
  177. optional: true,
  178. },
  179. 'profile.cardMaximized': {
  180. /**
  181. * has user clicked maximize card?
  182. */
  183. type: Boolean,
  184. optional: true,
  185. },
  186. 'profile.customFieldsGrid': {
  187. /**
  188. * has user at card Custom Fields have Grid (false) or one per row (true) layout?
  189. */
  190. type: Boolean,
  191. optional: true,
  192. },
  193. 'profile.hiddenSystemMessages': {
  194. /**
  195. * does the user want to hide system messages?
  196. */
  197. type: Boolean,
  198. optional: true,
  199. },
  200. 'profile.hiddenMinicardLabelText': {
  201. /**
  202. * does the user want to hide minicard label texts?
  203. */
  204. type: Boolean,
  205. optional: true,
  206. },
  207. 'profile.initials': {
  208. /**
  209. * initials of the user
  210. */
  211. type: String,
  212. optional: true,
  213. },
  214. 'profile.invitedBoards': {
  215. /**
  216. * board IDs the user has been invited to
  217. */
  218. type: [String],
  219. optional: true,
  220. },
  221. 'profile.language': {
  222. /**
  223. * language of the user
  224. */
  225. type: String,
  226. optional: true,
  227. },
  228. 'profile.moveAndCopyDialog': {
  229. /**
  230. * move and copy card dialog
  231. */
  232. type: Object,
  233. optional: true,
  234. blackbox: true,
  235. },
  236. 'profile.moveAndCopyDialog.$.boardId': {
  237. /**
  238. * last selected board id
  239. */
  240. type: String,
  241. },
  242. 'profile.moveAndCopyDialog.$.swimlaneId': {
  243. /**
  244. * last selected swimlane id
  245. */
  246. type: String,
  247. },
  248. 'profile.moveAndCopyDialog.$.listId': {
  249. /**
  250. * last selected list id
  251. */
  252. type: String,
  253. },
  254. 'profile.moveChecklistDialog': {
  255. /**
  256. * move checklist dialog
  257. */
  258. type: Object,
  259. optional: true,
  260. blackbox: true,
  261. },
  262. 'profile.moveChecklistDialog.$.boardId': {
  263. /**
  264. * last selected board id
  265. */
  266. type: String,
  267. },
  268. 'profile.moveChecklistDialog.$.swimlaneId': {
  269. /**
  270. * last selected swimlane id
  271. */
  272. type: String,
  273. },
  274. 'profile.moveChecklistDialog.$.listId': {
  275. /**
  276. * last selected list id
  277. */
  278. type: String,
  279. },
  280. 'profile.moveChecklistDialog.$.cardId': {
  281. /**
  282. * last selected card id
  283. */
  284. type: String,
  285. },
  286. 'profile.copyChecklistDialog': {
  287. /**
  288. * copy checklist dialog
  289. */
  290. type: Object,
  291. optional: true,
  292. blackbox: true,
  293. },
  294. 'profile.copyChecklistDialog.$.boardId': {
  295. /**
  296. * last selected board id
  297. */
  298. type: String,
  299. },
  300. 'profile.copyChecklistDialog.$.swimlaneId': {
  301. /**
  302. * last selected swimlane id
  303. */
  304. type: String,
  305. },
  306. 'profile.copyChecklistDialog.$.listId': {
  307. /**
  308. * last selected list id
  309. */
  310. type: String,
  311. },
  312. 'profile.copyChecklistDialog.$.cardId': {
  313. /**
  314. * last selected card id
  315. */
  316. type: String,
  317. },
  318. 'profile.notifications': {
  319. /**
  320. * enabled notifications for the user
  321. */
  322. type: [Object],
  323. optional: true,
  324. },
  325. 'profile.notifications.$.activity': {
  326. /**
  327. * The id of the activity this notification references
  328. */
  329. type: String,
  330. },
  331. 'profile.notifications.$.read': {
  332. /**
  333. * the date on which this notification was read
  334. */
  335. type: Date,
  336. optional: true,
  337. },
  338. 'profile.rescueCardDescription': {
  339. /**
  340. * show dialog for saving card description on unintentional card closing
  341. */
  342. type: Boolean,
  343. optional: true,
  344. },
  345. 'profile.showCardsCountAt': {
  346. /**
  347. * showCardCountAt field of the user
  348. */
  349. type: Number,
  350. optional: true,
  351. },
  352. 'profile.startDayOfWeek': {
  353. /**
  354. * startDayOfWeek field of the user
  355. */
  356. type: Number,
  357. optional: true,
  358. },
  359. 'profile.starredBoards': {
  360. /**
  361. * list of starred board IDs
  362. */
  363. type: [String],
  364. optional: true,
  365. },
  366. 'profile.icode': {
  367. /**
  368. * icode
  369. */
  370. type: String,
  371. optional: true,
  372. },
  373. 'profile.boardView': {
  374. /**
  375. * boardView field of the user
  376. */
  377. type: String,
  378. optional: true,
  379. allowedValues: [
  380. 'board-view-swimlanes',
  381. 'board-view-lists',
  382. 'board-view-cal',
  383. ],
  384. },
  385. 'profile.listSortBy': {
  386. /**
  387. * default sort list for user
  388. */
  389. type: String,
  390. optional: true,
  391. defaultValue: defaultSortBy,
  392. allowedValues: allowedSortValues,
  393. },
  394. 'profile.templatesBoardId': {
  395. /**
  396. * Reference to the templates board
  397. */
  398. type: String,
  399. defaultValue: '',
  400. },
  401. 'profile.cardTemplatesSwimlaneId': {
  402. /**
  403. * Reference to the card templates swimlane Id
  404. */
  405. type: String,
  406. defaultValue: '',
  407. },
  408. 'profile.listTemplatesSwimlaneId': {
  409. /**
  410. * Reference to the list templates swimlane Id
  411. */
  412. type: String,
  413. defaultValue: '',
  414. },
  415. 'profile.boardTemplatesSwimlaneId': {
  416. /**
  417. * Reference to the board templates swimlane Id
  418. */
  419. type: String,
  420. defaultValue: '',
  421. },
  422. services: {
  423. /**
  424. * services field of the user
  425. */
  426. type: Object,
  427. optional: true,
  428. blackbox: true,
  429. },
  430. heartbeat: {
  431. /**
  432. * last time the user has been seen
  433. */
  434. type: Date,
  435. optional: true,
  436. },
  437. isAdmin: {
  438. /**
  439. * is the user an admin of the board?
  440. */
  441. type: Boolean,
  442. optional: true,
  443. },
  444. createdThroughApi: {
  445. /**
  446. * was the user created through the API?
  447. */
  448. type: Boolean,
  449. optional: true,
  450. },
  451. loginDisabled: {
  452. /**
  453. * loginDisabled field of the user
  454. */
  455. type: Boolean,
  456. optional: true,
  457. },
  458. authenticationMethod: {
  459. /**
  460. * authentication method of the user
  461. */
  462. type: String,
  463. optional: false,
  464. defaultValue: 'password',
  465. },
  466. sessionData: {
  467. /**
  468. * profile settings
  469. */
  470. type: Object,
  471. optional: true,
  472. // eslint-disable-next-line consistent-return
  473. autoValue() {
  474. if (this.isInsert && !this.isSet) {
  475. return {};
  476. }
  477. },
  478. },
  479. 'sessionData.totalHits': {
  480. /**
  481. * Total hits from last searchquery['members.userId'] = Meteor.userId();
  482. * last hit that was returned
  483. */
  484. type: Number,
  485. optional: true,
  486. },
  487. importUsernames: {
  488. /**
  489. * username for imported
  490. */
  491. type: [String],
  492. optional: true,
  493. },
  494. lastConnectionDate: {
  495. type: Date,
  496. optional: true,
  497. },
  498. }),
  499. );
  500. Users.allow({
  501. update(userId, doc) {
  502. const user = Users.findOne({
  503. _id: userId,
  504. });
  505. if ((user && user.isAdmin) || (Meteor.user() && Meteor.user().isAdmin))
  506. return true;
  507. if (!user) {
  508. return false;
  509. }
  510. return doc._id === userId;
  511. },
  512. remove(userId, doc) {
  513. const adminsNumber = Users.find({
  514. isAdmin: true,
  515. }).count();
  516. const { isAdmin } = Users.findOne(
  517. {
  518. _id: userId,
  519. },
  520. {
  521. fields: {
  522. isAdmin: 1,
  523. },
  524. },
  525. );
  526. // Prevents remove of the only one administrator
  527. if (adminsNumber === 1 && isAdmin && userId === doc._id) {
  528. return false;
  529. }
  530. // If it's the user or an admin
  531. return userId === doc._id || isAdmin;
  532. },
  533. fetch: [],
  534. });
  535. // Non-Admin users can not change to Admin
  536. Users.deny({
  537. update(userId, board, fieldNames) {
  538. return _.contains(fieldNames, 'isAdmin') && !Meteor.user().isAdmin;
  539. },
  540. fetch: [],
  541. });
  542. // Search a user in the complete server database by its name, username or emails adress. This
  543. // is used for instance to add a new user to a board.
  544. UserSearchIndex = new Index({
  545. collection: Users,
  546. fields: ['username', 'profile.fullname', 'profile.avatarUrl'],
  547. allowedFields: ['username', 'profile.fullname', 'profile.avatarUrl'],
  548. engine: new MongoDBEngine({
  549. fields: function (searchObject, options) {
  550. return {
  551. username: 1,
  552. 'profile.fullname': 1,
  553. 'profile.avatarUrl': 1,
  554. };
  555. },
  556. }),
  557. });
  558. Users.safeFields = {
  559. _id: 1,
  560. username: 1,
  561. 'profile.fullname': 1,
  562. 'profile.avatarUrl': 1,
  563. 'profile.initials': 1,
  564. orgs: 1,
  565. teams: 1,
  566. authenticationMethod: 1,
  567. lastConnectionDate: 1,
  568. };
  569. if (Meteor.isClient) {
  570. Users.helpers({
  571. isBoardMember() {
  572. const board = Utils.getCurrentBoard();
  573. return board && board.hasMember(this._id);
  574. },
  575. isNotNoComments() {
  576. const board = Utils.getCurrentBoard();
  577. return (
  578. board && board.hasMember(this._id) && !board.hasNoComments(this._id)
  579. );
  580. },
  581. isNoComments() {
  582. const board = Utils.getCurrentBoard();
  583. return board && board.hasNoComments(this._id);
  584. },
  585. isNotCommentOnly() {
  586. const board = Utils.getCurrentBoard();
  587. return (
  588. board && board.hasMember(this._id) && !board.hasCommentOnly(this._id)
  589. );
  590. },
  591. isCommentOnly() {
  592. const board = Utils.getCurrentBoard();
  593. return board && board.hasCommentOnly(this._id);
  594. },
  595. isNotWorker() {
  596. const board = Utils.getCurrentBoard();
  597. return board && board.hasMember(this._id) && !board.hasWorker(this._id);
  598. },
  599. isWorker() {
  600. const board = Utils.getCurrentBoard();
  601. return board && board.hasWorker(this._id);
  602. },
  603. isBoardAdmin(boardId) {
  604. let board;
  605. if (boardId) {
  606. board = ReactiveCache.getBoard(boardId);
  607. } else {
  608. board = Utils.getCurrentBoard();
  609. }
  610. return board && board.hasAdmin(this._id);
  611. },
  612. });
  613. }
  614. Users.parseImportUsernames = (usernamesString) => {
  615. return usernamesString.trim().split(new RegExp('\\s*[,;]\\s*'));
  616. };
  617. Users.helpers({
  618. importUsernamesString() {
  619. if (this.importUsernames) {
  620. return this.importUsernames.join(', ');
  621. }
  622. return '';
  623. },
  624. teamIds() {
  625. if (this.teams) {
  626. // TODO: Should the Team collection be queried to determine if the team isActive?
  627. return this.teams.map((team) => {
  628. return team.teamId;
  629. });
  630. }
  631. return [];
  632. },
  633. orgIds() {
  634. if (this.orgs) {
  635. // TODO: Should the Org collection be queried to determine if the organization isActive?
  636. return this.orgs.map((org) => {
  637. return org.orgId;
  638. });
  639. }
  640. return [];
  641. },
  642. orgsUserBelongs() {
  643. if (this.orgs) {
  644. return this.orgs
  645. .map(function (org) {
  646. return org.orgDisplayName;
  647. })
  648. .sort()
  649. .join(',');
  650. }
  651. return '';
  652. },
  653. orgIdsUserBelongs() {
  654. if (this.orgs) {
  655. return this.orgs
  656. .map(function (org) {
  657. return org.orgId;
  658. })
  659. .join(',');
  660. }
  661. return '';
  662. },
  663. teamsUserBelongs() {
  664. if (this.teams) {
  665. return this.teams
  666. .map(function (team) {
  667. return team.teamDisplayName;
  668. })
  669. .sort()
  670. .join(',');
  671. }
  672. return '';
  673. },
  674. teamIdsUserBelongs() {
  675. if (this.teams) {
  676. return this.teams
  677. .map(function (team) {
  678. return team.teamId;
  679. })
  680. .join(',');
  681. }
  682. return '';
  683. },
  684. boards() {
  685. return Boards.userBoards(this._id, null, {}, { sort: { sort: 1 } });
  686. },
  687. starredBoards() {
  688. const { starredBoards = [] } = this.profile || {};
  689. return Boards.userBoards(
  690. this._id,
  691. false,
  692. { _id: { $in: starredBoards } },
  693. { sort: { sort: 1 } },
  694. );
  695. },
  696. hasStarred(boardId) {
  697. const { starredBoards = [] } = this.profile || {};
  698. return _.contains(starredBoards, boardId);
  699. },
  700. invitedBoards() {
  701. const { invitedBoards = [] } = this.profile || {};
  702. return Boards.userBoards(
  703. this._id,
  704. false,
  705. { _id: { $in: invitedBoards } },
  706. { sort: { sort: 1 } },
  707. );
  708. },
  709. isInvitedTo(boardId) {
  710. const { invitedBoards = [] } = this.profile || {};
  711. return _.contains(invitedBoards, boardId);
  712. },
  713. _getListSortBy() {
  714. const profile = this.profile || {};
  715. const sortBy = profile.listSortBy || defaultSortBy;
  716. const keyPattern = /^(-{0,1})(.*$)/;
  717. const ret = [];
  718. if (keyPattern.exec(sortBy)) {
  719. ret[0] = RegExp.$2;
  720. ret[1] = RegExp.$1 ? -1 : 1;
  721. }
  722. return ret;
  723. },
  724. hasSortBy() {
  725. // if use doesn't have dragHandle, then we can let user to choose sort list by different order
  726. return !this.hasShowDesktopDragHandles();
  727. },
  728. getListSortBy() {
  729. return this._getListSortBy()[0];
  730. },
  731. getListSortTypes() {
  732. return allowedSortValues;
  733. },
  734. getListSortByDirection() {
  735. return this._getListSortBy()[1];
  736. },
  737. /** returns all confirmed move and copy dialog field values
  738. * <li> the board, swimlane and list id is stored for each board
  739. */
  740. getMoveAndCopyDialogOptions() {
  741. let _ret = {};
  742. if (this.profile && this.profile.moveAndCopyDialog) {
  743. _ret = this.profile.moveAndCopyDialog;
  744. }
  745. return _ret;
  746. },
  747. /** returns all confirmed move checklist dialog field values
  748. * <li> the board, swimlane, list and card id is stored for each board
  749. */
  750. getMoveChecklistDialogOptions() {
  751. let _ret = {};
  752. if (this.profile && this.profile.moveChecklistDialog) {
  753. _ret = this.profile.moveChecklistDialog;
  754. }
  755. return _ret;
  756. },
  757. /** returns all confirmed copy checklist dialog field values
  758. * <li> the board, swimlane, list and card id is stored for each board
  759. */
  760. getCopyChecklistDialogOptions() {
  761. let _ret = {};
  762. if (this.profile && this.profile.copyChecklistDialog) {
  763. _ret = this.profile.copyChecklistDialog;
  764. }
  765. return _ret;
  766. },
  767. hasTag(tag) {
  768. const { tags = [] } = this.profile || {};
  769. return _.contains(tags, tag);
  770. },
  771. hasNotification(activityId) {
  772. const { notifications = [] } = this.profile || {};
  773. return _.contains(notifications, activityId);
  774. },
  775. notifications() {
  776. const { notifications = [] } = this.profile || {};
  777. for (const index in notifications) {
  778. if (!notifications.hasOwnProperty(index)) continue;
  779. const notification = notifications[index];
  780. // this preserves their db sort order for editing
  781. notification.dbIndex = index;
  782. notification.activity = Activities.findOne(notification.activity);
  783. }
  784. // this sorts them newest to oldest to match Trello's behavior
  785. notifications.reverse();
  786. return notifications;
  787. },
  788. hasShowDesktopDragHandles() {
  789. const profile = this.profile || {};
  790. return profile.showDesktopDragHandles || false;
  791. },
  792. hasHideCheckedItems() {
  793. const profile = this.profile || {};
  794. return profile.hideCheckedItems || false;
  795. },
  796. hasHiddenSystemMessages() {
  797. const profile = this.profile || {};
  798. return profile.hiddenSystemMessages || false;
  799. },
  800. hasCustomFieldsGrid() {
  801. const profile = this.profile || {};
  802. return profile.customFieldsGrid || false;
  803. },
  804. hasCardMaximized() {
  805. const profile = this.profile || {};
  806. return profile.cardMaximized || false;
  807. },
  808. hasHiddenMinicardLabelText() {
  809. const profile = this.profile || {};
  810. return profile.hiddenMinicardLabelText || false;
  811. },
  812. hasRescuedCardDescription() {
  813. const profile = this.profile || {};
  814. return profile.rescueCardDescription || false;
  815. },
  816. getEmailBuffer() {
  817. const { emailBuffer = [] } = this.profile || {};
  818. return emailBuffer;
  819. },
  820. getInitials() {
  821. const profile = this.profile || {};
  822. if (profile.initials) return profile.initials;
  823. else if (profile.fullname) {
  824. return profile.fullname
  825. .split(/\s+/)
  826. .reduce((memo, word) => {
  827. return memo + word[0];
  828. }, '')
  829. .toUpperCase();
  830. } else {
  831. return this.username[0].toUpperCase();
  832. }
  833. },
  834. getLimitToShowCardsCount() {
  835. const profile = this.profile || {};
  836. return profile.showCardsCountAt;
  837. },
  838. getName() {
  839. const profile = this.profile || {};
  840. return profile.fullname || this.username;
  841. },
  842. getLanguage() {
  843. const profile = this.profile || {};
  844. return profile.language || 'en';
  845. },
  846. getStartDayOfWeek() {
  847. const profile = this.profile || {};
  848. if (typeof profile.startDayOfWeek === 'undefined') {
  849. // default is 'Monday' (1)
  850. return 1;
  851. }
  852. return profile.startDayOfWeek;
  853. },
  854. getTemplatesBoardId() {
  855. return (this.profile || {}).templatesBoardId;
  856. },
  857. getTemplatesBoardSlug() {
  858. //return (Boards.findOne((this.profile || {}).templatesBoardId) || {}).slug;
  859. return 'templates';
  860. },
  861. remove() {
  862. User.remove({
  863. _id: this._id,
  864. });
  865. },
  866. });
  867. Users.mutations({
  868. /** set the confirmed board id/swimlane id/list id of a board
  869. * @param boardId the current board id
  870. * @param options an object with the confirmed field values
  871. */
  872. setMoveAndCopyDialogOption(boardId, options) {
  873. let currentOptions = this.getMoveAndCopyDialogOptions();
  874. currentOptions[boardId] = options;
  875. return {
  876. $set: {
  877. 'profile.moveAndCopyDialog': currentOptions,
  878. },
  879. };
  880. },
  881. /** set the confirmed board id/swimlane id/list id/card id of a board (move checklist)
  882. * @param boardId the current board id
  883. * @param options an object with the confirmed field values
  884. */
  885. setMoveChecklistDialogOption(boardId, options) {
  886. let currentOptions = this.getMoveChecklistDialogOptions();
  887. currentOptions[boardId] = options;
  888. return {
  889. $set: {
  890. 'profile.moveChecklistDialog': currentOptions,
  891. },
  892. };
  893. },
  894. /** set the confirmed board id/swimlane id/list id/card id of a board (copy checklist)
  895. * @param boardId the current board id
  896. * @param options an object with the confirmed field values
  897. */
  898. setCopyChecklistDialogOption(boardId, options) {
  899. let currentOptions = this.getCopyChecklistDialogOptions();
  900. currentOptions[boardId] = options;
  901. return {
  902. $set: {
  903. 'profile.copyChecklistDialog': currentOptions,
  904. },
  905. };
  906. },
  907. toggleBoardStar(boardId) {
  908. const queryKind = this.hasStarred(boardId) ? '$pull' : '$addToSet';
  909. return {
  910. [queryKind]: {
  911. 'profile.starredBoards': boardId,
  912. },
  913. };
  914. },
  915. addInvite(boardId) {
  916. return {
  917. $addToSet: {
  918. 'profile.invitedBoards': boardId,
  919. },
  920. };
  921. },
  922. removeInvite(boardId) {
  923. return {
  924. $pull: {
  925. 'profile.invitedBoards': boardId,
  926. },
  927. };
  928. },
  929. addTag(tag) {
  930. return {
  931. $addToSet: {
  932. 'profile.tags': tag,
  933. },
  934. };
  935. },
  936. removeTag(tag) {
  937. return {
  938. $pull: {
  939. 'profile.tags': tag,
  940. },
  941. };
  942. },
  943. toggleTag(tag) {
  944. if (this.hasTag(tag)) this.removeTag(tag);
  945. else this.addTag(tag);
  946. },
  947. setListSortBy(value) {
  948. return {
  949. $set: {
  950. 'profile.listSortBy': value,
  951. },
  952. };
  953. },
  954. setName(value) {
  955. return {
  956. $set: {
  957. 'profile.fullname': value,
  958. },
  959. };
  960. },
  961. toggleDesktopHandles(value = false) {
  962. return {
  963. $set: {
  964. 'profile.showDesktopDragHandles': !value,
  965. },
  966. };
  967. },
  968. toggleHideCheckedItems() {
  969. const value = this.hasHideCheckedItems();
  970. return {
  971. $set: {
  972. 'profile.hideCheckedItems': !value,
  973. },
  974. };
  975. },
  976. toggleSystem(value = false) {
  977. return {
  978. $set: {
  979. 'profile.hiddenSystemMessages': !value,
  980. },
  981. };
  982. },
  983. toggleFieldsGrid(value = false) {
  984. return {
  985. $set: {
  986. 'profile.customFieldsGrid': !value,
  987. },
  988. };
  989. },
  990. toggleCardMaximized(value = false) {
  991. return {
  992. $set: {
  993. 'profile.cardMaximized': !value,
  994. },
  995. };
  996. },
  997. toggleLabelText(value = false) {
  998. return {
  999. $set: {
  1000. 'profile.hiddenMinicardLabelText': !value,
  1001. },
  1002. };
  1003. },
  1004. toggleRescueCardDescription(value = false) {
  1005. return {
  1006. $set: {
  1007. 'profile.rescueCardDescription': !value,
  1008. },
  1009. };
  1010. },
  1011. addNotification(activityId) {
  1012. return {
  1013. $addToSet: {
  1014. 'profile.notifications': {
  1015. activity: activityId,
  1016. },
  1017. },
  1018. };
  1019. },
  1020. removeNotification(activityId) {
  1021. return {
  1022. $pull: {
  1023. 'profile.notifications': {
  1024. activity: activityId,
  1025. },
  1026. },
  1027. };
  1028. },
  1029. addEmailBuffer(text) {
  1030. return {
  1031. $addToSet: {
  1032. 'profile.emailBuffer': text,
  1033. },
  1034. };
  1035. },
  1036. clearEmailBuffer() {
  1037. return {
  1038. $set: {
  1039. 'profile.emailBuffer': [],
  1040. },
  1041. };
  1042. },
  1043. setAvatarUrl(avatarUrl) {
  1044. return {
  1045. $set: {
  1046. 'profile.avatarUrl': avatarUrl,
  1047. },
  1048. };
  1049. },
  1050. setShowCardsCountAt(limit) {
  1051. return {
  1052. $set: {
  1053. 'profile.showCardsCountAt': limit,
  1054. },
  1055. };
  1056. },
  1057. setStartDayOfWeek(startDay) {
  1058. return {
  1059. $set: {
  1060. 'profile.startDayOfWeek': startDay,
  1061. },
  1062. };
  1063. },
  1064. setBoardView(view) {
  1065. return {
  1066. $set: {
  1067. 'profile.boardView': view,
  1068. },
  1069. };
  1070. },
  1071. });
  1072. Meteor.methods({
  1073. setListSortBy(value) {
  1074. check(value, String);
  1075. Meteor.user().setListSortBy(value);
  1076. },
  1077. toggleDesktopDragHandles() {
  1078. const user = Meteor.user();
  1079. user.toggleDesktopHandles(user.hasShowDesktopDragHandles());
  1080. },
  1081. toggleHideCheckedItems() {
  1082. const user = Meteor.user();
  1083. user.toggleHideCheckedItems();
  1084. },
  1085. toggleSystemMessages() {
  1086. const user = Meteor.user();
  1087. user.toggleSystem(user.hasHiddenSystemMessages());
  1088. },
  1089. toggleCustomFieldsGrid() {
  1090. const user = Meteor.user();
  1091. user.toggleFieldsGrid(user.hasCustomFieldsGrid());
  1092. },
  1093. toggleCardMaximized() {
  1094. const user = Meteor.user();
  1095. user.toggleCardMaximized(user.hasCardMaximized());
  1096. },
  1097. toggleMinicardLabelText() {
  1098. const user = Meteor.user();
  1099. user.toggleLabelText(user.hasHiddenMinicardLabelText());
  1100. },
  1101. toggleRescueCardDescription() {
  1102. const user = Meteor.user();
  1103. user.toggleRescueCardDescription(user.hasRescuedCardDescription());
  1104. },
  1105. changeLimitToShowCardsCount(limit) {
  1106. check(limit, Number);
  1107. Meteor.user().setShowCardsCountAt(limit);
  1108. },
  1109. changeStartDayOfWeek(startDay) {
  1110. check(startDay, Number);
  1111. Meteor.user().setStartDayOfWeek(startDay);
  1112. },
  1113. });
  1114. if (Meteor.isServer) {
  1115. Meteor.methods({
  1116. setAllUsersHideSystemMessages() {
  1117. if (Meteor.user() && Meteor.user().isAdmin) {
  1118. // If setting is missing, add it
  1119. Users.update(
  1120. {
  1121. 'profile.hiddenSystemMessages': {
  1122. $exists: false,
  1123. },
  1124. },
  1125. {
  1126. $set: {
  1127. 'profile.hiddenSystemMessages': true,
  1128. },
  1129. },
  1130. {
  1131. multi: true,
  1132. },
  1133. );
  1134. // If setting is false, set it to true
  1135. Users.update(
  1136. {
  1137. 'profile.hiddenSystemMessages': false,
  1138. },
  1139. {
  1140. $set: {
  1141. 'profile.hiddenSystemMessages': true,
  1142. },
  1143. },
  1144. {
  1145. multi: true,
  1146. },
  1147. );
  1148. return true;
  1149. } else {
  1150. return false;
  1151. }
  1152. },
  1153. setCreateUser(
  1154. fullname,
  1155. username,
  1156. initials,
  1157. password,
  1158. isAdmin,
  1159. isActive,
  1160. email,
  1161. importUsernames,
  1162. userOrgsArray,
  1163. userTeamsArray,
  1164. ) {
  1165. check(fullname, String);
  1166. check(username, String);
  1167. check(initials, String);
  1168. check(password, String);
  1169. check(isAdmin, String);
  1170. check(isActive, String);
  1171. check(email, String);
  1172. check(importUsernames, Array);
  1173. check(userOrgsArray, Array);
  1174. check(userTeamsArray, Array);
  1175. if (Meteor.user() && Meteor.user().isAdmin) {
  1176. const nUsersWithUsername = Users.find({
  1177. username,
  1178. }).count();
  1179. const nUsersWithEmail = Users.find({
  1180. email,
  1181. }).count();
  1182. if (nUsersWithUsername > 0) {
  1183. throw new Meteor.Error('username-already-taken');
  1184. } else if (nUsersWithEmail > 0) {
  1185. throw new Meteor.Error('email-already-taken');
  1186. } else {
  1187. Accounts.createUser({
  1188. username,
  1189. password,
  1190. isAdmin,
  1191. isActive,
  1192. email: email.toLowerCase(),
  1193. from: 'admin',
  1194. });
  1195. const user =
  1196. Users.findOne(username) ||
  1197. Users.findOne({
  1198. username,
  1199. });
  1200. if (user) {
  1201. Users.update(user._id, {
  1202. $set: {
  1203. 'profile.fullname': fullname,
  1204. importUsernames,
  1205. 'profile.initials': initials,
  1206. orgs: userOrgsArray,
  1207. teams: userTeamsArray,
  1208. },
  1209. });
  1210. }
  1211. }
  1212. }
  1213. },
  1214. setUsername(username, userId) {
  1215. check(username, String);
  1216. check(userId, String);
  1217. if (Meteor.user() && Meteor.user().isAdmin) {
  1218. const nUsersWithUsername = Users.find({
  1219. username,
  1220. }).count();
  1221. if (nUsersWithUsername > 0) {
  1222. throw new Meteor.Error('username-already-taken');
  1223. } else {
  1224. Users.update(userId, {
  1225. $set: {
  1226. username,
  1227. },
  1228. });
  1229. }
  1230. }
  1231. },
  1232. setEmail(email, userId) {
  1233. check(email, String);
  1234. check(username, String);
  1235. if (Meteor.user() && Meteor.user().isAdmin) {
  1236. if (Array.isArray(email)) {
  1237. email = email.shift();
  1238. }
  1239. const existingUser = Users.findOne(
  1240. {
  1241. 'emails.address': email,
  1242. },
  1243. {
  1244. fields: {
  1245. _id: 1,
  1246. },
  1247. },
  1248. );
  1249. if (existingUser) {
  1250. throw new Meteor.Error('email-already-taken');
  1251. } else {
  1252. Users.update(userId, {
  1253. $set: {
  1254. emails: [
  1255. {
  1256. address: email,
  1257. verified: false,
  1258. },
  1259. ],
  1260. },
  1261. });
  1262. }
  1263. }
  1264. },
  1265. setUsernameAndEmail(username, email, userId) {
  1266. check(username, String);
  1267. check(email, String);
  1268. check(userId, String);
  1269. if (Meteor.user() && Meteor.user().isAdmin) {
  1270. if (Array.isArray(email)) {
  1271. email = email.shift();
  1272. }
  1273. Meteor.call('setUsername', username, userId);
  1274. Meteor.call('setEmail', email, userId);
  1275. }
  1276. },
  1277. setPassword(newPassword, userId) {
  1278. check(userId, String);
  1279. check(newPassword, String);
  1280. if (Meteor.user() && Meteor.user().isAdmin) {
  1281. if (Meteor.user().isAdmin) {
  1282. Accounts.setPassword(userId, newPassword);
  1283. }
  1284. }
  1285. },
  1286. setEmailVerified(email, verified, userId) {
  1287. check(email, String);
  1288. check(verified, Boolean);
  1289. check(userId, String);
  1290. if (Meteor.user() && Meteor.user().isAdmin) {
  1291. Users.update(userId, {
  1292. $set: {
  1293. emails: [
  1294. {
  1295. address: email,
  1296. verified,
  1297. },
  1298. ],
  1299. },
  1300. });
  1301. }
  1302. },
  1303. setInitials(initials, userId) {
  1304. check(initials, String);
  1305. check(userId, String);
  1306. if (Meteor.user() && Meteor.user().isAdmin) {
  1307. Users.update(userId, {
  1308. $set: {
  1309. 'profile.initials': initials,
  1310. },
  1311. });
  1312. }
  1313. },
  1314. // we accept userId, username, email
  1315. inviteUserToBoard(username, boardId) {
  1316. check(username, String);
  1317. check(boardId, String);
  1318. const inviter = Meteor.user();
  1319. const board = ReactiveCache.getBoard(boardId);
  1320. const allowInvite =
  1321. inviter &&
  1322. board &&
  1323. board.members &&
  1324. _.contains(_.pluck(board.members, 'userId'), inviter._id) &&
  1325. _.where(board.members, {
  1326. userId: inviter._id,
  1327. })[0].isActive;
  1328. // GitHub issue 2060
  1329. //_.where(board.members, { userId: inviter._id })[0].isAdmin;
  1330. if (!allowInvite) throw new Meteor.Error('error-board-notAMember');
  1331. this.unblock();
  1332. const posAt = username.indexOf('@');
  1333. let user = null;
  1334. if (posAt >= 0) {
  1335. user = Users.findOne({
  1336. emails: {
  1337. $elemMatch: {
  1338. address: username,
  1339. },
  1340. },
  1341. });
  1342. } else {
  1343. user =
  1344. Users.findOne(username) ||
  1345. Users.findOne({
  1346. username,
  1347. });
  1348. }
  1349. if (user) {
  1350. if (user._id === inviter._id)
  1351. throw new Meteor.Error('error-user-notAllowSelf');
  1352. } else {
  1353. if (posAt <= 0) throw new Meteor.Error('error-user-doesNotExist');
  1354. if (ReactiveCache.getCurrentSetting().disableRegistration) {
  1355. throw new Meteor.Error('error-user-notCreated');
  1356. }
  1357. // Set in lowercase email before creating account
  1358. const email = username.toLowerCase();
  1359. username = email.substring(0, posAt);
  1360. const newUserId = Accounts.createUser({
  1361. username,
  1362. email,
  1363. });
  1364. if (!newUserId) throw new Meteor.Error('error-user-notCreated');
  1365. // assume new user speak same language with inviter
  1366. if (inviter.profile && inviter.profile.language) {
  1367. Users.update(newUserId, {
  1368. $set: {
  1369. 'profile.language': inviter.profile.language,
  1370. },
  1371. });
  1372. }
  1373. Accounts.sendEnrollmentEmail(newUserId);
  1374. user = Users.findOne(newUserId);
  1375. }
  1376. board.addMember(user._id);
  1377. user.addInvite(boardId);
  1378. //Check if there is a subtasks board
  1379. if (board.subtasksDefaultBoardId) {
  1380. const subBoard = ReactiveCache.getBoard(board.subtasksDefaultBoardId);
  1381. //If there is, also add user to that board
  1382. if (subBoard) {
  1383. subBoard.addMember(user._id);
  1384. user.addInvite(subBoard._id);
  1385. }
  1386. }
  1387. try {
  1388. const fullName =
  1389. inviter.profile !== undefined &&
  1390. inviter.profile.fullname !== undefined
  1391. ? inviter.profile.fullname
  1392. : '';
  1393. const userFullName =
  1394. user.profile !== undefined && user.profile.fullname !== undefined
  1395. ? user.profile.fullname
  1396. : '';
  1397. const params = {
  1398. user:
  1399. userFullName != ''
  1400. ? userFullName + ' (' + user.username + ' )'
  1401. : user.username,
  1402. inviter:
  1403. fullName != ''
  1404. ? fullName + ' (' + inviter.username + ' )'
  1405. : inviter.username,
  1406. board: board.title,
  1407. url: board.absoluteUrl(),
  1408. };
  1409. const lang = user.getLanguage();
  1410. /*
  1411. if (process.env.MAIL_SERVICE !== '') {
  1412. let transporter = nodemailer.createTransport({
  1413. service: process.env.MAIL_SERVICE,
  1414. auth: {
  1415. user: process.env.MAIL_SERVICE_USER,
  1416. pass: process.env.MAIL_SERVICE_PASSWORD
  1417. },
  1418. })
  1419. let info = transporter.sendMail({
  1420. to: user.emails[0].address.toLowerCase(),
  1421. from: Accounts.emailTemplates.from,
  1422. subject: TAPi18n.__('email-invite-subject', params, lang),
  1423. text: TAPi18n.__('email-invite-text', params, lang),
  1424. })
  1425. } else {
  1426. Email.send({
  1427. to: user.emails[0].address.toLowerCase(),
  1428. from: Accounts.emailTemplates.from,
  1429. subject: TAPi18n.__('email-invite-subject', params, lang),
  1430. text: TAPi18n.__('email-invite-text', params, lang),
  1431. });
  1432. }
  1433. */
  1434. Email.send({
  1435. to: user.emails[0].address.toLowerCase(),
  1436. from: Accounts.emailTemplates.from,
  1437. subject: TAPi18n.__('email-invite-subject', params, lang),
  1438. text: TAPi18n.__('email-invite-text', params, lang),
  1439. });
  1440. } catch (e) {
  1441. throw new Meteor.Error('email-fail', e.message);
  1442. }
  1443. return {
  1444. username: user.username,
  1445. email: user.emails[0].address,
  1446. };
  1447. },
  1448. impersonate(userId) {
  1449. check(userId, String);
  1450. if (!Meteor.users.findOne(userId))
  1451. throw new Meteor.Error(404, 'User not found');
  1452. if (!Meteor.user().isAdmin)
  1453. throw new Meteor.Error(403, 'Permission denied');
  1454. ImpersonatedUsers.insert({
  1455. adminId: Meteor.user()._id,
  1456. userId: userId,
  1457. reason: 'clickedImpersonate',
  1458. });
  1459. this.setUserId(userId);
  1460. },
  1461. isImpersonated(userId) {
  1462. check(userId, String);
  1463. const isImpersonated = ImpersonatedUsers.findOne({
  1464. userId: userId,
  1465. });
  1466. return isImpersonated;
  1467. },
  1468. setUsersTeamsTeamDisplayName(teamId, teamDisplayName) {
  1469. check(teamId, String);
  1470. check(teamDisplayName, String);
  1471. if (Meteor.user() && Meteor.user().isAdmin) {
  1472. Users.find({
  1473. teams: {
  1474. $elemMatch: { teamId: teamId },
  1475. },
  1476. }).forEach((user) => {
  1477. Users.update(
  1478. {
  1479. _id: user._id,
  1480. teams: {
  1481. $elemMatch: { teamId: teamId },
  1482. },
  1483. },
  1484. {
  1485. $set: {
  1486. 'teams.$.teamDisplayName': teamDisplayName,
  1487. },
  1488. },
  1489. );
  1490. });
  1491. }
  1492. },
  1493. setUsersOrgsOrgDisplayName(orgId, orgDisplayName) {
  1494. check(orgId, String);
  1495. check(orgDisplayName, String);
  1496. if (Meteor.user() && Meteor.user().isAdmin) {
  1497. Users.find({
  1498. orgs: {
  1499. $elemMatch: { orgId: orgId },
  1500. },
  1501. }).forEach((user) => {
  1502. Users.update(
  1503. {
  1504. _id: user._id,
  1505. orgs: {
  1506. $elemMatch: { orgId: orgId },
  1507. },
  1508. },
  1509. {
  1510. $set: {
  1511. 'orgs.$.orgDisplayName': orgDisplayName,
  1512. },
  1513. },
  1514. );
  1515. });
  1516. }
  1517. },
  1518. });
  1519. Accounts.onCreateUser((options, user) => {
  1520. const userCount = Users.find().count();
  1521. if (userCount === 0) {
  1522. user.isAdmin = true;
  1523. }
  1524. if (user.services.oidc) {
  1525. let email = user.services.oidc.email;
  1526. if (Array.isArray(email)) {
  1527. email = email.shift();
  1528. }
  1529. email = email.toLowerCase();
  1530. user.username = user.services.oidc.username;
  1531. user.emails = [
  1532. {
  1533. address: email,
  1534. verified: true,
  1535. },
  1536. ];
  1537. const initials = user.services.oidc.fullname
  1538. .split(/\s+/)
  1539. .reduce((memo, word) => {
  1540. return memo + word[0];
  1541. }, '')
  1542. .toUpperCase();
  1543. user.profile = {
  1544. initials,
  1545. fullname: user.services.oidc.fullname,
  1546. boardView: 'board-view-swimlanes',
  1547. };
  1548. user.authenticationMethod = 'oauth2';
  1549. // see if any existing user has this email address or username, otherwise create new
  1550. const existingUser = Meteor.users.findOne({
  1551. $or: [
  1552. {
  1553. 'emails.address': email,
  1554. },
  1555. {
  1556. username: user.username,
  1557. },
  1558. ],
  1559. });
  1560. if (!existingUser) return user;
  1561. // copy across new service info
  1562. const service = _.keys(user.services)[0];
  1563. existingUser.services[service] = user.services[service];
  1564. existingUser.emails = user.emails;
  1565. existingUser.username = user.username;
  1566. existingUser.profile = user.profile;
  1567. existingUser.authenticationMethod = user.authenticationMethod;
  1568. Meteor.users.remove({
  1569. _id: user._id,
  1570. });
  1571. Meteor.users.remove({
  1572. _id: existingUser._id,
  1573. }); // is going to be created again
  1574. return existingUser;
  1575. }
  1576. if (options.from === 'admin') {
  1577. user.createdThroughApi = true;
  1578. return user;
  1579. }
  1580. const disableRegistration = ReactiveCache.getCurrentSetting().disableRegistration;
  1581. // If this is the first Authentication by the ldap and self registration disabled
  1582. if (disableRegistration && options && options.ldap) {
  1583. user.authenticationMethod = 'ldap';
  1584. return user;
  1585. }
  1586. // If self registration enabled
  1587. if (!disableRegistration) {
  1588. return user;
  1589. }
  1590. if (!options || !options.profile) {
  1591. throw new Meteor.Error(
  1592. 'error-invitation-code-blank',
  1593. 'The invitation code is required',
  1594. );
  1595. }
  1596. const invitationCode = InvitationCodes.findOne({
  1597. code: options.profile.invitationcode,
  1598. email: options.email,
  1599. valid: true,
  1600. });
  1601. if (!invitationCode) {
  1602. throw new Meteor.Error(
  1603. 'error-invitation-code-not-exist',
  1604. // eslint-disable-next-line quotes
  1605. "The invitation code doesn't exist",
  1606. );
  1607. } else {
  1608. user.profile = {
  1609. icode: options.profile.invitationcode,
  1610. };
  1611. user.profile.boardView = 'board-view-swimlanes';
  1612. // Deletes the invitation code after the user was created successfully.
  1613. setTimeout(
  1614. Meteor.bindEnvironment(() => {
  1615. InvitationCodes.remove({
  1616. _id: invitationCode._id,
  1617. });
  1618. }),
  1619. 200,
  1620. );
  1621. return user;
  1622. }
  1623. });
  1624. }
  1625. const addCronJob = _.debounce(
  1626. Meteor.bindEnvironment(function notificationCleanupDebounced() {
  1627. // passed in the removeAge has to be a number standing for the number of days after a notification is read before we remove it
  1628. const envRemoveAge =
  1629. process.env.NOTIFICATION_TRAY_AFTER_READ_DAYS_BEFORE_REMOVE;
  1630. // default notifications will be removed 2 days after they are read
  1631. const defaultRemoveAge = 2;
  1632. const removeAge = parseInt(envRemoveAge, 10) || defaultRemoveAge;
  1633. SyncedCron.add({
  1634. name: 'notification_cleanup',
  1635. schedule: (parser) => parser.text('every 1 days'),
  1636. job: () => {
  1637. for (const user of Users.find()) {
  1638. if (!user.profile || !user.profile.notifications) continue;
  1639. for (const notification of user.profile.notifications) {
  1640. if (notification.read) {
  1641. const removeDate = new Date(notification.read);
  1642. removeDate.setDate(removeDate.getDate() + removeAge);
  1643. if (removeDate <= new Date()) {
  1644. user.removeNotification(notification.activity);
  1645. }
  1646. }
  1647. }
  1648. }
  1649. },
  1650. });
  1651. SyncedCron.start();
  1652. }),
  1653. 500,
  1654. );
  1655. if (Meteor.isServer) {
  1656. // Let mongoDB ensure username unicity
  1657. Meteor.startup(() => {
  1658. allowedSortValues.forEach((value) => {
  1659. Lists._collection.createIndex(value);
  1660. });
  1661. Users._collection.createIndex({
  1662. modifiedAt: -1,
  1663. });
  1664. /* Commented out extra index because of IndexOptionsConflict.
  1665. Users._collection.createIndex(
  1666. {
  1667. username: 1,
  1668. },
  1669. {
  1670. unique: true,
  1671. },
  1672. );
  1673. */
  1674. Meteor.defer(() => {
  1675. addCronJob();
  1676. });
  1677. });
  1678. // OLD WAY THIS CODE DID WORK: When user is last admin of board,
  1679. // if admin is removed, board is removed.
  1680. // NOW THIS IS COMMENTED OUT, because other board users still need to be able
  1681. // to use that board, and not have board deleted.
  1682. // Someone can be later changed to be admin of board, by making change to database.
  1683. // TODO: Add UI for changing someone as board admin.
  1684. //Users.before.remove((userId, doc) => {
  1685. // Boards
  1686. // .find({members: {$elemMatch: {userId: doc._id, isAdmin: true}}})
  1687. // .forEach((board) => {
  1688. // // If only one admin for the board
  1689. // if (board.members.filter((e) => e.isAdmin).length === 1) {
  1690. // Boards.remove(board._id);
  1691. // }
  1692. // });
  1693. //});
  1694. // Each board document contains the de-normalized number of users that have
  1695. // starred it. If the user star or unstar a board, we need to update this
  1696. // counter.
  1697. // We need to run this code on the server only, otherwise the incrementation
  1698. // will be done twice.
  1699. Users.after.update(function (userId, user, fieldNames) {
  1700. // The `starredBoards` list is hosted on the `profile` field. If this
  1701. // field hasn't been modificated we don't need to run this hook.
  1702. if (!_.contains(fieldNames, 'profile')) return;
  1703. // To calculate a diff of board starred ids, we get both the previous
  1704. // and the newly board ids list
  1705. function getStarredBoardsIds(doc) {
  1706. return doc.profile && doc.profile.starredBoards;
  1707. }
  1708. const oldIds = getStarredBoardsIds(this.previous);
  1709. const newIds = getStarredBoardsIds(user);
  1710. // The _.difference(a, b) method returns the values from a that are not in
  1711. // b. We use it to find deleted and newly inserted ids by using it in one
  1712. // direction and then in the other.
  1713. function incrementBoards(boardsIds, inc) {
  1714. boardsIds.forEach((boardId) => {
  1715. Boards.update(boardId, {
  1716. $inc: {
  1717. stars: inc,
  1718. },
  1719. });
  1720. });
  1721. }
  1722. incrementBoards(_.difference(oldIds, newIds), -1);
  1723. incrementBoards(_.difference(newIds, oldIds), +1);
  1724. });
  1725. // Override getUserId so that we can TODO get the current userId
  1726. const fakeUserId = new Meteor.EnvironmentVariable();
  1727. const getUserId = CollectionHooks.getUserId;
  1728. CollectionHooks.getUserId = () => {
  1729. return fakeUserId.get() || getUserId();
  1730. };
  1731. if (!isSandstorm) {
  1732. Users.after.insert((userId, doc) => {
  1733. const fakeUser = {
  1734. extendAutoValueContext: {
  1735. userId: doc._id,
  1736. },
  1737. };
  1738. fakeUserId.withValue(doc._id, () => {
  1739. /*
  1740. // Insert the Welcome Board
  1741. Boards.insert({
  1742. title: TAPi18n.__('welcome-board'),
  1743. permission: 'private',
  1744. }, fakeUser, (err, boardId) => {
  1745. Swimlanes.insert({
  1746. title: TAPi18n.__('welcome-swimlane'),
  1747. boardId,
  1748. sort: 1,
  1749. }, fakeUser);
  1750. ['welcome-list1', 'welcome-list2'].forEach((title, titleIndex) => {
  1751. Lists.insert({title: TAPi18n.__(title), boardId, sort: titleIndex}, fakeUser);
  1752. });
  1753. });
  1754. */
  1755. // Insert Template Container
  1756. const Future = require('fibers/future');
  1757. const future1 = new Future();
  1758. const future2 = new Future();
  1759. const future3 = new Future();
  1760. Boards.insert(
  1761. {
  1762. title: TAPi18n.__('templates'),
  1763. permission: 'private',
  1764. type: 'template-container',
  1765. },
  1766. fakeUser,
  1767. (err, boardId) => {
  1768. // Insert the reference to our templates board
  1769. Users.update(fakeUserId.get(), {
  1770. $set: {
  1771. 'profile.templatesBoardId': boardId,
  1772. },
  1773. });
  1774. // Insert the card templates swimlane
  1775. Swimlanes.insert(
  1776. {
  1777. title: TAPi18n.__('card-templates-swimlane'),
  1778. boardId,
  1779. sort: 1,
  1780. type: 'template-container',
  1781. },
  1782. fakeUser,
  1783. (err, swimlaneId) => {
  1784. // Insert the reference to out card templates swimlane
  1785. Users.update(fakeUserId.get(), {
  1786. $set: {
  1787. 'profile.cardTemplatesSwimlaneId': swimlaneId,
  1788. },
  1789. });
  1790. future1.return();
  1791. },
  1792. );
  1793. // Insert the list templates swimlane
  1794. Swimlanes.insert(
  1795. {
  1796. title: TAPi18n.__('list-templates-swimlane'),
  1797. boardId,
  1798. sort: 2,
  1799. type: 'template-container',
  1800. },
  1801. fakeUser,
  1802. (err, swimlaneId) => {
  1803. // Insert the reference to out list templates swimlane
  1804. Users.update(fakeUserId.get(), {
  1805. $set: {
  1806. 'profile.listTemplatesSwimlaneId': swimlaneId,
  1807. },
  1808. });
  1809. future2.return();
  1810. },
  1811. );
  1812. // Insert the board templates swimlane
  1813. Swimlanes.insert(
  1814. {
  1815. title: TAPi18n.__('board-templates-swimlane'),
  1816. boardId,
  1817. sort: 3,
  1818. type: 'template-container',
  1819. },
  1820. fakeUser,
  1821. (err, swimlaneId) => {
  1822. // Insert the reference to out board templates swimlane
  1823. Users.update(fakeUserId.get(), {
  1824. $set: {
  1825. 'profile.boardTemplatesSwimlaneId': swimlaneId,
  1826. },
  1827. });
  1828. future3.return();
  1829. },
  1830. );
  1831. },
  1832. );
  1833. // HACK
  1834. future1.wait();
  1835. future2.wait();
  1836. future3.wait();
  1837. // End of Insert Template Container
  1838. });
  1839. });
  1840. }
  1841. Users.after.insert((userId, doc) => {
  1842. // HACK
  1843. doc = Users.findOne({
  1844. _id: doc._id,
  1845. });
  1846. if (doc.createdThroughApi) {
  1847. // The admin user should be able to create a user despite disabling registration because
  1848. // it is two different things (registration and creation).
  1849. // So, when a new user is created via the api (only admin user can do that) one must avoid
  1850. // the disableRegistration check.
  1851. // Issue : https://github.com/wekan/wekan/issues/1232
  1852. // PR : https://github.com/wekan/wekan/pull/1251
  1853. Users.update(doc._id, {
  1854. $set: {
  1855. createdThroughApi: '',
  1856. },
  1857. });
  1858. return;
  1859. }
  1860. //invite user to corresponding boards
  1861. const disableRegistration = Utils.getCurrentSetting().disableRegistration;
  1862. // If ldap, bypass the inviation code if the self registration isn't allowed.
  1863. // TODO : pay attention if ldap field in the user model change to another content ex : ldap field to connection_type
  1864. if (doc.authenticationMethod !== 'ldap' && disableRegistration) {
  1865. let invitationCode = null;
  1866. if (doc.authenticationMethod.toLowerCase() == 'oauth2') {
  1867. // OIDC authentication mode
  1868. invitationCode = InvitationCodes.findOne({
  1869. email: doc.emails[0].address.toLowerCase(),
  1870. valid: true,
  1871. });
  1872. } else {
  1873. invitationCode = InvitationCodes.findOne({
  1874. code: doc.profile.icode,
  1875. valid: true,
  1876. });
  1877. }
  1878. if (!invitationCode) {
  1879. throw new Meteor.Error('error-invitation-code-not-exist');
  1880. } else {
  1881. invitationCode.boardsToBeInvited.forEach((boardId) => {
  1882. const board = ReactiveCache.getBoard(boardId);
  1883. board.addMember(doc._id);
  1884. });
  1885. if (!doc.profile) {
  1886. doc.profile = {};
  1887. }
  1888. doc.profile.invitedBoards = invitationCode.boardsToBeInvited;
  1889. Users.update(doc._id, {
  1890. $set: {
  1891. profile: doc.profile,
  1892. },
  1893. });
  1894. InvitationCodes.update(invitationCode._id, {
  1895. $set: {
  1896. valid: false,
  1897. },
  1898. });
  1899. }
  1900. }
  1901. });
  1902. }
  1903. // USERS REST API
  1904. if (Meteor.isServer) {
  1905. // Middleware which checks that API is enabled.
  1906. JsonRoutes.Middleware.use(function (req, res, next) {
  1907. const api = req.url.startsWith('/api');
  1908. if ((api === true && process.env.WITH_API === 'true') || api === false) {
  1909. return next();
  1910. } else {
  1911. res.writeHead(301, {
  1912. Location: '/',
  1913. });
  1914. return res.end();
  1915. }
  1916. });
  1917. /**
  1918. * @operation get_current_user
  1919. *
  1920. * @summary returns the current user
  1921. * @return_type Users
  1922. */
  1923. JsonRoutes.add('GET', '/api/user', function (req, res) {
  1924. try {
  1925. Authentication.checkLoggedIn(req.userId);
  1926. const data = Meteor.users.findOne({
  1927. _id: req.userId,
  1928. });
  1929. delete data.services;
  1930. // get all boards where the user is member of
  1931. let boards = Boards.find(
  1932. {
  1933. type: 'board',
  1934. 'members.userId': req.userId,
  1935. },
  1936. {
  1937. fields: {
  1938. _id: 1,
  1939. members: 1,
  1940. },
  1941. },
  1942. );
  1943. boards = boards.map((b) => {
  1944. const u = b.members.find((m) => m.userId === req.userId);
  1945. delete u.userId;
  1946. u.boardId = b._id;
  1947. return u;
  1948. });
  1949. data.boards = boards;
  1950. JsonRoutes.sendResult(res, {
  1951. code: 200,
  1952. data,
  1953. });
  1954. } catch (error) {
  1955. JsonRoutes.sendResult(res, {
  1956. code: 200,
  1957. data: error,
  1958. });
  1959. }
  1960. });
  1961. /**
  1962. * @operation get_all_users
  1963. *
  1964. * @summary return all the users
  1965. *
  1966. * @description Only the admin user (the first user) can call the REST API.
  1967. * @return_type [{ _id: string,
  1968. * username: string}]
  1969. */
  1970. JsonRoutes.add('GET', '/api/users', function (req, res) {
  1971. try {
  1972. Authentication.checkUserId(req.userId);
  1973. JsonRoutes.sendResult(res, {
  1974. code: 200,
  1975. data: Meteor.users.find({}).map(function (doc) {
  1976. return {
  1977. _id: doc._id,
  1978. username: doc.username,
  1979. };
  1980. }),
  1981. });
  1982. } catch (error) {
  1983. JsonRoutes.sendResult(res, {
  1984. code: 200,
  1985. data: error,
  1986. });
  1987. }
  1988. });
  1989. /**
  1990. * @operation get_user
  1991. *
  1992. * @summary get a given user
  1993. *
  1994. * @description Only the admin user (the first user) can call the REST API.
  1995. *
  1996. * @param {string} userId the user ID or username
  1997. * @return_type Users
  1998. */
  1999. JsonRoutes.add('GET', '/api/users/:userId', function (req, res) {
  2000. try {
  2001. Authentication.checkUserId(req.userId);
  2002. let id = req.params.userId;
  2003. let user = Meteor.users.findOne({
  2004. _id: id,
  2005. });
  2006. if (!user) {
  2007. user = Meteor.users.findOne({
  2008. username: id,
  2009. });
  2010. id = user._id;
  2011. }
  2012. // get all boards where the user is member of
  2013. let boards = Boards.find(
  2014. {
  2015. type: 'board',
  2016. 'members.userId': id,
  2017. },
  2018. {
  2019. fields: {
  2020. _id: 1,
  2021. members: 1,
  2022. },
  2023. },
  2024. );
  2025. boards = boards.map((b) => {
  2026. const u = b.members.find((m) => m.userId === id);
  2027. delete u.userId;
  2028. u.boardId = b._id;
  2029. return u;
  2030. });
  2031. user.boards = boards;
  2032. JsonRoutes.sendResult(res, {
  2033. code: 200,
  2034. data: user,
  2035. });
  2036. } catch (error) {
  2037. JsonRoutes.sendResult(res, {
  2038. code: 200,
  2039. data: error,
  2040. });
  2041. }
  2042. });
  2043. /**
  2044. * @operation edit_user
  2045. *
  2046. * @summary edit a given user
  2047. *
  2048. * @description Only the admin user (the first user) can call the REST API.
  2049. *
  2050. * Possible values for *action*:
  2051. * - `takeOwnership`: The admin takes the ownership of ALL boards of the user (archived and not archived) where the user is admin on.
  2052. * - `disableLogin`: Disable a user (the user is not allowed to login and his login tokens are purged)
  2053. * - `enableLogin`: Enable a user
  2054. *
  2055. * @param {string} userId the user ID
  2056. * @param {string} action the action
  2057. * @return_type {_id: string,
  2058. * title: string}
  2059. */
  2060. JsonRoutes.add('PUT', '/api/users/:userId', function (req, res) {
  2061. try {
  2062. Authentication.checkUserId(req.userId);
  2063. const id = req.params.userId;
  2064. const action = req.body.action;
  2065. let data = Meteor.users.findOne({
  2066. _id: id,
  2067. });
  2068. if (data !== undefined) {
  2069. if (action === 'takeOwnership') {
  2070. data = Boards.find(
  2071. {
  2072. 'members.userId': id,
  2073. 'members.isAdmin': true,
  2074. },
  2075. {
  2076. sort: {
  2077. sort: 1 /* boards default sorting */,
  2078. },
  2079. },
  2080. ).map(function (board) {
  2081. if (board.hasMember(req.userId)) {
  2082. board.removeMember(req.userId);
  2083. }
  2084. board.changeOwnership(id, req.userId);
  2085. return {
  2086. _id: board._id,
  2087. title: board.title,
  2088. };
  2089. });
  2090. } else {
  2091. if (action === 'disableLogin' && id !== req.userId) {
  2092. Users.update(
  2093. {
  2094. _id: id,
  2095. },
  2096. {
  2097. $set: {
  2098. loginDisabled: true,
  2099. 'services.resume.loginTokens': '',
  2100. },
  2101. },
  2102. );
  2103. } else if (action === 'enableLogin') {
  2104. Users.update(
  2105. {
  2106. _id: id,
  2107. },
  2108. {
  2109. $set: {
  2110. loginDisabled: '',
  2111. },
  2112. },
  2113. );
  2114. }
  2115. data = Meteor.users.findOne({
  2116. _id: id,
  2117. });
  2118. }
  2119. }
  2120. JsonRoutes.sendResult(res, {
  2121. code: 200,
  2122. data,
  2123. });
  2124. } catch (error) {
  2125. JsonRoutes.sendResult(res, {
  2126. code: 200,
  2127. data: error,
  2128. });
  2129. }
  2130. });
  2131. /**
  2132. * @operation add_board_member
  2133. * @tag Boards
  2134. *
  2135. * @summary Add New Board Member with Role
  2136. *
  2137. * @description Only the admin user (the first user) can call the REST API.
  2138. *
  2139. * **Note**: see [Boards.set_board_member_permission](#set_board_member_permission)
  2140. * to later change the permissions.
  2141. *
  2142. * @param {string} boardId the board ID
  2143. * @param {string} userId the user ID
  2144. * @param {string} action the action (needs to be `add`)
  2145. * @param {boolean} isAdmin is the user an admin of the board
  2146. * @param {boolean} isNoComments disable comments
  2147. * @param {boolean} isCommentOnly only enable comments
  2148. * @param {boolean} isWorker is the user a board worker
  2149. * @return_type {_id: string,
  2150. * title: string}
  2151. */
  2152. JsonRoutes.add(
  2153. 'POST',
  2154. '/api/boards/:boardId/members/:userId/add',
  2155. function (req, res) {
  2156. try {
  2157. Authentication.checkUserId(req.userId);
  2158. const userId = req.params.userId;
  2159. const boardId = req.params.boardId;
  2160. const action = req.body.action;
  2161. const { isAdmin, isNoComments, isCommentOnly, isWorker } = req.body;
  2162. let data = Meteor.users.findOne({
  2163. _id: userId,
  2164. });
  2165. if (data !== undefined) {
  2166. if (action === 'add') {
  2167. data = Boards.find({
  2168. _id: boardId,
  2169. }).map(function (board) {
  2170. if (!board.hasMember(userId)) {
  2171. board.addMember(userId);
  2172. function isTrue(data) {
  2173. return data.toLowerCase() === 'true';
  2174. }
  2175. board.setMemberPermission(
  2176. userId,
  2177. isTrue(isAdmin),
  2178. isTrue(isNoComments),
  2179. isTrue(isCommentOnly),
  2180. isTrue(isWorker),
  2181. userId,
  2182. );
  2183. }
  2184. return {
  2185. _id: board._id,
  2186. title: board.title,
  2187. };
  2188. });
  2189. }
  2190. }
  2191. JsonRoutes.sendResult(res, { code: 200, data });
  2192. } catch (error) {
  2193. JsonRoutes.sendResult(res, {
  2194. code: 200,
  2195. data: error,
  2196. });
  2197. }
  2198. },
  2199. );
  2200. /**
  2201. * @operation remove_board_member
  2202. * @tag Boards
  2203. *
  2204. * @summary Remove Member from Board
  2205. *
  2206. * @description Only the admin user (the first user) can call the REST API.
  2207. *
  2208. * @param {string} boardId the board ID
  2209. * @param {string} userId the user ID
  2210. * @param {string} action the action (needs to be `remove`)
  2211. * @return_type {_id: string,
  2212. * title: string}
  2213. */
  2214. JsonRoutes.add(
  2215. 'POST',
  2216. '/api/boards/:boardId/members/:userId/remove',
  2217. function (req, res) {
  2218. try {
  2219. Authentication.checkUserId(req.userId);
  2220. const userId = req.params.userId;
  2221. const boardId = req.params.boardId;
  2222. const action = req.body.action;
  2223. let data = Meteor.users.findOne({
  2224. _id: userId,
  2225. });
  2226. if (data !== undefined) {
  2227. if (action === 'remove') {
  2228. data = Boards.find({
  2229. _id: boardId,
  2230. }).map(function (board) {
  2231. if (board.hasMember(userId)) {
  2232. board.removeMember(userId);
  2233. }
  2234. return {
  2235. _id: board._id,
  2236. title: board.title,
  2237. };
  2238. });
  2239. }
  2240. }
  2241. JsonRoutes.sendResult(res, { code: 200, data });
  2242. } catch (error) {
  2243. JsonRoutes.sendResult(res, {
  2244. code: 200,
  2245. data: error,
  2246. });
  2247. }
  2248. },
  2249. );
  2250. /**
  2251. * @operation new_user
  2252. *
  2253. * @summary Create a new user
  2254. *
  2255. * @description Only the admin user (the first user) can call the REST API.
  2256. *
  2257. * @param {string} username the new username
  2258. * @param {string} email the email of the new user
  2259. * @param {string} password the password of the new user
  2260. * @return_type {_id: string}
  2261. */
  2262. JsonRoutes.add('POST', '/api/users/', function (req, res) {
  2263. try {
  2264. Authentication.checkUserId(req.userId);
  2265. const id = Accounts.createUser({
  2266. username: req.body.username,
  2267. email: req.body.email,
  2268. password: req.body.password,
  2269. from: 'admin',
  2270. });
  2271. JsonRoutes.sendResult(res, {
  2272. code: 200,
  2273. data: {
  2274. _id: id,
  2275. },
  2276. });
  2277. } catch (error) {
  2278. JsonRoutes.sendResult(res, {
  2279. code: 200,
  2280. data: error,
  2281. });
  2282. }
  2283. });
  2284. /**
  2285. * @operation delete_user
  2286. *
  2287. * @summary Delete a user
  2288. *
  2289. * @description Only the admin user (the first user) can call the REST API.
  2290. *
  2291. * @param {string} userId the ID of the user to delete
  2292. * @return_type {_id: string}
  2293. */
  2294. JsonRoutes.add('DELETE', '/api/users/:userId', function (req, res) {
  2295. try {
  2296. Authentication.checkUserId(req.userId);
  2297. const id = req.params.userId;
  2298. // Delete user is enabled, but is still has bug of leaving empty user avatars
  2299. // to boards: boards members, card members and assignees have
  2300. // empty users. So it would be better to delete user from all boards before
  2301. // deleting user.
  2302. // See:
  2303. // - wekan/client/components/settings/peopleBody.jade deleteButton
  2304. // - wekan/client/components/settings/peopleBody.js deleteButton
  2305. // - wekan/client/components/sidebar/sidebar.js Popup.afterConfirm('removeMember'
  2306. // that does now remove member from board, card members and assignees correctly,
  2307. // but that should be used to remove user from all boards similarly
  2308. // - wekan/models/users.js Delete is not enabled
  2309. Meteor.users.remove({ _id: id });
  2310. JsonRoutes.sendResult(res, {
  2311. code: 200,
  2312. data: {
  2313. _id: id,
  2314. },
  2315. });
  2316. } catch (error) {
  2317. JsonRoutes.sendResult(res, {
  2318. code: 200,
  2319. data: error,
  2320. });
  2321. }
  2322. });
  2323. /**
  2324. * @operation create_user_token
  2325. *
  2326. * @summary Create a user token
  2327. *
  2328. * @description Only the admin user (the first user) can call the REST API.
  2329. *
  2330. * @param {string} userId the ID of the user to create token for.
  2331. * @return_type {_id: string}
  2332. */
  2333. JsonRoutes.add('POST', '/api/createtoken/:userId', function (req, res) {
  2334. try {
  2335. Authentication.checkUserId(req.userId);
  2336. const id = req.params.userId;
  2337. const token = Accounts._generateStampedLoginToken();
  2338. Accounts._insertLoginToken(id, token);
  2339. JsonRoutes.sendResult(res, {
  2340. code: 200,
  2341. data: {
  2342. _id: id,
  2343. authToken: token.token,
  2344. },
  2345. });
  2346. } catch (error) {
  2347. JsonRoutes.sendResult(res, {
  2348. code: 200,
  2349. data: error,
  2350. });
  2351. }
  2352. });
  2353. /**
  2354. * @operation delete_user_token
  2355. *
  2356. * @summary Delete one or all user token.
  2357. *
  2358. * @description Only the admin user (the first user) can call the REST API.
  2359. *
  2360. * @param {string} userId the user ID
  2361. * @param {string} token the user hashedToken
  2362. * @return_type {message: string}
  2363. */
  2364. JsonRoutes.add('POST', '/api/deletetoken', function (req, res) {
  2365. try {
  2366. const { userId, token } = req.body;
  2367. Authentication.checkUserId(req.userId);
  2368. let data = {
  2369. message: 'Expected a userId to be set but received none.',
  2370. };
  2371. if (token && userId) {
  2372. Accounts.destroyToken(userId, token);
  2373. data.message = 'Delete token: [' + token + '] from user: ' + userId;
  2374. } else if (userId) {
  2375. check(userId, String);
  2376. Users.update(
  2377. {
  2378. _id: userId,
  2379. },
  2380. {
  2381. $set: {
  2382. 'services.resume.loginTokens': '',
  2383. },
  2384. },
  2385. );
  2386. data.message = 'Delete all token from user: ' + userId;
  2387. }
  2388. JsonRoutes.sendResult(res, {
  2389. code: 200,
  2390. data,
  2391. });
  2392. } catch (error) {
  2393. JsonRoutes.sendResult(res, {
  2394. code: 200,
  2395. data: error,
  2396. });
  2397. }
  2398. });
  2399. }
  2400. export default Users;