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

   1 package org.asamk.signal.commands;
   2
   3 import net.sourceforge.argparse4j.inf.Namespace;
   4 import net.sourceforge.argparse4j.inf.Subparser;
   5
   6 import org.asamk.signal.commands.exceptions.CommandException;
   7 import org.asamk.signal.commands.exceptions.UnexpectedErrorException;
   8 import org.asamk.signal.manager.Manager;
   9 import org.asamk.signal.output.OutputWriter;
  10 import org.asamk.signal.util.CommandUtil;
  11
  12 import java.io.IOException;
  13 import java.util.Base64;
  14
  15 import static org.asamk.signal.util.SendMessageResultUtils.outputResult;
  16
  17 public class SendPaymentNotificationCommand implements JsonRpcLocalCommand {
  18
  19     @Override
  20     public String getName() {
  21         return "sendPaymentNotification";
  22     }
  23
  24     @Override
  25     public void attachToSubparser(final Subparser subparser) {
  26         subparser.help("Send a payment notification.");
  27         subparser.addArgument("recipient").help("Specify the recipient's phone number.");
  28         subparser.addArgument("--receipt").required(true).help("The base64 encoded receipt blob.");
  29         subparser.addArgument("--note").help("Specify a note for the payment notification.");
  30     }
  31
  32     @Override
  33     public void handleCommand(
  34             final Namespace ns, final Manager m, final OutputWriter outputWriter
  35     ) throws CommandException {
  36         final var recipientString = ns.getString("recipient");
  37         final var recipientIdentifier = CommandUtil.getSingleRecipientIdentifier(recipientString, m.getSelfNumber());
  38
  39         final var receiptString = ns.getString("receipt");
  40         final var receipt = Base64.getDecoder().decode(receiptString);
  41         final var note = ns.getString("note");
  42
  43         try {
  44             final var results = m.sendPaymentNotificationMessage(receipt, note, recipientIdentifier);
  45             outputResult(outputWriter, results);
  46         } catch (IOException e) {
  47             throw new UnexpectedErrorException("Failed to send message: " + e.getMessage() + " (" + e.getClass()
  48                     .getSimpleName() + ")", e);
  49         }
  50     }
  51 }