MahdiKarimipour

services.AddDbContextPool<IdentityDBContext>(options =>
{
    options.UseSqlServer(secrets.DbConnectionString,
        x => x.MigrationsAssembly("DataAccess")
            .EnableRetryOnFailure(maxRetryCount: 3))
            .UseLazyLoadingProxies()
            .EnableSensitiveDataLogging(CurrentEnvironment.IsDevelopment())
            .EnableServiceProviderCaching()
            .UseLoggerFactory(IdentityDBContext.PropertyAppLoggerFactory);
});

MahdiKarimipour

public abstract class MyBackgroundService : IHostedService, IDisposable
{
    private Task executingTask;
    private readonly CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
    protected abstract Task ExecuteAsync(CancellationToken stoppingToken);

    public virtual Task StartAsync(CancellationToken cancellationToken)
    {
        executingTask = ExecuteAsync(cancellationTokenSource.Token);

MahdiKarimipour

public class KafkaHostedService : MyBackgroundService
{
    private readonly ILogger<KafkaHostedService> logger;
    private readonly AppSettings appSettings;
    private readonly IConfiguration configuration;
    private readonly IServiceScopeFactory scopeFactory;

    public KafkaHostedService(
        ILogger<KafkaHostedService> logger,
        AppSettings appSettings,

MahdiKarimipour

services.AddTransient<IKafkaService>(x =>
    new KafkaService(
        appSettings.KafkaSettings.Server,
        appSecrets.KafkaSaslKey,
        appSecrets.KafkaSaslSecret));

MahdiKarimipour

public class KafkaService : IKafkaService
{
    private readonly string saslUsername;
    private readonly string saslPassword;
    public readonly string serverAddress;

    public KafkaService(string serverAddress, string saslUsername, string saslPassword)
    {
        this.serverAddress = serverAddress;
        this.saslUsername = saslUsername;

MahdiKarimipour

{
    "user": {
        "accessToken": "eyJhbGciOiJodH.....PXKnzQbFZ9xkNx0",
        "refreshToken": "CfDJ8HmkbyESYkdH......ajwoA=="
    }
}

MahdiKarimipour

{
    "AccessToken": "eyJhbGciOiJs.....Brev24Z1n80",
    "RefreshToken": "CfDJ8H...TTwyjZEPpw=="
}

MahdiKarimipour

{
    "user": {
        "userId": "a3686...8b37",
        "tenantId": "37fd7...940",
        "tenantDomain": "https://app.contoso-finance.com",
        "accessToken": "eyJhbIzNyIsIlRlbmF....pMqI4KUZ1w",
        "refreshToken": "kcGqqnGLOfJpG....h1M06Vo=",
        "email": "[email protected]",
        "isSociallyAuthenticated": false,
        "embeddedModeAuthentication": false

MahdiKarimipour

az account set --subscription subscription-id

az aks get-credentials --resource-group TechnologyLeads-Common --name technologyleads-aks

kubectl apply -f SecretProviderClass.yaml

helm uninstall ecosystem-identity-api-release 

helm upgrade --install ecosystem-identity-api-release ./Helm --values ./Helm/values.production.yaml --set image.tag="v1.0.0" --set global.env.ASPNETCORE_ENVIRONMENT="Production"

MahdiKarimipour

- task: CopyFiles@2
  inputs:
    SourceFolder: 'Infrastructure'
    Contents: '**'
    TargetFolder: '$(Build.ArtifactStagingDirectory)'
    
- task: PublishBuildArtifacts@1
  inputs:
    pathtoPublish: '$(Build.ArtifactStagingDirectory)' 
    artifactName: '$(projectName)'