Add initial requires

.gitignore

@@ -0,0 +1,4 @@
+.idea
+*.swp
+.testrepository
+.tox

.project

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>interface-ceph-client</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.python.pydev.PyDevBuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.python.pydev.pythonNature</nature>
+	</natures>
+</projectDescription>

.pydevproject

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<?eclipse-pydev version="1.0"?><pydev_project>
+<pydev_pathproperty name="org.python.pydev.PROJECT_SOURCE_PATH">
+<path>/interface-ceph-client</path>
+</pydev_pathproperty>
+<pydev_property name="org.python.pydev.PYTHON_PROJECT_VERSION">python 2.7</pydev_property>
+<pydev_property name="org.python.pydev.PYTHON_PROJECT_INTERPRETER">Default</pydev_property>
+</pydev_project>

README.md

@@ -0,0 +1,43 @@
+# Overview
+
+This interface layer handles the communication between the Ceph Monitor
+cluster and a client that requires an access key and a pool to use.
+
+# Usage
+
+## Requires
+
+This interface layer will set the following states, as appropriate:
+
+  * `{relation_name}.available` The ceph client has been related to a provider.
+
+The following accessors will be available:
+
+   - key - The cephx access key
+   - auth - Whether or not strict auth is supported
+   - mon_hosts - The public addresses list of the monitor cluster
+
+Client example:
+
+```python
+@when('ceph-client.connected')
+def ceph_connected(ceph_client):
+  ceph_client.create_pool('newpool')
+
+@when('ceph-client.available')
+def ceph_ready(ceph_client):
+  charm_ceph_conf= os.path.join(os.sep, 'etc', 'ceph', 'ceph.conf')
+  cephx_key = os.path.join(os.sep, 'etc', 'ceph', 'ceph.client.charm.keyring')
+
+  ceph_context = {
+      'auth_supported': ceph_client.auth,
+      'mon_hosts': ceph_client.mon_hosts,
+  }
+
+  with open(charm_ceph_conf, 'w') as cephconf:
+    cephconf.write(render_template('ceph.conf', ceph_context))
+
+  # Write out the cephx_key also
+  with open(cephx_key, 'w') as cephconf:
+    cephconf.write(ceph_client.key)
+```

requires.py

@@ -0,0 +1,119 @@
+# Copyright 2017 Canonical Ltd
+#
+# 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.
+
+import json
+
+from charms.reactive import hook
+from charms.reactive import RelationBase
+from charms.reactive import scopes
+from charmhelpers.core import hookenv
+from charmhelpers.core.hookenv import log
+from charmhelpers.contrib.network.ip import format_ipv6_addr
+
+from charmhelpers.contrib.storage.linux.ceph import (
+    CephBrokerRq,
+    is_request_complete,
+    send_request_if_needed,
+)
+
+
+class CephClientRequires(RelationBase):
+    scope = scopes.GLOBAL
+
+    auto_accessors = ['auth', 'key']
+
+    @hook('{requires:ceph-client}-relation-{joined}')
+    def joined(self):
+        self.set_state('{relation_name}.connected')
+
+    @hook('{requires:ceph-client}-relation-{changed,departed}')
+    def changed(self):
+        data = {
+            'key': self.key(),
+            'auth': self.auth(),
+            'mon_hosts': self.mon_hosts()
+        }
+        if all(data.values()):
+            self.set_state('{relation_name}.available')
+
+        json_rq = self.get_local(key='broker_req')
+        if json_rq:
+            rq = CephBrokerRq()
+            j = json.loads(json_rq)
+            rq.ops = j['ops']
+            log("changed broker_req: {}".format(rq.ops))
+
+            if rq and is_request_complete(rq,
+                                          relation=self.relation_name):
+                log("Setting ceph-client.pools.available")
+                self.set_state('{relation_name}.pools.available')
+            else:
+                log("incomplete request. broker_req not found")
+
+    @hook('{requires:ceph-client}-relation-{broken}')
+    def broken(self):
+        self.remove_state('{relation_name}.available')
+        self.remove_state('{relation_name}.connected')
+        self.remove_state('{relation_name}.pools.available')
+
+    def create_pool(self, name, replicas=3):
+        """
+        Request pool setup
+
+        @param name: name of pool to create
+        @param replicas: number of replicas for supporting pools
+        """
+        # json.dumps of the CephBrokerRq()
+        json_rq = self.get_local(key='broker_req')
+
+        if not json_rq:
+            rq = CephBrokerRq()
+            rq.add_op_create_pool(name="{}".format(name),
+                                  replica_count=replicas,
+                                  weight=None)
+            self.set_local(key='broker_req', value=rq.request)
+            send_request_if_needed(rq, relation=self.relation_name)
+        else:
+            rq = CephBrokerRq()
+            try:
+                j = json.loads(json_rq)
+                log("Json request: {}".format(json_rq))
+                rq.ops = j['ops']
+                send_request_if_needed(rq, relation=self.relation_name)
+            except ValueError as err:
+                log("Unable to decode broker_req: {}.  Error: {}".format(
+                    json_rq, err))
+
+    def get_remote_all(self, key, default=None):
+        """Return a list of all values presented by remote units for key"""
+        # TODO: might be a nicer way todo this - written a while back!
+        values = []
+        for conversation in self.conversations():
+            for relation_id in conversation.relation_ids:
+                for unit in hookenv.related_units(relation_id):
+                    value = hookenv.relation_get(key,
+                                                 unit,
+                                                 relation_id) or default
+                    if value:
+                        values.append(value)
+        return list(set(values))
+
+    def mon_hosts(self):
+        """List of all monitor host public addresses"""
+        hosts = []
+        addrs = self.get_remote_all('ceph-public-address')
+        for addr in addrs:
+            hosts.append('{}:6789'.format(format_ipv6_addr(addr) or addr))
+        hosts.sort()
+        return hosts

test-requirements.txt

@@ -0,0 +1,2 @@
+flake8>=2.2.4,<=2.4.1
+os-testr>=0.4.1

tox.ini

@@ -0,0 +1,43 @@
+[tox]
+envlist = pep8,py27,py34,py35
+skipsdist = True
+skip_missing_interpreters = True
+
+[testenv]
+setenv = VIRTUAL_ENV={envdir}
+         PYTHONHASHSEED=0
+install_command =
+  pip install --allow-unverified python-apt {opts} {packages}
+commands = ostestr {posargs}
+
+[testenv:py27]
+basepython = python2.7
+deps = -r{toxinidir}/test-requirements.txt
+# TODO: Need to write unit tests then remove the following command.
+# https://github.com/juju/charm-tools/issues/249
+commands = /bin/true
+
+[testenv:py34]
+basepython = python3.4
+deps = -r{toxinidir}/test-requirements.txt
+# TODO: Need to write unit tests then remove the following command.
+# https://github.com/juju/charm-tools/issues/249
+commands = /bin/true
+
+[testenv:py35]
+basepython = python3.5
+deps = -r{toxinidir}/test-requirements.txt
+# TODO: Need to write unit tests then remove the following command.
+# https://github.com/juju/charm-tools/issues/249
+commands = /bin/true
+
+[testenv:pep8]
+basepython = python2.7
+deps = -r{toxinidir}/test-requirements.txt
+commands = flake8 {posargs}
+
+[testenv:venv]
+commands = {posargs}
+
+[flake8]
+ignore = E402,E226