import org.asamk.signal.commands.exceptions.UserErrorException;
import org.asamk.signal.manager.Manager;
import org.asamk.signal.manager.api.SendMessageResults;
-import org.asamk.signal.output.JsonWriter;
import org.asamk.signal.output.OutputWriter;
-import org.asamk.signal.output.PlainTextWriter;
import org.asamk.signal.util.CommandUtil;
-import org.asamk.signal.util.ErrorUtils;
import java.io.IOException;
-import java.util.Map;
+
+import static org.asamk.signal.util.SendMessageResultUtils.outputResult;
public class SendReceiptCommand implements JsonRpcLocalCommand {
subparser.addArgument("-t", "--target-timestamp")
.type(long.class)
.nargs("+")
+ .required(true)
.help("Specify the timestamp of the messages for which a receipt should be sent.");
subparser.addArgument("--type")
.help("Specify the receipt type (default is read receipt).")
} else {
throw new UserErrorException("Unknown receipt type: " + type);
}
- outputResult(outputWriter, results.timestamp());
- ErrorUtils.handleSendMessageResults(results.results());
+ outputResult(outputWriter, results);
} catch (IOException e) {
throw new UserErrorException("Failed to send message: " + e.getMessage() + " (" + e.getClass()
.getSimpleName() + ")");
}
}
-
- private void outputResult(final OutputWriter outputWriter, final long timestamp) {
- if (outputWriter instanceof PlainTextWriter writer) {
- writer.println("{}", timestamp);
- } else {
- final var writer = (JsonWriter) outputWriter;
- writer.write(Map.of("timestamp", timestamp));
- }
- }
}