1 line
27 KiB
JavaScript
1 line
27 KiB
JavaScript
|
"use strict";(self["webpackChunk_jupyterlab_application_top"]=self["webpackChunk_jupyterlab_application_top"]||[]).push([[5521],{65521:(t,e,s)=>{s.r(e);s.d(e,{YBaseCell:()=>k,YCodeCell:()=>C,YDocument:()=>b,YFile:()=>v,YMarkdownCell:()=>V,YNotebook:()=>E,YRawCell:()=>x,convertYMapEventToMapChange:()=>n,createMutex:()=>a,createStandaloneCell:()=>w});function n(t){let e=new Map;t.changes.keys.forEach(((t,s)=>{e.set(s,{action:t.action,oldValue:t.oldValue,newValue:this.ymeta.get(s)})}));return e}const a=()=>{let t=true;return e=>{if(t){t=false;try{e()}finally{t=true}}}};var o=s(5592);var i=s(2336);var r=s(64191);var d=s(63616);var c=s(5739);var l=s(53110);var u=s(74356);const h=3e4;class g extends c.c{constructor(t){super();this.doc=t;this.clientID=t.clientID;this.states=new Map;this.meta=new Map;this._checkInterval=setInterval((()=>{const t=r._g();if(this.getLocalState()!==null&&h/2<=t-this.meta.get(this.clientID).lastUpdated){this.setLocalState(this.getLocalState())}const e=[];this.meta.forEach(((s,n)=>{if(n!==this.clientID&&h<=t-s.lastUpdated&&this.states.has(n)){e.push(n)}}));if(e.length>0){p(this,e,"timeout")}}),d.RI(h/10));t.on("destroy",(()=>{this.destroy()}));this.setLocalState({})}destroy(){this.emit("destroy",[this]);this.setLocalState(null);super.destroy();clearInterval(this._checkInterval)}getLocalState(){return this.states.get(this.clientID)||null}setLocalState(t){const e=this.clientID;const s=this.meta.get(e);const n=s===undefined?0:s.clock+1;const a=this.states.get(e);if(t===null){this.states.delete(e)}else{this.states.set(e,t)}this.meta.set(e,{clock:n,lastUpdated:r._g()});const o=[];const i=[];const d=[];const c=[];if(t===null){c.push(e)}else if(a==null){if(t!=null){o.push(e)}}else{i.push(e);if(!l.vo(a,t)){d.push(e)}}if(o.length>0||d.length>0||c.length>0){this.emit("change",[{added:o,updated:d,removed:c},"local"])}this.emit("update",[{added:o,updated:i,removed:c},"local"])}setLocalStateField(t,e){const s=this.getLocalState();if(s!==null){this.setLocalState({...s,[t]:e})}}getStates(){return this.states}}const p=(t,e,s)=>{const n=[];for(let a=0;a<e.length;a++){const s=e[a];if(t.states.has(s)){t.states.delete(s);if(s===t.clientID){const e=t.meta.get(s);t.meta.set(s,{clock:e.clock+1,lastUpdated:r._g()})}n.push(s)}}if(n.length>0){t.emit("change",[{added:[],updated:[],removed:n},s]);t.emit("update",[{added:[],updated:[],removed:n},s])}};const m=(t,e,s=t.states)=>{const n=e.length;const a=encoding.createEncoder();encoding.writeVarUint(a,n);for(let o=0;o<n;o++){const n=e[o];const i=s.get(n)||null;const r=t.meta.get(n).clock;encoding.writeVarUint(a,n);encoding.writeVarUint(a,r);encoding.writeVarString(a,JSON.stringify(i))}return encoding.toUint8Array(a)};const y=(t,e)=>{const s=decoding.createDecoder(t);const n=encoding.createEncoder();const a=decoding.readVarUint(s);encoding.writeVarUint(n,a);for(let o=0;o<a;o++){const t=decoding.readVarUint(s);const a=decoding.readVarUint(s);const o=JSON.parse(decoding.readVarString(s));const i=e(o);encoding.writeVarUint(n,t);encoding.writeVarUint(n,a);encoding.writeVarString(n,JSON.stringify(i))}return encoding.toUint8Array(n)};const _=(t,e,s)=>{const n=decoding.createDecoder(e);const a=time.getUnixTime();const o=[];const i=[];const r=[];const d=[];const c=decoding.readVarUint(n);for(let l=0;l<c;l++){const e=decoding.readVarUint(n);let s=decoding.readVarUint(n);const c=JSON.parse(decoding.readVarString(n));const l=t.meta.get(e);const u=t.states.get(e);const h=l===undefined?0:l.clock;if(h<s||h===s&&c===null&&t.states.has(e)){if(c===null){if(e===t.clientID&&t.getLocalState()!=null){s++}else{t.states.delete(e)}}else{t.states.set(e,c)}t.meta.set(e,{clock:s,lastUpdated:a});if(l===undefined&&c!==null){o.push(e)}else if(l!==undefined&&c===null){d.push(e)}else if(c!==null){if(!f.equalityDeep(c,u)){r.push(e)}i.push(e)}}}if(o.length>0||r.length>0||d.length>0){t.emit("change",[{added:o,updated:r,removed:d},s])}if(o.length>0||i.length>0||d.length>0){t.emit("update",[{added:o,updated:i,removed:d},s])}};class b{constructor(t){var e;this.onStateChanged=t=>{const e=new Array;t.keysChanged.forEach
|