- private static String readAll(InputStream in) throws IOException {
- StringWriter output = new StringWriter();
- byte[] buffer = new byte[4096];
- long count = 0;
- int n;
- while (-1 != (n = System.in.read(buffer))) {
- output.write(new String(buffer, 0, n, Charset.defaultCharset()));
- count += n;
- }
- return output.toString();
- }
-
- private static class ReceiveMessageHandler implements Manager.ReceiveMessageHandler {
- final Manager m;
-
- public ReceiveMessageHandler(Manager m) {
- this.m = m;
- }
-
- @Override
- public void handleMessage(SignalServiceEnvelope envelope, SignalServiceContent content) {
- SignalServiceAddress source = envelope.getSourceAddress();
- ContactInfo sourceContact = m.getContact(source.getNumber());
- System.out.println(String.format("Envelope from: %s (device: %d)", (sourceContact == null ? "" : "“" + sourceContact.name + "” ") + source.getNumber(), envelope.getSourceDevice()));
- if (source.getRelay().isPresent()) {
- System.out.println("Relayed by: " + source.getRelay().get());
- }
- System.out.println("Timestamp: " + envelope.getTimestamp());
-
- if (envelope.isReceipt()) {
- System.out.println("Got receipt.");
- } else if (envelope.isSignalMessage() | envelope.isPreKeySignalMessage()) {
- if (content == null) {
- System.out.println("Failed to decrypt message.");
- } else {
- if (content.getDataMessage().isPresent()) {
- SignalServiceDataMessage message = content.getDataMessage().get();
- handleSignalServiceDataMessage(message);
- }
- if (content.getSyncMessage().isPresent()) {
- System.out.println("Received a sync message");
- SignalServiceSyncMessage syncMessage = content.getSyncMessage().get();
-
- if (syncMessage.getContacts().isPresent()) {
- System.out.println("Received sync contacts");
- printAttachment(syncMessage.getContacts().get());
- }
- if (syncMessage.getGroups().isPresent()) {
- System.out.println("Received sync groups");
- printAttachment(syncMessage.getGroups().get());
- }
- if (syncMessage.getRead().isPresent()) {
- System.out.println("Received sync read messages list");
- for (ReadMessage rm : syncMessage.getRead().get()) {
- ContactInfo fromContact = m.getContact(rm.getSender());
- System.out.println("From: " + (fromContact == null ? "" : "“" + fromContact.name + "” ") + rm.getSender() + " Message timestamp: " + rm.getTimestamp());
- }
- }
- if (syncMessage.getRequest().isPresent()) {
- System.out.println("Received sync request");
- if (syncMessage.getRequest().get().isContactsRequest()) {
- System.out.println(" - contacts request");
- }
- if (syncMessage.getRequest().get().isGroupsRequest()) {
- System.out.println(" - groups request");
- }
- }
- if (syncMessage.getSent().isPresent()) {
- System.out.println("Received sync sent message");
- final SentTranscriptMessage sentTranscriptMessage = syncMessage.getSent().get();
- String to;
- if (sentTranscriptMessage.getDestination().isPresent()) {
- String dest = sentTranscriptMessage.getDestination().get();
- ContactInfo destContact = m.getContact(dest);
- to = (destContact == null ? "" : "“" + destContact.name + "” ") + dest;
- } else {
- to = "Unknown";
- }
- System.out.println("To: " + to + " , Message timestamp: " + sentTranscriptMessage.getTimestamp());
- SignalServiceDataMessage message = sentTranscriptMessage.getMessage();
- handleSignalServiceDataMessage(message);
- }
- }
- }
- } else {
- System.out.println("Unknown message received.");
- }
- System.out.println();
- }
-
- private void handleSignalServiceDataMessage(SignalServiceDataMessage message) {
- System.out.println("Message timestamp: " + message.getTimestamp());
-
- if (message.getBody().isPresent()) {
- System.out.println("Body: " + message.getBody().get());
- }
- if (message.getGroupInfo().isPresent()) {
- SignalServiceGroup groupInfo = message.getGroupInfo().get();
- System.out.println("Group info:");
- System.out.println(" Id: " + Base64.encodeBytes(groupInfo.getGroupId()));
- if (groupInfo.getType() == SignalServiceGroup.Type.UPDATE && groupInfo.getName().isPresent()) {
- System.out.println(" Name: " + groupInfo.getName().get());
- } else {
- GroupInfo group = m.getGroup(groupInfo.getGroupId());
- if (group != null) {
- System.out.println(" Name: " + group.name);
- } else {
- System.out.println(" Name: <Unknown group>");
- }
- }
- System.out.println(" Type: " + groupInfo.getType());
- if (groupInfo.getMembers().isPresent()) {
- for (String member : groupInfo.getMembers().get()) {
- System.out.println(" Member: " + member);
- }
- }
- if (groupInfo.getAvatar().isPresent()) {
- System.out.println(" Avatar:");
- printAttachment(groupInfo.getAvatar().get());
- }
- }
- if (message.isEndSession()) {
- System.out.println("Is end session");
git.nmode.ca / signal-cli / blobdiff
