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
.OutputType
;
8 import org
.asamk
.signal
.commands
.exceptions
.CommandException
;
9 import org
.asamk
.signal
.jsonrpc
.SignalJsonRpcDispatcherHandler
;
10 import org
.asamk
.signal
.manager
.Manager
;
11 import org
.asamk
.signal
.output
.JsonWriter
;
12 import org
.asamk
.signal
.output
.OutputWriter
;
13 import org
.asamk
.signal
.util
.IOUtils
;
14 import org
.slf4j
.Logger
;
15 import org
.slf4j
.LoggerFactory
;
17 import java
.io
.InputStreamReader
;
18 import java
.util
.List
;
19 import java
.util
.function
.Supplier
;
21 public class JsonRpcDispatcherCommand
implements LocalCommand
{
23 private final static Logger logger
= LoggerFactory
.getLogger(JsonRpcDispatcherCommand
.class);
26 public String
getName() {
31 public void attachToSubparser(final Subparser subparser
) {
32 subparser
.help("Take commands from standard input as line-delimited JSON RPC while receiving messages.");
33 subparser
.addArgument("--ignore-attachments")
34 .help("Don’t download attachments of received messages.")
35 .action(Arguments
.storeTrue());
39 public List
<OutputType
> getSupportedOutputTypes() {
40 return List
.of(OutputType
.JSON
);
44 public void handleCommand(
45 final Namespace ns
, final Manager m
, final OutputWriter outputWriter
46 ) throws CommandException
{
47 final boolean ignoreAttachments
= Boolean
.TRUE
.equals(ns
.getBoolean("ignore-attachments"));
48 m
.setIgnoreAttachments(ignoreAttachments
);
50 final var jsonOutputWriter
= (JsonWriter
) outputWriter
;
51 final Supplier
<String
> lineSupplier
= IOUtils
.getLineSupplier(new InputStreamReader(System
.in,
52 IOUtils
.getConsoleCharset()));
54 final var handler
= new SignalJsonRpcDispatcherHandler(jsonOutputWriter
, lineSupplier
, false);
55 handler
.handleConnection(m
);