From ac8aa17a8029d36aa78379faf5e65e9a774c9b7f Mon Sep 17 00:00:00 2001
From: Doug Hoffman <doug+github@hoff.mn>
Date: Sun, 24 Apr 2022 05:15:34 -0400
Subject: [PATCH] Check in with Broadcastify Calls to stay online while
 otherwise idle (#1214)

---
 .../BroadcastifyCallBroadcaster.java          | 20 +++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/src/main/java/io/github/dsheirer/audio/broadcast/broadcastify/BroadcastifyCallBroadcaster.java b/src/main/java/io/github/dsheirer/audio/broadcast/broadcastify/BroadcastifyCallBroadcaster.java
index 324e9c33..067725b5 100644
--- a/src/main/java/io/github/dsheirer/audio/broadcast/broadcastify/BroadcastifyCallBroadcaster.java
+++ b/src/main/java/io/github/dsheirer/audio/broadcast/broadcastify/BroadcastifyCallBroadcaster.java
@@ -68,6 +68,8 @@ public class BroadcastifyCallBroadcaster extends AbstractAudioBroadcaster<Broadc
     private static final String MULTIPART_TYPE = "multipart";
     private static final String DEFAULT_SUBTYPE = "form-data";
     private static final String MULTIPART_FORM_DATA = MULTIPART_TYPE + "/" + DEFAULT_SUBTYPE;
+    private static final long BROADCASTIFY_TEST_INTERVAL = 15l; // minutes
+    private ScheduledFuture<?> mBroadcastifyTestFuture;
     private Queue<AudioRecording> mAudioRecordingQueue = new LinkedTransferQueue<>();
     private ScheduledFuture<?> mAudioRecordingProcessorFuture;
     private HttpClient mHttpClient = HttpClient.newBuilder()
@@ -102,6 +104,9 @@ public class BroadcastifyCallBroadcaster extends AbstractAudioBroadcaster<Broadc
         if(response != null && response.toLowerCase().startsWith("ok"))
         {
             setBroadcastState(BroadcastState.CONNECTED);
+
+            // Test periodically so we don't get marked offline due to radio inactivity
+            mBroadcastifyTestFuture = ThreadPool.SCHEDULED.scheduleAtFixedRate(new BroadcastifyCallTest(), BROADCASTIFY_TEST_INTERVAL, BROADCASTIFY_TEST_INTERVAL, TimeUnit.MINUTES);
         }
         else
         {
@@ -124,6 +129,8 @@ public class BroadcastifyCallBroadcaster extends AbstractAudioBroadcaster<Broadc
     {
         if(mAudioRecordingProcessorFuture != null)
         {
+            mBroadcastifyTestFuture.cancel(true);
+            mBroadcastifyTestFuture = null;
             mAudioRecordingProcessorFuture.cancel(true);
             mAudioRecordingProcessorFuture = null;
             dispose();
@@ -131,6 +138,19 @@ public class BroadcastifyCallBroadcaster extends AbstractAudioBroadcaster<Broadc
         }
     }
 
+    public class BroadcastifyCallTest implements Runnable
+    {
+        @Override
+        public void run()
+        {
+            String response = testConnection(getBroadcastConfiguration());
+            if(response != null && !response.toLowerCase().startsWith("ok"))
+            {
+                mLog.info("Broadcastify Calls test failure");
+            }
+        }
+    }
+
     /**
      * Prepares for disposal
      */