package com.airlock.iam.ssi.infrastructure.factory;

import com.airlock.iam.base.api.infrastructure.plugin.ModuleForConfig;
import com.airlock.iam.base.api.infrastructure.plugin.PluginConfigToLogic;
import com.airlock.iam.database.infrastructure.JooqConfig;
import com.airlock.iam.database.infrastructure.TenantId;
import com.airlock.iam.flow.api.domain.model.session.FlowSession;
import com.airlock.iam.flow.infrastructure.step.StepSessionModuleHelper;
import com.airlock.iam.flow.shared.infrastructure.factory.message.ValueMapProviderListFactory;
import com.airlock.iam.ssi.application.configuration.VerifiableCredentialsRepositoryConfig;
import com.airlock.iam.ssi.application.configuration.step.SsiPersistedIssuanceStepConfig;
import com.airlock.iam.ssi.domain.model.step.CredentialSchema;
import com.airlock.iam.ssi.domain.model.step.SsiIssuanceStepSession;
import com.airlock.iam.ssi.domain.model.step.SsiIssuanceStepSettings;
import com.airlock.iam.ssi.domain.model.vc.VerifiableCredentialRepository;
import com.airlock.iam.ssi.infrastructure.repository.JooqVerifiableCredentialRepository;
import com.google.inject.Exposed;
import com.google.inject.PrivateModule;
import com.google.inject.Provides;
import jakarta.inject.Provider;
import java.util.List;
import java.util.Optional;

@ModuleForConfig(SsiPersistedIssuanceStepConfig.class)
public final class SsiPersistedIssuanceStepModule extends PrivateModule {
   @Exposed
   @Provides
   SsiIssuanceStepSession provideSsiIssuanceStepSession(FlowSession flowSession) {
      return StepSessionModuleHelper.retrieveStepSession(flowSession, SsiIssuanceStepSession.class);
   }

   @Exposed
   @Provides
   SsiIssuanceStepSettings provideSsiIssuanceStepSettings(SsiPersistedIssuanceStepConfig config, PluginConfigToLogic configToLogic) {
      return new SsiIssuanceStepSettings(
         new CredentialSchema(config.getCredentialSchemaName()),
         ValueMapProviderListFactory.valueMapProviderList(config.getValueProviders(), configToLogic),
         config.getAttributeMappings()
      );
   }

   @Provides
   JooqConfig provideJooqConfig(SsiPersistedIssuanceStepConfig config) {
      VerifiableCredentialsRepositoryConfig repositoryConfig = config.getVcRepositoryConfig();
      return new JooqConfig(
         repositoryConfig.getSqlDataSource(),
         repositoryConfig.getSqlDataSource().getDbType(),
         null,
         List.of(),
         repositoryConfig.isLogQueries(),
         TenantId.tenantId(repositoryConfig.getTenantId())
      );
   }

   @Provides
   @Exposed
   Optional<VerifiableCredentialRepository> provideVerifiableCredentialRepository(Provider<JooqConfig> jooqConfig) {
      return Optional.of(new JooqVerifiableCredentialRepository(jooqConfig));
   }

   protected void configure() {
      this.bind(VerifiableCredentialRepository.class).to(JooqVerifiableCredentialRepository.class);
      this.expose(VerifiableCredentialRepository.class);
   }
}