add missing file

app/src/main/java/nodomain/freeyourgadget/gadgetbridge/service/devices/amazfitbip/operations/AmazfitBipFetchLogsOperation.java

@@ -0,0 +1,131 @@
+/*  Copyright (C) 2016-2017 Carsten Pfeiffer
+
+    This file is part of Gadgetbridge.
+
+    Gadgetbridge is free software: you can redistribute it and/or modify
+    it under the terms of the GNU Affero General Public License as published
+    by the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    Gadgetbridge is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU Affero General Public License for more details.
+
+    You should have received a copy of the GNU Affero General Public License
+    along with this program.  If not, see <http://www.gnu.org/licenses/>. */
+package nodomain.freeyourgadget.gadgetbridge.service.devices.amazfitbip.operations;
+
+import android.support.annotation.NonNull;
+import android.support.v4.util.TimeUtils;
+import android.widget.Toast;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.util.Arrays;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.GregorianCalendar;
+import java.util.Locale;
+import java.util.concurrent.TimeUnit;
+
+import nodomain.freeyourgadget.gadgetbridge.devices.amazfitbip.AmazfitBipService;
+import nodomain.freeyourgadget.gadgetbridge.devices.miband.MiBand2Service;
+import nodomain.freeyourgadget.gadgetbridge.service.btle.BLETypeConversions;
+import nodomain.freeyourgadget.gadgetbridge.service.btle.TransactionBuilder;
+import nodomain.freeyourgadget.gadgetbridge.service.btle.actions.WaitAction;
+import nodomain.freeyourgadget.gadgetbridge.service.devices.amazfitbip.AmazfitBipSupport;
+import nodomain.freeyourgadget.gadgetbridge.service.devices.miband2.operations.AbstractFetchOperation;
+import nodomain.freeyourgadget.gadgetbridge.util.FileUtils;
+import nodomain.freeyourgadget.gadgetbridge.util.GB;
+
+public class AmazfitBipFetchLogsOperation extends AbstractFetchOperation {
+    private static final Logger LOG = LoggerFactory.getLogger(AmazfitBipFetchLogsOperation.class);
+
+    private FileOutputStream logOutputStream;
+
+    public AmazfitBipFetchLogsOperation(AmazfitBipSupport support) {
+        super(support);
+    }
+
+    @Override
+    protected void startFetching(TransactionBuilder builder) {
+        File dir;
+        try {
+            dir = FileUtils.getExternalFilesDir();
+        } catch (IOException e) {
+            return;
+        }
+
+        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd-hhmmss", Locale.US);
+        String filename = "amazfitbip_" + dateFormat.format(new Date()) + ".log";
+
+        File outputFile = new File(dir, filename );
+        try {
+            logOutputStream = new FileOutputStream(outputFile);
+        } catch (IOException e) {
+            LOG.warn("could not create file " + outputFile, e);
+            return;
+        }
+
+        GregorianCalendar sinceWhen = BLETypeConversions.createCalendar();
+        sinceWhen.add(Calendar.DAY_OF_MONTH, -10);
+        builder.write(characteristicFetch, BLETypeConversions.join(new byte[]{
+                        MiBand2Service.COMMAND_ACTIVITY_DATA_START_DATE,
+                        AmazfitBipService.COMMAND_ACTIVITY_DATA_TYPE_DEBUGLOGS},
+                getSupport().getTimeBytes(sinceWhen, TimeUnit.MINUTES)));
+        builder.add(new WaitAction(1000)); // TODO: actually wait for the success-reply
+        builder.notify(characteristicActivityData, true);
+        builder.write(characteristicFetch, new byte[]{MiBand2Service.COMMAND_FETCH_DATA});
+    }
+
+    @Override
+    protected String getLastSyncTimeKey() {
+        return null;
+    }
+
+    @Override
+    protected void handleActivityFetchFinish() {
+        LOG.info("Fetching log data has finished");
+        try {
+            logOutputStream.close();
+            logOutputStream = null;
+        } catch (IOException e) {
+            LOG.warn("could not close output stream", e);
+            return;
+        }
+        super.handleActivityFetchFinish();
+    }
+
+    @Override
+    protected void handleActivityNotif(byte[] value) {
+        if (!isOperationRunning()) {
+            LOG.error("ignoring notification because operation is not running. Data length: " + value.length);
+            getSupport().logMessageContent(value);
+            return;
+        }
+
+        if ((byte) (lastPacketCounter + 1) == value[0]) {
+            lastPacketCounter++;
+            bufferActivityData(value);
+        } else {
+            GB.toast("Error fetching activity data, invalid package counter: " + value[0], Toast.LENGTH_LONG, GB.ERROR);
+            handleActivityFetchFinish();
+        }
+    }
+
+    @Override
+    protected void bufferActivityData(@NonNull byte[] value) {
+        try {
+            logOutputStream.write(Arrays.copyOfRange(value, 1, value.length));
+        } catch (IOException e) {
+            LOG.warn("could not write to output stream", e);
+            handleActivityFetchFinish();
+        }
+    }
+}