1
2
3
4
5
6 package dev.metaschema.cli.commands;
7
8 import org.apache.commons.cli.CommandLine;
9 import org.apache.commons.cli.Option;
10 import org.apache.logging.log4j.LogManager;
11 import org.apache.logging.log4j.Logger;
12
13 import java.io.File;
14 import java.io.FileNotFoundException;
15 import java.io.IOException;
16 import java.io.OutputStreamWriter;
17 import java.io.Writer;
18 import java.net.URI;
19 import java.nio.charset.StandardCharsets;
20 import java.nio.file.Files;
21 import java.nio.file.Path;
22 import java.nio.file.StandardOpenOption;
23 import java.util.Collection;
24 import java.util.List;
25
26 import dev.metaschema.cli.processor.CallingContext;
27 import dev.metaschema.cli.processor.ExitCode;
28 import dev.metaschema.cli.processor.command.AbstractCommandExecutor;
29 import dev.metaschema.cli.processor.command.AbstractTerminalCommand;
30 import dev.metaschema.cli.processor.command.CommandExecutionException;
31 import dev.metaschema.cli.processor.command.ExtraArgument;
32 import dev.metaschema.core.model.MetaschemaException;
33 import dev.metaschema.core.util.AutoCloser;
34 import dev.metaschema.core.util.ObjectUtils;
35 import dev.metaschema.databind.IBindingContext;
36 import dev.metaschema.databind.io.Format;
37 import dev.metaschema.databind.io.IBoundLoader;
38 import edu.umd.cs.findbugs.annotations.NonNull;
39
40
41
42
43 public abstract class AbstractConvertSubcommand
44 extends AbstractTerminalCommand {
45 private static final Logger LOGGER = LogManager.getLogger(AbstractConvertSubcommand.class);
46
47 @NonNull
48 private static final String COMMAND = "convert";
49 @NonNull
50 private static final List<ExtraArgument> EXTRA_ARGUMENTS = ObjectUtils.notNull(List.of(
51 ExtraArgument.newInstance("source-file-or-URL", true, URI.class),
52 ExtraArgument.newInstance("destination-file", false, File.class)));
53
54 @Override
55 public String getName() {
56 return COMMAND;
57 }
58
59 @Override
60 public Collection<? extends Option> gatherOptions() {
61 return ObjectUtils.notNull(List.of(
62 MetaschemaCommands.OVERWRITE_OPTION,
63 MetaschemaCommands.TO_OPTION));
64 }
65
66 @Override
67 public List<ExtraArgument> getExtraArguments() {
68 return EXTRA_ARGUMENTS;
69 }
70
71
72
73
74
75 protected abstract static class AbstractConversionCommandExecutor
76 extends AbstractCommandExecutor {
77
78
79
80
81
82
83
84
85
86 protected AbstractConversionCommandExecutor(
87 @NonNull CallingContext callingContext,
88 @NonNull CommandLine commandLine) {
89 super(callingContext, commandLine);
90 }
91
92
93
94
95
96
97
98
99
100
101
102 @NonNull
103 protected abstract IBindingContext getBindingContext() throws CommandExecutionException, MetaschemaException;
104
105 @Override
106 public void execute() throws CommandExecutionException {
107 CommandLine cmdLine = getCommandLine();
108
109 List<String> extraArgs = cmdLine.getArgList();
110
111 Path destination = null;
112 if (extraArgs.size() > 1) {
113 destination = MetaschemaCommands.handleDestination(ObjectUtils.requireNonNull(extraArgs.get(1)), cmdLine);
114 }
115
116 @SuppressWarnings("synthetic-access")
117 URI source = MetaschemaCommands.handleSource(
118 ObjectUtils.requireNonNull(extraArgs.get(0)),
119 ObjectUtils.notNull(getCurrentWorkingDirectory().toUri()));
120
121 Format toFormat = MetaschemaCommands.getFormat(cmdLine, MetaschemaCommands.TO_OPTION);
122
123 try {
124 IBindingContext bindingContext = getBindingContext();
125
126 IBoundLoader loader = bindingContext.newPermissiveBoundLoader();
127 if (LOGGER.isInfoEnabled()) {
128 LOGGER.info("Converting '{}'.", source);
129 }
130
131 if (destination == null) {
132
133 try (OutputStreamWriter writer
134 = new OutputStreamWriter(AutoCloser.preventClose(System.out), StandardCharsets.UTF_8)) {
135 handleConversion(source, toFormat, writer, loader);
136 }
137 } else {
138 try (Writer writer = Files.newBufferedWriter(
139 destination,
140 StandardCharsets.UTF_8,
141 StandardOpenOption.CREATE,
142 StandardOpenOption.WRITE,
143 StandardOpenOption.TRUNCATE_EXISTING)) {
144 assert writer != null;
145 handleConversion(source, toFormat, writer, loader);
146 }
147 }
148 } catch (IllegalArgumentException | MetaschemaException ex) {
149 throw new CommandExecutionException(ExitCode.PROCESSING_ERROR, ex);
150 } catch (IOException ex) {
151 throw new CommandExecutionException(ExitCode.IO_ERROR, ex);
152 }
153 if (destination != null && LOGGER.isInfoEnabled()) {
154 LOGGER.info("Generated {} file: {}", toFormat.toString(), destination);
155 }
156 }
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174 protected abstract void handleConversion(
175 @NonNull URI source,
176 @NonNull Format toFormat,
177 @NonNull Writer writer,
178 @NonNull IBoundLoader loader) throws FileNotFoundException, IOException;
179 }
180 }