Changeset View
Changeset View
Standalone View
Standalone View
swh/objstorage/tests/test_objstorage_winery.py
| Show First 20 Lines • Show All 91 Lines • ▼ Show 20 Lines | def test_winery_sharedbase(winery): | ||||
| id1 = base.id | id1 = base.id | ||||
| assert id1 is not None | assert id1 is not None | ||||
| assert id1 == base.id | assert id1 == base.id | ||||
| def test_winery_add_get(winery): | def test_winery_add_get(winery): | ||||
| shard = winery.base.whoami | shard = winery.base.whoami | ||||
| content = b"SOMETHING" | content = b"SOMETHING" | ||||
| obj_id = winery.add(content=content, obj_id=compute_hash(content, "sha256")) | obj_id = compute_hash(content, "sha256") | ||||
| assert ( | assert ( | ||||
| obj_id.hex() | obj_id.hex() | ||||
| == "866878b165607851782d8d233edf0c261172ff67926330d3bbd10c705b92d24f" | == "866878b165607851782d8d233edf0c261172ff67926330d3bbd10c705b92d24f" | ||||
| ) | ) | ||||
| assert winery.add(content=content, obj_id=obj_id) == obj_id | winery.add(content=content, obj_id=obj_id) | ||||
| assert winery.add(content=content, obj_id=obj_id, check_presence=False) == obj_id | winery.add(content=content, obj_id=obj_id) | ||||
| winery.add(content=content, obj_id=obj_id, check_presence=False) | |||||
| assert winery.base.whoami == shard | assert winery.base.whoami == shard | ||||
| assert winery.get(obj_id) == content | assert winery.get(obj_id) == content | ||||
| with pytest.raises(exc.ObjNotFoundError): | with pytest.raises(exc.ObjNotFoundError): | ||||
| winery.get(b"unknown") | winery.get(b"unknown") | ||||
| winery.shard.drop() | winery.shard.drop() | ||||
| @pytest.mark.shard_max_size(1) | @pytest.mark.shard_max_size(1) | ||||
| def test_winery_add_and_pack(winery, mocker): | def test_winery_add_and_pack(winery, mocker): | ||||
| mocker.patch("swh.objstorage.backends.winery.objstorage.pack", return_value=True) | mocker.patch("swh.objstorage.backends.winery.objstorage.pack", return_value=True) | ||||
| shard = winery.base.whoami | shard = winery.base.whoami | ||||
| content = b"SOMETHING" | content = b"SOMETHING" | ||||
| obj_id = winery.add(content=content, obj_id=compute_hash(content, "sha256")) | winery.add(content=content, obj_id=compute_hash(content, "sha256")) | ||||
| assert ( | |||||
| obj_id.hex() | |||||
| == "866878b165607851782d8d233edf0c261172ff67926330d3bbd10c705b92d24f" | |||||
| ) | |||||
| assert winery.base.whoami != shard | assert winery.base.whoami != shard | ||||
| assert len(winery.packers) == 1 | assert len(winery.packers) == 1 | ||||
| packer = winery.packers[0] | packer = winery.packers[0] | ||||
| packer.join() | packer.join() | ||||
| assert packer.exitcode == 0 | assert packer.exitcode == 0 | ||||
| def test_winery_delete(storage): | def test_winery_delete(storage): | ||||
| ▲ Show 20 Lines • Show All 271 Lines • Show Last 20 Lines | |||||