AgileConfig/AgileConfig.Server.Apisite/Controllers/RemoteServerProxyController.cs

using Agile.Config.Protocol;
using AgileConfig.Server.Data.Entity;
using AgileConfig.Server.IService;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
using System;
using System.Threading.Tasks;

namespace AgileConfig.Server.Apisite.Controllers
{
    [Authorize]
    public class RemoteServerProxyController : Controller
    {
        private readonly IRemoteServerNodeActionProxy _remoteServerNodeProxy;
        private readonly IServerNodeService _serverNodeService;
        private readonly ILogger _logger;
        private readonly ISysLogService _sysLogService;

        public RemoteServerProxyController(IRemoteServerNodeActionProxy remoteServerNodeProxy,
            IServerNodeService serverNodeService,
            ILoggerFactory loggerFactory,
            ISysLogService sysLogService)
        {
            _remoteServerNodeProxy = remoteServerNodeProxy;
            _serverNodeService = serverNodeService;
            _sysLogService = sysLogService;
            _logger = loggerFactory.CreateLogger<RemoteServerProxyController>();
        }

        [HttpPost]
        public async Task<IActionResult> Client_Offline(string address, string clientId)
        {
            var action = new WebsocketAction { Action = "offline" };
            var result = await _remoteServerNodeProxy.OneClientDoActionAsync(address, clientId, action);

            _logger.LogInformation("Request remote node {0} 's action OneClientDoAction {1} .", address, result ? "success" : "fail");

            return Json(new
            {
                success = true,
            });
        }

        [HttpPost]
        public async Task<IActionResult> AllClients_Reload(string address)
        {
            var action = new WebsocketAction { Action = "reload" };
            var nodes = await _serverNodeService.GetAllNodesAsync();
            var result = await _remoteServerNodeProxy.AllClientsDoActionAsync(address, action);

            _logger.LogInformation("Request remote node {0} 's action AllClientsDoAction {1} .", address, result ? "success" : "fail");

            return Json(new
            {
                success = true,
            });
        }

        [HttpPost]
        public async Task<IActionResult> Client_Reload(string address, string clientId)
        {
            var action = new WebsocketAction { Action = "reload" };
            var result = await _remoteServerNodeProxy.OneClientDoActionAsync(address, clientId, action);

            _logger.LogInformation("Request remote node {0} 's action OneClientDoAction {1} .", address, result ? "success" : "fail");

            return Json(new
            {
                success = true,
            });
        }
    }
}