perf(eventbus): remove inline allocations and expose binding snapshots

.gitea/workflows/publish-nuget.yml

@@ -14,38 +14,109 @@ jobs:
       packages: write
     env:
       NUGET_AUTH_TOKEN: ${{ secrets.SHRINKSDK_PACKAGE_TOKEN }}
+      DOTNET_SYSTEM_GLOBALIZATION_INVARIANT: '1'
+      DOTNET_CLI_TELEMETRY_OPTOUT: '1'
+      LD_LIBRARY_PATH: /opt/dotnet-libs/usr/lib/x86_64-linux-gnu
+      SSL_CERT_FILE: /opt/ca-certificates.crt
     steps:
-      - name: Checkout tagged source
-        uses: actions/checkout@v4
-
-      - name: Set up .NET
-        uses: actions/setup-dotnet@v4
-        with:
-          dotnet-version: '8.0.x'
-
-      - name: Validate tag and pack projects
+      - name: Fetch exact tagged source
         env:
           GITEA_REF: ${{ gitea.ref }}
+          GITEA_REPOSITORY: ${{ gitea.repository }}
         shell: bash
         run: |
           set -euo pipefail
           tag="${GITEA_REF#refs/tags/}"
-          version="$(node -p "require('./package.json').version")"
+          case "$tag" in
+            v[0-9]*) ;;
+            *) echo "Expected a version tag ref, got: $GITEA_REF" >&2; exit 1 ;;
+          esac
+          export SHRINKSDK_ARCHIVE_URL="https://git.crash.work/${GITEA_REPOSITORY}/archive/${tag}.tar.gz"
+          node --input-type=module <<'NODE'
+          import { writeFile } from 'node:fs/promises';
+
+          const response = await fetch(process.env.SHRINKSDK_ARCHIVE_URL);
+          if (!response.ok) {
+            throw new Error(`Release archive download failed: ${response.status} ${response.statusText}`);
+          }
+          await writeFile('release.tar.gz', new Uint8Array(await response.arrayBuffer()));
+          NODE
+          mkdir release
+          tar -xzf release.tar.gz --strip-components=1 -C release
+          rm -f release.tar.gz
+          printf '%s' "$tag" > release/.shrink-sdk-release-tag
+
+      - name: Install .NET 8 SDK
+        shell: bash
+        run: |
+          set -euo pipefail
+          node --input-type=module <<'NODE'
+          import { writeFile } from 'node:fs/promises';
+          import { rootCertificates } from 'node:tls';
+
+          await writeFile('/opt/ca-certificates.crt', rootCertificates.join('\n'));
+
+          const metadataResponse = await fetch('https://dotnetcli.blob.core.windows.net/dotnet/release-metadata/8.0/releases.json');
+          if (!metadataResponse.ok) throw new Error(`Release metadata download failed: ${metadataResponse.status}`);
+          const metadata = await metadataResponse.json();
+          const sdkVersion = metadata['latest-sdk'];
+          const release = metadata.releases.find(item => item.sdk?.version === sdkVersion);
+          const file = release?.sdk?.files?.find(item => item.rid === 'linux-x64' && item.name.endsWith('.tar.gz'));
+          if (!file) throw new Error(`Linux x64 SDK archive not found for ${sdkVersion}`);
+          const archiveResponse = await fetch(file.url);
+          if (!archiveResponse.ok) throw new Error(`SDK download failed: ${archiveResponse.status}`);
+          await writeFile('/tmp/dotnet-sdk.tar.gz', new Uint8Array(await archiveResponse.arrayBuffer()));
+
+          const poolUrl = 'https://deb.debian.org/debian-security/pool/updates/main/o/openssl/';
+          const poolResponse = await fetch(poolUrl);
+          if (!poolResponse.ok) throw new Error(`OpenSSL package index download failed: ${poolResponse.status}`);
+          const poolIndex = await poolResponse.text();
+          const packages = [...poolIndex.matchAll(/href="(libssl3_[^"]+_amd64\.deb)"/g)].map(match => match[1]).sort();
+          const packageName = packages.at(-1);
+          if (!packageName) throw new Error('Debian libssl3 package was not found');
+          const packageResponse = await fetch(poolUrl + packageName);
+          if (!packageResponse.ok) throw new Error(`OpenSSL package download failed: ${packageResponse.status}`);
+          await writeFile('/tmp/libssl3.deb', new Uint8Array(await packageResponse.arrayBuffer()));
+          NODE
+          mkdir -p /opt/dotnet
+          tar -xzf /tmp/dotnet-sdk.tar.gz -C /opt/dotnet
+          mkdir -p /opt/dotnet-libs
+          dpkg-deb -x /tmp/libssl3.deb /opt/dotnet-libs
+          rm -f /tmp/dotnet-sdk.tar.gz
+          rm -f /tmp/libssl3.deb
+          /opt/dotnet/dotnet --info
+
+      - name: Validate, pack and publish
+        shell: bash
+        run: |
+          set -euo pipefail
+          : "${NUGET_AUTH_TOKEN:?SHRINKSDK_PACKAGE_TOKEN is required}"
+          export PATH="/opt/dotnet:$PATH"
+          cd release
+          tag="$(cat .shrink-sdk-release-tag)"
+          projects=()
+          if [[ -d DotNet~ ]]; then
+            while IFS= read -r -d '' project; do projects+=("$project"); done < <(find DotNet~ -type f -name '*.csproj' -print0)
+          fi
+          if [[ -d Godot~ ]]; then
+            while IFS= read -r -d '' project; do projects+=("$project"); done < <(find Godot~ -type f -name '*.csproj' -print0)
+          fi
+          if [[ "${#projects[@]}" -eq 0 ]]; then
+            while IFS= read -r -d '' project; do projects+=("$project"); done < <(find . -maxdepth 1 -type f -name '*.csproj' -print0)
+          fi
+          test "${#projects[@]}" -gt 0
+          if [[ -f package.json ]]; then
+            version="$(node -p "require('./package.json').version")"
+          else
+            version="$(dotnet msbuild "${projects[0]}" -getProperty:Version -nologo)"
+          fi
           test "$tag" = "v$version"
           mkdir -p packages
-          mapfile -d '' projects < <(find DotNet~ Godot~ -type f -name '*.csproj' -print0 2>/dev/null || true)
-          test "${#projects[@]}" -gt 0
           for project in "${projects[@]}"; do
             dotnet restore "$project" --configfile NuGet.Config
             dotnet pack "$project" --configuration Release --no-restore --output "$PWD/packages" --include-symbols --include-source
           done
           find packages -maxdepth 1 -name '*.nupkg' -type f | grep -q .
-
-      - name: Publish packages
-        shell: bash
-        run: |
-          set -euo pipefail
-          : "${NUGET_AUTH_TOKEN:?SHRINKSDK_PACKAGE_TOKEN is required}"
           dotnet nuget push 'packages/*.nupkg' --api-key "$NUGET_AUTH_TOKEN" --source https://git.crash.work/api/packages/ShrinkSDK/nuget/index.json --skip-duplicate
           if compgen -G 'packages/*.snupkg' > /dev/null; then
             dotnet nuget push 'packages/*.snupkg' --api-key "$NUGET_AUTH_TOKEN" --source https://git.crash.work/api/packages/ShrinkSDK/nuget/index.json --skip-duplicate

.gitignore

@@ -30,6 +30,8 @@
 /[Aa]ssets/Plugins/Editor/JetBrains*
 # Jetbrains Rider personal-layer settings
 *.DotSettings.user
+!DotNet~/*.csproj
+!DotNet~/**/*.csproj
 /DotNet~/**/[Bb]in/
 /DotNet~/**/[Oo]bj/
 /Godot~/**/[Bb]in/
@@ -116,3 +118,5 @@ InitTestScene*.unity*
 /Tools~/**/[Oo]bj/
 *.user
 *.DotSettings.user
+!DotNet~/*.csproj
+!DotNet~/**/*.csproj

.npmignore

@@ -10,3 +10,5 @@ DotNet~/
 Godot~/
 NuGet.Config
 Directory.Build.props
+NuGet.Config.meta
+Directory.Build.props.meta

CodeGen/Editor/EventBusILPostProcessor.cs

@@ -11,8 +11,8 @@ namespace ShrinkEventBus.CodeGen
     {
         public override ILPostProcessor GetInstance() => this;
 
-        public override bool WillProcess(ICompiledAssembly compiledAssembly) =>
-            UnityShrinkCodeGenAdapter.ReferencesAny(compiledAssembly, "ShrinkEventBus.Runtime");
+        // ShrinkRegistryILPostProcessor owns the complete pass, including event bindings.
+        public override bool WillProcess(ICompiledAssembly compiledAssembly) => false;
 
         public override ILPostProcessResult Process(ICompiledAssembly compiledAssembly) =>
             WillProcess(compiledAssembly)

Directory.Build.props.meta

@@ -0,0 +1,7 @@
+fileFormatVersion: 2
+guid: bb9607b086e27c14c9be7469aac61d0d
+DefaultImporter:
+  externalObjects: {}
+  userData: 
+  assetBundleName: 
+  assetBundleVariant: 

DotNet~/ShrinkSDK.EventBus.csproj

@@ -0,0 +1,19 @@
+<Project Sdk="Microsoft.NET.Sdk">
+  <PropertyGroup>
+    <TargetFramework>netstandard2.1</TargetFramework>
+    <EnableDefaultCompileItems>false</EnableDefaultCompileItems>
+    <AssemblyName>ShrinkEventBus.Runtime</AssemblyName>
+    <RootNamespace>ShrinkEventBus</RootNamespace>
+    <PackageId>ShrinkSDK.EventBus</PackageId>
+    <Version>2.2.2</Version>
+    <Description>ShrinkSDK typed event bus runtime.</Description>
+    <ShrinkCodeGenEnabled>false</ShrinkCodeGenEnabled>
+  </PropertyGroup>
+  <ItemGroup>
+    <Compile Include="..\Runtime\**\*.cs"
+             Exclude="..\Runtime\ShrinkMonoEventScope.cs" />
+    <PackageReference Include="UniTask" Version="2.5.10" />
+    <PackageReference Include="ShrinkSDK.CodeGen" Version="0.2.0" PrivateAssets="compile;runtime;contentfiles;native" />
+    <PackageReference Include="ShrinkSDK.Runtime.Abstractions" Version="0.1.0" />
+  </ItemGroup>
+</Project>

NuGet.Config.meta

@@ -0,0 +1,32 @@
+fileFormatVersion: 2
+guid: cc42bc8ffa8649949aa6d63f9a225d27
+PluginImporter:
+  externalObjects: {}
+  serializedVersion: 2
+  iconMap: {}
+  executionOrder: {}
+  defineConstraints: []
+  isPreloaded: 0
+  isOverridable: 0
+  isExplicitlyReferenced: 0
+  validateReferences: 1
+  platformData:
+  - first:
+      Any: 
+    second:
+      enabled: 0
+      settings: {}
+  - first:
+      Editor: Editor
+    second:
+      enabled: 0
+      settings:
+        DefaultValueInitialized: true
+  - first:
+      Windows Store Apps: WindowsStoreApps
+    second:
+      enabled: 1
+      settings: {}
+  userData: 
+  assetBundleName: 
+  assetBundleVariant: 

README.md

@@ -182,3 +182,13 @@ ShrinkEventBusBenchmark.Run(
 - Editor 诊断是可选观察层，不参与正式无诊断热路径。
 
 架构审计与来源说明见 `Docs/JustAnyProjectArchitectureAudit.md` 和根目录 `DESIGN.md`。
+
+## 可复用能力
+
+<!-- shrink:capabilities -->
+Capability: 按类型发布事实和请求，支持同步、异步、优先级和可撤回订阅
+Aliases: 事件 事件未触发 消息 订阅 通知 event bus
+Limits: EventBus 不等于业务状态机或资源计量；并行派发须由业务明确选择
+Extension: IShrinkEvent、ShrinkSubscribe、BusOptions 和拥有者 Attach/Dispose
+Evidence: [EventBus](Runtime/EventBus.cs); [ShrinkSubscribeAttribute](Runtime/ShrinkEventAttributes.cs); [ShrinkGeneratedBinding](Runtime/ShrinkEventBindings.cs)
+<!-- /shrink:capabilities -->

Runtime/EventBus.cs

@@ -143,6 +143,14 @@ namespace ShrinkEventBus
             return generated.AttachGenerated(Resolver, defaultBus ?? ShrinkBusKey.Game);
         }
 
+        public static IReadOnlyList<(Type EventType, System.Reflection.MethodInfo Handler)> CaptureBindings(IShrinkEventBus bus)
+        {
+            if (bus is ShrinkEventBusInstance instance) return instance.CaptureBindings();
+            throw new NotSupportedException("This event bus does not expose binding diagnostics.");
+        }
+
+        public static IReadOnlyList<IShrinkEventBus> CaptureNamedBuses() => new List<IShrinkEventBus>(Buses.Values);
+
         internal static IReadOnlyList<(ShrinkBusKey Key, ShrinkBusOptions Options, int Subscribers)> Snapshot()
         {
             var snapshot = new List<(ShrinkBusKey, ShrinkBusOptions, int)>(Buses.Count);

Runtime/ShrinkEventBusCore.cs

@@ -14,6 +14,7 @@ namespace ShrinkEventBus
     internal interface IShrinkEventChannel
     {
         int Count { get; }
+        void CaptureBindings(List<(Type EventType, System.Reflection.MethodInfo Handler)> bindings);
         bool RemoveSubscription(long subscriptionId);
         void Clear();
         void DetachSlot(int slot);
@@ -87,6 +88,15 @@ namespace ShrinkEventBus
         private Action<TEvent>? _syncDispatcher;
 
         public int Count => _snapshot.Length;
+        public void CaptureBindings(List<(Type EventType, System.Reflection.MethodInfo Handler)> bindings)
+        {
+            var snapshot = _snapshot;
+            foreach (var entry in snapshot)
+            {
+                var method = entry.SyncHandler?.Method ?? entry.AsyncHandler?.Method;
+                if (method != null) bindings.Add((typeof(TEvent), method));
+            }
+        }
 
         public void Add(long subscriptionId, long registrationOrder, Action<TEvent> handler,
             ShrinkSubscribeDescriptor descriptor)

Runtime/ShrinkEventBusInstance.cs

@@ -75,7 +75,7 @@ namespace ShrinkEventBus
         [MethodImpl(MethodImplOptions.AggressiveInlining)]
         public virtual ShrinkPostResult Post<TEvent>(in TEvent eventData) where TEvent : IShrinkEvent
         {
-            if (eventData is null)
+            if (!typeof(TEvent).IsValueType && eventData is null)
                 throw new ArgumentNullException(nameof(eventData));
             if (Volatile.Read(ref _disposed) != 0)
                 return TraceWithoutDispatch(in eventData,
@@ -84,6 +84,11 @@ namespace ShrinkEventBus
             if (_isInline || _scheduler.IsOnSchedulerThread)
                 return Dispatch(in eventData);
 
+            return PostScheduled(in eventData);
+        }
+
+        private ShrinkPostResult PostScheduled<TEvent>(in TEvent eventData) where TEvent : IShrinkEvent
+        {
             var queuedEvent = eventData;
             if (_scheduler.TryPost(() => Dispatch(in queuedEvent)))
                 return new ShrinkPostResult(true, false, false);
@@ -94,7 +99,7 @@ namespace ShrinkEventBus
         public virtual UniTask<ShrinkPostResult> PostAsync<TEvent>(TEvent eventData,
             CancellationToken cancellationToken = default) where TEvent : IShrinkEvent
         {
-            if (eventData is null)
+            if (!typeof(TEvent).IsValueType && eventData is null)
                 throw new ArgumentNullException(nameof(eventData));
             if (Volatile.Read(ref _disposed) != 0)
                 return UniTask.FromResult(TraceWithoutDispatch(in eventData,
@@ -168,6 +173,13 @@ namespace ShrinkEventBus
             return new EventSubscription(this, subscriptionId);
         }
 
+        internal IReadOnlyList<(Type EventType, System.Reflection.MethodInfo Handler)> CaptureBindings()
+        {
+            var bindings = new List<(Type, System.Reflection.MethodInfo)>();
+            lock (_channelGate) foreach (var channel in _channels.Values) channel.CaptureBindings(bindings);
+            return bindings;
+        }
+
         internal int SubscriberCount
         {
             get
@@ -367,7 +379,7 @@ namespace ShrinkEventBus
         [MethodImpl(MethodImplOptions.AggressiveInlining)]
         public override ShrinkPostResult Post<TEvent>(in TEvent eventData)
         {
-            if (eventData is null)
+            if (!typeof(TEvent).IsValueType && eventData is null)
                 throw new ArgumentNullException(nameof(eventData));
             if (IsDisposed)
                 return TraceWithoutDispatch(in eventData,
@@ -378,7 +390,7 @@ namespace ShrinkEventBus
         public override UniTask<ShrinkPostResult> PostAsync<TEvent>(TEvent eventData,
             CancellationToken cancellationToken = default)
         {
-            if (eventData is null)
+            if (!typeof(TEvent).IsValueType && eventData is null)
                 throw new ArgumentNullException(nameof(eventData));
             if (IsDisposed)
                 return UniTask.FromResult(TraceWithoutDispatch(in eventData,

package.json

@@ -1,6 +1,6 @@
 {
   "name": "com.cneicy.shrink-eventbus",
-  "version": "2.1.0",
+  "version": "2.2.2",
   "displayName": "ShrinkEventBus",
   "description": "多 Bus、特性强类型注册、UniTask 调度与低分配发布的 Unity 事件总线。",
   "unity": "2022.3",
@@ -10,7 +10,7 @@
   "dependencies": {
     "com.cysharp.unitask": "2.5.10",
     "com.unity.nuget.mono-cecil": "1.11.4",
-    "com.cneicy.shrink-shared-codegen": "0.1.1",
+    "com.cneicy.shrink-shared-codegen": "0.2.1",
     "com.cneicy.shrink-runtime-abstractions": "0.1.0"
   },
   "keywords": [