fix dirpath for date-based subscriptions

ECCC-MSC · Feb 19, 2025 · eccdc28 · eccdc28
1 parent 121d9f8
commit eccdc28
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/msc-wis2node-management/msc_wis2node/publisher.py b/msc-wis2node-management/msc_wis2node/publisher.py
@@ -235,7 +235,8 @@ def _subtopic2dirpath(self, subtopic: str) -> str:
 
         LOGGER.debug(f'AMQP subtopic: {subtopic}')
 
-        dirpath = '/' + subtopic.replace('.', '/').rstrip('/#')
+        dirpath = '/' + subtopic.replace('*.', '/').replace('.', '/').rstrip('/#')
+        dirpath = dirpath.replace('//', '/')
         dirpath = f'*{dirpath}*'
 
         LOGGER.debug(f'directory path: {dirpath}')