chore: remove payload logging

gateway/handle.go

 gw.logger.Debugn("response", 
 gw.logger.Debugn("response", 
@@ -597,11 +597,10 @@ func (gw *Handle) getPayloadFromRequest(r *http.Request) ([]byte, error) {
 	payload, err := io.ReadAll(r.Body)
 	_ = r.Body.Close()
 	if err != nil {
-		gw.logger.Errorf(
-			"Error reading request body, 'Content-Length': %s, partial payload:\n\t%s\n:%v",
-			r.Header.Get("Content-Length"),
-			string(payload),
-			err,
+		gw.logger.Errorn(
+			"Error reading request body",
+			logger.NewStringField("Content-Length", r.Header.Get("Content-Length")),
+			logger.NewErrorField(err),
 		)
 		return payload, errors.New(response.RequestBodyReadFailed)
 	}
@@ -723,7 +722,6 @@ func (gw *Handle) internalBatchHandlerFunc() http.HandlerFunc {
 			logger.NewStringField("path", r.URL.Path),
 			logger.NewIntField("status", int64(status)),
 			logger.NewStringField("body", responseBody),
-			logger.NewStringField("request", string(body)),
 		)
 		http.Error(w, responseBody, status)
 	}
@@ -1016,7 +1014,6 @@ func (gw *Handle) storeJobs(ctx context.Context, jobs []*jobsdb.JobT) error {
 			gw.logger.Errorn(
 				"Store into gateway db failed with error",
 				obskit.Error(err),
-				logger.NewField("jobs", jobs),
 			)
 			return err
 		}

router/transformer/transformer.go

@@ -164,7 +164,7 @@
 	// Call remote transformation
 	rawJSON, err := jsonrs.Marshal(&transformMessageCopy)
 	if err != nil {
-		trans.logger.Errorf("problematic input for marshalling: %#v", transformMessage)
+		trans.logger.Errorw("problematic input for marshalling", "error", err)
 		panic(err)
 	}
 
@@ -290,8 +290,6 @@
 			panic(fmt.Errorf("Incompatible transformer version: Expected: %d Received: %d, URL: %v", utilTypes.SupportedTransformerApiVersion, transformerAPIVersion, url))
 		}
 
-		trans.logger.Debugf("[Router Transfomrer] :: output payload : %s", string(respData))
-
 		if transformType == BATCH {
 			integrations.CollectIntgTransformErrorStats(respData)
 			err = jsonrs.Unmarshal(respData, &destinationJobs)
@@ -341,8 +339,6 @@
 		}
 
 		if invalidResponseReason != "" {
-
-			trans.logger.Error(invalidResponseError)
 			stats.Default.NewTaggedStat(`router.transformer.invalid.response`, stats.CountType, stats.Tags{
 				"destType": transformMessage.DestType,
 				"reason":   invalidResponseReason,
@@ -501,7 +497,6 @@
 			}
 		}
 	**/
-	trans.logger.Debugf("ProxyResponseData: %s\n", string(respData))
 	respData = []byte(gjson.GetBytes(respData, "output").Raw)
 	integrations.CollectDestErrorStats(respData)
 
@@ -615,7 +610,6 @@
 func (trans *handle) doProxyRequest(ctx context.Context, proxyUrl string, proxyReqParams *ProxyRequestParams, payload []byte) httpProxyResponse {
 	var respData []byte
 	destName := proxyReqParams.DestName
-	trans.logger.Debugf(`[TransformerProxy] (Dest-%[1]v) Proxy Request payload - %[2]s`, destName, string(payload))
 	req, err := http.NewRequestWithContext(ctx, http.MethodPost, proxyUrl, bytes.NewReader(payload))
 	if err != nil {
 		trans.logger.Errorf(`[TransformerProxy] (Dest-%[1]v) NewRequestWithContext Failed for %[1]v, with %[3]v`, destName, err.Error())
@@ -678,7 +672,7 @@
 	// error handling if body is missing
 	if resp.Body == nil {
 		errStr := "empty response body"
-		trans.logger.Errorf(`[TransformerProxy] (Dest-%[1]v) Failed with statusCode: %[2]v, message: %[3]v`, destName, http.StatusInternalServerError, string(respData))
+		trans.logger.Errorn(`[TransformerProxy] empty response body`, logger.NewIntField("statusCode", http.StatusInternalServerError))
 		return httpProxyResponse{
 			respData:   []byte{},
 			statusCode: http.StatusInternalServerError,
@@ -690,17 +684,15 @@
 	defer func() { httputil.CloseResponse(resp) }()
 	// error handling while reading from resp.Body
 	if err != nil {
 		respData = []byte(fmt.Sprintf(`failed to read response body, Error:: %+v`, err))
-		trans.logger.Errorf(`[TransformerProxy] (Dest-%[1]v) Failed with statusCode: %[2]v, message: %[3]v`, destName, http.StatusBadRequest, string(respData))
+		trans.logger.Errorn(`[TransformerProxy] Failure`, logger.NewIntField("statusCode", http.StatusBadRequest), logger.NewErrorField(err))
 		return httpProxyResponse{
 			respData:   []byte{}, // sending this as it is not getting sent at all
 			statusCode: http.StatusInternalServerError,
 			err:        err,
 		}
 	}
 
-	trans.logger.Debugf(`[TransformerProxy] (Dest-%[1]v) Proxy Request response - %[2]s`, destName, string(respData))
-
 	return httpProxyResponse{
 		respData:   respData,
 		statusCode: resp.StatusCode,