-
Notifications
You must be signed in to change notification settings - Fork 118
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
chore(release): pull release/v1.37.0 into main (#2435)
* chore: onboard swagger api on docker (#2400) onboard swagger api on docker * refactor: migrate destinations from cdk v1 to v2 (#2381) * refactor: migrate autopilot to cdkv2 * refactor: migrate heap to cdkv2 Modified the tests according to cdk v2 style. * refactor: migrate vitally to cdk v2 * chore: remove legacy profile routes * chore: remove legacy profile routes * refactor: migrate variance to cdk v2 * refactor: migrate statsig to cdkv2 * refactor: migrate userlist to cdkv2 * refactor: migrate zapier to cdk v2 * refactor: migrate lytics to cdk v2 * fix: pr comments * refactor: migrate new relic to cdk v2 Migrate cdk v1 implementation to v2. * refactor: migrate dcm_floodlight to cdk v1 * refactor: migrate kochava to cdk v2 * fix: pr comments * fix: stat labels (#2412) fix stat labels * feat: sessionId stitching (#2204) * feat: sessionId stitching * chore: comments addressed * chore: test coverage improved * chore: small fixes * chore: update test file coverage and improvised metrics * chore: update test file coverage * Update src/v0/sources/shopify/transform.js Co-authored-by: Utsab Chowdhury <[email protected]> * chore: shifted to hgetall to retrieve all data from redis in one go * chore: test case fix * chore: increase test coverage * chore: increase test coverage+1 * chore: sonarcloud issues * chore: separate util test file for redis related test cases --------- Co-authored-by: Sai Sankeerth <[email protected]> Co-authored-by: Utsab Chowdhury <[email protected]> * fix: customerIO source bugsnag issue for invalid timestamp (#2413) * chore: outgoing request latency metric (#2421) * fix: update images to fix integration tests (#2417) * chore: update tiktok ads api version to 1.3 (#2423) chore: update tiktok version to 1.3 * chore(transformation): set to default dns servers (#2416) * chore: tags for missed destinations for latency metric (#2425) Co-authored-by: Chandra shekar Varkala <[email protected]> * fix: rETL timestamp order (#2343) * fix(transformation): return retryable error when faas service exists … (#2427) * feat: return relevant stack trace as error from ivm (#2314) * feat: return relevant stack trace as error from ivm * chore: throw platform error for get recordId * chore: change error type for get recordId * fix: continue on git action failure to next steps (#2429) * fix(INT-256): handling non float price input for braze purchase events (#2431) * fix: handling non fload price input for braze purchase events Braze purchase events require the price value to be float. This commit is purposed to solve that * fix: add test cases and refactored the code for puchase events for braze --------- Co-authored-by: Mihir Bhalala <[email protected]> * fix(tiktok_ads): format productId to string data type (#2434) * fix: handle marketo auth token response when expires_in is 0 sec (#2432) * fix: handle marketo auth token response when expires_in is 0 sec * Update src/v0/destinations/marketo/util.js Co-authored-by: Dilip Kola <[email protected]> --------- Co-authored-by: Dilip Kola <[email protected]> * chore(release): 1.37.0 * fix(tiktok_ads): format products array product ids to string (#2445) * fix: heap timestamp mapping (#2451) * chore: update changelog entry for heap and tiktok (#2452) --------- Co-authored-by: Utsab Chowdhury <[email protected]> Co-authored-by: sandeepdigumarty <[email protected]> Co-authored-by: Krishna Chaitanya <[email protected]> Co-authored-by: Dilip Kola <[email protected]> Co-authored-by: Anant Jain <[email protected]> Co-authored-by: Sai Sankeerth <[email protected]> Co-authored-by: chandumlg <[email protected]> Co-authored-by: Jayachand <[email protected]> Co-authored-by: Yashasvi Bajpai <[email protected]> Co-authored-by: Chandra shekar Varkala <[email protected]> Co-authored-by: Sankeerth <[email protected]> Co-authored-by: Daniyal Parveez <[email protected]> Co-authored-by: Gauravudia <[email protected]> Co-authored-by: AASHISH MALIK <[email protected]> Co-authored-by: Gauravudia <[email protected]> Co-authored-by: Mihir Bhalala <[email protected]> Co-authored-by: GitHub Actions <[email protected]>
- Loading branch information
18 people
authored
Aug 8, 2023
1 parent
8543dbb
commit 3b847bf
Showing
121 changed files
with
5,871 additions
and
1,438 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -7,3 +7,4 @@ | |
| !tsconfig.json | ||
| !test | ||
| !scripts/skipPrepareScript.js | ||
| !swagger | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
119 changes: 119 additions & 0 deletions
119
src/cdk/v2/destinations/dcm_floodlight/procWorkflow.yaml
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,119 @@ | ||
| bindings: | ||
| - name: EventType | ||
| path: ../../../../constants | ||
| - name: isEmpty | ||
| path: ../../../../v0/util | ||
| - name: getIntegrationsObj | ||
| path: ../../../../v0/util | ||
| - name: removeUndefinedAndNullValues | ||
| path: ../../../../v0/util | ||
| - name: defaultRequestConfig | ||
| path: ../../../../v0/util | ||
| - path: ./utils | ||
|
|
||
| steps: | ||
| - name: validateInput | ||
| template: | | ||
| $.assert(.message.type, "message Type is not present. Aborting message."); | ||
| $.assert(.message.context.device.advertisingId, "advertisingId is required"); | ||
| $.assert(.message.type in {{$.EventType.([.PAGE, .TRACK])}}, | ||
| "message type " + .message.type + " is not supported"); | ||
| $.assert(.message.context.userAgent, .message.type + ":: userAgent is required"); | ||
| - name: setMessageType | ||
| template: | | ||
| $.context.messageType = .message.type.toLowerCase(); | ||
| - name: baseDestPayload | ||
| template: | | ||
| $.context.payload = .message.({ | ||
| src: ^.destination.Config.advertiserId, | ||
| cat: ^.destination.Config.activityTag, | ||
| type: ^.destination.Config.groupTag, | ||
| dc_rdid: .context.device.advertisingId, | ||
| ord: .properties.orderId ?? .properties.order_id, | ||
| qty: .properties.quantity, | ||
| cost: .properties.revenue, | ||
| dc_lat: .context.device.adTrackingEnabled | ||
| }); | ||
| $.context.userAgent = .message.context.userAgent; | ||
| $.context.integrations = $.getIntegrationsObj(.message, "dcm_floodlight"); | ||
| - name: prepareEventName | ||
| steps: | ||
| - name: pageEventName | ||
| condition: $.context.messageType === {{$.EventType.PAGE}} | ||
| template: | | ||
| const category = .message.properties.category; | ||
| const name = .message.name || .message.properties.name; | ||
| const eventNameArray = ["Viewed"]; | ||
| category ? eventNameArray.push(category); | ||
| name ? eventNameArray.push(name); | ||
| eventNameArray.push("Page"); | ||
| $.context.event = eventNameArray.join(" "); | ||
| - name: trackEventName | ||
| condition: $.context.messageType === {{$.EventType.TRACK}} | ||
| template: | | ||
| $.assert(.message.event, $.context.messageType + ":: event is required"); | ||
| $.context.event = .message.event | ||
| - name: cleanEventName | ||
| template: | | ||
| $.context.event = $.context.event.trim().toLowerCase(); | ||
| - name: handleIntegrationsObject | ||
| condition: $.context.integrations | ||
| template: | | ||
| $.context.integrations.COPPA ? | ||
| $.context.payload.tag_for_child_directed_treatment = $.mapFlagValue("COPPA", $.context.integrations.COPPA); | ||
| $.context.integrations.GDPR ? | ||
| $.context.payload.tfua = $.mapFlagValue("GDPR", $.context.integrations.GDPR); | ||
| $.context.integrations.npa ? | ||
| $.context.payload.npa = $.mapFlagValue("npa", $.context.integrations.npa); | ||
| - name: handleConversionEvents | ||
| template: | | ||
| const conversionEvent = .destination.Config.conversionEvents.find(function(conversionEvent) { | ||
| conversionEvent.eventName.trim().toLowerCase() === $.context.event | ||
| }); | ||
| $.assert(conversionEvent, $.context.messageType + ":: Conversion event not found"); | ||
| (!$.isEmpty(conversionEvent.floodlightActivityTag) && | ||
| !$.isEmpty(conversionEvent.floodlightGroupTag)) ? | ||
| ( | ||
| $.context.payload.cat = conversionEvent.floodlightActivityTag.trim(); | ||
| $.context.payload.type = conversionEvent.floodlightGroupTag.trim(); | ||
| ); | ||
| $.context.payload = Object.assign( | ||
| $.context.payload, | ||
| $.transformCustomVariable(conversionEvent.customVariables || [], .message) | ||
| ); | ||
| $.context.salesTag = conversionEvent.salesTag; | ||
| console.log("$.context.salesTag", $.context.salesTag); | ||
| - name: handleSalesTag | ||
| condition: $.context.salesTag | ||
| template: | | ||
| const products = .message.properties.products; | ||
| products ? ( | ||
| $.context.payload.qty = $.sum(~r products.quantity[]); | ||
| ) | ||
| else: | ||
| name: handleCounterTag | ||
| template: | | ||
| $.context.payload.ord = .message.messageId; | ||
| $.context.payload = $.context.payload.{~["qty", "cost"]}; | ||
| - name: cleanPayload | ||
| template: | | ||
| $.context.payload.( | ||
| .dc_lat ? $.context.payload.dc_lat = $.mapFlagValue('dc_lat', .dc_lat) | ||
| ); | ||
| $.context.payload = $.removeUndefinedAndNullValues($.context.payload) | ||
| - name: prepareEndpoint | ||
| template: | | ||
| const payloadParams = Object.entries($.context.payload).map(lambda ?0[0] + "=" + ?0[1]).join(";"); | ||
| $.context.endpoint = $.BASE_URL + payloadParams; | ||
| - name: buildResponseForProcessTransformation | ||
| template: | | ||
| const response = $.defaultRequestConfig(); | ||
| response.method = "GET"; | ||
| response.endpoint = $.context.endpoint; | ||
| response.headers = { | ||
| "User-Agent": $.context.userAgent | ||
| }; | ||
| response |
Oops, something went wrong.