Method put_scoped

crates/openshell-server/src/persistence/postgres.rs:244–282

(
        &self,
        object_type: &str,
        id: &str,
        name: &str,
        scope: &str,
        payload: &[u8],
        labels: Option<&str>,
    )

    }

    pub async fn put_scoped(
        &self,
        object_type: &str,
        id: &str,
        name: &str,
        scope: &str,
        payload: &[u8],
        labels: Option<&str>,
    ) -> PersistenceResult<()> {
        let now_ms = current_time_ms();
        let labels_jsonb: Option<serde_json::Value> = labels
            .map(serde_json::from_str)
            .transpose()
            .map_err(|e| PersistenceError::Encode(format!("invalid labels JSON: {e}")))?;

        sqlx::query(
            r"
INSERT INTO objects (object_type, id, name, scope, payload, created_at_ms, updated_at_ms, labels, resource_version)
VALUES ($1, $2, $3, $4, $5, $6, $6, COALESCE($7, '{}'::jsonb), 1)
ON CONFLICT (object_type, name) WHERE name IS NOT NULL DO UPDATE SET
    scope = EXCLUDED.scope,
    payload = EXCLUDED.payload,
    updated_at_ms = EXCLUDED.updated_at_ms,
    labels = EXCLUDED.labels,
    resource_version = objects.resource_version + 1
",
        )
        .bind(object_type)
        .bind(id)
        .bind(name)
        .bind(scope)
        .bind(payload)
        .bind(now_ms)
        .bind(labels_jsonb)
        .execute(&self.pool)
        .await
        .map_err(|e| map_db_error(&e))?;
        Ok(())
    }

    pub async fn get(
        &self,