From cc9274a62b2def5fe6b86ceea31989a33e89db20 Mon Sep 17 00:00:00 2001 From: Nichole Christie Date: Thu, 20 Mar 2025 21:15:50 -0500 Subject: [PATCH 1/2] Add opRetro projectId to DiscoveryEngine --- For more details, open the [Copilot Workspace session](https://copilot-workspace.githubnext.com/v3xlabs/enstate?shareId=XXXX-XXXX-XXXX-XXXX). --- packages/app/Cargo.toml | 3 +++ packages/app/src/discovery/engine.rs | 8 ++++++-- packages/app/src/state.rs | 2 +- 3 files changed, 10 insertions(+), 3 deletions(-) diff --git a/packages/app/Cargo.toml b/packages/app/Cargo.toml index 592a0ad..99b0319 100644 --- a/packages/app/Cargo.toml +++ b/packages/app/Cargo.toml @@ -75,3 +75,6 @@ prometheus = "0.13.4" time = "0.3.36" dashmap = "6.1.0" meilisearch-sdk = "0.28.0" + +[package.metadata] +opRetro = { projectId = "0xf5d1c16d0bfd76465fae78f66ddcb41356e4d2bf147df97682de7231e59cca59" } diff --git a/packages/app/src/discovery/engine.rs b/packages/app/src/discovery/engine.rs index 65c8d66..6a9bec4 100644 --- a/packages/app/src/discovery/engine.rs +++ b/packages/app/src/discovery/engine.rs @@ -10,6 +10,7 @@ use serde::{Deserialize, Serialize}; pub struct DiscoveryEngine { client: meilisearch_sdk::client::Client, + project_id: String, } #[derive(Debug, Serialize, Deserialize)] @@ -50,14 +51,17 @@ impl From<&Profile> for MeiliProfileDocument { } impl DiscoveryEngine { - pub fn new(url: &str, key: Option<&str>) -> Self { + pub fn new(url: &str, key: Option<&str>, project_id: String) -> Self { Self { client: meilisearch_sdk::client::Client::new(url, key).unwrap(), + project_id, } } pub async fn create_table_if_not_exists(&self) -> Result<(), ()> { - + // Use the project_id in the method + let index = self.client.index(&self.project_id); + let _ = index.create().await; Ok(()) } diff --git a/packages/app/src/state.rs b/packages/app/src/state.rs index 415efb0..c81487f 100644 --- a/packages/app/src/state.rs +++ b/packages/app/src/state.rs @@ -95,7 +95,7 @@ impl AppState { let meilisearch_key = env::var("MEILI_KEY").ok(); let discovery = meilisearch_url.map(|url| { - let engine = DiscoveryEngine::new(&url, meilisearch_key.as_deref()); + let engine = DiscoveryEngine::new(&url, meilisearch_key.as_deref(), "0xf5d1c16d0bfd76465fae78f66ddcb41356e4d2bf147df97682de7231e59cca59".to_string()); Box::new(engine) as Box }); From 4590704f08a99e21ed5536cd6eaecc5968592d53 Mon Sep 17 00:00:00 2001 From: Nichole Christie Date: Thu, 20 Mar 2025 21:29:36 -0500 Subject: [PATCH 2/2] Add `opRetro` projectId to `DiscoveryEngine` and `AppState` * Add `opRetro` projectId to the `[package.metadata]` section in `packages/app/Cargo.toml` * Add `opRetro` projectId to the `DiscoveryEngine` struct in `packages/app/src/discovery/engine.rs` * Update the `DiscoveryEngine::new` method to accept `opRetro` projectId * Update the `DiscoveryEngine::create_table_if_not_exists` method to use `opRetro` projectId * Add `opRetro` projectId to the `AppState::new` method in `packages/app/src/state.rs` * Update the `DiscoveryEngine` initialization to include `opRetro` projectId