feat: update code using functions new names and response body's

Author: DanielFillol

request/api_async_request.go

@@ -8,20 +8,20 @@ import (
 
 const API = "/_search"
 
-// AsyncAPIRequest makes API requests asynchronously
-func AsyncAPIRequest(users []models.ReadCsv, numberOfWorkers int, url string, method string, auth string) ([]models.ResponseBody, error) {
+// AsyncAPIRequestLawsuit makes API requests asynchronously
+func AsyncAPIRequestLawsuit(users []models.ReadCsvLaawsuit, numberOfWorkers int, url string, method string, auth string) ([]models.ResponseBodyLawsuit, error) {
 	// Create a channel to signal when the goroutines are done processing inputs
 	done := make(chan struct{})
 	defer close(done)
 	// Create a channel to receive inputs from
-	inputCh := StreamInputs(done, users)
+	inputCh := StreamInputsLawsuits(done, users)
 
 	// Create a wait group to wait for the worker goroutines to finish
 	var wg sync.WaitGroup
 	wg.Add(numberOfWorkers)
 
 	// Create a channel to receive results from
-	resultCh := make(chan models.ResponseBody)
+	resultCh := make(chan models.ResponseBodyLawsuit)
 
 	// Spawn worker goroutines to process inputs
 	var errorOnApiRequests error
@@ -30,8 +30,8 @@ func AsyncAPIRequest(users []models.ReadCsv, numberOfWorkers int, url string, me
 			// Each worker goroutine consumes inputs from the shared input channel
 			for input := range inputCh {
 				// Make the API request and send the response to the result channel
-				tj, err := defineTJ(input.CNJNumber)
-				bodyStr, err := APIRequest(url+tj+API, method, auth, input)
+				tj, err := defineTJLawsuit(input.CNJNumber)
+				bodyStr, err := APIRequestLawsuit(url+tj+API, method, auth, input)
 				resultCh <- bodyStr
 				if err != nil {
 					// If there is an error making the API request, print the error
@@ -58,18 +58,18 @@ func AsyncAPIRequest(users []models.ReadCsv, numberOfWorkers int, url string, me
 	}
 
 	// Collect results from the result channel and return them as a slice
-	var results []models.ResponseBody
+	var results []models.ResponseBodyLawsuit
 	for result := range resultCh {
 		results = append(results, result)
 	}
 
 	return results, nil
 }
 
-// StreamInputs sends inputs from a slice to a channel
-func StreamInputs(done <-chan struct{}, inputs []models.ReadCsv) <-chan models.ReadCsv {
+// StreamInputsLawsuits sends inputs from a slice to a channel
+func StreamInputsLawsuits(done <-chan struct{}, inputs []models.ReadCsvLaawsuit) <-chan models.ReadCsvLaawsuit {
 	// Create a channel to send inputs to
-	inputCh := make(chan models.ReadCsv)
+	inputCh := make(chan models.ReadCsvLaawsuit)
 	go func() {
 		defer close(inputCh)
 		for _, input := range inputs {