1 /*
2  * Copyright (C) 2011 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.accessorychat;
18 
19 import android.app.Activity;
20 import android.app.PendingIntent;
21 import android.content.BroadcastReceiver;
22 import android.content.Context;
23 import android.content.Intent;
24 import android.content.IntentFilter;
25 import android.os.Bundle;
26 import android.os.Handler;
27 import android.os.Message;
28 import android.os.ParcelFileDescriptor;
29 import android.view.KeyEvent;
30 import android.view.View;
31 import android.view.inputmethod.EditorInfo;
32 import android.util.Log;
33 import android.widget.EditText;
34 import android.widget.TextView;
35 
36 import android.hardware.usb.UsbManager;
37 import android.hardware.usb.UsbAccessory;
38 
39 import java.io.FileDescriptor;
40 import java.io.FileInputStream;
41 import java.io.FileOutputStream;
42 import java.io.IOException;
43 
44 public class AccessoryChat extends Activity implements Runnable, TextView.OnEditorActionListener {
45 
46     private static final String TAG = "AccessoryChat";
47 
48     private static final String ACTION_USB_PERMISSION =
49             "com.android.accessorychat.action.USB_PERMISSION";
50 
51     private TextView mLog;
52     private EditText mEditText;
53     private ParcelFileDescriptor mFileDescriptor;
54     private FileInputStream mInputStream;
55     private FileOutputStream mOutputStream;
56     private UsbManager mUsbManager;
57     private PendingIntent mPermissionIntent;
58     private boolean mPermissionRequestPending;
59 
60     private static final int MESSAGE_LOG = 1;
61 
62    private final BroadcastReceiver mUsbReceiver = new BroadcastReceiver() {
63         @Override
64         public void onReceive(Context context, Intent intent) {
65             if (ACTION_USB_PERMISSION.equals(intent.getAction())) {
66                 synchronized (this) {
67                     UsbAccessory accessory = (UsbAccessory) intent.getParcelableExtra(UsbManager.EXTRA_ACCESSORY);
68                     if (intent.getBooleanExtra(UsbManager.EXTRA_PERMISSION_GRANTED, false)) {
69                         if (accessory != null) {
70                             openAccessory(accessory);
71                         }
72                     } else {
73                         Log.d(TAG, "permission denied for accessory " + accessory);
74                     }
75                     mPermissionRequestPending = false;
76                 }
77             }
78         }
79     };
80 
81     @Override
onCreate(Bundle savedInstanceState)82     public void onCreate(Bundle savedInstanceState) {
83         super.onCreate(savedInstanceState);
84 
85         mUsbManager = (UsbManager) getSystemService(Context.USB_SERVICE);
86         mPermissionIntent = PendingIntent.getBroadcast(this, 0,
87                 new Intent(ACTION_USB_PERMISSION).setPackage(this.getPackageName()),
88                 PendingIntent.FLAG_MUTABLE);
89         IntentFilter filter = new IntentFilter(ACTION_USB_PERMISSION);
90         registerReceiver(mUsbReceiver, filter);
91 
92         setContentView(R.layout.accessory_chat);
93         mLog = (TextView)findViewById(R.id.log);
94         mEditText = (EditText)findViewById(R.id.message);
95         mEditText.setOnEditorActionListener(this);
96     }
97 
98     @Override
onResume()99     public void onResume() {
100         super.onResume();
101 
102         Intent intent = getIntent();
103         Log.d(TAG, "intent: " + intent);
104         UsbAccessory[] accessories = mUsbManager.getAccessoryList();
105         UsbAccessory accessory = (accessories == null ? null : accessories[0]);
106         if (accessory != null) {
107             if (mUsbManager.hasPermission(accessory)) {
108                 openAccessory(accessory);
109             } else {
110                 synchronized (mUsbReceiver) {
111                     if (!mPermissionRequestPending) {
112                         mUsbManager.requestPermission(accessory, mPermissionIntent);
113                         mPermissionRequestPending = true;
114                     }
115                 }
116             }
117          } else {
118             Log.d(TAG, "mAccessory is null");
119         }
120     }
121 
122     @Override
onPause()123     public void onPause() {
124         super.onPause();
125         if (mFileDescriptor != null) {
126             try {
127                 mFileDescriptor.close();
128             } catch (IOException e) {
129             } finally {
130                 mFileDescriptor = null;
131             }
132         }
133     }
134 
135     @Override
onDestroy()136     public void onDestroy() {
137         unregisterReceiver(mUsbReceiver);
138        super.onDestroy();
139     }
140 
openAccessory(UsbAccessory accessory)141     private void openAccessory(UsbAccessory accessory) {
142         Log.d(TAG, "openAccessory: " + accessory);
143         mFileDescriptor = mUsbManager.openAccessory(accessory);
144         if (mFileDescriptor != null) {
145             FileDescriptor fd = mFileDescriptor.getFileDescriptor();
146             mInputStream = new FileInputStream(fd);
147             mOutputStream = new FileOutputStream(fd);
148             Thread thread = new Thread(null, this, "AccessoryChat");
149             thread.start();
150             Log.d(TAG, "openAccessory succeeded");
151         } else {
152             Log.d(TAG, "openAccessory fail");
153         }
154     }
155 
onEditorAction(TextView v, int actionId, KeyEvent event)156     public boolean onEditorAction(TextView v, int actionId, KeyEvent event) {
157         if (actionId == EditorInfo.IME_ACTION_DONE && mOutputStream != null) {
158             try {
159                 mOutputStream.write(v.getText().toString().getBytes());
160             } catch (IOException e) {
161                 Log.e(TAG, "write failed", e);
162             }
163             v.setText("");
164             return true;
165         }
166         Log.d(TAG, "onEditorAction " + actionId + " event: " + event);
167         return false;
168     }
169 
run()170     public void run() {
171         int ret = 0;
172         byte[] buffer = new byte[16384];
173         while (ret >= 0) {
174             try {
175                 ret = mInputStream.read(buffer);
176             } catch (IOException e) {
177                 break;
178             }
179 
180             if (ret > 0) {
181                 Message m = Message.obtain(mHandler, MESSAGE_LOG);
182                 String text = new String(buffer, 0, ret);
183                 Log.d(TAG, "chat: " + text);
184                 m.obj = text;
185                 mHandler.sendMessage(m);
186             }
187         }
188         Log.d(TAG, "thread out");
189     }
190 
191    Handler mHandler = new Handler() {
192         @Override
193         public void handleMessage(Message msg) {
194             switch (msg.what) {
195                 case MESSAGE_LOG:
196                     mLog.setText(mLog.getText() + "\n" + (String)msg.obj);
197                     break;
198              }
199         }
200     };
201 }
202 
203 
204