on.nemtina/persistence
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

Setpoint API #1

Merged
on.nemtina merged 10 commits from Setpoint into master 2024-11-25 10:33:36 +05:00
Conversation 0 Commits 10 Files Changed 16 +4 -3
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 4fa00de88e - Show all commits

6
Persistence.IntegrationTests/Controllers/SetpointControllerTest.cs
View File

@ -49,7 +49,7 @@ namespace Persistence.IntegrationTests.Controllers
Assert.Equal(HttpStatusCode.OK, response.StatusCode); Assert.Equal(HttpStatusCode.OK, response.StatusCode);
Assert.NotNull(response.Content); Assert.NotNull(response.Content);
Assert.NotEmpty(response.Content); Assert.NotEmpty(response.Content);
Assert.Equal(response.Content.FirstOrDefault()?.Key, setpointKey); Assert.Equal(setpointKey, response.Content.FirstOrDefault()?.Key);
} }
[Fact] [Fact]
@ -87,7 +87,7 @@ namespace Persistence.IntegrationTests.Controllers
Assert.Equal(HttpStatusCode.OK, response.StatusCode); Assert.Equal(HttpStatusCode.OK, response.StatusCode);
Assert.NotNull(response.Content); Assert.NotNull(response.Content);
Assert.NotEmpty(response.Content); Assert.NotEmpty(response.Content);
Assert.Equal(response.Content.FirstOrDefault()?.Key, setpointKey); Assert.Equal(setpointKey, response.Content.FirstOrDefault()?.Key);
} }
[Fact] [Fact]
@ -122,7 +122,7 @@ namespace Persistence.IntegrationTests.Controllers
Assert.Equal(HttpStatusCode.OK, response.StatusCode); Assert.Equal(HttpStatusCode.OK, response.StatusCode);
Assert.NotNull(response.Content); Assert.NotNull(response.Content);
Assert.NotEmpty(response.Content); Assert.NotEmpty(response.Content);
Assert.Equal(response.Content.FirstOrDefault().Value.FirstOrDefault()?.Key, setpointKey); Assert.Equal(setpointKey, response.Content.FirstOrDefault()?.Key);
} }
[Fact] [Fact]

1
Persistence.Repository/Repositories/SetpointRepository.cs
View File

@ -35,6 +35,7 @@ namespace Persistence.Repository.Repositories
.ToArrayAsync(token); .ToArrayAsync(token);
var filteredEntities = entities var filteredEntities = entities
.GroupBy(e => e.Key) .GroupBy(e => e.Key)
.Select(e => e.OrderBy(o => o.Created))
.Select(e => e.Where(e => e.Created <= historyMoment).Last()); .Select(e => e.Where(e => e.Created <= historyMoment).Last());
var dtos = filteredEntities var dtos = filteredEntities
.Select(e => e.Adapt<SetpointValueDto>()); .Select(e => e.Adapt<SetpointValueDto>());