ShareJsDoc.js 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414
  1. /* eslint-disable
  2. camelcase,
  3. max-len,
  4. no-undef,
  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. * DS001: Remove Babel/TypeScript constructor workaround
  12. * DS101: Remove unnecessary use of Array.from
  13. * DS102: Remove unnecessary code created because of implicit returns
  14. * DS103: Rewrite code to no longer use __guard__
  15. * DS205: Consider reworking code to avoid use of IIFEs
  16. * DS206: Consider reworking classes to avoid initClass
  17. * DS207: Consider shorter variations of null checks
  18. * Full docs: https://github.com/decaffeinate/decaffeinate/blob/master/docs/suggestions.md
  19. */
  20. define(['utils/EventEmitter', 'libs/sharejs'], function(EventEmitter, ShareJs) {
  21. let ShareJsDoc
  22. const SINGLE_USER_FLUSH_DELAY = 1000 // ms
  23. return (ShareJsDoc = (function() {
  24. ShareJsDoc = class ShareJsDoc extends EventEmitter {
  25. static initClass() {
  26. this.prototype.INFLIGHT_OP_TIMEOUT = 5000 // Retry sending ops after 5 seconds without an ack
  27. this.prototype.WAIT_FOR_CONNECTION_TIMEOUT = 500
  28. this.prototype.FATAL_OP_TIMEOUT = 30000
  29. }
  30. constructor(doc_id, docLines, version, socket) {
  31. super()
  32. // Dencode any binary bits of data
  33. // See http://ecmanaut.blogspot.co.uk/2006/07/encoding-decoding-utf8-in-javascript.html
  34. this.doc_id = doc_id
  35. this.socket = socket
  36. this.type = 'text'
  37. docLines = Array.from(docLines).map(line =>
  38. decodeURIComponent(escape(line))
  39. )
  40. const snapshot = docLines.join('\n')
  41. this.track_changes = false
  42. this.connection = {
  43. send: update => {
  44. this._startInflightOpTimeout(update)
  45. if (
  46. window.disconnectOnUpdate != null &&
  47. Math.random() < window.disconnectOnUpdate
  48. ) {
  49. sl_console.log('Disconnecting on update', update)
  50. window._ide.socket.socket.disconnect()
  51. }
  52. if (
  53. window.dropUpdates != null &&
  54. Math.random() < window.dropUpdates
  55. ) {
  56. sl_console.log('Simulating a lost update', update)
  57. return
  58. }
  59. if (this.track_changes) {
  60. if (update.meta == null) {
  61. update.meta = {}
  62. }
  63. update.meta.tc = this.track_changes_id_seeds.inflight
  64. }
  65. return this.socket.emit(
  66. 'applyOtUpdate',
  67. this.doc_id,
  68. update,
  69. error => {
  70. if (error != null) {
  71. return this._handleError(error)
  72. }
  73. }
  74. )
  75. },
  76. state: 'ok',
  77. id: this.socket.socket.sessionid
  78. }
  79. this._doc = new ShareJs.Doc(this.connection, this.doc_id, {
  80. type: this.type
  81. })
  82. this._doc.setFlushDelay(SINGLE_USER_FLUSH_DELAY)
  83. this._doc.on('change', (...args) => {
  84. return this.trigger('change', ...Array.from(args))
  85. })
  86. this._doc.on('acknowledge', () => {
  87. this.lastAcked = new Date() // note time of last ack from server for an op we sent
  88. return this.trigger('acknowledge')
  89. })
  90. this._doc.on('remoteop', (...args) => {
  91. // As soon as we're working with a collaborator, start sending
  92. // ops as quickly as possible for low latency.
  93. this._doc.setFlushDelay(0)
  94. return this.trigger('remoteop', ...Array.from(args))
  95. })
  96. this._doc.on('flipped_pending_to_inflight', () => {
  97. return this.trigger('flipped_pending_to_inflight')
  98. })
  99. this._doc.on('saved', () => {
  100. return this.trigger('saved')
  101. })
  102. this._doc.on('error', e => {
  103. return this._handleError(e)
  104. })
  105. this._bindToDocChanges(this._doc)
  106. this.processUpdateFromServer({
  107. open: true,
  108. v: version,
  109. snapshot
  110. })
  111. }
  112. submitOp(...args) {
  113. return this._doc.submitOp(...Array.from(args || []))
  114. }
  115. // The following code puts out of order messages into a queue
  116. // so that they can be processed in order. This is a workaround
  117. // for messages being delayed by redis cluster.
  118. // FIXME: REMOVE THIS WHEN REDIS PUBSUB IS SENDING MESSAGES IN ORDER
  119. _isAheadOfExpectedVersion(message) {
  120. return this._doc.version > 0 && message.v > this._doc.version
  121. }
  122. _pushOntoQueue(message) {
  123. sl_console.log(`[processUpdate] push onto queue ${message.v}`)
  124. // set a timer so that we never leave messages in the queue indefinitely
  125. if (!this.queuedMessageTimer) {
  126. this.queuedMessageTimer = setTimeout(() => {
  127. sl_console.log(
  128. `[processUpdate] queue timeout fired for ${message.v}`
  129. )
  130. // force the message to be processed after the timeout,
  131. // it will cause an error if the missing update has not arrived
  132. this.processUpdateFromServer(message)
  133. }, this.INFLIGHT_OP_TIMEOUT)
  134. }
  135. this.queuedMessages.push(message)
  136. // keep the queue in order, lowest version first
  137. this.queuedMessages.sort(function(a, b) {
  138. return a.v - b.v
  139. })
  140. }
  141. _clearQueue() {
  142. this.queuedMessages = []
  143. }
  144. _processQueue() {
  145. if (this.queuedMessages.length > 0) {
  146. nextAvailableVersion = this.queuedMessages[0].v
  147. if (nextAvailableVersion > this._doc.version) {
  148. // there are updates we still can't apply yet
  149. } else {
  150. // there's a version we can accept on the queue, apply it
  151. sl_console.log(
  152. `[processUpdate] taken from queue ${nextAvailableVersion}`
  153. )
  154. this.processUpdateFromServerInOrder(this.queuedMessages.shift())
  155. // clear the pending timer if the queue has now been cleared
  156. if (this.queuedMessages.length === 0 && this.queuedMessageTimer) {
  157. sl_console.log('[processUpdate] queue is empty, cleared timeout')
  158. clearTimeout(this.queuedMessageTimer)
  159. this.queuedMessageTimer = null
  160. }
  161. }
  162. }
  163. }
  164. // FIXME: This is the new method which reorders incoming updates if needed
  165. // called from Document.js
  166. processUpdateFromServerInOrder(message) {
  167. // Create an array to hold queued messages
  168. if (!this.queuedMessages) {
  169. this.queuedMessages = []
  170. }
  171. // Is this update ahead of the next expected update?
  172. // If so, put it on a queue to be handled later.
  173. if (this._isAheadOfExpectedVersion(message)) {
  174. this._pushOntoQueue(message)
  175. return // defer processing this update for now
  176. }
  177. var error = this.processUpdateFromServer(message)
  178. if (
  179. error instanceof Error &&
  180. error.message === 'Invalid version from server'
  181. ) {
  182. // if there was an error, abandon the queued updates ahead of this one
  183. this._clearQueue()
  184. return
  185. }
  186. // Do we have any messages queued up?
  187. // find the next message if available
  188. this._processQueue()
  189. }
  190. // FIXME: This is the original method. Switch back to this when redis
  191. // issues are resolved.
  192. processUpdateFromServer(message) {
  193. try {
  194. this._doc._onMessage(message)
  195. } catch (error) {
  196. // Version mismatches are thrown as errors
  197. console.log(error)
  198. this._handleError(error)
  199. return error // return the error for queue handling
  200. }
  201. if (
  202. __guard__(message != null ? message.meta : undefined, x => x.type) ===
  203. 'external'
  204. ) {
  205. return this.trigger('externalUpdate', message)
  206. }
  207. }
  208. catchUp(updates) {
  209. return (() => {
  210. const result = []
  211. for (let i = 0; i < updates.length; i++) {
  212. const update = updates[i]
  213. update.v = this._doc.version
  214. update.doc = this.doc_id
  215. result.push(this.processUpdateFromServer(update))
  216. }
  217. return result
  218. })()
  219. }
  220. getSnapshot() {
  221. return this._doc.snapshot
  222. }
  223. getVersion() {
  224. return this._doc.version
  225. }
  226. getType() {
  227. return this.type
  228. }
  229. clearInflightAndPendingOps() {
  230. this._doc.inflightOp = null
  231. this._doc.inflightCallbacks = []
  232. this._doc.pendingOp = null
  233. return (this._doc.pendingCallbacks = [])
  234. }
  235. flushPendingOps() {
  236. // This will flush any ops that are pending.
  237. // If there is an inflight op it will do nothing.
  238. return this._doc.flush()
  239. }
  240. updateConnectionState(state) {
  241. sl_console.log(`[updateConnectionState] Setting state to ${state}`)
  242. this.connection.state = state
  243. this.connection.id = this.socket.socket.sessionid
  244. this._doc.autoOpen = false
  245. this._doc._connectionStateChanged(state)
  246. return (this.lastAcked = null) // reset the last ack time when connection changes
  247. }
  248. hasBufferedOps() {
  249. return this._doc.inflightOp != null || this._doc.pendingOp != null
  250. }
  251. getInflightOp() {
  252. return this._doc.inflightOp
  253. }
  254. getPendingOp() {
  255. return this._doc.pendingOp
  256. }
  257. getRecentAck() {
  258. // check if we have received an ack recently (within a factor of two of the single user flush delay)
  259. return (
  260. this.lastAcked != null &&
  261. new Date() - this.lastAcked < 2 * SINGLE_USER_FLUSH_DELAY
  262. )
  263. }
  264. getOpSize(op) {
  265. // compute size of an op from its components
  266. // (total number of characters inserted and deleted)
  267. let size = 0
  268. for (let component of Array.from(op || [])) {
  269. if ((component != null ? component.i : undefined) != null) {
  270. size += component.i.length
  271. }
  272. if ((component != null ? component.d : undefined) != null) {
  273. size += component.d.length
  274. }
  275. }
  276. return size
  277. }
  278. attachToAce(ace) {
  279. return this._doc.attach_ace(ace, false, window.maxDocLength)
  280. }
  281. detachFromAce() {
  282. return typeof this._doc.detach_ace === 'function'
  283. ? this._doc.detach_ace()
  284. : undefined
  285. }
  286. attachToCM(cm) {
  287. return this._doc.attach_cm(cm, false)
  288. }
  289. detachFromCM() {
  290. return typeof this._doc.detach_cm === 'function'
  291. ? this._doc.detach_cm()
  292. : undefined
  293. } // If we're waiting for the project to join, try again in 0.5 seconds
  294. _startInflightOpTimeout(update) {
  295. this._startFatalTimeoutTimer(update)
  296. var retryOp = () => {
  297. // Only send the update again if inflightOp is still populated
  298. // This can be cleared when hard reloading the document in which
  299. // case we don't want to keep trying to send it.
  300. sl_console.log('[inflightOpTimeout] Trying op again')
  301. if (this._doc.inflightOp != null) {
  302. // When there is a socket.io disconnect, @_doc.inflightSubmittedIds
  303. // is updated with the socket.io client id of the current op in flight
  304. // (meta.source of the op).
  305. // @connection.id is the client id of the current socket.io session.
  306. // So we need both depending on whether the op was submitted before
  307. // one or more disconnects, or if it was submitted during the current session.
  308. update.dupIfSource = [
  309. this.connection.id,
  310. ...Array.from(this._doc.inflightSubmittedIds)
  311. ]
  312. // We must be joined to a project for applyOtUpdate to work on the real-time
  313. // service, so don't send an op if we're not. Connection state is set to 'ok'
  314. // when we've joined the project
  315. if (this.connection.state !== 'ok') {
  316. let timer
  317. sl_console.log(
  318. '[inflightOpTimeout] Not connected, retrying in 0.5s'
  319. )
  320. return (timer = setTimeout(
  321. retryOp,
  322. this.WAIT_FOR_CONNECTION_TIMEOUT
  323. ))
  324. } else {
  325. sl_console.log('[inflightOpTimeout] Sending')
  326. return this.connection.send(update)
  327. }
  328. }
  329. }
  330. const timer = setTimeout(retryOp, this.INFLIGHT_OP_TIMEOUT)
  331. return this._doc.inflightCallbacks.push(() => {
  332. this._clearFatalTimeoutTimer()
  333. return clearTimeout(timer)
  334. }) // 30 seconds
  335. }
  336. _startFatalTimeoutTimer(update) {
  337. // If an op doesn't get acked within FATAL_OP_TIMEOUT, something has
  338. // gone unrecoverably wrong (the op will have been retried multiple times)
  339. if (this._timeoutTimer != null) {
  340. return
  341. }
  342. return (this._timeoutTimer = setTimeout(() => {
  343. this._clearFatalTimeoutTimer()
  344. return this.trigger('op:timeout', update)
  345. }, this.FATAL_OP_TIMEOUT))
  346. }
  347. _clearFatalTimeoutTimer() {
  348. if (this._timeoutTimer == null) {
  349. return
  350. }
  351. clearTimeout(this._timeoutTimer)
  352. return (this._timeoutTimer = null)
  353. }
  354. _handleError(error, meta) {
  355. if (meta == null) {
  356. meta = {}
  357. }
  358. return this.trigger('error', error, meta)
  359. }
  360. _bindToDocChanges(doc) {
  361. const { submitOp } = doc
  362. doc.submitOp = (...args) => {
  363. this.trigger('op:sent', ...Array.from(args))
  364. doc.pendingCallbacks.push(() => {
  365. return this.trigger('op:acknowledged', ...Array.from(args))
  366. })
  367. return submitOp.apply(doc, args)
  368. }
  369. const { flush } = doc
  370. return (doc.flush = (...args) => {
  371. this.trigger('flush', doc.inflightOp, doc.pendingOp, doc.version)
  372. return flush.apply(doc, args)
  373. })
  374. }
  375. }
  376. ShareJsDoc.initClass()
  377. return ShareJsDoc
  378. })())
  379. })
  380. function __guard__(value, transform) {
  381. return typeof value !== 'undefined' && value !== null
  382. ? transform(value)
  383. : undefined
  384. }