-
Notifications
You must be signed in to change notification settings - Fork 422
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #294 from bndeff/usbapi
Add a USB API compatible with libusb
- Loading branch information
Showing
4 changed files
with
195 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,165 @@ | ||
| package com.termux.api; | ||
|
|
||
| import android.app.PendingIntent; | ||
| import android.content.BroadcastReceiver; | ||
| import android.content.Context; | ||
| import android.content.Intent; | ||
| import android.content.IntentFilter; | ||
| import android.hardware.usb.UsbDevice; | ||
| import android.hardware.usb.UsbDeviceConnection; | ||
| import android.hardware.usb.UsbManager; | ||
| import android.os.Looper; | ||
| import android.util.JsonWriter; | ||
| import android.util.SparseArray; | ||
|
|
||
| import com.termux.api.util.ResultReturner; | ||
|
|
||
| import java.io.IOException; | ||
| import java.io.PrintWriter; | ||
| import java.util.Iterator; | ||
| import java.util.HashMap; | ||
|
|
||
| import androidx.annotation.NonNull; | ||
|
|
||
| public class UsbAPI { | ||
|
|
||
| private static SparseArray<UsbDeviceConnection> openDevices = new SparseArray<>(); | ||
|
|
||
| static void onReceive(final TermuxApiReceiver apiReceiver, final Context context, final Intent intent) { | ||
| UsbDevice device; | ||
| String action = intent.getAction(); | ||
| if (action == null) { | ||
| ResultReturner.returnData(apiReceiver, intent, out -> out.append("Missing action\n")); | ||
| } else { | ||
| switch (action) { | ||
| case "list": | ||
| ResultReturner.returnData(apiReceiver, intent, new ResultReturner.ResultJsonWriter() { | ||
| @Override | ||
| public void writeJson(JsonWriter out) throws Exception { | ||
| listDevices(context, out); | ||
| } | ||
| }); | ||
| break; | ||
| case "permission": | ||
| device = getDevice(apiReceiver, context, intent); | ||
| if (device == null) return; | ||
| ResultReturner.returnData(apiReceiver, intent, out -> { | ||
| boolean result = getPermission(device, context, intent); | ||
| out.append(result ? "yes\n" : "no\n"); | ||
| }); | ||
| break; | ||
| case "open": | ||
| device = getDevice(apiReceiver, context, intent); | ||
| if (device == null) return; | ||
| ResultReturner.returnData(apiReceiver, intent, new ResultReturner.WithAncillaryFd() { | ||
| @Override | ||
| public void writeResult(PrintWriter out) { | ||
| if (getPermission(device, context, intent)) { | ||
| int result = open(device, context); | ||
| if (result < 0) { | ||
| out.append("Failed to open device\n"); | ||
| } else { | ||
| this.setFd(result); | ||
| out.append("@"); // has to be non-empty | ||
| } | ||
| } else out.append("No permission\n"); | ||
| } | ||
| }); | ||
|
|
||
| break; | ||
| default: | ||
| ResultReturner.returnData(apiReceiver, intent, out -> out.append("Invalid action\n")); | ||
| } | ||
| } | ||
|
|
||
| } | ||
|
|
||
| private static void listDevices(final Context context, JsonWriter out) throws IOException { | ||
| final UsbManager usbManager = (UsbManager) context.getSystemService(Context.USB_SERVICE); | ||
| HashMap<String, UsbDevice> deviceList = usbManager.getDeviceList(); | ||
| Iterator<String> deviceIterator = deviceList.keySet().iterator(); | ||
| out.beginArray(); | ||
| while (deviceIterator.hasNext()) { | ||
| out.value(deviceIterator.next()); | ||
| } | ||
| out.endArray(); | ||
| } | ||
|
|
||
| private static UsbDevice getDevice(final TermuxApiReceiver apiReceiver, final Context context, final Intent intent) { | ||
| String deviceName = intent.getStringExtra("device"); | ||
| final UsbManager usbManager = (UsbManager) context.getSystemService(Context.USB_SERVICE); | ||
| HashMap<String, UsbDevice> deviceList = usbManager.getDeviceList(); | ||
| UsbDevice device = deviceList.get(deviceName); | ||
| if (device == null) { | ||
| ResultReturner.returnData(apiReceiver, intent, out -> out.append("No such device\n")); | ||
| } | ||
| return device; | ||
| } | ||
|
|
||
| private static boolean hasPermission(final @NonNull UsbDevice device, final Context context) { | ||
| final UsbManager usbManager = (UsbManager) context.getSystemService(Context.USB_SERVICE); | ||
| return usbManager.hasPermission(device); | ||
| } | ||
|
|
||
| private static boolean requestPermission(final @NonNull UsbDevice device, final Context context) { | ||
| Looper.prepare(); | ||
| Looper looper = Looper.myLooper(); | ||
| final boolean[] result = new boolean[1]; | ||
|
|
||
| final String ACTION_USB_PERMISSION = "com.termux.api.USB_PERMISSION"; | ||
| final BroadcastReceiver usbReceiver = new BroadcastReceiver() { | ||
| @Override | ||
| public void onReceive(final Context usbContext, final Intent usbIntent) { | ||
| String action = usbIntent.getAction(); | ||
| if (ACTION_USB_PERMISSION.equals(action)) { | ||
| synchronized (this) { | ||
| UsbDevice device = usbIntent.getParcelableExtra(UsbManager.EXTRA_DEVICE); | ||
| if (usbIntent.getBooleanExtra(UsbManager.EXTRA_PERMISSION_GRANTED, false)) { | ||
| if (device != null) { | ||
| result[0] = true; | ||
| if (looper != null) looper.quit(); | ||
| } | ||
| } else { | ||
| result[0] = false; | ||
| if (looper != null) looper.quit(); | ||
| } | ||
| } | ||
|
|
||
| } | ||
| } | ||
| }; | ||
|
|
||
| final UsbManager usbManager = (UsbManager) context.getSystemService(Context.USB_SERVICE); | ||
| PendingIntent permissionIntent = PendingIntent.getBroadcast(context, 0, | ||
| new Intent(ACTION_USB_PERMISSION), 0); | ||
| IntentFilter filter = new IntentFilter(ACTION_USB_PERMISSION); | ||
| context.getApplicationContext().registerReceiver(usbReceiver, filter); | ||
| usbManager.requestPermission(device, permissionIntent); | ||
| Looper.loop(); | ||
| return result[0]; | ||
| } | ||
|
|
||
| private static boolean getPermission(final @NonNull UsbDevice device, final Context context, final Intent intent) { | ||
| boolean request = intent.getBooleanExtra("request", false); | ||
| if(request) { | ||
| return requestPermission(device, context); | ||
| } else { | ||
| return hasPermission(device, context); | ||
| } | ||
| } | ||
|
|
||
| private static int open(final @NonNull UsbDevice device, final Context context) { | ||
| final UsbManager usbManager = (UsbManager) context.getSystemService(Context.USB_SERVICE); | ||
| UsbDeviceConnection connection = usbManager.openDevice(device); | ||
| if (connection == null) | ||
| return -2; | ||
| int fd = connection.getFileDescriptor(); | ||
| if (fd == -1) { | ||
| connection.close(); | ||
| return -1; | ||
| } | ||
| openDevices.put(fd, connection); | ||
| return fd; | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters