Method put_if

crates/openshell-server/src/persistence/sqlite.rs:115–229

(
        &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();

        match condition {
            WriteCondition::MustCreate => {
                // Insert only - fail if object exists
                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, ?6, 1)
"#,
                )
                .bind(object_type)
                .bind(id)
                .bind(name)
                .bind(payload)
                .bind(now_ms)
                .bind(labels.unwrap_or("{}"))
                .execute(&self.pool)
                .await
                .map_err(|e| map_db_error(&e))?;

                Ok(WriteResult {
                    resource_version: 1,
                    created_at_ms: now_ms,
                    updated_at_ms: now_ms,
                })
            }
            WriteCondition::MatchResourceVersion(expected_version) => {
                // Update with version check
                let result = sqlx::query(
                    r#"
UPDATE "objects"
SET "payload" = ?4, "labels" = ?5, "updated_at_ms" = ?6, "resource_version" = "resource_version" + 1
WHERE "object_type" = ?1 AND "id" = ?2 AND "resource_version" = ?3
"#,
                )
                .bind(object_type)
                .bind(id)
                .bind(i64::try_from(expected_version).unwrap_or(i64::MAX))
                .bind(payload)
                .bind(labels.unwrap_or("{}"))
                .bind(now_ms)
                .execute(&self.pool)
                .await
                .map_err(|e| map_db_error(&e))?;

                if result.rows_affected() == 0 {
                    // Check if object exists to distinguish NotFound from Conflict
                    let existing = self.get(object_type, id).await?;