feat(LENS-1466): add support for partial updates in the UpdateStreamService

[jgwatkincoveo]

LENS-1466

Added the capability of pushing the partialUpdate object in the UpdateStreamService. See Dictionary field update

Testing

Update the catalog using the SDK
This resulted in the following data

After using the sdk with the following to update

UpdateStreamService updateStreamService = new UpdateStreamService(SourceBuilder.buildCatalogSource());
Map<String,String> dictionary = new HashMap<>();
dictionary.put("sp", "Spanish");
dictionary.put("de", "German");

PartialUpdateDocument partialUpdateDocument1 = new PartialUpdateDocument("http://someurl.com/92833", PartialUpdateOperator.FIELDVALUEREPLACE, "ec_description", "Some Great description");
PartialUpdateDocument partialUpdateDocument2 = new PartialUpdateDocument("http://someurl.com/92833", PartialUpdateOperator.ARRAYREMOVE, "availableskus", new String[]{"sku1"});
PartialUpdateDocument partialUpdateDocument3 = new PartialUpdateDocument("http://someurl.com/92833", PartialUpdateOperator.DICTIONARYPUT, "languages", dictionary);
PartialUpdateDocument partialUpdateDocument4 = new PartialUpdateDocument("http://someurl.com/92833", PartialUpdateOperator.DICTIONARYREMOVE, "languages", new String[]{"en", "fr"});

PartialUpdateDocument partialUpdateDocument5 = new PartialUpdateDocument("http://someurl.com/92834", PartialUpdateOperator.ARRAYAPPEND, "availableskus", new String[]{"sku1", "sku2"});
PartialUpdateDocument partialUpdateDocument6 = new PartialUpdateDocument("http://someurl.com/92834", PartialUpdateOperator.DICTIONARYREMOVE, "languages", "en");

updateStreamService.addPartialUpdate(partialUpdateDocument1);
updateStreamService.addPartialUpdate(partialUpdateDocument2);
updateStreamService.addPartialUpdate(partialUpdateDocument3);
updateStreamService.addPartialUpdate(partialUpdateDocument4);
updateStreamService.addPartialUpdate(partialUpdateDocument5);
updateStreamService.addPartialUpdate(partialUpdateDocument6);
HttpResponse<String> response = updateStreamService.close();

We get the following updated in the admin UI

[samisayegh]

Great 🙌

[sallainCoveo]

✅