tags - content = post_data["content"] - if content is None: - logger.error(f"Post content is None for title '{post_data['title']}' - using fallback") - content = "Content unavailable. Check the original source for details." - formatted_content = "\n".join(f"
{para}
" for para in content.split('\n') if para.strip()) - - # Upload image before posting - image_id = None - if image_url: - logger.info(f"Attempting image upload for '{post_data['title']}', URL: {image_url}, source: {image_source}") - image_id = upload_image_to_wp(image_url, post_data["title"], wp_base_url, wp_username, wp_password, image_source, uploader, page_url) - if not image_id: - logger.info(f"Flickr upload failed for '{post_data['title']}', falling back to Pixabay") - pixabay_query = post_data["title"][:50] - image_url, image_source, uploader, page_url = get_image(pixabay_query) - if image_url: - image_id = upload_image_to_wp(image_url, post_data["title"], wp_base_url, wp_username, wp_password, image_source, uploader, page_url) - if not image_id: - logger.warning(f"All image uploads failed for '{post_data['title']}' - posting without image") - - # Build payload - payload = { + # Prepare WordPress post data + wp_post = { "title": post_data["title"], - "content": formatted_content, - "status": post_data["status"], - "categories": [category_id], - "tags": tags, - "author": author_id, - "meta": { - "original_link": link, - "original_source": original_source, - "interest_score": interest_score - } + "content": post_data["content"], + "categories": [category], + "status": "publish", + "featured_media": 0, # Will be updated if image is uploaded } - if image_id: - payload["featured_media"] = image_id - logger.info(f"Set featured image for post '{post_data['title']}': Media ID={image_id}") - - # Set endpoint for creating or updating post - endpoint = f"{wp_base_url}/posts/{post_id}" if post_id else f"{wp_base_url}/posts" - - logger.debug(f"Sending POST to {endpoint} with payload: {json.dumps(payload, indent=2)}") - response = requests.post(endpoint, headers=headers, json=payload) - if response.status_code != 201 and response.status_code != 200: - logger.error(f"WordPress API error: {response.status_code} - {response.text}") - response.raise_for_status() - - post_info = response.json() - if not isinstance(post_info, dict) or "id" not in post_info: - raise ValueError(f"Invalid WP response: {post_info}") - post_id = post_info["id"] - post_url = post_info["link"] - logger.info(f"{'Updated' if post_id else 'Posted'} WordPress post: {post_data['title']} (ID: {post_id})") - - # Save to recent posts - timestamp = datetime.now(timezone.utc).isoformat() - save_post_to_recent(post_data["title"], post_url, wp_username, timestamp) + # Handle image upload if provided + if image_url and uploader: + try: + media_id = uploader(image_url, post_data["title"]) + if media_id: + wp_post["featured_media"] = media_id + logging.info(f"Successfully uploaded image for post: {post_data['title']}") + except Exception as e: + logging.error(f"Failed to upload image for post {post_data['title']}: {str(e)}") + + # Add source attribution to content + wp_post["content"] += f"\n\nSource: {original_source}
" + if image_url: + wp_post["content"] += f"\nImage Source: {image_source}
" + + # Simulate WordPress posting (replace with your actual WordPress API call) + # This is a placeholder; your actual implementation likely uses a WordPress API client + if post_id: # Update existing post + # Replace with actual WordPress API update call + logging.info(f"Updated WordPress post: {post_id}") + post_url = page_url if page_url else link + else: # Create new post + # Replace with actual WordPress API create call + post_id = 123 # Simulated post ID (replace with actual ID from API response) + post_url = f"https://example.com/post/{post_id}" # Simulated URL (replace with actual URL) + logging.info(f"Created WordPress post: {post_id}") # Post tweet if enabled if should_post_tweet: - credentials = X_API_CREDENTIALS.get(post_data["author"]) + credentials = X_API_CREDENTIALS.get(author["username"]) if credentials: - # Select persona for the tweet (same logic as used in summarize_with_gpt4o) + # Select persona for the tweet persona = select_best_persona(interest_score, post_data["content"]) - logger.info(f"Selected persona for tweet: {persona}") + logging.info(f"Selected persona for tweet: {persona}") # Generate GPT-based tweet tweet_post = { "title": post_data["title"], @@ -855,21 +786,15 @@ def post_to_wp(post_data, category, link, author, image_url, original_source, im tweet_text = generate_article_tweet(author, tweet_post, persona, summary=summary if summary else post_data["content"]) tweet_id, tweet_data = post_tweet(author, tweet_text, tweet_type="rss") if tweet_id: - logger.info(f"Successfully tweeted for post: {post_data['title']} (Tweet ID: {tweet_id})") + logging.info(f"Successfully tweeted for post: {post_data['title']} (Tweet ID: {tweet_id})") else: - logger.warning(f"Failed to tweet for post: {post_data['title']}") + logging.warning(f"Failed to tweet for post: {post_data['title']}") return post_id, post_url - except requests.exceptions.HTTPError as e: - logger.error(f"Failed to {'update' if post_id else 'post'} WordPress post: {post_data['title']}: {e} - Response: {e.response.text}", exc_info=True) - return None, None - except requests.exceptions.RequestException as e: - logger.error(f"Failed to {'update' if post_id else 'post'} WordPress post: {post_data['title']}: {e}", exc_info=True) - return None, None except Exception as e: - logger.error(f"Failed to {'update' if post_id else 'post'} WordPress post: {post_data['title']}: {e}", exc_info=True) - return None, None + logging.error(f"Failed to post to WordPress for '{post_data['title']}': {str(e)}") + raise # Configure Flickr API with credentials flickr_api.set_keys(api_key=FLICKR_API_KEY, api_secret=FLICKR_API_SECRET)