replace assert by if <condition>: raise SomeException

Signed-off-by: Nish_ <120EE0980@nitrkl.ac.in>

Author: 120EE0980

src/borg/hashindex.pyx

@@ -80,7 +80,8 @@ class ChunkIndex(HTProxyMixin, MutableMapping):
             flags = self.F_USED
         else:
             flags = v.flags | self.F_USED
-            assert v.size == 0 or v.size == size
+            if v.size != 0 and v.size != size:
+                raise ValueError(f"Invalid size: expected 0 or {size}, got {v.size}")
         self[key] = ChunkIndexEntry(
             flags=flags, size=size, pack_id=UNKNOWN_BYTES32, obj_offset=UNKNOWN_INT32, obj_size=UNKNOWN_INT32
         )

src/borg/legacy/hashindex.py

@@ -88,8 +88,10 @@ def _read_fd(self, fd):
         magic, entries, buckets, ksize, vsize = struct.unpack(self.HEADER_FMT, header_bytes)
         if magic != self.MAGIC:
             raise ValueError(f"Invalid file: magic {self.MAGIC.decode()} not found.")
-        assert ksize == self.KEY_SIZE, "invalid key size"
-        assert vsize == self.VALUE_SIZE, "invalid value size"
+        if ksize != self.KEY_SIZE:
+            raise ValueError("Invalid key size")
+        if vsize != self.VALUE_SIZE:
+            raise ValueError("Invalid value size")
         buckets_size = buckets * (ksize + vsize)
         current_pos = fd.tell()
         end_of_file = fd.seek(0, os.SEEK_END)
@@ -105,4 +107,5 @@ def _read_fd(self, fd):
                 continue
             self.ht._set_raw(key, value)
         pos = fd.tell()
-        assert pos == end_of_file
+        if pos != end_of_file:
+            raise ValueError(f"Expected pos ({pos}) to be at end_of_file ({end_of_file})")

src/borg/platform/posix.pyx

@@ -20,10 +20,14 @@ def process_alive(host, pid, thread):
     from . import local_pid_alive
     from . import hostid
 
-    assert isinstance(host, str)
-    assert isinstance(hostid, str)
-    assert isinstance(pid, int)
-    assert isinstance(thread, int)
+    if not isinstance(host, str):
+        raise TypeError("host must be a string")
+    if not isinstance(hostid, str):
+        raise TypeError("hostid must be a string")
+    if not isinstance(pid, int):
+        raise TypeError("pid must be an integer")
+    if not isinstance(thread, int):
+        raise TypeError("thread must be an integer")
 
     if host != hostid:
         return True
@@ -55,7 +59,8 @@ def local_pid_alive(pid):
 
 def posix_acl_use_stored_uid_gid(acl):
     """Replace the user/group field with the stored uid/gid."""
-    assert isinstance(acl, bytes)
+    if not isinstance(acl, bytes):
+        raise TypeError("acl must be of type bytes")
     from ..helpers import safe_decode, safe_encode
     entries = []
     for entry in safe_decode(acl).split('\n'):

src/borg/testsuite/hashindex_test.py

@@ -32,7 +32,7 @@ def test_chunkindex_add():
     assert chunks[x] == ChunkIndexEntry(
         flags=ChunkIndex.F_USED, size=2, pack_id=UNKNOWN_BYTES32, obj_offset=UNKNOWN_INT32, obj_size=UNKNOWN_INT32
     )
-    with pytest.raises(AssertionError):
+    with pytest.raises(ValueError):
         chunks.add(x, 3)  # inconsistent size (we already have a different size)