@@ -0,0 +1,56 @@
+/*  Copyright (C) 2024 José Rebelo

@@ -0,0 +122,4 @@
+    protected TransactionBuilder initializeDevice(TransactionBuilder builder) {
+        builder.add(new SetDeviceStateAction(getDevice(), GBDevice.State.INITIALIZING, getContext()));
+
+        getDevice().setFirmwareVersion("N/A");

@@ -0,0 +126,4 @@
+        getDevice().setFirmwareVersion2("N/A");
+        deviceInfoProfile.requestDeviceInfo(builder);
+
+        builder.add(new SetDeviceStateAction(getDevice(), GBDevice.State.INITIALIZED, getContext()));

@@ -0,0 +129,4 @@
+        builder.add(new SetDeviceStateAction(getDevice(), GBDevice.State.INITIALIZED, getContext()));
+
+        builder.notify(getCharacteristic(ColmiR02Constants.CHARACTERISTIC_SERVICE), true);
+        builder.notify(getCharacteristic(ColmiR02Constants.CHARACTERISTIC_WRITE), true);

@@ -0,0 +255,4 @@
+                case ColmiR02Constants.CMD_GOALS:
+                    ByteBuffer stepsData = ByteBuffer.allocate(4);
+                    stepsData.order(ByteOrder.LITTLE_ENDIAN);
+                    stepsData.put(0, value[2]);

@@ -0,0 +343,4 @@
+                        sampleCal.set(Calendar.HOUR_OF_DAY, value[4] / 4);
+                        sampleCal.set(Calendar.MINUTE, 0);
+                        sampleCal.set(Calendar.SECOND, 0);
+                        ByteBuffer calories = ByteBuffer.allocate(2);

@@ -0,0 +506,4 @@
+        Calendar now = GregorianCalendar.getInstance();
+        byte[] setDateTimePacket = buildPacket(new byte[]{
+                ColmiR02Constants.CMD_SET_DATE_TIME,
+                GB.hexStringToByteArray(String.format("%1$2s", now.get(Calendar.YEAR) % 100).replace(' ', '0'))[0],

@@ -1614,6 +1614,7 @@
     <string name="devicetype_redmi_watch_2_lite">Redmi Watch 2 Lite</string>
     <string name="devicetype_redmi_smart_band_pro">Redmi Smart Band Pro</string>
     <string name="devicetype_redmi_watch_4">Redmi Watch 4</string>
+    <string name="devicetype_colmi_r02">Colmi R02 Smart Ring</string>

@@ -0,0 +188,4 @@
+                    int levelResponse = value[1];
+                    LOG.info("Received battery level response: {}%", levelResponse);
+                    GBDeviceEventBatteryInfo batteryEvent = new GBDeviceEventBatteryInfo();
+                    batteryEvent.state = BatteryState.BATTERY_NORMAL;

@@ -0,0 +136,4 @@
+        // Delay initialization with 2 seconds to give the ring time to settle
+        Handler handler = new Handler(Looper.getMainLooper());
+        handler.postDelayed(() -> {
+            postConnectInitialization();

@@ -0,0 +29,4 @@
+    public static final byte CMD_BATTERY = 0x03;
+    public static final byte CMD_POWER_OFF = 0x08;
+    public static final byte CMD_PREFERENCES = 0x0a;
+    public static final byte CMD_SYNC_HEART_RATE = 0x15;

@@ -0,0 +37,4 @@
+    public static final byte CMD_SYNC_STRESS = 0x37;
+    public static final byte CMD_SYNC_ACTIVITY = 0x43;
+    public static final byte CMD_FIND_DEVICE = 0x50;
+    public static final byte CMD_MANUAL_HEART_RATE = 0x69;

@@ -0,0 +149,4 @@
+        requestSettingsFromRing();
+
+        // Testing packets, these are sent by the official app, but don't seem to be necessary
+//        byte[] unknownRequest1 = buildPacket(new byte[]{0x61});

@@ -0,0 +152,4 @@
+//        byte[] unknownRequest1 = buildPacket(new byte[]{0x61});
+//        LOG.info("Unknown request sent: {}", StringUtils.bytesToHex(unknownRequest1));
+//        sendWrite("unknownRequest1", unknownRequest1);
+//        byte[] unknownRequest2 = buildPacket(new byte[]{0x48});

@@ -0,0 +155,4 @@
+//        byte[] unknownRequest2 = buildPacket(new byte[]{0x48});
+//        LOG.info("Unknown request sent: {}", StringUtils.bytesToHex(unknownRequest2));
+//        sendWrite("unknownRequest2", unknownRequest2);
+//        byte[] unknownRequest3 = buildPacket(new byte[]{0x38, 0x01});

@@ -0,0 +158,4 @@
+//        byte[] unknownRequest3 = buildPacket(new byte[]{0x38, 0x01});
+//        LOG.info("Unknown request sent: {}", StringUtils.bytesToHex(unknownRequest3));
+//        sendWrite("unknownRequest3", unknownRequest3);
+//        byte[] unknownRequest4 = buildPacket(new byte[]{0x0c, 0x01});

@@ -0,0 +161,4 @@
+//        byte[] unknownRequest4 = buildPacket(new byte[]{0x0c, 0x01});
+//        LOG.info("Unknown request sent: {}", StringUtils.bytesToHex(unknownRequest4));
+//        sendWrite("unknownRequest4", unknownRequest4);
+//        byte[] unknownRequest5 = buildPacket(new byte[]{0x0a, 0x01});

@@ -0,0 +548,4 @@
+    public void onSetHeartRateMeasurementInterval(int seconds) {
+        // Round to nearest 5 minutes and limit to 60 minutes due to device constraints
+        long hrIntervalMins = Math.min(Math.round(seconds / 60.0 / 5.0) * 5, 60);
+        byte[] hrIntervalPacket = buildPacket(new byte[]{ColmiR02Constants.CMD_SET_HR_INTERVAL, 0x02, 0x01, (byte) hrIntervalMins});

@@ -0,0 +589,4 @@
+
+    @Override
+    public void onPowerOff() {
+        byte[] poweroffPacket = buildPacket(new byte[]{ColmiR02Constants.CMD_POWER_OFF, 0x01});

@@ -0,0 +106,4 @@
+        } else {
+            // Unpack timestamp and data
+            Calendar sampleCal = Calendar.getInstance();
+            sampleCal.set(Calendar.YEAR, 2000 + Integer.valueOf(String.format("%02x", value[1])));

@@ -0,0 +243,4 @@
+                    }
+                    break;
+                case ColmiR0xConstants.CMD_SET_HR_INTERVAL:
+                    LOG.info("Received HR interval: {} minutes, enabled={}", value[3], value[2] == 0x01);

@@ -85,0 +89,4 @@
+            HeartRateSample sample = (HeartRateSample) result;
+            heartRate = sample.getHeartRate();
+        }
+        if (HeartRateUtils.getInstance().isValidHeartRateValue(heartRate)) {

@@ -0,0 +32,4 @@
+    public static final byte CMD_POWER_OFF = 0x08;
+    public static final byte CMD_PREFERENCES = 0x0a;
+    public static final byte CMD_SYNC_HEART_RATE = 0x15;
+    public static final byte CMD_SET_HR_INTERVAL = 0x16;

@@ -0,0 +34,4 @@
+    public static final byte CMD_SYNC_HEART_RATE = 0x15;
+    public static final byte CMD_SET_HR_INTERVAL = 0x16;
+    public static final byte CMD_GOALS = 0x21;
+    public static final byte CMD_SET_SPO2_ENABLED = 0x2c;

@@ -0,0 +36,4 @@
+    public static final byte CMD_GOALS = 0x21;
+    public static final byte CMD_SET_SPO2_ENABLED = 0x2c;
+    public static final byte CMD_PACKET_SIZE = 0x2f;
+    public static final byte CMD_SET_STRESS_ENABLED = 0x36;

@@ -0,0 +42,4 @@
+    public static final byte CMD_FIND_DEVICE = 0x50;
+    public static final byte CMD_MANUAL_HEART_RATE = 0x69;
+    public static final byte CMD_NOTIFICATION = 0x73;
+    public static final byte CMD_BIG_DATA_V2 = (byte) 0xbc;

@@ -0,0 +61,4 @@
+        QueryBuilder<?> qb;
+
+        qb = session.getColmiActivitySampleDao().queryBuilder();
+        qb.where(ColmiActivitySampleDao.Properties.DeviceId.eq(deviceId)).buildDelete().executeDeleteWithoutDetachingEntities();

@@ -0,0 +102,4 @@
+
+    @Override
+    protected Pattern getSupportedDeviceName() {
+        return Pattern.compile("R0[2-6]_.*");

@@ -0,0 +107,4 @@
+
+    @Override
+    public int getBondingStyle() {
+        return BONDING_STYLE_NONE;

@@ -0,0 +61,4 @@
+        int steps = BLETypeConversions.toUint32(value[2], value[3], value[4], (byte) 0);
+        int calories = BLETypeConversions.toUint32(value[5], value[6], value[7], (byte) 0);
+        int distance = BLETypeConversions.toUint32(value[8], value[9], value[10], (byte) 0);
+        LOG.info("Received requested goals settings: {} steps, {} calories, {}m distance", steps, calories, distance);

@@ -0,0 +65,4 @@
+    }
+
+    public static void liveHeartRate(GBDevice device, Context context, byte[] value) {
+        int hrResponse = value[3] & 0xff;

@@ -0,0 +93,4 @@
+    public static void liveActivity(byte[] value) {
+        int steps = BLETypeConversions.toUint32(value[4], value[3], value[2], (byte) 0);
+        int calories = BLETypeConversions.toUint32(value[7], value[6], value[5], (byte) 0) / 10;
+        int distance = BLETypeConversions.toUint32(value[10], value[9], value[8], (byte) 0);

@@ -0,0 +97,4 @@
+        LOG.info("Received live activity notification: {} steps, {} calories, {}m distance", steps, calories, distance);
+    }
+
+    public static void historicalActivity(GBDevice device, byte[] value) {

@@ -0,0 +143,4 @@
+        }
+    }
+
+    public static void historicalStress(GBDevice device, byte[] value) {

@@ -0,0 +195,4 @@
+        }
+    }
+
+    public static void historicalSpo2(GBDevice device, byte[] value) {

@@ -0,0 +242,4 @@
+        }
+    }
+
+    public static void historicalSleep(GBDevice gbDevice, Context context, byte[] value) {

@@ -0,0 +173,4 @@
+                case ColmiR0xConstants.CMD_SET_DATE_TIME:
+                    LOG.info("Received set date/time response: {}", StringUtils.bytesToHex(value));
+                    break;
+                case ColmiR0xConstants.CMD_BATTERY:

@@ -0,0 +188,4 @@
+                case ColmiR0xConstants.CMD_PREFERENCES:
+                    LOG.info("Received user preferences response: {}", StringUtils.bytesToHex(value));
+                    break;
+                case ColmiR0xConstants.CMD_SYNC_HEART_RATE:

@@ -0,0 +292,4 @@
+                        case ColmiR0xConstants.NOTIFICATION_NEW_STEPS_DATA:
+                            LOG.info("Received notification from ring that new steps data is available to sync");
+                            break;
+                        case ColmiR0xConstants.NOTIFICATION_BATTERY_LEVEL:

@@ -0,0 +308,4 @@
+                            break;
+                    }
+                    break;
+                case ColmiR0xConstants.CMD_BIG_DATA_V2:

@@ -0,0 +441,4 @@
+        // TODO: find out how to send gender and possibly other preferences
+        byte[] userPrefsPacket = buildPacket(new byte[]{
+                ColmiR0xConstants.CMD_PREFERENCES,
+                0x02,

@@ -0,0 +442,4 @@
+        byte[] userPrefsPacket = buildPacket(new byte[]{
+                ColmiR0xConstants.CMD_PREFERENCES,
+                0x02,
+                0x00,

@@ -0,0 +444,4 @@
+                0x02,
+                0x00,
+                (byte) ("metric".equals(measurementSystem) ? 0x00 : 0x01),
+                0x00,

@@ -0,0 +448,4 @@
+                (byte) user.getAge(),
+                (byte) user.getHeightCm(),
+                (byte) user.getWeightKg()
+        });

@@ -0,0 +513,4 @@
+        syncingDay.set(Calendar.HOUR_OF_DAY, 0);
+        syncingDay.set(Calendar.MINUTE, 0);
+        syncingDay.set(Calendar.SECOND, 0);
+        byte[] activityHistoryRequest = buildPacket(new byte[]{ColmiR0xConstants.CMD_SYNC_ACTIVITY, (byte) daysAgo, 0x0f, 0x00, 0x5f, 0x01});

@@ -0,0 +546,4 @@
+
+    private void fetchHistorySpo2() {
+        getDevice().setBusyTask("spo2HistoryRequest");
+        byte[] spo2HistoryRequest = new byte[]{

@@ -0,0 +561,4 @@
+
+    private void fetchHistorySleep() {
+        getDevice().setBusyTask("sleepHistoryRequest");
+        byte[] sleepHistoryRequest = new byte[]{

@@ -0,0 +107,4 @@
+
+    public static void liveHeartRate(GBDevice device, Context context, byte[] value) {
+        int errorCode = value[2];
+        if (errorCode == 1) {

@@ -0,0 +389,4 @@
+        BluetoothGattCharacteristic characteristic = getCharacteristic(ColmiR0xConstants.CHARACTERISTIC_WRITE);
+        if (characteristic != null) {
+            builder.write(characteristic, contents);
+            builder.queue(getQueue());

@@ -127,6 +127,12 @@ public class GBDaoGenerator {
         addWena3StressSample(schema, user, device);
         addFemometerVinca2TemperatureSample(schema, user, device);
         addMiScaleWeightSample(schema, user, device);
+        addColmiActivitySample(schema, user, device);

@@ -0,0 +509,4 @@
+        byte[] userPrefsPacket = buildPacket(new byte[]{
+                ColmiR0xConstants.CMD_PREFERENCES,
+                ColmiR0xConstants.PREF_WRITE,
+                0x00,  // 24h format, 0x01 is 12h format

@@ -0,0 +577,4 @@
+    }
+
+    private void fetchHistoryActivity() {
+        getDevice().setBusyTask("activityHistoryRequest");