salman/igny8
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ref

Browse Source
This commit is contained in:
IGNY8 VPS (Salman)
2025-12-01 03:07:07 +00:00
parent a7a772a78c
commit 861ca016aa
2 changed files with 1164 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
backend/igny8_core/tasks/wordpress_publishing.py
View File

@@ -57,7 +57,8 @@ def publish_content_to_wordpress(self, content_id: int, site_integration_id: int
# Extract site info for logging context
site_id = site_integration.site.id if site_integration.site else 'unknown'
site_domain = site_integration.base_url.replace('https://', '').replace('http://', '').split('/')[0] if site_integration.base_url else 'unknown'
base_url = site_integration.config_json.get('site_url', '') or site_integration.config_json.get('base_url', '')
site_domain = base_url.replace('https://', '').replace('http://', '').split('/')[0] if base_url else 'unknown'
log_prefix = f"[{site_id}-{site_domain}]"
publish_logger.info(f" ✅ Content loaded:")
@@ -70,8 +71,9 @@ def publish_content_to_wordpress(self, content_id: int, site_integration_id: int
publish_logger.info(f" ✅ Integration loaded:")
publish_logger.info(f" {log_prefix} Platform: {site_integration.platform}")
publish_logger.info(f" {log_prefix} Site: {site_integration.site.name}")
publish_logger.info(f" {log_prefix} Base URL: {site_integration.base_url}")
publish_logger.info(f" {log_prefix} API Key: {'***' + site_integration.api_key[-4:] if site_integration.api_key else 'None'}")
publish_logger.info(f" {log_prefix} Base URL: {base_url}")
api_key = site_integration.get_credentials().get('api_key', '')
publish_logger.info(f" {log_prefix} API Key: {'***' + api_key[-4:] if api_key else 'None'}")
except (Content.DoesNotExist, SiteIntegration.DoesNotExist) as e:
publish_logger.error(f" ❌ Database lookup failed: {e}")
return {"success": False, "error": str(e)}
@@ -253,15 +255,28 @@ def publish_content_to_wordpress(self, content_id: int, site_integration_id: int
publish_logger.info(f" {log_prefix} Sector ID: {content_data['sector_id']}")
# STEP 8: Send API request to WordPress
wordpress_url = f"{site_integration.base_url}/wp-json/igny8/v1/publish"
base_url = site_integration.config_json.get('site_url', '') or site_integration.config_json.get('base_url', '')
api_key = site_integration.get_credentials().get('api_key', '')
if not base_url:
error_msg = "No base_url/site_url configured in integration"
publish_logger.error(f" {log_prefix} ❌ {error_msg}")
return {"success": False, "error": error_msg}
if not api_key:
error_msg = "No API key configured in integration"
publish_logger.error(f" {log_prefix} ❌ {error_msg}")
return {"success": False, "error": error_msg}
wordpress_url = f"{base_url}/wp-json/igny8/v1/publish"
headers = {
'X-IGNY8-API-Key': site_integration.api_key,
'X-IGNY8-API-Key': api_key,
'Content-Type': 'application/json',
}
publish_logger.info(f"{log_prefix} STEP 8: Sending POST request to WordPress...")
api_logger.info(f"{log_prefix} API REQUEST: POST {wordpress_url}")
api_logger.info(f" {log_prefix} Headers: X-IGNY8-API-Key: ***{site_integration.api_key[-4:]}")
api_logger.info(f" {log_prefix} Headers: X-IGNY8-API-Key: ***{api_key[-4:]}")
api_logger.info(f" {log_prefix} Payload: {json.dumps(content_data, indent=2)[:500]}...")
try: