Fix #1552 - Migrate jobs to infrastructure

src/AzureIoTHub.Portal.Application/AzureIoTHub.Portal.Application.csproj

@@ -8,6 +8,7 @@
 
   <ItemGroup>
     <PackageReference Include="AutoMapper" Version="12.0.0" />
+    <PackageReference Include="Azure.Messaging.EventHubs" Version="5.7.5" />
     <PackageReference Include="Microsoft.Azure.Devices" Version="1.38.2" />
     <PackageReference Include="Microsoft.Azure.Devices.Provisioning.Service" Version="1.18.2" />
     <PackageReference Include="AutoMapper.Extensions.Microsoft.DependencyInjection" Version="12.0.0" />

src/AzureIoTHub.Portal.Server/Services/IConfigService.cs → src/AzureIoTHub.Portal.Application/Services/IConfigService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using System.Collections.Generic;
     using System.Threading.Tasks;

src/AzureIoTHub.Portal.Server/Services/IDeviceConfigurationsService.cs → src/AzureIoTHub.Portal.Application/Services/IDeviceConfigurationsService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using AzureIoTHub.Portal.Models.v10;
     using AzureIoTHub.Portal.Shared.Models.v10;

src/AzureIoTHub.Portal.Server/Services/IDeviceModelPropertiesService.cs → src/AzureIoTHub.Portal.Application/Services/IDeviceModelPropertiesService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using AzureIoTHub.Portal.Domain.Entities;
     using System.Collections.Generic;

src/AzureIoTHub.Portal.Server/Services/IDeviceModelService.cs → src/AzureIoTHub.Portal.Application/Services/IDeviceModelService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using System.Collections.Generic;
     using System.Threading.Tasks;

src/AzureIoTHub.Portal.Server/Services/IDevicePropertyService.cs → src/AzureIoTHub.Portal.Application/Services/IDevicePropertyService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using Models.v10;
     using System.Collections.Generic;

src/AzureIoTHub.Portal.Server/Services/IDeviceService.cs → src/AzureIoTHub.Portal.Application/Services/IDeviceService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using System.Collections.Generic;
     using System.Threading.Tasks;

src/AzureIoTHub.Portal.Server/Services/IDeviceTagService.cs → src/AzureIoTHub.Portal.Application/Services/IDeviceTagService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using AzureIoTHub.Portal.Models.v10;
     using System.Collections.Generic;

src/AzureIoTHub.Portal.Server/Services/IEdgeDevicesService.cs → src/AzureIoTHub.Portal.Application/Services/IEdgeDevicesService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using System.Collections.Generic;
     using System.Threading.Tasks;

src/AzureIoTHub.Portal.Server/Services/IEdgeModelService.cs → src/AzureIoTHub.Portal.Application/Services/IEdgeModelService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using System.Collections.Generic;
     using System.Threading.Tasks;

src/AzureIoTHub.Portal.Server/Services/IExternalDeviceService.cs → src/AzureIoTHub.Portal.Application/Services/IExternalDeviceService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using System.Collections.Generic;
     using System.Threading.Tasks;

src/AzureIoTHub.Portal.Server/Services/IIdeaService.cs → src/AzureIoTHub.Portal.Application/Services/IIdeaService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using System.Threading.Tasks;
     using Shared.Models.v1._0;

src/AzureIoTHub.Portal.Server/Services/ILoRaWANCommandService.cs → src/AzureIoTHub.Portal.Application/Services/ILoRaWANCommandService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using System.Threading.Tasks;
     using Models.v10.LoRaWAN;

src/AzureIoTHub.Portal.Server/Services/ILoRaWANConcentratorService.cs → src/AzureIoTHub.Portal.Application/Services/ILoRaWANConcentratorService.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Services
+namespace AzureIoTHub.Portal.Application.Services
 {
     using System.Threading.Tasks;
     using AzureIoTHub.Portal.Models.v10.LoRaWAN;

src/AzureIoTHub.Portal.Infrastructure/AzureIoTHub.Portal.Infrastructure.csproj

@@ -107,6 +107,8 @@
 
   <ItemGroup>
     <PackageReference Include="Azure.Data.Tables" Version="12.7.1" />
+    <PackageReference Include="Azure.Messaging.EventHubs" Version="5.7.5" />
+    <PackageReference Include="Azure.Messaging.EventHubs.Processor" Version="5.7.5" />
     <PackageReference Include="Azure.Storage.Blobs" Version="12.14.1" />
     <PackageReference Include="CsvHelper" Version="30.0.1" />
     <PackageReference Include="Microsoft.AspNetCore.Hosting" Version="2.2.7" />
@@ -132,6 +134,9 @@
     <PackageReference Include="Newtonsoft.Json" Version="13.0.2" />
     <PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="7.0.0" />
     <PackageReference Include="Polly.Extensions.Http" Version="3.0.0" />
+    <PackageReference Include="prometheus-net" Version="7.0.0" />
+    <PackageReference Include="Quartz" Version="3.5.0" />
+    <PackageReference Include="Quartz.Extensions.DependencyInjection" Version="3.5.0" />
     <PackageReference Include="System.Linq.Dynamic.Core" Version="1.2.23" />
     <PackageReference Include="EntityFrameworkCore.Exceptions.PostgreSQL" Version="6.0.3" />
 

src/AzureIoTHub.Portal.Server/Extensions/QuartzConfiguratorExtension.cs → src/AzureIoTHub.Portal.Infrastructure/Extenstions/QuartzConfiguratorExtension.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Extensions
+namespace AzureIoTHub.Portal.Infrastructure.Extensions
 {
     using AzureIoTHub.Portal.Domain;
     using Quartz;

src/AzureIoTHub.Portal.Server/Jobs/ConcentratorMetricExporterJob.cs → src/AzureIoTHub.Portal.Infrastructure/Jobs/ConcentratorMetricExporterJob.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Jobs
+namespace AzureIoTHub.Portal.Infrastructure.Jobs
 {
     using System.Threading.Tasks;
     using AzureIoTHub.Portal.Domain.Shared.Constants;

src/AzureIoTHub.Portal.Server/Jobs/ConcentratorMetricLoaderJob.cs → src/AzureIoTHub.Portal.Infrastructure/Jobs/ConcentratorMetricLoaderJob.cs

@@ -1,11 +1,11 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Jobs
+namespace AzureIoTHub.Portal.Infrastructure.Jobs
 {
     using System.Threading.Tasks;
     using AzureIoTHub.Portal.Domain.Exceptions;
-    using AzureIoTHub.Portal.Server.Services;
+    using AzureIoTHub.Portal.Application.Services;
     using Microsoft.Extensions.Logging;
     using Quartz;
     using Shared.Models.v1._0;

src/AzureIoTHub.Portal.Server/Jobs/DeviceMetricExporterJob.cs → src/AzureIoTHub.Portal.Infrastructure/Jobs/DeviceMetricExporterJob.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Jobs
+namespace AzureIoTHub.Portal.Infrastructure.Jobs
 {
     using System.Threading.Tasks;
     using AzureIoTHub.Portal.Domain.Shared.Constants;

src/AzureIoTHub.Portal.Server/Jobs/DeviceMetricLoaderJob.cs → src/AzureIoTHub.Portal.Infrastructure/Jobs/DeviceMetricLoaderJob.cs

@@ -1,11 +1,11 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Jobs
+namespace AzureIoTHub.Portal.Infrastructure.Jobs
 {
     using System.Threading.Tasks;
     using AzureIoTHub.Portal.Domain.Exceptions;
-    using AzureIoTHub.Portal.Server.Services;
+    using AzureIoTHub.Portal.Application.Services;
     using Microsoft.Extensions.Logging;
     using Quartz;
     using Shared.Models.v1._0;

src/AzureIoTHub.Portal.Server/Jobs/EdgeDeviceMetricExporterJob.cs → src/AzureIoTHub.Portal.Infrastructure/Jobs/EdgeDeviceMetricExporterJob.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Jobs
+namespace AzureIoTHub.Portal.Infrastructure.Jobs
 {
     using System.Threading.Tasks;
     using AzureIoTHub.Portal.Domain.Shared.Constants;

src/AzureIoTHub.Portal.Server/Jobs/EdgeDeviceMetricLoaderJob.cs → src/AzureIoTHub.Portal.Infrastructure/Jobs/EdgeDeviceMetricLoaderJob.cs

@@ -1,11 +1,11 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Jobs
+namespace AzureIoTHub.Portal.Infrastructure.Jobs
 {
     using System.Threading.Tasks;
     using AzureIoTHub.Portal.Domain.Exceptions;
-    using AzureIoTHub.Portal.Server.Services;
+    using AzureIoTHub.Portal.Application.Services;
     using Microsoft.Extensions.Logging;
     using Quartz;
     using Shared.Models.v1._0;

src/AzureIoTHub.Portal.Server/Jobs/SyncConcentratorsJob.cs → src/AzureIoTHub.Portal.Infrastructure/Jobs/SyncConcentratorsJob.cs

@@ -1,20 +1,20 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Jobs
+namespace AzureIoTHub.Portal.Infrastructure.Jobs
 {
     using System;
     using System.Collections.Generic;
+    using System.Linq;
     using System.Threading.Tasks;
     using AutoMapper;
-    using Domain;
+    using AzureIoTHub.Portal.Application.Services;
     using AzureIoTHub.Portal.Domain.Entities;
+    using Domain;
     using Domain.Repositories;
-    using Services;
     using Microsoft.Azure.Devices.Shared;
     using Microsoft.Extensions.Logging;
     using Quartz;
-    using System.Linq;
 
     [DisallowConcurrentExecution]
     public class SyncConcentratorsJob : IJob

src/AzureIoTHub.Portal.Server/Jobs/SyncDevicesJob.cs → src/AzureIoTHub.Portal.Infrastructure/Jobs/SyncDevicesJob.cs

@@ -1,20 +1,20 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Jobs
+namespace AzureIoTHub.Portal.Infrastructure.Jobs
 {
     using System;
     using System.Collections.Generic;
+    using System.Linq;
     using System.Threading.Tasks;
     using AutoMapper;
-    using Domain;
+    using AzureIoTHub.Portal.Application.Services;
     using AzureIoTHub.Portal.Domain.Entities;
+    using Domain;
     using Domain.Repositories;
-    using Services;
     using Microsoft.Azure.Devices.Shared;
     using Microsoft.Extensions.Logging;
     using Quartz;
-    using System.Linq;
 
     [DisallowConcurrentExecution]
     public class SyncDevicesJob : IJob

src/AzureIoTHub.Portal.Server/Jobs/SyncEdgeDeviceJob.cs → src/AzureIoTHub.Portal.Infrastructure/Jobs/SyncEdgeDeviceJob.cs

@@ -1,17 +1,17 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Jobs
+namespace AzureIoTHub.Portal.Infrastructure.Jobs
 {
     using System;
     using System.Collections.Generic;
     using System.Linq;
     using System.Threading.Tasks;
     using AutoMapper;
+    using AzureIoTHub.Portal.Application.Services;
     using AzureIoTHub.Portal.Domain;
     using AzureIoTHub.Portal.Domain.Entities;
     using AzureIoTHub.Portal.Domain.Repositories;
-    using AzureIoTHub.Portal.Server.Services;
     using Microsoft.Azure.Devices.Shared;
     using Microsoft.Extensions.Logging;
     using Quartz;

src/AzureIoTHub.Portal.Server/Jobs/SyncGatewayIDJob.cs → src/AzureIoTHub.Portal.Infrastructure/Jobs/SyncGatewayIDJob.cs

@@ -1,11 +1,11 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Jobs
+namespace AzureIoTHub.Portal.Infrastructure.Jobs
 {
     using System;
     using System.Threading.Tasks;
-    using AzureIoTHub.Portal.Server.Services;
+    using AzureIoTHub.Portal.Application.Services;
     using AzureIoTHub.Portal.Shared.Models.v1._0;
     using Microsoft.Extensions.Logging;
     using Quartz;

src/AzureIoTHub.Portal.Server/Jobs/SyncLoRaDeviceTelemetryJob.cs → src/AzureIoTHub.Portal.Infrastructure/Jobs/SyncLoRaDeviceTelemetryJob.cs

@@ -1,18 +1,18 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Server.Jobs
+namespace AzureIoTHub.Portal.Infrastructure.Jobs
 {
+    using System.Threading;
     using System.Threading.Tasks;
-    using Domain;
-    using Microsoft.Extensions.Logging;
-    using Quartz;
     using Azure.Messaging.EventHubs;
-    using Azure.Storage.Blobs;
-    using System.Threading;
     using Azure.Messaging.EventHubs.Processor;
+    using Azure.Storage.Blobs;
+    using AzureIoTHub.Portal.Application.Services;
     using AzureIoTHub.Portal.Models.v10.LoRaWAN;
-    using AzureIoTHub.Portal.Server.Services;
+    using Domain;
+    using Microsoft.Extensions.Logging;
+    using Quartz;
 
     public class SyncLoRaDeviceTelemetryJob : IJob
     {