Add pipe api to tjnetwork

api/s5_pipes.py

@@ -40,12 +40,12 @@ def delete_pipe(name: str, id: str) -> ChangeSet:
     return delete_link(name, PIPE, id, sql, undo_sql)
 
 
-def get_pipe_ndoe1(name: str, id: str) -> str | None:
+def get_pipe_node1(name: str, id: str) -> str | None:
     row = _get_pipe(name, id)
     return float(row['node1']) if row != None else None
 
 
-def get_pipe_ndoe2(name: str, id: str) -> str | None:
+def get_pipe_node2(name: str, id: str) -> str | None:
     row = _get_pipe(name, id)
     return float(row['node2']) if row != None else None
 
@@ -86,6 +86,20 @@ def _set_pipe(name: str, id: str, key: str, key_type: str, value: str, optional:
     return utility.update(name, PIPE, 'pipes', 'id', id, key, key_type, row[key], value, optional)
 
 
+def set_pipe_node1(name: str, id: str, node1: str) -> ChangeSet:
+    if not is_node(name, node1):
+        return
+
+    return _set_pipe(name, id, 'node1', 'str', str(node1))
+
+
+def set_pipe_node2(name: str, id: str, node2: str) -> ChangeSet:
+    if not is_node(name, node2):
+        return
+
+    return _set_pipe(name, id, 'node2', 'str', str(node2))
+
+
 def set_pipe_length(name: str, id: str, length: float) -> ChangeSet:
     return _set_pipe(name, id, 'length', 'float', str(length))