fix: Fix logic in specversion checks

Author: dazuma

CLAUDE.md

@@ -90,6 +90,7 @@ All errors inherit from `CloudEventsError`: `NotCloudEventError`, `UnsupportedFo
 
 ## Contributing
 
+- Use red-green test-driven development when making changes, unless instructed otherwise.
 - Conventional Commits format required (`fix:`, `feat:`, `docs:`, etc.)
 - Commits must be signed off (`git commit --signoff`)
 - Run `toys ci` before submitting PRs

lib/cloud_events/kafka_binding.rb

@@ -209,7 +209,10 @@ def encode_event(event, structured_format: false, key_mapper: :NOT_SET, **format
       if event.is_a?(Event::Opaque)
         return encode_opaque_event(event)
       end
-      unless event.respond_to?(:spec_version) && event.spec_version.start_with?("1.")
+      unless event.respond_to?(:spec_version)
+        raise(SpecVersionError, "Unable to determine specversion")
+      end
+      unless event.spec_version.start_with?("1.")
         raise(SpecVersionError, "Unrecognized specversion: #{event.spec_version}")
       end
       if structured_format
@@ -286,7 +289,8 @@ def decode_structured_content(message, content_type, allow_opaque, **format_args
                                             **format_args)
       if result
         event = result[:event]
-        if event && !(event.respond_to?(:spec_version) && event.spec_version.start_with?("1."))
+        raise(SpecVersionError, "Unable to determine specversion") unless event.respond_to?(:spec_version)
+        unless event.spec_version.start_with?("1.")
           raise(SpecVersionError, "Unrecognized specversion: #{event.spec_version}")
         end
         return event