Method put_if

crates/openshell-server/src/persistence/postgres.rs:93–208

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

    }

    pub async fn put_if(
        &self,
        object_type: &str,
        id: &str,
        name: &str,
        payload: &[u8],
        labels: Option<&str>,
        condition: WriteCondition,
    ) -> PersistenceResult<WriteResult> {
        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}")))?;

        match condition {
            WriteCondition::MustCreate => {
                // Insert only - fail if object exists
                let row = sqlx::query(
                    r"
INSERT INTO objects (object_type, id, name, payload, created_at_ms, updated_at_ms, labels, resource_version)
VALUES ($1, $2, $3, $4, $5, $5, COALESCE($6, '{}'::jsonb), 1)
RETURNING resource_version, created_at_ms, updated_at_ms
",
                )
                .bind(object_type)
                .bind(id)
                .bind(name)
                .bind(payload)
                .bind(now_ms)
                .bind(labels_jsonb)
                .fetch_one(&self.pool)
                .await
                .map_err(|e| map_db_error(&e))?;

                let resource_version_i64: i64 = row.try_get("resource_version").unwrap_or(1);
                Ok(WriteResult {
                    resource_version: resource_version_i64.max(1).cast_unsigned(),
                    created_at_ms: row.get("created_at_ms"),
                    updated_at_ms: row.get("updated_at_ms"),
                })
            }
            WriteCondition::MatchResourceVersion(expected_version) => {
                // Update with version check using RETURNING
                let row_result = sqlx::query(
                    r"
UPDATE objects
SET payload = $4, labels = COALESCE($5, '{}'::jsonb), updated_at_ms = $6, resource_version = resource_version + 1
WHERE object_type = $1 AND id = $2 AND resource_version = $3
RETURNING resource_version, created_at_ms, updated_at_ms
",
                )
                .bind(object_type)
                .bind(id)
                .bind(i64::try_from(expected_version).unwrap_or(i64::MAX))
                .bind(payload)
                .bind(labels_jsonb)
                .bind(now_ms)