ReviewPanelController.js 41 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300
  1. /* eslint-disable
  2. camelcase,
  3. max-len,
  4. no-return-assign,
  5. no-unused-vars,
  6. */
  7. // TODO: This file was created by bulk-decaffeinate.
  8. // Fix any style issues and re-enable lint.
  9. /*
  10. * decaffeinate suggestions:
  11. * DS101: Remove unnecessary use of Array.from
  12. * DS102: Remove unnecessary code created because of implicit returns
  13. * DS205: Consider reworking code to avoid use of IIFEs
  14. * DS207: Consider shorter variations of null checks
  15. * Full docs: https://github.com/decaffeinate/decaffeinate/blob/master/docs/suggestions.md
  16. */
  17. import App from '../../../base'
  18. import EventEmitter from '../../../utils/EventEmitter'
  19. import ColorManager from '../../colors/ColorManager'
  20. import RangesTracker from '../RangesTracker'
  21. export default App.controller(
  22. 'ReviewPanelController',
  23. function (
  24. $scope,
  25. $element,
  26. ide,
  27. $timeout,
  28. $http,
  29. $modal,
  30. eventTracking,
  31. localStorage
  32. ) {
  33. let UserTCSyncState
  34. const $reviewPanelEl = $element.find('#review-panel')
  35. const UserTypes = {
  36. MEMBER: 'member', // Invited, listed in project.members
  37. GUEST: 'guest', // Not invited, but logged in so has a user_id
  38. ANONYMOUS: 'anonymous', // No user_id
  39. }
  40. const currentUserType = function () {
  41. if ((ide.$scope.user != null ? ide.$scope.user.id : undefined) == null) {
  42. return UserTypes.ANONYMOUS
  43. } else {
  44. const user_id = ide.$scope.user.id
  45. const { project } = ide.$scope
  46. if (
  47. (project.owner != null ? project.owner.id : undefined) === user_id
  48. ) {
  49. return UserTypes.MEMBER
  50. }
  51. for (const member of Array.from(project.members)) {
  52. if (member._id === user_id) {
  53. return UserTypes.MEMBER
  54. }
  55. }
  56. return UserTypes.GUEST
  57. }
  58. }
  59. $scope.SubViews = {
  60. CUR_FILE: 'cur_file',
  61. OVERVIEW: 'overview',
  62. }
  63. $scope.UserTCSyncState = UserTCSyncState = {
  64. SYNCED: 'synced',
  65. PENDING: 'pending',
  66. }
  67. $scope.reviewPanel = {
  68. trackChangesState: {},
  69. trackChangesOnForEveryone: false,
  70. trackChangesOnForGuests: false,
  71. trackChangesForGuestsAvailable: false,
  72. entries: {},
  73. resolvedComments: {},
  74. hasEntries: false,
  75. subView: $scope.SubViews.CUR_FILE,
  76. openSubView: $scope.SubViews.CUR_FILE,
  77. overview: {
  78. loading: false,
  79. docsCollapsedState:
  80. JSON.parse(
  81. localStorage(`docs_collapsed_state:${$scope.project_id}`)
  82. ) || {},
  83. },
  84. dropdown: {
  85. loading: false,
  86. },
  87. commentThreads: {},
  88. resolvedThreadIds: {},
  89. rendererData: {},
  90. formattedProjectMembers: {},
  91. fullTCStateCollapsed: true,
  92. loadingThreads: false,
  93. // All selected changes. If a aggregated change (insertion + deletion) is selection, the two ids
  94. // will be present. The length of this array will differ from the count below (see explanation).
  95. selectedEntryIds: [],
  96. // A count of user-facing selected changes. An aggregated change (insertion + deletion) will count
  97. // as only one.
  98. nVisibleSelectedChanges: 0,
  99. }
  100. window.addEventListener('beforeunload', function () {
  101. const collapsedStates = {}
  102. for (const doc in $scope.reviewPanel.overview.docsCollapsedState) {
  103. const state = $scope.reviewPanel.overview.docsCollapsedState[doc]
  104. if (state) {
  105. collapsedStates[doc] = state
  106. }
  107. }
  108. const valToStore =
  109. Object.keys(collapsedStates).length > 0
  110. ? JSON.stringify(collapsedStates)
  111. : null
  112. return localStorage(
  113. `docs_collapsed_state:${$scope.project_id}`,
  114. valToStore
  115. )
  116. })
  117. $scope.$on('layout:pdf:linked', (event, state) =>
  118. $scope.$broadcast('review-panel:layout')
  119. )
  120. $scope.$on('layout:pdf:resize', (event, state) =>
  121. $scope.$broadcast('review-panel:layout', false)
  122. )
  123. $scope.$on('expandable-text-area:resize', event =>
  124. $timeout(() => $scope.$broadcast('review-panel:layout'))
  125. )
  126. // TODO: unused?
  127. $scope.$on('review-panel:sizes', (e, sizes) =>
  128. $scope.$broadcast('editor:set-scroll-size', sizes)
  129. )
  130. $scope.$watch('project.features.trackChangesVisible', function (visible) {
  131. if (visible == null) {
  132. return
  133. }
  134. if (!visible) {
  135. return ($scope.ui.reviewPanelOpen = false)
  136. }
  137. })
  138. $scope.$watch('project.members', function (members) {
  139. $scope.reviewPanel.formattedProjectMembers = {}
  140. if (($scope.project != null ? $scope.project.owner : undefined) != null) {
  141. $scope.reviewPanel.formattedProjectMembers[$scope.project.owner._id] =
  142. formatUser($scope.project.owner)
  143. }
  144. if (
  145. ($scope.project != null ? $scope.project.members : undefined) != null
  146. ) {
  147. return (() => {
  148. const result = []
  149. for (const member of Array.from(members)) {
  150. if (member.privileges === 'readAndWrite') {
  151. if ($scope.reviewPanel.trackChangesState[member._id] == null) {
  152. // An added member will have track changes enabled if track changes is on for everyone
  153. _setUserTCState(
  154. member._id,
  155. $scope.reviewPanel.trackChangesOnForEveryone,
  156. true
  157. )
  158. }
  159. result.push(
  160. ($scope.reviewPanel.formattedProjectMembers[member._id] =
  161. formatUser(member))
  162. )
  163. } else {
  164. result.push(undefined)
  165. }
  166. }
  167. return result
  168. })()
  169. }
  170. })
  171. $scope.commentState = {
  172. adding: false,
  173. content: '',
  174. }
  175. $scope.users = {}
  176. $scope.reviewPanelEventsBridge = new EventEmitter()
  177. ide.socket.on('new-comment', function (thread_id, comment) {
  178. const thread = getThread(thread_id)
  179. delete thread.submitting
  180. thread.messages.push(formatComment(comment))
  181. $scope.$apply()
  182. return $timeout(() => $scope.$broadcast('review-panel:layout'))
  183. })
  184. ide.socket.on('accept-changes', function (doc_id, change_ids) {
  185. if (doc_id !== $scope.editor.open_doc_id) {
  186. getChangeTracker(doc_id).removeChangeIds(change_ids)
  187. } else {
  188. $scope.$broadcast('changes:accept', change_ids)
  189. dispatchReviewPanelEvent('changes:accept', change_ids)
  190. }
  191. updateEntries(doc_id)
  192. return $scope.$apply(function () {})
  193. })
  194. ide.socket.on('resolve-thread', (thread_id, user) =>
  195. _onCommentResolved(thread_id, user)
  196. )
  197. ide.socket.on('reopen-thread', thread_id => _onCommentReopened(thread_id))
  198. ide.socket.on('delete-thread', function (thread_id) {
  199. _onThreadDeleted(thread_id)
  200. return $scope.$apply(function () {})
  201. })
  202. ide.socket.on('edit-message', function (thread_id, message_id, content) {
  203. _onCommentEdited(thread_id, message_id, content)
  204. return $scope.$apply(function () {})
  205. })
  206. ide.socket.on('delete-message', function (thread_id, message_id) {
  207. _onCommentDeleted(thread_id, message_id)
  208. return $scope.$apply(function () {})
  209. })
  210. const rangesTrackers = {}
  211. const getDocEntries = function (doc_id) {
  212. if ($scope.reviewPanel.entries[doc_id] == null) {
  213. $scope.reviewPanel.entries[doc_id] = {}
  214. }
  215. return $scope.reviewPanel.entries[doc_id]
  216. }
  217. const getDocResolvedComments = function (doc_id) {
  218. if ($scope.reviewPanel.resolvedComments[doc_id] == null) {
  219. $scope.reviewPanel.resolvedComments[doc_id] = {}
  220. }
  221. return $scope.reviewPanel.resolvedComments[doc_id]
  222. }
  223. function getThread(thread_id) {
  224. if ($scope.reviewPanel.commentThreads[thread_id] == null) {
  225. $scope.reviewPanel.commentThreads[thread_id] = { messages: [] }
  226. }
  227. return $scope.reviewPanel.commentThreads[thread_id]
  228. }
  229. function getChangeTracker(doc_id) {
  230. if (rangesTrackers[doc_id] == null) {
  231. rangesTrackers[doc_id] = new RangesTracker()
  232. rangesTrackers[doc_id].resolvedThreadIds =
  233. $scope.reviewPanel.resolvedThreadIds
  234. }
  235. return rangesTrackers[doc_id]
  236. }
  237. let scrollbar = {}
  238. $scope.reviewPanelEventsBridge.on(
  239. 'aceScrollbarVisibilityChanged',
  240. function (isVisible, scrollbarWidth) {
  241. scrollbar = { isVisible, scrollbarWidth }
  242. return updateScrollbar()
  243. }
  244. )
  245. function updateScrollbar() {
  246. if (
  247. scrollbar.isVisible &&
  248. $scope.reviewPanel.subView === $scope.SubViews.CUR_FILE &&
  249. !$scope.editor.showRichText
  250. ) {
  251. return $reviewPanelEl.css('right', `${scrollbar.scrollbarWidth}px`)
  252. } else {
  253. return $reviewPanelEl.css('right', '0')
  254. }
  255. }
  256. $scope.$watch(
  257. '!ui.reviewPanelOpen && reviewPanel.hasEntries',
  258. function (open, prevVal) {
  259. if (open == null) {
  260. return
  261. }
  262. $scope.ui.miniReviewPanelVisible = open
  263. if (open !== prevVal) {
  264. return $timeout(() => $scope.$broadcast('review-panel:toggle'))
  265. }
  266. }
  267. )
  268. $scope.$watch('ui.reviewPanelOpen', function (open) {
  269. if (open == null) {
  270. return
  271. }
  272. if (!open) {
  273. // Always show current file when not open, but save current state
  274. $scope.reviewPanel.openSubView = $scope.reviewPanel.subView
  275. $scope.reviewPanel.subView = $scope.SubViews.CUR_FILE
  276. } else {
  277. // Reset back to what we had when previously open
  278. $scope.reviewPanel.subView = $scope.reviewPanel.openSubView
  279. }
  280. return $timeout(function () {
  281. $scope.$broadcast('review-panel:toggle')
  282. return $scope.$broadcast('review-panel:layout', false)
  283. })
  284. })
  285. $scope.$watch('reviewPanel.subView', function (view) {
  286. if (view == null) {
  287. return
  288. }
  289. updateScrollbar()
  290. if (view === $scope.SubViews.OVERVIEW) {
  291. return refreshOverviewPanel()
  292. }
  293. })
  294. $scope.$watch('editor.sharejs_doc', function (doc, old_doc) {
  295. if (doc == null) {
  296. return
  297. }
  298. // The open doc range tracker is kept up to date in real-time so
  299. // replace any outdated info with this
  300. rangesTrackers[doc.doc_id] = doc.ranges
  301. rangesTrackers[doc.doc_id].resolvedThreadIds =
  302. $scope.reviewPanel.resolvedThreadIds
  303. $scope.reviewPanel.rangesTracker = rangesTrackers[doc.doc_id]
  304. if (old_doc != null) {
  305. old_doc.off('flipped_pending_to_inflight')
  306. }
  307. doc.on('flipped_pending_to_inflight', () => regenerateTrackChangesId(doc))
  308. return regenerateTrackChangesId(doc)
  309. })
  310. $scope.$watch(
  311. function () {
  312. const entries =
  313. $scope.reviewPanel.entries[$scope.editor.open_doc_id] || {}
  314. const permEntries = {}
  315. for (const entry in entries) {
  316. const entryData = entries[entry]
  317. if (!['add-comment', 'bulk-actions'].includes(entry)) {
  318. permEntries[entry] = entryData
  319. }
  320. }
  321. return Object.keys(permEntries).length
  322. },
  323. nEntries =>
  324. ($scope.reviewPanel.hasEntries =
  325. nEntries > 0 && $scope.project.features.trackChangesVisible)
  326. )
  327. function regenerateTrackChangesId(doc) {
  328. const old_id = getChangeTracker(doc.doc_id).getIdSeed()
  329. const new_id = RangesTracker.generateIdSeed()
  330. getChangeTracker(doc.doc_id).setIdSeed(new_id)
  331. return doc.setTrackChangesIdSeeds({ pending: new_id, inflight: old_id })
  332. }
  333. const refreshRanges = () =>
  334. $http
  335. .get(`/project/${$scope.project_id}/ranges`)
  336. .then(function (response) {
  337. const docs = response.data
  338. return (() => {
  339. const result = []
  340. for (const doc of Array.from(docs)) {
  341. if (
  342. $scope.reviewPanel.overview.docsCollapsedState[doc.id] == null
  343. ) {
  344. $scope.reviewPanel.overview.docsCollapsedState[doc.id] = false
  345. }
  346. if (doc.id !== $scope.editor.open_doc_id) {
  347. // this is kept up to date in real-time, don't overwrite
  348. const rangesTracker = getChangeTracker(doc.id)
  349. rangesTracker.comments =
  350. (doc.ranges != null ? doc.ranges.comments : undefined) || []
  351. rangesTracker.changes =
  352. (doc.ranges != null ? doc.ranges.changes : undefined) || []
  353. }
  354. result.push(updateEntries(doc.id))
  355. }
  356. return result
  357. })()
  358. })
  359. function refreshOverviewPanel() {
  360. $scope.reviewPanel.overview.loading = true
  361. return refreshRanges()
  362. .then(() => ($scope.reviewPanel.overview.loading = false))
  363. .catch(() => ($scope.reviewPanel.overview.loading = false))
  364. }
  365. $scope.refreshResolvedCommentsDropdown = function () {
  366. $scope.reviewPanel.dropdown.loading = true
  367. const q = refreshRanges()
  368. q.then(() => ($scope.reviewPanel.dropdown.loading = false))
  369. q.catch(() => ($scope.reviewPanel.dropdown.loading = false))
  370. return q
  371. }
  372. function updateEntries(doc_id) {
  373. const rangesTracker = getChangeTracker(doc_id)
  374. const entries = getDocEntries(doc_id)
  375. const resolvedComments = getDocResolvedComments(doc_id)
  376. let changed = false
  377. // Assume we'll delete everything until we see it, then we'll remove it from this object
  378. const delete_changes = {}
  379. for (const id in entries) {
  380. const change = entries[id]
  381. if (!['add-comment', 'bulk-actions'].includes(id)) {
  382. for (const entry_id of Array.from(change.entry_ids)) {
  383. delete_changes[entry_id] = true
  384. }
  385. }
  386. }
  387. for (const id in resolvedComments) {
  388. const change = resolvedComments[id]
  389. for (const entry_id of Array.from(change.entry_ids)) {
  390. delete_changes[entry_id] = true
  391. }
  392. }
  393. let potential_aggregate = false
  394. let prev_insertion = null
  395. for (const change of Array.from(rangesTracker.changes)) {
  396. changed = true
  397. if (
  398. potential_aggregate &&
  399. change.op.d &&
  400. change.op.p === prev_insertion.op.p + prev_insertion.op.i.length &&
  401. change.metadata.user_id === prev_insertion.metadata.user_id
  402. ) {
  403. // An actual aggregate op.
  404. entries[prev_insertion.id].type = 'aggregate-change'
  405. entries[prev_insertion.id].metadata.replaced_content = change.op.d
  406. entries[prev_insertion.id].entry_ids.push(change.id)
  407. } else {
  408. if (entries[change.id] == null) {
  409. entries[change.id] = {}
  410. }
  411. delete delete_changes[change.id]
  412. const new_entry = {
  413. type: change.op.i ? 'insert' : 'delete',
  414. entry_ids: [change.id],
  415. content: change.op.i || change.op.d,
  416. offset: change.op.p,
  417. metadata: change.metadata,
  418. }
  419. for (const key in new_entry) {
  420. entries[change.id][key] = new_entry[key]
  421. }
  422. }
  423. if (change.op.i) {
  424. potential_aggregate = true
  425. prev_insertion = change
  426. } else {
  427. potential_aggregate = false
  428. prev_insertion = null
  429. }
  430. if ($scope.users[change.metadata.user_id] == null) {
  431. if (!window.isRestrictedTokenMember) {
  432. refreshChangeUsers(change.metadata.user_id)
  433. }
  434. }
  435. }
  436. if (rangesTracker.comments.length > 0) {
  437. if (!window.isRestrictedTokenMember) {
  438. ensureThreadsAreLoaded()
  439. }
  440. }
  441. for (const comment of Array.from(rangesTracker.comments)) {
  442. let new_comment
  443. changed = true
  444. delete delete_changes[comment.id]
  445. if ($scope.reviewPanel.resolvedThreadIds[comment.op.t]) {
  446. new_comment =
  447. resolvedComments[comment.id] != null
  448. ? resolvedComments[comment.id]
  449. : (resolvedComments[comment.id] = {})
  450. delete entries[comment.id]
  451. } else {
  452. new_comment =
  453. entries[comment.id] != null
  454. ? entries[comment.id]
  455. : (entries[comment.id] = {})
  456. delete resolvedComments[comment.id]
  457. }
  458. const new_entry = {
  459. type: 'comment',
  460. thread_id: comment.op.t,
  461. entry_ids: [comment.id],
  462. content: comment.op.c,
  463. offset: comment.op.p,
  464. }
  465. for (const key in new_entry) {
  466. new_comment[key] = new_entry[key]
  467. }
  468. }
  469. for (const change_id in delete_changes) {
  470. const _ = delete_changes[change_id]
  471. changed = true
  472. delete entries[change_id]
  473. delete resolvedComments[change_id]
  474. }
  475. if (changed) {
  476. // TODO: unused?
  477. $scope.$broadcast('entries:changed')
  478. }
  479. return entries
  480. }
  481. $scope.$on('editor:track-changes:changed', function () {
  482. const doc_id = $scope.editor.open_doc_id
  483. const entries = updateEntries(doc_id)
  484. // For now, not worrying about entry panels for rich text
  485. if (!$scope.editor.showRichText) {
  486. $scope.$broadcast('review-panel:recalculate-screen-positions')
  487. dispatchReviewPanelEvent('recalculate-screen-positions', entries)
  488. return $scope.$broadcast('review-panel:layout')
  489. }
  490. })
  491. $scope.$on('editor:track-changes:visibility_changed', () =>
  492. $timeout(() => $scope.$broadcast('review-panel:layout', false))
  493. )
  494. $scope.$on(
  495. 'editor:focus:changed',
  496. function (e, selection_offset_start, selection_offset_end, selection) {
  497. const doc_id = $scope.editor.open_doc_id
  498. const entries = getDocEntries(doc_id)
  499. // All selected changes will be added to this array.
  500. $scope.reviewPanel.selectedEntryIds = []
  501. // Count of user-visible changes, i.e. an aggregated change will count as one.
  502. $scope.reviewPanel.nVisibleSelectedChanges = 0
  503. delete entries['add-comment']
  504. delete entries['bulk-actions']
  505. if (selection) {
  506. entries['add-comment'] = {
  507. type: 'add-comment',
  508. offset: selection_offset_start,
  509. length: selection_offset_end - selection_offset_start,
  510. }
  511. entries['bulk-actions'] = {
  512. type: 'bulk-actions',
  513. offset: selection_offset_start,
  514. length: selection_offset_end - selection_offset_start,
  515. }
  516. }
  517. for (const id in entries) {
  518. const entry = entries[id]
  519. let isChangeEntryAndWithinSelection = false
  520. if (
  521. entry.type === 'comment' &&
  522. !$scope.reviewPanel.resolvedThreadIds[entry.thread_id]
  523. ) {
  524. entry.focused =
  525. entry.offset <= selection_offset_start &&
  526. selection_offset_start <= entry.offset + entry.content.length
  527. } else if (entry.type === 'insert') {
  528. isChangeEntryAndWithinSelection =
  529. entry.offset >= selection_offset_start &&
  530. entry.offset + entry.content.length <= selection_offset_end
  531. entry.focused =
  532. entry.offset <= selection_offset_start &&
  533. selection_offset_start <= entry.offset + entry.content.length
  534. } else if (entry.type === 'delete') {
  535. isChangeEntryAndWithinSelection =
  536. selection_offset_start <= entry.offset &&
  537. entry.offset <= selection_offset_end
  538. entry.focused = entry.offset === selection_offset_start
  539. } else if (entry.type === 'aggregate-change') {
  540. isChangeEntryAndWithinSelection =
  541. entry.offset >= selection_offset_start &&
  542. entry.offset + entry.content.length <= selection_offset_end
  543. entry.focused =
  544. entry.offset <= selection_offset_start &&
  545. selection_offset_start <= entry.offset + entry.content.length
  546. } else if (
  547. ['add-comment', 'bulk-actions'].includes(entry.type) &&
  548. selection
  549. ) {
  550. entry.focused = true
  551. }
  552. if (isChangeEntryAndWithinSelection) {
  553. for (const entry_id of Array.from(entry.entry_ids)) {
  554. $scope.reviewPanel.selectedEntryIds.push(entry_id)
  555. }
  556. $scope.reviewPanel.nVisibleSelectedChanges++
  557. }
  558. }
  559. $scope.$broadcast('review-panel:recalculate-screen-positions')
  560. dispatchReviewPanelEvent('recalculate-screen-positions', entries)
  561. return $scope.$broadcast('review-panel:layout')
  562. }
  563. )
  564. $scope.acceptChanges = function (change_ids) {
  565. _doAcceptChanges(change_ids)
  566. eventTracking.sendMB('rp-changes-accepted', {
  567. view: $scope.ui.reviewPanelOpen ? $scope.reviewPanel.subView : 'mini',
  568. })
  569. }
  570. $scope.rejectChanges = function (change_ids) {
  571. _doRejectChanges(change_ids)
  572. eventTracking.sendMB('rp-changes-rejected', {
  573. view: $scope.ui.reviewPanelOpen ? $scope.reviewPanel.subView : 'mini',
  574. })
  575. }
  576. function _doAcceptChanges(change_ids) {
  577. $http.post(
  578. `/project/${$scope.project_id}/doc/${$scope.editor.open_doc_id}/changes/accept`,
  579. { change_ids, _csrf: window.csrfToken }
  580. )
  581. $scope.$broadcast('changes:accept', change_ids)
  582. dispatchReviewPanelEvent('changes:accept', change_ids)
  583. }
  584. const _doRejectChanges = change_ids => {
  585. $scope.$broadcast('changes:reject', change_ids)
  586. dispatchReviewPanelEvent('changes:reject', change_ids)
  587. }
  588. const bulkAccept = function () {
  589. _doAcceptChanges($scope.reviewPanel.selectedEntryIds.slice())
  590. eventTracking.sendMB('rp-bulk-accept', {
  591. view: $scope.ui.reviewPanelOpen ? $scope.reviewPanel.subView : 'mini',
  592. nEntries: $scope.reviewPanel.nVisibleSelectedChanges,
  593. })
  594. }
  595. const bulkReject = function () {
  596. _doRejectChanges($scope.reviewPanel.selectedEntryIds.slice())
  597. eventTracking.sendMB('rp-bulk-reject', {
  598. view: $scope.ui.reviewPanelOpen ? $scope.reviewPanel.subView : 'mini',
  599. nEntries: $scope.reviewPanel.nVisibleSelectedChanges,
  600. })
  601. }
  602. $scope.showBulkAcceptDialog = () => showBulkActionsDialog(true)
  603. $scope.showBulkRejectDialog = () => showBulkActionsDialog(false)
  604. const showBulkActionsDialog = isAccept =>
  605. $modal
  606. .open({
  607. templateUrl: 'bulkActionsModalTemplate',
  608. controller: 'BulkActionsModalController',
  609. resolve: {
  610. isAccept() {
  611. return isAccept
  612. },
  613. nChanges() {
  614. return $scope.reviewPanel.nVisibleSelectedChanges
  615. },
  616. },
  617. scope: $scope.$new(),
  618. })
  619. .result.then(function (isAccept) {
  620. if (isAccept) {
  621. return bulkAccept()
  622. } else {
  623. return bulkReject()
  624. }
  625. })
  626. $scope.handleTogglerClick = function (e) {
  627. e.target.blur()
  628. return $scope.toggleReviewPanel()
  629. }
  630. $scope.addNewComment = function () {
  631. $scope.$broadcast('comment:start_adding')
  632. return $scope.toggleReviewPanel()
  633. }
  634. $scope.addNewCommentFromKbdShortcut = function () {
  635. if (!$scope.project.features.trackChangesVisible) {
  636. return
  637. }
  638. $scope.$broadcast('comment:select_line')
  639. dispatchReviewPanelEvent('comment:select_line')
  640. if (!$scope.ui.reviewPanelOpen) {
  641. $scope.toggleReviewPanel()
  642. }
  643. return $timeout(function () {
  644. $scope.$broadcast('review-panel:layout')
  645. return $scope.$broadcast('comment:start_adding')
  646. })
  647. }
  648. $scope.startNewComment = function () {
  649. $scope.$broadcast('comment:select_line')
  650. dispatchReviewPanelEvent('comment:select_line')
  651. return $timeout(() => $scope.$broadcast('review-panel:layout'))
  652. }
  653. $scope.submitNewComment = function (content) {
  654. if (content == null || content === '') {
  655. return
  656. }
  657. const doc_id = $scope.editor.open_doc_id
  658. const entries = getDocEntries(doc_id)
  659. if (entries['add-comment'] == null) {
  660. return
  661. }
  662. const { offset, length } = entries['add-comment']
  663. const thread_id = RangesTracker.generateId()
  664. const thread = getThread(thread_id)
  665. thread.submitting = true
  666. $scope.$broadcast('comment:add', thread_id, offset, length)
  667. dispatchReviewPanelEvent('comment:add', {
  668. threadId: thread_id,
  669. offset,
  670. length,
  671. })
  672. $http
  673. .post(`/project/${$scope.project_id}/thread/${thread_id}/messages`, {
  674. content,
  675. _csrf: window.csrfToken,
  676. })
  677. .catch(() =>
  678. ide.showGenericMessageModal(
  679. 'Error submitting comment',
  680. 'Sorry, there was a problem submitting your comment'
  681. )
  682. )
  683. // TODO: unused?
  684. $scope.$broadcast('editor:clearSelection')
  685. $timeout(() => $scope.$broadcast('review-panel:layout'))
  686. eventTracking.sendMB('rp-new-comment', { size: content.length })
  687. }
  688. $scope.cancelNewComment = entry =>
  689. $timeout(() => $scope.$broadcast('review-panel:layout'))
  690. $scope.startReply = function (entry) {
  691. entry.replying = true
  692. return $timeout(() => $scope.$broadcast('review-panel:layout'))
  693. }
  694. $scope.submitReply = function (entry, entry_id) {
  695. const { thread_id } = entry
  696. const content = entry.replyContent
  697. $http
  698. .post(`/project/${$scope.project_id}/thread/${thread_id}/messages`, {
  699. content,
  700. _csrf: window.csrfToken,
  701. })
  702. .catch(() =>
  703. ide.showGenericMessageModal(
  704. 'Error submitting comment',
  705. 'Sorry, there was a problem submitting your comment'
  706. )
  707. )
  708. const trackingMetadata = {
  709. view: $scope.ui.reviewPanelOpen ? $scope.reviewPanel.subView : 'mini',
  710. size: entry.replyContent.length,
  711. thread: thread_id,
  712. }
  713. const thread = getThread(thread_id)
  714. thread.submitting = true
  715. entry.replyContent = ''
  716. entry.replying = false
  717. $timeout(() => $scope.$broadcast('review-panel:layout'))
  718. eventTracking.sendMB('rp-comment-reply', trackingMetadata)
  719. }
  720. $scope.cancelReply = function (entry) {
  721. entry.replying = false
  722. entry.replyContent = ''
  723. return $scope.$broadcast('review-panel:layout')
  724. }
  725. $scope.resolveComment = function (entry, entry_id) {
  726. entry.focused = false
  727. $http.post(
  728. `/project/${$scope.project_id}/thread/${entry.thread_id}/resolve`,
  729. { _csrf: window.csrfToken }
  730. )
  731. _onCommentResolved(entry.thread_id, ide.$scope.user)
  732. eventTracking.sendMB('rp-comment-resolve', {
  733. view: $scope.ui.reviewPanelOpen ? $scope.reviewPanel.subView : 'mini',
  734. })
  735. }
  736. $scope.unresolveComment = function (thread_id) {
  737. _onCommentReopened(thread_id)
  738. $http.post(`/project/${$scope.project_id}/thread/${thread_id}/reopen`, {
  739. _csrf: window.csrfToken,
  740. })
  741. eventTracking.sendMB('rp-comment-reopen')
  742. }
  743. function _onCommentResolved(thread_id, user) {
  744. const thread = getThread(thread_id)
  745. if (thread == null) {
  746. return
  747. }
  748. thread.resolved = true
  749. thread.resolved_by_user = formatUser(user)
  750. thread.resolved_at = new Date().toISOString()
  751. $scope.reviewPanel.resolvedThreadIds[thread_id] = true
  752. $scope.$broadcast('comment:resolve_threads', [thread_id])
  753. dispatchReviewPanelEvent('comment:resolve_threads', [thread_id])
  754. }
  755. function _onCommentReopened(thread_id) {
  756. const thread = getThread(thread_id)
  757. if (thread == null) {
  758. return
  759. }
  760. delete thread.resolved
  761. delete thread.resolved_by_user
  762. delete thread.resolved_at
  763. delete $scope.reviewPanel.resolvedThreadIds[thread_id]
  764. $scope.$broadcast('comment:unresolve_thread', thread_id)
  765. dispatchReviewPanelEvent('comment:unresolve_thread', thread_id)
  766. }
  767. function _onThreadDeleted(thread_id) {
  768. delete $scope.reviewPanel.resolvedThreadIds[thread_id]
  769. delete $scope.reviewPanel.commentThreads[thread_id]
  770. $scope.$broadcast('comment:remove', thread_id)
  771. dispatchReviewPanelEvent('comment:remove', thread_id)
  772. }
  773. function _onCommentEdited(thread_id, comment_id, content) {
  774. const thread = getThread(thread_id)
  775. if (thread == null) {
  776. return
  777. }
  778. for (const message of Array.from(thread.messages)) {
  779. if (message.id === comment_id) {
  780. message.content = content
  781. }
  782. }
  783. return updateEntries()
  784. }
  785. function _onCommentDeleted(thread_id, comment_id) {
  786. const thread = getThread(thread_id)
  787. if (thread == null) {
  788. return
  789. }
  790. thread.messages = thread.messages.filter(m => m.id !== comment_id)
  791. return updateEntries()
  792. }
  793. $scope.deleteThread = function (entry_id, doc_id, thread_id) {
  794. _onThreadDeleted(thread_id)
  795. $http({
  796. method: 'DELETE',
  797. url: `/project/${$scope.project_id}/doc/${doc_id}/thread/${thread_id}`,
  798. headers: {
  799. 'X-CSRF-Token': window.csrfToken,
  800. },
  801. })
  802. eventTracking.sendMB('rp-comment-delete')
  803. }
  804. $scope.saveEdit = function (thread_id, comment) {
  805. $http.post(
  806. `/project/${$scope.project_id}/thread/${thread_id}/messages/${comment.id}/edit`,
  807. {
  808. content: comment.content,
  809. _csrf: window.csrfToken,
  810. }
  811. )
  812. return $timeout(() => $scope.$broadcast('review-panel:layout'))
  813. }
  814. $scope.deleteComment = function (thread_id, comment) {
  815. _onCommentDeleted(thread_id, comment.id)
  816. $http({
  817. method: 'DELETE',
  818. url: `/project/${$scope.project_id}/thread/${thread_id}/messages/${comment.id}`,
  819. headers: {
  820. 'X-CSRF-Token': window.csrfToken,
  821. },
  822. })
  823. return $timeout(() => $scope.$broadcast('review-panel:layout'))
  824. }
  825. $scope.setSubView = function (subView) {
  826. $scope.reviewPanel.subView = subView
  827. eventTracking.sendMB('rp-subview-change', { subView })
  828. }
  829. $scope.gotoEntry = (doc_id, entry) =>
  830. ide.editorManager.openDocId(doc_id, { gotoOffset: entry.offset })
  831. $scope.toggleFullTCStateCollapse = function () {
  832. if ($scope.project.features.trackChanges) {
  833. return ($scope.reviewPanel.fullTCStateCollapsed =
  834. !$scope.reviewPanel.fullTCStateCollapsed)
  835. } else {
  836. _sendAnalytics()
  837. return $scope.openTrackChangesUpgradeModal()
  838. }
  839. }
  840. const _sendAnalytics = () => {
  841. eventTracking.send(
  842. 'subscription-funnel',
  843. 'editor-click-feature',
  844. 'real-time-track-changes'
  845. )
  846. eventTracking.sendMB('paywall-prompt', {
  847. 'paywall-type': 'track-changes',
  848. })
  849. }
  850. const _setUserTCState = function (userId, newValue, isLocal) {
  851. if (isLocal == null) {
  852. isLocal = false
  853. }
  854. if ($scope.reviewPanel.trackChangesState[userId] == null) {
  855. $scope.reviewPanel.trackChangesState[userId] = {}
  856. }
  857. const state = $scope.reviewPanel.trackChangesState[userId]
  858. if (
  859. state.syncState == null ||
  860. state.syncState === UserTCSyncState.SYNCED
  861. ) {
  862. state.value = newValue
  863. state.syncState = UserTCSyncState.SYNCED
  864. } else if (
  865. state.syncState === UserTCSyncState.PENDING &&
  866. state.value === newValue
  867. ) {
  868. state.syncState = UserTCSyncState.SYNCED
  869. } else if (isLocal) {
  870. state.value = newValue
  871. state.syncState = UserTCSyncState.PENDING
  872. }
  873. if (userId === ide.$scope.user.id) {
  874. return ($scope.editor.wantTrackChanges = newValue)
  875. }
  876. }
  877. const _setEveryoneTCState = function (newValue, isLocal) {
  878. if (isLocal == null) {
  879. isLocal = false
  880. }
  881. $scope.reviewPanel.trackChangesOnForEveryone = newValue
  882. const { project } = $scope
  883. for (const member of Array.from(project.members)) {
  884. _setUserTCState(member._id, newValue, isLocal)
  885. }
  886. _setGuestsTCState(newValue, isLocal)
  887. return _setUserTCState(project.owner._id, newValue, isLocal)
  888. }
  889. function _setGuestsTCState(newValue, isLocal) {
  890. if (isLocal == null) {
  891. isLocal = false
  892. }
  893. $scope.reviewPanel.trackChangesOnForGuests = newValue
  894. if (
  895. currentUserType() === UserTypes.GUEST ||
  896. currentUserType() === UserTypes.ANONYMOUS
  897. ) {
  898. return ($scope.editor.wantTrackChanges = newValue)
  899. }
  900. }
  901. const applyClientTrackChangesStateToServer = function () {
  902. const data = {}
  903. if ($scope.reviewPanel.trackChangesOnForEveryone) {
  904. data.on = true
  905. } else {
  906. data.on_for = {}
  907. for (const userId in $scope.reviewPanel.trackChangesState) {
  908. const userState = $scope.reviewPanel.trackChangesState[userId]
  909. data.on_for[userId] = userState.value
  910. }
  911. if ($scope.reviewPanel.trackChangesOnForGuests) {
  912. data.on_for_guests = true
  913. }
  914. }
  915. data._csrf = window.csrfToken
  916. return $http.post(`/project/${$scope.project_id}/track_changes`, data)
  917. }
  918. const applyTrackChangesStateToClient = function (state) {
  919. if (typeof state === 'boolean') {
  920. _setEveryoneTCState(state)
  921. return _setGuestsTCState(state)
  922. } else {
  923. const { project } = $scope
  924. $scope.reviewPanel.trackChangesOnForEveryone = false
  925. _setGuestsTCState(state.__guests__ === true)
  926. for (const member of Array.from(project.members)) {
  927. _setUserTCState(
  928. member._id,
  929. state[member._id] != null ? state[member._id] : false
  930. )
  931. }
  932. return _setUserTCState(
  933. $scope.project.owner._id,
  934. state[$scope.project.owner._id] != null
  935. ? state[$scope.project.owner._id]
  936. : false
  937. )
  938. }
  939. }
  940. $scope.toggleTrackChangesForEveryone = function (onForEveryone) {
  941. _setEveryoneTCState(onForEveryone, true)
  942. _setGuestsTCState(onForEveryone, true)
  943. return applyClientTrackChangesStateToServer()
  944. }
  945. $scope.toggleTrackChangesForGuests = function (onForGuests) {
  946. _setGuestsTCState(onForGuests, true)
  947. return applyClientTrackChangesStateToServer()
  948. }
  949. $scope.toggleTrackChangesForUser = function (onForUser, userId) {
  950. _setUserTCState(userId, onForUser, true)
  951. return applyClientTrackChangesStateToServer()
  952. }
  953. ide.socket.on('toggle-track-changes', state =>
  954. $scope.$apply(() => applyTrackChangesStateToClient(state))
  955. )
  956. $scope.toggleTrackChangesFromKbdShortcut = function () {
  957. if (
  958. !(
  959. $scope.project.features.trackChangesVisible &&
  960. $scope.project.features.trackChanges
  961. )
  962. ) {
  963. return
  964. }
  965. return $scope.toggleTrackChangesForUser(
  966. !$scope.reviewPanel.trackChangesState[ide.$scope.user.id].value,
  967. ide.$scope.user.id
  968. )
  969. }
  970. const setGuestFeatureBasedOnProjectAccessLevel = projectPublicAccessLevel =>
  971. ($scope.reviewPanel.trackChangesForGuestsAvailable =
  972. projectPublicAccessLevel === 'tokenBased')
  973. const onToggleTrackChangesForGuestsAvailability = function (available) {
  974. // If the feature is no longer available we need to turn off the guest flag
  975. if (available) {
  976. return
  977. }
  978. if (!$scope.reviewPanel.trackChangesOnForGuests) {
  979. return
  980. } // Already turned off
  981. if ($scope.reviewPanel.trackChangesOnForEveryone) {
  982. return
  983. } // Overrides guest setting
  984. return $scope.toggleTrackChangesForGuests(false)
  985. }
  986. $scope.$watch(
  987. 'project.publicAccesLevel',
  988. setGuestFeatureBasedOnProjectAccessLevel
  989. )
  990. $scope.$watch(
  991. 'reviewPanel.trackChangesForGuestsAvailable',
  992. function (available) {
  993. if (available != null) {
  994. return onToggleTrackChangesForGuestsAvailability(available)
  995. }
  996. }
  997. )
  998. let _inited = false
  999. ide.$scope.$on('project:joined', function () {
  1000. if (_inited) {
  1001. return
  1002. }
  1003. const { project } = ide.$scope
  1004. if (project.features.trackChanges) {
  1005. applyTrackChangesStateToClient(project.trackChangesState)
  1006. } else {
  1007. applyTrackChangesStateToClient(false)
  1008. }
  1009. setGuestFeatureBasedOnProjectAccessLevel(project.publicAccesLevel)
  1010. return (_inited = true)
  1011. })
  1012. let _refreshingRangeUsers = false
  1013. const _refreshedForUserIds = {}
  1014. function refreshChangeUsers(refresh_for_user_id) {
  1015. if (refresh_for_user_id != null) {
  1016. if (_refreshedForUserIds[refresh_for_user_id] != null) {
  1017. // We've already tried to refresh to get this user id, so stop it looping
  1018. return
  1019. }
  1020. _refreshedForUserIds[refresh_for_user_id] = true
  1021. }
  1022. // Only do one refresh at once
  1023. if (_refreshingRangeUsers) {
  1024. return
  1025. }
  1026. _refreshingRangeUsers = true
  1027. return $http
  1028. .get(`/project/${$scope.project_id}/changes/users`)
  1029. .then(function (response) {
  1030. const users = response.data
  1031. _refreshingRangeUsers = false
  1032. $scope.users = {}
  1033. // Always include ourself, since if we submit an op, we might need to display info
  1034. // about it locally before it has been flushed through the server
  1035. if (
  1036. (ide.$scope.user != null ? ide.$scope.user.id : undefined) != null
  1037. ) {
  1038. $scope.users[ide.$scope.user.id] = formatUser(ide.$scope.user)
  1039. }
  1040. return (() => {
  1041. const result = []
  1042. for (const user of Array.from(users)) {
  1043. if (user.id != null) {
  1044. result.push(($scope.users[user.id] = formatUser(user)))
  1045. } else {
  1046. result.push(undefined)
  1047. }
  1048. }
  1049. return result
  1050. })()
  1051. })
  1052. .catch(() => (_refreshingRangeUsers = false))
  1053. }
  1054. let _threadsLoaded = false
  1055. function ensureThreadsAreLoaded() {
  1056. if (_threadsLoaded) {
  1057. // We get any updates in real time so only need to load them once.
  1058. return
  1059. }
  1060. _threadsLoaded = true
  1061. $scope.reviewPanel.loadingThreads = true
  1062. return $http
  1063. .get(`/project/${$scope.project_id}/threads`)
  1064. .then(function (response) {
  1065. const threads = response.data
  1066. $scope.reviewPanel.loadingThreads = false
  1067. for (const thread_id in $scope.reviewPanel.resolvedThreadIds) {
  1068. const _ = $scope.reviewPanel.resolvedThreadIds[thread_id]
  1069. delete $scope.reviewPanel.resolvedThreadIds[thread_id]
  1070. }
  1071. for (const thread_id in threads) {
  1072. const thread = threads[thread_id]
  1073. for (const comment of Array.from(thread.messages)) {
  1074. formatComment(comment)
  1075. }
  1076. if (thread.resolved_by_user != null) {
  1077. thread.resolved_by_user = formatUser(thread.resolved_by_user)
  1078. $scope.reviewPanel.resolvedThreadIds[thread_id] = true
  1079. $scope.$broadcast('comment:resolve_threads', [thread_id])
  1080. dispatchReviewPanelEvent('comment:resolve_threads', [thread_id])
  1081. }
  1082. }
  1083. $scope.reviewPanel.commentThreads = threads
  1084. return $timeout(() => $scope.$broadcast('review-panel:layout'))
  1085. })
  1086. }
  1087. function formatComment(comment) {
  1088. comment.user = formatUser(comment.user)
  1089. comment.timestamp = new Date(comment.timestamp)
  1090. return comment
  1091. }
  1092. function formatUser(user) {
  1093. let isSelf, name
  1094. const id =
  1095. (user != null ? user._id : undefined) ||
  1096. (user != null ? user.id : undefined)
  1097. if (id == null) {
  1098. return {
  1099. email: null,
  1100. name: 'Anonymous',
  1101. isSelf: false,
  1102. hue: ColorManager.ANONYMOUS_HUE,
  1103. avatar_text: 'A',
  1104. }
  1105. }
  1106. if (id === window.user_id) {
  1107. name = 'You'
  1108. isSelf = true
  1109. } else {
  1110. name = [user.first_name, user.last_name]
  1111. .filter(n => n != null && n !== '')
  1112. .join(' ')
  1113. if (name === '') {
  1114. name =
  1115. (user.email != null ? user.email.split('@')[0] : undefined) ||
  1116. 'Unknown'
  1117. }
  1118. isSelf = false
  1119. }
  1120. return {
  1121. id,
  1122. email: user.email,
  1123. name,
  1124. isSelf,
  1125. hue: ColorManager.getHueForUserId(id),
  1126. avatar_text: [user.first_name, user.last_name]
  1127. .filter(n => n != null)
  1128. .map(n => n[0])
  1129. .join(''),
  1130. }
  1131. }
  1132. $scope.openTrackChangesUpgradeModal = () =>
  1133. $modal.open({
  1134. templateUrl: 'trackChangesUpgradeModalTemplate',
  1135. controller: 'TrackChangesUpgradeModalController',
  1136. scope: $scope.$new(),
  1137. })
  1138. // listen for events from the CodeMirror 6 track changes extension
  1139. window.addEventListener('editor:event', event => {
  1140. const { type, payload } = event.detail
  1141. switch (type) {
  1142. case 'line-height': {
  1143. $scope.reviewPanel.rendererData.lineHeight = payload
  1144. $scope.$broadcast('review-panel:layout')
  1145. break
  1146. }
  1147. case 'track-changes:changed': {
  1148. $scope.$broadcast('editor:track-changes:changed')
  1149. break
  1150. }
  1151. case 'track-changes:visibility_changed': {
  1152. $scope.$broadcast('editor:track-changes:visibility_changed')
  1153. break
  1154. }
  1155. case 'focus:changed': {
  1156. const { from, to, empty } = payload
  1157. $scope.$broadcast('editor:focus:changed', from, to, !empty)
  1158. break
  1159. }
  1160. }
  1161. })
  1162. }
  1163. )
  1164. // send events to the CodeMirror 6 track changes extension
  1165. const dispatchReviewPanelEvent = (type, payload) => {
  1166. window.dispatchEvent(
  1167. new CustomEvent('review-panel:event', {
  1168. detail: { type, payload },
  1169. })
  1170. )
  1171. }