Return len

crates/pile-client/Cargo.toml

@@ -8,6 +8,8 @@ edition = { workspace = true }
 workspace = true
 
 [dependencies]
+pile-dataset = { workspace = true }
+
 reqwest = { version = "0.12", features = ["json", "stream"] }
 futures-core = "0.3"
 serde = { workspace = true }

crates/pile-client/src/lib.rs

@@ -5,14 +5,12 @@ use axum::{
 use bytes::Bytes;
 use futures_core::Stream;
 use reqwest::{Client, StatusCode, header};
-use serde::{Deserialize, Serialize};
+use serde::Deserialize;
 use std::pin::Pin;
 use thiserror::Error;
 use tracing::{trace, warn};
 
-//
-// MARK: Error
-//
+pub use pile_dataset::serve::{ItemsResponse, LookupRequest, LookupResponse};
 
 #[derive(Debug, Error)]
 pub enum ClientError {
@@ -26,48 +24,11 @@ pub enum ClientError {
 	Reqwest(#[from] reqwest::Error),
 }
 
-//
-// MARK: Response types
-//
-
 #[derive(Debug, Deserialize)]
 pub struct DatasetInfo {
 	pub name: String,
 }
 
-#[derive(Debug, Serialize)]
-pub struct LookupRequest {
-	pub query: String,
-	#[serde(skip_serializing_if = "Option::is_none")]
-	pub limit: Option<usize>,
-}
-
-#[derive(Debug, Deserialize)]
-pub struct LookupResult {
-	pub score: f32,
-	pub source: String,
-	pub key: String,
-}
-
-#[derive(Debug, Deserialize)]
-pub struct LookupResponse {
-	pub results: Vec<LookupResult>,
-}
-
-#[derive(Debug, Deserialize)]
-pub struct ItemRef {
-	pub source: String,
-	pub key: String,
-}
-
-#[derive(Debug, Deserialize)]
-pub struct ItemsResponse {
-	pub items: Vec<ItemRef>,
-	pub total: usize,
-	pub offset: usize,
-	pub limit: usize,
-}
-
 /// Raw field response: the content-type and body bytes as returned by the server.
 pub struct FieldResponse {
 	pub content_type: String,