gotta fix that valkey shit later

This commit is contained in:
pigwin
2025-01-07 20:39:47 +00:00
parent 07838da0ad
commit 9919c159f2

View File

@@ -35,6 +35,14 @@ func InsertOrUpdateEstimatedCall(ctx context.Context, db *sql.DB, values []inter
key := fmt.Sprintf("%v.%v", estimatedVehicleJourneyID, orderID)
fmt.Printf("Estimated Vehicle Journey ID: %v, Order ID: %v\n", estimatedVehicleJourneyID, orderID)
var err error
// Set the MD5 hash in Valkey
err = valki.SetValkeyValue(ctx, valkeyClient, key, hashString)
if err != nil {
return 0, "", fmt.Errorf("failed to set value in Valkey: %v", err)
}
// Get the MD5 hash from Valkey
retrievedHash, err := valki.GetValkeyValue(ctx, valkeyClient, key)
if err != nil {
@@ -47,12 +55,6 @@ func InsertOrUpdateEstimatedCall(ctx context.Context, db *sql.DB, values []inter
}
fmt.Println("Retrieved hash matches the original hash.")
// Set the MD5 hash in Valkey
err = valki.SetValkeyValue(ctx, valkeyClient, key, hashString)
if err != nil {
return 0, "", fmt.Errorf("failed to set value in Valkey: %v", err)
}
query := `
INSERT INTO calls (
estimatedvehiclejourney, "order", stoppointref,