fix(ci): restore boundary and Rust checks

Correct feature ownership and SSE API drift, then run locked workspace compilation and boundary self-tests in CI.

Author: limityan

.github/workflows/ci.yml

@@ -119,6 +119,9 @@ jobs:
       - name: Check repository hygiene
         run: pnpm run check:repo-hygiene
 
+      - name: Check core boundaries
+        run: node --test scripts/check-core-boundaries.test.mjs
+
       - name: Install dependencies
         run: pnpm install --frozen-lockfile
 

scripts/core-boundaries/rules/feature-rules.mjs

@@ -86,7 +86,7 @@ export const optionalDependencyFeatureOwnerRules = [
       { depName: 'rustls', ownerFeatures: ['remote-connect'] },
       { depName: 'rustls-native-certs', ownerFeatures: ['remote-connect'] },
       { depName: 'schannel', ownerFeatures: ['remote-connect'] },
-      { depName: 'sha2', ownerFeatures: ['canvas-runtime', 'plugin-source', 'remote-connect', 'remote-ssh'] },
+      { depName: 'sha2', ownerFeatures: ['canvas-runtime', 'plugin-source', 'remote-connect', 'remote-ssh', 'review-platform'] },
       { depName: 'shellexpand', ownerFeatures: ['remote-ssh-concrete'] },
       { depName: 'sse-stream', ownerFeatures: ['mcp'] },
       { depName: 'ssh_config', ownerFeatures: ['remote-ssh-concrete', 'ssh_config'] },
@@ -97,7 +97,7 @@ export const optionalDependencyFeatureOwnerRules = [
       { depName: 'urlencoding', ownerFeatures: ['canvas-runtime', 'remote-connect', 'review-platform'] },
       { depName: 'uuid', ownerFeatures: ['canvas-runtime', 'debug-log', 'miniapp-runtime', 'plugin-source', 'remote-connect', 'remote-ssh-concrete'] },
       { depName: 'which', ownerFeatures: ['miniapp-runtime', 'remote-connect', 'workspace-search'] },
-      { depName: 'windows', ownerFeatures: ['plugin-source'] },
+      { depName: 'windows', ownerFeatures: ['plugin-source', 'review-platform'] },
       { depName: 'x25519-dalek', ownerFeatures: ['remote-connect'] },
     ],
   },

scripts/core-boundaries/self-test.mjs

@@ -698,6 +698,14 @@ export function runManifestParserSelfTest({
       throw new Error(`services-integrations plugin-source must own optional dependency ${dep}`);
     }
   }
+  for (const dep of ['sha2', 'windows']) {
+    const owner = servicesOptionalOwnerRule?.dependencies.find(
+      (dependency) => dependency.depName === dep,
+    );
+    if (!owner?.ownerFeatures.includes('review-platform')) {
+      throw new Error(`services-integrations review-platform must own optional dependency ${dep}`);
+    }
+  }
   const productDomainsOptionalOwnerRule = optionalDependencyFeatureOwnerRules.find(
     (rule) => rule.crateName === 'product-domains',
   );

src/crates/services/services-integrations/src/mcp/protocol/transport_remote.rs

@@ -202,7 +202,7 @@ impl StreamableHttpClient for BitFunStreamableHttpClient {
             }
         }
 
-        let event_stream = SseStream::from_bytes_stream(response.bytes_stream()).boxed();
+        let event_stream = SseStream::from_byte_stream(response.bytes_stream()).boxed();
         Ok(event_stream)
     }
 
@@ -303,7 +303,7 @@ impl StreamableHttpClient for BitFunStreamableHttpClient {
 
         match content_type.as_deref() {
             Some(ct) if ct.as_bytes().starts_with(EVENT_STREAM_MIME_TYPE.as_bytes()) => {
-                let event_stream = SseStream::from_bytes_stream(response.bytes_stream()).boxed();
+                let event_stream = SseStream::from_byte_stream(response.bytes_stream()).boxed();
                 Ok(StreamableHttpPostResponse::Sse(event_stream, session_id))
             }
             Some(ct) if ct.as_bytes().starts_with(JSON_MIME_TYPE.as_bytes()) => {