123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154 |
- using Aip.Service.Models.Dto;
- using Aip.Service.Models.Response;
- using Aip.Service.Repositories;
- using Aip.Service.Services.Interfaces;
- using Microsoft.AspNetCore.Mvc;
- using Swashbuckle.AspNetCore.Annotations;
- using System.ComponentModel.DataAnnotations;
- namespace Aip.Service.Controllers;
- [ApiController]
- [Route("/api/v1/db")]
- [Produces("application/json")]
- public class ApiDbController : BaseController
- {
- private readonly ILogger<ApiDbController> _log;
- private readonly IApiAuthService _authService;
- private readonly IApiDbService _service;
- public ApiDbController(ILogger<ApiDbController> log, IApiAuthService authService, IApiDbService apiDbService)
- {
- _log = log;
- _authService = authService;
- _service = apiDbService;
- }
- [HttpPost("reload")]
- [SwaggerResponse(200, type: typeof(ApiResponseModel<GeneralResponse>))]
- public async Task<IResult> ReloadDatabase([Required] string apiKey)
- {
- return await CreateResponseAsync(async () =>
- {
- GlobalConstants.SetAuthorization(HttpContext, GlobalConstants.API_DB_RELOAD, apiKey, null);
- int authError = _authService.CheckApiKeyValidation(HttpContext, apiKey, GlobalConstants.API_DB_RELOAD);
- if (authError != 0)
- {
- throw ResponseApiKeyValidationError(HttpContext, authError);
- }
- var response = await _service.ReloadDatabase();
- var result = Results.Ok(ResponseSuccess(HttpContext, response));
- HttpContext.Items[GlobalConstants.API_RESULT] = result;
- return result;
- });
- }
- [HttpGet("linked-systems")]
- [SwaggerResponse(200, type: typeof(ApiResponseModel<List<LinkedSystemDto>>))]
- public async Task<IResult> GetDbLinkedSystems([Required] string apiKey)
- {
- return await CreateResponseAsync(async () =>
- {
- GlobalConstants.SetAuthorization(HttpContext, GlobalConstants.API_DB_LINKED_SYSTEMS, apiKey, null);
- int authError = _authService.CheckApiKeyValidation(HttpContext, apiKey, GlobalConstants.API_DB_LINKED_SYSTEMS);
- if (authError != 0)
- {
- throw ResponseApiKeyValidationError(HttpContext, authError);
- }
- var response = await _service.GetLinkedSystems();
- var result = Results.Ok(new ApiResponseModel<List<LinkedSystemDto>>()
- {
- success = true,
- errorCode = 0,
- errorMessage = GlobalConstants.API_RESULT_SUCCESS,
- result = response,
- });
- HttpContext.Items[GlobalConstants.API_RESULT_CODE] = GlobalConstants.API_RESULT_SUCCESS_CODE;
- HttpContext.Items[GlobalConstants.API_RESULT_MESSAGE] = GlobalConstants.API_RESULT_SUCCESS;
- HttpContext.Items[GlobalConstants.API_RESULT] = result;
- return result;
- });
- }
- [HttpGet("linked-servers")]
- [SwaggerResponse(200, type: typeof(ApiResponseModel<List<LinkedServerDto>>))]
- public async Task<IResult> GetDbLinkedServers([Required] string apiKey)
- {
- return await CreateResponseAsync(async () =>
- {
- GlobalConstants.SetAuthorization(HttpContext, GlobalConstants.API_DB_LINKED_SERVERS, apiKey, null);
- int authError = _authService.CheckApiKeyValidation(HttpContext, apiKey, GlobalConstants.API_DB_LINKED_SERVERS);
- if (authError != 0)
- {
- throw ResponseApiKeyValidationError(HttpContext, authError);
- }
- var response = await _service.GetLinkedServers();
- var result = Results.Ok(new ApiResponseModel<List<LinkedServerDto>>()
- {
- success = true,
- errorCode = 0,
- errorMessage = GlobalConstants.API_RESULT_SUCCESS,
- result = response,
- });
- HttpContext.Items[GlobalConstants.API_RESULT_CODE] = GlobalConstants.API_RESULT_SUCCESS_CODE;
- HttpContext.Items[GlobalConstants.API_RESULT_MESSAGE] = GlobalConstants.API_RESULT_SUCCESS;
- HttpContext.Items[GlobalConstants.API_RESULT] = result;
- return result;
- });
- }
- [HttpGet("linked-api-keys")]
- [SwaggerResponse(200, type: typeof(ApiResponseModel<List<LinkedApiKeyDto>>))]
- public async Task<IResult> GetDbLinkedApiKeys([Required] string apiKey)
- {
- return await CreateResponseAsync(async () =>
- {
- GlobalConstants.SetAuthorization(HttpContext, GlobalConstants.API_DB_LINKED_API_KEYS, apiKey, null);
- int authError = _authService.CheckApiKeyValidation(HttpContext, apiKey, GlobalConstants.API_DB_LINKED_API_KEYS);
- if (authError != 0)
- {
- throw ResponseApiKeyValidationError(HttpContext, authError);
- }
- var response = await _service.GetLinkedApiKeys();
- var result = Results.Ok(new ApiResponseModel<List<LinkedApiKeyDto>>()
- {
- success = true,
- errorCode = 0,
- errorMessage = GlobalConstants.API_RESULT_SUCCESS,
- result = response,
- });
- HttpContext.Items[GlobalConstants.API_RESULT_CODE] = GlobalConstants.API_RESULT_SUCCESS_CODE;
- HttpContext.Items[GlobalConstants.API_RESULT_MESSAGE] = GlobalConstants.API_RESULT_SUCCESS;
- HttpContext.Items[GlobalConstants.API_RESULT] = result;
- return result;
- });
- }
- [HttpGet("linked-decrypt-keys")]
- [SwaggerResponse(200, type: typeof(ApiResponseModel<List<LinkedDecryptKeyDto>>))]
- public async Task<IResult> GetDbLinkedDecryptKeys([Required] string apiKey)
- {
- return await CreateResponseAsync(async () =>
- {
- GlobalConstants.SetAuthorization(HttpContext, GlobalConstants.API_DB_LINKED_DECRYPT_KEYS, apiKey, null);
- int authError = _authService.CheckApiKeyValidation(HttpContext, apiKey, GlobalConstants.API_DB_LINKED_DECRYPT_KEYS);
- if (authError != 0)
- {
- throw ResponseApiKeyValidationError(HttpContext, authError);
- }
- var response = await _service.GetLinkedDecryptKeys();
- var result = Results.Ok(new ApiResponseModel<List<LinkedDecryptKeyDto>>()
- {
- success = true,
- errorCode = 0,
- errorMessage = GlobalConstants.API_RESULT_SUCCESS,
- result = response,
- });
- HttpContext.Items[GlobalConstants.API_RESULT_CODE] = GlobalConstants.API_RESULT_SUCCESS_CODE;
- HttpContext.Items[GlobalConstants.API_RESULT_MESSAGE] = GlobalConstants.API_RESULT_SUCCESS;
- HttpContext.Items[GlobalConstants.API_RESULT] = result;
- return result;
- });
- }
- }
|