New charm revision updater api

state/apiserver/root.go

 // Copyright 2013 Canonical Ltd.
 // Licensed under the AGPLv3, see LICENCE file for details.
 
 package apiserver
 
 import (
         "errors"
         "time"
 
         "launchpad.net/tomb"
 
         "launchpad.net/juju-core/rpc"
         "launchpad.net/juju-core/state"
         "launchpad.net/juju-core/state/apiserver/agent"
+        "launchpad.net/juju-core/state/apiserver/charmrevisionupdater"
         "launchpad.net/juju-core/state/apiserver/client"
         "launchpad.net/juju-core/state/apiserver/common"
         "launchpad.net/juju-core/state/apiserver/deployer"
         "launchpad.net/juju-core/state/apiserver/keymanager"
         "launchpad.net/juju-core/state/apiserver/keyupdater"
         loggerapi "launchpad.net/juju-core/state/apiserver/logger"
         "launchpad.net/juju-core/state/apiserver/machine"
         "launchpad.net/juju-core/state/apiserver/provisioner"
         "launchpad.net/juju-core/state/apiserver/uniter"
         "launchpad.net/juju-core/state/apiserver/upgrader"
@@ skipping 170 matching lines @@
 // KeyUpdater returns an object that provides access to the KeyUpdater API facade.
 // The id argument is reserved for future use and must be empty.
 func (r *srvRoot) KeyUpdater(id string) (*keyupdater.KeyUpdaterAPI, error) {
         if id != "" {
                 // TODO: There is no direct test for this
                 return nil, common.ErrBadId
         }
         return keyupdater.NewKeyUpdaterAPI(r.srv.state, r.resources, r)
 }
 
+// CharmRevisionUpdater returns an object that provides access to the CharmRevisionUpdater API facade.
+// The id argument is reserved for future use and must be empty.
+func (r *srvRoot) CharmRevisionUpdater(id string) (*charmrevisionupdater.CharmRevisionUpdaterAPI, error) {
+        if id != "" {
+                // TODO: There is no direct test for this
+                return nil, common.ErrBadId
+        }
+        return charmrevisionupdater.NewCharmRevisionUpdaterAPI(r.srv.state, r.resources, r)
+}
+
 // NotifyWatcher returns an object that provides
 // API access to methods on a state.NotifyWatcher.
 // Each client has its own current set of watchers, stored
 // in r.resources.
 func (r *srvRoot) NotifyWatcher(id string) (*srvNotifyWatcher, error) {
         if err := r.requireAgent(); err != nil {
                 return nil, err
         }
         watcher, ok := r.resources.Get(id).(state.NotifyWatcher)
         if !ok {
@@ skipping 172 matching lines @@
                 case <-pt.tomb.Dying():
                         return nil
                 case <-timer.C:
                         go pt.action()
                         return errors.New("ping timeout")
                 case <-pt.reset:
                         timer.Reset(pt.timeout)
                 }
         }
 }