nmode's Git Repositories - signal-cli/blob - src/main/java/org/asamk/signal/commands/RemoteDeleteCommand.java

   1 package org.asamk.signal.commands;
   2
   3 import net.sourceforge.argparse4j.impl.Arguments;
   4 import net.sourceforge.argparse4j.inf.Namespace;
   5 import net.sourceforge.argparse4j.inf.Subparser;
   6
   7 import org.asamk.signal.commands.exceptions.CommandException;
   8 import org.asamk.signal.commands.exceptions.UnexpectedErrorException;
   9 import org.asamk.signal.commands.exceptions.UserErrorException;
  10 import org.asamk.signal.manager.Manager;
  11 import org.asamk.signal.manager.groups.GroupNotFoundException;
  12 import org.asamk.signal.manager.groups.GroupSendingNotAllowedException;
  13 import org.asamk.signal.manager.groups.NotAGroupMemberException;
  14 import org.asamk.signal.output.JsonWriter;
  15 import org.asamk.signal.output.OutputWriter;
  16 import org.asamk.signal.output.PlainTextWriter;
  17 import org.asamk.signal.util.CommandUtil;
  18 import org.asamk.signal.util.ErrorUtils;
  19
  20 import java.io.IOException;
  21 import java.util.Map;
  22
  23 public class RemoteDeleteCommand implements JsonRpcLocalCommand {
  24
  25     @Override
  26     public String getName() {
  27         return "remoteDelete";
  28     }
  29
  30     @Override
  31     public void attachToSubparser(final Subparser subparser) {
  32         subparser.help("Remotely delete a previously sent message.");
  33         subparser.addArgument("-t", "--target-timestamp")
  34                 .required(true)
  35                 .type(long.class)
  36                 .help("Specify the timestamp of the message to delete.");
  37         subparser.addArgument("-g", "--group-id", "--group").help("Specify the recipient group ID.").nargs("*");
  38         subparser.addArgument("recipient").help("Specify the recipients' phone number.").nargs("*");
  39         subparser.addArgument("--note-to-self").action(Arguments.storeTrue());
  40     }
  41
  42     @Override
  43     public void handleCommand(
  44             final Namespace ns, final Manager m, final OutputWriter outputWriter
  45     ) throws CommandException {
  46         final var isNoteToSelf = Boolean.TRUE.equals(ns.getBoolean("note-to-self"));
  47         final var recipientStrings = ns.<String>getList("recipient");
  48         final var groupIdStrings = ns.<String>getList("group-id");
  49
  50         final var recipientIdentifiers = CommandUtil.getRecipientIdentifiers(m,
  51                 isNoteToSelf,
  52                 recipientStrings,
  53                 groupIdStrings);
  54
  55         final long targetTimestamp = ns.getLong("target-timestamp");
  56
  57         try {
  58             final var results = m.sendRemoteDeleteMessage(targetTimestamp, recipientIdentifiers);
  59             outputResult(outputWriter, results.timestamp());
  60             ErrorUtils.handleSendMessageResults(results.results());
  61         } catch (GroupNotFoundException | NotAGroupMemberException | GroupSendingNotAllowedException e) {
  62             throw new UserErrorException(e.getMessage());
  63         } catch (IOException e) {
  64             throw new UnexpectedErrorException("Failed to send message: " + e.getMessage() + " (" + e.getClass()
  65                     .getSimpleName() + ")", e);
  66         }
  67     }
  68
  69     private void outputResult(final OutputWriter outputWriter, final long timestamp) {
  70         if (outputWriter instanceof PlainTextWriter writer) {
  71             writer.println("{}", timestamp);
  72         } else {
  73             final var writer = (JsonWriter) outputWriter;
  74             writer.write(Map.of("timestamp", timestamp));
  75         }
  76     }
  77 }