@@ -94,7 +94,7 @@ export const appierAnalyticsAdapter = Object.assign(adapter({DEFAULT_SERVER, ana
94
94
contentType : 'application/json'
95
95
} ) ;
96
96
} ,
97
- newCommonMessageBody ( auctionId ) {
97
+ createCommonMessage ( auctionId ) {
98
98
return {
99
99
version : ANALYTICS_VERSION ,
100
100
auctionId : auctionId ,
@@ -126,9 +126,16 @@ export const appierAnalyticsAdapter = Object.assign(adapter({DEFAULT_SERVER, ana
126
126
}
127
127
return result ;
128
128
} ,
129
- newAuctionMessageBody ( auctionEndArgs , winningBids , timeoutBids ) {
129
+ addBidResponseToMessage ( message , bid , status ) {
130
+ const adUnitCode = parseAdUnitCode ( bid ) ;
131
+ message . adUnits [ adUnitCode ] = message . adUnits [ adUnitCode ] || { } ;
132
+ const bidder = parseBidderCode ( bid ) ;
133
+ const bidResponse = this . serializeBidResponse ( bid , status ) ;
134
+ message . adUnits [ adUnitCode ] [ bidder ] = bidResponse ;
135
+ } ,
136
+ createBidMessage ( auctionEndArgs , winningBids , timeoutBids ) {
130
137
const { auctionId, timestamp, timeout, auctionEnd, adUnitCodes, bidsReceived, noBids} = auctionEndArgs ;
131
- const message = this . newCommonMessageBody ( auctionId ) ;
138
+ const message = this . createCommonMessage ( auctionId ) ;
132
139
133
140
message . auctionElapsed = ( auctionEnd - timestamp ) ;
134
141
message . timeout = timeout ;
@@ -137,26 +144,9 @@ export const appierAnalyticsAdapter = Object.assign(adapter({DEFAULT_SERVER, ana
137
144
message . adUnits [ adUnitCode ] = { } ;
138
145
} ) ;
139
146
140
- bidsReceived . forEach ( ( bid ) => {
141
- const adUnitCode = parseAdUnitCode ( bid ) ;
142
- const bidder = parseBidderCode ( bid ) ;
143
- const bidResponse = this . serializeBidResponse ( bid , BIDDER_STATUS . BID ) ;
144
- message . adUnits [ adUnitCode ] [ bidder ] = bidResponse ;
145
- } ) ;
146
-
147
- noBids . forEach ( ( bid ) => {
148
- const adUnitCode = parseAdUnitCode ( bid ) ;
149
- const bidder = parseBidderCode ( bid ) ;
150
- const bidResponse = this . serializeBidResponse ( bid , BIDDER_STATUS . NO_BID ) ;
151
- message . adUnits [ adUnitCode ] [ bidder ] = bidResponse ;
152
- } ) ;
153
-
154
- timeoutBids . forEach ( ( bid ) => {
155
- const adUnitCode = parseAdUnitCode ( bid ) ;
156
- const bidder = parseBidderCode ( bid ) ;
157
- const bidResponse = this . serializeBidResponse ( bid , BIDDER_STATUS . TIMEOUT ) ;
158
- message . adUnits [ adUnitCode ] [ bidder ] = bidResponse ;
159
- } ) ;
147
+ bidsReceived . forEach ( bid => this . addBidResponseToMessage ( message , bid , BIDDER_STATUS . BID ) ) ;
148
+ noBids . forEach ( bid => this . addBidResponseToMessage ( message , bid , BIDDER_STATUS . NO_BID ) ) ;
149
+ timeoutBids . forEach ( bid => this . addBidResponseToMessage ( message , bid , BIDDER_STATUS . TIMEOUT ) ) ;
160
150
161
151
// mark the winning bids with prebidWon = true
162
152
winningBids . forEach ( bid => {
@@ -166,17 +156,13 @@ export const appierAnalyticsAdapter = Object.assign(adapter({DEFAULT_SERVER, ana
166
156
} ) ;
167
157
return message ;
168
158
} ,
169
- newImpressionMessageBody ( bid ) {
170
- const message = this . newCommonMessageBody ( bid . auctionId ) ;
171
- const adUnitCode = parseAdUnitCode ( bid ) ;
172
- message . adUnits [ adUnitCode ] = { } ;
173
- const bidder = parseBidderCode ( bid ) ;
174
- const bidResponse = this . serializeBidResponse ( bid , BIDDER_STATUS . BID_WON ) ;
175
- message . adUnits [ adUnitCode ] [ bidder ] = bidResponse ;
159
+ createImpressionMessage ( bid ) {
160
+ const message = this . createCommonMessage ( bid . auctionId ) ;
161
+ this . addBidResponseToMessage ( message , bid , BIDDER_STATUS . BID_WON ) ;
176
162
return message ;
177
163
} ,
178
- newCreativeMessageBody ( auctionId , bids ) {
179
- const message = this . newCommonMessageBody ( auctionId ) ;
164
+ createCreativeMessage ( auctionId , bids ) {
165
+ const message = this . createCommonMessage ( auctionId ) ;
180
166
bids . forEach ( ( bid ) => {
181
167
const adUnitCode = parseAdUnitCode ( bid ) ;
182
168
const bidder = parseBidderCode ( bid ) ;
@@ -196,13 +182,13 @@ export const appierAnalyticsAdapter = Object.assign(adapter({DEFAULT_SERVER, ana
196
182
const highestCpmBids = pbjs . getHighestCpmBids ( ) ;
197
183
198
184
this . sendEventMessage ( 'bid' ,
199
- this . newAuctionMessageBody ( auctionEndArgs , highestCpmBids , cachedAuction . timeoutBids )
185
+ this . createBidMessage ( auctionEndArgs , highestCpmBids , cachedAuction . timeoutBids )
200
186
) ;
201
187
202
188
if ( analyticsOptions . adSampled ) {
203
189
// FIXME: do not send the message if there are no creatives at all to safe bandwidth
204
190
this . sendEventMessage ( 'cr' ,
205
- this . newCreativeMessageBody ( auctionEndArgs . auctionId , auctionEndArgs . bidsReceived )
191
+ this . createCreativeMessage ( auctionEndArgs . auctionId , auctionEndArgs . bidsReceived )
206
192
) ;
207
193
}
208
194
} ,
@@ -213,7 +199,7 @@ export const appierAnalyticsAdapter = Object.assign(adapter({DEFAULT_SERVER, ana
213
199
} ) ;
214
200
} ,
215
201
handleBidWon ( bidWonArgs ) {
216
- this . sendEventMessage ( 'imp' , this . newImpressionMessageBody ( bidWonArgs ) ) ;
202
+ this . sendEventMessage ( 'imp' , this . createImpressionMessage ( bidWonArgs ) ) ;
217
203
} ,
218
204
track ( { eventType, args} ) {
219
205
if ( analyticsOptions . sampled ) {
0 commit comments