This is an automated email from the ASF dual-hosted git repository.
yasith pushed a change to branch feat/grpc-armeria-migration
in repository https://gitbox.apache.org/repos/asf/airavata.git
from 57e9d7d3b0 refactor: replace remaining POJOs with proto types, remove
REST controllers covered by gRPC
add 4a296a9094 style: apply spotless formatting
No new revisions were added by this update.
Summary of changes:
.../service/handlers/AgentConnectionHandler.java | 32 +-
.../handlers/AgentInteractionGrpcHandler.java | 160 ++++---
.../service/handlers/AgentManagementHandler.java | 51 ++-
.../handlers/ExperimentManagementGrpcHandler.java | 43 +-
.../connection/service/handlers/FuseFSHandler.java | 2 +-
.../service/handlers/PlanGrpcHandler.java | 12 +-
.../service/services/AiravataService.java | 19 +-
.../service/GatewayResourceProfileServiceTest.java | 6 +-
.../service/GroupResourceProfileServiceTest.java | 20 +-
.../compute/service/ResourceServiceTest.java | 110 +++--
.../service/UserResourceProfileServiceTest.java | 6 +-
.../handler/CredentialStoreServerHandler.java | 131 +++---
.../repository/CertificateCredentialWriter.java | 8 +-
.../credential/repository/CredentialReader.java | 4 +-
.../repository/CredentialReaderImpl.java | 4 +-
.../credential/repository/db/CredentialsDAO.java | 14 +-
.../apache/airavata/credential/util/Utility.java | 3 +-
.../sharing/util/AiravataDataMigrator.java | 33 +-
.../handler/CredentialStoreServerHandlerTest.java | 9 +-
.../repository/db/CommunityUserDAOTest.java | 45 +-
.../repository/db/CredentialsDAOTest.java | 40 +-
.../repository/db/SSHCredentialTest.java | 5 +-
.../credential/service/CredentialServiceTest.java | 6 +-
.../credential/service/SSHAccountServiceTest.java | 4 +-
.../store/cpi/SSHSummaryTest/SSHSummaryTest.java | 5 +-
.../service/ApplicationCatalogService.java | 1 -
.../research/service/ExperimentService.java | 47 +-
.../research/service/NotificationService.java | 4 +-
.../airavata/research/service/ProjectService.java | 8 +-
.../research/service/handlers/ProjectHandler.java | 3 +-
.../service/handlers/ResearchHubGrpcHandler.java | 16 +-
.../handlers/ResearchProjectGrpcHandler.java | 33 +-
.../handlers/ResearchResourceGrpcHandler.java | 125 ++++--
.../handlers/ResearchSessionGrpcHandler.java | 18 +-
.../research/service/handlers/ResourceHandler.java | 34 +-
.../service/ApplicationCatalogServiceTest.java | 35 +-
.../research/service/ExperimentServiceTest.java | 73 +--
.../research/service/NotificationServiceTest.java | 12 +-
.../research/service/ProjectServiceTest.java | 6 +-
.../ApplicationDeploymentRepository.java | 6 +-
.../repository/ApplicationInterfaceRepository.java | 5 +-
.../repository/ComputeResourceRepository.java | 5 +-
.../repository/GroupResourceProfileRepository.java | 26 +-
.../repository/GrpComputePrefRepository.java | 15 +-
.../repository/GwyResourceProfileRepository.java | 9 +-
.../repository/ResourceJobManagerRepository.java | 9 +-
.../compute/spi/ComputeResourceProvider.java | 36 +-
.../compute/task/ForkJobSubmissionTask.java | 1 -
.../compute/task/HTCondorJobConfiguration.java | 10 +-
.../compute/task/HTCondorOutputParser.java | 16 +-
.../apache/airavata/compute/task/JobFactory.java | 2 +-
.../airavata/compute/task/JobSubmissionTask.java | 4 +-
.../airavata/compute/task/LSFJobConfiguration.java | 1 -
.../airavata/compute/task/LSFOutputParser.java | 16 +-
.../airavata/compute/task/PBSOutputParser.java | 16 +-
.../compute/task/SlurmJobConfiguration.java | 17 +-
.../airavata/compute/task/SlurmOutputParser.java | 16 +-
.../airavata/compute/task/UGEJobConfiguration.java | 1 -
.../airavata/compute/task/UGEOutputParser.java | 6 +-
.../compute/task/aws/AWSJobSubmissionTask.java | 7 +-
.../compute/task/aws/AWSProcessContextManager.java | 5 +-
.../airavata/compute/util/AppDeploymentUtil.java | 5 +-
.../credential/spi/CredentialProvider.java | 36 +-
.../execution/handler/RegistryServerHandler.java | 497 ++++++++++-----------
.../handler/RegistryServiceDBEventHandler.java | 8 +-
.../monitor/AiravataCustomMailParser.java | 2 +-
.../execution/monitor/ClusterStatusMonitorJob.java | 22 +-
.../execution/monitor/ComputeResourceMonitor.java | 2 +-
.../execution/monitor/EmailBasedMonitor.java | 2 +-
.../execution/monitor/HTCondorEmailParser.java | 2 +-
.../execution/monitor/JobStateValidator.java | 2 +-
.../airavata/execution/monitor/LSFEmailParser.java | 2 +-
.../airavata/execution/monitor/MonitoringJob.java | 2 +-
.../airavata/execution/monitor/PBSEmailParser.java | 2 +-
.../execution/monitor/RealtimeJobStatusParser.java | 2 +-
.../execution/monitor/RealtimeMonitor.java | 2 +-
.../execution/monitor/SLURMEmailParser.java | 2 +-
.../airavata/execution/monitor/UGEEmailParser.java | 2 +-
.../orchestrator/AbstractOrchestrator.java | 1 -
.../execution/orchestrator/AiravataTask.java | 48 +-
.../orchestrator/BatchQueueValidator.java | 55 ++-
.../orchestrator/ExperimentStatusValidator.java | 3 +-
.../GroupResourceProfileValidator.java | 18 +-
.../execution/orchestrator/Orchestrator.java | 3 +-
.../orchestrator/OrchestratorServerUtils.java | 3 +-
.../execution/orchestrator/OrchestratorUtils.java | 4 +-
.../orchestrator/ParserWorkflowManager.java | 7 +-
.../orchestrator/PostWorkflowManager.java | 23 +-
.../execution/orchestrator/PreWorkflowManager.java | 6 +-
.../orchestrator/SimpleOrchestratorImpl.java | 68 +--
.../execution/orchestrator/SlurmTaskFactory.java | 5 +-
.../execution/orchestrator/TaskContext.java | 3 +-
.../execution/orchestrator/WorkflowManager.java | 11 +-
.../repository/ExperimentErrorRepository.java | 4 +-
.../execution/repository/ExperimentRepository.java | 17 +-
.../repository/ExperimentStatusRepository.java | 15 +-
.../repository/ExperimentSummaryRepository.java | 12 +-
.../execution/repository/JobRepository.java | 9 +-
.../execution/repository/JobStatusRepository.java | 4 +-
.../repository/NotificationRepository.java | 3 +-
.../repository/ProcessErrorRepository.java | 4 +-
.../execution/repository/ProcessRepository.java | 20 +-
.../repository/ProcessStatusRepository.java | 12 +-
.../execution/repository/ProjectRepository.java | 5 +-
.../execution/repository/TaskErrorRepository.java | 4 +-
.../execution/repository/TaskRepository.java | 17 +-
.../execution/repository/TaskStatusRepository.java | 4 +-
.../execution/repository/WorkflowRepository.java | 11 +-
.../ComputeResourceSelectionPolicyImpl.java | 2 +-
.../execution/scheduler/DataAnalyzerImpl.java | 2 +-
.../DefaultComputeResourceSelectionPolicy.java | 2 +-
.../scheduler/ExponentialBackOffReScheduler.java | 33 +-
.../scheduler/MultipleComputeResourcePolicy.java | 2 +-
.../execution/scheduler/ProcessScannerImpl.java | 2 +-
.../execution/scheduler/ProcessSchedulerImpl.java | 33 +-
.../apache/airavata/execution/scheduler/Utils.java | 27 +-
.../airavata/execution/task/DataParsingTask.java | 3 +-
.../airavata/execution/util/QueryConstants.java | 4 +-
.../airavata/messaging/config/MessagingConfig.java | 3 +-
.../messaging/handler/ExperimentConsumer.java | 2 +-
.../messaging/handler/MessageConsumer.java | 2 +-
.../messaging/handler/ProcessConsumer.java | 2 +-
.../airavata/messaging/handler/StatusConsumer.java | 17 +-
.../airavata/messaging/service/EventPublisher.java | 18 +-
.../messaging/service/RabbitMQPublisher.java | 4 +-
.../profile/commons/utils/QueryConstants.java | 8 +-
.../core/impl/TenantManagementKeycloakImpl.java | 15 +-
.../security/service/GatewayGroupsInitializer.java | 3 +-
.../security/service/KeyCloakSecurityManager.java | 1 -
.../service/interceptor/SecurityInterceptor.java | 2 +-
.../security/util/AuthorizationException.java | 19 +
.../cpi/exception/IamAdminServicesException.java | 19 +
.../handler/SharingRegistryServerHandler.java | 137 +++---
.../handler/SharingServiceDBEventHandler.java | 29 +-
.../sharing/model/DuplicateEntryException.java | 19 +
.../sharing/model/SharingRegistryException.java | 19 +
.../repository/GroupMembershipRepository.java | 6 +-
.../repository/PermissionTypeRepository.java | 3 +-
.../sharing/service/ResourceSharingService.java | 3 +-
.../sharing/util/ThriftDataModelConversion.java | 1 -
.../storage/repository/DataProductRepository.java | 3 +-
.../repository/DataReplicaLocationRepository.java | 3 +-
.../repository/StorageResourceRepository.java | 4 +-
.../airavata/storage/spi/StorageProvider.java | 36 +-
.../airavata/storage/util/SSHJStorageAdaptor.java | 4 +-
.../ApplicationDeploymentRepositoryTest.java | 11 +-
.../ApplicationInterfaceRepositoryTest.java | 5 +-
.../repository/ComputeResourceRepositoryTest.java | 17 +-
.../repository/GatewayGroupsRepositoryTest.java | 32 +-
.../repository/GatewayProfileRepositoryTest.java | 43 +-
.../GroupResourceProfileRepositoryTest.java | 84 ++--
.../JobSubmissionInterfaceRepositoryTest.java | 22 +-
.../repository/StorageResourceRepositoryTest.java | 41 +-
.../UserResourceProfileRepositoryTest.java | 60 ++-
.../repository/ExperimentErrorRepositoryTest.java | 14 +-
.../repository/ExperimentInputRepositoryTest.java | 20 +-
.../repository/ExperimentOutputRepositoryTest.java | 20 +-
.../repository/ExperimentRepositoryTest.java | 162 +++++--
.../repository/ExperimentStatusRepositoryTest.java | 30 +-
.../ExperimentSummaryRepositoryTest.java | 111 +++--
.../repository/GatewayRepositoryTest.java | 8 +-
.../execution/repository/JobRepositoryTest.java | 31 +-
.../repository/JobStatusRepositoryTest.java | 28 +-
.../repository/NotificationRepositoryTest.java | 11 +-
.../repository/ProcessErrorRepositoryTest.java | 17 +-
.../repository/ProcessInputRepositoryTest.java | 26 +-
.../repository/ProcessOutputRepositoryTest.java | 26 +-
.../repository/ProcessRepositoryTest.java | 76 +++-
.../repository/ProcessStatusRepositoryTest.java | 32 +-
.../repository/ProjectRepositoryTest.java | 6 +-
.../repository/QueueStatusRepositoryTest.java | 6 +-
.../repository/TaskErrorRepositoryTest.java | 21 +-
.../execution/repository/TaskRepositoryTest.java | 47 +-
.../repository/TaskStatusRepositoryTest.java | 27 +-
.../execution/repository/UserRepositoryTest.java | 16 +-
.../replicacatalog/DataProductRepositoryTest.java | 78 +++-
.../DataReplicaLocationRepositoryTest.java | 37 +-
.../ExperimentRepositoryIntegrationTest.java | 35 +-
.../integration/SharingServiceIntegrationTest.java | 3 +-
.../admin/services/core/tests/SetupNewGateway.java | 68 ++-
.../service/GatewayGroupsInitializerTest.java | 3 +-
.../service/KeyCloakSecurityManagerTest.java | 1 -
.../handler/SharingRegistryServerHandlerTest.java | 1 -
.../service/ResourceSharingServiceTest.java | 18 +-
.../sharing/service/SharingHelperTest.java | 11 +-
.../storage/service/AirvataFileService.java | 2 +-
.../storage/service/ProcessDataManager.java | 3 +-
.../storage/service/AirvataFileServiceTest.java | 18 +-
.../storage/service/DataProductServiceTest.java | 16 +-
.../server/config/ServiceWiringConfig.java | 6 +-
.../server/grpc/AiravataArmeriaConfig.java | 23 +-
.../airavata/server/grpc/GrpcStatusMapper.java | 17 +-
.../server/grpc/config/GrpcAuthInterceptor.java | 2 +-
.../services/ApplicationCatalogGrpcService.java | 183 ++++----
.../grpc/services/CredentialGrpcService.java | 53 +--
.../grpc/services/DataProductGrpcService.java | 28 +-
.../grpc/services/ExperimentGrpcService.java | 148 +++---
.../server/grpc/services/GatewayGrpcService.java | 35 +-
.../GatewayResourceProfileGrpcService.java | 96 ++--
.../grpc/services/GroupManagerGrpcService.java | 18 +-
.../services/GroupResourceProfileGrpcService.java | 109 +++--
.../server/grpc/services/GrpcRequestContext.java | 6 +-
.../server/grpc/services/IamAdminGrpcService.java | 47 +-
.../grpc/services/NotificationGrpcService.java | 30 +-
.../server/grpc/services/ParserGrpcService.java | 50 +--
.../server/grpc/services/ProjectGrpcService.java | 39 +-
.../server/grpc/services/ResourceGrpcService.java | 183 ++++----
.../server/grpc/services/SharingGrpcService.java | 347 +++++++-------
.../grpc/services/UserProfileGrpcService.java | 27 +-
.../services/UserResourceProfileGrpcService.java | 148 +++---
210 files changed, 3432 insertions(+), 2406 deletions(-)
