webmaster/signal-cli
1
0
Fork 0
mirror of https://github.com/AsamK/signal-cli synced 2025-09-02 12:30:39 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

added file

Browse source
This commit is contained in:
Carl Bingel 2020-02-09 18:27:44 +01:00
parent a3365651d1
commit b94e837a95
1 changed files with 61 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

61
src/main/java/org/asamk/signal/JsonEvtLoopReceiveMessageHandler.java Normal file
View file

@ -0,0 +1,61 @@
package org.asamk.signal;
/*
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import com.fasterxml.jackson.databind.node.ObjectNode;
*/
//import org.asamk.signal.*;
import org.asamk.signal.commands.*;
import org.asamk.signal.manager.Manager;
import org.whispersystems.signalservice.api.messages.SignalServiceContent;
import org.whispersystems.signalservice.api.messages.SignalServiceEnvelope;
//import java.io.IOException;
public class JsonEvtLoopReceiveMessageHandler implements Manager.ReceiveMessageHandler {
public interface ResponseEmitter {
public void emit( JsonEvtLoopStatusReport resp);
}
final Manager m;
ResponseEmitter responseEmitter;
public JsonEvtLoopReceiveMessageHandler(Manager m) {
this.m = m;
}
public JsonEvtLoopReceiveMessageHandler( Manager m, ResponseEmitter responseEmitter) {
this.m = m;
this.responseEmitter = responseEmitter;
}
@Override
public void handleMessage(SignalServiceEnvelope envelope, SignalServiceContent content, Throwable exception) {
//ObjectNode result = jsonProcessor.createObjectNode();
JsonEvtLoopStatusReport resp = null;
if (exception != null) {
resp = new JsonEvtLoopStatusReport( "error", null, "error", "JsonEvtLoopReceiveMessageHandler::handleMessage: Exception: " + exception.toString());
//result.putPOJO("error", new JsonError(exception));
}
if (envelope != null) {
//result.putPOJO("envelope", new JsonMessageEnvelope(envelope, content));
resp = new JsonEvtLoopStatusReport( new JsonMessageEnvelope(envelope, content));
}
if(resp == null) {
new JsonEvtLoopStatusReport( "error", null, "JsonEvtLoopReceiveMessageHandler::handleMessage: both exceptino and envelope is null!").emit();
} else {
if( this.responseEmitter != null) {
this.responseEmitter.emit( resp);
} else {
resp.emit();
}
}
}
}