■ ■ ■ ■ ■ ■
src/main/java/io/onedev/k8shelper/KubernetesHelper.java
| skipped 865 lines |
866 | 866 | | |
867 | 867 | | try (Response response = builder.post(Entity.entity(os, MediaType.APPLICATION_OCTET_STREAM))) { |
868 | 868 | | checkStatus(response); |
869 | | - | ServerExecutionResult result = SerializationUtils.deserialize(response.readEntity(byte[].class)); |
870 | | - | for (String logMessage: result.getLogMessages()) |
871 | | - | logger.info(logMessage); |
872 | | - | if (result.getOutputFiles() != null) { |
873 | | - | for (Map.Entry<String, byte[]> entry: result.getOutputFiles().entrySet()) { |
| 869 | + | try (InputStream is = response.readEntity(InputStream.class)) { |
| 870 | + | while (readInt(is) == 1) { |
| 871 | + | logger.info(readString(is)); |
| 872 | + | } |
| 873 | + | byte[] bytes = new byte[readInt(is)]; |
| 874 | + | IOUtils.readFully(is, bytes); |
| 875 | + | Map<String, byte[]> files = SerializationUtils.deserialize(bytes); |
| 876 | + | for (Map.Entry<String, byte[]> entry: files.entrySet()) { |
874 | 877 | | try { |
875 | 878 | | FileUtils.writeByteArrayToFile( |
876 | 879 | | new File(getBuildHome(), entry.getKey()), |
| skipped 2 lines |
879 | 882 | | throw new RuntimeException(e); |
880 | 883 | | } |
881 | 884 | | } |
| 885 | + | } catch (IOException e) { |
| 886 | + | throw new RuntimeException(e); |
882 | 887 | | } |
883 | 888 | | } |
884 | 889 | | } finally { |
| skipped 69 lines |