Method read

python/pyfory/struct.py:645–752

(self, read_context)

        write_context.try_flush()

    def read(self, read_context):
        if read_context.policy is not DEFAULT_POLICY:
            read_context.policy.authorize_instantiation(self.type_)
        if not self.type_resolver.compatible:
            hash_ = read_context.read_int32()
            if hash_ != self._hash:
                raise TypeNotCompatibleError(
                    f"Hash {hash_} is not consistent with {self._hash} for type {self.type_}",
                )
        obj = self.type_.__new__(self.type_)
        read_context.reference(obj)
        obj_dict = obj.__dict__ if not self._has_slots else None
        if self._has_missing_fields:
            for index, field_name in enumerate(self._field_names):
                serializer = self._serializers[index]
                is_nullable = self._nullable_fields.get(field_name, False)
                is_dynamic = self._dynamic_fields.get(field_name, False)
                is_tracking_ref = self._ref_fields.get(field_name, False)
                is_basic = self._basic_field_flags[index]
                is_compatible_scalar_field = self._compatible_scalar_field_flags[index]
                if field_name not in self._current_class_field_names or not self._assign_fields[index]:
                    self._read_missing_field_value(
                        read_context,
                        serializer,
                        is_nullable,
                        is_dynamic,
                        is_basic,
                        is_tracking_ref,
                        is_compatible_scalar_field,
                    )
                    continue
                field_value = self._read_field_value(
                    read_context,
                    serializer,
                    is_nullable,
                    is_dynamic,
                    is_basic,
                    is_tracking_ref,
                    is_compatible_scalar_field,
                )
                validation_field_type = self._validation_field_types[index]
                if validation_field_type is None:
                    interned_name = self._field_name_interned[field_name]
                    if obj_dict is not None:
                        obj_dict[interned_name] = field_value
                    else:
                        setattr(obj, interned_name, field_value)
                else:
                    self._assign_read_field_value(obj, obj_dict, field_name, field_value, validation_field_type)
        else:
            if not self._has_validation_fields:
                for index, field_name in enumerate(self._field_names):
                    serializer = self._serializers[index]
                    is_nullable = self._nullable_fields.get(field_name, False)
                    is_dynamic = self._dynamic_fields.get(field_name, False)
                    is_tracking_ref = self._ref_fields.get(field_name, False)
                    is_basic = self._basic_field_flags[index]
                    is_compatible_scalar_field = self._compatible_scalar_field_flags[index]