1 package org
.asamk
.signal
.commands
;
3 import net
.sourceforge
.argparse4j
.impl
.Arguments
;
4 import net
.sourceforge
.argparse4j
.inf
.Namespace
;
5 import net
.sourceforge
.argparse4j
.inf
.Subparser
;
7 import org
.asamk
.signal
.JsonWriter
;
8 import org
.asamk
.signal
.OutputWriter
;
9 import org
.asamk
.signal
.PlainTextWriter
;
10 import org
.asamk
.signal
.commands
.exceptions
.CommandException
;
11 import org
.asamk
.signal
.commands
.exceptions
.UserErrorException
;
12 import org
.asamk
.signal
.manager
.Manager
;
13 import org
.asamk
.signal
.manager
.api
.RecipientIdentifier
;
14 import org
.asamk
.signal
.manager
.api
.TypingAction
;
15 import org
.asamk
.signal
.manager
.groups
.GroupNotFoundException
;
16 import org
.asamk
.signal
.manager
.groups
.GroupSendingNotAllowedException
;
17 import org
.asamk
.signal
.manager
.groups
.NotAGroupMemberException
;
18 import org
.asamk
.signal
.util
.CommandUtil
;
19 import org
.asamk
.signal
.util
.ErrorUtils
;
21 import java
.io
.IOException
;
22 import java
.util
.HashSet
;
25 public class SendTypingCommand
implements JsonRpcLocalCommand
{
28 public String
getName() {
33 public void attachToSubparser(final Subparser subparser
) {
35 "Send typing message to trigger a typing indicator for the recipient. Indicator will be shown for 15seconds unless a typing STOP message is sent first.");
36 subparser
.addArgument("-g", "--group-id", "--group").help("Specify the recipient group ID.").nargs("*");
37 subparser
.addArgument("recipient").help("Specify the recipients' phone number.").nargs("*");
38 subparser
.addArgument("-s", "--stop").help("Send a typing STOP message.").action(Arguments
.storeTrue());
42 public void handleCommand(
43 final Namespace ns
, final Manager m
, final OutputWriter outputWriter
44 ) throws CommandException
{
45 final var recipientStrings
= ns
.<String
>getList("recipient");
46 final var groupIdStrings
= ns
.<String
>getList("group-id");
47 final var action
= Boolean
.TRUE
.equals(ns
.getBoolean("stop")) ? TypingAction
.STOP
: TypingAction
.START
;
49 final var recipientIdentifiers
= new HashSet
<RecipientIdentifier
>();
50 if (recipientStrings
!= null) {
51 final var localNumber
= m
.getSelfNumber();
52 recipientIdentifiers
.addAll(CommandUtil
.getSingleRecipientIdentifiers(recipientStrings
, localNumber
));
54 if (groupIdStrings
!= null) {
55 recipientIdentifiers
.addAll(CommandUtil
.getGroupIdentifiers(groupIdStrings
));
58 if (recipientIdentifiers
.isEmpty()) {
59 throw new UserErrorException("No recipients given");
63 final var results
= m
.sendTypingMessage(action
, recipientIdentifiers
);
64 outputResult(outputWriter
, results
.timestamp());
65 ErrorUtils
.handleSendMessageResults(results
.results());
66 } catch (IOException e
) {
67 throw new UserErrorException("Failed to send message: " + e
.getMessage() + " (" + e
.getClass()
68 .getSimpleName() + ")");
69 } catch (GroupNotFoundException
| NotAGroupMemberException
| GroupSendingNotAllowedException e
) {
70 throw new UserErrorException("Failed to send to group: " + e
.getMessage());
74 private void outputResult(final OutputWriter outputWriter
, final long timestamp
) {
75 if (outputWriter
instanceof PlainTextWriter writer
) {
76 writer
.println("{}", timestamp
);
78 final var writer
= (JsonWriter
) outputWriter
;
79 writer
.write(Map
.of("timestamp", timestamp
));