| 895 | } |
| 896 | |
| 897 | fn row_to_object_record(row: sqlx::sqlite::SqliteRow) -> ObjectRecord { |
| 898 | let resource_version_i64: i64 = row.try_get("resource_version").unwrap_or(1); |
| 899 | ObjectRecord { |
| 900 | object_type: row.get("object_type"), |
| 901 | id: row.get("id"), |
| 902 | name: row.get("name"), |
| 903 | payload: row.get("payload"), |
| 904 | created_at_ms: row.get("created_at_ms"), |
| 905 | updated_at_ms: row.get("updated_at_ms"), |
| 906 | labels: row.get("labels"), |
| 907 | resource_version: resource_version_i64.max(1).cast_unsigned(), |
| 908 | } |
| 909 | } |
| 910 | |
| 911 | fn row_to_policy_record(row: sqlx::sqlite::SqliteRow) -> PersistenceResult<PolicyRecord> { |
| 912 | let id: String = row.get("id"); |