LexBus 1.0.2

LexBus

Quick Start

using LexBus.DependencyInjection;

var builder = WebApplication.CreateBuilder(args);

// Add services to the container.
builder.Services.AddHttpClient();
builder.Services.AddSingleton<Demo>();

builder.Services.AddLexBus(options =>
{
    options.HostOfRabbit = "your.rabbit.server";
    options.PortOfRabbit = 5672;
    options.UserOfRabbit = "user";
    options.PasswordOfRabbit = "password";

    options.AddBus<int>("device.int");
    options.AddBus<long>("device.long");
    options.AddBus<Mark>("device.mark");
});

var app = builder.Build();

// Configure the HTTP request pipeline.

app.UseLexBus();

app.Start();

//all registed buses，communicate through the serverid
var intBus = app.Services.GetService<LexBus.Bus.IShellBus<int>>();
var longBus = app.Services.GetService<LexBus.Bus.IShellBus<long>>();
var markBus = app.Services.GetService<LexBus.Bus.IShellBus<Mark>>();

//1. by bus call shell.
//result:{"Code":1,"DataType":3,"Message":"Successful","Data":"Func"}
var resultByBus = intBus.CallAsync("device.int", "demo call -arg2 1", CancellationToken.None).Result;

//2. by http call shell. target serverid uri:http://localhost:5174
var factory = app.Services.GetService<IHttpClientFactory>();
var http = factory.CreateClient();

http.DefaultRequestHeaders.Add("shell-secret", "blymonix");

var content = new StringContent("demo call2 call3 call4");

//result:{"Code":1,"DataType":3,"Message":"Successful","Data":"Funcs"}
var resultByHttp = http.PostAsync("http://localhost:5174/shell", content)
    .Result.Content.ReadFromJsonAsync<LexBus.Shell.ShellExecutedResult>().Result;

Console.ReadKey();

[LexBus.Attributes.Shell]
public class Demo
{
    [LexBus.Attributes.Tag("tag")]
    [LexBus.Attributes.Group("group")]
    [LexBus.Attributes.Command("demo", "call")]
    [LexBus.Attributes.Argument("arg1", "desc")]
    [LexBus.Attributes.Argument("arg2", "desc", required: true)]
    public ValueTask<LexBus.Shell.ShellExecutedResult> Func(LexBus.Shell.ShellExecutingContext context)
    {
        if (context.TryGetArgument("arg1", out var arg1Span))
        {
            //it may not exist
        }

        if (context.TryGetArgument("arg2", out var arg2Span))
        {
            //it must exist
        }

        return new ValueTask<LexBus.Shell.ShellExecutedResult>(LexBus.Shell.ShellExecutedResult.ByText("Func"));
    }

    [LexBus.Attributes.Tag("tag")]
    [LexBus.Attributes.Group("group")]
    [LexBus.Attributes.Command("demo", "call1")]
    public Task<LexBus.Shell.ShellExecutedResult> Func1(LexBus.Shell.ShellExecutingContext context)
    {
        return Task.FromResult(LexBus.Shell.ShellExecutedResult.ByText("Func1"));
    }

    [LexBus.Attributes.Tag("tag")]
    [LexBus.Attributes.Group("group")]
    [LexBus.Attributes.Command("demo", "call2", "call3", "call4")]
    public LexBus.Shell.ShellExecutedResult Func2(LexBus.Shell.ShellExecutingContext context)
    {
        return LexBus.Shell.ShellExecutedResult.ByText("Funcs");
    }
}

public class Mark { }