fix: fix subscription's expire_at

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "writing"
-version = "1.3.4"
+version = "1.3.5"
 edition = "2021"
 rust-version = "1.64"
 description = ""

cql/schema_table.cql

@@ -151,7 +151,7 @@ CREATE TABLE IF NOT EXISTS collection_subscription (
     cid        BLOB,   -- collection id, 12 bytes XID
     txn        BLOB,   -- latest subscription transaction id, 12 bytes XID
     updated_at BIGINT, -- updated at, unix time, ms
-    expire_at  BIGINT, -- subscription expire at, unix time, ms
+    expire_at  BIGINT, -- subscription expire at, unix time, second!!
     PRIMARY KEY (uid, cid)
 ) WITH CLUSTERING ORDER BY (cid DESC)
     AND caching = {'enabled': 'true'}
@@ -167,7 +167,7 @@ CREATE TABLE IF NOT EXISTS creation_subscription (
     cid        BLOB,   -- creation id, 12 bytes XID
     txn        BLOB,   -- latest subscription transaction id, 12 bytes XID
     updated_at BIGINT, -- updated at, unix time, ms
-    expire_at  BIGINT, -- subscription expire at, unix time, ms
+    expire_at  BIGINT, -- subscription expire at, unix time, second!!
     PRIMARY KEY (uid, cid)
 ) WITH CLUSTERING ORDER BY (cid DESC)
     AND caching = {'enabled': 'true'}

src/api/collection.rs

@@ -309,7 +309,7 @@ pub async fn get(
                 }
             }
             Some(ref sub) => {
-                if sub.expire_at < ctx.unix_ms as i64 {
+                if sub.expire_at * 1000 < ctx.unix_ms as i64 {
                     output.rfp = Some(RFP {
                         creation: None,
                         collection: Some(price),
@@ -1095,7 +1095,7 @@ pub async fn list_by_child(
             let mut output = CollectionOutput::from(doc, &to);
             match subscription {
                 Some(s) => {
-                    if s.expire_at < ctx.unix_ms as i64 {
+                    if s.expire_at * 1000 < ctx.unix_ms as i64 {
                         output.rfp = Some(RFP {
                             creation: None,
                             collection: Some(price),

src/api/publication.rs

@@ -419,7 +419,8 @@ async fn try_get_subscription(
     }
 
     let mut subscription = db::CreationSubscription::with_pk(uid, creation.id);
-    if subscription.get_one(scylla, vec![]).await.is_ok() && subscription.expire_at >= now_ms {
+    if subscription.get_one(scylla, vec![]).await.is_ok() && subscription.expire_at * 1000 >= now_ms
+    {
         return (None, Some(subscription));
     }
 
@@ -451,7 +452,7 @@ async fn try_get_subscription(
             .get_one(scylla, vec!["expire_at".to_string()])
             .await
             .is_ok()
-            && doc.expire_at >= now_ms
+            && doc.expire_at * 1000 >= now_ms
         {
             return (None, subscription);
         }