Skip to content
Snippets Groups Projects
Commit df538060 authored by Tumbul, Erwin's avatar Tumbul, Erwin
Browse files

Update BroadcastReceiver to use new protocol definition.

parent 7bdbe960
No related branches found
No related tags found
No related merge requests found
......@@ -7,27 +7,28 @@ import android.util.Log;
import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import io.grpc.notifier.Message;
import io.grpc.notifier.Nothing;
import io.grpc.notifier.NotifierComGrpc;
import io.grpc.notifier.SendMessageRequest;
import io.grpc.notifier.NotifierCommunicationGrpc;
import io.grpc.stub.StreamObserver;
public class NotificationBroadcastReceiver extends BroadcastReceiver {
private ManagedChannel channel;
private final NotifierComGrpc.NotifierComStub asyncStub;
private final NotifierCommunicationGrpc.NotifierCommunicationStub asyncStub;
public NotificationBroadcastReceiver() {
channel = ManagedChannelBuilder.forAddress("192.168.0.127", 8080).usePlaintext().build();
Log.i("NOTIFIER[NotificationBroadcastReceiver]", String.format("ConnectivityState: %s", channel.getState(true).name()));
asyncStub = NotifierComGrpc.newStub(channel);
asyncStub = NotifierCommunicationGrpc.newStub(channel);
}
@Override
public void onReceive(Context context, Intent intent) {
Log.i("NOTIFIER[onReceive]", "Received notification.");
Notification notification = (Notification) intent.getSerializableExtra("Notification");
SendMessageRequest message = SendMessageRequest.newBuilder().setMessage(notification.toString()).build();
Message message = Message.newBuilder().setCommId(1).setContent(notification.toString()).build();
asyncStub.sendMessage(message, new StreamObserver<Nothing>() {
@Override
public void onNext(Nothing value) {
......@@ -46,5 +47,6 @@ public class NotificationBroadcastReceiver extends BroadcastReceiver {
Log.i("NOTIFIER[onReceive]", "Completed sendMessage.");
}
});
}
}
......@@ -23,11 +23,10 @@ class NotifierService(NotifierCommunicationServicer):
# TODO: read comm_id and wait for messages
yield Message(comm_id=-1, content="test")
def SendMessage(self, request_iterator, context):
for msg in request_iterator:
def SendMessage(self, request, context):
# TODO: read comm_id and route message
print(msg.comm_id)
print(msg.content)
print(request.comm_id)
print(request.content)
return Nothing()
......
......@@ -10,7 +10,7 @@ package netcode;
service NotifierCommunication {
rpc Open (OpenRequest) returns (CommResponse);
rpc Answer (AnswerRequest) returns (CommResponse);
rpc SendMessage (stream Message) returns (Nothing);
rpc SendMessage (Message) returns (Nothing);
rpc ReceiveMessage (ReceiveRequest) returns (stream Message);
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment