Как в ES6 работать с асинхронными операциями в обработчике Proxy?

Question

[yurygolikov]

Как заставить подождать выполнения обработчика Proxy после отслеживаемого действия (например, подождать обработчик Proxy операции присовения, а уже потом продолжить исполнение)?

Скорее всего, я что-то не допонимаю или упустил. Спасибо за ответы.

Упрощенный пример:

function PromiseTimeOut() {
    return new Promise((resolve, reject) => {
        setTimeout(resolve ,1000);
    });
}

const target = {
    value: null,
    setValue(value) {
        this.value = value;
        console.log(this.value); //Тут будет NULL
    }
};
const proxy = new Proxy(target, {
  get(target, prop) {
    return target[prop];
  },
  async set(target, prop, value) {
    await PromiseTimeOut();
    target[prop] = value;
    return true;
  }
});

proxy.setValue(1);
//В этом месте исполнение должно подождать асинхронного обработчика Proxy.set
console.log(proxy.value);//И тут будет NULL

Пробовал также делать set обработчик синхронной, а в target[prop] присваивать Promise. Все равно само присваивание в обработчике происходит позже.

function PromiseTimeOut() {
    return new Promise((resolve, reject) => {
        setTimeout(resolve ,1000);
    });
}

const target = {
    value: null,
    async setValue(value) {
        this.value = value;
        await this.value; // СЮДА НЕ ПРИХОДИТ ПРОКСИ, а по идее должен
        console.log(this.value); //Тут будет NULL
    }
};
const proxy = new Proxy(target, {
    get(target, prop) {
        return target[prop];
    },
    set(target, prop, value) {
        target[prop] = new Promise(async (resolve, reject) => {
            await PromiseTimeOut();
            resolve();
        });
        return true;
    }
});

proxy.setValue(1);

Делаю на node.js последней версии. Использую новый синтаксис async/await

Comments

[Kovalsky]

(например, подождать обработчик Proxy операции присовения, а уже потом продолжить исполнение)

Пробовал... Все равно само присваивание в обработчике происходит позже.

Вот после первой фразы создаётся впечатление что это вам нужно - присвоить через некоторое время. Объясните, что именно нужно.

[yurygolikov]

Никита Полевой: Там будет NULL, а мне нужно, чтобы там где выводится NULL сейчас - уже было присвоено значение. Те мне нужно "подождать" выполнения асинхронных операций в обработчике

async set(target, prop, value) {
    await PromiseTimeOut();
    target[prop] = value;
    return true;
  }

, и присвоения значения
this.value = value;

А у вас выходит не NULL?
На вякий случай - обработчик Set в Proxy - асинхронный.

[Kovalsky]

yurygolikov: а что именно вам тогда нужно отложить? Я не понял 0_0

UPD: погодите, вы что, хотите просто остановить выполнение главного потока на секунду, типа sleep? Что именно вам принципиально в задержке?

[yurygolikov]

Никита Полевой: Нет sleep мне не нужен. И откладывать мне тоже ничего не нужно.
Нужно просто подождать исполнения асинхронного обработчика proxy.set, а уже только потом продолжить исполнение.

[Kovalsky]

yurygolikov: ну тут не особенно важно как вы это называете - слип, "отложить выполнение" или "подождать исполнения". В любом случае, в рамках главного потока нельзя вот так запросто подождать.

Вы можете попробовать сделать так, то есть откладывать выполнение нужных функций в теле асинхронной функции. Остановить выполнение главного потока без запихивания в него тяжелых синхронных вычислений нельзя.

[yurygolikov]

Никита Полевой: ЕЩЕ РАЗ :) Повторю, мне НЕ нужно ничего откладывать. Сейчас опишу последовательность исполнения которая мне нужна.

[yurygolikov]

Никита Полевой: Опишу последовательность исполнения которая мне нужна.

proxy.setValue(1); //Запускаем
target.setValue(value); // Начало
this.value = value;// Запрос идет к обработчику proxy set
async set(target, prop, value) {//Иполняется
    await PromiseTimeOut();
    target[prop] = value;
    return true;
  }
console.log(this.value); //Вернулись в setValue тут PromiseTimeOut уже должна быть исполнена

[Kovalsky]

yurygolikov: в основном потоке такое невозможно, но можно весь описанный вами алгоритм завернуть в асинхронную функцию и тогда уже останавливать выполнение в любом удобном месте. Если я опять не понял, то видимо у меня чего-то не хватает в голове, вероятно лучше подождать более компетентных специалистов.

[yurygolikov]

Никита Полевой: Все это конечно можно сделать. Проблема именно в Proxy. Мне нужно чтобы какие то асинхронные операции были в обработчике proxy. А какая то часть в target.

[Kovalsky]

yurygolikov: ну, значит у вас будет асинхронная функция у которой внутри тоже будут асинхронные функции. Или я уже совсем не соображаю на ночь глядя.

[yurygolikov]

Никита Полевой: Не понял, что вы имеете ввиду. Вы понимаете, что я использую Proxy?

Answer 1

[Николай]

Мне кажется такое не получится. По сути вам нужно написать что-то типа:

setValue(value) {
        await this.value = value;
        console.log(this.value); //Тут будет NULL
    }

Но такого синтаксиса нет (и вроде не планируется).

А почему на сам setValue не повесить Proxy?

const proxy = new Proxy(target, {
 async setValue(target, prop) {
    await PromiseTimeOut();
    target[prop] = value;
    return true;
  },
});

Тогда можно будет писать
await proxy.setValue(1)

Comments

[yurygolikov]

Потому что мне нужно разделить логику с помощью Proxy. "setValue" должно быть в target а "PromiseTimeOut" в set обработчике.
Я пробовал возвращать промис вот так: Но это не работает. Не понимаю почему.

function PromiseTimeOut() {
    return new Promise((resolve, reject) => {
        setTimeout(resolve ,1000);
    });
}

const target = {
    value: null,
    async setValue(value) {
        this.value = value;
        await this.value; // СЮДА НЕ ПРИХОДИТ ПРОКСИ, а по идее должен
        console.log(this.value); //Тут будет NULL
    }
};
const proxy = new Proxy(target, {
    get(target, prop) {
        return target[prop];
    },
    set(target, prop, value) {
        target[prop] = new Promise(async (resolve, reject) => {
            await PromiseTimeOut();
            resolve();
        });
        return true;
    }
});

proxy.setValue(1);

Answer 2

[Kovalsky]

Я говорил о чем-то типа отдельной процедуры в которую можно запихнуть все нужные вам действия и там уже останавливать что угодно и как угодно.

Как-то так

function PromiseTimeOut(delay) {
    return new Promise((resolve, reject) => {
        setTimeout(resolve, delay);
    });
}

var target = {
    value: null,
    setValue(value) {
        this.value = value;
    }
};

var proxy = new Proxy(target, {
  get(target, prop) {
    return target[prop];
  },
  set(target, prop, value) {
    target[prop] = value;
    return true;
  }
});

async function demo() {
	proxy.setValue('I have no idea what i\'m doing');
	await PromiseTimeOut( 1000 );
	console.log( proxy.value );
}

demo(); 
// Promise, а через секунду
// "I have no idea what i'm doing"

Как вам и предлагали, можно proxy.setValue тоже сделать асинхронной функцией.

Comments

[yurygolikov]

Я знаю, что так можно. Но мне так НЕ надо. У меня разделение логики. В этом СУТЬ, чтобы поместить PromiseTimeOut в обработчик proxy.set. Я по этой причине использую Proxy.
Опишу вам, что я в реальной задаче пытаюсь сделать:
У меня есть сущность и есть репозиторий. Репозиторий слушает через Proxy изменения состояния сущности и делает необходимые асинхронные операции в базе. Но эти операции должны быть выполнены ДО того, как продолжатся дальнейшие операции, тк они конфликтуют с другими операциями в базу.

[Kovalsky]

yurygolikov: это был полезный комментарий, до меня наконец дошло. Такое количество слоёв - setValue да ещё и Proxy - тоже обязательно?

[yurygolikov]

Никита Полевой: Их всего два в данном контексте.
setValue это пример поведения(метода) сущности.
proxy.set тут репозиторий слушает изменения и делает асинхронные операции
Так что да.

Есть другие реализации этой концепции. Но меня заинтересовала именно эта задача с использованием Proxy.
Неужели никак нельзя вернуть Promise из обработчика proxy.set?

[Kovalsky]

yurygolikov: в общем единственное что я смог придумать это синхронные запросы, вроде бы только с их помощью можно надёжно остановить выполнение главного потока:

Proxy + demo $.ajax( async: false )

var obj = {};

var proxy = new Proxy(obj, {
    set(target, prop, value) {
        target[prop] = value;
	    jQuery.ajax({
	        url: 'https://yahoo.com',
	        async: false
	    });
    }
});

proxy.value = 2;
console.log(proxy.value);

[yurygolikov]

Никита Полевой: Это понятно. Спасибо вам за ответы) К сожалению, выбранная мной, docs.sequelizejs.com вроде бы не поддерживает синхронщину. Да и вообще как то это не совсем правильно делать в однопоточном то платформе.

[yurygolikov]

Никита Полевой: Если вам интересно я задал вопрос на другой площадке:
https://stackoverflow.com/questions/45202061/how-i...