Skip to content
Snippets Groups Projects

Remove truncate and add on conflict clause instead

Merged Jonah Husson requested to merge hotfix/remove-truncate into master
Compare and Show latest version
1 file
+ 9
6
Compare changes
  • Side-by-side
  • Inline
+ 9
6
@@ -225,16 +225,19 @@ def get_substrate_provider():
@@ -225,16 +225,19 @@ def get_substrate_provider():
def revoke_auth(to_revoke):
def revoke_auth(to_revoke):
"""
"""
revoke_auth accepts a list of node IDs to revoke auth from
revoke_auth accepts a list of node IP addresses to revoke auth from
:param to_revoke: list of node IDs
:param to_revoke: list of node IP addresses
"""
"""
 
log.info(f"Revoking access to {len(to_revoke)} nodes...")
for nid in to_revoke:
for nid in to_revoke:
cmd = f"sudo nft -a list chain inet filter input | grep '{nid}' | awk -F'handle ' '{{print $2}}' | xargs -Ixxx sudo nft delete rule inet filter input handle xxx"
cmd = f"sudo nft -a list chain inet filter input | grep '{nid}' | awk -F'handle ' '{{print $2}}' | xargs -Ixxx sudo nft delete rule inet filter input handle xxx"
 
log.debug(cmd)
p = subprocess.Popen(cmd.split())
p = subprocess.Popen(cmd.split())
output, error = p.communicate()
output, error = p.communicate()
log.debug(output)
if output:
 
log.debug(output)
if error:
if error:
log.error(error)
raise IOError(error)
def id_to_reg_code(cmix_id):
def id_to_reg_code(cmix_id):
@@ -707,7 +710,7 @@ def set_authorizer_nodes(conn, to_add, to_delete):
@@ -707,7 +710,7 @@ def set_authorizer_nodes(conn, to_add, to_delete):
node_list = get_authorizer_nodes(conn)
node_list = get_authorizer_nodes(conn)
to_revoke = []
to_revoke = []
delete_command = "DELETE FROM nodes WHERE id = ?;"
delete_command = "DELETE FROM nodes WHERE id = %s;"
for row in node_list:
for row in node_list:
if row[0] in to_delete:
if row[0] in to_delete:
try:
try:
@@ -716,7 +719,7 @@ def set_authorizer_nodes(conn, to_add, to_delete):
@@ -716,7 +719,7 @@ def set_authorizer_nodes(conn, to_add, to_delete):
except Exception as e:
except Exception as e:
log.error(f"Failed to remove node from authorizer DB: {cur.query}")
log.error(f"Failed to remove node from authorizer DB: {cur.query}")
raise e
raise e
to_revoke.append(row[1])
to_revoke.append(row[1])
insert_list = [(i, None, None) for i in to_add]
insert_list = [(i, None, None) for i in to_add]
# Insert Node information into authorizer db
# Insert Node information into authorizer db
Loading