Skip to content

Commit 6307956

Browse files
committed
Remove dead code
1 parent b3ad696 commit 6307956

File tree

3 files changed

+0
-88
lines changed

3 files changed

+0
-88
lines changed

lib/diff/storage/gcs.ex

Lines changed: 0 additions & 41 deletions
Original file line numberDiff line numberDiff line change
@@ -5,43 +5,6 @@ defmodule Diff.Storage.GCS do
55

66
@gs_xml_url "https://storage.googleapis.com"
77

8-
def get(package, from_version, to_version) do
9-
with {:ok, hash} <- combined_checksum(package, from_version, to_version),
10-
url = url(key(package, from_version, to_version, hash)),
11-
{:ok, 200, _headers, stream} <-
12-
Diff.HTTP.retry("gs", fn -> Diff.HTTP.get_stream(url, headers()) end) do
13-
{:ok, stream}
14-
else
15-
{:ok, 404, _headers, _body} ->
16-
{:error, :not_found}
17-
18-
{:ok, status, _headers, _body} ->
19-
Logger.error("Failed to get diff from storage. Status #{status}")
20-
{:error, :not_found}
21-
22-
{:error, reason} ->
23-
Logger.error("Failed to get diff from storage. Reason #{inspect(reason)}")
24-
{:error, :not_found}
25-
end
26-
end
27-
28-
def put(package, from_version, to_version, stream) do
29-
with {:ok, hash} <- combined_checksum(package, from_version, to_version),
30-
url = url(key(package, from_version, to_version, hash)),
31-
{:ok, 200, _headers, _body} <-
32-
Diff.HTTP.retry("gs", fn -> Diff.HTTP.put_stream(url, headers(), stream) end) do
33-
:ok
34-
else
35-
{:ok, status, _headers, _body} ->
36-
Logger.error("Failed to put diff to storage. Status #{status}")
37-
{:error, :not_found}
38-
39-
error ->
40-
Logger.error("Failed to put diff to storage. Reason #{inspect(error)}")
41-
error
42-
end
43-
end
44-
458
def get_patch(package, from_version, to_version, patch_id) do
469
with {:ok, hash} <- combined_checksum(package, from_version, to_version),
4710
url = url(patch_key(package, from_version, to_version, hash, patch_id)),
@@ -149,10 +112,6 @@ defmodule Diff.Storage.GCS do
149112
end
150113
end
151114

152-
defp key(package, from_version, to_version, hash) do
153-
"diffs/#{package}-#{from_version}-#{to_version}-#{hash}.html"
154-
end
155-
156115
defp patch_key(package, from_version, to_version, hash, patch_id) do
157116
"diffs/patches/#{package}-#{from_version}-#{to_version}-#{hash}-#{patch_id}.patch"
158117
end

lib/diff/storage/local.ex

Lines changed: 0 additions & 35 deletions
Original file line numberDiff line numberDiff line change
@@ -3,37 +3,6 @@ defmodule Diff.Storage.Local do
33

44
@behaviour Diff.Storage
55

6-
def get(package, from_version, to_version) do
7-
case combined_checksum(package, from_version, to_version) do
8-
{:ok, hash} ->
9-
filename = key(package, from_version, to_version, hash)
10-
path = Path.join([dir(), package, filename])
11-
12-
if File.regular?(path) do
13-
{:ok, File.stream!(path, [:read_ahead])}
14-
else
15-
{:error, :not_found}
16-
end
17-
18-
{:error, :not_found} ->
19-
{:error, :not_found}
20-
end
21-
end
22-
23-
def put(package, from_version, to_version, stream) do
24-
with {:ok, hash} <- combined_checksum(package, from_version, to_version),
25-
filename = key(package, from_version, to_version, hash),
26-
path = Path.join([dir(), package, filename]),
27-
:ok <- File.mkdir_p(Path.dirname(path)) do
28-
Enum.into(stream, File.stream!(path, [:write_delay]))
29-
:ok
30-
else
31-
{:error, reason} ->
32-
Logger.error("Failed to store diff. Reason: #{inspect(reason)}.")
33-
{:error, reason}
34-
end
35-
end
36-
376
def get_patch(package, from_version, to_version, patch_id) do
387
case combined_checksum(package, from_version, to_version) do
398
{:ok, hash} ->
@@ -152,10 +121,6 @@ defmodule Diff.Storage.Local do
152121
end
153122
end
154123

155-
defp key(package, from_version, to_version, hash) do
156-
"#{package}-#{from_version}-#{to_version}-#{hash}.html"
157-
end
158-
159124
defp patch_key(package, from_version, to_version, hash, patch_id) do
160125
"#{package}-#{from_version}-#{to_version}-#{hash}-#{patch_id}.patch"
161126
end

lib/diff/storage/storage.ex

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ defmodule Diff.Storage do
22
@type package :: String.t()
33
@type from_version :: String.t()
44
@type to_version :: String.t()
5-
@type diff :: Enum.t()
65
@type patch_id :: String.t()
76
@type patch_html :: String.t()
87
@type diff_metadata :: %{
@@ -12,9 +11,6 @@ defmodule Diff.Storage do
1211
files_changed: non_neg_integer()
1312
}
1413

15-
@callback get(package, from_version, to_version) :: {:ok, diff} | {:error, term}
16-
@callback put(package, from_version, to_version, diff) :: :ok | {:error, term}
17-
1814
# New patch-level storage callbacks
1915
@callback get_patch(package, from_version, to_version, patch_id) ::
2016
{:ok, patch_html} | {:error, term}
@@ -29,14 +25,6 @@ defmodule Diff.Storage do
2925

3026
defp impl(), do: Application.get_env(:diff, :storage_impl)
3127

32-
def get(package, from_version, to_version) do
33-
impl().get(package, from_version, to_version)
34-
end
35-
36-
def put(package, from_version, to_version, diff) do
37-
impl().put(package, from_version, to_version, diff)
38-
end
39-
4028
def get_patch(package, from_version, to_version, patch_id) do
4129
impl().get_patch(package, from_version, to_version, patch_id)
4230
end

0 commit comments

Comments
 (0)