Add moniker-manage CLI commands to trigger sync's

Change-Id: I5445ed183754f4f5a75860d14b94cf69b13c83e2

moniker/manage/base.py

@@ -25,7 +25,8 @@ class Command(CliffCommand):
     __metaclass__ = abc.ABCMeta
 
     def run(self, parsed_args):
-        self.context = MonikerContext.get_admin_context()
+        self.context = MonikerContext.get_admin_context(
+            request_id="moniker-manage")
 
         return super(Command, self).run(parsed_args)
 

moniker/manage/sync.py

@@ -0,0 +1,57 @@
+# Copyright 2012 Managed I.T.
+#
+# Author: Kiall Mac Innes <kiall@managedit.ie>
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may
+# not use this file except in compliance with the License. You may obtain
+# a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations
+# under the License.
+from moniker.openstack.common import log as logging
+from moniker.manage import base
+from moniker.central import api as central_api
+
+LOG = logging.getLogger(__name__)
+
+
+class SyncAllCommand(base.Command):
+    """ Sync Everything """
+
+    def take_action(self, parsed_args):
+        return central_api.sync_all(self.context)
+
+
+class SyncDomainCommand(base.Command):
+    """ Sync A Single Domain """
+
+    def get_parser(self, prog_name):
+        parser = super(SyncDomainCommand, self).get_parser(prog_name)
+
+        parser.add_argument('id', help="Domain ID")
+
+        return parser
+
+    def take_action(self, parsed_args):
+        return central_api.sync_domain(self.context, parsed_args.id)
+
+
+class SyncRecordCommand(base.Command):
+    """ Sync A Single Record """
+
+    def get_parser(self, prog_name):
+        parser = super(SyncDomainCommand, self).get_parser(prog_name)
+
+        parser.add_argument('domain_id', help="Domain ID")
+        parser.add_argument('id', help="Record ID")
+
+        return parser
+
+    def take_action(self, parsed_args):
+        return central_api.sync_record(self.context, parsed_args.domain_id,
+                                       parsed_args.id)

setup.py

@@ -88,6 +88,10 @@ setup(
         tsigkey-create = moniker.manage.tsigkeys:CreateTsigKeyCommand
         tsigkey-update = moniker.manage.tsigkeys:UpdateTsigKeyCommand
         tsigkey-delete = moniker.manage.tsigkeys:DeleteTsigKeyCommand
+
+        sync-all = moniker.manage.sync:SyncAllCommand
+        sync-domain = moniker.manage.sync:SyncDomainCommand
+        sync-record = moniker.manage.sync:SyncRecordCommand
         """),
     classifiers=[
         'Development Status :: 3 - Alpha',