Compare commits
12
Commits
df3519fa96
..
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
66f17aae85
|
||
|
|
72ff3eeb6b
|
||
|
|
2247038b12
|
||
|
|
7577f2c57d
|
||
|
|
b75d8f0d20
|
||
|
|
bfff8600b6
|
||
|
|
c5645dce3e
|
||
|
|
3a1dc91c85
|
||
|
|
eb7fa55656
|
||
|
|
005ebf43cf | ||
|
|
ac2ee2df1e | ||
|
|
00f50c1289 |
@@ -0,0 +1,123 @@
|
|||||||
|
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 }}
|
||||||
|
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: Fetch exact tagged source
|
||||||
|
env:
|
||||||
|
GITEA_REF: ${{ gitea.ref }}
|
||||||
|
GITEA_REPOSITORY: ${{ gitea.repository }}
|
||||||
|
shell: bash
|
||||||
|
run: |
|
||||||
|
set -euo pipefail
|
||||||
|
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/${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
|
||||||
|
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 .
|
||||||
|
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
|
||||||
@@ -37,7 +37,6 @@ jobs:
|
|||||||
"$unity_bin" \
|
"$unity_bin" \
|
||||||
-batchmode \
|
-batchmode \
|
||||||
-nographics \
|
-nographics \
|
||||||
-quit \
|
|
||||||
-projectPath "$PWD/Development~/UnityProject" \
|
-projectPath "$PWD/Development~/UnityProject" \
|
||||||
-runTests \
|
-runTests \
|
||||||
-testPlatform EditMode \
|
-testPlatform EditMode \
|
||||||
|
|||||||
@@ -8,3 +8,11 @@
|
|||||||
/Tools~/**/[Oo]bj/
|
/Tools~/**/[Oo]bj/
|
||||||
*.user
|
*.user
|
||||||
*.DotSettings.user
|
*.DotSettings.user
|
||||||
|
/DotNet~/**/[Bb]in/
|
||||||
|
/DotNet~/**/[Oo]bj/
|
||||||
|
/Godot~/**/[Bb]in/
|
||||||
|
/Godot~/**/[Oo]bj/
|
||||||
|
/artifacts/
|
||||||
|
/packages/
|
||||||
|
!DotNet~/**/*.csproj
|
||||||
|
!Godot~/**/*.csproj
|
||||||
|
|||||||
@@ -6,3 +6,9 @@ Tools~/
|
|||||||
*.sln
|
*.sln
|
||||||
*.user
|
*.user
|
||||||
*.DotSettings.user
|
*.DotSettings.user
|
||||||
|
DotNet~/
|
||||||
|
Godot~/
|
||||||
|
NuGet.Config
|
||||||
|
Directory.Build.props
|
||||||
|
NuGet.Config.meta
|
||||||
|
Directory.Build.props.meta
|
||||||
|
|||||||
@@ -2,6 +2,12 @@
|
|||||||
|
|
||||||
本文件记录 `ShrinkNetwork.Integration.EventBus` 在当前工作区中的包内变更。
|
本文件记录 `ShrinkNetwork.Integration.EventBus` 在当前工作区中的包内变更。
|
||||||
|
|
||||||
|
## [0.1.3] - 2026-08-28
|
||||||
|
|
||||||
|
### Changed
|
||||||
|
|
||||||
|
- 精确依赖 `ShrinkEventBus 2.0.1`。
|
||||||
|
|
||||||
## [0.1.1] - 2026-04-06
|
## [0.1.1] - 2026-04-06
|
||||||
|
|
||||||
### Added
|
### Added
|
||||||
|
|||||||
@@ -1,13 +1,7 @@
|
|||||||
#nullable enable
|
#nullable enable
|
||||||
|
|
||||||
using System;
|
|
||||||
using System.Collections.Generic;
|
using System.Collections.Generic;
|
||||||
using System.IO;
|
using ShrinkShared.CodeGen;
|
||||||
using System.Linq;
|
|
||||||
using Mono.Cecil;
|
|
||||||
using Mono.Cecil.Cil;
|
|
||||||
using Mono.Cecil.Pdb;
|
|
||||||
using ShrinkEventBus.CodeGen;
|
|
||||||
using Unity.CompilationPipeline.Common.Diagnostics;
|
using Unity.CompilationPipeline.Common.Diagnostics;
|
||||||
using Unity.CompilationPipeline.Common.ILPostProcessing;
|
using Unity.CompilationPipeline.Common.ILPostProcessing;
|
||||||
|
|
||||||
@@ -15,170 +9,14 @@ namespace ShrinkNetwork.Integration.CodeGen
|
|||||||
{
|
{
|
||||||
public sealed class NetworkEventILPostProcessor : ILPostProcessor
|
public sealed class NetworkEventILPostProcessor : ILPostProcessor
|
||||||
{
|
{
|
||||||
private const string IntegrationAssembly = "ShrinkNetwork.Integration.EventBus";
|
|
||||||
|
|
||||||
public override ILPostProcessor GetInstance() => this;
|
public override ILPostProcessor GetInstance() => this;
|
||||||
|
|
||||||
public override bool WillProcess(ICompiledAssembly compiledAssembly) =>
|
public override bool WillProcess(ICompiledAssembly compiledAssembly) =>
|
||||||
compiledAssembly.References.Any(reference =>
|
UnityShrinkCodeGenAdapter.ReferencesAny(compiledAssembly, "ShrinkNetwork.Integration.EventBus");
|
||||||
string.Equals(Path.GetFileNameWithoutExtension(reference), IntegrationAssembly,
|
|
||||||
StringComparison.Ordinal));
|
|
||||||
|
|
||||||
public override ILPostProcessResult Process(ICompiledAssembly compiledAssembly)
|
public override ILPostProcessResult Process(ICompiledAssembly compiledAssembly) =>
|
||||||
{
|
WillProcess(compiledAssembly)
|
||||||
var diagnostics = new List<DiagnosticMessage>();
|
? UnityShrinkCodeGenAdapter.Process(compiledAssembly, "ShrinkNetwork.EventBus.CodeGen")
|
||||||
if (!WillProcess(compiledAssembly))
|
: new ILPostProcessResult(compiledAssembly.InMemoryAssembly, new List<DiagnosticMessage>());
|
||||||
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);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -3,7 +3,8 @@
|
|||||||
"rootNamespace": "ShrinkNetwork.Integration.CodeGen",
|
"rootNamespace": "ShrinkNetwork.Integration.CodeGen",
|
||||||
"references": [
|
"references": [
|
||||||
"ShrinkNetwork.Integration.EventBus",
|
"ShrinkNetwork.Integration.EventBus",
|
||||||
"Unity.ShrinkEventBus.CodeGen"
|
"Unity.ShrinkEventBus.CodeGen",
|
||||||
|
"Unity.ShrinkShared.CodeGen"
|
||||||
],
|
],
|
||||||
"includePlatforms": ["Editor"],
|
"includePlatforms": ["Editor"],
|
||||||
"excludePlatforms": [],
|
"excludePlatforms": [],
|
||||||
|
|||||||
@@ -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,7 @@
|
|||||||
|
fileFormatVersion: 2
|
||||||
|
guid: cd1432968dbc5d94fa487b5eabeb234b
|
||||||
|
DefaultImporter:
|
||||||
|
externalObjects: {}
|
||||||
|
userData:
|
||||||
|
assetBundleName:
|
||||||
|
assetBundleVariant:
|
||||||
@@ -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>
|
||||||
@@ -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>
|
||||||
@@ -0,0 +1,32 @@
|
|||||||
|
fileFormatVersion: 2
|
||||||
|
guid: 18c54f23448f1aa4a95f895a24ba37be
|
||||||
|
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:
|
||||||
@@ -2,6 +2,8 @@
|
|||||||
|
|
||||||
把实现 `IShrinkEvent` 的网络事件与 ShrinkEventBus 2.0 连接。广播事件可从本地 Bus 转发到远端;请求事件可在远端 `PostAsync` 后回传 `EventResult` 与取消状态;delta 事件按版本去重。
|
把实现 `IShrinkEvent` 的网络事件与 ShrinkEventBus 2.0 连接。广播事件可从本地 Bus 转发到远端;请求事件可在远端 `PostAsync` 后回传 `EventResult` 与取消状态;delta 事件按版本去重。
|
||||||
|
|
||||||
|
Godot 和普通 .NET 项目安装 `ShrinkSDK.Network.Integration.EventBus`;可打包源码位于 `DotNet~`。
|
||||||
|
|
||||||
## 广播事件
|
## 广播事件
|
||||||
|
|
||||||
```csharp
|
```csharp
|
||||||
|
|||||||
@@ -5,6 +5,7 @@
|
|||||||
"ShrinkNetwork.Runtime",
|
"ShrinkNetwork.Runtime",
|
||||||
"ShrinkContext.Core.Runtime",
|
"ShrinkContext.Core.Runtime",
|
||||||
"ShrinkEventBus.Runtime",
|
"ShrinkEventBus.Runtime",
|
||||||
|
"ShrinkRuntime.Abstractions",
|
||||||
"UniTask"
|
"UniTask"
|
||||||
],
|
],
|
||||||
"optionalUnityReferences": [],
|
"optionalUnityReferences": [],
|
||||||
|
|||||||
@@ -5,7 +5,7 @@ using System.Linq;
|
|||||||
using System.Threading;
|
using System.Threading;
|
||||||
using Cysharp.Threading.Tasks;
|
using Cysharp.Threading.Tasks;
|
||||||
using ShrinkEventBus;
|
using ShrinkEventBus;
|
||||||
using UnityEngine;
|
using ShrinkSDK.Runtime;
|
||||||
|
|
||||||
namespace ShrinkNetwork.Integration
|
namespace ShrinkNetwork.Integration
|
||||||
{
|
{
|
||||||
@@ -24,7 +24,9 @@ namespace ShrinkNetwork.Integration
|
|||||||
private static Dictionary<Type, ShrinkNetworkEventRegistration> _networkEventTypes = new();
|
private static Dictionary<Type, ShrinkNetworkEventRegistration> _networkEventTypes = new();
|
||||||
private static bool _initialized;
|
private static bool _initialized;
|
||||||
|
|
||||||
[RuntimeInitializeOnLoadMethod(RuntimeInitializeLoadType.SubsystemRegistration)]
|
#if UNITY_5_3_OR_NEWER
|
||||||
|
[UnityEngine.RuntimeInitializeOnLoadMethod(UnityEngine.RuntimeInitializeLoadType.SubsystemRegistration)]
|
||||||
|
#endif
|
||||||
private static void ResetStaticState()
|
private static void ResetStaticState()
|
||||||
{
|
{
|
||||||
EventBus.Posted -= HandleLocalEventPosted;
|
EventBus.Posted -= HandleLocalEventPosted;
|
||||||
@@ -215,9 +217,8 @@ namespace ShrinkNetwork.Integration
|
|||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
Debug.LogException(ex);
|
ShrinkRuntimeServices.Logger.Error(
|
||||||
Debug.LogError(
|
$"[ShrinkNetwork.Integration] 序列化网络事件失败: {eventArgs.GetType().FullName}", ex);
|
||||||
$"[ShrinkNetwork.Integration] 序列化网络事件失败: {eventArgs.GetType().FullName}");
|
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -236,9 +237,8 @@ namespace ShrinkNetwork.Integration
|
|||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
Debug.LogException(ex);
|
ShrinkRuntimeServices.Logger.Error(
|
||||||
Debug.LogError(
|
$"[ShrinkNetwork.Integration] 转发网络事件失败: {eventArgs.GetType().FullName}, Session={session.SessionId}", ex);
|
||||||
$"[ShrinkNetwork.Integration] 转发网络事件失败: {eventArgs.GetType().FullName}, Session={session.SessionId}");
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -349,7 +349,7 @@ namespace ShrinkNetwork.Integration
|
|||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
Debug.LogException(ex);
|
ShrinkRuntimeServices.Logger.Error("[ShrinkNetwork.Integration] 处理网络事件请求失败。", ex);
|
||||||
return new ShrinkNetworkEventResultResponse
|
return new ShrinkNetworkEventResultResponse
|
||||||
{
|
{
|
||||||
ErrorCode = ShrinkRpcErrorCode.HandlerException,
|
ErrorCode = ShrinkRpcErrorCode.HandlerException,
|
||||||
@@ -481,6 +481,7 @@ namespace ShrinkNetwork.Integration
|
|||||||
/// handlers. Use ShrinkNetworkDispatchQueue when a hard per-frame budget is
|
/// handlers. Use ShrinkNetworkDispatchQueue when a hard per-frame budget is
|
||||||
/// required instead of an unbounded PlayerLoop backlog.
|
/// required instead of an unbounded PlayerLoop backlog.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
#if UNITY_5_3_OR_NEWER
|
||||||
public sealed class ShrinkNetworkUnityMainThreadDispatchScheduler : IShrinkNetworkDispatchScheduler
|
public sealed class ShrinkNetworkUnityMainThreadDispatchScheduler : IShrinkNetworkDispatchScheduler
|
||||||
{
|
{
|
||||||
public async UniTask<bool> ScheduleAsync(Func<UniTask> callback)
|
public async UniTask<bool> ScheduleAsync(Func<UniTask> callback)
|
||||||
@@ -493,4 +494,5 @@ namespace ShrinkNetwork.Integration
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|||||||
+6
-4
@@ -1,13 +1,15 @@
|
|||||||
{
|
{
|
||||||
"name": "com.cneicy.shrink-network-integration-eventbus",
|
"name": "com.cneicy.shrink-network-integration-eventbus",
|
||||||
"version": "0.1.1",
|
"version": "0.2.0",
|
||||||
"displayName": "ShrinkNetwork - EventBus Integration",
|
"displayName": "ShrinkNetwork - EventBus Integration",
|
||||||
"description": "ShrinkNetwork 与 ShrinkEventBus 2.0 的生成式桥接层,让 IShrinkEvent 网络事件可广播、裁决并在远端重新进入命名 Bus。",
|
"description": "ShrinkNetwork 与 ShrinkEventBus 2.0 的生成式桥接层,让 IShrinkEvent 网络事件可广播、裁决并在远端重新进入命名 Bus。",
|
||||||
"unity": "2022.3",
|
"unity": "2022.3",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"com.cneicy.shrink-network": "0.2.0",
|
"com.cneicy.shrink-network": "0.3.0",
|
||||||
"com.cneicy.shrink-context-core": "0.1.0",
|
"com.cneicy.shrink-context-core": "0.2.0",
|
||||||
"com.cneicy.shrink-eventbus": "2.0.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": [
|
"keywords": [
|
||||||
"network",
|
"network",
|
||||||
|
|||||||
Reference in New Issue
Block a user