+
+{% endfor %}
+{{render_pagination(fractals)}}
+{% endblock %}
diff --git a/faafo/faafo/queues.py b/faafo/faafo/queues.py
new file mode 100644
index 0000000..4e5a6fd
--- /dev/null
+++ b/faafo/faafo/queues.py
@@ -0,0 +1,32 @@
+# 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 copy
+
+import kombu
+from oslo_config import cfg
+
+task_exchange = kombu.Exchange('tasks', type='direct')
+task_queue = kombu.Queue('normal', task_exchange, routing_key='normal')
+
+queues_opts = [
+ cfg.StrOpt('transport-url',
+ default='amqp://guest:guest@localhost:5672//',
+ help='AMQP connection URL.')
+]
+
+cfg.CONF.register_opts(queues_opts)
+
+
+def list_opts():
+ """Entry point for oslo-config-generator."""
+ return [(None, copy.deepcopy(queues_opts))]
diff --git a/faafo/faafo/version.py b/faafo/faafo/version.py
new file mode 100644
index 0000000..7a68690
--- /dev/null
+++ b/faafo/faafo/version.py
@@ -0,0 +1,15 @@
+# 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 pbr.version
+
+version_info = pbr.version.VersionInfo('faafo')
diff --git a/faafo/faafo/worker/__init__.py b/faafo/faafo/worker/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/faafo/faafo/worker/service.py b/faafo/faafo/worker/service.py
new file mode 100644
index 0000000..d1bb193
--- /dev/null
+++ b/faafo/faafo/worker/service.py
@@ -0,0 +1,156 @@
+#!/usr/bin/env python
+
+# 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.
+
+# based on http://code.activestate.com/recipes/577120-julia-fractals/
+
+import base64
+import copy
+import hashlib
+import json
+import os
+from PIL import Image
+import random
+import socket
+import tempfile
+import time
+
+from kombu.mixins import ConsumerMixin
+from oslo_config import cfg
+from oslo_log import log
+import requests
+
+from faafo import queues
+
+LOG = log.getLogger('faafo.worker')
+CONF = cfg.CONF
+
+
+worker_opts = {
+ cfg.StrOpt('endpoint-url',
+ default='http://localhost',
+ help='API connection URL')
+}
+
+CONF.register_opts(worker_opts)
+
+
+def list_opts():
+ """Entry point for oslo-config-generator."""
+ return [(None, copy.deepcopy(worker_opts))]
+
+
+class JuliaSet(object):
+
+ def __init__(self, width, height, xa=-2.0, xb=2.0, ya=-1.5, yb=1.5,
+ iterations=255):
+ self.xa = xa
+ self.xb = xb
+ self.ya = ya
+ self.yb = yb
+ self.iterations = iterations
+ self.width = width
+ self.height = height
+ self.draw()
+
+ def draw(self):
+ self.image = Image.new("RGB", (self.width, self.height))
+ c, z = self._set_point()
+ for y in range(self.height):
+ zy = y * (self.yb - self.ya) / (self.height - 1) + self.ya
+ for x in range(self.width):
+ zx = x * (self.xb - self.xa) / (self.width - 1) + self.xa
+ z = zx + zy * 1j
+ for i in range(self.iterations):
+ if abs(z) > 2.0:
+ break
+ z = z * z + c
+ self.image.putpixel((x, y),
+ (i % 8 * 32, i % 16 * 16, i % 32 * 8))
+
+ def get_file(self):
+ with tempfile.NamedTemporaryFile(delete=False) as fp:
+ self.image.save(fp, "PNG")
+ return fp.name
+
+ def _set_point(self):
+ random.seed()
+ while True:
+ cx = random.random() * (self.xb - self.xa) + self.xa
+ cy = random.random() * (self.yb - self.ya) + self.ya
+ c = cx + cy * 1j
+ z = c
+ for i in range(self.iterations):
+ if abs(z) > 2.0:
+ break
+ z = z * z + c
+ if i > 10 and i < 100:
+ break
+
+ return (c, z)
+
+
+class Worker(ConsumerMixin):
+
+ def __init__(self, connection):
+ self.connection = connection
+
+ def get_consumers(self, Consumer, channel):
+ return [Consumer(queues=queues.task_queue,
+ accept=['json'],
+ callbacks=[self.process])]
+
+ def process(self, task, message):
+ LOG.info("processing task %s" % task['uuid'])
+ LOG.debug(task)
+ start_time = time.time()
+ juliaset = JuliaSet(task['width'],
+ task['height'],
+ task['xa'],
+ task['xb'],
+ task['ya'],
+ task['yb'],
+ task['iterations'])
+ elapsed_time = time.time() - start_time
+ LOG.info("task %s processed in %f seconds" %
+ (task['uuid'], elapsed_time))
+
+ filename = juliaset.get_file()
+ LOG.debug("saved result of task %s to temporary file %s" %
+ (task['uuid'], filename))
+ with open(filename, "rb") as fp:
+ size = os.fstat(fp.fileno()).st_size
+ image = base64.b64encode(fp.read())
+ checksum = hashlib.sha256(open(filename, 'rb').read()).hexdigest()
+ os.remove(filename)
+ LOG.debug("removed temporary file %s" % filename)
+
+ result = {
+ 'uuid': task['uuid'],
+ 'duration': elapsed_time,
+ 'image': image,
+ 'checksum': checksum,
+ 'size': size,
+ 'generated_by': socket.gethostname()
+ }
+
+ # NOTE(berendt): only necessary when using requests < 2.4.2
+ headers = {'Content-type': 'application/json',
+ 'Accept': 'text/plain'}
+
+ requests.put("%s/v1/fractal/%s" %
+ (CONF.endpoint_url, str(task['uuid'])),
+ json.dumps(result), headers=headers)
+
+ message.ack()
+ return result
diff --git a/faafo/requirements.txt b/faafo/requirements.txt
new file mode 100644
index 0000000..55d2597
--- /dev/null
+++ b/faafo/requirements.txt
@@ -0,0 +1,17 @@
+pbr>=1.6
+pytz
+positional
+iso8601
+anyjson>=0.3.3
+eventlet>=0.17.4
+PyMySQL>=0.6.2,<0.7 # 0.7 design change breaks faafo, MIT License
+Pillow==2.4.0 # MIT
+requests>=2.5.2
+Flask-Bootstrap
+Flask>=0.10,<1.0
+flask-restless
+flask-sqlalchemy
+oslo.config>=2.3.0 # Apache-2.0
+oslo.log>=1.8.0 # Apache-2.0
+PrettyTable>=0.7,<0.8
+kombu>=3.0.7
diff --git a/faafo/setup.cfg b/faafo/setup.cfg
new file mode 100644
index 0000000..47e621e
--- /dev/null
+++ b/faafo/setup.cfg
@@ -0,0 +1,54 @@
+[metadata]
+name = faafo
+summary = First App Application for OpenStack
+description-file =
+ README.rst
+author = OpenStack Documentation
+author-email = openstack-doc@lists.openstack.org
+home-page = http://docs.openstack.org/developer/faafo/
+classifier =
+ Environment :: OpenStack
+ Intended Audience :: Information Technology
+ Intended Audience :: System Administrators
+ License :: OSI Approved :: Apache Software License
+ Operating System :: POSIX :: Linux
+ Programming Language :: Python
+ Programming Language :: Python :: 2
+ Programming Language :: Python :: 2.7
+
+[files]
+packages =
+ faafo
+scripts =
+ bin/faafo
+ bin/faafo-worker
+extra_files =
+ faafo/api/templates/index.html
+data_files =
+ /etc/faafo = etc/faafo.conf
+
+[global]
+setup-hooks =
+ pbr.hooks.setup_hook
+
+[entry_points]
+console_scripts =
+ faafo-api = faafo.api.service:main
+oslo.config.opts =
+ faafo.api = faafo.api.service:list_opts
+ faafo.worker = faafo.worker.service:list_opts
+ faafo.queues= faafo.queues:list_opts
+
+[build_sphinx]
+source-dir = doc/source
+build-dir = doc/build
+all_files = 1
+
+[upload_sphinx]
+upload-dir = doc/build/html
+
+[wheel]
+universal = 1
+
+[pbr]
+warnerrors = true
diff --git a/faafo/setup.py b/faafo/setup.py
new file mode 100644
index 0000000..ee06f22
--- /dev/null
+++ b/faafo/setup.py
@@ -0,0 +1,29 @@
+#!/usr/bin/env python
+# Copyright (c) 2013 Hewlett-Packard Development Company, L.P.
+#
+# 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 setuptools
+
+# In python < 2.7.4, a lazy loading of package `pbr` will break
+# setuptools if some other modules registered functions in `atexit`.
+# solution from: http://bugs.python.org/issue15881#msg170215
+try:
+ import multiprocessing # noqa
+except ImportError:
+ pass
+
+setuptools.setup(
+ setup_requires=['pbr'],
+ pbr=True)
diff --git a/faafo/test-requirements.txt b/faafo/test-requirements.txt
new file mode 100644
index 0000000..3592358
--- /dev/null
+++ b/faafo/test-requirements.txt
@@ -0,0 +1,2 @@
+hacking<0.11,>=0.10
+sphinx>=1.1.2,!=1.2.0,!=1.3b1,<1.3
diff --git a/faafo/tox.ini b/faafo/tox.ini
new file mode 100644
index 0000000..5f9d4d0
--- /dev/null
+++ b/faafo/tox.ini
@@ -0,0 +1,27 @@
+[tox]
+minversion = 1.6
+envlist = pep8
+skipsdist = True
+
+[testenv]
+usedevelop = True
+deps = -r{toxinidir}/test-requirements.txt
+ -r{toxinidir}/requirements.txt
+install_command = pip install -U {opts} {packages}
+
+[testenv:venv]
+commands = {posargs}
+
+[testenv:docs]
+commands = python setup.py build_sphinx
+
+[testenv:genconfig]
+commands =
+ oslo-config-generator --config-file etc/oslo-config-generator/faafo.conf
+
+[testenv:pep8]
+commands = flake8 {posargs}
+
+[flake8]
+show-source = True
+exclude=.venv,.git,.tox,*egg*,build,*openstack/common*
+
+ 
+
+
+
+
+
+
+
+| UUID | +{{ fractal.uuid }} | +
| Duration | +{{ fractal.duration }} seconds | +
| Dimensions | +{{ fractal.width }} x {{ fractal.height }} px | +
| Iterations | +{{ fractal.iterations }} | +
| Parameters | +
+ xa = {{ fractal.xa }}
+xb = {{ fractal.xb }}
+ya = {{ fractal.ya }}
+yb = {{ fractal.yb }}
+ |
+
| Filesize | +{{ fractal.size}} bytes | +
| Checksum | +{{ fractal.checksum }} |
+
| Generated by | +{{ fractal.generated_by }} | +