@@ -28,6 +28,8 @@ django-extensions = "*"
 activecampaign-python = {git = "https://github.com/renzon/activecampaign-python.git",ref = "last-v1-api"}
 codecov = "*"
 django-bootstrap4 = "*"
+celery = "*"
+redis = "*"
 
 [dev-packages]
 faker = "*"
 
@@ -1,2 +1,3 @@
 release: python manage.py sync_roles & python manage.py migrate --noinput
 web: newrelic-admin run-program gunicorn pythonpro.wsgi --log-file -
+worker: newrelic-admin run-program celery -A pythonpro.celery worker --loglevel=info
@@ -40,4 +40,9 @@ ACTIVE_CAMPAIGN_TURNED_ON=true
 
 # Google Tag Manager Config
 GOOGLE_TAG_MANAGER_ID=GTM-ABC1234
+
+#CELERY_CONFIG
+
+CLOUDAMQP_URL=amqp://guest:guest@localhost:5672
+REDIS_URL=redis://localhost:6379/1
 
@@ -12,4 +12,16 @@ services:
       - POSTGRES_PASSWORD=pythonpro
       - POSTGRES_USER=pythonpro
     ports:
-      - 5433:5432
+      - 5433:5432
+  celery_broker:
+    container_name: pythonpro_celery_broker
+    image: rabbitmq:3.8.2
+    restart: always
+    ports:
+      - 5672:5672
+  redis:
+    container_name: pythonpro_redis
+    image: redis:5.0.7
+    restart: always
+    ports:
+      - 6379:6379
@@ -0,0 +1 @@
+from .celery import app  # noqa
@@ -0,0 +1,9 @@
+import os
+
+from celery import Celery
+from django.conf import settings
+
+os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'pythonpro.settings')
+app = Celery('pythonpro.celery')
+app.config_from_object('django.conf:settings')
+app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
@@ -8,9 +8,7 @@
 
 from pythonpro.absolute_uri import build_absolute_uri
 from pythonpro.core.models import UserInteraction
-from pythonpro.django_assertions import (
-    dj_assert_not_contains, dj_assert_contains, dj_assert_template_used
-)
+from pythonpro.django_assertions import (dj_assert_contains, dj_assert_not_contains, dj_assert_template_used)
 
 
 @pytest.fixture
@@ -98,12 +96,17 @@ def resp_lead_change_pasword(resp_lead_creation, client):
 
 @pytest.fixture(autouse=True)
 def sync_user(mocker):
-    return mocker.patch('pythonpro.domain.user_facade._discourse_facade.sync_user')
+    return mocker.patch('pythonpro.domain.user_facade.sync_user_on_discourse')
 
 
-def test_user_discourse_sync(resp_lead_creation, django_user_model, sync_user):
+@pytest.fixture(autouse=True)
+def sync_user_delay(mocker):
+    return mocker.patch('pythonpro.domain.user_facade.sync_user_on_discourse.delay')
+
+
+def test_user_discourse_sync(resp_lead_creation, django_user_model, sync_user_delay):
     user = django_user_model.objects.first()
-    sync_user.assert_called_once_with(user)
+    sync_user_delay.assert_called_once_with(user.id)
 
 
 def test_lead_creation(resp_lead_creation, django_user_model):
 
@@ -5,7 +5,6 @@
 from logging import Logger
 from urllib import parse
 
-import requests
 from django.conf import settings
 
 _key_bytes = settings.DISCOURSE_SSO_SECRET.encode('utf-8')
@@ -43,37 +42,6 @@ def generate_discourse_login_url(user, payload, signature):
     return _generate_discourse_login_url(nonce, user)
 
 
-def sync_user(user):
-    """
-    Synchronize user data on forum if API is set
-    :param user: Django user
-    :return: returns nothing
-    """
-    can_make_api_call = bool(settings.DISCOURSE_API_KEY and settings.DISCOURSE_API_USER)
-    can_work_without_sync = not (settings.DISCOURSE_BASE_URL or can_make_api_call)
-    if can_work_without_sync:
-        return
-    elif not can_make_api_call:
-        raise MissingDiscourseAPICredentials('Must define both DISCOURSE_API_KEY and DISCOURSE_API_USER configs')
-    # https://meta.discourse.org/t/sync-sso-user-data-with-the-sync-sso-route/84398
-    params = {
-        'email': user.email,
-        'external_id': user.id,
-        'require_activation': 'false',
-        'groups': ','.join(g.name for g in user.groups.all())
-    }
-    sso_payload, signature = generate_sso_payload_and_signature(params)
-    # query_string = parse.urlencode()
-    url = f'{settings.DISCOURSE_BASE_URL}/admin/users/sync_sso'
-    headers = {
-        'content-type': 'multipart/form-data',
-        'Api-Key': settings.DISCOURSE_API_KEY,
-        'Api-Username': settings.DISCOURSE_API_USER,
-    }
-
-    return requests.post(url, data={'sso': sso_payload, 'sig': signature}, headers=headers)
-
-
 def _generate_discourse_login_url(nonce, user):
     params = {
         'nonce': nonce,
 
@@ -1,6 +1,7 @@
 import pytest
 import responses
 
+import pythonpro.domain.user_facade
 from pythonpro.discourse import facade
 
 
@@ -14,21 +15,21 @@ def test_missing_discourse_api_key(settings, no_responses):
     settings.DISCOURSE_API_KEY = ''
     settings.DISCOURSE_BASE_URL = 'https://forum.python.pro.br/'
     with pytest.raises(facade.MissingDiscourseAPICredentials):
-        facade.sync_user(None)
+        pythonpro.domain.user_facade.sync_user_on_discourse(None)
 
 
 def test_missing_discourse_api_user(settings, no_responses):
     settings.DISCOURSE_API_USER = ''
     settings.DISCOURSE_BASE_URL = 'https://forum.python.pro.br/'
     with pytest.raises(facade.MissingDiscourseAPICredentials):
-        facade.sync_user(None)
+        pythonpro.domain.user_facade.sync_user_on_discourse(None)
 
 
 def test_no_integration_on_missing_url_config(settings, no_responses):
     settings.DISCOURSE_API_USER = ''
     settings.DISCOURSE_API_KEY = ''
     settings.DISCOURSE_BASE_URL = ''
-    assert facade.sync_user(None) is None
+    assert pythonpro.domain.user_facade.sync_user_on_discourse(None) is None
 
 
 @pytest.fixture
@@ -43,7 +44,7 @@ def resps(settings):
 
 
 def test_user_sync(logged_user, resps):
-    facade.sync_user(logged_user)
+    pythonpro.domain.user_facade.sync_user_on_discourse(logged_user)
 
 
 success_response = {
Original file line number	Diff line number	Diff line change
`@@ -1,2 +1,3 @@`
`1`	`1`	`release: python manage.py sync_roles & python manage.py migrate --noinput`
`2`	`2`	`web: newrelic-admin run-program gunicorn pythonpro.wsgi --log-file -`
	`3`	`+worker: newrelic-admin run-program celery -A pythonpro.celery worker --loglevel=info`