SWATCH-2018: Report filtered instance data to Export Service in JSON

- configured the export listener for the tally service (worker profile)
- report the instances data as JSON
- generated instances export POJOs from JSON schemas

src/main/java/org/candlepin/subscriptions/export/DataExporterService.java

@@ -28,10 +28,10 @@ public interface DataExporterService<T extends Serializable, U> {
 
   Stream<T> fetchData(ExportServiceRequest request);
 
-  U mapDataItem(T item);
+  U mapDataItem(T item, ExportServiceRequest request);
 
-  default U mapDataItem(Object item) {
-    return mapDataItem(getDataClass().cast(item));
+  default U mapDataItem(Object item, ExportServiceRequest request) {
+    return mapDataItem(getDataClass().cast(item), request);
   }
 
   Class<T> getDataClass();

src/main/java/org/candlepin/subscriptions/export/ExportSubscriptionListener.java

@@ -31,7 +31,6 @@
 import com.redhat.swatch.clients.export.api.model.DownloadExportErrorRequest;
 import com.redhat.swatch.clients.export.api.resources.ExportApi;
 import io.micrometer.core.annotation.Timed;
-import jakarta.transaction.Transactional;
 import jakarta.ws.rs.core.Response.Status;
 import java.io.File;
 import java.io.FileOutputStream;
@@ -49,6 +48,7 @@
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 /** Listener for Export messages from Kafka */
 @Service
@@ -82,7 +82,7 @@ protected ExportSubscriptionListener(
   }
 
   @Timed("rhsm-subscriptions.exports.upload")
-  @Transactional
+  @Transactional(readOnly = true)
   @KafkaListener(
       id = "#{__listener.groupId}",
       topics = "#{__listener.topic}",
@@ -159,7 +159,7 @@ private void uploadJson(
       var serializer =
           serializerProvider.findTypedValueSerializer(
               exporterService.getExportItemClass(), false, null);
-      data.map(exporterService::mapDataItem)
+      data.map(i -> exporterService.mapDataItem(i, request))
           .forEach(
               item -> {
                 try {

src/main/java/org/candlepin/subscriptions/resource/InstancesResource.java

@@ -274,7 +274,7 @@ private static Sort toSort(String sort, SortDirection dir) {
     return sortValue;
   }
 
-  private static Boolean isPayg(Optional<Variant> variant) {
+  public static boolean isPayg(Optional<Variant> variant) {
     return variant
         .map(Variant::getSubscription)
         .map(SubscriptionDefinition::isPaygEligible)
@@ -346,7 +346,7 @@ private static List<Double> getInstanceMeasurements(
     return measurementList;
   }
 
-  private static List<HardwareMeasurementType> getHardwareMeasurementTypesFromCategory(
+  public static List<HardwareMeasurementType> getHardwareMeasurementTypesFromCategory(
       ReportCategory reportCategory) {
     if (Objects.isNull(reportCategory)) {
       return new ArrayList<>();
@@ -355,7 +355,7 @@ private static List<HardwareMeasurementType> getHardwareMeasurementTypesFromCate
     }
   }
 
-  private static ReportCategory getCategoryByMeasurementType(
+  public static ReportCategory getCategoryByMeasurementType(
       HardwareMeasurementType measurementType) {
     if (HardwareMeasurementType.isSupportedCloudProvider(measurementType.name())) {
       return ReportCategory.CLOUD;
@@ -368,7 +368,7 @@ private static ReportCategory getCategoryByMeasurementType(
     };
   }
 
-  private static CloudProvider getCloudProviderByMeasurementType(
+  public static CloudProvider getCloudProviderByMeasurementType(
       HardwareMeasurementType measurementType) {
     return switch (measurementType) {
       case AWS -> CloudProvider.AWS;

src/main/java/org/candlepin/subscriptions/subscription/export/SubscriptionDataExporterService.java

@@ -96,7 +96,7 @@ public Stream<Subscription> fetchData(ExportServiceRequest request) {
   }
 
   @Override
-  public SubscriptionsExportItem mapDataItem(Subscription dataItem) {
+  public SubscriptionsExportItem mapDataItem(Subscription dataItem, ExportServiceRequest request) {
     var item = new SubscriptionsExportItem();
     item.setOrgId(dataItem.getOrgId());
     item.setMeasurements(new ArrayList<>());

src/main/java/org/candlepin/subscriptions/tally/TallyWorkerConfiguration.java

@@ -32,6 +32,7 @@
 import org.candlepin.subscriptions.db.AccountServiceInventoryRepository;
 import org.candlepin.subscriptions.db.HostRepository;
 import org.candlepin.subscriptions.db.TallySnapshotRepository;
+import org.candlepin.subscriptions.export.ExportSubscriptionConfiguration;
 import org.candlepin.subscriptions.inventory.db.InventoryDataSourceConfiguration;
 import org.candlepin.subscriptions.json.BillableUsage;
 import org.candlepin.subscriptions.json.EnabledOrgsRequest;
@@ -92,7 +93,8 @@
   TaskConsumerConfiguration.class,
   BillingProducerConfiguration.class,
   InventoryDataSourceConfiguration.class,
-  ProductConfiguration.class
+  ProductConfiguration.class,
+  ExportSubscriptionConfiguration.class
 })
 @ComponentScan(
     basePackages = {