mirror of
https://github.com/netbox-community/netbox.git
synced 2024-05-10 07:54:54 +00:00
d8784d4155
* WIP * WIP * Add git sync * Fix file hashing * Add last_synced to DataSource * Build out UI & API resources * Add status field to DataSource * Add UI control to sync data source * Add API endpoint to sync data sources * Fix display of DataSource job results * DataSource password should be write-only * General cleanup * Add data file UI view * Punt on HTTP, FTP support for now * Add DataSource URL validation * Add HTTP proxy support to git fetcher * Add management command to sync data sources * DataFile REST API endpoints should be read-only * Refactor fetch methods into backend classes * Replace auth & git branch fields with general-purpose parameters * Fix last_synced time * Render discrete form fields for backend parameters * Enable dynamic edit form for DataSource * Register DataBackend classes in application registry * Add search indexers for DataSource, DataFile * Add single & bulk delete views for DataFile * Add model documentation * Convert DataSource to a primary model * Introduce pre_sync & post_sync signals * Clean up migrations * Rename url to source_url * Clean up filtersets * Add API & filterset tests * Add view tests * Add initSelect() to HTMX refresh handler * Render DataSourceForm fieldsets dynamically * Update compiled static resources
30 lines
850 B
Python
30 lines
850 B
Python
import logging
|
|
|
|
from extras.choices import JobResultStatusChoices
|
|
from netbox.search.backends import search_backend
|
|
from .choices import *
|
|
from .exceptions import SyncError
|
|
from .models import DataSource
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
def sync_datasource(job_result, *args, **kwargs):
|
|
"""
|
|
Call sync() on a DataSource.
|
|
"""
|
|
datasource = DataSource.objects.get(name=job_result.name)
|
|
|
|
try:
|
|
job_result.start()
|
|
datasource.sync()
|
|
|
|
# Update the search cache for DataFiles belonging to this source
|
|
search_backend.cache(datasource.datafiles.iterator())
|
|
|
|
except SyncError as e:
|
|
job_result.set_status(JobResultStatusChoices.STATUS_ERRORED)
|
|
job_result.save()
|
|
DataSource.objects.filter(pk=datasource.pk).update(status=DataSourceStatusChoices.FAILED)
|
|
logging.error(e)
|