1 /* 2 * Copyright (C) 2016 The Android Open Source Project 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * http://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17 package com.android.bluetooth.mapclient; 18 19 import android.util.Log; 20 21 import com.android.bluetooth.ObexServerSockets; 22 23 import java.io.IOException; 24 import java.lang.ref.WeakReference; 25 import java.util.Arrays; 26 27 import javax.obex.HeaderSet; 28 import javax.obex.Operation; 29 import javax.obex.ResponseCodes; 30 import javax.obex.ServerRequestHandler; 31 32 class MnsObexServer extends ServerRequestHandler { 33 34 private final static String TAG = "MnsObexServer"; 35 private boolean VDBG = MapClientService.VDBG; 36 37 private static final byte[] MNS_TARGET = new byte[]{ 38 (byte) 0xbb, 0x58, 0x2b, 0x41, 0x42, 0x0c, 0x11, (byte) 0xdb, (byte) 0xb0, (byte) 0xde, 39 0x08, 0x00, 0x20, 0x0c, (byte) 0x9a, 0x66 40 }; 41 42 private final static String TYPE = "x-bt/MAP-event-report"; 43 44 private final WeakReference<MceStateMachine> mStateMachineReference; 45 private final ObexServerSockets mObexServerSockets; 46 MnsObexServer(MceStateMachine stateMachine, ObexServerSockets socketOriginator)47 public MnsObexServer(MceStateMachine stateMachine, ObexServerSockets socketOriginator) { 48 super(); 49 mStateMachineReference = new WeakReference<>(stateMachine); 50 mObexServerSockets = socketOriginator; 51 } 52 53 @Override onConnect(final HeaderSet request, HeaderSet reply)54 public int onConnect(final HeaderSet request, HeaderSet reply) { 55 if (VDBG) Log.v(TAG, "onConnect"); 56 mObexServerSockets.prepareForNewConnect(); 57 58 try { 59 byte[] uuid = (byte[]) request.getHeader(HeaderSet.TARGET); 60 if (!Arrays.equals(uuid, MNS_TARGET)) { 61 return ResponseCodes.OBEX_HTTP_NOT_ACCEPTABLE; 62 } 63 } catch (IOException e) { 64 // this should never happen since getHeader won't throw exception it 65 // declares to throw 66 return ResponseCodes.OBEX_HTTP_INTERNAL_ERROR; 67 } 68 69 reply.setHeader(HeaderSet.WHO, MNS_TARGET); 70 return ResponseCodes.OBEX_HTTP_OK; 71 } 72 73 @Override onDisconnect(final HeaderSet request, HeaderSet reply)74 public void onDisconnect(final HeaderSet request, HeaderSet reply) { 75 if (VDBG) Log.v(TAG, "onDisconnect"); 76 } 77 78 @Override onGet(final Operation op)79 public int onGet(final Operation op) { 80 if (VDBG) Log.v(TAG, "onGet"); 81 return ResponseCodes.OBEX_HTTP_BAD_REQUEST; 82 } 83 84 @Override onPut(final Operation op)85 public int onPut(final Operation op) { 86 if (VDBG) Log.v(TAG, "onPut"); 87 88 try { 89 HeaderSet headerset; 90 headerset = op.getReceivedHeader(); 91 92 String type = (String) headerset.getHeader(HeaderSet.TYPE); 93 ObexAppParameters oap = ObexAppParameters.fromHeaderSet(headerset); 94 if (!TYPE.equals(type) || !oap.exists(Request.OAP_TAGID_MAS_INSTANCE_ID)) { 95 return ResponseCodes.OBEX_HTTP_BAD_REQUEST; 96 } 97 98 Byte inst = oap.getByte(Request.OAP_TAGID_MAS_INSTANCE_ID); 99 EventReport ev = EventReport.fromStream(op.openDataInputStream()); 100 op.close(); 101 102 MceStateMachine currentStateMachine = mStateMachineReference.get(); 103 if (currentStateMachine != null) { 104 currentStateMachine.receiveEvent(ev); 105 } 106 } catch (IOException e) { 107 Log.e(TAG, "I/O exception when handling PUT request", e); 108 return ResponseCodes.OBEX_HTTP_INTERNAL_ERROR; 109 } 110 return ResponseCodes.OBEX_HTTP_OK; 111 } 112 113 @Override onAbort(final HeaderSet request, HeaderSet reply)114 public int onAbort(final HeaderSet request, HeaderSet reply) { 115 if (VDBG) Log.v(TAG, "onAbort"); 116 return ResponseCodes.OBEX_HTTP_NOT_IMPLEMENTED; 117 } 118 119 @Override onSetPath(final HeaderSet request, HeaderSet reply, final boolean backup, final boolean create)120 public int onSetPath(final HeaderSet request, HeaderSet reply, 121 final boolean backup, final boolean create) { 122 if (VDBG) Log.v(TAG, "onSetPath"); 123 return ResponseCodes.OBEX_HTTP_BAD_REQUEST; 124 } 125 126 @Override onClose()127 public void onClose() { 128 if (VDBG) Log.v(TAG, "onClose"); 129 } 130 } 131