private static PluginConfig getPluginConfigFromJobTask()

in seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/service/impl/JobTaskServiceImpl.java [572:613]
42 lines of code
7 McCabe index (conditional complexity)

    private static PluginConfig getPluginConfigFromJobTask(JobTask jobTask) {
        try {
            return PluginConfig.builder()
                    .pluginId(jobTask.getPluginId())
                    .name(jobTask.getName())
                    .type(PluginType.valueOf(jobTask.getType().toUpperCase()))
                    .dataSourceId(jobTask.getDataSourceId())
                    .config(jobTask.getConfig())
                    .connectorType(jobTask.getConnectorType())
                    .sceneMode(
                            StringUtils.isEmpty(jobTask.getSceneMode())
                                    ? null
                                    : SceneMode.valueOf(jobTask.getSceneMode()))
                    .tableOption(
                            StringUtils.isEmpty(jobTask.getDataSourceOption())
                                    ? null
                                    : OBJECT_MAPPER.readValue(
                                            jobTask.getDataSourceOption(), DataSourceOption.class))
                    .selectTableFields(
                            StringUtils.isEmpty(jobTask.getSelectTableFields())
                                    ? null
                                    : OBJECT_MAPPER.readValue(
                                            jobTask.getSelectTableFields(),
                                            SelectTableFields.class))
                    .outputSchema(
                            StringUtils.isEmpty(jobTask.getOutputSchema())
                                    ? null
                                    : OBJECT_MAPPER.readValue(
                                            jobTask.getOutputSchema(),
                                            new TypeReference<List<DatabaseTableSchemaReq>>() {}))
                    .transformOptions(
                            StringUtils.isEmpty(jobTask.getTransformOptions())
                                    ? null
                                    : OBJECT_MAPPER.readValue(
                                            jobTask.getTransformOptions(),
                                            new TypeReference<Map<String, Object>>() {}))
                    .config(jobTask.getConfig())
                    .build();
        } catch (Exception e) {
            throw new SeatunnelException(SeatunnelErrorEnum.UNKNOWN, e.getMessage());
        }
    }