change hb id to bigint + fix time type?

Author: ImShyMike

rustytime/Cargo.lock

@@ -1,7 +1,7 @@
 [package]
 name = "rustytime-server"
 description = "🕒 blazingly fast time tracking for developers"
-version = "0.5.5"
+version = "0.5.6"
 edition = "2024"
 authors = ["ImShyMike"]
 readme = "../README.md"

rustytime/Cargo.toml

@@ -0,0 +1,14 @@
+-- Disable compression
+ALTER TABLE heartbeats SET (timescaledb.compress = false);
+
+-- Drop default
+ALTER TABLE heartbeats ALTER COLUMN id DROP DEFAULT;
+
+-- Revert to INTEGER
+ALTER TABLE heartbeats ALTER COLUMN id TYPE INTEGER;
+
+-- Drop sequence
+DROP SEQUENCE IF EXISTS heartbeats_id_seq;
+
+-- Re-enable compression
+ALTER TABLE heartbeats SET (timescaledb.compress = true);

rustytime/migrations/2025-10-10-204244_add_hb_id_to_bigserial/down.sql

@@ -0,0 +1,38 @@
+-- 0. Decompress all compressed chunks
+DO $$
+DECLARE
+    r RECORD;
+BEGIN
+    FOR r IN
+        SELECT
+            c.schema_name AS chunk_schema,
+            c.table_name  AS chunk_name
+        FROM _timescaledb_catalog.hypertable h
+        JOIN _timescaledb_catalog.chunk c ON c.hypertable_id = h.id
+        WHERE h.table_name = 'heartbeats'
+          AND c.compressed_chunk_id IS NOT NULL
+    LOOP
+        EXECUTE format('SELECT decompress_chunk(''%I.%I'')', r.chunk_schema, r.chunk_name);
+    END LOOP;
+END
+$$;
+
+-- 1. Disable compression temporarily
+ALTER TABLE heartbeats SET (timescaledb.compress = false);
+
+-- 2. Change column type from INTEGER -> BIGINT
+ALTER TABLE heartbeats ALTER COLUMN id TYPE BIGINT;
+
+-- 3. Ensure the sequence exists and is attached
+DO $$
+BEGIN
+    IF NOT EXISTS (SELECT 1 FROM pg_class WHERE relname = 'heartbeats_id_seq') THEN
+        CREATE SEQUENCE heartbeats_id_seq OWNED BY heartbeats.id;
+    END IF;
+END
+$$;
+
+ALTER TABLE heartbeats ALTER COLUMN id SET DEFAULT nextval('heartbeats_id_seq');
+
+-- 4. Re-enable compression
+ALTER TABLE heartbeats SET (timescaledb.compress = true);

rustytime/migrations/2025-10-10-204244_add_hb_id_to_bigserial/up.sql

@@ -4,7 +4,6 @@ use diesel::prelude::*;
 use diesel::sql_types::{BigInt, Date, Nullable, Text};
 use ipnetwork::IpNetwork;
 use serde::{Deserialize, Serialize};
-use serde_json::Value;
 
 use crate::schema::heartbeats;
 use crate::utils::http::parse_user_agent;
@@ -167,11 +166,11 @@ pub enum HeartbeatApiResponseVariant {
 
 #[derive(Serialize, Debug)]
 pub struct HeartbeatResponse {
-    pub id: String,
+    pub id: i64,
     pub entity: String,
     #[serde(rename = "type")]
     pub type_: String,
-    pub time: DateTime<Utc>,
+    pub time: i64,
 }
 
 #[derive(Serialize, Debug)]
@@ -191,7 +190,7 @@ pub struct BulkResponseItem(pub HeartbeatResponse, pub u16);
 #[diesel(table_name = heartbeats)]
 #[diesel(check_for_backend(diesel::pg::Pg))]
 pub struct Heartbeat {
-    pub id: i32,
+    pub id: i64,
     pub time: DateTime<Utc>,
     pub created_at: DateTime<Utc>,
     pub user_id: i32,
@@ -431,13 +430,19 @@ impl NewHeartbeat {
         sanitized.into_new_heartbeat(user_id, ip_address, headers)
     }
 }
+
 impl From<Heartbeat> for HeartbeatResponse {
     fn from(heartbeat: Heartbeat) -> Self {
+        let time = heartbeat
+            .time
+            .timestamp_nanos_opt()
+            .unwrap_or_else(|| heartbeat.time.timestamp() * 1_000_000_000);
+
         Self {
-            id: heartbeat.id.to_string(),
+            id: heartbeat.id,
             entity: heartbeat.entity,
             type_: heartbeat.type_,
-            time: heartbeat.time,
+            time,
         }
     }
 }

rustytime/src/models/heartbeat.rs

@@ -2,7 +2,7 @@
 
 diesel::table! {
     heartbeats (user_id, time) {
-        id -> Int4,
+        id -> Int8,
         time -> Timestamptz,
         created_at -> Timestamptz,
         user_id -> Int4,