using Sers.Core.Module.PubSub;
using Sers.Core.Module.Rpc;
using Sers.SersLoader;
using Vit.Core.Util.ComponentModel.Api;
using Vit.Core.Util.ComponentModel.Data;
using Vit.Extensions;

namespace Did.SersLoader.Demo.Controllers.PubSub.Controller
{

    //路由前缀，可不指定
    [SsRoutePrefix("api/pubsub/controller")]
    public class PublishController
        : IApiController
    {

        /// <summary>
        /// 
        /// </summary>
        /// <returns></returns>
        [SsRoute("publish/*")]
        public ApiReturn Publish(string msgBody)
        {
            var rpcData = RpcContext.RpcData;
            var http_url_search = rpcData.http_url_search_Get();
            string msgTitle = http_url_search.Split('/')[0];

            MessageClient.Publish(msgTitle, msgBody);
            return new ApiReturn();
        }

    }
}