forked from planetarium/libplanet
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
14 changed files
with
313 additions
and
36 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,48 +1,62 @@ | ||
using Libplanet.Node.API.Services; | ||
using Libplanet.Node.Extensions; | ||
using Libplanet.Node.Options.Schema; | ||
using Microsoft.AspNetCore; | ||
using Microsoft.AspNetCore.Server.Kestrel.Core; | ||
|
||
SynchronizationContext.SetSynchronizationContext(new()); | ||
var builder = WebApplication.CreateBuilder(args); | ||
|
||
builder.Logging.AddConsole(); | ||
|
||
if (builder.Environment.IsDevelopment()) | ||
var builder = WebHost.CreateDefaultBuilder(args); | ||
var assemblies = new string[] | ||
{ | ||
"Libplanet.Node.Swagger", | ||
"Libplanet.Node.Explorer", | ||
}; | ||
builder.UseSetting(WebHostDefaults.HostingStartupAssembliesKey, string.Join(';', assemblies)); | ||
builder.ConfigureLogging(logging => | ||
{ | ||
logging.AddConsole(); | ||
}); | ||
builder.ConfigureKestrel((context, options) => | ||
{ | ||
builder.WebHost.ConfigureKestrel(options => | ||
if (context.HostingEnvironment.IsDevelopment()) | ||
{ | ||
// Setup a HTTP/2 endpoint without TLS. | ||
options.ListenLocalhost(5259, o => o.Protocols = | ||
HttpProtocols.Http1AndHttp2); | ||
}); | ||
} | ||
|
||
// Additional configuration is required to successfully run gRPC on macOS. | ||
// For instructions on how to configure Kestrel and gRPC clients on macOS, | ||
// visit https://go.microsoft.com/fwlink/?linkid=2099682 | ||
|
||
// Add services to the container. | ||
builder.Services.AddGrpc(); | ||
builder.Services.AddGrpcReflection(); | ||
var libplanetBuilder = builder.Services.AddLibplanetNode(builder.Configuration); | ||
|
||
var app = builder.Build(); | ||
var handlerMessage = """ | ||
Communication with gRPC endpoints must be made through a gRPC client. To learn how to | ||
create a client, visit: https://go.microsoft.com/fwlink/?linkid=2086909 | ||
"""; | ||
var schema = await OptionsSchemaBuilder.GetSchemaAsync(default); | ||
|
||
// Configure the HTTP request pipeline. | ||
app.MapGrpcService<BlockChainGrpcService>(); | ||
app.MapGrpcService<SchemaGrpcService>(); | ||
app.MapGet("/", () => handlerMessage); | ||
app.MapGet("/schema", () => schema); | ||
|
||
if (builder.Environment.IsDevelopment()) | ||
} | ||
}); | ||
builder.ConfigureServices((context, services) => | ||
{ | ||
app.MapGrpcReflectionService().AllowAnonymous(); | ||
} | ||
services.AddGrpc(); | ||
services.AddGrpcReflection(); | ||
services.AddLibplanetNode(context.Configuration); | ||
}); | ||
builder.Configure((context, app) => | ||
{ | ||
app.UseRouting(); | ||
app.UseEndpoints(endPoint => | ||
{ | ||
var handlerMessage = """ | ||
Communication with gRPC endpoints must be made through a gRPC client. To learn how to | ||
create a client, visit: https://go.microsoft.com/fwlink/?linkid=2086909 | ||
"""; | ||
string? schema = null; | ||
endPoint.MapGet(string.Empty, async context => | ||
{ | ||
await context.Response.WriteAsync(handlerMessage); | ||
}); | ||
endPoint.MapGet("/schema", async context => | ||
{ | ||
schema ??= await OptionsSchemaBuilder.GetSchemaAsync(context.RequestAborted); | ||
await context.Response.WriteAsync(schema); | ||
}); | ||
endPoint.MapGrpcService<BlockChainGrpcService>(); | ||
endPoint.MapGrpcService<SchemaGrpcService>(); | ||
if (context.HostingEnvironment.IsDevelopment()) | ||
{ | ||
endPoint.MapGrpcReflectionService().AllowAnonymous(); | ||
} | ||
}); | ||
}); | ||
|
||
using var app = builder.Build(); | ||
await app.RunAsync(); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,39 @@ | ||
using System.Reflection; | ||
using Libplanet.Blockchain; | ||
using Libplanet.Explorer.Indexing; | ||
using Libplanet.Explorer.Interfaces; | ||
using Libplanet.Net; | ||
using Libplanet.Node.Services; | ||
using Libplanet.Store; | ||
|
||
namespace Libplanet.Node.Explorer; | ||
|
||
internal sealed class BlockChainContext( | ||
IBlockChainService blockChainService, ISwarmService swarmService) : IBlockChainContext | ||
{ | ||
public bool Preloaded => false; | ||
|
||
public BlockChain BlockChain => blockChainService.BlockChain; | ||
|
||
#pragma warning disable S3011 // Reflection should not be used to increase accessibility ... | ||
public IStore Store | ||
{ | ||
get | ||
{ | ||
var bindingFlags = BindingFlags.NonPublic | BindingFlags.Instance; | ||
var propertyInfo = typeof(BlockChain).GetProperty("Store", bindingFlags) ?? | ||
throw new InvalidOperationException("Store property not found."); | ||
if (propertyInfo.GetValue(BlockChain) is IStore store) | ||
{ | ||
return store; | ||
} | ||
|
||
throw new InvalidOperationException("Store property is not IStore."); | ||
} | ||
} | ||
#pragma warning restore S3011 | ||
|
||
public Swarm Swarm => swarmService.Swarm; | ||
|
||
public IBlockChainIndex Index => throw new NotSupportedException(); | ||
} |
49 changes: 49 additions & 0 deletions
49
sdk/node/Libplanet.Node.Explorer/ExplorerHostingStartup.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,49 @@ | ||
using Libplanet.Explorer; | ||
using Libplanet.Node.Explorer; | ||
using Libplanet.Node.Explorer.Options; | ||
using Microsoft.AspNetCore.Builder; | ||
using Microsoft.AspNetCore.Hosting; | ||
using Microsoft.Extensions.DependencyInjection; | ||
using Microsoft.Extensions.Options; | ||
|
||
[assembly: HostingStartup(typeof(ExplorerHostingStartup))] | ||
|
||
namespace Libplanet.Node.Explorer; | ||
|
||
internal sealed class ExplorerHostingStartup : IHostingStartup, IStartupFilter | ||
{ | ||
public void Configure(IWebHostBuilder builder) | ||
{ | ||
builder.ConfigureServices((context, services) => | ||
{ | ||
services.AddOptions<ExplorerOptions>() | ||
.Bind(context.Configuration.GetSection(ExplorerOptions.Position)); | ||
|
||
var serviceProvider = services.BuildServiceProvider(); | ||
var options = serviceProvider.GetRequiredService<IOptions<ExplorerOptions>>().Value; | ||
|
||
if (options.IsEnabled) | ||
{ | ||
services.AddSingleton<BlockChainContext>(); | ||
services.AddSingleton<ExplorerStartup<BlockChainContext>>(); | ||
serviceProvider = services.BuildServiceProvider(); | ||
var startUp | ||
= serviceProvider.GetRequiredService<ExplorerStartup<BlockChainContext>>(); | ||
startUp.ConfigureServices(services); | ||
services.AddSingleton<IStartupFilter>(this); | ||
} | ||
}); | ||
} | ||
|
||
public Action<IApplicationBuilder> Configure(Action<IApplicationBuilder> next) | ||
{ | ||
return builder => | ||
{ | ||
var serviceProvider = builder.ApplicationServices; | ||
var environment = serviceProvider.GetRequiredService<IWebHostEnvironment>(); | ||
var startUp = serviceProvider.GetService<ExplorerStartup<BlockChainContext>>(); | ||
startUp?.Configure(builder, environment); | ||
next(builder); | ||
}; | ||
} | ||
} |
11 changes: 11 additions & 0 deletions
11
sdk/node/Libplanet.Node.Explorer/Libplanet.Node.Explorer.csproj
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,11 @@ | ||
<Project Sdk="Microsoft.NET.Sdk"> | ||
|
||
<ItemGroup> | ||
</ItemGroup> | ||
|
||
<ItemGroup> | ||
<ProjectReference Include="..\Libplanet.Node\Libplanet.Node.csproj" /> | ||
<ProjectReference Include="..\..\..\tools\Libplanet.Explorer.Executable\Libplanet.Explorer.Executable.csproj" /> | ||
</ItemGroup> | ||
|
||
</Project> |
13 changes: 13 additions & 0 deletions
13
sdk/node/Libplanet.Node.Explorer/Options/ExplorerOptions.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,13 @@ | ||
using System.ComponentModel; | ||
using Libplanet.Node.Options; | ||
|
||
namespace Libplanet.Node.Explorer.Options; | ||
|
||
[Options(Position)] | ||
public sealed class ExplorerOptions : OptionsBase<ExplorerOptions> | ||
{ | ||
public const string Position = "Explorer"; | ||
|
||
[DefaultValue(true)] | ||
public bool IsEnabled { get; set; } = true; | ||
} |
1 change: 0 additions & 1 deletion
1
sdk/node/Libplanet.Node.Extensions/LibplanetServicesExtensions.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
14 changes: 14 additions & 0 deletions
14
sdk/node/Libplanet.Node.Swagger/Libplanet.Node.Swagger.csproj
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,14 @@ | ||
<Project Sdk="Microsoft.NET.Sdk"> | ||
|
||
<ItemGroup> | ||
<PackageReference Include="Swashbuckle.AspNetCore.Swagger" Version="6.7.0" /> | ||
<PackageReference Include="Swashbuckle.AspNetCore.SwaggerGen" Version="6.7.0" /> | ||
<PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="6.7.0" /> | ||
<PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="8.0.7" /> | ||
</ItemGroup> | ||
|
||
<ItemGroup> | ||
<ProjectReference Include="..\Libplanet.Node\Libplanet.Node.csproj" /> | ||
</ItemGroup> | ||
|
||
</Project> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,13 @@ | ||
using System.ComponentModel; | ||
using Libplanet.Node.Options; | ||
|
||
namespace Libplanet.Node.Swagger.Options; | ||
|
||
[Options(Position)] | ||
public sealed class SwaggerOptions : OptionsBase<SwaggerOptions> | ||
{ | ||
public const string Position = "Swagger"; | ||
|
||
[DefaultValue(true)] | ||
public bool IsEnabled { get; set; } = true; | ||
} |
Oops, something went wrong.