feat(commands): add custom label trend report

CHANGELOG.md

@@ -1,4 +1,5 @@
 # Unreleased
+- add custom label trend report
 - Add `get keyed sync states`
 - Add `delete keyed sync states`
 

api/src/lib.rs

@@ -21,9 +21,9 @@ use resources::{
     bucket_statistics::GetBucketStatisticsResponse,
     comment::{AttachmentReference, CommentTimestampFilter},
     dataset::{
-        QueryRequestParams, QueryResponse,
-        StatisticsRequestParams as DatasetStatisticsRequestParams, SummaryRequestParams,
-        SummaryResponse,
+        GetAllModelsInDatasetRequest, GetAllModelsInDatasetRespone, QueryRequestParams,
+        QueryResponse, StatisticsRequestParams as DatasetStatisticsRequestParams,
+        SummaryRequestParams, SummaryResponse, UserModelMetadata,
     },
     documents::{Document, SyncRawEmailsRequest, SyncRawEmailsResponse},
     email::{Email, GetEmailResponse},
@@ -106,11 +106,13 @@ pub use crate::{
             Identifier as BucketIdentifier, Name as BucketName, NewBucket,
         },
         comment::{
-            AnnotatedComment, Comment, CommentFilter, CommentsIterPage, Continuation,
-            EitherLabelling, Entities, Entity, HasAnnotations, Id as CommentId, Label, Labelling,
+            AnnotatedComment, Comment, CommentFilter, CommentPredictionsThreshold,
+            CommentsIterPage, Continuation, EitherLabelling, Entities, Entity,
+            GetCommentPredictionsRequest, HasAnnotations, Id as CommentId, Label, Labelling,
             Message, MessageBody, MessageSignature, MessageSubject, NewAnnotatedComment,
             NewComment, NewEntities, NewLabelling, NewMoonForm, PredictedLabel, Prediction,
-            PropertyMap, PropertyValue, Sentiment, SyncCommentsResponse, Uid as CommentUid,
+            PropertyMap, PropertyValue, Sentiment, SyncCommentsResponse, TriggerLabelThreshold,
+            Uid as CommentUid,
         },
         dataset::{
             Dataset, FullName as DatasetFullName, Id as DatasetId, Identifier as DatasetIdentifier,
@@ -623,6 +625,16 @@ impl Client {
         self.get::<_, ValidationResponse>(self.endpoints.validation(dataset_name, model_version)?)
     }
 
+    pub fn get_labellers(&self, dataset_name: &DatasetFullName) -> Result<Vec<UserModelMetadata>> {
+        Ok(self
+            .post::<_, _, GetAllModelsInDatasetRespone>(
+                self.endpoints.labellers(dataset_name)?,
+                GetAllModelsInDatasetRequest {},
+                Retry::Yes,
+            )?
+            .labellers)
+    }
+
     pub fn get_label_validation(
         &self,
         label: &LabelName,
@@ -967,15 +979,22 @@ impl Client {
         dataset_name: &DatasetFullName,
         model_version: &ModelVersion,
         comment_uids: impl Iterator<Item = &'a CommentUid>,
+        threshold: Option<CommentPredictionsThreshold>,
+        labels: Option<Vec<TriggerLabelThreshold>>,
     ) -> Result<Vec<Prediction>> {
         Ok(self
             .post::<_, _, GetPredictionsResponse>(
                 self.endpoints
                     .get_comment_predictions(dataset_name, model_version)?,
-                json!({
-                    "threshold": "auto",
-                    "uids": comment_uids.into_iter().map(|id| id.0.as_str()).collect::<Vec<_>>(),
-                }),
+                GetCommentPredictionsRequest {
+                    uids: comment_uids
+                        .into_iter()
+                        .map(|id| id.0.clone())
+                        .collect::<Vec<_>>(),
+
+                    threshold,
+                    labels,
+                },
                 Retry::Yes,
             )?
             .predictions)
@@ -2131,6 +2150,13 @@ impl Endpoints {
         )
     }
 
+    fn labellers(&self, dataset_name: &DatasetFullName) -> Result<Url> {
+        construct_endpoint(
+            &self.base,
+            &["api", "_private", "datasets", &dataset_name.0, "labellers"],
+        )
+    }
+
     fn get_comment_predictions(
         &self,
         dataset_name: &DatasetFullName,

api/src/resources/comment.rs

@@ -70,14 +70,18 @@ type UserPropertyName = String;
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub struct UserPropertiesFilter(pub HashMap<UserPropertyName, PropertyFilter>);
 
-#[derive(Debug, Clone, Serialize, Deserialize)]
+#[derive(Default, Debug, Clone, Serialize, Deserialize)]
 pub struct PropertyFilter {
-    #[serde(skip_serializing_if = "<[_]>::is_empty", default)]
+    #[serde(skip_serializing_if = "<[_]>::is_empty")]
     pub one_of: Vec<PropertyValue>,
-    #[serde(skip_serializing_if = "<[_]>::is_empty", default)]
+    #[serde(skip_serializing_if = "<[_]>::is_empty")]
     pub not_one_of: Vec<PropertyValue>,
-    #[serde(skip_serializing_if = "<[_]>::is_empty", default)]
+    #[serde(skip_serializing_if = "<[_]>::is_empty")]
     pub domain_not_one_of: Vec<PropertyValue>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub minimum: Option<NotNan<f64>>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub maximum: Option<NotNan<f64>>,
 }
 
 impl PropertyFilter {
@@ -90,6 +94,7 @@ impl PropertyFilter {
             one_of,
             not_one_of,
             domain_not_one_of,
+            ..Default::default()
         }
     }
 }
@@ -122,6 +127,27 @@ pub struct MessagesFilter {
     pub to: Option<PropertyFilter>,
 }
 
+#[derive(Debug, Clone, Serialize)]
+#[serde(rename_all(serialize = "lowercase"))]
+pub enum CommentPredictionsThreshold {
+    Auto,
+}
+
+#[derive(Debug, Clone, Serialize)]
+pub struct TriggerLabelThreshold {
+    pub name: Vec<String>,
+    pub threshold: NotNan<f64>,
+}
+
+#[derive(Debug, Clone, Serialize)]
+pub struct GetCommentPredictionsRequest {
+    pub uids: Vec<String>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub threshold: Option<CommentPredictionsThreshold>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub labels: Option<Vec<TriggerLabelThreshold>>,
+}
+
 #[derive(Debug, Clone, Serialize)]
 pub(crate) struct GetRecentRequest<'a> {
     pub limit: usize,
@@ -488,7 +514,7 @@ pub struct AnnotatedComment {
 pub struct Prediction {
     pub uid: Uid,
     #[serde(skip_serializing_if = "should_skip_serializing_optional_vec")]
-    pub labels: Option<Vec<AutoThresholdLabel>>,
+    pub labels: Option<Vec<PredictedLabel>>,
     #[serde(skip_serializing_if = "should_skip_serializing_optional_vec")]
     pub entities: Option<Vec<Entity>>,
 }
@@ -683,13 +709,22 @@ pub struct Label {
     pub metadata: Option<HashMap<String, JsonValue>>,
 }
 
-#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
+#[derive(Debug, Hash, Clone, Deserialize, Serialize, PartialEq, Eq)]
 #[serde(untagged)]
 pub enum PredictedLabelName {
     Parts(Vec<String>),
     String(LabelName),
 }
 
+impl PredictedLabelName {
+    pub fn to_label_name(&self) -> LabelName {
+        match self {
+            Self::Parts(parts) => LabelName(parts.join(" > ")),
+            Self::String(string) => string.clone(),
+        }
+    }
+}
+
 #[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
 pub struct PredictedLabel {
     pub name: PredictedLabelName,
@@ -700,13 +735,6 @@ pub struct PredictedLabel {
     pub auto_thresholds: Option<Vec<String>>,
 }
 
-#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
-pub struct AutoThresholdLabel {
-    pub name: Vec<String>,
-    pub probability: NotNan<f64>,
-    pub auto_thresholds: Vec<String>,
-}
-
 #[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
 pub struct LabelProperty {
     pub id: String,

api/src/resources/dataset.rs

@@ -110,6 +110,19 @@ pub struct AttributeFilter {
     pub filter: AttributeFilterEnum,
 }
 
+#[derive(Debug, Clone, Serialize, Default)]
+pub struct GetAllModelsInDatasetRequest {}
+
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct UserModelMetadata {
+    pub version: ModelVersion,
+}
+
+#[derive(Debug, Clone, Deserialize, Serialize, Default)]
+pub struct GetAllModelsInDatasetRespone {
+    pub labellers: Vec<UserModelMetadata>,
+}
+
 #[derive(Debug, Clone, Serialize, Default)]
 pub struct StatisticsRequestParams {
     #[serde(skip_serializing_if = "<[_]>::is_empty")]
@@ -133,15 +146,21 @@ pub enum OrderEnum {
     Sample { seed: usize },
 }
 
-#[derive(Debug, Clone, Serialize)]
+impl Default for OrderEnum {
+    fn default() -> Self {
+        Self::Recent
+    }
+}
+
+#[derive(Debug, Clone, Serialize, Default)]
 pub struct SummaryRequestParams {
     #[serde(skip_serializing_if = "<[_]>::is_empty")]
     pub attribute_filters: Vec<AttributeFilter>,
 
     pub filter: CommentFilter,
 }
 
-#[derive(Debug, Clone, Serialize)]
+#[derive(Debug, Default, Clone, Serialize)]
 pub struct QueryRequestParams {
     #[serde(skip_serializing_if = "<[_]>::is_empty")]
     pub attribute_filters: Vec<AttributeFilter>,
@@ -157,14 +176,25 @@ pub struct QueryRequestParams {
 }
 
 #[derive(Debug, Clone, Deserialize, Serialize)]
-pub struct UserPropertySummary {
+pub struct UserPropertySummaryValue {
+    pub value: String,
+}
+
+#[derive(Debug, Clone, Deserialize, Serialize)]
+pub struct UserPropertySummaryString {
+    pub full_name: String,
+    pub values: Vec<UserPropertySummaryValue>,
+}
+
+#[derive(Debug, Clone, Deserialize, Serialize)]
+pub struct UserPropertySummaryNumber {
     pub full_name: String,
 }
 
 #[derive(Debug, Clone, Deserialize, Serialize)]
 pub struct UserPropertySummaryList {
-    pub string: Vec<UserPropertySummary>,
-    pub number: Vec<UserPropertySummary>,
+    pub string: Vec<UserPropertySummaryString>,
+    pub number: Vec<UserPropertySummaryNumber>,
 }
 
 #[derive(Debug, Clone, Deserialize, Serialize)]

cli/Cargo.toml

@@ -35,7 +35,7 @@ structopt = { version = "0.3.26", default-features = false }
 url = { version = "2.3.1", features = ["serde"] }
 
 reinfer-client = { version = "0.30.1", path = "../api" }
-dialoguer = "0.10.4"
+dialoguer = { version="0.11.0", features = ["fuzzy-select"] }
 scoped_threadpool = "0.1.9"
 backoff = "0.4.0"
 cfb = "0.9.0"
@@ -44,6 +44,7 @@ ordered-float = { version = "3.9.1", features = ["serde"] }
 mailparse = "0.14.0"
 diff = "0.1.13"
 rand = "0.8.5"
+csv = "1.3.0"
 
 [dev-dependencies]
 pretty_assertions = "1.3.0"