2 * Copyright (C) 2015 AsamK
4 * This program is free software: you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License as published by
6 * the Free Software Foundation, either version 3 of the License, or
7 * (at your option) any later version.
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
14 * You should have received a copy of the GNU General Public License
15 * along with this program. If not, see <http://www.gnu.org/licenses/>.
17 package org
.asamk
.signal
;
19 import net
.sourceforge
.argparse4j
.ArgumentParsers
;
20 import net
.sourceforge
.argparse4j
.impl
.Arguments
;
21 import net
.sourceforge
.argparse4j
.inf
.*;
22 import org
.apache
.http
.util
.TextUtils
;
23 import org
.asamk
.Signal
;
24 import org
.freedesktop
.dbus
.DBusConnection
;
25 import org
.freedesktop
.dbus
.DBusSigHandler
;
26 import org
.freedesktop
.dbus
.exceptions
.DBusException
;
27 import org
.freedesktop
.dbus
.exceptions
.DBusExecutionException
;
28 import org
.whispersystems
.libsignal
.InvalidKeyException
;
29 import org
.whispersystems
.signalservice
.api
.crypto
.UntrustedIdentityException
;
30 import org
.whispersystems
.signalservice
.api
.messages
.*;
31 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.*;
32 import org
.whispersystems
.signalservice
.api
.push
.SignalServiceAddress
;
33 import org
.whispersystems
.signalservice
.api
.push
.exceptions
.EncapsulatedExceptions
;
34 import org
.whispersystems
.signalservice
.api
.push
.exceptions
.NetworkFailureException
;
35 import org
.whispersystems
.signalservice
.api
.push
.exceptions
.UnregisteredUserException
;
36 import org
.whispersystems
.signalservice
.api
.util
.PhoneNumberFormatter
;
39 import java
.io
.IOException
;
40 import java
.io
.InputStream
;
41 import java
.io
.StringWriter
;
43 import java
.net
.URISyntaxException
;
44 import java
.nio
.charset
.Charset
;
45 import java
.security
.Security
;
46 import java
.text
.DateFormat
;
47 import java
.text
.SimpleDateFormat
;
49 import java
.util
.concurrent
.TimeUnit
;
50 import java
.util
.concurrent
.TimeoutException
;
54 public static final String SIGNAL_BUSNAME
= "org.asamk.Signal";
55 public static final String SIGNAL_OBJECTPATH
= "/org/asamk/Signal";
57 private static final TimeZone tzUTC
= TimeZone
.getTimeZone("UTC");
59 public static void main(String
[] args
) {
60 // Workaround for BKS truststore
61 Security
.insertProviderAt(new org
.bouncycastle
.jce
.provider
.BouncyCastleProvider(), 1);
63 Namespace ns
= parseArgs(args
);
68 int res
= handleCommands(ns
);
72 private static int handleCommands(Namespace ns
) {
73 final String username
= ns
.getString("username");
76 DBusConnection dBusConn
= null;
78 if (ns
.getBoolean("dbus") || ns
.getBoolean("dbus_system")) {
82 if (ns
.getBoolean("dbus_system")) {
83 busType
= DBusConnection
.SYSTEM
;
85 busType
= DBusConnection
.SESSION
;
87 dBusConn
= DBusConnection
.getConnection(busType
);
88 ts
= (Signal
) dBusConn
.getRemoteObject(
89 SIGNAL_BUSNAME
, SIGNAL_OBJECTPATH
,
91 } catch (UnsatisfiedLinkError e
) {
92 System
.err
.println("Missing native library dependency for dbus service: " + e
.getMessage());
94 } catch (DBusException e
) {
96 if (dBusConn
!= null) {
97 dBusConn
.disconnect();
102 String settingsPath
= ns
.getString("config");
103 if (TextUtils
.isEmpty(settingsPath
)) {
104 settingsPath
= System
.getProperty("user.home") + "/.config/signal";
105 if (!new File(settingsPath
).exists()) {
106 String legacySettingsPath
= System
.getProperty("user.home") + "/.config/textsecure";
107 if (new File(legacySettingsPath
).exists()) {
108 settingsPath
= legacySettingsPath
;
113 m
= new Manager(username
, settingsPath
);
115 if (m
.userExists()) {
118 } catch (Exception e
) {
119 System
.err
.println("Error loading state file \"" + m
.getFileName() + "\": " + e
.getMessage());
125 switch (ns
.getString("command")) {
127 if (dBusConn
!= null) {
128 System
.err
.println("register is not yet implemented via dbus");
131 if (!m
.userHasKeys()) {
132 m
.createNewIdentity();
135 m
.register(ns
.getBoolean("voice"));
136 } catch (IOException e
) {
137 System
.err
.println("Request verify error: " + e
.getMessage());
142 if (dBusConn
!= null) {
143 System
.err
.println("unregister is not yet implemented via dbus");
146 if (!m
.isRegistered()) {
147 System
.err
.println("User is not registered.");
152 } catch (IOException e
) {
153 System
.err
.println("Unregister error: " + e
.getMessage());
157 case "updateAccount":
158 if (dBusConn
!= null) {
159 System
.err
.println("updateAccount is not yet implemented via dbus");
162 if (!m
.isRegistered()) {
163 System
.err
.println("User is not registered.");
167 m
.updateAccountAttributes();
168 } catch (IOException e
) {
169 System
.err
.println("UpdateAccount error: " + e
.getMessage());
174 if (dBusConn
!= null) {
175 System
.err
.println("verify is not yet implemented via dbus");
178 if (!m
.userHasKeys()) {
179 System
.err
.println("User has no keys, first call register.");
182 if (m
.isRegistered()) {
183 System
.err
.println("User registration is already verified");
187 m
.verifyAccount(ns
.getString("verificationCode"));
188 } catch (IOException e
) {
189 System
.err
.println("Verify error: " + e
.getMessage());
194 if (dBusConn
!= null) {
195 System
.err
.println("link is not yet implemented via dbus");
199 // When linking, username is null and we always have to create keys
200 m
.createNewIdentity();
202 String deviceName
= ns
.getString("name");
203 if (deviceName
== null) {
207 System
.out
.println(m
.getDeviceLinkUri());
208 m
.finishDeviceLink(deviceName
);
209 System
.out
.println("Associated with: " + m
.getUsername());
210 } catch (TimeoutException e
) {
211 System
.err
.println("Link request timed out, please try again.");
213 } catch (IOException e
) {
214 System
.err
.println("Link request error: " + e
.getMessage());
216 } catch (AssertionError e
) {
217 handleAssertionError(e
);
219 } catch (InvalidKeyException e
) {
222 } catch (UserAlreadyExists e
) {
223 System
.err
.println("The user " + e
.getUsername() + " already exists\nDelete \"" + e
.getFileName() + "\" before trying again.");
228 if (dBusConn
!= null) {
229 System
.err
.println("link is not yet implemented via dbus");
232 if (!m
.isRegistered()) {
233 System
.err
.println("User is not registered.");
237 m
.addDeviceLink(new URI(ns
.getString("uri")));
238 } catch (IOException e
) {
241 } catch (InvalidKeyException e
) {
244 } catch (AssertionError e
) {
245 handleAssertionError(e
);
247 } catch (URISyntaxException e
) {
253 if (dBusConn
!= null) {
254 System
.err
.println("listDevices is not yet implemented via dbus");
257 if (!m
.isRegistered()) {
258 System
.err
.println("User is not registered.");
262 List
<DeviceInfo
> devices
= m
.getLinkedDevices();
263 for (DeviceInfo d
: devices
) {
264 System
.out
.println("Device " + d
.getId() + (d
.getId() == m
.getDeviceId() ?
" (this device)" : "") + ":");
265 System
.out
.println(" Name: " + d
.getName());
266 System
.out
.println(" Created: " + formatTimestamp(d
.getCreated()));
267 System
.out
.println(" Last seen: " + formatTimestamp(d
.getLastSeen()));
269 } catch (IOException e
) {
275 if (dBusConn
!= null) {
276 System
.err
.println("removeDevice is not yet implemented via dbus");
279 if (!m
.isRegistered()) {
280 System
.err
.println("User is not registered.");
284 int deviceId
= ns
.getInt("deviceId");
285 m
.removeLinkedDevices(deviceId
);
286 } catch (IOException e
) {
292 if (dBusConn
== null && !m
.isRegistered()) {
293 System
.err
.println("User is not registered.");
297 if (ns
.getBoolean("endsession")) {
298 if (ns
.getList("recipient") == null) {
299 System
.err
.println("No recipients given");
300 System
.err
.println("Aborting sending.");
304 ts
.sendEndSessionMessage(ns
.<String
>getList("recipient"));
305 } catch (IOException e
) {
306 handleIOException(e
);
308 } catch (EncapsulatedExceptions e
) {
309 handleEncapsulatedExceptions(e
);
311 } catch (AssertionError e
) {
312 handleAssertionError(e
);
314 } catch (DBusExecutionException e
) {
315 handleDBusExecutionException(e
);
319 String messageText
= ns
.getString("message");
320 if (messageText
== null) {
322 messageText
= readAll(System
.in);
323 } catch (IOException e
) {
324 System
.err
.println("Failed to read message from stdin: " + e
.getMessage());
325 System
.err
.println("Aborting sending.");
331 List
<String
> attachments
= ns
.getList("attachment");
332 if (attachments
== null) {
333 attachments
= new ArrayList
<>();
335 if (ns
.getString("group") != null) {
336 byte[] groupId
= decodeGroupId(ns
.getString("group"));
337 ts
.sendGroupMessage(messageText
, attachments
, groupId
);
339 ts
.sendMessage(messageText
, attachments
, ns
.<String
>getList("recipient"));
341 } catch (IOException e
) {
342 handleIOException(e
);
344 } catch (EncapsulatedExceptions e
) {
345 handleEncapsulatedExceptions(e
);
347 } catch (AssertionError e
) {
348 handleAssertionError(e
);
350 } catch (GroupNotFoundException e
) {
351 handleGroupNotFoundException(e
);
353 } catch (NotAGroupMemberException e
) {
354 handleNotAGroupMemberException(e
);
356 } catch (AttachmentInvalidException e
) {
357 System
.err
.println("Failed to add attachment: " + e
.getMessage());
358 System
.err
.println("Aborting sending.");
360 } catch (DBusExecutionException e
) {
361 handleDBusExecutionException(e
);
368 if (dBusConn
!= null) {
370 dBusConn
.addSigHandler(Signal
.MessageReceived
.class, new DBusSigHandler
<Signal
.MessageReceived
>() {
372 public void handle(Signal
.MessageReceived s
) {
373 System
.out
.print(String
.format("Envelope from: %s\nTimestamp: %s\nBody: %s\n",
374 s
.getSender(), formatTimestamp(s
.getTimestamp()), s
.getMessage()));
375 if (s
.getGroupId().length
> 0) {
376 System
.out
.println("Group info:");
377 System
.out
.println(" Id: " + Base64
.encodeBytes(s
.getGroupId()));
379 if (s
.getAttachments().size() > 0) {
380 System
.out
.println("Attachments: ");
381 for (String attachment
: s
.getAttachments()) {
382 System
.out
.println("- Stored plaintext in: " + attachment
);
385 System
.out
.println();
388 } catch (UnsatisfiedLinkError e
) {
389 System
.err
.println("Missing native library dependency for dbus service: " + e
.getMessage());
391 } catch (DBusException e
) {
398 } catch (InterruptedException e
) {
403 if (!m
.isRegistered()) {
404 System
.err
.println("User is not registered.");
408 if (ns
.getDouble("timeout") != null) {
409 timeout
= ns
.getDouble("timeout");
411 boolean returnOnTimeout
= true;
413 returnOnTimeout
= false;
416 boolean ignoreAttachments
= ns
.getBoolean("ignore_attachments");
418 m
.receiveMessages((long) (timeout
* 1000), TimeUnit
.MILLISECONDS
, returnOnTimeout
, ignoreAttachments
, new ReceiveMessageHandler(m
));
419 } catch (IOException e
) {
420 System
.err
.println("Error while receiving messages: " + e
.getMessage());
422 } catch (AssertionError e
) {
423 handleAssertionError(e
);
428 if (dBusConn
!= null) {
429 System
.err
.println("quitGroup is not yet implemented via dbus");
432 if (!m
.isRegistered()) {
433 System
.err
.println("User is not registered.");
438 m
.sendQuitGroupMessage(decodeGroupId(ns
.getString("group")));
439 } catch (IOException e
) {
440 handleIOException(e
);
442 } catch (EncapsulatedExceptions e
) {
443 handleEncapsulatedExceptions(e
);
445 } catch (AssertionError e
) {
446 handleAssertionError(e
);
448 } catch (GroupNotFoundException e
) {
449 handleGroupNotFoundException(e
);
451 } catch (NotAGroupMemberException e
) {
452 handleNotAGroupMemberException(e
);
458 if (dBusConn
!= null) {
459 System
.err
.println("updateGroup is not yet implemented via dbus");
462 if (!m
.isRegistered()) {
463 System
.err
.println("User is not registered.");
468 byte[] groupId
= null;
469 if (ns
.getString("group") != null) {
470 groupId
= decodeGroupId(ns
.getString("group"));
472 byte[] newGroupId
= m
.sendUpdateGroupMessage(groupId
, ns
.getString("name"), ns
.<String
>getList("member"), ns
.getString("avatar"));
473 if (groupId
== null) {
474 System
.out
.println("Creating new group \"" + Base64
.encodeBytes(newGroupId
) + "\" …");
476 } catch (IOException e
) {
477 handleIOException(e
);
479 } catch (AttachmentInvalidException e
) {
480 System
.err
.println("Failed to add avatar attachment for group\": " + e
.getMessage());
481 System
.err
.println("Aborting sending.");
483 } catch (GroupNotFoundException e
) {
484 handleGroupNotFoundException(e
);
486 } catch (NotAGroupMemberException e
) {
487 handleNotAGroupMemberException(e
);
489 } catch (EncapsulatedExceptions e
) {
490 handleEncapsulatedExceptions(e
);
495 case "listIdentities":
496 if (dBusConn
!= null) {
497 System
.err
.println("listIdentities is not yet implemented via dbus");
500 if (!m
.isRegistered()) {
501 System
.err
.println("User is not registered.");
504 if (ns
.get("number") == null) {
505 for (Map
.Entry
<String
, List
<JsonIdentityKeyStore
.Identity
>> keys
: m
.getIdentities().entrySet()) {
506 for (JsonIdentityKeyStore
.Identity id
: keys
.getValue()) {
507 printIdentityFingerprint(m
, keys
.getKey(), id
);
511 String number
= ns
.getString("number");
512 for (JsonIdentityKeyStore
.Identity id
: m
.getIdentities(number
)) {
513 printIdentityFingerprint(m
, number
, id
);
518 if (dBusConn
!= null) {
519 System
.err
.println("trust is not yet implemented via dbus");
522 if (!m
.isRegistered()) {
523 System
.err
.println("User is not registered.");
526 String number
= ns
.getString("number");
527 if (ns
.getBoolean("trust_all_known_keys")) {
528 boolean res
= m
.trustIdentityAllKeys(number
);
530 System
.err
.println("Failed to set the trust for this number, make sure the number is correct.");
534 String fingerprint
= ns
.getString("verified_fingerprint");
535 if (fingerprint
!= null) {
536 fingerprint
= fingerprint
.replaceAll(" ", "");
537 if (fingerprint
.length() == 66) {
538 byte[] fingerprintBytes
;
540 fingerprintBytes
= Hex
.toByteArray(fingerprint
.toLowerCase(Locale
.ROOT
));
541 } catch (Exception e
) {
542 System
.err
.println("Failed to parse the fingerprint, make sure the fingerprint is a correctly encoded hex string without additional characters.");
545 boolean res
= m
.trustIdentityVerified(number
, fingerprintBytes
);
547 System
.err
.println("Failed to set the trust for the fingerprint of this number, make sure the number and the fingerprint are correct.");
550 } else if (fingerprint
.length() == 60) {
551 boolean res
= m
.trustIdentityVerifiedSafetyNumber(number
, fingerprint
);
553 System
.err
.println("Failed to set the trust for the safety number of this phone number, make sure the phone number and the safety number are correct.");
557 System
.err
.println("Fingerprint has invalid format, either specify the old hex fingerprint or the new safety number");
561 System
.err
.println("You need to specify the fingerprint you have verified with -v FINGERPRINT");
567 if (dBusConn
!= null) {
568 System
.err
.println("Stop it.");
571 if (!m
.isRegistered()) {
572 System
.err
.println("User is not registered.");
575 DBusConnection conn
= null;
579 if (ns
.getBoolean("system")) {
580 busType
= DBusConnection
.SYSTEM
;
582 busType
= DBusConnection
.SESSION
;
584 conn
= DBusConnection
.getConnection(busType
);
585 conn
.exportObject(SIGNAL_OBJECTPATH
, m
);
586 conn
.requestBusName(SIGNAL_BUSNAME
);
587 } catch (UnsatisfiedLinkError e
) {
588 System
.err
.println("Missing native library dependency for dbus service: " + e
.getMessage());
590 } catch (DBusException e
) {
594 ignoreAttachments
= ns
.getBoolean("ignore_attachments");
596 m
.receiveMessages(1, TimeUnit
.HOURS
, false, ignoreAttachments
, new DbusReceiveMessageHandler(m
, conn
));
597 } catch (IOException e
) {
598 System
.err
.println("Error while receiving messages: " + e
.getMessage());
600 } catch (AssertionError e
) {
601 handleAssertionError(e
);
614 if (dBusConn
!= null) {
615 dBusConn
.disconnect();
620 private static void printIdentityFingerprint(Manager m
, String theirUsername
, JsonIdentityKeyStore
.Identity theirId
) {
621 String digits
= formatSafetyNumber(m
.computeSafetyNumber(theirUsername
, theirId
.identityKey
));
622 System
.out
.println(String
.format("%s: %s Added: %s Fingerprint: %s Safety Number: %s", theirUsername
,
623 theirId
.trustLevel
, theirId
.added
, Hex
.toStringCondensed(theirId
.getFingerprint()), digits
));
626 private static String
formatSafetyNumber(String digits
) {
627 final int partCount
= 12;
628 int partSize
= digits
.length() / partCount
;
629 StringBuilder f
= new StringBuilder(digits
.length() + partCount
);
630 for (int i
= 0; i
< partCount
; i
++) {
631 f
.append(digits
.substring(i
* partSize
, (i
* partSize
) + partSize
)).append(" ");
636 private static void handleGroupNotFoundException(GroupNotFoundException e
) {
637 System
.err
.println("Failed to send to group: " + e
.getMessage());
638 System
.err
.println("Aborting sending.");
641 private static void handleNotAGroupMemberException(NotAGroupMemberException e
) {
642 System
.err
.println("Failed to send to group: " + e
.getMessage());
643 System
.err
.println("Update the group on another device to readd the user to this group.");
644 System
.err
.println("Aborting sending.");
648 private static void handleDBusExecutionException(DBusExecutionException e
) {
649 System
.err
.println("Cannot connect to dbus: " + e
.getMessage());
650 System
.err
.println("Aborting.");
653 private static byte[] decodeGroupId(String groupId
) {
655 return Base64
.decode(groupId
);
656 } catch (IOException e
) {
657 System
.err
.println("Failed to decode groupId (must be base64) \"" + groupId
+ "\": " + e
.getMessage());
658 System
.err
.println("Aborting sending.");
664 private static Namespace
parseArgs(String
[] args
) {
665 ArgumentParser parser
= ArgumentParsers
.newArgumentParser("signal-cli")
667 .description("Commandline interface for Signal.")
668 .version(Manager
.PROJECT_NAME
+ " " + Manager
.PROJECT_VERSION
);
670 parser
.addArgument("-v", "--version")
671 .help("Show package version.")
672 .action(Arguments
.version());
673 parser
.addArgument("--config")
674 .help("Set the path, where to store the config (Default: $HOME/.config/signal).");
676 MutuallyExclusiveGroup mut
= parser
.addMutuallyExclusiveGroup();
677 mut
.addArgument("-u", "--username")
678 .help("Specify your phone number, that will be used for verification.");
679 mut
.addArgument("--dbus")
680 .help("Make request via user dbus.")
681 .action(Arguments
.storeTrue());
682 mut
.addArgument("--dbus-system")
683 .help("Make request via system dbus.")
684 .action(Arguments
.storeTrue());
686 Subparsers subparsers
= parser
.addSubparsers()
687 .title("subcommands")
689 .description("valid subcommands")
690 .help("additional help");
692 Subparser parserLink
= subparsers
.addParser("link");
693 parserLink
.addArgument("-n", "--name")
694 .help("Specify a name to describe this new device.");
696 Subparser parserAddDevice
= subparsers
.addParser("addDevice");
697 parserAddDevice
.addArgument("--uri")
699 .help("Specify the uri contained in the QR code shown by the new device.");
701 Subparser parserDevices
= subparsers
.addParser("listDevices");
703 Subparser parserRemoveDevice
= subparsers
.addParser("removeDevice");
704 parserRemoveDevice
.addArgument("-d", "--deviceId")
707 .help("Specify the device you want to remove. Use listDevices to see the deviceIds.");
709 Subparser parserRegister
= subparsers
.addParser("register");
710 parserRegister
.addArgument("-v", "--voice")
711 .help("The verification should be done over voice, not sms.")
712 .action(Arguments
.storeTrue());
714 Subparser parserUnregister
= subparsers
.addParser("unregister");
715 parserUnregister
.help("Unregister the current device from the signal server.");
717 Subparser parserUpdateAccount
= subparsers
.addParser("updateAccount");
718 parserUpdateAccount
.help("Update the account attributes on the signal server.");
720 Subparser parserVerify
= subparsers
.addParser("verify");
721 parserVerify
.addArgument("verificationCode")
722 .help("The verification code you received via sms or voice call.");
724 Subparser parserSend
= subparsers
.addParser("send");
725 parserSend
.addArgument("-g", "--group")
726 .help("Specify the recipient group ID.");
727 parserSend
.addArgument("recipient")
728 .help("Specify the recipients' phone number.")
730 parserSend
.addArgument("-m", "--message")
731 .help("Specify the message, if missing standard input is used.");
732 parserSend
.addArgument("-a", "--attachment")
734 .help("Add file as attachment");
735 parserSend
.addArgument("-e", "--endsession")
736 .help("Clear session state and send end session message.")
737 .action(Arguments
.storeTrue());
739 Subparser parserLeaveGroup
= subparsers
.addParser("quitGroup");
740 parserLeaveGroup
.addArgument("-g", "--group")
742 .help("Specify the recipient group ID.");
744 Subparser parserUpdateGroup
= subparsers
.addParser("updateGroup");
745 parserUpdateGroup
.addArgument("-g", "--group")
746 .help("Specify the recipient group ID.");
747 parserUpdateGroup
.addArgument("-n", "--name")
748 .help("Specify the new group name.");
749 parserUpdateGroup
.addArgument("-a", "--avatar")
750 .help("Specify a new group avatar image file");
751 parserUpdateGroup
.addArgument("-m", "--member")
753 .help("Specify one or more members to add to the group");
755 Subparser parserListIdentities
= subparsers
.addParser("listIdentities");
756 parserListIdentities
.addArgument("-n", "--number")
757 .help("Only show identity keys for the given phone number.");
759 Subparser parserTrust
= subparsers
.addParser("trust");
760 parserTrust
.addArgument("number")
761 .help("Specify the phone number, for which to set the trust.")
763 MutuallyExclusiveGroup mutTrust
= parserTrust
.addMutuallyExclusiveGroup();
764 mutTrust
.addArgument("-a", "--trust-all-known-keys")
765 .help("Trust all known keys of this user, only use this for testing.")
766 .action(Arguments
.storeTrue());
767 mutTrust
.addArgument("-v", "--verified-fingerprint")
768 .help("Specify the fingerprint of the key, only use this option if you have verified the fingerprint.");
770 Subparser parserReceive
= subparsers
.addParser("receive");
771 parserReceive
.addArgument("-t", "--timeout")
773 .help("Number of seconds to wait for new messages (negative values disable timeout)");
774 parserReceive
.addArgument("--ignore-attachments")
775 .help("Don’t download attachments of received messages.")
776 .action(Arguments
.storeTrue());
778 Subparser parserDaemon
= subparsers
.addParser("daemon");
779 parserDaemon
.addArgument("--system")
780 .action(Arguments
.storeTrue())
781 .help("Use DBus system bus instead of user bus.");
782 parserDaemon
.addArgument("--ignore-attachments")
783 .help("Don’t download attachments of received messages.")
784 .action(Arguments
.storeTrue());
787 Namespace ns
= parser
.parseArgs(args
);
788 if ("link".equals(ns
.getString("command"))) {
789 if (ns
.getString("username") != null) {
791 System
.err
.println("You cannot specify a username (phone number) when linking");
794 } else if (!ns
.getBoolean("dbus") && !ns
.getBoolean("dbus_system")) {
795 if (ns
.getString("username") == null) {
797 System
.err
.println("You need to specify a username (phone number)");
800 if (!PhoneNumberFormatter
.isValidNumber(ns
.getString("username"))) {
801 System
.err
.println("Invalid username (phone number), make sure you include the country code.");
805 if (ns
.getList("recipient") != null && !ns
.getList("recipient").isEmpty() && ns
.getString("group") != null) {
806 System
.err
.println("You cannot specify recipients by phone number and groups a the same time");
810 } catch (ArgumentParserException e
) {
811 parser
.handleError(e
);
816 private static void handleAssertionError(AssertionError e
) {
817 System
.err
.println("Failed to send/receive message (Assertion): " + e
.getMessage());
819 System
.err
.println("If you use an Oracle JRE please check if you have unlimited strength crypto enabled, see README");
822 private static void handleEncapsulatedExceptions(EncapsulatedExceptions e
) {
823 System
.err
.println("Failed to send (some) messages:");
824 for (NetworkFailureException n
: e
.getNetworkExceptions()) {
825 System
.err
.println("Network failure for \"" + n
.getE164number() + "\": " + n
.getMessage());
827 for (UnregisteredUserException n
: e
.getUnregisteredUserExceptions()) {
828 System
.err
.println("Unregistered user \"" + n
.getE164Number() + "\": " + n
.getMessage());
830 for (UntrustedIdentityException n
: e
.getUntrustedIdentityExceptions()) {
831 System
.err
.println("Untrusted Identity for \"" + n
.getE164Number() + "\": " + n
.getMessage());
835 private static void handleIOException(IOException e
) {
836 System
.err
.println("Failed to send message: " + e
.getMessage());
839 private static String
readAll(InputStream
in) throws IOException
{
840 StringWriter output
= new StringWriter();
841 byte[] buffer
= new byte[4096];
844 while (-1 != (n
= System
.in.read(buffer
))) {
845 output
.write(new String(buffer
, 0, n
, Charset
.defaultCharset()));
848 return output
.toString();
851 private static class ReceiveMessageHandler
implements Manager
.ReceiveMessageHandler
{
854 public ReceiveMessageHandler(Manager m
) {
859 public void handleMessage(SignalServiceEnvelope envelope
, SignalServiceContent content
, Throwable exception
) {
860 SignalServiceAddress source
= envelope
.getSourceAddress();
861 ContactInfo sourceContact
= m
.getContact(source
.getNumber());
862 System
.out
.println(String
.format("Envelope from: %s (device: %d)", (sourceContact
== null ?
"" : "“" + sourceContact
.name
+ "” ") + source
.getNumber(), envelope
.getSourceDevice()));
863 if (source
.getRelay().isPresent()) {
864 System
.out
.println("Relayed by: " + source
.getRelay().get());
866 System
.out
.println("Timestamp: " + formatTimestamp(envelope
.getTimestamp()));
868 if (envelope
.isReceipt()) {
869 System
.out
.println("Got receipt.");
870 } else if (envelope
.isSignalMessage() | envelope
.isPreKeySignalMessage()) {
871 if (exception
!= null) {
872 if (exception
instanceof org
.whispersystems
.libsignal
.UntrustedIdentityException
) {
873 org
.whispersystems
.libsignal
.UntrustedIdentityException e
= (org
.whispersystems
.libsignal
.UntrustedIdentityException
) exception
;
874 System
.out
.println("The user’s key is untrusted, either the user has reinstalled Signal or a third party sent this message.");
875 System
.out
.println("Use 'signal-cli -u " + m
.getUsername() + " listIdentities -n " + e
.getName() + "', verify the key and run 'signal-cli -u " + m
.getUsername() + " trust -v \"FINGER_PRINT\" " + e
.getName() + "' to mark it as trusted");
876 System
.out
.println("If you don't care about security, use 'signal-cli -u " + m
.getUsername() + " trust -a " + e
.getName() + "' to trust it without verification");
878 System
.out
.println("Exception: " + exception
.getMessage() + " (" + exception
.getClass().getSimpleName() + ")");
881 if (content
== null) {
882 System
.out
.println("Failed to decrypt message.");
884 if (content
.getDataMessage().isPresent()) {
885 SignalServiceDataMessage message
= content
.getDataMessage().get();
886 handleSignalServiceDataMessage(message
);
888 if (content
.getSyncMessage().isPresent()) {
889 System
.out
.println("Received a sync message");
890 SignalServiceSyncMessage syncMessage
= content
.getSyncMessage().get();
892 if (syncMessage
.getContacts().isPresent()) {
893 System
.out
.println("Received sync contacts");
894 printAttachment(syncMessage
.getContacts().get());
896 if (syncMessage
.getGroups().isPresent()) {
897 System
.out
.println("Received sync groups");
898 printAttachment(syncMessage
.getGroups().get());
900 if (syncMessage
.getRead().isPresent()) {
901 System
.out
.println("Received sync read messages list");
902 for (ReadMessage rm
: syncMessage
.getRead().get()) {
903 ContactInfo fromContact
= m
.getContact(rm
.getSender());
904 System
.out
.println("From: " + (fromContact
== null ?
"" : "“" + fromContact
.name
+ "” ") + rm
.getSender() + " Message timestamp: " + formatTimestamp(rm
.getTimestamp()));
907 if (syncMessage
.getRequest().isPresent()) {
908 System
.out
.println("Received sync request");
909 if (syncMessage
.getRequest().get().isContactsRequest()) {
910 System
.out
.println(" - contacts request");
912 if (syncMessage
.getRequest().get().isGroupsRequest()) {
913 System
.out
.println(" - groups request");
916 if (syncMessage
.getSent().isPresent()) {
917 System
.out
.println("Received sync sent message");
918 final SentTranscriptMessage sentTranscriptMessage
= syncMessage
.getSent().get();
920 if (sentTranscriptMessage
.getDestination().isPresent()) {
921 String dest
= sentTranscriptMessage
.getDestination().get();
922 ContactInfo destContact
= m
.getContact(dest
);
923 to = (destContact
== null ?
"" : "“" + destContact
.name
+ "” ") + dest
;
927 System
.out
.println("To: " + to + " , Message timestamp: " + formatTimestamp(sentTranscriptMessage
.getTimestamp()));
928 if (sentTranscriptMessage
.getExpirationStartTimestamp() > 0) {
929 System
.out
.println("Expiration started at: " + formatTimestamp(sentTranscriptMessage
.getExpirationStartTimestamp()));
931 SignalServiceDataMessage message
= sentTranscriptMessage
.getMessage();
932 handleSignalServiceDataMessage(message
);
934 if (syncMessage
.getBlockedList().isPresent()) {
935 System
.out
.println("Received sync message with block list");
936 System
.out
.println("Blocked numbers:");
937 final BlockedListMessage blockedList
= syncMessage
.getBlockedList().get();
938 for (String number
: blockedList
.getNumbers()) {
939 System
.out
.println(" - " + number
);
945 System
.out
.println("Unknown message received.");
947 System
.out
.println();
950 private void handleSignalServiceDataMessage(SignalServiceDataMessage message
) {
951 System
.out
.println("Message timestamp: " + formatTimestamp(message
.getTimestamp()));
953 if (message
.getBody().isPresent()) {
954 System
.out
.println("Body: " + message
.getBody().get());
956 if (message
.getGroupInfo().isPresent()) {
957 SignalServiceGroup groupInfo
= message
.getGroupInfo().get();
958 System
.out
.println("Group info:");
959 System
.out
.println(" Id: " + Base64
.encodeBytes(groupInfo
.getGroupId()));
960 if (groupInfo
.getType() == SignalServiceGroup
.Type
.UPDATE
&& groupInfo
.getName().isPresent()) {
961 System
.out
.println(" Name: " + groupInfo
.getName().get());
963 GroupInfo group
= m
.getGroup(groupInfo
.getGroupId());
965 System
.out
.println(" Name: " + group
.name
);
967 System
.out
.println(" Name: <Unknown group>");
970 System
.out
.println(" Type: " + groupInfo
.getType());
971 if (groupInfo
.getMembers().isPresent()) {
972 for (String member
: groupInfo
.getMembers().get()) {
973 System
.out
.println(" Member: " + member
);
976 if (groupInfo
.getAvatar().isPresent()) {
977 System
.out
.println(" Avatar:");
978 printAttachment(groupInfo
.getAvatar().get());
981 if (message
.isEndSession()) {
982 System
.out
.println("Is end session");
984 if (message
.isExpirationUpdate()) {
985 System
.out
.println("Is Expiration update: " + message
.isExpirationUpdate());
987 if (message
.getExpiresInSeconds() > 0) {
988 System
.out
.println("Expires in: " + message
.getExpiresInSeconds() + " seconds");
991 if (message
.getAttachments().isPresent()) {
992 System
.out
.println("Attachments: ");
993 for (SignalServiceAttachment attachment
: message
.getAttachments().get()) {
994 printAttachment(attachment
);
999 private void printAttachment(SignalServiceAttachment attachment
) {
1000 System
.out
.println("- " + attachment
.getContentType() + " (" + (attachment
.isPointer() ?
"Pointer" : "") + (attachment
.isStream() ?
"Stream" : "") + ")");
1001 if (attachment
.isPointer()) {
1002 final SignalServiceAttachmentPointer pointer
= attachment
.asPointer();
1003 System
.out
.println(" Id: " + pointer
.getId() + " Key length: " + pointer
.getKey().length
+ (pointer
.getRelay().isPresent() ?
" Relay: " + pointer
.getRelay().get() : ""));
1004 System
.out
.println(" Size: " + (pointer
.getSize().isPresent() ? pointer
.getSize().get() + " bytes" : "<unavailable>") + (pointer
.getPreview().isPresent() ?
" (Preview is available: " + pointer
.getPreview().get().length
+ " bytes)" : ""));
1005 File file
= m
.getAttachmentFile(pointer
.getId());
1006 if (file
.exists()) {
1007 System
.out
.println(" Stored plaintext in: " + file
);
1013 private static class DbusReceiveMessageHandler
extends ReceiveMessageHandler
{
1014 final DBusConnection conn
;
1016 public DbusReceiveMessageHandler(Manager m
, DBusConnection conn
) {
1022 public void handleMessage(SignalServiceEnvelope envelope
, SignalServiceContent content
, Throwable exception
) {
1023 super.handleMessage(envelope
, content
, exception
);
1025 if (!envelope
.isReceipt() && content
!= null && content
.getDataMessage().isPresent()) {
1026 SignalServiceDataMessage message
= content
.getDataMessage().get();
1028 if (!message
.isEndSession() &&
1029 !(message
.getGroupInfo().isPresent() &&
1030 message
.getGroupInfo().get().getType() != SignalServiceGroup
.Type
.DELIVER
)) {
1031 List
<String
> attachments
= new ArrayList
<>();
1032 if (message
.getAttachments().isPresent()) {
1033 for (SignalServiceAttachment attachment
: message
.getAttachments().get()) {
1034 if (attachment
.isPointer()) {
1035 attachments
.add(m
.getAttachmentFile(attachment
.asPointer().getId()).getAbsolutePath());
1041 conn
.sendSignal(new Signal
.MessageReceived(
1043 message
.getTimestamp(),
1044 envelope
.getSource(),
1045 message
.getGroupInfo().isPresent() ? message
.getGroupInfo().get().getGroupId() : new byte[0],
1046 message
.getBody().isPresent() ? message
.getBody().get() : "",
1048 } catch (DBusException e
) {
1049 e
.printStackTrace();
1057 private static String
formatTimestamp(long timestamp
) {
1058 Date date
= new Date(timestamp
);
1059 final DateFormat df
= new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'"); // Quoted "Z" to indicate UTC, no timezone offset
1060 df
.setTimeZone(tzUTC
);
1061 return timestamp
+ " (" + df
.format(date
) + ")";