Add opRetro projectId to DiscoveryEngine

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" }

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(())
     }

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<dyn Discovery>
         });