LogDog: Support per-namespace expired archival.

appengine/cmd/cron/engine/engine_test.go

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package engine
 
 import (
         "encoding/json"
         "math/rand"
         "sort"
@@ skipping 601 matching lines @@
 
 func TestPrepareTopic(t *testing.T) {
         Convey("PrepareTopic works", t, func(ctx C) {
                 c := newTestContext(epoch)
 
                 e, _ := newTestEngine()
 
                 pubSubCalls := 0
                 e.configureTopic = func(c context.Context, topic, sub, pushURL, publisher string) error {
                         pubSubCalls++
-                        ctx.So(topic, ShouldEqual, "projects/dev~app/topics/dev-cron+noop+some~publisher.com")
-                        ctx.So(sub, ShouldEqual, "projects/dev~app/subscriptions/dev-cron+noop+some~publisher.com")
+                        ctx.So(topic, ShouldEqual, "projects/app/topics/dev-cron+noop+some~publisher.com")
+                        ctx.So(sub, ShouldEqual, "projects/app/subscriptions/dev-cron+noop+some~publisher.com")
                         ctx.So(pushURL, ShouldEqual, "") // pull on dev server
                         ctx.So(publisher, ShouldEqual, "some@publisher.com")
                         return nil
                 }
 
                 ctl := &taskController{
                         ctx:     c,
                         eng:     e,
                         manager: &noop.TaskManager{},
                         saved: Invocation{
                                 ID:     123456,
                                 JobKey: datastore.Get(c).NewKey("CronJob", "job_id", 0, nil),
                         },
                 }
                 ctl.populateState()
 
                 // Once.
                 topic, token, err := ctl.PrepareTopic("some@publisher.com")
                 So(err, ShouldBeNil)
-                So(topic, ShouldEqual, "projects/dev~app/topics/dev-cron+noop+some~publisher.com")
+                So(topic, ShouldEqual, "projects/app/topics/dev-cron+noop+some~publisher.com")
                 So(token, ShouldNotEqual, "")
                 So(pubSubCalls, ShouldEqual, 1)
 
                 // Again. 'configureTopic' should not be called anymore.
                 _, _, err = ctl.PrepareTopic("some@publisher.com")
                 So(err, ShouldBeNil)
                 So(pubSubCalls, ShouldEqual, 1)
 
                 // Make sure memcache-based deduplication also works.
                 e.doneFlags = make(map[string]bool)
@@ skipping 257 matching lines @@
 
 func ensureOneTask(c context.Context, q string) *taskqueue.Task {
         tqt := taskqueue.Get(c).Testable()
         tasks := tqt.GetScheduledTasks()[q]
         So(len(tasks), ShouldEqual, 1)
         for _, t := range tasks {
                 return t
         }
         return nil
 }