UOE-12386: Template based framework for reading signal data

modules/pubmatic/openwrap/config/config.go

@@ -25,6 +25,19 @@ type Config struct {
 	GeoDB            GeoDB
 	BidCache         BidCache
 	ResponseOverride ResponseOverride
+	Template         Template
+}
+
+type Template struct {
+	GoogleSDK    TemplateData
+	AppLovingMax TemplateData
+	LevelPlay    TemplateData
+}
+
+type TemplateData struct {
+	Enable           bool
+	Data             string
+	DeserializedData map[string]any
 }
 
 type ResponseOverride struct {

modules/pubmatic/openwrap/entrypointhook.go

@@ -91,8 +91,8 @@ func (m OpenWrap) handleEntrypointHook(
 
 	if endpoint == models.EndpointGoogleSDK {
 		rCtx.MetricsEngine = m.metricEngine
-		// Update fields from signal
-		payload.Body = googlesdk.ModifyRequestWithGoogleSDKParams(payload.Body, rCtx, m.features)
+		gsdk := googlesdk.NewGoogleSDK(m.metricEngine, m.cfg, m.features)
+		payload.Body = gsdk.ModifyRequestWithGoogleSDKParams(payload.Body)
 		result.ChangeSet.AddMutation(func(ep hookstage.EntrypointPayload) (hookstage.EntrypointPayload, error) {
 			ep.Body = payload.Body
 			return ep, nil

modules/pubmatic/openwrap/openwrap.go

@@ -113,6 +113,12 @@ func initOpenWrap(rawCfg json.RawMessage, moduleDeps moduledeps.ModuleDeps) (Ope
 	featureLoader := feature.NewFeatureLoader(mysqlDriver, cfg.Database)
 	features := featureLoader.LoadFeatures()
 
+	// Deserisalize Template Data
+	err = deserializeTemplates(&cfg)
+	if err != nil {
+		return OpenWrap{}, fmt.Errorf("error deserializing templates: %v", err)
+	}
+
 	// Init VAST Unwrap
 	vastunwrap.InitUnWrapperConfig(cfg.VastUnwrapCfg)
 	uw := unwrap.NewUnwrap(fmt.Sprintf("http://%s:%d/unwrap", cfg.VastUnwrapCfg.APPConfig.Host, cfg.VastUnwrapCfg.APPConfig.Port),
@@ -187,3 +193,25 @@ func patchConfig(cfg *config.Config) error {
 	}
 	return nil
 }
+
+func deserializeTemplates(cfg *config.Config) error {
+	if cfg.Template.GoogleSDK.Enable && len(cfg.Template.GoogleSDK.Data) > 0 {
+		if err := json.Unmarshal([]byte(cfg.Template.GoogleSDK.Data), &cfg.Template.GoogleSDK.DeserializedData); err != nil {
+			return fmt.Errorf("error deserializing Google SDK template: %v", err)
+		}
+	}
+
+	if cfg.Template.AppLovingMax.Enable && len(cfg.Template.AppLovingMax.Data) > 0 {
+		if err := json.Unmarshal([]byte(cfg.Template.AppLovingMax.Data), &cfg.Template.AppLovingMax.DeserializedData); err != nil {
+			return fmt.Errorf("error deserializing App Loving Max template: %v", err)
+		}
+	}
+
+	if cfg.Template.LevelPlay.Enable && len(cfg.Template.LevelPlay.Data) > 0 {
+		if err := json.Unmarshal([]byte(cfg.Template.LevelPlay.Data), &cfg.Template.LevelPlay.DeserializedData); err != nil {
+			return fmt.Errorf("error deserializing Level Play template: %v", err)
+		}
+	}
+
+	return nil
+}