in src/cartservice/src/cartstore/AlloyDBCartStore.cs [134:155]
public async Task EmptyCartAsync(string userId)
{
Console.WriteLine($"EmptyCartAsync called for userId={userId}");
try
{
await using var dataSource = NpgsqlDataSource.Create(connectionString);
var deleteCmd = $"DELETE FROM {tableName} WHERE userID = '{userId}'";
await using (var cmd = dataSource.CreateCommand(deleteCmd))
{
await Task.Run(() =>
{
return cmd.ExecuteNonQueryAsync();
});
}
}
catch (Exception ex)
{
throw new RpcException(
new Status(StatusCode.FailedPrecondition, $"Can't access cart storage at {connectionString}. {ex}"));
}
}