Method hydrate_from_postgres

libs/@local/hashql/eval/src/orchestrator/partial.rs:625–853

(
        &mut self,
        env: &Environment<'heap>,
        decoder: &Decoder<'_, 'heap, A>,
        path: EntityPath,
        r#type: TypeId,
        column: Indexed<ColumnDescriptor>,
        row

    #[expect(clippy::too_many_lines)]
    fn hydrate_from_postgres(
        &mut self,
        env: &Environment<'heap>,
        decoder: &Decoder<'_, 'heap, A>,
        path: EntityPath,
        r#type: TypeId,
        column: Indexed<ColumnDescriptor>,
        row: &Row,
    ) -> Result<(), BridgeError<'heap>>
    where
        A: Clone,
    {
        let row_hydration_error = |source| BridgeError::RowHydration { column, source };

        match path {
            EntityPath::Properties => {
                let value: serde_json::Value =
                    row.try_get(column.index).map_err(row_hydration_error)?;
                let value = decoder.try_decode(r#type, (&value).into(), column)?;
                self.properties.set(value);
            }
            EntityPath::Vectors => unreachable!(
                "entity vectors should never reach postgres compilation; the placement pass \
                 should have rejected this"
            ),
            EntityPath::RecordId => {
                let value: serde_json::Value =
                    row.try_get(column.index).map_err(row_hydration_error)?;

                let entity_id = &value["entity_id"];
                let edition_id = &value["edition_id"];

                self.hydrate_entity_id(env, decoder, column, entity_id)?;
                self.hydrate_edition_id(env, decoder, column, edition_id)?;
            }
            EntityPath::EntityId => {
                let value: serde_json::Value =
                    row.try_get(column.index).map_err(row_hydration_error)?;

                self.hydrate_entity_id(env, decoder, column, &value)?;
            }
            EntityPath::WebId => {
                let value: Uuid = row.try_get(column.index).map_err(row_hydration_error)?;
                self.hydrate_web_id(
                    env,
                    decoder,
                    column,
                    JsonValueRef::String(&value.hyphenated().to_string()),
                )?;
            }
            EntityPath::EntityUuid => {
                let value: Uuid = row.try_get(column.index).map_err(row_hydration_error)?;
                self.hydrate_entity_uuid(
                    env,
                    decoder,
                    column,
                    JsonValueRef::String(&value.hyphenated().to_string()),
                )?;