Implement periodic sync command and functions.

[rochacbruno]

Introduces resource_registry/tasks/sync.py and resource_sync management command.

Depends on: #311 and resource_server#351

Config on django.conf.settings looks like

RESOURCE_SERVER = {
    "URL": "https://localhost",
    "SECRET_KEY": "<VERY-SECRET-KEY-HERE>",
    "VALIDATE_HTTPS": False,
}
RESOURCE_JWT_USER_ID = "97447387-8596-404f-b0d0-6429b04c8d22"
RESOURCE_SERVICE_PATH = "/api/server/v1/service-index/"

$ django-admin resource_sync --asyncio

----- RESOURCE SYNC STARTED -----

>>> shared.organization
Deleting 1 orphaned resources
Processing 2 resources with asyncio executor.
CREATED 3e3cc6a4-72fa-43ec-9e17-76ae5a3846ca Acme
NOOP 3e3cc6a4-72fa-43ec-9e17-76ae5a389999
Processed 3 | Created 1 | Updated 0 | Conflict 0 | Unavailable 0 | Skipped 1 | Deleted 1

>>> shared.team
Processing 1 resources with asyncio executor.

NOOP f43938cf-a618-4a73-bc90-922a6b217e4d
CREATED f43938cf-a618-4a73-bc90-922a6b28888
Processed 2 | Created 1 | Updated 0 | Conflict 0 | Unavailable 0 | Skipped 1 | Deleted 0

>>> shared.user
Processing 4 resources with asyncio executor.

UPDATED 31daab14-cb67-4c62-8dcd-39f411c82242 joe
NOOP 97447387-8596-404f-b0d0-6429b04c8d22
NOOP 4d01427e-a11e-4d0e-9408-4ef7c2b478d6
CONFLICT 53886798-29e7-426f-b9cb-f7f74b346072 mary
Processed 4 | Created 0 | Updated 1 | Conflict 1 | Unavailable 0 | Skipped 2 | Deleted 0

----- RESOURCE SYNC FINISHED -----

OR run in a task queue such as Celery, RQ or Pulp Task

from celery import Celery
from celery.schedules import crontab
from ansible_base.resource_registry.tasks.sync import SyncExecutor

# Initialize Celery app
celery = Celery('your_app_name', broker='redis://localhost:6379/0')

# Define Celery task
@celery.task
def execute_sync_executor():
    SyncExecutor(
        asyncio=False,
        api_client=ResourceAPIClient(....),  # Omit to have a default client created
        retries=3,
        retrysleep=60,
        retain_seconds=300,  # Avoid delete resources created in the latest 5 minutes
        stdout=sys.stdout  # omit to silence it
    ).run()

# Schedule the task to run every 15 minutes
celery.conf.beat_schedule = {
    'execute-every-15-minutes': {
        'task': 'your_module.execute_sync_executor',
        'schedule': crontab(minute='*/15'),
    },
}

[AlanCoding]

Thanks for responding to comments.

[sonarcloud]

Quality Gate passed

Issues
1 New issue
0 Accepted issues

Measures
0 Security Hotspots
95.9% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarCloud