fix: klaviyo bulk upload and BingAds OC (#5305)

* fix: bing ads audience (#5299)

* chore: handle 500kb limit, refactor to service impl (#5302)

* chore: handle 500kb limit, refactor to service impl

* chore: fix mock

* chore: fix mock newline

* chore: fix apiservice newline

* chore: move error

---------

Co-authored-by: Sudip Paul <67197965+ItsSudip@users.noreply.github.com>

router/batchrouter/asyncdestinationmanager/bing-ads/offline-conversions/bingads_test.go

@@ -539,14 +539,14 @@ var _ = Describe("Bing ads Offline Conversions", func() {
 			Expect(err).To(BeNil())
 		})
 
-		It("Transform() Test -> conversionAdjustedTime not available", func() {
+		It("Transform() Test -> adjustedConversionTime not available", func() {
 			job := &jobsdb.JobT{
 				EventPayload: []byte("{\"type\": \"record\", \"action\": \"update\", \"fields\": {\"conversionName\": \"Test-Integration\", \"conversionTime\": \"5/22/2023 6:27:54 AM\", \"conversionValue\": \"100\", \"microsoftClickId\": \"click_id\", \"conversionCurrencyCode\": \"USD\"}}"),
 			}
 			uploader := &BingAdsBulkUploader{}
 			// Execute
 			_, err := uploader.Transform(job)
-			expectedResult := fmt.Errorf(" conversionAdjustedTime field not defined")
+			expectedResult := fmt.Errorf(" adjustedConversionTime field not defined")
 			Expect(err.Error()).To(Equal(expectedResult.Error()))
 		})
 	})

router/batchrouter/asyncdestinationmanager/bing-ads/offline-conversions/bulk_uploader.go

@@ -69,7 +69,7 @@ func (b *BingAdsBulkUploader) Transform(job *jobsdb.JobT) (string, error) {
 	}
 	if event.Action != "insert" {
 		// validate for adjusted time
-		err := validateField(fields, "conversionAdjustedTime")
+		err := validateField(fields, "adjustedConversionTime")
 		if err != nil {
 			return payload, err
 		}