gru/certpusher
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

logging

Browse Source
This commit is contained in:
Mateusz Gruszczyński
2025-10-27 07:22:27 +01:00
parent f6a7a621f9
commit 62537ce93c
1 changed files with 38 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
certpusher.py
View File

@@ -565,48 +565,48 @@ class CertPusher:
def process_proxmox(self, section: str, hostname: str, port: int, def process_proxmox(self, section: str, hostname: str, port: int,
username: str, ssh_key: str, source_cert_path: str) -> bool: username: str, ssh_key: str, source_cert_path: str) -> bool:
"""Process Proxmox VE server specifically""" """Process Proxmox VE server specifically"""
try: try:
logger.info("Using Proxmox deployment method") logger.info("Using Proxmox deployment method")
source_key_path = self.get_key_path(section, source_cert_path) source_key_path = self.get_key_path(section, source_cert_path)
if not os.path.exists(source_key_path): if not os.path.exists(source_key_path):
logger.error(f"Private key not found: {source_key_path}") logger.error(f"Private key not found: {source_key_path}")
return False return False
# Load source certificate for comparison # Load source certificate for comparison
source_cert = self.cert_manager.get_cert_from_file(source_cert_path) source_cert = self.cert_manager.get_cert_from_file(source_cert_path)
# Get check URL if available # Get check URL if available
check_url = self.config.get(section, 'check_url', fallback=None) check_url = self.config.get(section, 'check_url', fallback=None)
# Check if we should verify before upload # Check if we should verify before upload
check_first = self.config.getboolean(section, 'check_before_upload', fallback=True) check_first = self.config.getboolean(section, 'check_before_upload', fallback=True)
proxmox = ProxmoxManager(hostname, port, username, ssh_key) proxmox = ProxmoxManager(hostname, port, username, ssh_key)
if not proxmox.connect(): if not proxmox.connect():
self.stats['failed'] += 1 self.stats['failed'] += 1
return False return False
# Upload with optional checking
if not proxmox.upload_certificate(source_cert_path, source_key_path,
check_first, source_cert, check_url):
proxmox.disconnect()
self.stats['failed'] += 1
return False
# Upload with optional checking
if not proxmox.upload_certificate(source_cert_path, source_key_path,
check_first, source_cert, check_url):
proxmox.disconnect() proxmox.disconnect()
self.stats['uploaded'] += 1
logger.info(f"✓ Proxmox processed successfully")
return True
except Exception as e:
logger.error(f"Proxmox processing failed: {e}")
self.stats['failed'] += 1 self.stats['failed'] += 1
return False return False
proxmox.disconnect()
self.stats['uploaded'] += 1
logger.info(f"✓ Proxmox processed successfully")
return True
except Exception as e:
logger.error(f"Proxmox processing failed: {e}")
self.stats['failed'] += 1
return False
def process_host(self, section: str) -> bool: def process_host(self, section: str) -> bool:
"""Process certificate deployment for a single host""" """Process certificate deployment for a single host"""