fix: fix count_published_by_gid

Cargo.toml

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

cmd/sync-to-publication-index/src/main.rs

@@ -10,7 +10,9 @@ async fn main() -> anyhow::Result<()> {
         .with_target_writer("*", new_writer(io::stdout()))
         .init();
 
-    let nodes = std::env::var("SCYLLA_NODES").unwrap_or_else(|_| "127.0.0.1:9042".into());
+    let nodes = std::env::var("SCYLLA_NODES").expect(
+        "env SCYLLA_NODES required:\nSCYLLA_NODES=127.0.0.1:9042 ./sync-to-publication-index",
+    );
 
     let cfg = conf::ScyllaDB {
         nodes: nodes.split(',').map(|s| s.to_string()).collect(),

src/db/model_publication.rs

@@ -1,7 +1,7 @@
 use isolang::Language;
 use std::{collections::HashSet, convert::From};
 
-use scylla_orm::{ColumnsMap, CqlValue, ToCqlVal};
+use scylla_orm::{ColumnsMap, CqlValue, FromCqlVal, ToCqlVal};
 use scylla_orm_macros::CqlOrm;
 
 use crate::db::{
@@ -268,10 +268,20 @@ impl PublicationIndex {
             return Ok(0);
         }
 
-        let query = "SELECT cid FROM pub_index WHERE gid=? GROUP BY cid USING TIMEOUT 3s";
+        let query = "SELECT cid FROM pub_index WHERE gid=? GROUP BY day, cid USING TIMEOUT 3s";
         let params = (gid.to_cql(),);
         let rows = db.execute_iter(query, params).await?;
-        Ok(rows.len())
+        let mut cids: HashSet<xid::Id> = HashSet::new();
+        for row in rows {
+            if let Some(v) = row.columns.first() {
+                if let Some(v) = v {
+                    let cid = xid::Id::from_cql(v)?;
+                    cids.insert(cid);
+                }
+            }
+        }
+
+        Ok(cids.len())
     }
 }