Use BIGINT for in_bytes to avoid overflows

Author: grafolean

dbutils.py

@@ -154,3 +154,8 @@ def migration_step_2():
 def migration_step_3():
     with get_db_cursor() as c:
         c.execute(f'CREATE TABLE {DB_PREFIX}exporters (ip INET NOT NULL PRIMARY KEY);')
+
+def migration_step_4():
+    with get_db_cursor() as c:
+        # INTEGER (signed 32 bits) is not enough for in_bytes:
+        c.execute(f"ALTER TABLE {DB_PREFIX}flows ALTER COLUMN in_bytes SET DATA TYPE BIGINT;")

netflowwriter.py

@@ -57,7 +57,7 @@ def _pgwriter_write(pgwriter, ts, client_ip, IN_BYTES, PROTOCOL, DIRECTION, L4_D
         11,  # number of columns
         4, int(ts),                       # integer - beware of Y2038 problem! :)
         8, IPV4_PREFIX, socket.inet_aton(client_ip),   # 4 bytes prefix + 4 bytes IP
-        4, IN_BYTES,                      # integer
+        8, IN_BYTES,                      # bigint
         2, PROTOCOL,
         2, DIRECTION,
         4, L4_DST_PORT,