[AI] test(ccct-3829): expand null/malformed date coverage in OpportunitiesParserTest

Add cases for null and malformed top-level start_date and end_date, plus
claim end_date and date_claimed. Each test places a valid record before the
invalid one and verifies only the valid record is passed to storeJobs.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: shubham1g5

app/unit-tests/src/org/commcare/connect/network/connect/parser/ConnectOpportunitiesParserTest.kt

@@ -87,6 +87,11 @@ class ConnectOpportunitiesParserTest {
             put("learn_modules", JSONArray())
         }
 
+    private fun claimedJobJson(
+        id: Int,
+        claim: JSONObject,
+    ): JSONObject = validJobJson(id).apply { put("claim", claim) }
+
     private fun jsonArrayOf(vararg objects: JSONObject): ByteArrayInputStream {
         val array = JSONArray().apply { objects.forEach { put(it) } }
         return ByteArrayInputStream(array.toString().toByteArray())
@@ -225,4 +230,111 @@ class ConnectOpportunitiesParserTest {
         }
         verify(exactly = 1) { ConnectJobUtils.storeJobs(any(), match { it.size == 1 && it[0].jobId == 1 }, true) }
     }
+
+    @Test
+    fun `parse stores valid job and skips job with malformed end_date`() {
+        val malformedJob = validJobJson(10).apply { put("end_date", "not-a-date") }
+        val inputStream = jsonArrayOf(validJobJson(1), malformedJob)
+        every { ConnectJobUtils.storeJobs(any(), any(), any()) } returns 1
+        every { ConnectReleaseTogglesWorker.scheduleOneTimeFetch(any()) } just Runs
+
+        assertThrows(JSONException::class.java) {
+            parser.parse(200, inputStream, null)
+        }
+        verify(exactly = 1) { ConnectJobUtils.storeJobs(any(), match { it.size == 1 && it[0].jobId == 1 }, true) }
+    }
+
+    @Test
+    fun `parse stores valid job and skips job with null start_date`() {
+        val nullStartJob = validJobJson(10).apply { put("start_date", JSONObject.NULL) }
+        val inputStream = jsonArrayOf(validJobJson(1), nullStartJob)
+        every { ConnectJobUtils.storeJobs(any(), any(), any()) } returns 1
+        every { ConnectReleaseTogglesWorker.scheduleOneTimeFetch(any()) } just Runs
+
+        assertThrows(JSONException::class.java) {
+            parser.parse(200, inputStream, null)
+        }
+        verify(exactly = 1) { ConnectJobUtils.storeJobs(any(), match { it.size == 1 && it[0].jobId == 1 }, true) }
+    }
+
+    @Test
+    fun `parse stores valid job and skips job with malformed start_date`() {
+        val malformedJob = validJobJson(10).apply { put("start_date", "not-a-date") }
+        val inputStream = jsonArrayOf(validJobJson(1), malformedJob)
+        every { ConnectJobUtils.storeJobs(any(), any(), any()) } returns 1
+        every { ConnectReleaseTogglesWorker.scheduleOneTimeFetch(any()) } just Runs
+
+        assertThrows(JSONException::class.java) {
+            parser.parse(200, inputStream, null)
+        }
+        verify(exactly = 1) { ConnectJobUtils.storeJobs(any(), match { it.size == 1 && it[0].jobId == 1 }, true) }
+    }
+
+    @Test
+    fun `parse stores valid job and skips claimed job with null claim end_date`() {
+        val claim =
+            JSONObject().apply {
+                put("end_date", JSONObject.NULL)
+                put("date_claimed", "2025-01-15")
+            }
+        val inputStream = jsonArrayOf(validJobJson(1), claimedJobJson(10, claim))
+        every { ConnectJobUtils.storeJobs(any(), any(), any()) } returns 1
+        every { ConnectReleaseTogglesWorker.scheduleOneTimeFetch(any()) } just Runs
+
+        assertThrows(JSONException::class.java) {
+            parser.parse(200, inputStream, null)
+        }
+        verify(exactly = 1) { ConnectJobUtils.storeJobs(any(), match { it.size == 1 && it[0].jobId == 1 }, true) }
+    }
+
+    @Test
+    fun `parse stores valid job and skips claimed job with malformed claim end_date`() {
+        val claim =
+            JSONObject().apply {
+                put("end_date", "not-a-date")
+                put("date_claimed", "2025-01-15")
+            }
+        val inputStream = jsonArrayOf(validJobJson(1), claimedJobJson(10, claim))
+        every { ConnectJobUtils.storeJobs(any(), any(), any()) } returns 1
+        every { ConnectReleaseTogglesWorker.scheduleOneTimeFetch(any()) } just Runs
+
+        assertThrows(JSONException::class.java) {
+            parser.parse(200, inputStream, null)
+        }
+        verify(exactly = 1) { ConnectJobUtils.storeJobs(any(), match { it.size == 1 && it[0].jobId == 1 }, true) }
+    }
+
+    @Test
+    fun `parse stores valid job and skips claimed job with null date_claimed`() {
+        val claim =
+            JSONObject().apply {
+                put("end_date", "2025-12-31")
+                put("date_claimed", JSONObject.NULL)
+            }
+        val inputStream = jsonArrayOf(validJobJson(1), claimedJobJson(10, claim))
+        every { ConnectJobUtils.storeJobs(any(), any(), any()) } returns 1
+        every { ConnectReleaseTogglesWorker.scheduleOneTimeFetch(any()) } just Runs
+
+        assertThrows(JSONException::class.java) {
+            parser.parse(200, inputStream, null)
+        }
+        verify(exactly = 1) { ConnectJobUtils.storeJobs(any(), match { it.size == 1 && it[0].jobId == 1 }, true) }
+    }
+
+    @Test
+    fun `parse stores valid job and skips claimed job with malformed date_claimed`() {
+        val claim =
+            JSONObject().apply {
+                put("end_date", "2025-12-31")
+                put("date_claimed", "not-a-date")
+            }
+        val inputStream = jsonArrayOf(validJobJson(1), claimedJobJson(10, claim))
+        every { ConnectJobUtils.storeJobs(any(), any(), any()) } returns 1
+        every { ConnectReleaseTogglesWorker.scheduleOneTimeFetch(any()) } just Runs
+
+        assertThrows(JSONException::class.java) {
+            parser.parse(200, inputStream, null)
+        }
+        verify(exactly = 1) { ConnectJobUtils.storeJobs(any(), match { it.size == 1 && it[0].jobId == 1 }, true) }
+    }
 }