MM2: Normalize directory paths received from airtime once and for all.
This commit is contained in:
parent
43bef4939e
commit
3fc60c741d
1 changed files with 2 additions and 0 deletions
|
@ -54,6 +54,7 @@ class AirtimeNotifier(Loggable):
|
||||||
message.ack()
|
message.ack()
|
||||||
self.logger.info("Received md from RabbitMQ: %s" % str(body))
|
self.logger.info("Received md from RabbitMQ: %s" % str(body))
|
||||||
m = json.loads(message.body)
|
m = json.loads(message.body)
|
||||||
|
if 'directory' in m: m['directory'] = normpath(m['directory'])
|
||||||
self.handler.message(m)
|
self.handler.message(m)
|
||||||
|
|
||||||
class AirtimeMessageReceiver(Loggable):
|
class AirtimeMessageReceiver(Loggable):
|
||||||
|
@ -119,6 +120,7 @@ class AirtimeMessageReceiver(Loggable):
|
||||||
% md_path, e)
|
% md_path, e)
|
||||||
|
|
||||||
def new_watch(self, msg):
|
def new_watch(self, msg):
|
||||||
|
msg['directory'] = normpath(msg['directory'])
|
||||||
self.logger.info("Creating watch for directory: '%s'" %
|
self.logger.info("Creating watch for directory: '%s'" %
|
||||||
msg['directory'])
|
msg['directory'])
|
||||||
if not os.path.exists(msg['directory']):
|
if not os.path.exists(msg['directory']):
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue