Revert "*Change pullRemote to throw if the item is not empty"

This reverts commit 74b0f1d596.
This commit is contained in:
Derrick Hammer 2023-04-06 16:21:30 -04:00
parent 74b0f1d596
commit eb4a8f1c9e
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 2 additions and 8 deletions

View File

@ -777,15 +777,12 @@ module.exports = class Protomux {
async popFree(id) { async popFree(id) {
await this.userData.syncProtomux("popFree", id); await this.userData.syncProtomux("popFree", id);
} }
async pushFree(id) { async pushFree(id) {
await this.userData.syncProtomux("pushFree", id); await this.userData.syncProtomux("pushFree", id);
} }
async pushLocal(id) { async pushLocal(id) {
await this.userData.syncProtomux("pushLocal", id); await this.userData.syncProtomux("pushLocal", id);
} }
async pushRemote(id) { async pushRemote(id) {
await this.userData.syncProtomux("pushRemote", id); await this.userData.syncProtomux("pushRemote", id);
} }
@ -800,23 +797,20 @@ module.exports = class Protomux {
} }
}); });
} }
async pullFree() { async pullFree() {
const ids = await this.userData.syncProtomux("pullFree"); const ids = await this.userData.syncProtomux("pullFree");
this._free = Array.from(new Set([...this._free, ...ids])); this._free = Array.from(new Set([...this._free, ...ids]));
this._free = this._free.filter((item) => item !== null); this._free = this._free.filter((item) => item !== null);
} }
async pullRemote() { async pullRemote() {
const ids = await this.userData.syncProtomux("pullRemote"); const ids = await this.userData.syncProtomux("pullRemote");
ids.forEach((item) => { ids.forEach((item) => {
item = parseInt(item); item = parseInt(item);
if (typeof this._remote[item] !== "undefined") { if (typeof this._remote[item] === "undefined") {
throw new Error("empty remote element expected"); this._remote[item] = null;
} }
this._remote[item] = null;
}); });
} }
}; };