hexedtech/codemp-vscode
3
0
Fork 0
mirror of https://github.com/hexedtech/codemp-vscode.git synced 2024-11-22 15:34:49 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fix: remove opcache

Browse source
This commit is contained in:
əlemi 2024-09-07 02:14:25 +02:00
parent f18898a1c5
commit 8f93fcab86
Signed by: alemi
GPG key ID: A4895B84D311642C
1 changed files with 10 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
src/commands.ts
View file

@ -8,9 +8,7 @@ import { LOGGER, provider } from './extension';
export let client: codemp.Client | null = null; export let client: codemp.Client | null = null;
export let workspace: codemp.Workspace | null = null; export let workspace: codemp.Workspace | null = null;
export let workspace_list: string[] = []; export let workspace_list: string[] = [];
let locks : Map<string, boolean> = new Map();
let CACHE = new codemp.OpCache(); // TODO do we still need this after "mine" flag?
export async function connect() { export async function connect() {
let config = vscode.workspace.getConfiguration('codemp'); let config = vscode.workspace.getConfiguration('codemp');
@ -128,22 +126,20 @@ export async function attach(selected: vscode.TreeItem | undefined) {
let file_uri: vscode.Uri = editor.document.uri; let file_uri: vscode.Uri = editor.document.uri;
mapping.bufferMapper.register(buffer.get_path(), file_uri); mapping.bufferMapper.register(buffer.get_path(), file_uri);
let bufferContent = await buffer.content(); let bufferContent = await buffer.content();
let doc_len = editor.document.getText().length;
let range = new vscode.Range( let range = new vscode.Range(
editor.document.positionAt(0), editor.document.positionAt(0),
editor.document.positionAt(bufferContent.length) editor.document.positionAt(doc_len)
); );
CACHE.put(buffer_name, 0, bufferContent, bufferContent.length) await editor.edit(editBuilder => {
editor.edit(editBuilder => {
editBuilder editBuilder
.replace(range, bufferContent) .replace(range, bufferContent)
}); });
let mine = false; // this toggles off send callback while we're updating the buffer TODO does it work? is it reliable?
vscode.workspace.onDidChangeTextDocument(async (event: vscode.TextDocumentChangeEvent) => { vscode.workspace.onDidChangeTextDocument(async (event: vscode.TextDocumentChangeEvent) => {
if(mine) { return } if (locks.get(buffer_name)) { return }
if (event.document.uri !== file_uri) return; // ? if (event.document.uri !== file_uri) return; // ?
for (let change of event.contentChanges) { for (let change of event.contentChanges) {
if (CACHE.get(buffer_name, change.rangeOffset, change.text, change.rangeOffset + change.rangeLength)) continue;
LOGGER.debug(`onDidChangeTextDocument(event: [${change.rangeOffset}, ${change.text}, ${change.rangeOffset + change.rangeLength}])`); LOGGER.debug(`onDidChangeTextDocument(event: [${change.rangeOffset}, ${change.text}, ${change.rangeOffset + change.rangeLength}])`);
await buffer.send({ await buffer.send({
start: change.rangeOffset, start: change.rangeOffset,
@ -157,19 +153,18 @@ export async function attach(selected: vscode.TreeItem | undefined) {
let event = await controller.try_recv(); let event = await controller.try_recv();
if (event === null) break; if (event === null) break;
LOGGER.debug(`buffer.callback(event: [${event.start}, ${event.content}, ${event.end}])`) LOGGER.debug(`buffer.callback(event: [${event.start}, ${event.content}, ${event.end}])`)
CACHE.put(buffer_name, event.start, event.content, event.end);
let editor = mapping.bufferMapper.by_buffer(buffer_name); let editor = mapping.bufferMapper.by_buffer(buffer_name);
if (editor === undefined) { throw "Open an editor first" } if (editor === undefined) { throw "Open an editor first" }
let range = new vscode.Range( let range = new vscode.Range(
editor.document.positionAt(event.start), editor.document.positionAt(event.start),
editor.document.positionAt(event.end) editor.document.positionAt(event.end)
) )
mine = true locks.set(buffer_name, true);
await editor.edit(editBuilder => { await editor.edit(editBuilder => {
editBuilder editBuilder
.replace(range, event.content) .replace(range, event.content)
}); });
mine = false; locks.set(buffer_name, false);
} }
}); });
@ -204,8 +199,9 @@ export async function sync(selected: vscode.TreeItem | undefined) {
editor.document.positionAt(doc_len) editor.document.positionAt(doc_len)
); );
CACHE.put(buffer_name, 0, content, doc_len); locks.set(buffer_name, true);
editor.edit(editBuilder => editBuilder.replace(range, content)); await editor.edit(editBuilder => editBuilder.replace(range, content));
locks.set(buffer_name, false);
} }
export async function listBuffers() { export async function listBuffers() {