byp4a55 professor6T9

Linux SamCT211 4.4.302+ #86009 SMP Wed Nov 26 18:19:20 CST 2025 x86_64
nginx/1.23.1
192.168.4.211

File Name : CollabObject.js

"use strict";Object.defineProperty(exports,"__esModule",{value:true});Object.defineProperty(exports,"default",{enumerable:true,get:function(){return i}});const t=a(require("./Constants"));const e=require("./error");const r=require("./snapshot");const s=require("../webapi/error");const n=a(require("lodash/isEqual"));const o=require("@synology-office/logger");function a(t){return t&&t.__esModule?t:{default:t}}class i{constructor(t,e,r){this.objectId=t;this.password=e;this.migrator=r.migrator;this.snapshotter=r.snapshotter;this.version=0}getObjectId(){return this.objectId}getPassword(){return this.password}getSchema(t){const e=this.doGetSchema();if(t==null||t>=e.getVersion()){return e}else{return this.doGetLegacySchema(t)}}getVersionCache(){return this.version}createVersionError(t,r){return new e.OfficeError(`${this.getObjectId()}: ${(0,e.getVersionErrorMessage)(r,t,this.getVersionCache())}`,r)}assertVersion(e,r=false){if(r&&e<this.getVersionCache()){throw this.createVersionError(e,t.default.ERR_VERSION_NOT_CURRENT)}if(e<0){throw this.createVersionError(e,t.default.ERR_INVALID_VERSION)}}async handleSnapshotter(t,...e){const r=await this.snapshotter[t](this.getObjectId(),...e);if(t==="init"||t==="step"||t==="stepRebase"){this.version=r.version}return r}ensureContentVersion(t){if(!t){return 0}return t<=Number.MAX_SAFE_INTEGER/2?t:Number.MAX_SAFE_INTEGER/4}async initCommands(t){const e=t.content?.data?.attrs?.schema;const r=await this.readCommands({legacyFile:!e||e<4});const s=t.command;if(s&&r&&s.length<=r.length&&(0,n.default)(s,r.slice(0,s.length))){return r.slice(s.length)}else{return r||[]}}async initSnapshotData(t,e){const r=this.getObjectId();const{data:n,version:a}=t.content||{};const{data:i}=t.comment||{};const h=n?n.attrs?.schema??1:t.schema_version;const c=this.ensureContentVersion(a);let d=false;const l=this.getSchema().getVersion();if(h>=0&&h!==l){if(h>l){o.logger.error(`${r}: failed to migrate, ${h} is newer than ${l}`);throw s.WEBAPI_ERR.SYNOFFICE_ERR_OFILE_SCHEMA_VERSION}o.logger.info(`${r}: Start schema migration from ${h} to ${l}.`);const{doc:a,comments:m,migrated:u,migrationCommands:f}=await this.migrator.migrate(r,{doc:n||this.getSchema(h).getPresetJson(),comments:i||[],commands:e,options:{page_setup:t.page_setup,style:t.style}});d=u;await this.handleSnapshotter("init",{password:this.password,version:c+e.length+f.length,doc:a,comments:m,queuedCommands:e,additionalCommands:f,applyCommands:false})}else{await this.handleSnapshotter("init",{password:this.password,version:c,doc:n,comments:i,queuedCommands:e,applyCommands:true})}return{migrated:d}}async init(t){try{const e=await this.initCommands(t);return this.initSnapshotData(t,e)}catch(t){if(typeof t==="number"){throw new e.OfficeError(`${this.getObjectId()}: Failed to init. err: ${t.toString()}`)}throw t}}initSteps(){}async destroy(){try{await this.handleSnapshotter("destroy")}catch(t){o.logger.error(`${this.getObjectId()}: Failed to destroy.`,t)}}async applySteps(s,n,o,a,i){this.assertVersion(n,!i);const h=s;for(const t of h){t.uid=o;t.clientID=a}let c;try{if(i){c=await this.handleSnapshotter("stepRebase",h,n)}else{c=await this.handleSnapshotter("step",h,n)}}catch(s){if(s===r.SnapshotErrorEnum.INVALID_COMMAND){throw new e.OfficeError(`${this.getObjectId()}: Invalid command`,t.default.ERR_INVALID_COMMAND)}else if(s===r.SnapshotErrorEnum.INVALID_VERSION){if(!i){throw this.createVersionError(n,t.default.ERR_VERSION_NOT_CURRENT)}}throw new e.OfficeError(`${this.getObjectId()}: Failed to apply steps. err: ${s}`)}return c}async drain(){try{return await this.handleSnapshotter("drain")}catch(t){throw new e.OfficeError(`${this.getObjectId()}: Failed to drain. err: ${t}`)}}async snapshot(t){try{return await this.handleSnapshotter("snapshot",t)}catch(t){throw new e.OfficeError(`${this.getObjectId()}: Failed to do snapshot. err: ${t}`)}}async cut(t){if(t===0){return}try{return await this.handleSnapshotter("cut",t)}catch(t){if(t!==r.SnapshotErrorEnum.RUNNER_NOT_INIT){o.logger.error(`${this.getObjectId()}: Failed to cut command queue.`,t)}}}async fetchComments(t){try{return await this.handleSnapshotter("fetchComments",t)}catch(t){throw new e.OfficeError(`${this.getObjectId()}: Failed to fetch comments. err: ${t}`)}}async fetchCommands(s,n=false){this.assertVersion(s);try{const t=await this.handleSnapshotter("fetchCommands",s,n);return t}catch(n){if(n===r.SnapshotErrorEnum.TASK_TIMEOUT){return null}else if(n===r.SnapshotErrorEnum.INVALID_VERSION){throw this.createVersionError(s,t.default.ERR_HISTORY_NOT_AVAIL)}else{throw new e.OfficeError(`${this.getObjectId()}: Failed to fetch commands. err: ${n}`)}}}async fetchJson(){try{const t=await this.handleSnapshotter("fetchJson");return{...t,version:this.getVersionCache()}}catch(t){throw new e.OfficeError(`${this.getObjectId()}: Failed to fetch json. err: ${t}`)}}async stat(){return{version:this.getVersionCache()}}}

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	198276/198276	0755	2026-04-17 03:25:22
..	dir	-	198276/198276	0755	2026-04-17 03:25:20
command-queue	dir	-	198276/198276	0755	2026-04-17 03:25:21
migrator	dir	-	198276/198276	0755	2026-04-17 03:25:21
snapshot	dir	-	198276/198276	0755	2026-04-17 03:25:21
Application.js	text/plain	1.2 KB	198276/198276	0644	2026-04-17 03:25:21
Application2.js	text/plain	1.68 KB	198276/198276	0644	2026-04-17 03:25:21
CollabObject.js	text/plain	4.78 KB	198276/198276	0644	2026-04-17 03:25:21
Connection.js	text/plain	3.25 KB	198276/198276	0644	2026-04-17 03:25:22
Connection2.js	text/plain	1.76 KB	198276/198276	0644	2026-04-17 03:25:21
Constants.js	text/plain	493 B	198276/198276	0644	2026-04-17 03:25:21
Instance.js	text/plain	6.73 KB	198276/198276	0644	2026-04-17 03:25:21
Instance2.js	text/plain	3.46 KB	198276/198276	0644	2026-04-17 03:25:21
InstanceStore.js	text/plain	283 B	198276/198276	0644	2026-04-17 03:25:21
define.js	text/plain	70 B	198276/198276	0644	2026-04-17 03:25:21
error.js	text/plain	732 B	198276/198276	0644	2026-04-17 03:25:21

Team Anon Force

https://t.me/Professor6T9x