diff --git a/.editorconfig b/.editorconfig
new file mode 100644
index 0000000..0e6020c
--- /dev/null
+++ b/.editorconfig
@@ -0,0 +1,273 @@
+# Remove the line below if you want to inherit .editorconfig settings from higher directories
+root = true
+
+# C# files
+[*.cs]
+
+#### Core EditorConfig Options ####
+
+# Indentation and spacing
+indent_size = 4
+indent_style = space
+tab_width = 4
+
+# New line preferences
+end_of_line = crlf
+insert_final_newline = false
+
+#### .NET Coding Conventions ####
+
+# Organize usings
+dotnet_separate_import_directive_groups = false
+dotnet_sort_system_directives_first = false
+file_header_template = unset
+
+# this. and Me. preferences
+dotnet_style_qualification_for_event = false
+dotnet_style_qualification_for_field = false
+dotnet_style_qualification_for_method = false
+dotnet_style_qualification_for_property = false
+
+# Language keywords vs BCL types preferences
+dotnet_style_predefined_type_for_locals_parameters_members = true
+dotnet_style_predefined_type_for_member_access = true
+
+# Parentheses preferences
+dotnet_style_parentheses_in_arithmetic_binary_operators = always_for_clarity
+dotnet_style_parentheses_in_other_binary_operators = always_for_clarity
+dotnet_style_parentheses_in_other_operators = never_if_unnecessary
+dotnet_style_parentheses_in_relational_binary_operators = always_for_clarity
+
+# Modifier preferences
+dotnet_style_require_accessibility_modifiers = for_non_interface_members
+
+# Expression-level preferences
+dotnet_style_coalesce_expression = true
+dotnet_style_collection_initializer = true
+dotnet_style_explicit_tuple_names = true
+dotnet_style_namespace_match_folder = true
+dotnet_style_null_propagation = true
+dotnet_style_object_initializer = true
+dotnet_style_operator_placement_when_wrapping = beginning_of_line
+dotnet_style_prefer_auto_properties = true
+dotnet_style_prefer_collection_expression = when_types_loosely_match
+dotnet_style_prefer_compound_assignment = true
+dotnet_style_prefer_conditional_expression_over_assignment = true
+dotnet_style_prefer_conditional_expression_over_return = true
+dotnet_style_prefer_foreach_explicit_cast_in_source = when_strongly_typed
+dotnet_style_prefer_inferred_anonymous_type_member_names = true
+dotnet_style_prefer_inferred_tuple_names = true
+dotnet_style_prefer_is_null_check_over_reference_equality_method = true
+dotnet_style_prefer_simplified_boolean_expressions = true
+dotnet_style_prefer_simplified_interpolation = true
+
+# Field preferences
+dotnet_style_readonly_field = true
+
+# Parameter preferences
+dotnet_code_quality_unused_parameters = all
+
+# Suppression preferences
+dotnet_remove_unnecessary_suppression_exclusions = none
+
+# New line preferences
+dotnet_style_allow_multiple_blank_lines_experimental = true
+dotnet_style_allow_statement_immediately_after_block_experimental = true
+
+#### C# Coding Conventions ####
+
+# var preferences
+csharp_style_var_elsewhere = false:silent
+csharp_style_var_for_built_in_types = false:silent
+csharp_style_var_when_type_is_apparent = false:silent
+
+# Expression-bodied members
+csharp_style_expression_bodied_accessors = true:silent
+csharp_style_expression_bodied_constructors = false:silent
+csharp_style_expression_bodied_indexers = true:silent
+csharp_style_expression_bodied_lambdas = true:silent
+csharp_style_expression_bodied_local_functions = false:silent
+csharp_style_expression_bodied_methods = false:silent
+csharp_style_expression_bodied_operators = false:silent
+csharp_style_expression_bodied_properties = true:silent
+
+# Pattern matching preferences
+csharp_style_pattern_matching_over_as_with_null_check = true:suggestion
+csharp_style_pattern_matching_over_is_with_cast_check = true:suggestion
+csharp_style_prefer_extended_property_pattern = true:suggestion
+csharp_style_prefer_not_pattern = true:suggestion
+csharp_style_prefer_pattern_matching = true:silent
+csharp_style_prefer_switch_expression = true:suggestion
+
+# Null-checking preferences
+csharp_style_conditional_delegate_call = true:suggestion
+
+# Modifier preferences
+csharp_prefer_static_local_function = true:suggestion
+csharp_preferred_modifier_order = public,private,protected,internal,file,static,extern,new,virtual,abstract,sealed,override,readonly,unsafe,required,volatile,async
+csharp_style_prefer_readonly_struct = true:suggestion
+csharp_style_prefer_readonly_struct_member = true:suggestion
+
+# Code-block preferences
+csharp_prefer_braces = true:silent
+csharp_prefer_simple_using_statement = true:suggestion
+csharp_style_namespace_declarations = file_scoped:silent
+csharp_style_prefer_method_group_conversion = true:silent
+csharp_style_prefer_primary_constructors = false:none
+csharp_style_prefer_top_level_statements = true:silent
+
+# Expression-level preferences
+csharp_prefer_simple_default_expression = true:suggestion
+csharp_style_deconstructed_variable_declaration = true:suggestion
+csharp_style_implicit_object_creation_when_type_is_apparent = true:suggestion
+csharp_style_inlined_variable_declaration = true:suggestion
+csharp_style_prefer_index_operator = true:suggestion
+csharp_style_prefer_local_over_anonymous_function = true:suggestion
+csharp_style_prefer_null_check_over_type_check = true:suggestion
+csharp_style_prefer_range_operator = true:suggestion
+csharp_style_prefer_tuple_swap = true:suggestion
+csharp_style_prefer_utf8_string_literals = true:suggestion
+csharp_style_throw_expression = true:suggestion
+csharp_style_unused_value_assignment_preference = discard_variable:suggestion
+csharp_style_unused_value_expression_statement_preference = discard_variable:silent
+
+# 'using' directive preferences
+csharp_using_directive_placement = outside_namespace:silent
+
+# New line preferences
+csharp_style_allow_blank_line_after_colon_in_constructor_initializer_experimental = true:silent
+csharp_style_allow_blank_line_after_token_in_arrow_expression_clause_experimental = true:silent
+csharp_style_allow_blank_line_after_token_in_conditional_expression_experimental = true:silent
+csharp_style_allow_blank_lines_between_consecutive_braces_experimental = true:silent
+csharp_style_allow_embedded_statements_on_same_line_experimental = true:silent
+
+#### C# Formatting Rules ####
+
+# New line preferences
+csharp_new_line_before_catch = true
+csharp_new_line_before_else = true
+csharp_new_line_before_finally = true
+csharp_new_line_before_members_in_anonymous_types = true
+csharp_new_line_before_members_in_object_initializers = true
+csharp_new_line_before_open_brace = all
+csharp_new_line_between_query_expression_clauses = true
+
+# Indentation preferences
+csharp_indent_block_contents = true
+csharp_indent_braces = false
+csharp_indent_case_contents = true
+csharp_indent_case_contents_when_block = true
+csharp_indent_labels = one_less_than_current
+csharp_indent_switch_labels = true
+
+# Space preferences
+csharp_space_after_cast = false
+csharp_space_after_colon_in_inheritance_clause = true
+csharp_space_after_comma = true
+csharp_space_after_dot = false
+csharp_space_after_keywords_in_control_flow_statements = true
+csharp_space_after_semicolon_in_for_statement = true
+csharp_space_around_binary_operators = before_and_after
+csharp_space_around_declaration_statements = false
+csharp_space_before_colon_in_inheritance_clause = true
+csharp_space_before_comma = false
+csharp_space_before_dot = false
+csharp_space_before_open_square_brackets = false
+csharp_space_before_semicolon_in_for_statement = false
+csharp_space_between_empty_square_brackets = false
+csharp_space_between_method_call_empty_parameter_list_parentheses = false
+csharp_space_between_method_call_name_and_opening_parenthesis = false
+csharp_space_between_method_call_parameter_list_parentheses = false
+csharp_space_between_method_declaration_empty_parameter_list_parentheses = false
+csharp_space_between_method_declaration_name_and_open_parenthesis = false
+csharp_space_between_method_declaration_parameter_list_parentheses = false
+csharp_space_between_parentheses = false
+csharp_space_between_square_brackets = false
+
+# Wrapping preferences
+csharp_preserve_single_line_blocks = true
+csharp_preserve_single_line_statements = true
+
+#### Naming styles ####
+
+# Naming rules
+
+dotnet_naming_rule.interface_should_be_begins_with_i.severity = suggestion
+dotnet_naming_rule.interface_should_be_begins_with_i.symbols = interface
+dotnet_naming_rule.interface_should_be_begins_with_i.style = begins_with_i
+
+dotnet_naming_rule.types_should_be_pascal_case.severity = suggestion
+dotnet_naming_rule.types_should_be_pascal_case.symbols = types
+dotnet_naming_rule.types_should_be_pascal_case.style = pascal_case
+
+dotnet_naming_rule.non_field_members_should_be_pascal_case.severity = suggestion
+dotnet_naming_rule.non_field_members_should_be_pascal_case.symbols = non_field_members
+dotnet_naming_rule.non_field_members_should_be_pascal_case.style = pascal_case
+
+# Symbol specifications
+
+dotnet_naming_symbols.interface.applicable_kinds = interface
+dotnet_naming_symbols.interface.applicable_accessibilities = public, internal, private, protected, protected_internal, private_protected
+dotnet_naming_symbols.interface.required_modifiers =
+
+dotnet_naming_symbols.types.applicable_kinds = class, struct, interface, enum
+dotnet_naming_symbols.types.applicable_accessibilities = public, internal, private, protected, protected_internal, private_protected
+dotnet_naming_symbols.types.required_modifiers =
+
+dotnet_naming_symbols.non_field_members.applicable_kinds = property, event, method
+dotnet_naming_symbols.non_field_members.applicable_accessibilities = public, internal, private, protected, protected_internal, private_protected
+dotnet_naming_symbols.non_field_members.required_modifiers =
+
+# Naming styles
+
+dotnet_naming_style.pascal_case.required_prefix =
+dotnet_naming_style.pascal_case.required_suffix =
+dotnet_naming_style.pascal_case.word_separator =
+dotnet_naming_style.pascal_case.capitalization = pascal_case
+
+dotnet_naming_style.begins_with_i.required_prefix = I
+dotnet_naming_style.begins_with_i.required_suffix =
+dotnet_naming_style.begins_with_i.word_separator =
+dotnet_naming_style.begins_with_i.capitalization = pascal_case
+
+# Spell check
+
+spelling_languages = en-us,ru-RU
+spelling_exclusion_path = exclusion.dic
+
+[*.{cs,vb}]
+dotnet_style_operator_placement_when_wrapping = beginning_of_line
+tab_width = 4
+indent_size = 4
+end_of_line = crlf
+dotnet_style_coalesce_expression = true:suggestion
+dotnet_style_null_propagation = true:suggestion
+dotnet_style_prefer_is_null_check_over_reference_equality_method = true:suggestion
+dotnet_style_prefer_auto_properties = true:silent
+dotnet_style_object_initializer = true:suggestion
+dotnet_style_collection_initializer = true:suggestion
+dotnet_style_prefer_simplified_boolean_expressions = true:suggestion
+dotnet_style_prefer_conditional_expression_over_assignment = true:silent
+dotnet_style_prefer_conditional_expression_over_return = true:silent
+dotnet_style_explicit_tuple_names = true:suggestion
+dotnet_style_prefer_inferred_tuple_names = true:suggestion
+dotnet_style_prefer_inferred_anonymous_type_member_names = true:suggestion
+dotnet_style_prefer_compound_assignment = true:suggestion
+dotnet_style_prefer_simplified_interpolation = true:suggestion
+dotnet_style_prefer_collection_expression = when_types_loosely_match:suggestion
+dotnet_style_namespace_match_folder = true:suggestion
+dotnet_code_quality_unused_parameters = all:suggestion
+dotnet_style_predefined_type_for_locals_parameters_members = true:silent
+dotnet_style_predefined_type_for_member_access = true:silent
+dotnet_style_qualification_for_field = false:silent
+dotnet_style_qualification_for_property = false:silent
+dotnet_style_qualification_for_method = false:silent
+dotnet_style_qualification_for_event = false:silent
+dotnet_style_allow_multiple_blank_lines_experimental = true:silent
+dotnet_style_allow_statement_immediately_after_block_experimental = true:silent
+dotnet_style_readonly_field = true:suggestion
+dotnet_style_parentheses_in_arithmetic_binary_operators = always_for_clarity:silent
+dotnet_style_parentheses_in_other_binary_operators = always_for_clarity:silent
+dotnet_style_parentheses_in_relational_binary_operators = always_for_clarity:silent
+dotnet_style_parentheses_in_other_operators = never_if_unnecessary:silent
+dotnet_style_require_accessibility_modifiers = for_non_interface_members:silent
\ No newline at end of file
diff --git a/Persistence.API/Controllers/ChangeLogController.cs b/Persistence.API/Controllers/ChangeLogController.cs
index 52a68dd..72f0b08 100644
--- a/Persistence.API/Controllers/ChangeLogController.cs
+++ b/Persistence.API/Controllers/ChangeLogController.cs
@@ -12,7 +12,7 @@ namespace Persistence.API.Controllers;
[Route("api/[controller]")]
public class ChangeLogController : ControllerBase, IChangeLogApi
{
- private IChangeLogRepository repository;
+ private readonly IChangeLogRepository repository;
public ChangeLogController(IChangeLogRepository repository)
{
diff --git a/Persistence.API/Controllers/DataSaubController.cs b/Persistence.API/Controllers/DataSaubController.cs
index 202e527..715b1ef 100644
--- a/Persistence.API/Controllers/DataSaubController.cs
+++ b/Persistence.API/Controllers/DataSaubController.cs
@@ -1,7 +1,7 @@
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
+using Persistence.Models;
using Persistence.Repositories;
-using Persistence.Repository.Data;
namespace Persistence.API.Controllers;
diff --git a/Persistence.API/Controllers/SetpointController.cs b/Persistence.API/Controllers/SetpointController.cs
index 42a5ff5..c374d9e 100644
--- a/Persistence.API/Controllers/SetpointController.cs
+++ b/Persistence.API/Controllers/SetpointController.cs
@@ -1,8 +1,8 @@
-using System.Net;
-using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Persistence.Models;
using Persistence.Repositories;
+using System.Net;
namespace Persistence.API.Controllers;
@@ -14,99 +14,98 @@ namespace Persistence.API.Controllers;
[Route("api/[controller]")]
public class SetpointController : ControllerBase, ISetpointApi
{
- private readonly ISetpointRepository setpointRepository;
+ private readonly ISetpointRepository setpointRepository;
- public SetpointController(ISetpointRepository setpointRepository)
- {
- this.setpointRepository = setpointRepository;
- }
+ public SetpointController(ISetpointRepository setpointRepository)
+ {
+ this.setpointRepository = setpointRepository;
+ }
- ///
- /// Получить актуальные значения уставок
- ///
- ///
- ///
- ///
- [HttpGet("current")]
- public async Task>> GetCurrent([FromQuery] IEnumerable setpointKeys, CancellationToken token)
- {
- var result = await setpointRepository.GetCurrent(setpointKeys, token);
+ ///
+ /// Получить актуальные значения уставок
+ ///
+ ///
+ ///
+ ///
+ [HttpGet("current")]
+ public async Task>> GetCurrent([FromQuery] IEnumerable setpointKeys, CancellationToken token)
+ {
+ var result = await setpointRepository.GetCurrent(setpointKeys, token);
- return Ok(result);
- }
+ return Ok(result);
+ }
- ///
- /// Получить значения уставок за определенный момент времени
- ///
- ///
- ///
- ///
- ///
- [HttpGet("history")]
- public async Task>> GetHistory([FromQuery] IEnumerable setpointKeys, [FromQuery] DateTimeOffset historyMoment, CancellationToken token)
- {
- var result = await setpointRepository.GetHistory(setpointKeys, historyMoment, token);
+ ///
+ /// Получить значения уставок за определенный момент времени
+ ///
+ ///
+ ///
+ ///
+ ///
+ [HttpGet("history")]
+ public async Task>> GetHistory([FromQuery] IEnumerable setpointKeys, [FromQuery] DateTimeOffset historyMoment, CancellationToken token)
+ {
+ var result = await setpointRepository.GetHistory(setpointKeys, historyMoment, token);
- return Ok(result);
- }
+ return Ok(result);
+ }
- ///
- /// Получить историю изменений значений уставок
- ///
- ///
- ///
- ///
- [HttpGet("log")]
- public async Task>>> GetLog([FromQuery] IEnumerable setpointKeys, CancellationToken token)
- {
- var result = await setpointRepository.GetLog(setpointKeys, token);
+ ///
+ /// Получить историю изменений значений уставок
+ ///
+ ///
+ ///
+ ///
+ [HttpGet("log")]
+ public async Task>>> GetLog([FromQuery] IEnumerable setpointKeys, CancellationToken token)
+ {
+ var result = await setpointRepository.GetLog(setpointKeys, token);
- return Ok(result);
- }
+ return Ok(result);
+ }
- ///
- /// Получить диапазон дат, для которых есть данные в репозитории
- ///
- ///
- ///
- [HttpGet("range")]
- public async Task> GetDatesRangeAsync(CancellationToken token)
- {
- var result = await setpointRepository.GetDatesRangeAsync(token);
+ ///
+ /// Получить диапазон дат, для которых есть данные в репозитории
+ ///
+ ///
+ ///
+ [HttpGet("range")]
+ public async Task> GetDatesRangeAsync(CancellationToken token)
+ {
+ var result = await setpointRepository.GetDatesRangeAsync(token);
- return Ok(result);
- }
+ return Ok(result);
+ }
- ///
- /// Получить порцию записей, начиная с заданной даты
- ///
- ///
- ///
- ///
- ///
- [HttpGet("part")]
- public async Task>> GetPart(DateTimeOffset dateBegin, int take, CancellationToken token)
- {
- var result = await setpointRepository.GetPart(dateBegin, take, token);
+ ///
+ /// Получить порцию записей, начиная с заданной даты
+ ///
+ ///
+ ///
+ ///
+ ///
+ [HttpGet("part")]
+ public async Task>> GetPart(DateTimeOffset dateBegin, int take, CancellationToken token)
+ {
+ var result = await setpointRepository.GetPart(dateBegin, take, token);
- return Ok(result);
- }
+ return Ok(result);
+ }
- ///
- /// Сохранить уставку
- ///
- ///
- ///
- ///
- ///
- ///
- [HttpPost]
- [ProducesResponseType(typeof(int), (int)HttpStatusCode.Created)]
- public async Task Add(Guid setpointKey, object newValue, CancellationToken token)
- {
- var userId = User.GetUserId();
- await setpointRepository.Add(setpointKey, newValue, userId, token);
+ ///
+ /// Сохранить уставку
+ ///
+ ///
+ ///
+ ///
+ ///
+ [HttpPost]
+ [ProducesResponseType(typeof(int), (int)HttpStatusCode.Created)]
+ public async Task Add(Guid setpointKey, object newValue, CancellationToken token)
+ {
+ var userId = User.GetUserId();
+ await setpointRepository.Add(setpointKey, newValue, userId, token);
- return CreatedAtAction(nameof(Add), true);
- }
+ return CreatedAtAction(nameof(Add), true);
+ }
}
diff --git a/Persistence.API/Controllers/TechMessagesController.cs b/Persistence.API/Controllers/TechMessagesController.cs
index a7b0094..10efb04 100644
--- a/Persistence.API/Controllers/TechMessagesController.cs
+++ b/Persistence.API/Controllers/TechMessagesController.cs
@@ -1,129 +1,129 @@
-using System.Net;
-using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Persistence.Models;
using Persistence.Models.Requests;
using Persistence.Repositories;
+using System.Net;
namespace Persistence.API.Controllers;
///
-/// Работа с состояниями систем автобурения (АБ)
+/// Работа с технологическими сообщениями систем автобурения (АБ)
///
[ApiController]
[Authorize]
[Route("api/[controller]")]
public class TechMessagesController : ControllerBase
{
- private readonly ITechMessagesRepository techMessagesRepository;
- private static readonly Dictionary categories = new Dictionary()
- {
- { 0, "System" },
- { 1, "Авария" },
- { 2, "Предупреждение" },
- { 3, "Инфо" },
- { 4, "Прочее" }
- };
+ private readonly ITechMessagesRepository techMessagesRepository;
+ private static readonly Dictionary categories = new()
+ {
+ { 0, "System" },
+ { 1, "Авария" },
+ { 2, "Предупреждение" },
+ { 3, "Инфо" },
+ { 4, "Прочее" }
+ };
- public TechMessagesController(ITechMessagesRepository techMessagesRepository)
- {
- this.techMessagesRepository = techMessagesRepository;
- }
+ public TechMessagesController(ITechMessagesRepository techMessagesRepository)
+ {
+ this.techMessagesRepository = techMessagesRepository;
+ }
- ///
- /// Получить список технологических сообщений в виде страницы
- ///
- ///
- ///
- ///
- [HttpGet]
- public async Task>> GetPage([FromQuery] PaginationRequest request, CancellationToken token)
- {
- var result = await techMessagesRepository.GetPage(request, token);
+ ///
+ /// Получить список технологических сообщений в виде страницы
+ ///
+ ///
+ ///
+ ///
+ [HttpGet]
+ public async Task>> GetPage([FromQuery] PaginationRequest request, CancellationToken token)
+ {
+ var result = await techMessagesRepository.GetPage(request, token);
- return Ok(result);
- }
+ return Ok(result);
+ }
- ///
- /// Получить статистику по системам
- ///
- ///
- ///
- ///
- ///
- [HttpGet("statistics")]
- public async Task>> GetStatistics([FromQuery] IEnumerable autoDrillingSystem, [FromQuery] IEnumerable categoryIds, CancellationToken token)
- {
- var result = await techMessagesRepository.GetStatistics(autoDrillingSystem, categoryIds, token);
+ ///
+ /// Получить статистику по системам
+ ///
+ ///
+ ///
+ ///
+ ///
+ [HttpGet("statistics")]
+ public async Task>> GetStatistics([FromQuery] IEnumerable autoDrillingSystem, [FromQuery] IEnumerable categoryIds, CancellationToken token)
+ {
+ var result = await techMessagesRepository.GetStatistics(autoDrillingSystem, categoryIds, token);
- return Ok(result);
- }
+ return Ok(result);
+ }
- ///
- /// Получить список всех систем
- ///
- ///
- ///
- [HttpGet("systems")]
- public async Task>> GetSystems(CancellationToken token)
- {
- var result = await techMessagesRepository.GetSystems(token);
+ ///
+ /// Получить список всех систем
+ ///
+ ///
+ ///
+ [HttpGet("systems")]
+ public async Task>> GetSystems(CancellationToken token)
+ {
+ var result = await techMessagesRepository.GetSystems(token);
- return Ok(result);
- }
+ return Ok(result);
+ }
- ///
- /// Получить диапазон дат, для которых есть данные в репозитории
- ///
- ///
- ///
- [HttpGet("range")]
- public async Task> GetDatesRangeAsync(CancellationToken token)
- {
- var result = await techMessagesRepository.GetDatesRangeAsync(token);
+ ///
+ /// Получить диапазон дат, для которых есть данные в репозитории
+ ///
+ ///
+ ///
+ [HttpGet("range")]
+ public async Task> GetDatesRangeAsync(CancellationToken token)
+ {
+ var result = await techMessagesRepository.GetDatesRangeAsync(token);
- return Ok(result);
- }
+ return Ok(result);
+ }
- ///
- /// Получить порцию записей, начиная с заданной даты
- ///
- ///
- ///
- ///
- ///
- [HttpGet("part")]
- public async Task>> GetPart(DateTimeOffset dateBegin, int take, CancellationToken token)
- {
- var result = await techMessagesRepository.GetPart(dateBegin, take, token);
+ ///
+ /// Получить порцию записей, начиная с заданной даты
+ ///
+ ///
+ ///
+ ///
+ ///
+ [HttpGet("part")]
+ public async Task>> GetPart(DateTimeOffset dateBegin, int take, CancellationToken token)
+ {
+ var result = await techMessagesRepository.GetPart(dateBegin, take, token);
- return Ok(result);
- }
+ return Ok(result);
+ }
- ///
- /// Добавить новые технологические сообщения
- ///
- ///
- ///
- ///
- [HttpPost]
- [ProducesResponseType(typeof(int), (int)HttpStatusCode.Created)]
- public async Task AddRange([FromBody] IEnumerable dtos, CancellationToken token)
- {
- var userId = User.GetUserId();
+ ///
+ /// Добавить новые технологические сообщения
+ ///
+ ///
+ ///
+ ///
+ [HttpPost]
+ [ProducesResponseType(typeof(int), (int)HttpStatusCode.Created)]
+ public async Task AddRange([FromBody] IEnumerable dtos, CancellationToken token)
+ {
+ var userId = User.GetUserId();
var result = await techMessagesRepository.AddRange(dtos, userId, token);
- return CreatedAtAction(nameof(AddRange), result);
- }
+ return CreatedAtAction(nameof(AddRange), result);
+ }
- ///
- /// Получить словарь категорий
- ///
- ///
- [HttpGet("categories")]
- public ActionResult> GetImportantCategories()
- {
- return Ok(categories);
- }
+ ///
+ /// Получить словарь категорий
+ ///
+ ///
+ [HttpGet("categories")]
+ public ActionResult> GetImportantCategories()
+ {
+ return Ok(categories);
+ }
}
\ No newline at end of file
diff --git a/Persistence.API/Controllers/TimeSeriesController.cs b/Persistence.API/Controllers/TimeSeriesController.cs
index 6991759..f13c641 100644
--- a/Persistence.API/Controllers/TimeSeriesController.cs
+++ b/Persistence.API/Controllers/TimeSeriesController.cs
@@ -11,20 +11,20 @@ namespace Persistence.API.Controllers;
public class TimeSeriesController : ControllerBase, ITimeSeriesDataApi
where TDto : class, ITimeSeriesAbstractDto, new()
{
- private ITimeSeriesDataRepository timeSeriesDataRepository;
+ private readonly ITimeSeriesDataRepository timeSeriesDataRepository;
- public TimeSeriesController(ITimeSeriesDataRepository timeSeriesDataRepository)
- {
- this.timeSeriesDataRepository = timeSeriesDataRepository;
+ public TimeSeriesController(ITimeSeriesDataRepository timeSeriesDataRepository)
+ {
+ this.timeSeriesDataRepository = timeSeriesDataRepository;
}
- ///
- /// Получить список объектов, удовлетворяющий диапазону дат
- ///
- ///
- ///
- ///
- [HttpGet]
+ ///
+ /// Получить список объектов, удовлетворяющий диапазону дат
+ ///
+ ///
+ ///
+ ///
+ [HttpGet]
[ProducesResponseType(StatusCodes.Status200OK)]
public async Task Get(DateTimeOffset dateBegin, CancellationToken token)
{
@@ -32,40 +32,40 @@ public class TimeSeriesController : ControllerBase, ITimeSeriesDataApi
- /// Получить диапазон дат, для которых есть данные в репозиторие
- ///
- ///
- ///
- [HttpGet("datesRange")]
+ ///
+ /// Получить диапазон дат, для которых есть данные в репозитории
+ ///
+ ///
+ ///
+ [HttpGet("datesRange")]
public async Task GetDatesRange(CancellationToken token)
{
var result = await timeSeriesDataRepository.GetDatesRange(token);
return Ok(result);
}
- ///
- /// Получить список объектов с прореживанием, удовлетворяющий диапазону дат
- ///
- ///
- ///
- ///
- ///
- ///
- [HttpGet("resampled")]
+ ///
+ /// Получить список объектов с прореживанием, удовлетворяющий диапазону дат
+ ///
+ ///
+ ///
+ ///
+ ///
+ ///
+ [HttpGet("resampled")]
public async Task GetResampledData(DateTimeOffset dateBegin, double intervalSec = 600d, int approxPointsCount = 1024, CancellationToken token = default)
{
var result = await timeSeriesDataRepository.GetResampledData(dateBegin, intervalSec, approxPointsCount, token);
return Ok(result);
}
- ///
- /// Добавить записи
- ///
- ///
- ///
- ///
- [HttpPost]
+ ///
+ /// Добавить записи
+ ///
+ ///
+ ///
+ ///
+ [HttpPost]
public async Task AddRange(IEnumerable dtos, CancellationToken token)
{
var result = await timeSeriesDataRepository.AddRange(dtos, token);
diff --git a/Persistence.API/Controllers/TimestampedSetController.cs b/Persistence.API/Controllers/TimestampedSetController.cs
index bd0e97e..4687e72 100644
--- a/Persistence.API/Controllers/TimestampedSetController.cs
+++ b/Persistence.API/Controllers/TimestampedSetController.cs
@@ -13,7 +13,7 @@ namespace Persistence.API.Controllers;
[ApiController]
[Authorize]
[Route("api/[controller]/{idDiscriminator}")]
-public class TimestampedSetController : ControllerBase
+public class TimestampedSetController : ControllerBase
{
private readonly ITimestampedSetRepository repository;
@@ -32,7 +32,7 @@ public class TimestampedSetController : ControllerBase
/// кол-во затронутых записей
[HttpPost]
[ProducesResponseType(typeof(int), (int)HttpStatusCode.OK)]
- public async Task AddRange([FromRoute]Guid idDiscriminator, [FromBody]IEnumerable sets, CancellationToken token)
+ public async Task AddRange([FromRoute] Guid idDiscriminator, [FromBody] IEnumerable sets, CancellationToken token)
{
var result = await repository.AddRange(idDiscriminator, sets, token);
return Ok(result);
@@ -50,7 +50,7 @@ public class TimestampedSetController : ControllerBase
/// Фильтрованный набор данных с сортировкой по отметке времени
[HttpGet]
[ProducesResponseType(typeof(IEnumerable), (int)HttpStatusCode.OK)]
- public async Task Get(Guid idDiscriminator, DateTimeOffset? geTimestamp, [FromQuery]IEnumerable? columnNames, int skip, int take, CancellationToken token)
+ public async Task Get(Guid idDiscriminator, DateTimeOffset? geTimestamp, [FromQuery] IEnumerable? columnNames, int skip, int take, CancellationToken token)
{
var result = await repository.Get(idDiscriminator, geTimestamp, columnNames, skip, take, token);
return Ok(result);
@@ -66,7 +66,7 @@ public class TimestampedSetController : ControllerBase
/// Фильтрованный набор данных с сортировкой по отметке времени
[HttpGet("last")]
[ProducesResponseType(typeof(IEnumerable), (int)HttpStatusCode.OK)]
- public async Task GetLast(Guid idDiscriminator, [FromQuery]IEnumerable? columnNames, int take, CancellationToken token)
+ public async Task GetLast(Guid idDiscriminator, [FromQuery] IEnumerable? columnNames, int take, CancellationToken token)
{
var result = await repository.GetLast(idDiscriminator, columnNames, take, token);
return Ok(result);
diff --git a/Persistence.API/Controllers/WitsDataController.cs b/Persistence.API/Controllers/WitsDataController.cs
index 741b35c..9e855b7 100644
--- a/Persistence.API/Controllers/WitsDataController.cs
+++ b/Persistence.API/Controllers/WitsDataController.cs
@@ -1,8 +1,8 @@
-using System.Net;
-using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Persistence.Models;
using Persistence.Services.Interfaces;
+using System.Net;
namespace Persistence.API.Controllers;
@@ -14,73 +14,73 @@ namespace Persistence.API.Controllers;
[Route("api/[controller]")]
public class WitsDataController : ControllerBase, IWitsDataApi
{
- private readonly IWitsDataService witsDataService;
+ private readonly IWitsDataService witsDataService;
- public WitsDataController(IWitsDataService witsDataService)
- {
- this.witsDataService = witsDataService;
- }
+ public WitsDataController(IWitsDataService witsDataService)
+ {
+ this.witsDataService = witsDataService;
+ }
- ///
- /// Получить диапазон дат, для которых есть данные в репозитории
- ///
- ///
- ///
- ///
- [HttpGet("{discriminatorId}/datesRange")]
- public async Task> GetDatesRangeAsync([FromRoute] Guid discriminatorId, CancellationToken token)
- {
- var result = await witsDataService.GetDatesRangeAsync(discriminatorId, token);
+ ///
+ /// Получить диапазон дат, для которых есть данные в репозитории
+ ///
+ ///
+ ///
+ ///
+ [HttpGet("{discriminatorId}/datesRange")]
+ public async Task> GetDatesRangeAsync([FromRoute] Guid discriminatorId, CancellationToken token)
+ {
+ var result = await witsDataService.GetDatesRangeAsync(discriminatorId, token);
- return result == null ? NoContent() : Ok(result);
- }
+ return result == null ? NoContent() : Ok(result);
+ }
- ///
- /// Получить порцию записей, начиная с заданной даты
- ///
- ///
- ///
- ///
- ///
- ///
- [HttpGet("{discriminatorId}/part")]
- public async Task>> GetPart([FromRoute] Guid discriminatorId, [FromQuery] DateTimeOffset dateBegin, [FromQuery] int take, CancellationToken token)
- {
- var result = await witsDataService.GetPart(discriminatorId, dateBegin, take, token);
+ ///
+ /// Получить порцию записей, начиная с заданной даты
+ ///
+ ///
+ ///
+ ///
+ ///
+ ///
+ [HttpGet("{discriminatorId}/part")]
+ public async Task>> GetPart([FromRoute] Guid discriminatorId, [FromQuery] DateTimeOffset dateBegin, [FromQuery] int take, CancellationToken token)
+ {
+ var result = await witsDataService.GetPart(discriminatorId, dateBegin, take, token);
- return Ok(result);
- }
+ return Ok(result);
+ }
- ///
- /// Получить набор параметров (Wits) для построения графика
- ///
- /// Дискриминатор системы
- /// Начало временного интервала
- /// Конец временного интервала
- /// Количество точек
- ///
- ///
- [HttpGet("{discriminatorId}/graph")]
- public async Task>> GetValuesForGraph([FromRoute] Guid discriminatorId,
- [FromQuery] DateTimeOffset dateFrom, [FromQuery] DateTimeOffset dateTo, [FromQuery] int approxPointsCount, CancellationToken token)
- {
- var result = await witsDataService.GetValuesForGraph(discriminatorId, dateFrom, dateTo, approxPointsCount, token);
-
- return Ok(result);
- }
+ ///
+ /// Получить набор параметров (Wits) для построения графика
+ ///
+ /// Дискриминатор системы
+ /// Начало временного интервала
+ /// Конец временного интервала
+ /// Количество точек
+ ///
+ ///
+ [HttpGet("{discriminatorId}/graph")]
+ public async Task>> GetValuesForGraph([FromRoute] Guid discriminatorId,
+ [FromQuery] DateTimeOffset dateFrom, [FromQuery] DateTimeOffset dateTo, [FromQuery] int approxPointsCount, CancellationToken token)
+ {
+ var result = await witsDataService.GetValuesForGraph(discriminatorId, dateFrom, dateTo, approxPointsCount, token);
- ///
- /// Сохранить набор параметров (Wits)
- ///
- ///
- ///
- ///
- [HttpPost]
- [ProducesResponseType(typeof(int), (int)HttpStatusCode.Created)]
- public async Task AddRange([FromBody] IEnumerable dtos, CancellationToken token)
- {
- var result = await witsDataService.AddRange(dtos, token);
+ return Ok(result);
+ }
- return CreatedAtAction(nameof(AddRange), result);
- }
+ ///
+ /// Сохранить набор параметров (Wits)
+ ///
+ ///
+ ///
+ ///
+ [HttpPost]
+ [ProducesResponseType(typeof(int), (int)HttpStatusCode.Created)]
+ public async Task AddRange([FromBody] IEnumerable dtos, CancellationToken token)
+ {
+ var result = await witsDataService.AddRange(dtos, token);
+
+ return CreatedAtAction(nameof(AddRange), result);
+ }
}
diff --git a/Persistence.API/DependencyInjection.cs b/Persistence.API/DependencyInjection.cs
index f6eb7e6..d2960af 100644
--- a/Persistence.API/DependencyInjection.cs
+++ b/Persistence.API/DependencyInjection.cs
@@ -30,12 +30,11 @@ public static class DependencyInjection
c.MapType(() => new OpenApiSchema { Type = "string", Format = "date" });
c.MapType(() => new OpenApiSchema
{
- AnyOf = new OpenApiSchema[]
- {
+ AnyOf = [
new OpenApiSchema {Type = "string", Format = "string" },
new OpenApiSchema {Type = "number", Format = "int32" },
- new OpenApiSchema {Type = "number", Format = "float" },
- }
+ new OpenApiSchema {Type = "number", Format = "float" }
+ ]
});
c.CustomOperationIds(e =>
@@ -47,8 +46,8 @@ public static class DependencyInjection
var needUseKeyCloak = configuration.GetSection("NeedUseKeyCloak").Get();
if (needUseKeyCloak)
- c.AddKeycloackSecurity(configuration);
- else c.AddDefaultSecurity(configuration);
+ c.AddKeycloakSecurity(configuration);
+ else c.AddDefaultSecurity();
var xmlFile = $"{Assembly.GetExecutingAssembly().GetName().Name}.xml";
var xmlPath = Path.Combine(AppContext.BaseDirectory, xmlFile);
@@ -57,13 +56,13 @@ public static class DependencyInjection
});
}
- public static void AddServices(this IServiceCollection services)
- {
- services.AddTransient();
- }
+ public static void AddServices(this IServiceCollection services)
+ {
+ services.AddTransient();
+ }
- #region Authentication
- public static void AddJWTAuthentication(this IServiceCollection services, IConfiguration configuration)
+ #region Authentication
+ public static void AddJWTAuthentication(this IServiceCollection services, IConfiguration configuration)
{
var needUseKeyCloak = configuration
.GetSection("NeedUseKeyCloak")
@@ -108,7 +107,7 @@ public static class DependencyInjection
{
OnMessageReceived = context =>
{
- var accessToken = context.Request.Headers["Authorization"]
+ var accessToken = context.Request.Headers.Authorization
.ToString()
.Replace(JwtBearerDefaults.AuthenticationScheme, string.Empty)
.Trim();
@@ -141,12 +140,12 @@ public static class DependencyInjection
}
#endregion
- #region Security (Swagger)
- private static void AddKeycloackSecurity(this SwaggerGenOptions options, IConfiguration configuration)
+ #region Keycloak
+ private static void AddKeycloakSecurity(this SwaggerGenOptions options, IConfiguration configuration)
{
- options.AddSecurityDefinition("Keycloack", new OpenApiSecurityScheme
+ options.AddSecurityDefinition("Keycloak", new OpenApiSecurityScheme
{
- Description = @"JWT Authorization header using the Bearer scheme. Enter 'Bearer' [space] and then your token in the text input below. Example: 'Bearer 12345abcdef'",
+ Description = @"JWT Authorization header using the Bearer scheme. Enter 'Bearer' [space] and then your token in the text input below. Example: 'Bearer 12345token'",
Name = "Authorization",
In = ParameterLocation.Header,
Type = SecuritySchemeType.OAuth2,
@@ -154,7 +153,7 @@ public static class DependencyInjection
{
Implicit = new OpenApiOAuthFlow
{
- AuthorizationUrl = new Uri(configuration["Authentication:AuthorizationUrl"]),
+ AuthorizationUrl = new Uri(configuration["Authentication:AuthorizationUrl"]!),
}
}
});
@@ -167,7 +166,7 @@ public static class DependencyInjection
Reference = new OpenApiReference
{
Type = ReferenceType.SecurityScheme,
- Id = "Keycloack"
+ Id = "Keycloak"
},
Scheme = "Bearer",
Name = "Bearer",
@@ -178,11 +177,11 @@ public static class DependencyInjection
});
}
- private static void AddDefaultSecurity(this SwaggerGenOptions options, IConfiguration configuration)
+ private static void AddDefaultSecurity(this SwaggerGenOptions options)
{
options.AddSecurityDefinition("Bearer", new OpenApiSecurityScheme
{
- Description = @"JWT Authorization header using the Bearer scheme. Enter 'Bearer' [space] and then your token in the text input below. Example: 'Bearer 12345abcdef'",
+ Description = @"JWT Authorization header using the Bearer scheme. Enter 'Bearer' [space] and then your token in the text input below. Example: 'Bearer 12345token'",
Name = "Authorization",
In = ParameterLocation.Header,
Type = SecuritySchemeType.ApiKey,
diff --git a/Persistence.API/Extensions.cs b/Persistence.API/Extensions.cs
index 601a2f4..5fa9fd4 100644
--- a/Persistence.API/Extensions.cs
+++ b/Persistence.API/Extensions.cs
@@ -7,18 +7,15 @@ public static class Extensions
{
public static T GetUserId(this ClaimsPrincipal principal)
{
- if (principal == null)
- throw new ArgumentNullException(nameof(principal));
+ ArgumentNullException.ThrowIfNull(principal, nameof(principal));
var loggedInUserId = principal.FindFirstValue(ClaimTypes.NameIdentifier);
- if (String.IsNullOrEmpty(loggedInUserId))
- throw new ArgumentNullException(nameof(loggedInUserId));
+ ArgumentNullException.ThrowIfNullOrEmpty(loggedInUserId, nameof(loggedInUserId));
var result = TypeDescriptor.GetConverter(typeof(T)).ConvertFromInvariantString(loggedInUserId);
- if (result is null)
- throw new ArgumentNullException(nameof(result));
+ ArgumentNullException.ThrowIfNull(result, nameof(result));
return (T)result;
diff --git a/Persistence.API/Persistence.API.csproj b/Persistence.API/Persistence.API.csproj
index dfff363..fa3b7ad 100644
--- a/Persistence.API/Persistence.API.csproj
+++ b/Persistence.API/Persistence.API.csproj
@@ -9,6 +9,11 @@
$(NoWarn);1591
+
+ 1.0.$([System.DateTime]::UtcNow.ToString(yyMM.ddHH))
+ 1.0.$([System.DateTime]::UtcNow.ToString(yyMM.ddHH))
+
+
diff --git a/Persistence.API/Persistence.API.http b/Persistence.API/Persistence.API.http
deleted file mode 100644
index 0eba8fa..0000000
--- a/Persistence.API/Persistence.API.http
+++ /dev/null
@@ -1,6 +0,0 @@
-@Persistence.API_HostAddress = http://localhost:5032
-
-GET {{Persistence.API_HostAddress}}/weatherforecast/
-Accept: application/json
-
-###
diff --git a/Persistence.API/Program.cs b/Persistence.API/Program.cs
index bc54d92..bb6e9a7 100644
--- a/Persistence.API/Program.cs
+++ b/Persistence.API/Program.cs
@@ -1,6 +1,3 @@
-
-using Persistence.Models;
-
namespace Persistence.API;
public class Program
@@ -18,5 +15,5 @@ public class Program
.ConfigureWebHostDefaults(webBuilder =>
{
webBuilder.UseStartup();
- });
+ });
}
diff --git a/Persistence.API/Startup.cs b/Persistence.API/Startup.cs
index 77b3e72..2b522bd 100644
--- a/Persistence.API/Startup.cs
+++ b/Persistence.API/Startup.cs
@@ -1,6 +1,6 @@
-using Persistence.Repository;
-using Persistence.Database.Model;
+using Persistence.Database.Model;
using Persistence.Database.Postgres;
+using Persistence.Repository;
namespace Persistence.API;
diff --git a/Persistence.Client/Clients/IChangeLogClient.cs b/Persistence.Client/Clients/IChangeLogClient.cs
index 8391e84..06bbc4d 100644
--- a/Persistence.Client/Clients/IChangeLogClient.cs
+++ b/Persistence.Client/Clients/IChangeLogClient.cs
@@ -30,7 +30,7 @@ public interface IChangeLogClient
///
[Get($"{BaseRoute}/moment/{{idDiscriminator}}")]
Task>> GetByDate(
- Guid idDiscriminator,
+ Guid idDiscriminator,
DateTimeOffset moment,
[Query] SectionPartRequest filterRequest,
[Query] PaginationRequest paginationRequest);
diff --git a/Persistence.Client/Clients/ISetpointClient.cs b/Persistence.Client/Clients/ISetpointClient.cs
index 0b81ffa..47c4352 100644
--- a/Persistence.Client/Clients/ISetpointClient.cs
+++ b/Persistence.Client/Clients/ISetpointClient.cs
@@ -8,23 +8,23 @@ namespace Persistence.Client.Clients;
///
public interface ISetpointClient
{
- private const string BaseRoute = "/api/setpoint";
+ private const string BaseRoute = "/api/setpoint";
- [Get($"{BaseRoute}/current")]
- Task>> GetCurrent([Query(CollectionFormat.Multi)] IEnumerable setpointKeys);
-
- [Get($"{BaseRoute}/history")]
- Task>> GetHistory([Query(CollectionFormat.Multi)] IEnumerable setpointKeys, [Query] DateTimeOffset historyMoment);
+ [Get($"{BaseRoute}/current")]
+ Task>> GetCurrent([Query(CollectionFormat.Multi)] IEnumerable setpointKeys);
- [Get($"{BaseRoute}/log")]
- Task>>> GetLog([Query(CollectionFormat.Multi)] IEnumerable setpointKeys);
+ [Get($"{BaseRoute}/history")]
+ Task>> GetHistory([Query(CollectionFormat.Multi)] IEnumerable setpointKeys, [Query] DateTimeOffset historyMoment);
- [Get($"{BaseRoute}/range")]
- Task> GetDatesRangeAsync(CancellationToken token);
+ [Get($"{BaseRoute}/log")]
+ Task>>> GetLog([Query(CollectionFormat.Multi)] IEnumerable setpointKeys);
- [Get($"{BaseRoute}/part")]
- Task>> GetPart(DateTimeOffset dateBegin, int take, CancellationToken token);
+ [Get($"{BaseRoute}/range")]
+ Task> GetDatesRangeAsync(CancellationToken token);
- [Post($"{BaseRoute}/")]
- Task Add(Guid setpointKey, object newValue);
+ [Get($"{BaseRoute}/part")]
+ Task>> GetPart(DateTimeOffset dateBegin, int take, CancellationToken token);
+
+ [Post($"{BaseRoute}/")]
+ Task Add(Guid setpointKey, object newValue);
}
diff --git a/Persistence.Client/Clients/ITechMessagesClient.cs b/Persistence.Client/Clients/ITechMessagesClient.cs
index a9c80c1..1fde2a9 100644
--- a/Persistence.Client/Clients/ITechMessagesClient.cs
+++ b/Persistence.Client/Clients/ITechMessagesClient.cs
@@ -4,29 +4,29 @@ using Refit;
namespace Persistence.Client.Clients
{
- ///
- /// Интерфейс клиента для хранения технологических сообщений
- ///
- public interface ITechMessagesClient
- {
- private const string BaseRoute = "/api/techMessages";
+ ///
+ /// Интерфейс клиента для хранения технологических сообщений
+ ///
+ public interface ITechMessagesClient
+ {
+ private const string BaseRoute = "/api/techMessages";
- [Get($"{BaseRoute}")]
- Task>> GetPage([Query] PaginationRequest request, CancellationToken token);
+ [Get($"{BaseRoute}")]
+ Task>> GetPage([Query] PaginationRequest request, CancellationToken token);
- [Post($"{BaseRoute}")]
- Task> AddRange([Body] IEnumerable dtos, CancellationToken token);
+ [Post($"{BaseRoute}")]
+ Task> AddRange([Body] IEnumerable dtos, CancellationToken token);
- [Get($"{BaseRoute}/systems")]
- Task>> GetSystems(CancellationToken token);
+ [Get($"{BaseRoute}/systems")]
+ Task>> GetSystems(CancellationToken token);
- [Get($"{BaseRoute}/range")]
- Task> GetDatesRangeAsync(CancellationToken token);
+ [Get($"{BaseRoute}/range")]
+ Task> GetDatesRangeAsync(CancellationToken token);
- [Get($"{BaseRoute}/part")]
- Task>> GetPart(DateTimeOffset dateBegin, int take, CancellationToken token);
+ [Get($"{BaseRoute}/part")]
+ Task>> GetPart(DateTimeOffset dateBegin, int take, CancellationToken token);
- [Get($"{BaseRoute}/statistics")]
- Task>> GetStatistics([Query] string autoDrillingSystem, [Query] int categoryId, CancellationToken token);
- }
+ [Get($"{BaseRoute}/statistics")]
+ Task>> GetStatistics([Query] string autoDrillingSystem, [Query] int categoryId, CancellationToken token);
+ }
}
diff --git a/Persistence.Client/Clients/ITimeSeriesClient.cs b/Persistence.Client/Clients/ITimeSeriesClient.cs
index 8e97836..c2cbf91 100644
--- a/Persistence.Client/Clients/ITimeSeriesClient.cs
+++ b/Persistence.Client/Clients/ITimeSeriesClient.cs
@@ -15,7 +15,7 @@ public interface ITimeSeriesClient
[Get($"{BaseRoute}/resampled")]
Task>> GetResampledData(DateTimeOffset dateBegin, double intervalSec = 600d, int approxPointsCount = 1024);
-
+
[Get($"{BaseRoute}/datesRange")]
Task> GetDatesRange();
}
diff --git a/Persistence.Client/Clients/IWitsDataClient.cs b/Persistence.Client/Clients/IWitsDataClient.cs
index b89b3e5..95a34c3 100644
--- a/Persistence.Client/Clients/IWitsDataClient.cs
+++ b/Persistence.Client/Clients/IWitsDataClient.cs
@@ -1,21 +1,20 @@
-using Microsoft.AspNetCore.Mvc;
-using Persistence.Models;
+using Persistence.Models;
using Refit;
namespace Persistence.Client.Clients;
public interface IWitsDataClient
{
- private const string BaseRoute = "/api/witsData";
+ private const string BaseRoute = "/api/witsData";
- [Get($"{BaseRoute}/{{discriminatorId}}/graph")]
- Task>> GetValuesForGraph(Guid discriminatorId, [Query] DateTimeOffset dateFrom, [Query] DateTimeOffset dateTo, [Query] int approxPointsCount, CancellationToken token);
+ [Get($"{BaseRoute}/{{discriminatorId}}/graph")]
+ Task>> GetValuesForGraph(Guid discriminatorId, [Query] DateTimeOffset dateFrom, [Query] DateTimeOffset dateTo, [Query] int approxPointsCount, CancellationToken token);
- [Post($"{BaseRoute}/")]
- Task> AddRange(IEnumerable dtos, CancellationToken token);
+ [Post($"{BaseRoute}/")]
+ Task> AddRange(IEnumerable dtos, CancellationToken token);
- [Get($"{BaseRoute}/{{discriminatorId}}/part")]
- Task>> GetPart(Guid discriminatorId, [Query] DateTimeOffset dateBegin, [Query] int take = 24 * 60 * 60, CancellationToken token = default);
+ [Get($"{BaseRoute}/{{discriminatorId}}/part")]
+ Task>> GetPart(Guid discriminatorId, [Query] DateTimeOffset dateBegin, [Query] int take = 24 * 60 * 60, CancellationToken token = default);
- [Get($"{BaseRoute}/{{discriminatorId}}/datesRange")]
- Task> GetDatesRangeAsync(Guid discriminatorId, CancellationToken token);
+ [Get($"{BaseRoute}/{{discriminatorId}}/datesRange")]
+ Task> GetDatesRangeAsync(Guid discriminatorId, CancellationToken token);
}
diff --git a/Persistence.Client/Helpers/ApiTokenHelper.cs b/Persistence.Client/Helpers/ApiTokenHelper.cs
index d829fcf..d21363f 100644
--- a/Persistence.Client/Helpers/ApiTokenHelper.cs
+++ b/Persistence.Client/Helpers/ApiTokenHelper.cs
@@ -1,75 +1,74 @@
-using System.IdentityModel.Tokens.Jwt;
-using System.Net.Http.Headers;
-using System.Security.Claims;
-using System.Text.Json;
-using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Configuration;
using Microsoft.IdentityModel.Tokens;
using Persistence.Models.Configurations;
using RestSharp;
+using System.IdentityModel.Tokens.Jwt;
+using System.Net.Http.Headers;
+using System.Security.Claims;
+using System.Text.Json;
namespace Persistence.Client.Helpers;
public static class ApiTokenHelper
{
- public static void Authorize(this HttpClient httpClient, IConfiguration configuration)
- {
- var authUser = configuration
- .GetSection(nameof(AuthUser))
- .Get()!;
- var needUseKeyCloak = configuration
- .GetSection("NeedUseKeyCloak")
- .Get()!;
- var keycloakGetTokenUrl = configuration.GetSection("KeycloakGetTokenUrl").Get() ?? string.Empty;
+ public static void Authorize(this HttpClient httpClient, IConfiguration configuration)
+ {
+ var authUser = configuration
+ .GetSection(nameof(AuthUser))
+ .Get()!;
+ var needUseKeyCloak = configuration
+ .GetSection("NeedUseKeyCloak")
+ .Get()!;
+ var keycloakGetTokenUrl = configuration.GetSection("KeycloakGetTokenUrl").Get() ?? string.Empty;
- var jwtToken = needUseKeyCloak
- ? authUser.CreateKeyCloakJwtToken(keycloakGetTokenUrl)
- : authUser.CreateDefaultJwtToken();
+ var jwtToken = needUseKeyCloak
+ ? authUser.CreateKeyCloakJwtToken(keycloakGetTokenUrl)
+ : authUser.CreateDefaultJwtToken();
- httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", jwtToken);
- }
+ httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", jwtToken);
+ }
- private static string CreateDefaultJwtToken(this AuthUser authUser)
- {
- var nameIdetifier = Guid.NewGuid().ToString();
- var claims = new List()
- {
- new(ClaimTypes.NameIdentifier, nameIdetifier),
- new("client_id", authUser.ClientId),
- new("username", authUser.Username),
- new("password", authUser.Password),
- new("grant_type", authUser.GrantType),
- new(ClaimTypes.NameIdentifier.ToString(), Guid.NewGuid().ToString())
- };
+ private static string CreateDefaultJwtToken(this AuthUser authUser)
+ {
+ var nameIdetifier = Guid.NewGuid().ToString();
+ var claims = new List()
+ {
+ new(ClaimTypes.NameIdentifier, nameIdetifier),
+ new("client_id", authUser.ClientId),
+ new("username", authUser.Username),
+ new("password", authUser.Password),
+ new("grant_type", authUser.GrantType)
+ };
- var tokenDescriptor = new SecurityTokenDescriptor
- {
- Issuer = JwtParams.Issuer,
- Audience = JwtParams.Audience,
- Subject = new ClaimsIdentity(claims),
- Expires = DateTime.UtcNow.AddHours(1),
- SigningCredentials = new SigningCredentials(JwtParams.SecurityKey, SecurityAlgorithms.HmacSha256Signature)
- };
- var tokenHandler = new JwtSecurityTokenHandler();
- var token = tokenHandler.CreateToken(tokenDescriptor);
- return tokenHandler.WriteToken(token);
- }
+ var tokenDescriptor = new SecurityTokenDescriptor
+ {
+ Issuer = JwtParams.Issuer,
+ Audience = JwtParams.Audience,
+ Subject = new ClaimsIdentity(claims),
+ Expires = DateTime.UtcNow.AddHours(1),
+ SigningCredentials = new SigningCredentials(JwtParams.SecurityKey, SecurityAlgorithms.HmacSha256Signature)
+ };
+ var tokenHandler = new JwtSecurityTokenHandler();
+ var token = tokenHandler.CreateToken(tokenDescriptor);
+ return tokenHandler.WriteToken(token);
+ }
- private static string CreateKeyCloakJwtToken(this AuthUser authUser, string keycloakGetTokenUrl)
- {
- var restClient = new RestClient();
+ private static string CreateKeyCloakJwtToken(this AuthUser authUser, string keycloakGetTokenUrl)
+ {
+ var restClient = new RestClient();
- var request = new RestRequest(keycloakGetTokenUrl, Method.Post);
- request.AddParameter("username", authUser.Username);
- request.AddParameter("password", authUser.Password);
- request.AddParameter("client_id", authUser.ClientId);
- request.AddParameter("grant_type", authUser.GrantType);
+ var request = new RestRequest(keycloakGetTokenUrl, Method.Post);
+ request.AddParameter("username", authUser.Username);
+ request.AddParameter("password", authUser.Password);
+ request.AddParameter("client_id", authUser.ClientId);
+ request.AddParameter("grant_type", authUser.GrantType);
- var keyCloackResponse = restClient.Post(request);
- if (keyCloackResponse.IsSuccessful && !String.IsNullOrEmpty(keyCloackResponse.Content))
- {
- var token = JsonSerializer.Deserialize(keyCloackResponse.Content)!;
- return token.AccessToken;
- }
+ var keycloakResponse = restClient.Post(request);
+ if (keycloakResponse.IsSuccessful && !String.IsNullOrEmpty(keycloakResponse.Content))
+ {
+ var token = JsonSerializer.Deserialize(keycloakResponse.Content)!;
+ return token.AccessToken;
+ }
- return String.Empty;
- }
+ return String.Empty;
+ }
}
diff --git a/Persistence.Client/Persistence.Client.csproj b/Persistence.Client/Persistence.Client.csproj
index d699df7..3f61a17 100644
--- a/Persistence.Client/Persistence.Client.csproj
+++ b/Persistence.Client/Persistence.Client.csproj
@@ -6,6 +6,11 @@
enable
+
+ 1.0.$([System.DateTime]::UtcNow.ToString(yyMM.ddHH))
+ 1.0.$([System.DateTime]::UtcNow.ToString(yyMM.ddHH))
+
+
@@ -17,9 +22,4 @@
-
-
-
-
-
diff --git a/Persistence.Client/PersistenceClientFactory.cs b/Persistence.Client/PersistenceClientFactory.cs
index e84327d..697c901 100644
--- a/Persistence.Client/PersistenceClientFactory.cs
+++ b/Persistence.Client/PersistenceClientFactory.cs
@@ -1,32 +1,32 @@
-using System.Text.Json;
-using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Configuration;
using Persistence.Client.Helpers;
using Refit;
+using System.Text.Json;
namespace Persistence.Client
{
- ///
- /// Фабрика клиентов для доступа к Persistence - сервису
- ///
- public class PersistenceClientFactory
- {
- private static readonly JsonSerializerOptions JsonSerializerOptions = new()
- {
- PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
- PropertyNameCaseInsensitive = true
- };
- private static readonly RefitSettings RefitSettings = new(new SystemTextJsonContentSerializer(JsonSerializerOptions));
- private HttpClient httpClient;
- public PersistenceClientFactory(IHttpClientFactory httpClientFactory, IConfiguration configuration)
- {
- this.httpClient = httpClientFactory.CreateClient();
+ ///
+ /// Фабрика клиентов для доступа к Persistence - сервису
+ ///
+ public class PersistenceClientFactory
+ {
+ private static readonly JsonSerializerOptions JsonSerializerOptions = new()
+ {
+ PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
+ PropertyNameCaseInsensitive = true
+ };
+ private static readonly RefitSettings RefitSettings = new(new SystemTextJsonContentSerializer(JsonSerializerOptions));
+ private readonly HttpClient httpClient;
+ public PersistenceClientFactory(IHttpClientFactory httpClientFactory, IConfiguration configuration)
+ {
+ this.httpClient = httpClientFactory.CreateClient();
- httpClient.Authorize(configuration);
- }
+ httpClient.Authorize(configuration);
+ }
- public T GetClient()
- {
- return RestService.For(httpClient, RefitSettings);
- }
- }
+ public T GetClient()
+ {
+ return RestService.For(httpClient, RefitSettings);
+ }
+ }
}
diff --git a/Persistence.Database.Postgres/DependencyInjection.cs b/Persistence.Database.Postgres/DependencyInjection.cs
index b308629..e775952 100644
--- a/Persistence.Database.Postgres/DependencyInjection.cs
+++ b/Persistence.Database.Postgres/DependencyInjection.cs
@@ -1,7 +1,6 @@
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
-using Npgsql;
namespace Persistence.Database.Model;
diff --git a/Persistence.Database.Postgres/DesignTimeDbContextFactory.cs b/Persistence.Database.Postgres/DesignTimeDbContextFactory.cs
index 2123efd..b4fbd85 100644
--- a/Persistence.Database.Postgres/DesignTimeDbContextFactory.cs
+++ b/Persistence.Database.Postgres/DesignTimeDbContextFactory.cs
@@ -12,12 +12,14 @@ public class DesignTimeDbContextFactory : IDesignTimeDbContextFactory();
diff --git a/Persistence.Database.Postgres/EFExtensionsInitialization.cs b/Persistence.Database.Postgres/EFExtensionsInitialization.cs
index 99d3f5d..a876f7a 100644
--- a/Persistence.Database.Postgres/EFExtensionsInitialization.cs
+++ b/Persistence.Database.Postgres/EFExtensionsInitialization.cs
@@ -1,11 +1,6 @@
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Infrastructure;
-using System;
-using System.Collections.Generic;
using System.Diagnostics;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
namespace Persistence.Database.Postgres;
public static class EFExtensionsInitialization
diff --git a/Persistence.Database.Postgres/Migrations/20241118052225_SetpointMigration.cs b/Persistence.Database.Postgres/Migrations/20241118052225_SetpointMigration.cs
index ea6fccf..fac75d8 100644
--- a/Persistence.Database.Postgres/Migrations/20241118052225_SetpointMigration.cs
+++ b/Persistence.Database.Postgres/Migrations/20241118052225_SetpointMigration.cs
@@ -1,5 +1,4 @@
-using System;
-using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Migrations;
#nullable disable
diff --git a/Persistence.Database.Postgres/Migrations/20241126071115_Add_ChangeLog.cs b/Persistence.Database.Postgres/Migrations/20241126071115_Add_ChangeLog.cs
index 0802b00..4750bc3 100644
--- a/Persistence.Database.Postgres/Migrations/20241126071115_Add_ChangeLog.cs
+++ b/Persistence.Database.Postgres/Migrations/20241126071115_Add_ChangeLog.cs
@@ -1,6 +1,4 @@
-using System;
-using System.Collections.Generic;
-using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Migrations;
#nullable disable
diff --git a/Persistence.Database.Postgres/Migrations/20241126100631_Init.cs b/Persistence.Database.Postgres/Migrations/20241126100631_Init.cs
index ceca42c..74a549e 100644
--- a/Persistence.Database.Postgres/Migrations/20241126100631_Init.cs
+++ b/Persistence.Database.Postgres/Migrations/20241126100631_Init.cs
@@ -1,5 +1,4 @@
-using System;
-using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Migrations;
#nullable disable
diff --git a/Persistence.Database.Postgres/Migrations/20241202072250_TechMessageMigration.cs b/Persistence.Database.Postgres/Migrations/20241202072250_TechMessageMigration.cs
index ccf18d4..41ef8cb 100644
--- a/Persistence.Database.Postgres/Migrations/20241202072250_TechMessageMigration.cs
+++ b/Persistence.Database.Postgres/Migrations/20241202072250_TechMessageMigration.cs
@@ -1,5 +1,4 @@
-using System;
-using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Migrations;
#nullable disable
diff --git a/Persistence.Database.Postgres/Migrations/20241203120141_ParameterDataMigration.cs b/Persistence.Database.Postgres/Migrations/20241203120141_ParameterDataMigration.cs
index 7e9bde6..8d44be9 100644
--- a/Persistence.Database.Postgres/Migrations/20241203120141_ParameterDataMigration.cs
+++ b/Persistence.Database.Postgres/Migrations/20241203120141_ParameterDataMigration.cs
@@ -1,5 +1,4 @@
-using System;
-using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Migrations;
#nullable disable
diff --git a/Persistence.Database.Postgres/PersistencePostgresContext.cs b/Persistence.Database.Postgres/PersistencePostgresContext.cs
index 862b247..6016a1d 100644
--- a/Persistence.Database.Postgres/PersistencePostgresContext.cs
+++ b/Persistence.Database.Postgres/PersistencePostgresContext.cs
@@ -1,5 +1,4 @@
using Microsoft.EntityFrameworkCore;
-using Microsoft.EntityFrameworkCore.Infrastructure.Internal;
namespace Persistence.Database.Model;
@@ -10,7 +9,7 @@ public partial class PersistencePostgresContext : PersistenceDbContext
{
public PersistencePostgresContext(DbContextOptions options)
: base(options)
- {}
+ { }
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
diff --git a/Persistence.Database/EFExtensions.cs b/Persistence.Database/EFExtensions.cs
index d60d768..decdb39 100644
--- a/Persistence.Database/EFExtensions.cs
+++ b/Persistence.Database/EFExtensions.cs
@@ -1,6 +1,6 @@
using Microsoft.EntityFrameworkCore.ChangeTracking;
-using System.Text.Json.Serialization;
using System.Text.Json;
+using System.Text.Json.Serialization;
namespace Persistence.Database;
diff --git a/Persistence.Database/Entity/ChangeLog.cs b/Persistence.Database/Entity/ChangeLog.cs
index 9a8001b..edffb52 100644
--- a/Persistence.Database/Entity/ChangeLog.cs
+++ b/Persistence.Database/Entity/ChangeLog.cs
@@ -1,8 +1,8 @@
-using System.ComponentModel.DataAnnotations.Schema;
-using System.ComponentModel.DataAnnotations;
using Microsoft.EntityFrameworkCore;
using Persistence.Models;
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
namespace Persistence.Database.Model;
diff --git a/Persistence.Database/Entity/DataSaub.cs b/Persistence.Database/Entity/DataSaub.cs
index fecda5a..ee18d40 100644
--- a/Persistence.Database/Entity/DataSaub.cs
+++ b/Persistence.Database/Entity/DataSaub.cs
@@ -1,5 +1,4 @@
-using Microsoft.EntityFrameworkCore;
-using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
namespace Persistence.Database.Model;
diff --git a/Persistence.Database/Entity/DrillingSystem.cs b/Persistence.Database/Entity/DrillingSystem.cs
index 6588fb0..dc52ce7 100644
--- a/Persistence.Database/Entity/DrillingSystem.cs
+++ b/Persistence.Database/Entity/DrillingSystem.cs
@@ -1,16 +1,16 @@
-using System.ComponentModel.DataAnnotations;
+using Microsoft.EntityFrameworkCore;
+using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
-using Microsoft.EntityFrameworkCore;
namespace Persistence.Database.Entity;
public class DrillingSystem
{
- [Key, Comment("Id системы автобурения")]
- public Guid SystemId { get; set; }
+ [Key, Comment("Id системы автобурения")]
+ public Guid SystemId { get; set; }
- [Required, Column(TypeName = "varchar(256)"), Comment("Наименование системы автобурения")]
- public required string Name { get; set; }
+ [Required, Column(TypeName = "varchar(256)"), Comment("Наименование системы автобурения")]
+ public required string Name { get; set; }
- [Comment("Описание системы автобурения")]
- public string? Description { get; set; }
+ [Comment("Описание системы автобурения")]
+ public string? Description { get; set; }
}
diff --git a/Persistence.Database/Entity/ParameterData.cs b/Persistence.Database/Entity/ParameterData.cs
index f8257de..eb4fa4c 100644
--- a/Persistence.Database/Entity/ParameterData.cs
+++ b/Persistence.Database/Entity/ParameterData.cs
@@ -1,21 +1,21 @@
-using System.ComponentModel.DataAnnotations;
+using Microsoft.EntityFrameworkCore;
+using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
-using Microsoft.EntityFrameworkCore;
namespace Persistence.Database.Entity;
[PrimaryKey(nameof(DiscriminatorId), nameof(ParameterId), nameof(Timestamp))]
public class ParameterData
{
- [Required, Comment("Дискриминатор системы")]
- public Guid DiscriminatorId { get; set; }
+ [Required, Comment("Дискриминатор системы")]
+ public Guid DiscriminatorId { get; set; }
- [Comment("Id параметра")]
- public int ParameterId { get; set; }
+ [Comment("Id параметра")]
+ public int ParameterId { get; set; }
- [Column(TypeName = "varchar(256)"), Comment("Значение параметра в виде строки")]
- public required string Value { get; set; }
+ [Column(TypeName = "varchar(256)"), Comment("Значение параметра в виде строки")]
+ public required string Value { get; set; }
- [Comment("Временная отметка")]
- public DateTimeOffset Timestamp { get; set; }
+ [Comment("Временная отметка")]
+ public DateTimeOffset Timestamp { get; set; }
}
diff --git a/Persistence.Database/Entity/Setpoint.cs b/Persistence.Database/Entity/Setpoint.cs
index 6ca2c27..968bdd7 100644
--- a/Persistence.Database/Entity/Setpoint.cs
+++ b/Persistence.Database/Entity/Setpoint.cs
@@ -1,21 +1,21 @@
-using System.ComponentModel.DataAnnotations.Schema;
-using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore;
+using System.ComponentModel.DataAnnotations.Schema;
namespace Persistence.Database.Model
{
- [PrimaryKey(nameof(Key), nameof(Created))]
- public class Setpoint
- {
- [Comment("Ключ")]
- public Guid Key { get; set; }
+ [PrimaryKey(nameof(Key), nameof(Created))]
+ public class Setpoint
+ {
+ [Comment("Ключ")]
+ public Guid Key { get; set; }
- [Column(TypeName = "jsonb"), Comment("Значение уставки")]
- public required object Value { get; set; }
+ [Column(TypeName = "jsonb"), Comment("Значение уставки")]
+ public required object Value { get; set; }
- [Comment("Дата создания уставки")]
- public DateTimeOffset Created { get; set; }
+ [Comment("Дата создания уставки")]
+ public DateTimeOffset Created { get; set; }
- [Comment("Id автора последнего изменения")]
- public Guid IdUser { get; set; }
- }
+ [Comment("Id автора последнего изменения")]
+ public Guid IdUser { get; set; }
+ }
}
diff --git a/Persistence.Database/Entity/TechMessage.cs b/Persistence.Database/Entity/TechMessage.cs
index ea29cc2..8051415 100644
--- a/Persistence.Database/Entity/TechMessage.cs
+++ b/Persistence.Database/Entity/TechMessage.cs
@@ -1,33 +1,33 @@
-using System.ComponentModel.DataAnnotations;
+using Microsoft.EntityFrameworkCore;
+using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
-using Microsoft.EntityFrameworkCore;
namespace Persistence.Database.Entity
{
- public class TechMessage
- {
- [Key, Comment("Id события")]
- public Guid EventId { get; set; }
+ public class TechMessage
+ {
+ [Key, Comment("Id события")]
+ public Guid EventId { get; set; }
- [Comment("Id Категории важности")]
- public int CategoryId { get; set; }
+ [Comment("Id Категории важности")]
+ public int CategoryId { get; set; }
- [Comment("Дата возникновения")]
- public DateTimeOffset Timestamp { get; set; }
+ [Comment("Дата возникновения")]
+ public DateTimeOffset Timestamp { get; set; }
- [Comment("Глубина забоя")]
- public double? Depth { get; set; }
+ [Comment("Глубина забоя")]
+ public double? Depth { get; set; }
- [Column(TypeName = "varchar(512)"), Comment("Текст сообщения")]
- public required string MessageText { get; set; }
+ [Column(TypeName = "varchar(512)"), Comment("Текст сообщения")]
+ public required string MessageText { get; set; }
- [Required, Comment("Id системы автобурения, к которой относится сообщение")]
- public required Guid SystemId { get; set; }
+ [Required, Comment("Id системы автобурения, к которой относится сообщение")]
+ public required Guid SystemId { get; set; }
- [Required, ForeignKey(nameof(SystemId)), Comment("Система автобурения, к которой относится сообщение")]
- public virtual required DrillingSystem System { get; set; }
+ [Required, ForeignKey(nameof(SystemId)), Comment("Система автобурения, к которой относится сообщение")]
+ public virtual required DrillingSystem System { get; set; }
- [Comment("Id пользователя за пультом бурильщика")]
- public Guid UserId { get; set; }
- }
+ [Comment("Id пользователя за пультом бурильщика")]
+ public Guid UserId { get; set; }
+ }
}
diff --git a/Persistence.Database/Entity/TimestampedSet.cs b/Persistence.Database/Entity/TimestampedSet.cs
index c9a0dda..09a50ee 100644
--- a/Persistence.Database/Entity/TimestampedSet.cs
+++ b/Persistence.Database/Entity/TimestampedSet.cs
@@ -6,6 +6,6 @@ namespace Persistence.Database.Entity;
[Comment("Общая таблица данных временных рядов")]
[PrimaryKey(nameof(IdDiscriminator), nameof(Timestamp))]
public record TimestampedSet(
- [property: Comment("Дискриминатор ссылка на тип сохраняемых данных")] Guid IdDiscriminator,
- [property: Comment("Отметка времени, строго в UTC")] DateTimeOffset Timestamp,
+ [property: Comment("Дискриминатор ссылка на тип сохраняемых данных")] Guid IdDiscriminator,
+ [property: Comment("Отметка времени, строго в UTC")] DateTimeOffset Timestamp,
[property: Column(TypeName = "jsonb"), Comment("Набор сохраняемых данных")] IDictionary Set);
diff --git a/Persistence.Database/PersistenceDbContext.cs b/Persistence.Database/PersistenceDbContext.cs
index 849865d..a61ea31 100644
--- a/Persistence.Database/PersistenceDbContext.cs
+++ b/Persistence.Database/PersistenceDbContext.cs
@@ -17,11 +17,11 @@ public class PersistenceDbContext : DbContext
public DbSet ChangeLog => Set();
- public DbSet TechMessage => Set();
+ public DbSet TechMessage => Set();
- public DbSet ParameterData => Set();
+ public DbSet ParameterData => Set();
- public PersistenceDbContext(DbContextOptions options)
+ public PersistenceDbContext(DbContextOptions options)
: base(options)
{
diff --git a/Persistence.IntegrationTests/BaseIntegrationTest.cs b/Persistence.IntegrationTests/BaseIntegrationTest.cs
index 0f1152d..9cc68ab 100644
--- a/Persistence.IntegrationTests/BaseIntegrationTest.cs
+++ b/Persistence.IntegrationTests/BaseIntegrationTest.cs
@@ -1,12 +1,10 @@
-using Microsoft.EntityFrameworkCore;
-using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection;
using Persistence.Database;
using Persistence.Database.Model;
using Xunit;
namespace Persistence.IntegrationTests;
-public abstract class BaseIntegrationTest : IClassFixture,
- IDisposable
+public abstract class BaseIntegrationTest : IClassFixture, IDisposable
{
protected readonly IServiceScope scope;
@@ -23,5 +21,6 @@ public abstract class BaseIntegrationTest : IClassFixture,
{
scope.Dispose();
dbContext.Dispose();
+ GC.SuppressFinalize(this);
}
}
diff --git a/Persistence.IntegrationTests/Controllers/ChangeLogControllerTest.cs b/Persistence.IntegrationTests/Controllers/ChangeLogControllerTest.cs
index c4b5376..43a5418 100644
--- a/Persistence.IntegrationTests/Controllers/ChangeLogControllerTest.cs
+++ b/Persistence.IntegrationTests/Controllers/ChangeLogControllerTest.cs
@@ -3,7 +3,6 @@ using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;
using Persistence.Client;
using Persistence.Client.Clients;
-using Persistence.Database.Entity;
using Persistence.Database.Model;
using Persistence.Models;
using Persistence.Models.Requests;
@@ -14,7 +13,7 @@ namespace Persistence.IntegrationTests.Controllers;
public class ChangeLogControllerTest : BaseIntegrationTest
{
private readonly IChangeLogClient client;
- private static Random generatorRandomDigits = new Random();
+ private static readonly Random generatorRandomDigits = new();
public ChangeLogControllerTest(WebAppFactoryFixture factory) : base(factory)
{
@@ -27,11 +26,11 @@ public class ChangeLogControllerTest : BaseIntegrationTest
[Fact]
public async Task ClearAndInsertRange_InEmptyDb()
{
- // arrange
- dbContext.CleanupDbSet();
+ // arrange
+ dbContext.CleanupDbSet();
- var idDiscriminator = Guid.NewGuid();
- var dtos = Generate(2, DateTimeOffset.UtcNow);
+ var idDiscriminator = Guid.NewGuid();
+ var dtos = Generate(2);
// act
var result = await client.ClearAndAddRange(idDiscriminator, dtos);
@@ -55,7 +54,7 @@ public class ChangeLogControllerTest : BaseIntegrationTest
// assert
Assert.Equal(HttpStatusCode.OK, result.StatusCode);
- Assert.Equal(insertedCount*2, result.Content);
+ Assert.Equal(insertedCount * 2, result.Content);
}
[Fact]
@@ -64,7 +63,7 @@ public class ChangeLogControllerTest : BaseIntegrationTest
// arrange
var count = 1;
var idDiscriminator = Guid.NewGuid();
- var dtos = Generate(count, DateTimeOffset.UtcNow);
+ var dtos = Generate(count);
var dto = dtos.FirstOrDefault()!;
// act
@@ -81,7 +80,7 @@ public class ChangeLogControllerTest : BaseIntegrationTest
// arrange
var count = 3;
var idDiscriminator = Guid.NewGuid();
- var dtos = Generate(count, DateTimeOffset.UtcNow);
+ var dtos = Generate(count);
// act
var result = await client.AddRange(idDiscriminator, dtos);
@@ -94,11 +93,11 @@ public class ChangeLogControllerTest : BaseIntegrationTest
[Fact]
public async Task Update_returns_success()
{
- // arrange
- dbContext.CleanupDbSet();
+ // arrange
+ dbContext.CleanupDbSet();
- var idDiscriminator = Guid.NewGuid();
- var dtos = Generate(1, DateTimeOffset.UtcNow);
+ var idDiscriminator = Guid.NewGuid();
+ var dtos = Generate(1);
var dto = dtos.FirstOrDefault()!;
var result = await client.Add(idDiscriminator, dto);
Assert.Equal(HttpStatusCode.Created, result.StatusCode);
@@ -107,7 +106,7 @@ public class ChangeLogControllerTest : BaseIntegrationTest
.Where(x => x.IdDiscriminator == idDiscriminator)
.FirstOrDefault();
dto = entity.Adapt();
- dto.DepthEnd = dto.DepthEnd + 10;
+ dto.DepthEnd += 10;
// act
result = await client.Update(dto);
@@ -148,7 +147,7 @@ public class ChangeLogControllerTest : BaseIntegrationTest
{
// arrange
var count = 2;
- var dtos = Generate(count, DateTimeOffset.UtcNow);
+ var dtos = Generate(count);
var entities = dtos.Select(d => d.Adapt()).ToArray();
dbContext.ChangeLog.AddRange(entities);
dbContext.SaveChanges();
@@ -174,7 +173,7 @@ public class ChangeLogControllerTest : BaseIntegrationTest
public async Task Delete_returns_success()
{
// arrange
- var dtos = Generate(1, DateTimeOffset.UtcNow);
+ var dtos = Generate(1);
var dto = dtos.FirstOrDefault()!;
var entity = dto.Adapt();
dbContext.ChangeLog.Add(entity);
@@ -193,7 +192,7 @@ public class ChangeLogControllerTest : BaseIntegrationTest
{
// arrange
var count = 10;
- var dtos = Generate(count, DateTimeOffset.UtcNow);
+ var dtos = Generate(count);
var entities = dtos.Select(d => d.Adapt()).ToArray();
dbContext.ChangeLog.AddRange(entities);
dbContext.SaveChanges();
@@ -237,11 +236,11 @@ public class ChangeLogControllerTest : BaseIntegrationTest
[Fact]
public async Task GetByDate_returns_success()
{
- // arrange
- dbContext.CleanupDbSet();
+ // arrange
+ dbContext.CleanupDbSet();
- //создаем записи
- var count = 5;
+ //создаем записи
+ var count = 5;
var changeLogItems = CreateChangeLogItems(count, (-15, 15));
var idDiscriminator = changeLogItems.Item1;
var entities = changeLogItems.Item2;
@@ -255,8 +254,8 @@ public class ChangeLogControllerTest : BaseIntegrationTest
var filterRequest = new SectionPartRequest()
{
- DepthStart = 0,
- DepthEnd = 1000,
+ DepthStart = 0,
+ DepthEnd = 1000,
};
var paginationRequest = new PaginationRequest()
@@ -291,11 +290,11 @@ public class ChangeLogControllerTest : BaseIntegrationTest
int daysAfterNowFilter,
int changeLogCount)
{
- // arrange
- dbContext.CleanupDbSet();
+ // arrange
+ dbContext.CleanupDbSet();
- //создаем записи
- var count = insertedCount;
+ //создаем записи
+ var count = insertedCount;
var daysRange = (daysBeforeNowChangeLog, daysAfterNowChangeLog);
var changeLogItems = CreateChangeLogItems(count, daysRange);
var idDiscriminator = changeLogItems.Item1;
@@ -303,7 +302,7 @@ public class ChangeLogControllerTest : BaseIntegrationTest
foreach (var entity in entities)
{
- entity.DepthEnd = entity.DepthEnd + 10;
+ entity.DepthEnd += 10;
}
var dtos = entities.Select(e => e.Adapt()).ToArray();
await client.UpdateRange(dtos);
@@ -320,7 +319,7 @@ public class ChangeLogControllerTest : BaseIntegrationTest
}
- private static IEnumerable Generate(int count, DateTimeOffset from)
+ private static IEnumerable Generate(int count)
{
for (int i = 0; i < count; i++)
yield return new DataWithWellDepthAndSectionDto()
@@ -342,8 +341,8 @@ public class ChangeLogControllerTest : BaseIntegrationTest
var minDayCount = daysRange.Item1;
var maxDayCount = daysRange.Item2;
- var idDiscriminator = Guid.NewGuid();
- var dtos = Generate(count, DateTimeOffset.UtcNow);
+ Guid idDiscriminator = Guid.NewGuid();
+ var dtos = Generate(count);
var entities = dtos.Select(d =>
{
var entity = d.Adapt();
diff --git a/Persistence.IntegrationTests/Controllers/DataSaubControllerTest.cs b/Persistence.IntegrationTests/Controllers/DataSaubControllerTest.cs
index 9febbb5..49365a8 100644
--- a/Persistence.IntegrationTests/Controllers/DataSaubControllerTest.cs
+++ b/Persistence.IntegrationTests/Controllers/DataSaubControllerTest.cs
@@ -1,12 +1,11 @@
-using Persistence.Client;
-using Persistence.Database.Model;
-using Persistence.Repository.Data;
+using Persistence.Database.Model;
+using Persistence.Models;
using Xunit;
namespace Persistence.IntegrationTests.Controllers;
public class DataSaubControllerTest : TimeSeriesBaseControllerTest
{
- private readonly DataSaubDto dto = new DataSaubDto()
+ private readonly DataSaubDto dto = new()
{
AxialLoad = 1,
BitDepth = 2,
@@ -29,7 +28,7 @@ public class DataSaubControllerTest : TimeSeriesBaseControllerTest();
+ public class SetpointControllerTest : BaseIntegrationTest
+ {
+ private readonly ISetpointClient setpointClient;
+ private class TestObject
+ {
+ public string? Value1 { get; set; }
+ public int? Value2 { get; set; }
+ }
+ public SetpointControllerTest(WebAppFactoryFixture factory) : base(factory)
+ {
+ var scope = factory.Services.CreateScope();
+ var persistenceClientFactory = scope.ServiceProvider
+ .GetRequiredService();
- setpointClient = persistenceClientFactory.GetClient();
- }
+ setpointClient = persistenceClientFactory.GetClient();
+ }
- [Fact]
- public async Task GetCurrent_returns_success()
- {
- //arrange
- var setpointKeys = new List()
- {
- Guid.NewGuid(),
- Guid.NewGuid()
- };
+ [Fact]
+ public async Task GetCurrent_returns_success()
+ {
+ //arrange
+ var setpointKeys = new List()
+ {
+ Guid.NewGuid(),
+ Guid.NewGuid()
+ };
- //act
- var response = await setpointClient.GetCurrent(setpointKeys);
+ //act
+ var response = await setpointClient.GetCurrent(setpointKeys);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.Empty(response.Content);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.Empty(response.Content);
+ }
- [Fact]
- public async Task GetCurrent_AfterSave_returns_success()
- {
- //arrange
- var setpointKey = await Add();
+ [Fact]
+ public async Task GetCurrent_AfterSave_returns_success()
+ {
+ //arrange
+ var setpointKey = await Add();
- //act
- var response = await setpointClient.GetCurrent([setpointKey]);
+ //act
+ var response = await setpointClient.GetCurrent([setpointKey]);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.NotEmpty(response.Content);
- Assert.Equal(setpointKey, response.Content.FirstOrDefault()?.Key);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.NotEmpty(response.Content);
+ Assert.Equal(setpointKey, response.Content.FirstOrDefault()?.Key);
+ }
- [Fact]
- public async Task GetHistory_returns_success()
- {
- //arrange
- var setpointKeys = new List()
- {
- Guid.NewGuid(),
- Guid.NewGuid()
- };
- var historyMoment = DateTimeOffset.UtcNow;
+ [Fact]
+ public async Task GetHistory_returns_success()
+ {
+ //arrange
+ var setpointKeys = new List()
+ {
+ Guid.NewGuid(),
+ Guid.NewGuid()
+ };
+ var historyMoment = DateTimeOffset.UtcNow;
- //act
- var response = await setpointClient.GetHistory(setpointKeys, historyMoment);
+ //act
+ var response = await setpointClient.GetHistory(setpointKeys, historyMoment);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.Empty(response.Content);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.Empty(response.Content);
+ }
- [Fact]
- public async Task GetHistory_AfterSave_returns_success()
- {
- //arrange
- var setpointKey = await Add();
- var historyMoment = DateTimeOffset.UtcNow;
- historyMoment = historyMoment.AddDays(1);
+ [Fact]
+ public async Task GetHistory_AfterSave_returns_success()
+ {
+ //arrange
+ var setpointKey = await Add();
+ var historyMoment = DateTimeOffset.UtcNow;
+ historyMoment = historyMoment.AddDays(1);
- //act
- var response = await setpointClient.GetHistory([setpointKey], historyMoment);
+ //act
+ var response = await setpointClient.GetHistory([setpointKey], historyMoment);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.NotEmpty(response.Content);
- Assert.Equal(setpointKey, response.Content.FirstOrDefault()?.Key);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.NotEmpty(response.Content);
+ Assert.Equal(setpointKey, response.Content.FirstOrDefault()?.Key);
+ }
- [Fact]
- public async Task GetLog_returns_success()
- {
- //arrange
- var setpointKeys = new List()
- {
- Guid.NewGuid(),
- Guid.NewGuid()
- };
+ [Fact]
+ public async Task GetLog_returns_success()
+ {
+ //arrange
+ var setpointKeys = new List()
+ {
+ Guid.NewGuid(),
+ Guid.NewGuid()
+ };
- //act
- var response = await setpointClient.GetLog(setpointKeys);
+ //act
+ var response = await setpointClient.GetLog(setpointKeys);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.Empty(response.Content);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.Empty(response.Content);
+ }
- [Fact]
- public async Task GetLog_AfterSave_returns_success()
- {
- //arrange
- var setpointKey = await Add();
+ [Fact]
+ public async Task GetLog_AfterSave_returns_success()
+ {
+ //arrange
+ var setpointKey = await Add();
- //act
- var response = await setpointClient.GetLog([setpointKey]);
+ //act
+ var response = await setpointClient.GetLog([setpointKey]);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.NotEmpty(response.Content);
- Assert.Equal(setpointKey, response.Content.FirstOrDefault().Key);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.NotEmpty(response.Content);
+ Assert.Equal(setpointKey, response.Content.FirstOrDefault().Key);
+ }
- [Fact]
- public async Task GetDatesRange_returns_success()
- {
- //arrange
- dbContext.CleanupDbSet();
+ [Fact]
+ public async Task GetDatesRange_returns_success()
+ {
+ //arrange
+ dbContext.CleanupDbSet();
//act
var response = await setpointClient.GetDatesRangeAsync(CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.Equal(DateTimeOffset.MinValue, response.Content!.From);
- Assert.Equal(DateTimeOffset.MaxValue, response.Content!.To);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.Equal(DateTimeOffset.MinValue, response.Content!.From);
+ Assert.Equal(DateTimeOffset.MaxValue, response.Content!.To);
+ }
- [Fact]
- public async Task GetDatesRange_AfterSave_returns_success()
- {
- //arrange
- dbContext.CleanupDbSet();
-
- await Add();
+ [Fact]
+ public async Task GetDatesRange_AfterSave_returns_success()
+ {
+ //arrange
+ dbContext.CleanupDbSet();
+
+ await Add();
var dateBegin = DateTimeOffset.MinValue;
var take = 1;
@@ -164,78 +163,78 @@ namespace Persistence.IntegrationTests.Controllers
//act
var response = await setpointClient.GetDatesRangeAsync(CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
- var expectedValue = part.Content!
- .FirstOrDefault()!.Created
- .ToString("dd.MM.yyyy-HH:mm:ss");
- var actualValueFrom = response.Content.From
- .ToString("dd.MM.yyyy-HH:mm:ss");
- Assert.Equal(expectedValue, actualValueFrom);
+ var expectedValue = part.Content!
+ .FirstOrDefault()!.Created
+ .ToString("dd.MM.yyyy-HH:mm:ss");
+ var actualValueFrom = response.Content.From
+ .ToString("dd.MM.yyyy-HH:mm:ss");
+ Assert.Equal(expectedValue, actualValueFrom);
- var actualValueTo = response.Content.To
- .ToString("dd.MM.yyyy-HH:mm:ss");
- Assert.Equal(expectedValue, actualValueTo);
- }
+ var actualValueTo = response.Content.To
+ .ToString("dd.MM.yyyy-HH:mm:ss");
+ Assert.Equal(expectedValue, actualValueTo);
+ }
- [Fact]
- public async Task GetPart_returns_success()
- {
- //arrange
- var dateBegin = DateTimeOffset.UtcNow;
- var take = 2;
+ [Fact]
+ public async Task GetPart_returns_success()
+ {
+ //arrange
+ var dateBegin = DateTimeOffset.UtcNow;
+ var take = 2;
//act
var response = await setpointClient.GetPart(dateBegin, take, CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.Empty(response.Content);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.Empty(response.Content);
+ }
- [Fact]
- public async Task GetPart_AfterSave_returns_success()
- {
- //arrange
- var dateBegin = DateTimeOffset.UtcNow;
- var take = 1;
- await Add();
+ [Fact]
+ public async Task GetPart_AfterSave_returns_success()
+ {
+ //arrange
+ var dateBegin = DateTimeOffset.UtcNow;
+ var take = 1;
+ await Add();
//act
var response = await setpointClient.GetPart(dateBegin, take, CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.NotEmpty(response.Content);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.NotEmpty(response.Content);
+ }
- [Fact]
- public async Task Save_returns_success()
- {
- await Add();
- }
+ [Fact]
+ public async Task Save_returns_success()
+ {
+ await Add();
+ }
- private async Task Add()
- {
- //arrange
- var setpointKey = Guid.NewGuid();
- var setpointValue = new TestObject()
- {
- value1 = "1",
- value2 = 2
- };
+ private async Task Add()
+ {
+ //arrange
+ var setpointKey = Guid.NewGuid();
+ var setpointValue = new TestObject()
+ {
+ Value1 = "1",
+ Value2 = 2
+ };
- //act
- var response = await setpointClient.Add(setpointKey, setpointValue);
+ //act
+ var response = await setpointClient.Add(setpointKey, setpointValue);
- //assert
- Assert.Equal(HttpStatusCode.Created, response.StatusCode);
+ //assert
+ Assert.Equal(HttpStatusCode.Created, response.StatusCode);
- return setpointKey;
- }
- }
+ return setpointKey;
+ }
+ }
}
diff --git a/Persistence.IntegrationTests/Controllers/TechMessagesControllerTest.cs b/Persistence.IntegrationTests/Controllers/TechMessagesControllerTest.cs
index a87c19a..f970b25 100644
--- a/Persistence.IntegrationTests/Controllers/TechMessagesControllerTest.cs
+++ b/Persistence.IntegrationTests/Controllers/TechMessagesControllerTest.cs
@@ -1,4 +1,3 @@
-using System.Net;
using Microsoft.Extensions.Caching.Memory;
using Microsoft.Extensions.DependencyInjection;
using Persistence.Client;
@@ -6,284 +5,285 @@ using Persistence.Client.Clients;
using Persistence.Database.Entity;
using Persistence.Models;
using Persistence.Models.Requests;
+using System.Net;
using Xunit;
namespace Persistence.IntegrationTests.Controllers
{
- public class TechMessagesControllerTest : BaseIntegrationTest
- {
- private static readonly string SystemCacheKey = $"{typeof(Database.Entity.DrillingSystem).FullName}CacheKey";
- private readonly ITechMessagesClient techMessagesClient;
- private readonly IMemoryCache memoryCache;
- public TechMessagesControllerTest(WebAppFactoryFixture factory) : base(factory)
- {
- var scope = factory.Services.CreateScope();
- var persistenceClientFactory = scope.ServiceProvider
- .GetRequiredService();
+ public class TechMessagesControllerTest : BaseIntegrationTest
+ {
+ private static readonly string SystemCacheKey = $"{typeof(Database.Entity.DrillingSystem).FullName}CacheKey";
+ private readonly ITechMessagesClient techMessagesClient;
+ private readonly IMemoryCache memoryCache;
+ public TechMessagesControllerTest(WebAppFactoryFixture factory) : base(factory)
+ {
+ var scope = factory.Services.CreateScope();
+ var persistenceClientFactory = scope.ServiceProvider
+ .GetRequiredService();
- techMessagesClient = persistenceClientFactory.GetClient();
- memoryCache = scope.ServiceProvider.GetRequiredService();
- }
+ techMessagesClient = persistenceClientFactory.GetClient();
+ memoryCache = scope.ServiceProvider.GetRequiredService();
+ }
- [Fact]
- public async Task GetPage_returns_success()
- {
- //arrange
- memoryCache.Remove(SystemCacheKey);
- dbContext.CleanupDbSet();
- dbContext.CleanupDbSet();
+ [Fact]
+ public async Task GetPage_returns_success()
+ {
+ //arrange
+ memoryCache.Remove(SystemCacheKey);
+ dbContext.CleanupDbSet();
+ dbContext.CleanupDbSet();
- var requestDto = new PaginationRequest()
- {
- Skip = 1,
- Take = 2,
- SortSettings = nameof(TechMessage.CategoryId)
- };
+ var requestDto = new PaginationRequest()
+ {
+ Skip = 1,
+ Take = 2,
+ SortSettings = nameof(TechMessage.CategoryId)
+ };
- //act
- var response = await techMessagesClient.GetPage(requestDto, CancellationToken.None);
+ //act
+ var response = await techMessagesClient.GetPage(requestDto, CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.Empty(response.Content.Items);
- Assert.Equal(requestDto.Skip, response.Content.Skip);
- Assert.Equal(requestDto.Take, response.Content.Take);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.Empty(response.Content.Items);
+ Assert.Equal(requestDto.Skip, response.Content.Skip);
+ Assert.Equal(requestDto.Take, response.Content.Take);
+ }
- [Fact]
- public async Task GetPage_AfterSave_returns_success()
- {
- //arrange
- var dtos = await InsertRange();
- var dtosCount = dtos.Count();
- var requestDto = new PaginationRequest()
- {
- Skip = 0,
- Take = 2,
- SortSettings = nameof(TechMessage.CategoryId)
- };
+ [Fact]
+ public async Task GetPage_AfterSave_returns_success()
+ {
+ //arrange
+ var dtos = await InsertRange();
+ var dtosCount = dtos.Count();
+ var requestDto = new PaginationRequest()
+ {
+ Skip = 0,
+ Take = 2,
+ SortSettings = nameof(TechMessage.CategoryId)
+ };
- //act
- var response = await techMessagesClient.GetPage(requestDto, CancellationToken.None);
+ //act
+ var response = await techMessagesClient.GetPage(requestDto, CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.Equal(dtosCount, response.Content.Count);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.Equal(dtosCount, response.Content.Count);
+ }
- [Fact]
- public async Task InsertRange_returns_success()
- {
- await InsertRange();
- }
+ [Fact]
+ public async Task InsertRange_returns_success()
+ {
+ await InsertRange();
+ }
- [Fact]
- public async Task InsertRange_returns_BadRequest()
- {
- //arrange
- var dtos = new List()
- {
- new TechMessageDto()
- {
- EventId = Guid.NewGuid(),
- CategoryId = -1, // < 0
+ [Fact]
+ public async Task InsertRange_returns_BadRequest()
+ {
+ //arrange
+ var dtos = new List()
+ {
+ new()
+ {
+ EventId = Guid.NewGuid(),
+ CategoryId = -1, // < 0
Timestamp = DateTimeOffset.UtcNow,
- Depth = -1, // < 0
+ Depth = -1, // < 0
MessageText = string.Empty, // length < 0
System = string.Concat(Enumerable.Repeat(nameof(TechMessageDto.System), 100)), // length > 256
UserId = Guid.NewGuid()
- }
- };
+ }
+ };
- //act
- var response = await techMessagesClient.AddRange(dtos, CancellationToken.None);
+ //act
+ var response = await techMessagesClient.AddRange(dtos, CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.BadRequest, response.StatusCode);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.BadRequest, response.StatusCode);
+ }
- [Fact]
- public async Task GetSystems_returns_success()
- {
- //arrange
- memoryCache.Remove(SystemCacheKey);
- dbContext.CleanupDbSet();
- dbContext.CleanupDbSet();
+ [Fact]
+ public async Task GetSystems_returns_success()
+ {
+ //arrange
+ memoryCache.Remove(SystemCacheKey);
+ dbContext.CleanupDbSet();
+ dbContext.CleanupDbSet();
- //act
- var response = await techMessagesClient.GetSystems(CancellationToken.None);
+ //act
+ var response = await techMessagesClient.GetSystems(CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.Empty(response.Content);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.Empty(response.Content);
+ }
- [Fact]
- public async Task GetSystems_AfterSave_returns_success()
- {
- //arrange
- var dtos = await InsertRange();
- var systems = dtos
- .Select(e => e.System)
- .Distinct()
- .ToArray();
+ [Fact]
+ public async Task GetSystems_AfterSave_returns_success()
+ {
+ //arrange
+ var dtos = await InsertRange();
+ var systems = dtos
+ .Select(e => e.System)
+ .Distinct()
+ .ToArray();
- //act
- var response = await techMessagesClient.GetSystems(CancellationToken.None);
+ //act
+ var response = await techMessagesClient.GetSystems(CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- string?[]? content = response.Content?.ToArray();
- Assert.Equal(systems, content);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ string?[]? content = response.Content?.ToArray();
+ Assert.Equal(systems, content);
+ }
- [Fact]
- public async Task GetStatistics_returns_success()
- {
- //arrange
- memoryCache.Remove(SystemCacheKey);
- dbContext.CleanupDbSet();
- dbContext.CleanupDbSet();
+ [Fact]
+ public async Task GetStatistics_returns_success()
+ {
+ //arrange
+ memoryCache.Remove(SystemCacheKey);
+ dbContext.CleanupDbSet();
+ dbContext.CleanupDbSet();
- var imortantId = 1;
- var autoDrillingSystem = nameof(TechMessageDto.System);
+ var importantId = 1;
+ var autoDrillingSystem = nameof(TechMessageDto.System);
- //act
- var response = await techMessagesClient.GetStatistics(autoDrillingSystem, imortantId, CancellationToken.None);
+ //act
+ var response = await techMessagesClient.GetStatistics(autoDrillingSystem, importantId, CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.Empty(response.Content);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.Empty(response.Content);
+ }
- [Fact]
- public async Task GetStatistics_AfterSave_returns_success()
- {
- //arrange
- var imortantId = 0;
- var autoDrillingSystem = nameof(TechMessageDto.System);
- var dtos = await InsertRange();
- var filteredDtos = dtos.Where(e => e.CategoryId == imortantId && e.System == autoDrillingSystem);
+ [Fact]
+ public async Task GetStatistics_AfterSave_returns_success()
+ {
+ //arrange
+ var importantId = 0;
+ var autoDrillingSystem = nameof(TechMessageDto.System);
+ var dtos = await InsertRange();
+ var filteredDtos = dtos.Where(e => e.CategoryId == importantId && e.System == autoDrillingSystem);
- //act
- var response = await techMessagesClient.GetStatistics(autoDrillingSystem, imortantId, CancellationToken.None);
+ //act
+ var response = await techMessagesClient.GetStatistics(autoDrillingSystem, importantId, CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- var categories = response.Content
- .FirstOrDefault()?.Categories
- .FirstOrDefault(e => e.Key == 0).Value;
- Assert.Equal(filteredDtos.Count(), categories);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ var categories = response.Content
+ .FirstOrDefault()?.Categories
+ .FirstOrDefault(e => e.Key == 0).Value;
+ Assert.Equal(filteredDtos.Count(), categories);
+ }
- [Fact]
- public async Task GetDatesRange_returns_success()
- {
- //act
- var response = await techMessagesClient.GetDatesRangeAsync(CancellationToken.None);
+ [Fact]
+ public async Task GetDatesRange_returns_success()
+ {
+ //act
+ var response = await techMessagesClient.GetDatesRangeAsync(CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- //Assert.Equal(DateTimeOffset.MinValue, response.Content?.From);
- //Assert.Equal(DateTimeOffset.MaxValue, response.Content?.To);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ //Assert.Equal(DateTimeOffset.MinValue, response.Content?.From);
+ //Assert.Equal(DateTimeOffset.MaxValue, response.Content?.To);
+ }
- [Fact]
- public async Task GetDatesRange_AfterSave_returns_success()
- {
- //arrange
- await InsertRange();
+ [Fact]
+ public async Task GetDatesRange_AfterSave_returns_success()
+ {
+ //arrange
+ await InsertRange();
- //act
- var response = await techMessagesClient.GetDatesRangeAsync(CancellationToken.None);
+ //act
+ var response = await techMessagesClient.GetDatesRangeAsync(CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.NotNull(response.Content?.From);
- Assert.NotNull(response.Content?.To);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.NotNull(response.Content?.From);
+ Assert.NotNull(response.Content?.To);
+ }
- [Fact]
- public async Task GetPart_returns_success()
- {
- //arrange
- var dateBegin = DateTimeOffset.UtcNow;
- var take = 2;
+ [Fact]
+ public async Task GetPart_returns_success()
+ {
+ //arrange
+ var dateBegin = DateTimeOffset.UtcNow;
+ var take = 2;
- //act
- var response = await techMessagesClient.GetPart(dateBegin, take, CancellationToken.None);
+ //act
+ var response = await techMessagesClient.GetPart(dateBegin, take, CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.Empty(response.Content);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.Empty(response.Content);
+ }
- [Fact]
- public async Task GetPart_AfterSave_returns_success()
- {
- //arrange
- var dateBegin = DateTimeOffset.UtcNow;
- var take = 1;
- await InsertRange();
+ [Fact]
+ public async Task GetPart_AfterSave_returns_success()
+ {
+ //arrange
+ var dateBegin = DateTimeOffset.UtcNow;
+ var take = 1;
+ await InsertRange();
- //act
- var response = await techMessagesClient.GetPart(dateBegin, take, CancellationToken.None);
+ //act
+ var response = await techMessagesClient.GetPart(dateBegin, take, CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- Assert.NotEmpty(response.Content);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ Assert.NotEmpty(response.Content);
+ }
- private async Task> InsertRange()
- {
- //arrange
- memoryCache.Remove(SystemCacheKey);
- dbContext.CleanupDbSet();
- dbContext.CleanupDbSet();
+ private async Task> InsertRange()
+ {
+ //arrange
+ memoryCache.Remove(SystemCacheKey);
+ dbContext.CleanupDbSet();
+ dbContext.CleanupDbSet();
- var dtos = new List()
- {
- new TechMessageDto()
- {
- EventId = Guid.NewGuid(),
- CategoryId = 1,
- Timestamp = DateTimeOffset.UtcNow,
- Depth = 1.11,
- MessageText = nameof(TechMessageDto.MessageText),
- System = nameof(TechMessageDto.System).ToLower(),
- UserId = Guid.NewGuid()
- },
- new TechMessageDto()
- {
- EventId = Guid.NewGuid(),
- CategoryId = 2,
- Timestamp = DateTimeOffset.UtcNow,
- Depth = 2.22,
- MessageText = nameof(TechMessageDto.MessageText),
- System = nameof(TechMessageDto.System).ToLower(),
- UserId = Guid.NewGuid()
- }
- };
+ var dtos = new List()
+ {
+ new()
+ {
+ EventId = Guid.NewGuid(),
+ CategoryId = 1,
+ Timestamp = DateTimeOffset.UtcNow,
+ Depth = 1.11,
+ MessageText = nameof(TechMessageDto.MessageText),
+ System = nameof(TechMessageDto.System).ToLower(),
+ UserId = Guid.NewGuid()
+ },
+ new()
+ {
+ EventId = Guid.NewGuid(),
+ CategoryId = 2,
+ Timestamp = DateTimeOffset.UtcNow,
+ Depth = 2.22,
+ MessageText = nameof(TechMessageDto.MessageText),
+ System = nameof(TechMessageDto.System).ToLower(),
+ UserId = Guid.NewGuid()
+ }
+ };
- //act
- var response = await techMessagesClient.AddRange(dtos, CancellationToken.None);
+ //act
+ var response = await techMessagesClient.AddRange(dtos, CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.Created, response.StatusCode);
- Assert.Equal(dtos.Count, response.Content);
+ //assert
+ Assert.Equal(HttpStatusCode.Created, response.StatusCode);
+ Assert.Equal(dtos.Count, response.Content);
- return dtos;
- }
- }
+ return dtos;
+ }
+ }
}
diff --git a/Persistence.IntegrationTests/Controllers/TimeSeriesBaseControllerTest.cs b/Persistence.IntegrationTests/Controllers/TimeSeriesBaseControllerTest.cs
index 08bb11e..952522d 100644
--- a/Persistence.IntegrationTests/Controllers/TimeSeriesBaseControllerTest.cs
+++ b/Persistence.IntegrationTests/Controllers/TimeSeriesBaseControllerTest.cs
@@ -1,27 +1,28 @@
-using System.Net;
using Mapster;
using Microsoft.Extensions.DependencyInjection;
using Persistence.Client;
using Persistence.Client.Clients;
using Persistence.Database.Model;
+using System.Net;
using Xunit;
namespace Persistence.IntegrationTests.Controllers;
+
public abstract class TimeSeriesBaseControllerTest : BaseIntegrationTest
where TEntity : class, ITimestampedData, new()
where TDto : class, new()
{
- private ITimeSeriesClient timeSeriesClient;
+ private readonly ITimeSeriesClient timeSeriesClient;
public TimeSeriesBaseControllerTest(WebAppFactoryFixture factory) : base(factory)
{
dbContext.CleanupDbSet();
- var scope = factory.Services.CreateScope();
- var persistenceClientFactory = scope.ServiceProvider
- .GetRequiredService();
+ var scope = factory.Services.CreateScope();
+ var persistenceClientFactory = scope.ServiceProvider
+ .GetRequiredService();
- timeSeriesClient = persistenceClientFactory.GetClient>();
+ timeSeriesClient = persistenceClientFactory.GetClient>();
}
public async Task InsertRangeSuccess(TDto dto)
@@ -30,7 +31,7 @@ public abstract class TimeSeriesBaseControllerTest : BaseIntegrat
var expected = dto.Adapt();
//act
- var response = await timeSeriesClient.AddRange(new TDto[] { expected });
+ var response = await timeSeriesClient.AddRange([expected]);
//assert
Assert.Equal(HttpStatusCode.OK, response.StatusCode);
@@ -104,7 +105,7 @@ public abstract class TimeSeriesBaseControllerTest : BaseIntegrat
Assert.Equal(HttpStatusCode.OK, response.StatusCode);
Assert.NotNull(response.Content);
- var ratio = entities.Count() / approxPointsCount;
+ var ratio = entities.Count / approxPointsCount;
if (ratio > 1)
{
var expectedResampledCount = entities
@@ -115,7 +116,7 @@ public abstract class TimeSeriesBaseControllerTest : BaseIntegrat
}
else
{
- Assert.Equal(entities.Count(), response.Content.Count());
+ Assert.Equal(entities.Count, response.Content.Count());
}
diff --git a/Persistence.IntegrationTests/Controllers/TimestampedSetControllerTest.cs b/Persistence.IntegrationTests/Controllers/TimestampedSetControllerTest.cs
index 3fc7dff..1e7aa7e 100644
--- a/Persistence.IntegrationTests/Controllers/TimestampedSetControllerTest.cs
+++ b/Persistence.IntegrationTests/Controllers/TimestampedSetControllerTest.cs
@@ -39,7 +39,7 @@ public class TimestampedSetControllerTest : BaseIntegrationTest
Guid idDiscriminator = Guid.NewGuid();
int count = 10;
IEnumerable testSets = Generate(count, DateTimeOffset.Now.ToOffset(TimeSpan.FromHours(7)));
- var insertResponse = await client.AddRange(idDiscriminator, testSets);
+ await client.AddRange(idDiscriminator, testSets);
// act
var response = await client.Get(idDiscriminator, null, null, 0, int.MaxValue);
@@ -58,7 +58,7 @@ public class TimestampedSetControllerTest : BaseIntegrationTest
Guid idDiscriminator = Guid.NewGuid();
int count = 10;
IEnumerable testSets = Generate(count, DateTimeOffset.Now.ToOffset(TimeSpan.FromHours(7)));
- var insertResponse = await client.AddRange(idDiscriminator, testSets);
+ await client.AddRange(idDiscriminator, testSets);
string[] props = ["A"];
// act
@@ -69,12 +69,12 @@ public class TimestampedSetControllerTest : BaseIntegrationTest
Assert.NotNull(response.Content);
var items = response.Content!;
Assert.Equal(count, items.Count());
- foreach ( var item in items )
+ foreach (var item in items)
{
Assert.Single(item.Set);
var kv = item.Set.First();
Assert.Equal("A", kv.Key);
- }
+ }
}
[Fact]
@@ -85,7 +85,7 @@ public class TimestampedSetControllerTest : BaseIntegrationTest
int count = 10;
var dateMin = DateTimeOffset.Now;
var dateMax = DateTimeOffset.Now.AddSeconds(count);
- IEnumerable testSets = Generate(count, dateMin.ToOffset(TimeSpan.FromHours(7)));
+ IEnumerable testSets = Generate(count, dateMin.ToOffset(TimeSpan.FromHours(7)));
var insertResponse = await client.AddRange(idDiscriminator, testSets);
var tail = testSets.OrderBy(t => t.Timestamp).Skip(count / 2).Take(int.MaxValue);
var geDate = tail.First().Timestamp;
@@ -111,7 +111,7 @@ public class TimestampedSetControllerTest : BaseIntegrationTest
Guid idDiscriminator = Guid.NewGuid();
int count = 10;
IEnumerable testSets = Generate(count, DateTimeOffset.Now.ToOffset(TimeSpan.FromHours(7)));
- var insertResponse = await client.AddRange(idDiscriminator, testSets);
+ await client.AddRange(idDiscriminator, testSets);
var expectedCount = count / 2;
// act
@@ -133,7 +133,7 @@ public class TimestampedSetControllerTest : BaseIntegrationTest
var expectedCount = 1;
int count = 10 + expectedCount;
IEnumerable testSets = Generate(count, DateTimeOffset.Now.ToOffset(TimeSpan.FromHours(7)));
- var insertResponse = await client.AddRange(idDiscriminator, testSets);
+ await client.AddRange(idDiscriminator, testSets);
// act
var response = await client.Get(idDiscriminator, null, null, count - expectedCount, count);
@@ -152,7 +152,7 @@ public class TimestampedSetControllerTest : BaseIntegrationTest
Guid idDiscriminator = Guid.NewGuid();
int count = 10;
IEnumerable testSets = Generate(count, DateTimeOffset.Now.ToOffset(TimeSpan.FromHours(7)));
- var insertResponse = await client.AddRange(idDiscriminator, testSets);
+ await client.AddRange(idDiscriminator, testSets);
var expectedCount = 8;
// act
@@ -172,9 +172,9 @@ public class TimestampedSetControllerTest : BaseIntegrationTest
Guid idDiscriminator = Guid.NewGuid();
int count = 10;
var dateMin = DateTimeOffset.Now;
- var dateMax = DateTimeOffset.Now.AddSeconds(count-1);
+ var dateMax = DateTimeOffset.Now.AddSeconds(count - 1);
IEnumerable testSets = Generate(count, dateMin.ToOffset(TimeSpan.FromHours(7)));
- var insertResponse = await client.AddRange(idDiscriminator, testSets);
+ await client.AddRange(idDiscriminator, testSets);
var tolerance = TimeSpan.FromSeconds(1);
// act
@@ -195,7 +195,7 @@ public class TimestampedSetControllerTest : BaseIntegrationTest
Guid idDiscriminator = Guid.NewGuid();
int count = 144;
IEnumerable testSets = Generate(count, DateTimeOffset.Now.ToOffset(TimeSpan.FromHours(7)));
- var insertResponse = await client.AddRange(idDiscriminator, testSets);
+ await client.AddRange(idDiscriminator, testSets);
// act
var response = await client.Count(idDiscriminator);
diff --git a/Persistence.IntegrationTests/Controllers/WitsDataControllerTest.cs b/Persistence.IntegrationTests/Controllers/WitsDataControllerTest.cs
index 12866a4..f279845 100644
--- a/Persistence.IntegrationTests/Controllers/WitsDataControllerTest.cs
+++ b/Persistence.IntegrationTests/Controllers/WitsDataControllerTest.cs
@@ -1,235 +1,235 @@
-using System.Net;
-using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection;
using Persistence.Client;
using Persistence.Client.Clients;
using Persistence.Database.Entity;
using Persistence.Models;
+using System.Net;
using Xunit;
namespace Persistence.IntegrationTests.Controllers;
public class WitsDataControllerTest : BaseIntegrationTest
{
- private IWitsDataClient witsDataClient;
+ private IWitsDataClient witsDataClient;
- public WitsDataControllerTest(WebAppFactoryFixture factory) : base(factory)
- {
- var scope = factory.Services.CreateScope();
- var persistenceClientFactory = scope.ServiceProvider
- .GetRequiredService();
+ public WitsDataControllerTest(WebAppFactoryFixture factory) : base(factory)
+ {
+ var scope = factory.Services.CreateScope();
+ var persistenceClientFactory = scope.ServiceProvider
+ .GetRequiredService();
- witsDataClient = persistenceClientFactory.GetClient();
- }
+ witsDataClient = persistenceClientFactory.GetClient();
+ }
- [Fact]
- public async Task GetDatesRangeAsync_returns_success()
- {
- //arrange
- dbContext.CleanupDbSet();
+ [Fact]
+ public async Task GetDatesRangeAsync_returns_success()
+ {
+ //arrange
+ dbContext.CleanupDbSet();
- var discriminatorId = Guid.NewGuid();
+ var discriminatorId = Guid.NewGuid();
- //act
- var response = await witsDataClient.GetDatesRangeAsync(discriminatorId, CancellationToken.None);
+ //act
+ var response = await witsDataClient.GetDatesRangeAsync(discriminatorId, CancellationToken.None);
- //assert
- Assert.Equal(HttpStatusCode.OK, response.StatusCode);
- Assert.NotNull(response.Content);
- }
+ //assert
+ Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+ Assert.NotNull(response.Content);
+ }
- [Fact]
- public async Task GetPart_returns_success()
- {
- //arrange
- dbContext.CleanupDbSet