vrr/ruvector
2
0
Fork 0
mirror of https://github.com/ruvnet/RuVector.git synced 2026-05-22 19:56:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 15

fix: Fix postgres feature compilation errors

Browse source 
- Convert serde_json::Value to string for ToSql in remember()
- Parse metadata string back to JSON in recall()
- Pass get_intelligence_path() to Intelligence::new()
- Make get_intelligence_path() public for cross-module access
This commit is contained in:
Claude 2025-12-29 00:47:48 +00:00
parent 896288f327
commit bb3bf8b512
2 changed files with 16 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

2
crates/ruvector-cli/src/cli/hooks.rs
View file

@ -1003,7 +1003,7 @@ impl Intelligence {
// === Command Implementations ===
/// Get intelligence data path (cross-platform)
fn get_intelligence_path() -> PathBuf {
pub fn get_intelligence_path() -> PathBuf {
// Try HOME (Unix) then USERPROFILE (Windows) then HOMEPATH (Windows fallback)
let home = std::env::var("HOME")
.or_else(|_| std::env::var("USERPROFILE"))

26
crates/ruvector-cli/src/cli/hooks_postgres.rs
View file

@ -147,10 +147,11 @@ impl PostgresStorage {
metadata: &serde_json::Value,
) -> Result<i32, Box<dyn std::error::Error>> {
let client = self.pool.get().await?;
let metadata_str = serde_json::to_string(metadata)?;
let row = client
.query_one(
"SELECT ruvector_hooks_remember($1, $2, $3, $4)",
&[&memory_type, &content, &embedding, &metadata],
"SELECT ruvector_hooks_remember($1, $2, $3, $4::jsonb)",
&[&memory_type, &content, &embedding, &metadata_str],
)
.await?;
@ -166,7 +167,7 @@ impl PostgresStorage {
let client = self.pool.get().await?;
let rows = client
.query(
"SELECT id, memory_type, content, metadata, similarity
"SELECT id, memory_type, content, metadata::text, similarity
FROM ruvector_hooks_recall($1, $2)",
&[&query_embedding, &limit],
)
@ -174,12 +175,15 @@ impl PostgresStorage {
Ok(rows
.iter()
.map(|r| MemoryResult {
id: r.get(0),
memory_type: r.get(1),
content: r.get(2),
metadata: r.get(3),
similarity: r.get(4),
.map(|r| {
let metadata_str: String = r.get(3);
MemoryResult {
id: r.get(0),
memory_type: r.get(1),
content: r.get(2),
metadata: serde_json::from_str(&metadata_str).unwrap_or_default(),
similarity: r.get(4),
}
})
.collect())
}
@ -362,12 +366,12 @@ impl StorageBackend {
}
}
}
Ok(Self::Json(super::Intelligence::new()))
Ok(Self::Json(super::Intelligence::new(super::get_intelligence_path())))
}
#[cfg(not(feature = "postgres"))]
pub fn from_env() -> Self {
Self::Json(super::Intelligence::new())
Self::Json(super::Intelligence::new(super::get_intelligence_path()))
}
}