From 2059a829d412d5cc134eb45ba7cf05679539c7e9 Mon Sep 17 00:00:00 2001
From: jacekv <jacek.varky@bitpanda.com>
Date: Tue, 19 Nov 2024 11:12:57 +0100
Subject: [PATCH] PAN-2270: Point to certs (#148)

* PAN-2270: Point to certs

* PAN-2270: Set proper path based on broker url
---
 pantos/servicenode/celery.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/pantos/servicenode/celery.py b/pantos/servicenode/celery.py
index 5f2c103..2928061 100644
--- a/pantos/servicenode/celery.py
+++ b/pantos/servicenode/celery.py
@@ -7,6 +7,7 @@
 
 import amqp  # type: ignore
 import celery  # type: ignore
+import certifi  # type: ignore
 from pantos.common.logging import LogFile
 from pantos.common.logging import LogFormat
 from pantos.common.logging import initialize_logger
@@ -41,13 +42,16 @@ def is_main_module() -> bool:
     _logger.info('Initializing the Celery application...')
     initialize_application(False)
 
+ca_certs = {} if config['celery']['broker'].startswith('amqp') else {
+    'ca_certs': certifi.where()
+}
 celery_app = celery.Celery(
     'pantos.servicenode', broker=config['celery']['broker'],
     backend=config['celery']['backend'], include=[
         'pantos.common.blockchains.tasks',
         'pantos.servicenode.business.transfers',
         'pantos.servicenode.business.plugins'
-    ])
+    ], broker_use_ssl=ca_certs)
 """Celery application instance."""
 
 # Additional Celery configuration