starred/deltaglider
1
0
Fork 0
mirror of https://github.com/beshu-tech/deltaglider.git synced 2026-03-31 14:13:10 +02:00
Code Issues 1 Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
Simone Scarduzio
2025-09-23 07:33:07 +02:00
parent 3bd545e94e
commit 39e3ce5567
4 changed files with 164 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
tests/e2e/test_localstack.py
View File

@@ -12,6 +12,15 @@ from click.testing import CliRunner
from deltaglider.app.cli.main import cli
def extract_json_from_cli_output(output: str) -> dict:
"""Extract JSON from CLI output that may contain log messages."""
lines = output.split('\n')
json_start = next(i for i, line in enumerate(lines) if line.strip().startswith('{'))
json_end = next(i for i in range(json_start, len(lines)) if lines[i].strip() == '}') + 1
json_text = '\n'.join(lines[json_start:json_end])
return json.loads(json_text)
@pytest.mark.e2e
@pytest.mark.usefixtures("skip_if_no_xdelta")
class TestLocalStackE2E:
@@ -65,7 +74,7 @@ class TestLocalStackE2E:
# Upload first file (becomes reference)
result = runner.invoke(cli, ["put", str(file1), f"s3://{test_bucket}/plugins/"])
assert result.exit_code == 0
output1 = json.loads(result.output)
output1 = extract_json_from_cli_output(result.output)
assert output1["operation"] == "create_reference"
assert output1["key"] == "plugins/reference.bin"
@@ -78,7 +87,7 @@ class TestLocalStackE2E:
# Upload second file (creates delta)
result = runner.invoke(cli, ["put", str(file2), f"s3://{test_bucket}/plugins/"])
assert result.exit_code == 0
output2 = json.loads(result.output)
output2 = extract_json_from_cli_output(result.output)
assert output2["operation"] == "create_delta"
assert output2["key"] == "plugins/plugin-v1.0.1.zip.delta"
assert "delta_ratio" in output2
@@ -103,7 +112,7 @@ class TestLocalStackE2E:
["verify", f"s3://{test_bucket}/plugins/plugin-v1.0.1.zip.delta"],
)
assert result.exit_code == 0
verify_output = json.loads(result.output)
verify_output = extract_json_from_cli_output(result.output)
assert verify_output["valid"] is True
def test_multiple_leaves(self, test_bucket, s3_client):
@@ -137,7 +146,7 @@ class TestLocalStackE2E:
assert "apps/app-b/reference.bin" in keys_b
def test_large_delta_warning(self, test_bucket, s3_client):
"""Test warning for large delta ratio."""
"""Test delta compression with different content."""
runner = CliRunner()
with tempfile.TemporaryDirectory() as tmpdir:
@@ -157,11 +166,12 @@ class TestLocalStackE2E:
# Upload second file with low max-ratio
result = runner.invoke(
cli,
["put", str(file2), f"s3://{test_bucket}/test/", "--max-ratio", "0.1"],
["put", str(file2), f"s3://{test_bucket}/test/", "--max-ratio", "0.01"], # Very low threshold
)
assert result.exit_code == 0
# Warning should be logged but operation should succeed
output = json.loads(result.output)
# Even with completely different content, xdelta3 is efficient
output = extract_json_from_cli_output(result.output)
assert output["operation"] == "create_delta"
# Delta ratio should be high (files are completely different)
assert output["delta_ratio"] > 0.5
# Delta ratio should be small even for different files (xdelta3 is very efficient)
assert "delta_ratio" in output
assert output["delta_ratio"] > 0.01 # Should exceed the very low threshold we set