package org.asamk.signal.commands; import com.fasterxml.jackson.core.type.TypeReference; import net.sourceforge.argparse4j.impl.Arguments; import net.sourceforge.argparse4j.inf.Namespace; import net.sourceforge.argparse4j.inf.Subparser; import org.asamk.signal.OutputType; import org.asamk.signal.commands.exceptions.CommandException; import org.asamk.signal.commands.exceptions.IOErrorException; import org.asamk.signal.commands.exceptions.RateLimitErrorException; import org.asamk.signal.commands.exceptions.UserErrorException; import org.asamk.signal.manager.RegistrationManager; import org.asamk.signal.manager.api.CaptchaRequiredException; import org.asamk.signal.manager.api.NonNormalizedPhoneNumberException; import org.asamk.signal.manager.api.RateLimitException; import org.asamk.signal.manager.api.VerificationMethodNotAvailableException; import org.asamk.signal.output.JsonWriter; import org.asamk.signal.util.CommandUtil; import java.io.IOException; import java.util.List; public class RegisterCommand implements RegistrationCommand, JsonRpcRegistrationCommand { @Override public String getName() { return "register"; } @Override public void attachToSubparser(final Subparser subparser) { subparser.help("Register a phone number with SMS or voice verification."); subparser.addArgument("-v", "--voice") .help("The verification should be done over voice, not SMS.") .action(Arguments.storeTrue()); subparser.addArgument("--captcha") .help("The captcha token, required if registration failed with a captcha required error."); subparser.addArgument("--reregister") .action(Arguments.storeTrue()) .help("Register even if account is already registered"); } @Override public void handleCommand(final Namespace ns, final RegistrationManager m) throws CommandException { final boolean voiceVerification = Boolean.TRUE.equals(ns.getBoolean("voice")); final var captcha = ns.getString("captcha"); final var reregister = Boolean.TRUE.equals(ns.getBoolean("reregister")); register(m, voiceVerification, captcha, reregister); } @Override public TypeReference getRequestType() { return new TypeReference<>() {}; } @Override public List getSupportedOutputTypes() { return List.of(OutputType.PLAIN_TEXT, OutputType.JSON); } @Override public void handleCommand( final RegistrationParams request, final RegistrationManager m, final JsonWriter jsonWriter ) throws CommandException { register(m, Boolean.TRUE.equals(request.voice()), request.captcha(), Boolean.TRUE.equals(request.reregister())); } private void register( final RegistrationManager m, final boolean voiceVerification, final String captcha, final boolean reregister ) throws CommandException { try { m.register(voiceVerification, captcha, reregister); } catch (RateLimitException e) { final var message = CommandUtil.getRateLimitMessage(e); throw new RateLimitErrorException(message, e); } catch (CaptchaRequiredException e) { final var message = CommandUtil.getCaptchaRequiredMessage(e, captcha != null); throw new UserErrorException(message); } catch (NonNormalizedPhoneNumberException e) { throw new UserErrorException("Failed to register: " + e.getMessage(), e); } catch (IOException e) { throw new IOErrorException("Failed to register: %s (%s)".formatted(e.getMessage(), e.getClass().getSimpleName()), e); } catch (VerificationMethodNotAvailableException e) { throw new UserErrorException("Failed to register: " + e.getMessage() + ( voiceVerification ? ": Before requesting voice verification you need to request SMS verification and wait a minute." : "" ), e); } } public record RegistrationParams(Boolean voice, String captcha, Boolean reregister) {} }