-
Notifications
You must be signed in to change notification settings - Fork 1.2k
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 #1773 from Apres2707/atom_support
add atom support
- Loading branch information
Showing
7 changed files
with
437 additions
and
4 deletions.
There are no files selected for viewing
181 changes: 181 additions & 0 deletions
181
app/src/main/java/com/eveningoutpost/dexdrip/Models/Atom.java
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,181 @@ | ||
| package com.eveningoutpost.dexdrip.Models; | ||
|
|
||
| import com.eveningoutpost.dexdrip.ImportedLibraries.usbserial.util.HexDump; | ||
| import com.eveningoutpost.dexdrip.Models.UserError.Log; | ||
| import com.eveningoutpost.dexdrip.NFCReaderX; | ||
| import com.eveningoutpost.dexdrip.R; | ||
| import com.eveningoutpost.dexdrip.UtilityModels.BridgeResponse; | ||
| import com.eveningoutpost.dexdrip.UtilityModels.Constants; | ||
| import com.eveningoutpost.dexdrip.UtilityModels.LibreUtils; | ||
| import com.eveningoutpost.dexdrip.UtilityModels.PersistentStore; | ||
| import com.eveningoutpost.dexdrip.UtilityModels.Pref; | ||
|
|
||
| import java.nio.ByteBuffer; | ||
| import java.text.SimpleDateFormat; | ||
| import java.util.ArrayList; | ||
| import java.util.Arrays; | ||
|
|
||
| import static com.eveningoutpost.dexdrip.xdrip.gs; | ||
|
|
||
| /** | ||
| * | ||
| */ | ||
|
|
||
| public class Atom { | ||
| private static final String TAG = "Atom";//?????"Atom"; | ||
|
|
||
| private static volatile byte[] s_full_data = null; | ||
| private static volatile int s_acumulatedSize = 0; | ||
|
|
||
| public static boolean isAtom() { | ||
| final ActiveBluetoothDevice activeBluetoothDevice = ActiveBluetoothDevice.first(); | ||
| if (activeBluetoothDevice == null || activeBluetoothDevice.name == null) { | ||
| return false; | ||
| } | ||
| return activeBluetoothDevice.name.contentEquals("Atom"); | ||
| } | ||
|
|
||
|
|
||
| public static BridgeResponse getAtomResponse() { | ||
| final BridgeResponse reply = new BridgeResponse(); | ||
| ByteBuffer ackMessage = ByteBuffer.allocate(6); | ||
| ackMessage.put(0, (byte) 0x02); | ||
| ackMessage.put(1, (byte) 0x01); | ||
| ackMessage.put(2, (byte) 0x00); | ||
| ackMessage.put(3, (byte) 0x00); | ||
| ackMessage.put(4, (byte) 0x00); | ||
| ackMessage.put(5, (byte) 0x2B); | ||
| reply.add(ackMessage); | ||
| return reply; | ||
| } | ||
|
|
||
| public static int lens = 344; | ||
| public static int ATOM_FOOTER = 8; | ||
|
|
||
| static int errorCount = 0; | ||
|
|
||
|
|
||
| static byte[] patchUid = null; | ||
| static byte[] patchInfo = null; | ||
|
|
||
| public static BridgeResponse decodeAtomPacket(byte[] buffer, int len) { | ||
| final BridgeResponse reply = new BridgeResponse(); | ||
| int first = 0xff & buffer[0]; | ||
| if (first == 0x80) { | ||
| PersistentStore.setString("Atombattery", Integer.toString(buffer[4])); | ||
| Pref.setInt("bridge_battery", buffer[4]); | ||
| String atomfirmware = buffer[2] + "." + buffer[3]; | ||
| String atomHArdware = buffer[buffer.length-2] + "." + buffer[buffer.length-1]; | ||
| PersistentStore.setString("AtomHArdware", atomHArdware); | ||
| PersistentStore.setString("AtomFirmware", atomfirmware); | ||
| ByteBuffer ackMessage = ByteBuffer.allocate(6); | ||
| ackMessage.put(0, (byte) 0x02); | ||
| ackMessage.put(1, (byte) 0x01); | ||
| ackMessage.put(2, (byte) 0x00); | ||
| ackMessage.put(3, (byte) 0x00); | ||
| ackMessage.put(4, (byte) 0x00); | ||
| ackMessage.put(5, (byte) 0x2B); | ||
| reply.add(ackMessage); | ||
| s_full_data = null; | ||
| return getAtomResponse(); | ||
| } | ||
| if (first == 0xC0) { | ||
| patchUid = Arrays.copyOfRange(buffer, 2, 10); | ||
| String SensorSn = LibreUtils.decodeSerialNumberKey(patchUid); | ||
| PersistentStore.setString("LibreSN", SensorSn); | ||
|
|
||
| if (SensorSanity.checkLibreSensorChangeIfEnabled(SensorSn)) { | ||
| Log.e(TAG, "Problem with Libre Serial Number - not processing"); | ||
| } | ||
|
|
||
| return reply; | ||
| } | ||
| if (first == 0xC1) { | ||
| double fv = JoH.tolerantParseDouble(PersistentStore.getString("AtomFirmware")); | ||
| if (fv < 1.35) { | ||
| patchInfo = Arrays.copyOfRange(buffer, 3, 9); | ||
| } else { | ||
| if (buffer.length >= 11) { | ||
| patchInfo = Arrays.copyOfRange(buffer, 5, 11); | ||
| } | ||
| } | ||
| return reply; | ||
| } | ||
| if (first == 0x82) { | ||
| int expectedSize = lens + ATOM_FOOTER; | ||
| if (s_full_data == null) { | ||
| InitBuffer(expectedSize); | ||
| } | ||
| addData(buffer); | ||
| return reply; | ||
|
|
||
| } | ||
|
|
||
| if (first == 0xBF) { | ||
| Log.e(TAG, "No sensor has been found"); | ||
| reply.setError_message(gs(R.string.no_sensor_found)); | ||
| s_full_data = null; | ||
| errorCount++; | ||
| if (errorCount <= 2) { | ||
| return getAtomResponse(); | ||
| } | ||
| return reply; | ||
| } | ||
|
|
||
|
|
||
| return reply; | ||
| } | ||
|
|
||
|
|
||
| static void addData(byte[] buffer) { | ||
| System.arraycopy(buffer, 4, s_full_data, s_acumulatedSize, buffer.length-4); | ||
| s_acumulatedSize = s_acumulatedSize + buffer.length - 4; | ||
| AreWeDone(); | ||
| } | ||
|
|
||
|
|
||
| static void AreWeDone() { | ||
| if (s_acumulatedSize < lens) { | ||
| return; | ||
| } | ||
| long now = JoH.tsl(); | ||
| String SensorSn = PersistentStore.getString("LibreSN"); | ||
|
|
||
|
|
||
| byte[] data = Arrays.copyOfRange(s_full_data, 0, Constants.LIBRE_1_2_FRAM_SIZE); | ||
|
|
||
| // Set the time of the current reading | ||
| PersistentStore.setLong("libre-reading-timestamp", JoH.tsl()); | ||
|
|
||
| boolean checksum_ok = NFCReaderX.HandleGoodReading(SensorSn, data, now, true, patchUid, patchInfo); | ||
| int expectedSize = lens + ATOM_FOOTER; | ||
| InitBuffer(expectedSize); | ||
| errorCount = 0; | ||
| Log.e(TAG, "We have all the data that we need " + s_acumulatedSize + " checksum_ok = " + checksum_ok + HexDump.dumpHexString(data)); | ||
|
|
||
| } | ||
|
|
||
|
|
||
| static void InitBuffer(int expectedSize) { | ||
| s_full_data = new byte[expectedSize]; | ||
| s_acumulatedSize = 0; | ||
| } | ||
|
|
||
| public static ArrayList<ByteBuffer> initialize() { | ||
| Log.e(TAG, "initialize!"); | ||
| Pref.setInt("bridge_battery", 0); //force battery to no-value before first reading | ||
| return resetAtomState(); | ||
| } | ||
|
|
||
| private static ArrayList<ByteBuffer> resetAtomState() { | ||
| ArrayList<ByteBuffer> ret = new ArrayList<>(); | ||
|
|
||
| // Make Atom send data every 5 minutes | ||
| ByteBuffer ackMessage = ByteBuffer.allocate(3); | ||
| ackMessage.put(0, (byte) 0x00); | ||
| ackMessage.put(1, (byte) 0x01); | ||
| ackMessage.put(2, (byte) 0x05); | ||
| ret.add(ackMessage); | ||
| return ret; | ||
| } | ||
| } |
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
Oops, something went wrong.