enable celery

TODO.md

@@ -0,0 +1,13 @@
+QMN should be unique indexed on (message, URL)
+
+Test for non-json messages
+Test for messages where all the parts are known
+Many more tests
+
+"deploy" should do something
+
+Celery tasks
+
+Celery result endpoint
+
+Logging

django_kepi/migrations/0004_quarantinedmessageneeds.py

@@ -0,0 +1,23 @@
+# Generated by Django 2.1.1 on 2018-09-23 14:53
+
+from django.db import migrations, models
+import django.db.models.deletion
+import uuid
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('django_kepi', '0003_auto_20180918_1708'),
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='QuarantinedMessageNeeds',
+            fields=[
+                ('id', models.UUIDField(default=uuid.uuid4, editable=False, primary_key=True, serialize=False)),
+                ('needs_to_fetch', models.URLField()),
+                ('message', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to='django_kepi.QuarantinedMessage')),
+            ],
+        ),
+    ]

requirements.txt

@@ -4,3 +4,4 @@ django
 requests
 requests-http-signature
 cryptography
+django-celery

test_settings.py

@@ -1,5 +1,8 @@
 from django.urls import path, include
 
+import djcelery
+djcelery.setup_loader()
+
 KEPI = {
         'ACTIVITY_URL_FORMAT': 'https://example.com/activities/%s',
         }
@@ -13,6 +16,9 @@ INSTALLED_APPS = (
         'django.contrib.messages',
         'django.contrib.staticfiles',
 
+        'djcelery',
+        'django_celery_results',
+
         'django_kepi',
         'things_for_testing',
 
@@ -28,3 +34,5 @@ DATABASES = {
 SECRET_KEY = "secret_key_for_testing"
 
 ROOT_URLCONF = 'test_urls'
+
+#CELERY_ACCEPT_CONTENT = ['json']

things_for_testing/__init__.py

@@ -0,0 +1,4 @@
+from __future__ import absolute_import, unicode_literals
+from .celery import app as celery_app
+
+__all__ = ('celery_app',)