10 Commits
Author SHA1 Message Date
cneicy 3a1dc91c85 feat: add NuGet and Godot distribution 2026-09-05 03:41:43 +08:00
cneicy eb7fa55656 feat: add shared runtime and codegen support 2026-09-05 02:34:04 +08:00
cneicy 005ebf43cf chore: release 0.1.3
Publish UPM package / publish (push) Successful in 2s
2026-08-28 04:31:04 +08:00
cneicy ac2ee2df1e chore(package): align network version
Publish UPM package / publish (push) Successful in 2s
2026-08-26 12:48:34 +08:00
cneicy 00f50c1289 test(host): allow Unity test runner completion 2026-08-26 08:23:14 +08:00
cneicy df3519fa96 ci: mirror Git package dependencies 2026-08-26 07:07:05 +08:00
cneicy 91e0f5e679 test: enable standalone host discovery 2026-08-26 06:56:07 +08:00
cneicy 9e8a68c47c ci: stabilize standalone Unity host 2026-08-26 06:36:37 +08:00
ShrinkSDK Automation a6fb3db20b ci: fetch immutable release archive 2026-08-26 04:29:41 +08:00
ShrinkSDK Automation 3d653d23de ci: install Git in package publisher 2026-08-26 03:09:51 +08:00
16 changed files with 178 additions and 194 deletions
+52
View File
@@ -0,0 +1,52 @@
name: Publish NuGet packages
on:
push:
tags:
- 'v*'
workflow_dispatch:
jobs:
publish:
runs-on: ubuntu-latest
permissions:
contents: read
packages: write
env:
NUGET_AUTH_TOKEN: ${{ secrets.SHRINKSDK_PACKAGE_TOKEN }}
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
env:
GITEA_REF: ${{ gitea.ref }}
shell: bash
run: |
set -euo pipefail
tag="${GITEA_REF#refs/tags/}"
version="$(node -p "require('./package.json').version")"
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
fi
+27 -9
View File
@@ -15,22 +15,39 @@ jobs:
env:
NODE_AUTH_TOKEN: ${{ secrets.SHRINKSDK_PACKAGE_TOKEN }}
steps:
- name: Fetch tagged revision
- name: Fetch exact tagged release archive
env:
GITEA_REF: ${{ gitea.ref }}
shell: bash
run: |
set -eu
ref="${{ gitea.sha }}"
test -n "$ref"
git init .
git remote add origin "https://git.crash.work/ShrinkSDK/ShrinkNetwork.Integration.EventBus.git"
git fetch --depth=1 origin "$ref"
git checkout --detach FETCH_HEAD
tag="${GITEA_REF#refs/tags/}"
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/ShrinkSDK/ShrinkNetwork.Integration.EventBus/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: Validate immutable release version
shell: bash
run: |
set -eu
tag="$(git describe --exact-match --tags HEAD)"
cd release
tag="$(cat .shrink-sdk-release-tag)"
version="$(node -p "require('./package.json').version")"
test "$tag" = "v$version"
npm pack --dry-run
@@ -40,10 +57,11 @@ jobs:
run: |
set -eu
: "${NODE_AUTH_TOKEN:?SHRINKSDK_PACKAGE_TOKEN is required}"
cd release
npmrc="$HOME/.npmrc"
cleanup() { rm -f "$npmrc"; }
trap cleanup EXIT
printf '%s\n' \
'registry=https://git.crash.work/api/packages/ShrinkSDK/npm/' \
'//git.crash.work/api/packages/ShrinkSDK/npm/:_authToken=${NODE_AUTH_TOKEN}' > "$npmrc"
npm publish --registry=https://git.crash.work/api/packages/ShrinkSDK/npm/
npm publish --registry=https://git.crash.work/api/packages/ShrinkSDK/npm/
+6 -1
View File
@@ -26,12 +26,17 @@ jobs:
shell: bash
run: |
set -eu
machine_id_file="/root/.local/share/unity3d/Unity/.machine-id"
if test -s "$machine_id_file"; then
cat "$machine_id_file" > /etc/machine-id
echo "Unity machine identity restored"
fi
git config --global url."https://ghfast.top/https://github.com/".insteadOf "https://github.com/"
unity_bin="$(command -v unity-editor || command -v unity || command -v Unity || true)"
test -n "$unity_bin"
"$unity_bin" \
-batchmode \
-nographics \
-quit \
-projectPath "$PWD/Development~/UnityProject" \
-runTests \
-testPlatform EditMode \
+8
View File
@@ -8,3 +8,11 @@
/Tools~/**/[Oo]bj/
*.user
*.DotSettings.user
/DotNet~/**/[Bb]in/
/DotNet~/**/[Oo]bj/
/Godot~/**/[Bb]in/
/Godot~/**/[Oo]bj/
/artifacts/
/packages/
!DotNet~/**/*.csproj
!Godot~/**/*.csproj
+4
View File
@@ -6,3 +6,7 @@ Tools~/
*.sln
*.user
*.DotSettings.user
DotNet~/
Godot~/
NuGet.Config
Directory.Build.props
+6
View File
@@ -2,6 +2,12 @@
本文件记录 `ShrinkNetwork.Integration.EventBus` 在当前工作区中的包内变更。
## [0.1.3] - 2026-08-28
### Changed
- 精确依赖 `ShrinkEventBus 2.0.1`
## [0.1.1] - 2026-04-06
### Added
+6 -168
View File
@@ -1,13 +1,7 @@
#nullable enable
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using Mono.Cecil;
using Mono.Cecil.Cil;
using Mono.Cecil.Pdb;
using ShrinkEventBus.CodeGen;
using ShrinkShared.CodeGen;
using Unity.CompilationPipeline.Common.Diagnostics;
using Unity.CompilationPipeline.Common.ILPostProcessing;
@@ -15,170 +9,14 @@ namespace ShrinkNetwork.Integration.CodeGen
{
public sealed class NetworkEventILPostProcessor : ILPostProcessor
{
private const string IntegrationAssembly = "ShrinkNetwork.Integration.EventBus";
public override ILPostProcessor GetInstance() => this;
public override bool WillProcess(ICompiledAssembly compiledAssembly) =>
compiledAssembly.References.Any(reference =>
string.Equals(Path.GetFileNameWithoutExtension(reference), IntegrationAssembly,
StringComparison.Ordinal));
UnityShrinkCodeGenAdapter.ReferencesAny(compiledAssembly, "ShrinkNetwork.Integration.EventBus");
public override ILPostProcessResult Process(ICompiledAssembly compiledAssembly)
{
var diagnostics = new List<DiagnosticMessage>();
if (!WillProcess(compiledAssembly))
return new ILPostProcessResult(compiledAssembly.InMemoryAssembly, diagnostics);
var assembly = ReadAssembly(compiledAssembly);
try
{
InjectRegistrations(assembly.MainModule);
}
catch (Exception exception)
{
diagnostics.Add(new DiagnosticMessage
{
DiagnosticType = DiagnosticType.Error,
MessageData = $"[ShrinkNetwork.EventBus.CodeGen] {exception.Message}"
});
}
return WriteAssembly(assembly, diagnostics);
}
private static void InjectRegistrations(ModuleDefinition module)
{
var networkEventAttribute = ResolveType(module,
"ShrinkNetwork.Integration.ShrinkNetworkEventAttribute", IntegrationAssembly);
var messageAttribute = ResolveType(module,
"ShrinkNetwork.ShrinkNetworkMessageAttribute", "ShrinkNetwork.Runtime");
var registryType = ResolveType(module,
"ShrinkNetwork.Integration.ShrinkNetworkEventRegistry", IntegrationAssembly);
if (networkEventAttribute == null || messageAttribute == null || registryType == null)
return;
var registrations = GetAllTypes(module.Types)
.Where(type => !type.IsAbstract && HasAttribute(type, networkEventAttribute))
.Select(type => new
{
Type = type,
Message = type.CustomAttributes.FirstOrDefault(attribute =>
attribute.AttributeType.FullName == messageAttribute.FullName)
})
.Where(item => item.Message != null)
.ToArray();
if (registrations.Length == 0)
return;
var registerDefinition = registryType.Resolve()?.Methods.Single(method =>
method.Name == "Register" && method.HasGenericParameters)
?? throw new InvalidOperationException("ShrinkNetworkEventRegistry.Register<T> was not found.");
var registerOpen = module.ImportReference(registerDefinition);
var bootstrap = new TypeDefinition("ShrinkNetwork.Integration.Generated",
"ShrinkGeneratedNetworkEventBindings",
TypeAttributes.Abstract | TypeAttributes.Sealed | TypeAttributes.NotPublic,
module.TypeSystem.Object);
module.Types.Add(bootstrap);
var initialize = new MethodDefinition("Register",
MethodAttributes.Assembly | MethodAttributes.Static | MethodAttributes.HideBySig,
module.TypeSystem.Void);
bootstrap.Methods.Add(initialize);
var il = initialize.Body.GetILProcessor();
foreach (var item in registrations)
{
var attribute = item.Message!;
if (attribute.ConstructorArguments.Count == 0)
throw new InvalidOperationException(
$"[ShrinkNetworkMessage] on {item.Type.FullName} has no opcode.");
var opcode = Convert.ToInt32(attribute.ConstructorArguments[0].Value);
var route = attribute.ConstructorArguments.Count > 1
? attribute.ConstructorArguments[1].Value as string
: null;
var registerClosed = new GenericInstanceMethod(registerOpen);
registerClosed.GenericArguments.Add(module.ImportReference(item.Type));
il.Emit(OpCodes.Ldc_I4, opcode);
if (route == null)
il.Emit(OpCodes.Ldnull);
else
il.Emit(OpCodes.Ldstr, route);
il.Emit(OpCodes.Call, registerClosed);
}
il.Emit(OpCodes.Ret);
InjectModuleInitializer(module, initialize);
}
private static void InjectModuleInitializer(ModuleDefinition module, MethodReference register)
{
var moduleType = module.Types.First(type => type.Name == "<Module>");
var initializer = moduleType.Methods.FirstOrDefault(method => method.Name == ".cctor");
if (initializer == null)
{
initializer = new MethodDefinition(".cctor",
MethodAttributes.Private | MethodAttributes.Static | MethodAttributes.HideBySig |
MethodAttributes.SpecialName | MethodAttributes.RTSpecialName,
module.TypeSystem.Void);
initializer.Body.GetILProcessor().Emit(OpCodes.Ret);
moduleType.Methods.Add(initializer);
}
var il = initializer.Body.GetILProcessor();
il.InsertBefore(initializer.Body.Instructions[0], il.Create(OpCodes.Call, register));
}
private static bool HasAttribute(ICustomAttributeProvider provider, TypeReference attributeType) =>
provider.CustomAttributes.Any(attribute =>
attribute.AttributeType.FullName == attributeType.FullName);
private static IEnumerable<TypeDefinition> GetAllTypes(IEnumerable<TypeDefinition> roots)
{
foreach (var type in roots)
{
yield return type;
foreach (var nested in GetAllTypes(type.NestedTypes))
yield return nested;
}
}
private static TypeReference? ResolveType(ModuleDefinition module, string fullName,
string assemblyName)
{
var reference = module.AssemblyReferences.FirstOrDefault(item => item.Name == assemblyName);
var definition = reference == null ? null : module.AssemblyResolver.Resolve(reference);
var type = definition?.MainModule.GetType(fullName);
return type == null ? null : module.ImportReference(type);
}
private static AssemblyDefinition ReadAssembly(ICompiledAssembly compiledAssembly)
{
var resolver = new PostProcessorAssemblyResolver(compiledAssembly);
var parameters = new ReaderParameters
{
SymbolStream = new MemoryStream(compiledAssembly.InMemoryAssembly.PdbData.ToArray()),
SymbolReaderProvider = new PdbReaderProvider(),
AssemblyResolver = resolver,
ReflectionImporterProvider = new PostProcessorReflectionImporterProvider(),
ReadingMode = ReadingMode.Immediate
};
var assembly = AssemblyDefinition.ReadAssembly(
new MemoryStream(compiledAssembly.InMemoryAssembly.PeData.ToArray()), parameters);
resolver.AddAssemblyDefinitionBeingOperatedOn(assembly);
return assembly;
}
private static ILPostProcessResult WriteAssembly(AssemblyDefinition assembly,
List<DiagnosticMessage> diagnostics)
{
var pe = new MemoryStream();
var pdb = new MemoryStream();
assembly.Write(pe, new WriterParameters
{
SymbolWriterProvider = new PdbWriterProvider(),
SymbolStream = pdb,
WriteSymbols = true
});
return new ILPostProcessResult(new InMemoryAssembly(pe.ToArray(), pdb.ToArray()), diagnostics);
}
public override ILPostProcessResult Process(ICompiledAssembly compiledAssembly) =>
WillProcess(compiledAssembly)
? UnityShrinkCodeGenAdapter.Process(compiledAssembly, "ShrinkNetwork.EventBus.CodeGen")
: new ILPostProcessResult(compiledAssembly.InMemoryAssembly, new List<DiagnosticMessage>());
}
}
@@ -3,7 +3,8 @@
"rootNamespace": "ShrinkNetwork.Integration.CodeGen",
"references": [
"ShrinkNetwork.Integration.EventBus",
"Unity.ShrinkEventBus.CodeGen"
"Unity.ShrinkEventBus.CodeGen",
"Unity.ShrinkShared.CodeGen"
],
"includePlatforms": ["Editor"],
"excludePlatforms": [],
@@ -10,6 +10,10 @@
],
"dependencies": {
"com.unity.test-framework": "1.1.33",
"com.cneicy.shrink-network-integration-eventbus": "file:../../.."
}
"com.cneicy.shrink-network-integration-eventbus": "file:../../..",
"com.cysharp.unitask": "https://github.com/Cysharp/UniTask.git?path=src/UniTask/Assets/Plugins/UniTask#7c0f199fe0d3fc528024488ccd671e6c7b27745b"
},
"testables": [
"com.cneicy.shrink-network-integration-eventbus"
]
}
+13
View File
@@ -0,0 +1,13 @@
<Project>
<PropertyGroup>
<LangVersion>latest</LangVersion>
<Nullable>enable</Nullable>
<Deterministic>true</Deterministic>
<ContinuousIntegrationBuild>true</ContinuousIntegrationBuild>
<Authors>ShrinkSDK</Authors>
<Company>ShrinkSDK</Company>
<RepositoryUrl>https://git.crash.work/ShrinkSDK</RepositoryUrl>
<IncludeSymbols>true</IncludeSymbols>
<SymbolPackageFormat>snupkg</SymbolPackageFormat>
</PropertyGroup>
</Project>
@@ -0,0 +1,20 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFramework>netstandard2.1</TargetFramework>
<EnableDefaultCompileItems>false</EnableDefaultCompileItems>
<AssemblyName>ShrinkNetwork.Integration.EventBus</AssemblyName>
<RootNamespace>ShrinkNetwork.Integration</RootNamespace>
<PackageId>ShrinkSDK.Network.Integration.EventBus</PackageId>
<Version>0.2.0</Version>
<Description>ShrinkNetwork and EventBus generated bridge.</Description>
<ShrinkCodeGenEnabled>true</ShrinkCodeGenEnabled>
</PropertyGroup>
<ItemGroup>
<Compile Include="..\*.cs" />
<PackageReference Include="ShrinkSDK.Runtime.Abstractions" Version="0.1.0" />
<PackageReference Include="ShrinkSDK.Context.Core" Version="0.2.0" />
<PackageReference Include="ShrinkSDK.EventBus" Version="2.1.0" />
<PackageReference Include="ShrinkSDK.Network" Version="0.3.0" />
<PackageReference Include="ShrinkSDK.CodeGen" Version="0.1.0" PrivateAssets="compile;runtime;contentfiles;native" />
</ItemGroup>
</Project>
+8
View File
@@ -0,0 +1,8 @@
<?xml version="1.0" encoding="utf-8"?>
<configuration>
<packageSources>
<clear />
<add key="ShrinkSDK" value="https://git.crash.work/api/packages/ShrinkSDK/nuget/index.json" />
<add key="nuget.org" value="https://api.nuget.org/v3/index.json" protocolVersion="3" />
</packageSources>
</configuration>
+2
View File
@@ -2,6 +2,8 @@
把实现 `IShrinkEvent` 的网络事件与 ShrinkEventBus 2.0 连接。广播事件可从本地 Bus 转发到远端;请求事件可在远端 `PostAsync` 后回传 `EventResult` 与取消状态;delta 事件按版本去重。
Godot 和普通 .NET 项目安装 `ShrinkSDK.Network.Integration.EventBus`;可打包源码位于 `DotNet~`
## 广播事件
```csharp
@@ -5,6 +5,7 @@
"ShrinkNetwork.Runtime",
"ShrinkContext.Core.Runtime",
"ShrinkEventBus.Runtime",
"ShrinkRuntime.Abstractions",
"UniTask"
],
"optionalUnityReferences": [],
+11 -9
View File
@@ -5,7 +5,7 @@ using System.Linq;
using System.Threading;
using Cysharp.Threading.Tasks;
using ShrinkEventBus;
using UnityEngine;
using ShrinkSDK.Runtime;
namespace ShrinkNetwork.Integration
{
@@ -24,7 +24,9 @@ namespace ShrinkNetwork.Integration
private static Dictionary<Type, ShrinkNetworkEventRegistration> _networkEventTypes = new();
private static bool _initialized;
[RuntimeInitializeOnLoadMethod(RuntimeInitializeLoadType.SubsystemRegistration)]
#if UNITY_5_3_OR_NEWER
[UnityEngine.RuntimeInitializeOnLoadMethod(UnityEngine.RuntimeInitializeLoadType.SubsystemRegistration)]
#endif
private static void ResetStaticState()
{
EventBus.Posted -= HandleLocalEventPosted;
@@ -215,9 +217,8 @@ namespace ShrinkNetwork.Integration
}
catch (Exception ex)
{
Debug.LogException(ex);
Debug.LogError(
$"[ShrinkNetwork.Integration] 序列化网络事件失败: {eventArgs.GetType().FullName}");
ShrinkRuntimeServices.Logger.Error(
$"[ShrinkNetwork.Integration] 序列化网络事件失败: {eventArgs.GetType().FullName}", ex);
continue;
}
@@ -236,9 +237,8 @@ namespace ShrinkNetwork.Integration
}
catch (Exception ex)
{
Debug.LogException(ex);
Debug.LogError(
$"[ShrinkNetwork.Integration] 转发网络事件失败: {eventArgs.GetType().FullName}, Session={session.SessionId}");
ShrinkRuntimeServices.Logger.Error(
$"[ShrinkNetwork.Integration] 转发网络事件失败: {eventArgs.GetType().FullName}, Session={session.SessionId}", ex);
}
}
}
@@ -349,7 +349,7 @@ namespace ShrinkNetwork.Integration
}
catch (Exception ex)
{
Debug.LogException(ex);
ShrinkRuntimeServices.Logger.Error("[ShrinkNetwork.Integration] 处理网络事件请求失败。", ex);
return new ShrinkNetworkEventResultResponse
{
ErrorCode = ShrinkRpcErrorCode.HandlerException,
@@ -481,6 +481,7 @@ namespace ShrinkNetwork.Integration
/// handlers. Use ShrinkNetworkDispatchQueue when a hard per-frame budget is
/// required instead of an unbounded PlayerLoop backlog.
/// </summary>
#if UNITY_5_3_OR_NEWER
public sealed class ShrinkNetworkUnityMainThreadDispatchScheduler : IShrinkNetworkDispatchScheduler
{
public async UniTask<bool> ScheduleAsync(Func<UniTask> callback)
@@ -493,4 +494,5 @@ namespace ShrinkNetwork.Integration
return true;
}
}
#endif
}
+6 -4
View File
@@ -1,13 +1,15 @@
{
"name": "com.cneicy.shrink-network-integration-eventbus",
"version": "0.1.1",
"version": "0.2.0",
"displayName": "ShrinkNetwork - EventBus Integration",
"description": "ShrinkNetwork 与 ShrinkEventBus 2.0 的生成式桥接层,让 IShrinkEvent 网络事件可广播、裁决并在远端重新进入命名 Bus。",
"unity": "2022.3",
"dependencies": {
"com.cneicy.shrink-network": "0.2.0",
"com.cneicy.shrink-context-core": "0.1.0",
"com.cneicy.shrink-eventbus": "2.0.0"
"com.cneicy.shrink-network": "0.3.0",
"com.cneicy.shrink-context-core": "0.2.0",
"com.cneicy.shrink-eventbus": "2.1.0",
"com.cneicy.shrink-shared-codegen": "0.1.1",
"com.cneicy.shrink-runtime-abstractions": "0.1.0"
},
"keywords": [
"network",