Bugfix, owner was not considered.
Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-577
Change-Id: I960f5f9e328ee6c43ea9ef0df5736dcc17201da4
"producer_info_type_info": {
"description": "Information for an Information Type",
"type": "object",
- "required": [
- "info_job_data_schema",
- "info_type_information"
- ],
+ "required": ["info_job_data_schema"],
"properties": {
"info_type_information": {
"description": "Type specific information for the information type",
producer_info_type_info:
required:
- info_job_data_schema
- - info_type_information
type: object
properties:
info_type_information:
@Schema(
name = "info_type_information",
description = "Type specific information for the information type",
- required = true)
+ required = false)
@SerializedName("info_type_information")
- @JsonProperty(value = "info_type_information", required = true)
+ @JsonProperty(value = "info_type_information", required = false)
public Object typeSpecificInformation;
public ProducerInfoTypeInfo(Object jobDataSchema, Object typeSpecificInformation) {
}
public synchronized void put(SubscriptionInfo subscription) {
- allSubscriptions.put(subscription.getId(), subscription);
- subscriptionsByOwner.put(subscription.owner, subscription.id, subscription);
+ doPut(subscription);
storeInFile(subscription);
logger.debug("Added type status subscription {}", subscription.id);
}
for (File file : dbDir.listFiles()) {
String json = Files.readString(file.toPath());
SubscriptionInfo subscription = gson.fromJson(json, SubscriptionInfo.class);
- this.allSubscriptions.put(subscription.getId(), subscription);
+ doPut(subscription);
}
}
+ private void doPut(SubscriptionInfo subscription) {
+ allSubscriptions.put(subscription.getId(), subscription);
+ subscriptionsByOwner.put(subscription.owner, subscription.id, subscription);
+ }
+
private File getFile(SubscriptionInfo subscription) {
return getPath(subscription).toFile();
}
InfoTypeSubscriptions restoredSubscriptions = new InfoTypeSubscriptions(this.applicationConfig);
assertThat(restoredSubscriptions.size()).isEqualTo(1);
+ assertThat(restoredSubscriptions.getSubscriptionsForOwner("owner")).hasSize(1);
// Delete the subscription
restClient().deleteForEntity(typeSubscriptionUrl() + "/subscriptionId").block();