42 posts tagged with "troubleshooting"

@Component
class StartClusterDelegate(
	private val clusterOperator: ClusterOperator
) : JavaDelegate, LogCapability {

	override fun execute(execution: DelegateExecution) {
		clusterOperator.start(execution.getVariableAs(VARNAME_CLUSTER_ID))
	}
}

@Component
class ClusterOperator(
	private val clusterService: ClusterService,
	private val csClusterOperator: CsClusterOperator,
	private val csStorageOperator: CsStorageOperator,
	private val clusterBastionUserOperator: ClusterBastionUserOperator,
	private val netEnvOperator: NetEnvOperator
) : LongTimeOperationCapability {

	override fun start(id: Long) {
		clusterService.get(id).orNull()!!.let { cluster ->
			clusterService.patch(id) {
				state = ClusterState.STARTING
			}
			logger.info("Begin start cluster $id")
			csStorageOperator.start(cluster.csStorageId)
			csClusterOperator.start(cluster.csClusterId!!)
			clusterBastionUserOperator.start(cluster.id)
			logger.info("Successful to start cluster $id")
			clusterService.patch(id) {
				state = ClusterState.RUNNING
			}
		}

	}

}

@Service
class ClusterService(
	private val engine: ProcessEngine,
	private val clusterRepo: ClusterRepository,
	private val client: DeployService
) : LogCapability {

	@Transactional(propagation = Propagation.REQUIRES_NEW)
	fun patch(id: Long, patchFun: PatchClusterDto.() -> Unit): Either<ClusterOperationError, ClusterDetail> =
		clusterRepo.findById(id).map { originCluster ->
			val patch = PatchClusterDto(patchFun).apply {
				logger.info("patch request {}", this)
			}
			val patchedCluster = originCluster.copy(
				cloudAccount = patch.cloudAccount ?: originCluster.cloudAccount,
				csNetEnvId = patch.csNetEnvId ?: originCluster.csNetEnvId,
				csStorageId = patch.csStoreId ?: originCluster.csStorageId,
				csClusterId = patch.csClusterId ?: originCluster.csClusterId,
				isDelivered = when (patch.deliveryCluster) {
					DeliveryCluster.YES -> true
					DeliveryCluster.NO -> false
					DeliveryCluster.NONE -> originCluster.isDelivered
				},
				state = patch.state ?: originCluster.state
			)
			patchedCluster.apply {
				logger.info("patched cluster {}", this)
			}
		}.map {
			clusterRepo.save(it)
			get(it.id)
		}.orElseGet {
			Either.left(ClusterOperationError.NoSuchCluster(id))
		}
}

@Entity
class ProjectInfo(
	var name: String,
	var code: String,
	var ownerName: String,
	var applicantName: String,
	var companyCode: String,
	var companyName: String,
	var projectType: ProjectType,
	var submitDate: LocalDateTime = LocalDateTime.now(),
	var planStartDate: LocalDate?,
	var planEndDate: LocalDate?,
	var endDate: String,
	var targetCustomers: Array<String>?,
	var formStatus: ApplicationStatus = ApplicationStatus.DRAFT,
	var projectStatus: ApplicationProjectStatus = ApplicationProjectStatus.DRAFT,
	var comments: String?
) {

	@Id
	@GeneratedValue(strategy = GenerationType.IDENTITY)
	val id: Long = -1
}