GET /v5/campaign/list

primitives/src/sentry.rs

@@ -351,6 +351,9 @@ pub mod campaign {
         pub creator: Option<Address>,
         /// filters the campaigns containing a specific validator if provided
         pub validator: Option<ValidatorId>,
+        /// filters the campaigns where the provided validator is a leader if true
+        /// or if a validator isn't provided but an Auth.uid is provided (i.e. there is a auth header with token)
+        pub is_leader: Option<bool>,
     }
 }
 

sentry/src/db.rs

@@ -1,7 +1,10 @@
 use deadpool_postgres::{Manager, ManagerConfig, RecyclingMethod};
 use redis::aio::MultiplexedConnection;
-use std::env;
-use tokio_postgres::NoTls;
+use std::{env, str::FromStr};
+use tokio_postgres::{
+    types::{accepts, FromSql, Type},
+    NoTls,
+};
 
 use lazy_static::lazy_static;
 
@@ -53,6 +56,21 @@ lazy_static! {
     };
 }
 
+pub struct TotalCount(pub u64);
+impl<'a> FromSql<'a> for TotalCount {
+    fn from_sql(
+        ty: &Type,
+        raw: &'a [u8],
+    ) -> Result<Self, Box<dyn std::error::Error + Sync + Send>> {
+        let str_slice = <&str as FromSql>::from_sql(ty, raw)?;
+
+        Ok(Self(u64::from_str(str_slice)?))
+    }
+
+    // Use a varchar or text, since otherwise `int8` fails deserialization
+    accepts!(VARCHAR, TEXT);
+}
+
 pub async fn redis_connection(url: &str) -> Result<MultiplexedConnection, RedisError> {
     let client = redis::Client::open(url)?;