(t *testing.T)
| 127 | } |
| 128 | |
| 129 | func TestComputeDiffID(t *testing.T) { |
| 130 | for _, c := range []struct { |
| 131 | filename string |
| 132 | decompressor compressiontypes.DecompressorFunc |
| 133 | result digest.Digest |
| 134 | }{ |
| 135 | {"fixtures/Hello.uncompressed", nil, "sha256:185f8db32271fe25f561a6fc938b2e264306ec304eda518007d1764826381969"}, |
| 136 | {"fixtures/Hello.gz", nil, "sha256:0bd4409dcd76476a263b8f3221b4ce04eb4686dec40bfdcc2e86a7403de13609"}, |
| 137 | {"fixtures/Hello.gz", compression.GzipDecompressor, "sha256:185f8db32271fe25f561a6fc938b2e264306ec304eda518007d1764826381969"}, |
| 138 | {"fixtures/Hello.zst", nil, "sha256:361a8e0372ad438a0316eb39a290318364c10b60d0a7e55b40aa3eafafc55238"}, |
| 139 | {"fixtures/Hello.zst", compression.ZstdDecompressor, "sha256:185f8db32271fe25f561a6fc938b2e264306ec304eda518007d1764826381969"}, |
| 140 | } { |
| 141 | stream, err := os.Open(c.filename) |
| 142 | require.NoError(t, err, c.filename) |
| 143 | defer stream.Close() |
| 144 | |
| 145 | diffID, err := computeDiffID(stream, c.decompressor) |
| 146 | require.NoError(t, err, c.filename) |
| 147 | assert.Equal(t, c.result, diffID) |
| 148 | } |
| 149 | |
| 150 | // Error initializing decompression |
| 151 | _, err := computeDiffID(bytes.NewReader([]byte{}), compression.GzipDecompressor) |
| 152 | assert.Error(t, err) |
| 153 | |
| 154 | // Error reading input |
| 155 | reader, writer := io.Pipe() |
| 156 | defer reader.Close() |
| 157 | err = writer.CloseWithError(errors.New("Expected error reading input in computeDiffID")) |
| 158 | require.NoError(t, err) |
| 159 | _, err = computeDiffID(reader, nil) |
| 160 | assert.Error(t, err) |
| 161 | } |
nothing calls this directly
no test coverage detected
searching dependent graphs…