remove all event ids

Author: adnanhemani

service/common/src/main/java/org/apache/polaris/service/admin/PolarisServiceImpl.java

@@ -1427,7 +1427,8 @@ public void doRefresh() {
       if (latestLocation == null) {
         disableRefresh();
       } else {
-        polarisEventListener.onBeforeTableRefreshed(new BeforeTableRefreshedEvent(tableIdentifier));
+        polarisEventListener.onBeforeTableRefreshed(
+            new BeforeTableRefreshedEvent(tableIdentifier), callContext, securityContext);
         refreshFromMetadataLocation(
             latestLocation,
             SHOULD_RETRY_REFRESH_PREDICATE,
@@ -1447,13 +1448,16 @@ public void doRefresh() {
                       Set.of(PolarisStorageActions.READ, PolarisStorageActions.LIST));
               return TableMetadataParser.read(fileIO, metadataLocation);
             });
-        polarisEventListener.onAfterTableRefreshed(new AfterTableRefreshedEvent(tableIdentifier));
+        polarisEventListener.onAfterTableRefreshed(
+            new AfterTableRefreshedEvent(tableIdentifier), callContext, securityContext);
       }
     }
 
     public void doCommit(TableMetadata base, TableMetadata metadata) {
       polarisEventListener.onBeforeTableCommited(
-          new BeforeTableCommitedEvent(tableIdentifier, base, metadata));
+          new BeforeTableCommitedEvent(tableIdentifier, base, metadata),
+          callContext,
+          securityContext);
 
       LOGGER.debug(
           "doCommit for table {} with base {}, metadata {}", tableIdentifier, base, metadata);
@@ -1611,7 +1615,9 @@ public void doCommit(TableMetadata base, TableMetadata metadata) {
       }
 
       polarisEventListener.onAfterTableCommited(
-          new AfterTableCommitedEvent(tableIdentifier, base, metadata));
+          new AfterTableCommitedEvent(tableIdentifier, base, metadata),
+          callContext,
+          securityContext);
     }
 
     @Override
@@ -1802,7 +1808,8 @@ public void doRefresh() {
       if (latestLocation == null) {
         disableRefresh();
       } else {
-        polarisEventListener.onBeforeViewRefreshed(new BeforeViewRefreshedEvent(identifier));
+        polarisEventListener.onBeforeViewRefreshed(
+            new BeforeViewRefreshedEvent(identifier), callContext, securityContext);
         refreshFromMetadataLocation(
             latestLocation,
             SHOULD_RETRY_REFRESH_PREDICATE,
@@ -1824,13 +1831,14 @@ public void doRefresh() {
 
               return ViewMetadataParser.read(fileIO.newInputFile(metadataLocation));
             });
-        polarisEventListener.onAfterViewRefreshed(new AfterViewRefreshedEvent(identifier));
+        polarisEventListener.onAfterViewRefreshed(
+            new AfterViewRefreshedEvent(identifier), callContext, securityContext);
       }
     }
 
     public void doCommit(ViewMetadata base, ViewMetadata metadata) {
       polarisEventListener.onBeforeViewCommited(
-          new BeforeViewCommitedEvent(identifier, base, metadata));
+          new BeforeViewCommitedEvent(identifier, base, metadata), callContext, securityContext);
 
       // TODO: Maybe avoid writing metadata if there's definitely a transaction conflict
       LOGGER.debug("doCommit for view {} with base {}, metadata {}", identifier, base, metadata);
@@ -1927,7 +1935,7 @@ public void doCommit(ViewMetadata base, ViewMetadata metadata) {
       }
 
       polarisEventListener.onAfterViewCommited(
-          new AfterViewCommitedEvent(identifier, base, metadata));
+          new AfterViewCommitedEvent(identifier, base, metadata), callContext, securityContext);
     }
 
     protected String writeNewMetadataIfRequired(ViewMetadata metadata) {

service/common/src/main/java/org/apache/polaris/service/catalog/iceberg/IcebergCatalog.java

@@ -19,21 +19,18 @@
 
 package org.apache.polaris.service.events;
 
-import org.apache.polaris.core.admin.model.AddGrantRequest;
 import org.apache.polaris.core.admin.model.GrantResource;
 import org.apache.polaris.core.entity.PolarisPrivilege;
 
 /**
  * Event fired after a grant is added to a catalog role in Polaris.
  *
- * @param eventId the unique identifier for this event
  * @param catalogName the name of the catalog
  * @param catalogRoleName the name of the catalog role
  * @param privilege the privilege granted
  * @param grantResource the grant resource
  */
 public record AfterAddGrantToCatalogRoleEvent(
-    String eventId,
     String catalogName,
     String catalogRoleName,
     PolarisPrivilege privilege,

service/common/src/main/java/org/apache/polaris/service/events/AfterAddGrantToCatalogRoleEvent.java

@@ -24,9 +24,8 @@
 /**
  * Event fired after a principal role is assigned to a principal in Polaris.
  *
- * @param eventId the unique identifier for this event
  * @param principalName the name of the principal
  * @param principalRole the principal role assigned
  */
-public record AfterAssignPrincipalRoleEvent(
-    String eventId, String principalName, PrincipalRole principalRole) implements PolarisEvent {}
+public record AfterAssignPrincipalRoleEvent(String principalName, PrincipalRole principalRole)
+    implements PolarisEvent {}

service/common/src/main/java/org/apache/polaris/service/events/AfterAssignPrincipalRoleEvent.java

@@ -22,4 +22,4 @@
 import org.apache.polaris.core.admin.model.Catalog;
 
 /** Emitted when Polaris intends to create a table. */
-public record AfterCatalogCreatedEvent(String eventId, Catalog catalog) implements PolarisEvent {}
+public record AfterCatalogCreatedEvent(Catalog catalog) implements PolarisEvent {}

service/common/src/main/java/org/apache/polaris/service/events/AfterCatalogCreatedEvent.java

@@ -20,5 +20,4 @@
 package org.apache.polaris.service.events;
 
 /** Emitted when Polaris deletes a catalog. */
-public record AfterCatalogDeletedEvent(String eventId, String catalogName)
-    implements PolarisEvent {}
+public record AfterCatalogDeletedEvent(String catalogName) implements PolarisEvent {}

service/common/src/main/java/org/apache/polaris/service/events/AfterCatalogDeletedEvent.java

@@ -22,4 +22,4 @@
 import org.apache.polaris.core.admin.model.Catalog;
 
 /** Emitted when Polaris intends to get a catalog. */
-public record AfterCatalogGetEvent(String eventId, Catalog catalog) implements PolarisEvent {}
+public record AfterCatalogGetEvent(Catalog catalog) implements PolarisEvent {}

service/common/src/main/java/org/apache/polaris/service/events/AfterCatalogGetEvent.java

@@ -20,4 +20,4 @@
 package org.apache.polaris.service.events;
 
 /** Emitted when Polaris lists all catalogs. */
-public record AfterCatalogListEvent(String eventId) implements PolarisEvent {}
+public record AfterCatalogListEvent() implements PolarisEvent {}

service/common/src/main/java/org/apache/polaris/service/events/AfterCatalogListEvent.java

@@ -22,11 +22,9 @@
 /**
  * Event fired after a catalog role is assigned to a principal role in Polaris.
  *
- * @param eventId the unique identifier for this event
  * @param principalRoleName the name of the principal role
  * @param catalogName the name of the catalog
  * @param catalogRoleName the name of the catalog role assigned
  */
 public record AfterCatalogRoleAssignToPrincipalRoleEvent(
-    String eventId, String principalRoleName, String catalogName, String catalogRoleName)
-    implements PolarisEvent {}
+    String principalRoleName, String catalogName, String catalogRoleName) implements PolarisEvent {}

service/common/src/main/java/org/apache/polaris/service/events/AfterCatalogRoleAssignToPrincipalRoleEvent.java

@@ -24,9 +24,8 @@
 /**
  * Event fired after a catalog role is created in Polaris.
  *
- * @param eventId the unique identifier for this event
  * @param catalogName the name of the catalog
  * @param catalogRole the catalog role that was created
  */
-public record AfterCatalogRoleCreateEvent(
-    String eventId, String catalogName, CatalogRole catalogRole) implements PolarisEvent {}
+public record AfterCatalogRoleCreateEvent(String catalogName, CatalogRole catalogRole)
+    implements PolarisEvent {}