fix(sync): handle sync of datalayer delete (#2416)
Some checks are pending
Test & Docs / lint (push) Waiting to run
Test & Docs / docs (push) Waiting to run
Test & Docs / tests (postgresql, 3.10) (push) Waiting to run
Test & Docs / tests (postgresql, 3.12) (push) Waiting to run

fix #2268

There is a tricky choice to do: the delete actually occurs in two
times, first the datalayer is hidden from the UI and set as "deleted"
(this can then be undone) then at next "save" it will totally removed.

When syncing, given we removed the "reset/undo" feature for now, and
because it was simpler, I decide to do both step in once.

When working on a proper "undo/redo", we may challenge this choice
again.
This commit is contained in:
Yohan Boniface 2025-01-10 16:34:47 +01:00 committed by GitHub
commit 86a8e17aec
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
4 changed files with 89 additions and 6 deletions

View file

@ -574,9 +574,12 @@ export class DataLayer extends ServerStored {
}) })
} }
_delete() { del(sync = true) {
this.isDeleted = true
this.erase() this.erase()
if (sync) {
this.isDeleted = true
this.sync.delete()
}
} }
empty() { empty() {
@ -819,7 +822,7 @@ export class DataLayer extends ServerStored {
<i class="icon icon-24 icon-delete"></i>${translate('Delete')} <i class="icon icon-24 icon-delete"></i>${translate('Delete')}
</button>`) </button>`)
deleteButton.addEventListener('click', () => { deleteButton.addEventListener('click', () => {
this._delete() this.del()
this._umap.editPanel.close() this._umap.editPanel.close()
}) })
advancedButtons.appendChild(deleteButton) advancedButtons.appendChild(deleteButton)
@ -1147,10 +1150,14 @@ export class DataLayer extends ServerStored {
if (this.createdOnServer) { if (this.createdOnServer) {
await this._umap.server.post(this.getDeleteUrl()) await this._umap.server.post(this.getDeleteUrl())
} }
delete this._umap.datalayers[stamp(this)] this.commitDelete()
return true return true
} }
commitDelete() {
delete this._umap.datalayers[stamp(this)]
}
getName() { getName() {
return this.options.name || translate('Untitled layer') return this.options.name || translate('Untitled layer')
} }
@ -1221,7 +1228,7 @@ export class DataLayer extends ServerStored {
this._umap.dialog this._umap.dialog
.confirm(translate('Are you sure you want to delete this layer?')) .confirm(translate('Are you sure you want to delete this layer?'))
.then(() => { .then(() => {
this._delete() this.del()
}) })
}, },
this this

View file

@ -72,6 +72,14 @@ export class DataLayerUpdater extends BaseUpdater {
} }
datalayer.render([key]) datalayer.render([key])
} }
delete({ metadata }) {
const datalayer = this.getDataLayerFromID(metadata.id)
if (datalayer) {
datalayer.del(false)
datalayer.commitDelete()
}
}
} }
export class FeatureUpdater extends BaseUpdater { export class FeatureUpdater extends BaseUpdater {

View file

@ -127,6 +127,9 @@ class DataLayerFactory(factory.django.DjangoModelFactory):
def _adjust_kwargs(cls, **kwargs): def _adjust_kwargs(cls, **kwargs):
if "data" in kwargs: if "data" in kwargs:
data = copy.deepcopy(kwargs.pop("data")) data = copy.deepcopy(kwargs.pop("data"))
data.setdefault("_umap_options", {})
if "name" in data["_umap_options"] and kwargs["name"] == cls.name:
kwargs["name"] = data["_umap_options"]["name"]
if "settings" not in kwargs: if "settings" not in kwargs:
kwargs["settings"] = data.get("_umap_options", {}) kwargs["settings"] = data.get("_umap_options", {})
else: else:
@ -135,7 +138,6 @@ class DataLayerFactory(factory.django.DjangoModelFactory):
**DataLayerFactory.settings._defaults, **DataLayerFactory.settings._defaults,
**kwargs["settings"], **kwargs["settings"],
} }
data.setdefault("_umap_options", {})
kwargs["settings"]["name"] = kwargs["name"] kwargs["settings"]["name"] = kwargs["name"]
data["_umap_options"]["name"] = kwargs["name"] data["_umap_options"]["name"] = kwargs["name"]
data.setdefault("type", "FeatureCollection") data.setdefault("type", "FeatureCollection")

View file

@ -420,6 +420,72 @@ def test_should_sync_datalayers(new_page, live_server, websocket_server, tilelay
assert DataLayer.objects.count() == 2 assert DataLayer.objects.count() == 2
@pytest.mark.xdist_group(name="websockets")
def test_should_sync_datalayers_delete(
new_page, live_server, websocket_server, tilelayer
):
map = MapFactory(name="sync", edit_status=Map.ANONYMOUS)
map.settings["properties"]["syncEnabled"] = True
map.save()
data1 = {
"type": "FeatureCollection",
"features": [
{
"type": "Feature",
"properties": {
"name": "Point 1",
},
"geometry": {"type": "Point", "coordinates": [0.065918, 48.385442]},
},
],
"_umap_options": {
"name": "datalayer 1",
},
}
data2 = {
"type": "FeatureCollection",
"features": [
{
"type": "Feature",
"properties": {
"name": "Point 2",
},
"geometry": {"type": "Point", "coordinates": [3.55957, 49.767074]},
},
],
"_umap_options": {
"name": "datalayer 2",
},
}
DataLayerFactory(map=map, data=data1)
DataLayerFactory(map=map, data=data2)
# Create two tabs
peerA = new_page("Page A")
peerA.goto(f"{live_server.url}{map.get_absolute_url()}?edit")
peerB = new_page("Page B")
peerB.goto(f"{live_server.url}{map.get_absolute_url()}?edit")
peerA.get_by_role("button", name="Open browser").click()
expect(peerA.get_by_text("datalayer 1")).to_be_visible()
expect(peerA.get_by_text("datalayer 2")).to_be_visible()
peerB.get_by_role("button", name="Open browser").click()
expect(peerB.get_by_text("datalayer 1")).to_be_visible()
expect(peerB.get_by_text("datalayer 2")).to_be_visible()
# Delete "datalayer 2" in peerA
peerA.locator(".datalayer").get_by_role("button", name="Delete layer").first.click()
peerA.get_by_role("button", name="OK").click()
expect(peerA.get_by_text("datalayer 2")).to_be_hidden()
expect(peerB.get_by_text("datalayer 2")).to_be_hidden()
# Save delete to the server
with peerA.expect_response(re.compile(".*/datalayer/delete/.*")):
peerA.get_by_role("button", name="Save").click()
expect(peerA.get_by_text("datalayer 2")).to_be_hidden()
expect(peerB.get_by_text("datalayer 2")).to_be_hidden()
@pytest.mark.xdist_group(name="websockets") @pytest.mark.xdist_group(name="websockets")
def test_create_and_sync_map( def test_create_and_sync_map(
new_page, live_server, websocket_server, tilelayer, login, user new_page, live_server, websocket_server, tilelayer, login, user