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

   1 package org.asamk.signal.commands;
   2
   3 import com.fasterxml.jackson.core.type.TypeReference;
   4
   5 import org.asamk.signal.JsonWriter;
   6 import org.asamk.signal.commands.exceptions.CommandException;
   7 import org.asamk.signal.commands.exceptions.IOErrorException;
   8 import org.asamk.signal.commands.exceptions.UserErrorException;
   9 import org.asamk.signal.manager.MultiAccountManager;
  10 import org.asamk.signal.manager.UserAlreadyExists;
  11 import org.slf4j.Logger;
  12 import org.slf4j.LoggerFactory;
  13
  14 import java.io.IOException;
  15 import java.net.URI;
  16 import java.net.URISyntaxException;
  17 import java.util.concurrent.TimeoutException;
  18
  19 public class FinishLinkCommand implements JsonRpcMultiCommand<FinishLinkCommand.FinishLinkParams> {
  20
  21     private final static Logger logger = LoggerFactory.getLogger(FinishLinkCommand.class);
  22
  23     @Override
  24     public String getName() {
  25         return "finishLink";
  26     }
  27
  28     @Override
  29     public TypeReference<FinishLinkParams> getRequestType() {
  30         return new TypeReference<>() {};
  31     }
  32
  33     @Override
  34     public void handleCommand(
  35             final FinishLinkParams request, final MultiAccountManager m, final JsonWriter jsonWriter
  36     ) throws CommandException {
  37         final URI deviceLinkUri;
  38         try {
  39             deviceLinkUri = new URI(request.deviceLinkUri());
  40         } catch (URISyntaxException e) {
  41             throw new UserErrorException("Invalid device link uri.");
  42         }
  43         final var provisioningManager = m.getProvisioningManagerFor(deviceLinkUri);
  44         if (provisioningManager == null) {
  45             throw new UserErrorException("Unknown device link uri.");
  46         }
  47
  48         var deviceName = request.deviceName();
  49         if (deviceName == null) {
  50             deviceName = "cli";
  51         }
  52         final String number;
  53         try {
  54             number = provisioningManager.finishDeviceLink(deviceName);
  55         } catch (TimeoutException e) {
  56             throw new UserErrorException("Link request timed out, please try again.");
  57         } catch (IOException e) {
  58             throw new IOErrorException("Link request error: " + e.getMessage(), e);
  59         } catch (UserAlreadyExists e) {
  60             throw new UserErrorException("The user "
  61                     + e.getNumber()
  62                     + " already exists\nDelete \""
  63                     + e.getFileName()
  64                     + "\" before trying again.");
  65         }
  66
  67         jsonWriter.write(new JsonFinishLink(number));
  68     }
  69
  70     record FinishLinkParams(String deviceLinkUri, String deviceName) {}
  71
  72     private record JsonFinishLink(String number) {}
  73 }