This commit is contained in:
136
server/AyaNova/Controllers/EventLogController.cs
Normal file
136
server/AyaNova/Controllers/EventLogController.cs
Normal file
@@ -0,0 +1,136 @@
|
||||
using System.IO;
|
||||
using System.Threading.Tasks;
|
||||
using Microsoft.AspNetCore.Http;
|
||||
using Microsoft.AspNetCore.Mvc;
|
||||
using Microsoft.AspNetCore.Routing;
|
||||
using Microsoft.AspNetCore.Authorization;
|
||||
using Microsoft.Extensions.Logging;
|
||||
using Newtonsoft.Json.Linq;
|
||||
using AyaNova.Models;
|
||||
using AyaNova.Api.ControllerHelpers;
|
||||
using AyaNova.Biz;
|
||||
|
||||
|
||||
namespace AyaNova.Api.Controllers
|
||||
{
|
||||
|
||||
/// <summary>
|
||||
/// Log files controller
|
||||
/// </summary>
|
||||
[ApiVersion("8.0")]
|
||||
[Route("api/v{version:apiVersion}/[controller]")]
|
||||
[Authorize]
|
||||
public class EventLogController : Controller
|
||||
{
|
||||
private readonly AyContext ct;
|
||||
private readonly ILogger<LogFilesController> log;
|
||||
private readonly ApiServerState serverState;
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// ctor
|
||||
/// </summary>
|
||||
/// <param name="dbcontext"></param>
|
||||
/// <param name="logger"></param>
|
||||
/// <param name="apiServerState"></param>
|
||||
public EventLogController(AyContext dbcontext, ILogger<LogFilesController> logger, ApiServerState apiServerState)
|
||||
{
|
||||
ct = dbcontext;
|
||||
log = logger;
|
||||
serverState = apiServerState;
|
||||
}
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// Get events as text document for object specified
|
||||
///
|
||||
/// Required roles:
|
||||
/// OpsAdminFull | OpsAdminLimited
|
||||
/// </summary>
|
||||
/// <returns>Snapshot of metrics</returns>
|
||||
[HttpGet("TextSnapShot")]
|
||||
public async Task<IActionResult> GetObjectLog()
|
||||
{
|
||||
//Open or opsOnly and user is opsadminfull or opsadminlimited
|
||||
if (!serverState.IsOpenOrOpsOnly || (serverState.IsOpsOnly && !Authorized.HasAnyRole(HttpContext.Items, AuthorizationRoles.OpsAdminFull | AuthorizationRoles.OpsAdminLimited)))
|
||||
{
|
||||
return StatusCode(503, new ApiErrorResponse(ApiErrorCode.API_CLOSED, null, serverState.Reason));
|
||||
}
|
||||
|
||||
if (!Authorized.IsAuthorizedToRead(HttpContext.Items, AyaType.Metrics))
|
||||
{
|
||||
return StatusCode(401, new ApiNotAuthorizedResponse());
|
||||
}
|
||||
|
||||
string sResult = await GetTheMetrics("plain");
|
||||
|
||||
//Log
|
||||
EventLogProcessor.AddEntry(new Event(UserIdFromContext.Id(HttpContext.Items), 0, AyaType.Metrics, AyaEvent.Retrieved), ct);
|
||||
|
||||
return Content(sResult);
|
||||
}
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// Get metrics as json object
|
||||
///
|
||||
/// Required roles:
|
||||
/// OpsAdminFull | OpsAdminLimited
|
||||
/// </summary>
|
||||
/// <returns>Snapshot of metrics</returns>
|
||||
[HttpGet("JsonSnapShot")]
|
||||
public async Task<IActionResult> GetJsonMetrics()
|
||||
{
|
||||
//Open or opsOnly and user is opsadminfull or opsadminlimited
|
||||
if (!serverState.IsOpenOrOpsOnly || (serverState.IsOpsOnly && !Authorized.HasAnyRole(HttpContext.Items, AuthorizationRoles.OpsAdminFull | AuthorizationRoles.OpsAdminLimited)))
|
||||
{
|
||||
return StatusCode(503, new ApiErrorResponse(ApiErrorCode.API_CLOSED, null, serverState.Reason));
|
||||
}
|
||||
|
||||
if (!Authorized.IsAuthorizedToRead(HttpContext.Items, AyaType.Metrics))
|
||||
{
|
||||
return StatusCode(401, new ApiNotAuthorizedResponse());
|
||||
}
|
||||
|
||||
string sResult = await GetTheMetrics("json");
|
||||
JObject json = JObject.Parse(sResult);
|
||||
|
||||
//Log
|
||||
EventLogProcessor.AddEntry(new Event(UserIdFromContext.Id(HttpContext.Items), 0, AyaType.Metrics, AyaEvent.Retrieved), ct);
|
||||
|
||||
return Ok(new ApiOkResponse(json));
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Get the metrics snapshot
|
||||
/// </summary>
|
||||
/// <param name="format">Either "json" for json format or "plain" for plaintext format</param>
|
||||
/// <returns></returns>
|
||||
private async Task<string> GetTheMetrics(string format)
|
||||
{
|
||||
var snapshot = metrics.Snapshot.Get();
|
||||
|
||||
var formatters = ((IMetricsRoot)metrics).OutputMetricsFormatters;
|
||||
string sResult = $"ERROR GETTING METRICS IN {format} FORMAT";
|
||||
|
||||
foreach (var formatter in formatters)
|
||||
{
|
||||
if (formatter.MediaType.Format == format)
|
||||
{
|
||||
using (var stream = new MemoryStream())
|
||||
{
|
||||
await formatter.WriteAsync(stream, snapshot);
|
||||
sResult = System.Text.Encoding.UTF8.GetString(stream.ToArray());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return sResult;
|
||||
}
|
||||
|
||||
|
||||
//------------
|
||||
|
||||
|
||||
}
|
||||
}
|
||||
@@ -132,26 +132,7 @@ namespace AyaNova.Api.Controllers
|
||||
}
|
||||
});
|
||||
|
||||
// Newtonsoft.Json.Linq.JObject o = Newtonsoft.Json.Linq.JObject.FromObject(new
|
||||
// {
|
||||
// logs = new
|
||||
// {
|
||||
// licensedTo = ActiveKey.RegisteredTo,
|
||||
// registeredEmail = ActiveKey.FetchEmail,
|
||||
// trial = ActiveKey.Trial,
|
||||
// keySerial = ActiveKey.Id,
|
||||
// keySource = ActiveKey.Source,
|
||||
// created = ActiveKey.Created.ToString(),
|
||||
// features =
|
||||
// from f in files
|
||||
// orderby f
|
||||
// select new
|
||||
// {
|
||||
// logName = f
|
||||
// }
|
||||
// }
|
||||
// });
|
||||
|
||||
|
||||
|
||||
|
||||
return Ok(new ApiOkResponse(o));
|
||||
|
||||
Reference in New Issue
Block a user