@@ -42,6 +42,8 @@ defmodule Hexdocs.Queue do
42
42
43
43
@ doc false
44
44
def handle_message ( % { data: % { "Event" => "s3:TestEvent" } } = message ) do
45
+ Sentry.Context . set_extra_context ( % { queue_event: "s3:TestEvent" } )
46
+
45
47
message
46
48
end
47
49
@@ -51,6 +53,7 @@ defmodule Hexdocs.Queue do
51
53
end
52
54
53
55
def handle_message ( % { data: % { "hexdocs:sitemap" => key } } = message ) do
56
+ Sentry.Context . set_extra_context ( % { queue_event: "hexdocs:sitemap" } )
54
57
Logger . info ( "#{ key } : start" )
55
58
56
59
case key_components ( key ) do
@@ -86,6 +89,13 @@ defmodule Hexdocs.Queue do
86
89
87
90
case key_components ( key ) do
88
91
{ :ok , repository , package , version } ->
92
+ Sentry.Context . set_extra_context ( % {
93
+ queue_event: "ObjectCreated" ,
94
+ repository: repository ,
95
+ package: package ,
96
+ version: version
97
+ } )
98
+
89
99
body = Hexdocs.Store . get ( :repo_bucket , key )
90
100
91
101
{ version , all_versions } =
@@ -148,6 +158,13 @@ defmodule Hexdocs.Queue do
148
158
149
159
case key_components ( key ) do
150
160
{ :ok , repository , package , version } when package not in @ special_package_names ->
161
+ Sentry.Context . set_extra_context ( % {
162
+ queue_event: "ObjectRemoved" ,
163
+ repository: repository ,
164
+ package: package ,
165
+ version: version
166
+ } )
167
+
151
168
version = Version . parse! ( version )
152
169
all_versions = all_versions ( repository , package )
153
170
Hexdocs.Bucket . delete ( repository , package , version , all_versions )
0 commit comments