Skip to content

Commit

Permalink
fix: formatting - 2
Browse files Browse the repository at this point in the history
Signed-off-by: Sai Sankeerth <[email protected]>
  • Loading branch information
Sai Sankeerth committed Feb 26, 2024
1 parent fe4fcea commit 9cb5fec
Show file tree
Hide file tree
Showing 7 changed files with 17 additions and 9 deletions.
4 changes: 2 additions & 2 deletions src/adapters/network.js
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ const fireHTTPStats = (clientResponse, startTime, statTags) => {
destType,
endpointPath,
requestMethod,
module
module,
});
stats.counter('outgoing_request_count', 1, {
feature,
Expand All @@ -66,7 +66,7 @@ const fireHTTPStats = (clientResponse, startTime, statTags) => {
success: clientResponse.success,
statusCode,
requestMethod,
module
module,
});
};

Expand Down
2 changes: 1 addition & 1 deletion src/cdk/v2/destinations/reddit/procWorkflow.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ steps:
- name: customFields
condition: $.outputs.prepareTrackPayload.eventType.tracking_type === "Purchase"
reference: "https://ads-api.reddit.com/docs/v2/#tag/Conversions/paths/~1api~1v2.0~1conversions~1events~1%7Baccount_id%7D/post"
reference: 'https://ads-api.reddit.com/docs/v2/#tag/Conversions/paths/~1api~1v2.0~1conversions~1events~1%7Baccount_id%7D/post'
template: |
const revenue_in_cents = .message.properties.revenue ? Math.round(Number(.message.properties.revenue)*100)
const customFields = .message.().({
Expand Down
10 changes: 9 additions & 1 deletion src/util/prometheus.js
Original file line number Diff line number Diff line change
Expand Up @@ -533,7 +533,15 @@ class Prometheus {
name: 'outgoing_request_count',
help: 'Outgoing HTTP requests count',
type: 'counter',
labelNames: ['feature', 'destType', 'endpointPath', 'success', 'statusCode', 'requestMethod' , 'module'],
labelNames: [
'feature',
'destType',
'endpointPath',
'success',
'statusCode',
'requestMethod',
'module',
],
},

// Gauges
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ const getConversionActionId = async (headers, params) => {
feature: 'transformation',
endpointPath: `/googleAds:searchStream`,
requestMethod: 'POST',
module: 'dataDelivery'
module: 'dataDelivery',
});
searchStreamResponse = processAxiosResponse(searchStreamResponse);
if (!isHttpStatusSuccess(searchStreamResponse.status)) {
Expand Down
2 changes: 1 addition & 1 deletion src/v0/destinations/marketo/networkHandler.js
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ const { proxyRequest, prepareProxyRequest } = require('../../../adapters/network
const { processAxiosResponse } = require('../../../adapters/utils/networkUtils');

const responseHandler = (responseParams) => {
const { destinationResponse, destType,rudderJobMetadata } = responseParams;
const { destinationResponse, destType, rudderJobMetadata } = responseParams;
const message = 'Request Processed Successfully';
const { status } = destinationResponse;
const authCache = v0Utils.getDestAuthCacheInstance(destType);
Expand Down
2 changes: 1 addition & 1 deletion src/v0/destinations/marketo_static_list/networkHandler.js
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ const { DESTINATION } = require('./config');
const responseHandler = (responseParams) => {
const { destinationResponse, destType, rudderJobMetadata } = responseParams;
const message = 'Request Processed Successfully';
const { status} = destinationResponse;
const { status } = destinationResponse;
const authCache = v0Utils.getDestAuthCacheInstance(destType);
// check for marketo application level failures
marketoResponseHandler(
Expand Down
4 changes: 2 additions & 2 deletions src/v0/destinations/wootric/util.js
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ const getAccessToken = async (destination) => {
feature: 'transformation',
endpointPath: `/oauth/token`,
requestMethod: 'POST',
module: 'router'
module: 'router',
});
const processedAuthResponse = processAxiosResponse(wootricAuthResponse);
// If the request fails, throwing error.
Expand Down Expand Up @@ -103,7 +103,7 @@ const retrieveUserDetails = async (endUserId, externalId, accessToken) => {
feature: 'transformation',
endpointPath: `/v1/end_users/`,
requestMethod: 'GET',
module: 'router'
module: 'router',
});
const processedUserResponse = processAxiosResponse(userResponse);

Expand Down

0 comments on commit 9cb5fec

Please sign in to comment.