Do not notify about a GFI that has already been notified

bootstrap/src/test/java/onlydust/com/marketplace/api/it/api/feature/GoodFirstIssueCreatedNotifierJobIT.java

@@ -132,5 +132,11 @@ void should_notify_users_on_new_good_first_issues() throws InterruptedException
                         .withRequestBody(matchingJsonPath("$.subject", equalTo("New good first issue"))));
 
         customerIOWireMockServer.verify(2, postRequestedFor(urlEqualTo("/send/email")));
+        customerIOWireMockServer.resetAll();
+
+        // Check that notification for a single issue is sent only once
+        goodFirstIssueCreatedNotifierJob.run();
+        Thread.sleep(1000L);
+        customerIOWireMockServer.verify(0, postRequestedFor(urlEqualTo("/send/email")));
     }
 }

infrastructure/postgres-adapter/src/main/java/onlydust/com/marketplace/api/postgres/adapter/repository/GithubIssueViewRepository.java

@@ -31,6 +31,8 @@ public interface GithubIssueViewRepository extends Repository<GithubIssueViewEnt
               and gi.status = 'OPEN'
               and gia.user_id is null
               and NOT exists(SELECT 1 FROM hackathon_issues hi WHERE hi.issue_id = gi.id)
+              and NOT exists(SELECT 1 FROM iam.notifications n WHERE n.data->'notification'->>'@type' = 'GoodFirstIssueCreated'
+                                                               AND cast(n.data->'notification'->'issue'->>'id' as bigint) = gi.id)
             """, nativeQuery = true)
     List<GithubIssueViewEntity> findAllGoodFirstIssuesCreatedSince5Minutes(ZonedDateTime now, String timezone);
 

infrastructure/postgres-adapter/src/main/resources/db/changelog/changelogs/00000028_add_indexes.sql

@@ -0,0 +1,5 @@
+create index if not exists notifications_data_notification_type_index
+    on iam.notifications ((data -> 'notification' ->> '@type'));
+
+create index if not exists notifications_data_notification_issue_id_index
+    on iam.notifications ((cast(data -> 'notification' -> 'issue' ->> 'id' as bigint)));

infrastructure/postgres-adapter/src/main/resources/db/changelog/db.changelog-master.yaml

@@ -49,3 +49,5 @@ databaseChangeLog:
       file: db/changelog/changelogs/00000026_add_missing_indexes.sql
   - include:
       file: db/changelog/changelogs/00000027_restore_indexes.sql
+  - include:
+      file: db/changelog/changelogs/00000028_add_indexes.sql