@@ -27,10 +27,15 @@ def wait_until times: 5, delay: 1, &condition
2727 raise "Condition not met. Waited #{ times } times with #{ delay } sec delay"
2828 end
2929
30+ # Frequently used full path to "my_application_log" for test project
31+ def my_application_log_name
32+ "projects/#{ @project_id } /logs/my_application_log"
33+ end
34+
3035 # Returns entries logged to "my_application_log" in the test project
3136 def my_application_log_entries
3237 @logging . entries (
33- filter : %{logName = "projects/ #{ @project_id } /logs/my_application_log "} ,
38+ filter : %{logName = "#{ my_application_log_name } "} ,
3439 order : "timestamp desc"
3540 )
3641 end
@@ -73,7 +78,8 @@ def my_application_log_entries
7378
7479 # Delete log sink used by code samples if the test created one
7580 def cleanup!
76- @logging . sink ( "my-sink" ) &.delete
81+ test_sink = @logging . sink "my-sink"
82+ test_sink . delete if test_sink
7783 end
7884
7985 it "can create logging client" do
@@ -91,14 +97,14 @@ def cleanup!
9197
9298 it "can create log sink" do
9399 expect ( @logging . sink "my-sink" ) . to be nil
94-
100+
95101 create_log_sink
96102
97103 expect ( @logging . sink "my-sink" ) . not_to be nil
98104 end
99105
100106 it "can update log sink" do
101- original_destination = "storage.googleapis.com/#{ @bucket . id } "
107+ original_destination = "storage.googleapis.com/#{ @bucket . id } "
102108 updated_destination = "storage.googleapis.com/#{ @alt_bucket . id } "
103109
104110 create_log_sink
@@ -130,17 +136,15 @@ def cleanup!
130136 with ( filter : %{resource.type = "gae_app"} ) .
131137 and_wrap_original do |m , *args |
132138 m . call (
133- filter : %{logName = "projects/ #{ @project_id } /logs/my_application_log "} ,
139+ filter : %{logName = "#{ my_application_log_name } "} ,
134140 order : "timestamp desc"
135141 )
136- end
142+ end
137143
138144 timestamp = "\\ d{4}-\\ d{2}-\\ d{2} \\ d{2}:\\ d{2}:\\ d{2} [^\\ \\ ]+"
139- log_name = "projects/#{ @project_id } /logs/my_application_log"
140- payload = '"Log message"'
141145
142146 expect { list_log_entries } . to output (
143- %r{\[ #{ timestamp } \] #{ log_name } #{ payload } }
147+ %r{\[ #{ timestamp } \] #{ my_application_log_name } "Log message" }
144148 ) . to_stdout
145149 end
146150
@@ -167,7 +171,7 @@ def cleanup!
167171 end
168172
169173 entries = my_application_log_entries
170- entry = entries . detect { |e | e . payload . include? "time #{ current_time } " }
174+ entry = entries . detect { |e | e . payload . include? "time #{ current_time } " }
171175 expect ( entry ) . to be nil
172176
173177 write_log_entry
@@ -180,7 +184,7 @@ def cleanup!
180184 end
181185
182186 entries = my_application_log_entries
183- entry = entries . detect { |e | e . payload . include? "time #{ current_time } " }
187+ entry = entries . detect { |e | e . payload . include? "time #{ current_time } " }
184188 expect ( entry ) . not_to be nil
185189 expect ( entry . payload ) . to eq "Log message - current time #{ current_time } "
186190 expect ( entry . severity ) . to eq :NOTICE
@@ -200,7 +204,7 @@ def cleanup!
200204 filter : %{logName = "projects/#{ @project_id } /logs/my_application_log"} ,
201205 order : "timestamp desc"
202206 )
203- entry = entries . detect { |e | e . payload . include? "time #{ current_time } " }
207+ entry = entries . detect { |e | e . payload . include? "time #{ current_time } " }
204208 expect ( entry ) . to be nil
205209
206210 # Hooked up to real test project
@@ -227,7 +231,7 @@ def cleanup!
227231 m . call message
228232 end
229233
230- write_log_entry_using_ruby_logger
234+ write_log_entry_using_ruby_logger
231235
232236 # Wait for entry to be queryable
233237 wait_until do
@@ -237,7 +241,7 @@ def cleanup!
237241 end
238242
239243 entries = my_application_log_entries
240- entry = entries . detect { |e | e . payload . include? "time #{ current_time } " }
244+ entry = entries . detect { |e | e . payload . include? "time #{ current_time } " }
241245 expect ( entry ) . not_to be nil
242246 expect ( entry . payload ) . to eq "Log message - current time #{ current_time } "
243247 expect ( entry . severity ) . to eq :INFO
0 commit comments