milo: Enable Swarming LogDog log loading.

logdog/common/types/streamaddr_test.go

+// Copyright 2015 The LUCI Authors. All rights reserved.
+// Use of this source code is governed under the Apache License, Version 2.0
+// that can be found in the LICENSE file.
+
+package types
+
+import (
+        "fmt"
+        "net/url"
+        "testing"
+
+        . "github.com/luci/luci-go/common/testing/assertions"
+        . "github.com/smartystreets/goconvey/convey"
+)
+
+func TestStreamAddr(t *testing.T) {
+        t.Parallel()
+
+        var successes = []struct {
+                s   string
+                exp StreamAddr
+        }{
+                {"logdog://host/project/a/+/b", StreamAddr{"host", "project", "a/+/b"}},
+                {"logdog://host.example.com/project/foo/bar/+/baz", StreamAddr{"host.example.com", "project", "foo/bar/+/baz"}},
+        }
+
+        var failures = []struct {
+                s   string
+                err string
+        }{
+                {"://project/prefix/+/name", "failed to parse URL"},
+                {"http://example.com/foo/bar/+/baz", "is not logdog"},
+                {"logdog://example.com/foo", "URL path does not include both project and path components"},
+                {"logdog://example.com/foo@d/bar", "invalid project name"},
+                {"logdog://example.com/foo/bar", "invalid stream path"},
+                {"logdog://example.com/foo/bar/+/ba!", "invalid stream path"},
+        }
+
+        Convey(`Testing StreamAddr`, t, func() {
+
+                for _, tc := range successes {
+                        Convey(fmt.Sprintf(`Success: %q`, tc.s), func() {
+                                addr, err := ParseURL(tc.s)
+                                So(err, ShouldBeNil)
+                                So(addr, ShouldResemble, &tc.exp)
+
+                                u, err := url.Parse(tc.s)
+                                So(err, ShouldBeNil)
+                                So(addr.URL(), ShouldResemble, u)
+                        })
+                }
+
+                for _, tc := range failures {
+                        Convey(fmt.Sprintf(`Failure: %q fails like: %q`, tc.s, tc.err), func() {
+                                _, err := ParseURL(tc.s)
+                                So(err, ShouldErrLike, tc.err)
+                        })
+                }
+        })
+}