Return fully qualified subscription name

VERSION

@@ -1 +1 @@
-20170307-03
+20170316-01

auth.go

@@ -76,6 +76,11 @@ func FindAuth(ctx context.Context, id string) (*Auth, error) {
 
 func FindAuthWithToken(ctx context.Context, token string) (*Auth, error) {
 	parts := strings.SplitN(token, ":", 2)
+	if len(parts) != 2 {
+		err := errors.New("Invalid token: " + token)
+		log.Errorf(ctx, "@FindAuthWithToken %v", err)
+		return nil, err
+	}
 	id := parts[0]
 	pw := parts[1]
 	auth, err := FindAuth(ctx, id)

handler_test.go

@@ -20,7 +20,8 @@ const (
 )
 
 func TestActions(t *testing.T) {
-	inst, err := aetest.NewInstance(nil)
+	opt := &aetest.Options{StronglyConsistentDatastore: true}
+	inst, err := aetest.NewInstance(opt)
 	assert.NoError(t, err)
 	defer inst.Close()
 
@@ -49,6 +50,7 @@ func TestActions(t *testing.T) {
 	auth_headers := []string{
 		"",
 		"Bearer ",
+		"Bearer invalid-token",
 		"Bearer invalid-token:123456789",
 	}
 	for _, v := range auth_headers {
@@ -240,7 +242,7 @@ func TestActions(t *testing.T) {
 			if assert.Equal(t, 1, len(subscriptions)) {
 				sub := subscriptions[0]
 				assert.Equal(t, "pipeline01", sub.Pipeline)
-				assert.Equal(t, "pipeline01-progress-subscription", sub.Name)
+				assert.Equal(t, "projects/proj-123/subscriptions/pipeline01-progress-subscription", sub.Name)
 			}
 		}
 	}

pipeline.go

@@ -194,7 +194,7 @@ func GetActiveSubscriptions(ctx context.Context) ([]*Subscription, error) {
 	for _, pipeline := range pipelines {
 		r = append(r, &Subscription{
 			Pipeline: pipeline.Props.Name,
-			Name:     pipeline.Props.Name + "-progress-subscription",
+			Name:     fmt.Sprintf("projects/%v/subscriptions/%v-progress-subscription", pipeline.Props.ProjectID, pipeline.Props.Name),
 		})
 	}
 	return r, nil