OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 package logs | 5 package logs |
6 | 6 |
7 import ( | 7 import ( |
8 "bytes" | 8 "bytes" |
9 "errors" | 9 "errors" |
10 "fmt" | 10 "fmt" |
(...skipping 161 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
172 }) | 172 }) |
173 | 173 |
174 Convey(`Will fail with Internal if the datastore Get() d
oesn't work.`, func() { | 174 Convey(`Will fail with Internal if the datastore Get() d
oesn't work.`, func() { |
175 c, fb := featureBreaker.FilterRDS(c, nil) | 175 c, fb := featureBreaker.FilterRDS(c, nil) |
176 fb.BreakFeatures(errors.New("testing error"), "G
etMulti") | 176 fb.BreakFeatures(errors.New("testing error"), "G
etMulti") |
177 | 177 |
178 _, err := svr.Get(c, &req) | 178 _, err := svr.Get(c, &req) |
179 So(err, ShouldBeRPCInternal) | 179 So(err, ShouldBeRPCInternal) |
180 }) | 180 }) |
181 | 181 |
182 » » » Convey(`Will fail with NotFound if the log stream does n
ot exist (different project).`, func() { | 182 » » » Convey(`Will fail with PermissionDenied if the project d
oes not exist.`, func() { |
183 req.Project = "does-not-exist" | 183 req.Project = "does-not-exist" |
184 _, err := svr.Get(c, &req) | 184 _, err := svr.Get(c, &req) |
185 » » » » So(err, ShouldBeRPCNotFound) | 185 » » » » So(err, ShouldBeRPCPermissionDenied) |
| 186 » » » }) |
| 187 |
| 188 » » » Convey(`Will fail with PermissionDenied if the user can'
t access the project.`, func() { |
| 189 » » » » req.Project = "proj-exclusive" |
| 190 » » » » _, err := svr.Get(c, &req) |
| 191 » » » » So(err, ShouldBeRPCPermissionDenied) |
186 }) | 192 }) |
187 | 193 |
188 Convey(`Will fail with NotFound if the log path does not
exist (different path).`, func() { | 194 Convey(`Will fail with NotFound if the log path does not
exist (different path).`, func() { |
189 req.Path = "testing/+/does/not/exist" | 195 req.Path = "testing/+/does/not/exist" |
190 _, err := svr.Get(c, &req) | 196 _, err := svr.Get(c, &req) |
191 So(err, ShouldBeRPCNotFound) | 197 So(err, ShouldBeRPCNotFound) |
192 }) | 198 }) |
193 }) | 199 }) |
194 | 200 |
195 Convey(`Testing Tail requests (no logs)`, func() { | 201 Convey(`Testing Tail requests (no logs)`, func() { |
196 req := logdog.TailRequest{ | 202 req := logdog.TailRequest{ |
197 Project: string(project), | 203 Project: string(project), |
198 Path: string(tls.Path), | 204 Path: string(tls.Path), |
199 } | 205 } |
200 | 206 |
201 Convey(`Will succeed with no logs.`, func() { | 207 Convey(`Will succeed with no logs.`, func() { |
202 resp, err := svr.Tail(c, &req) | 208 resp, err := svr.Tail(c, &req) |
203 | 209 |
204 So(err, ShouldBeRPCOK) | 210 So(err, ShouldBeRPCOK) |
205 So(resp, shouldHaveLogs) | 211 So(resp, shouldHaveLogs) |
206 }) | 212 }) |
207 | 213 |
208 » » » Convey(`Will fail with NotFound if the log stream does n
ot exist (different project).`, func() { | 214 » » » Convey(`Will fail with PermissionDenied if the project d
oes not exist.`, func() { |
209 req.Project = "does-not-exist" | 215 req.Project = "does-not-exist" |
210 _, err := svr.Tail(c, &req) | 216 _, err := svr.Tail(c, &req) |
211 » » » » So(err, ShouldBeRPCNotFound) | 217 » » » » So(err, ShouldBeRPCPermissionDenied) |
| 218 » » » }) |
| 219 |
| 220 » » » Convey(`Will fail with PermissionDenied if the user can'
t access the project.`, func() { |
| 221 » » » » req.Project = "proj-exclusive" |
| 222 » » » » _, err := svr.Tail(c, &req) |
| 223 » » » » So(err, ShouldBeRPCPermissionDenied) |
212 }) | 224 }) |
213 | 225 |
214 Convey(`Will fail with NotFound if the log path does not
exist (different path).`, func() { | 226 Convey(`Will fail with NotFound if the log path does not
exist (different path).`, func() { |
215 req.Path = "testing/+/does/not/exist" | 227 req.Path = "testing/+/does/not/exist" |
216 _, err := svr.Tail(c, &req) | 228 _, err := svr.Tail(c, &req) |
217 So(err, ShouldBeRPCNotFound) | 229 So(err, ShouldBeRPCNotFound) |
218 }) | 230 }) |
219 }) | 231 }) |
220 | 232 |
221 Convey(`When testing log data is added`, func() { | 233 Convey(`When testing log data is added`, func() { |
(...skipping 313 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
535 t.Parallel() | 547 t.Parallel() |
536 | 548 |
537 testGetImpl(t, false) | 549 testGetImpl(t, false) |
538 } | 550 } |
539 | 551 |
540 func TestGetArchived(t *testing.T) { | 552 func TestGetArchived(t *testing.T) { |
541 t.Parallel() | 553 t.Parallel() |
542 | 554 |
543 testGetImpl(t, false) | 555 testGetImpl(t, false) |
544 } | 556 } |
OLD | NEW |