using Amazon.CloudWatchLogs;
using Amazon.CloudWatchLogs.Model;
using Amazon.Runtime;
using API_Infrastructure.DBHelpers;
using API_Infrastructure.Interfaces;
using API_Models.dbModels;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Linq;
using System.Threading.Tasks;
namespace API_Infrastructure.Helper
{
public class CloudWatcherLogger
{
private string LogMode;
private string LogGroupName;
private AmazonCloudWatchLogsClient LogClient;
private string _nextSequenceToken = null;
private string _logStream;
private string accessKey = ConfigurationManager.AppSettings["AccessKey"];
private string secretKey = ConfigurationManager.AppSettings["SecretKey"];
private string regionName = ConfigurationManager.AppSettings["RegionName"];
public CloudWatcherLogger()
{
this.LogMode = ConfigurationManager.AppSettings["LogMode"] ?? "DB";
this.LogGroupName = ConfigurationManager.AppSettings["LogGroupName"] ?? "/development/opensparkz/logs";
this.LogClient = new AmazonCloudWatchLogsClient();
}
public static CloudWatcherLogger GetLogger()
{
var logger = new CloudWatcherLogger();
// Create a log group for our logger
logger.CreateLogGroup();
// Create a log stream
logger.CreateLogStream();
return logger;
}
/// <summary>
/// Logs the data into cloud watch.
/// </summary>
/// <param name="json">String json to log.</param>
public async Task LogData(string json)
{
try
{
var response = await this.LogClient.PutLogEventsAsync(new PutLogEventsRequest()
{
LogGroupName = this.LogGroupName,
LogStreamName = _logStream,
LogEvents = new List<InputLogEvent>()
{
new InputLogEvent()
{
Message = json,
Timestamp = DateTime.UtcNow
}
},
SequenceToken = _nextSequenceToken
});
this._nextSequenceToken = response.NextSequenceToken;
}
catch (Exception)
{
}
}
private void CreateLogStream()
{
this._logStream = DateTime.UtcNow.ToString("yyyyMMddHHmmssfff");
this.LogClient.CreateLogStream(new CreateLogStreamRequest(this.LogGroupName, this._logStream));
}
private void CreateLogGroup()
{
try
{
var existing = this.LogClient.DescribeLogGroups(new DescribeLogGroupsRequest() { LogGroupNamePrefix = this.LogGroupName });
var logGroupExists = existing.LogGroups.Any(l => l.LogGroupName == this.LogGroupName);
if (!logGroupExists)
this.LogClient.CreateLogGroup(new CreateLogGroupRequest(this.LogGroupName));
}
catch (Exception ex)
{
throw ex;
}
}
}
}
