|
2 | 2 |
|
3 | 3 | import click
|
4 | 4 | import json
|
| 5 | +import syslog |
5 | 6 | import tabulate
|
6 | 7 | from natsort import natsorted
|
7 | 8 |
|
|
13 | 14 |
|
14 | 15 | def info(msg):
|
15 | 16 | click.echo(click.style("Info: ", fg='cyan') + click.style(str(msg), fg='green'))
|
| 17 | + syslog.syslog(syslog.LOG_INFO, msg) |
16 | 18 |
|
17 | 19 |
|
18 | 20 | def warning(msg):
|
19 | 21 | click.echo(click.style("Warning: ", fg='cyan') + click.style(str(msg), fg='yellow'))
|
| 22 | + syslog.syslog(syslog.LOG_WARNING, msg) |
20 | 23 |
|
21 | 24 |
|
22 | 25 | def error(msg):
|
23 | 26 | click.echo(click.style("Error: ", fg='cyan') + click.style(str(msg), fg='red'))
|
| 27 | + syslog.syslog(syslog.LOG_ERR, msg) |
24 | 28 |
|
25 | 29 |
|
26 | 30 | def deep_update(dst, src):
|
@@ -354,8 +358,11 @@ def convert_rules(self):
|
354 | 358 |
|
355 | 359 | for acl_entry_name in acl_set.acl_entries.acl_entry:
|
356 | 360 | acl_entry = acl_set.acl_entries.acl_entry[acl_entry_name]
|
357 |
| - rule = self.convert_rule_to_db_schema(table_name, acl_entry) |
358 |
| - deep_update(self.rules_info, rule) |
| 361 | + try: |
| 362 | + rule = self.convert_rule_to_db_schema(table_name, acl_entry) |
| 363 | + deep_update(self.rules_info, rule) |
| 364 | + except AclLoaderException as ex: |
| 365 | + error("Error processing rule %s: %s. Skipped." % (acl_entry_name, ex)) |
359 | 366 |
|
360 | 367 | if not self.is_table_mirror(table_name):
|
361 | 368 | deep_update(self.rules_info, self.deny_rule(table_name))
|
|
0 commit comments