Package de.hybris.platform.gigya.gigyab2bfacades.task.runner

Class GigyaWebHookEventsTaskRunner

java.lang.Object

de.hybris.platform.gigya.gigyab2bfacades.task.runner.GigyaWebHookEventsTaskRunner

All Implemented Interfaces:

de.hybris.platform.task.TaskRunner<TaskModel>

public class GigyaWebHookEventsTaskRunner
extends Object
implements de.hybris.platform.task.TaskRunner<TaskModel>

This class is used to process CDC Webhook Events data and create / update B2B users in Commerce

Constructor Summary

Constructors

Constructor	Description
GigyaWebHookEventsTaskRunner()

Method Summary

Modifier and Type	Method	Description
protected void	createOrUpdateCustomer(Map<String,Set<String>> uniqueUIDEventsMap, GigyaConfigModel gigyaConfig)	Create or Update Customer from the unique uids
de.hybris.platform.site.BaseSiteService	getBaseSiteService()
GigyaLoginFacade	getGigyaLoginFacade()
GigyaLoginService	getGigyaLoginService()
protected Map<String,Set<String>>	getUniqueUidsFromWebhookEvents(List<GigyaWebHookEvent> webhookEvents)	Get the unique uids from the incoming webhook events
void	handleError(de.hybris.platform.task.TaskService taskService, TaskModel taskModel, Throwable error)
protected void	processGigyaWebHookEvents(GigyaWebHookRequest gigyaWebHookRequest)
void	run(de.hybris.platform.task.TaskService taskService, TaskModel taskModel)
void	setBaseSiteService(de.hybris.platform.site.BaseSiteService baseSiteService)
void	setGigyaLoginFacade(GigyaLoginFacade gigyaLoginFacade)
void	setGigyaLoginService(GigyaLoginService gigyaLoginService)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface de.hybris.platform.task.TaskRunner

initLoggingCtx, isLoggingSupported, stopLoggingCtx

Constructor Details

GigyaWebHookEventsTaskRunner

public GigyaWebHookEventsTaskRunner()

Method Details

run

public void run(de.hybris.platform.task.TaskService taskService,
 TaskModel taskModel)

Specified by:

run in interface de.hybris.platform.task.TaskRunner<TaskModel>

handleError

public void handleError(de.hybris.platform.task.TaskService taskService,
 TaskModel taskModel,
 Throwable error)

Specified by:

handleError in interface de.hybris.platform.task.TaskRunner<TaskModel>

processGigyaWebHookEvents

protected void processGigyaWebHookEvents(GigyaWebHookRequest gigyaWebHookRequest)

getUniqueUidsFromWebhookEvents

protected Map<String,Set<String>> getUniqueUidsFromWebhookEvents(List<GigyaWebHookEvent> webhookEvents)

Get the unique uids from the incoming webhook events

Parameters:

webhookEvents - List of webhook events

createOrUpdateCustomer

protected void createOrUpdateCustomer(Map<String,Set<String>> uniqueUIDEventsMap,
 GigyaConfigModel gigyaConfig)

Create or Update Customer from the unique uids

Parameters:

uniqueUIDs - Set of Unique Gigya UIDs present in the webhook request

gigyaConfig - Gigya Config Model for the base site

getGigyaLoginService

public GigyaLoginService getGigyaLoginService()

setGigyaLoginService

public void setGigyaLoginService(GigyaLoginService gigyaLoginService)

getGigyaLoginFacade

public GigyaLoginFacade getGigyaLoginFacade()

setGigyaLoginFacade

public void setGigyaLoginFacade(GigyaLoginFacade gigyaLoginFacade)

getBaseSiteService

public de.hybris.platform.site.BaseSiteService getBaseSiteService()

setBaseSiteService

public void setBaseSiteService(de.hybris.platform.site.BaseSiteService baseSiteService)