feat: update trigger_new_sales.go file

wakflo · Jul 22, 2024 · 588c9f3 · 588c9f3
1 parent fae3948
commit 588c9f3
Showing 1 changed file with 6 additions and 10 deletions.
diff --git a/internal/connectors/cin7/trigger_new_sales.go b/internal/connectors/cin7/trigger_new_sales.go
@@ -56,19 +56,15 @@ func (t *TriggerNewSales) Run(ctx *sdk.RunContext) (sdk.JSON, error) {
 	applicationKey := ctx.Auth.Extra["key"]
 
 	lastRunTime := ctx.Metadata.LastRun
-	if lastRunTime == nil {
-		defaultTime := time.Now().Add(-24 * time.Hour).Format(time.RFC3339)
-		parsedTime, err := time.Parse(time.RFC3339, defaultTime)
-		if err != nil {
-			log.Fatalf("Error parsing default time: %v", err)
-		}
-		lastRunTime = &parsedTime
+
+	var fromDate string
+	if lastRunTime != nil {
+		fromDate = lastRunTime.Format(time.RFC3339)
 	}
 
 	queryParams := map[string]interface{}{
-		"Page":         "1",
-		"Limit":        "100",
-		"CreatedSince": lastRunTime.Format(time.RFC3339),
+		"Page":         1,
+		"CreatedSince": fromDate,
 	}
 
 	response, err := fetchData(endpoint, accountID, applicationKey, queryParams)