Hotel reservations
Problem
One room, two confirmations
A small hotel has four rooms. Reservations come from everywhere: from the website, from the front desk, from travel agencies. One Friday evening, two agencies reserve the last double room in the same second. Both get a confirmation. On Saturday, two families arrive at the room.
We will build a system where the server keeps the rooms and the reservations, and clients send requests over the network. A client can:
- see the free rooms;
- check one room;
- reserve a room in their own name;
- cancel their own reservation.
And when two clients reserve the same room at the same time, only one of them succeeds. We will prove it with a program that gives the same output on every run.
We build from the bottom up: the model without a network, the rules and the errors, the protocol, the server and the client, the simultaneous requests, and finally everything in one program.
More precisely, if you are curious
HttpClient. In both languages the same key idea guards the rooms: lock.The idea
The room
A room has a number, a type, a price per night and a state: free or taken.
class Room { private final int number; private final String type; private final int price; private boolean free = true;
public Room(int number, String type, int price) { this.number = number; this.type = type; this.price = price; }
public int getNumber() { return number; }
public String getType() { return type; }
public int getPrice() { return price; }
public boolean isFree() { return free; }
public void occupy() { free = false; }
public void release() { free = true; }
@Override public String toString() { return number + ", " + type + ", €" + price + " per night, " + (free ? "free" : "taken"); }}public class Room{ public int Number { get; } public string Type { get; } public int Price { get; } public bool IsFree { get; set; } = true;
public Room(int number, string type, int price) { Number = number; Type = type; Price = price; }
public void Occupy() { IsFree = false; }
public void Release() { IsFree = true; }
public override string ToString() { return Number + ", " + Type + ", €" + Price + " per night, " + (IsFree ? "free" : "taken"); }}class Room: def __init__(self, number, kind, price): self._number = number self._kind = kind self._price = price self._free = True
@property def number(self): return self._number
@property def kind(self): return self._kind
@property def price(self): return self._price
@property def is_free(self): return self._free
def occupy(self): self._free = False
def release(self): self._free = True
def __str__(self): state = "free" if self._free else "taken" return f"{self._number}, {self._kind}, €{self._price} per night, {state}"class Room { #number; #type; #price; #free = true;
constructor(number, type, price) { this.#number = number; this.#type = type; this.#price = price; }
get number() { return this.#number; }
get type() { return this.#type; }
get price() { return this.#price; }
get isFree() { return this.#free; }
occupy() { this.#free = false; }
release() { this.#free = true; }
toString() { const state = this.#free ? "free" : "taken"; return `${this.#number}, ${this.#type}, €${this.#price} per night, ${state}`; }}- The number, the type and the price do not change. Only the state changes, and only through two methods with clear names:
OccupyandRelease. - The room does not know who is staying in it. The room goes out to every client who asks, and the guest's name should not leave the hotel.
More precisely, if you are curious
IsFree has a public set because the client gets the room as JSON, and System.Text.Json has to write the state. The number, the type and the price come through the constructor. Without set, the client would see every room as free. For more than two states you use an enumeration: enum RoomState { Free, Taken, Repair }.See it
The hotel and the reservation
private final List<Room> rooms = new ArrayList<>();private final Map<Integer, String> guests = new HashMap<>();private readonly List<Room> rooms = new List<Room>();private readonly Dictionary<int, string> guests = new Dictionary<int, string>();def __init__(self): self._rooms = [] self._guests = {}#rooms = [];#guests = new Map();public void add(Room room) { rooms.add(room);}
public List<Room> freeRooms() { return rooms.stream().filter(Room::isFree).toList();}
public Room check(int number) { return find(number);}public void Add(Room room){ rooms.Add(room);}
public List<Room> FreeRooms(){ return rooms.Where(room => room.IsFree).ToList();}
public Room Check(int number){ return Find(number);}def add(self, room): self._rooms.append(room)
def free_rooms(self): return [room for room in self._rooms if room.is_free]
def check(self, number): return self._find(number)add(room) { this.#rooms.push(room);}
freeRooms() { return this.#rooms.filter((room) => room.isFree);}
check(number) { return this.#find(number);}Find is private: it looks up the room by number or throws an exception. That way nobody from outside can grab a room and take it around the rules:
private Room find(int number) { for (Room room : rooms) { if (room.getNumber() == number) { return room; } } throw new RoomNotFoundException("There is no room " + number + ".");}private Room Find(int number){ Room room = rooms.FirstOrDefault(r => r.Number == number); if (room == null) { throw new RoomNotFoundException("There is no room " + number + "."); } return room;}def _find(self, number): for room in self._rooms: if room.number == number: return room raise RoomNotFoundError(f"There is no room {number}.")#find(number) { const room = this.#rooms.find((r) => r.number === number); if (room === undefined) { throw new RoomNotFoundError(`There is no room ${number}.`); } return room;}The reservation checks the name, finds the room and checks whether it is free. Only then does it take it:
public void reserve(int number, String guest) { if (guest.isBlank()) { throw new HotelException("The guest's name is required."); } Room room = find(number); if (!room.isFree()) { throw new RoomTakenException("Room " + number + " is already taken."); } room.occupy(); guests.put(number, guest);}public void Reserve(int number, string guest){ if (string.IsNullOrWhiteSpace(guest)) { throw new HotelException("The guest's name is required."); } Room room = Find(number); if (!room.IsFree) { throw new RoomTakenException("Room " + number + " is already taken."); } room.Occupy(); guests[number] = guest;}def reserve(self, number, guest): if not guest.strip(): raise HotelError("The guest's name is required.") room = self._find(number) if not room.is_free: raise RoomTakenError(f"Room {number} is already taken.") room.occupy() self._guests[number] = guestreserve(number, guest) { if (guest.trim() === "") { throw new HotelError("The guest's name is required."); } const room = this.#find(number); if (!room.isFree) { throw new RoomTakenError(`Room ${number} is already taken.`); } room.occupy(); this.#guests.set(number, guest);}Hotel hotel = new Hotel();hotel.add(new Room(101, "single", 60));hotel.add(new Room(102, "double", 85));hotel.add(new Room(201, "double", 95));hotel.add(new Room(202, "suite", 140));
for (Room room : hotel.freeRooms()) { System.out.println(room);}hotel.reserve(102, "Anna Petrova");System.out.println("After the reservation: " + hotel.check(102));System.out.println("Free rooms: " + hotel.freeRooms().size());101, single, €60 per night, free102, double, €85 per night, free201, double, €95 per night, free202, suite, €140 per night, freeAfter the reservation: 102, double, €85 per night, takenFree rooms: 3Hotel hotel = new Hotel();hotel.Add(new Room(101, "single", 60));hotel.Add(new Room(102, "double", 85));hotel.Add(new Room(201, "double", 95));hotel.Add(new Room(202, "suite", 140));
foreach (Room room in hotel.FreeRooms()){ Console.WriteLine(room);}hotel.Reserve(102, "Anna Petrova");Console.WriteLine("After the reservation: " + hotel.Check(102));Console.WriteLine("Free rooms: " + hotel.FreeRooms().Count);101, single, €60 per night, free102, double, €85 per night, free201, double, €95 per night, free202, suite, €140 per night, freeAfter the reservation: 102, double, €85 per night, takenFree rooms: 3hotel = Hotel()hotel.add(Room(101, "single", 60))hotel.add(Room(102, "double", 85))hotel.add(Room(201, "double", 95))hotel.add(Room(202, "suite", 140))
for room in hotel.free_rooms(): print(room)hotel.reserve(102, "Anna Petrova")print(f"After the reservation: {hotel.check(102)}")print(f"Free rooms: {len(hotel.free_rooms())}")101, single, €60 per night, free102, double, €85 per night, free201, double, €95 per night, free202, suite, €140 per night, freeAfter the reservation: 102, double, €85 per night, takenFree rooms: 3const hotel = new Hotel();hotel.add(new Room(101, "single", 60));hotel.add(new Room(102, "double", 85));hotel.add(new Room(201, "double", 95));hotel.add(new Room(202, "suite", 140));
for (const room of hotel.freeRooms()) { console.log(String(room));}hotel.reserve(102, "Anna Petrova");console.log(`After the reservation: ${hotel.check(102)}`);console.log(`Free rooms: ${hotel.freeRooms().length}`);101, single, €60 per night, free102, double, €85 per night, free201, double, €95 per night, free202, suite, €140 per night, freeAfter the reservation: 102, double, €85 per night, takenFree rooms: 3The idea
Canceling and the rules
Not every request can be carried out: the room is taken, there is no room 305, a guest cancels someone else's reservation. These are refusals by the rules, so they are your own exceptions with a common parent:
class HotelException extends RuntimeException { public HotelException(String message) { super(message); }}
class RoomNotFoundException extends HotelException { public RoomNotFoundException(String message) { super(message); }}
class RoomTakenException extends HotelException { public RoomTakenException(String message) { super(message); }}public class HotelException : Exception{ public HotelException(string message) : base(message) { }}
public class RoomNotFoundException : HotelException{ public RoomNotFoundException(string message) : base(message) { }}
public class RoomTakenException : HotelException{ public RoomTakenException(string message) : base(message) { }}class HotelError(Exception): pass
class RoomNotFoundError(HotelError): pass
class RoomTakenError(HotelError): passclass HotelError extends Error { constructor(message) { super(message); this.name = "HotelError"; }}
class RoomNotFoundError extends HotelError { constructor(message) { super(message); this.name = "RoomNotFoundError"; }}
class RoomTakenError extends HotelError { constructor(message) { super(message); this.name = "RoomTakenError"; }}Canceling checks that the room is taken and that the same guest is canceling it:
public void cancel(int number, String guest) { Room room = find(number); if (room.isFree()) { throw new HotelException("Room " + number + " is not reserved."); } if (!guests.get(number).equals(guest)) { throw new HotelException("Room " + number + " is reserved by another guest."); } room.release(); guests.remove(number);}public void Cancel(int number, string guest){ Room room = Find(number); if (room.IsFree) { throw new HotelException("Room " + number + " is not reserved."); } if (guests[number] != guest) { throw new HotelException("Room " + number + " is reserved by another guest."); } room.Release(); guests.Remove(number);}def cancel(self, number, guest): room = self._find(number) if room.is_free: raise HotelError(f"Room {number} is not reserved.") if self._guests[number] != guest: raise HotelError(f"Room {number} is reserved by another guest.") room.release() del self._guests[number]cancel(number, guest) { const room = this.#find(number); if (room.isFree) { throw new HotelError(`Room ${number} is not reserved.`); } if (this.#guests.get(number) !== guest) { throw new HotelError(`Room ${number} is reserved by another guest.`); } room.release(); this.#guests.delete(number);}The project brief asks for the system to be checked in different scenarios: reserving, checking and canceling, both when they are valid and when they are not. Each scenario is a line in the output:
Hotel hotel = new Hotel();hotel.add(new Room(101, "single", 60));hotel.add(new Room(102, "double", 85));hotel.add(new Room(201, "double", 95));hotel.add(new Room(202, "suite", 140));
hotel.reserve(102, "Anna Petrova");System.out.println("1. Free room: " + hotel.check(102));try { hotel.reserve(102, "Boris Iliev");} catch (RoomTakenException e) { System.out.println("2. Taken room: " + e.getMessage());}try { hotel.cancel(102, "Boris Iliev");} catch (HotelException e) { System.out.println("3. Someone else's reservation: " + e.getMessage());}hotel.cancel(102, "Anna Petrova");System.out.println("4. Cancellation: " + hotel.check(102));try { hotel.cancel(102, "Anna Petrova");} catch (HotelException e) { System.out.println("5. Second cancellation: " + e.getMessage());}try { hotel.reserve(305, "Anna Petrova");} catch (RoomNotFoundException e) { System.out.println("6. No such room: " + e.getMessage());}try { hotel.reserve(201, " ");} catch (HotelException e) { System.out.println("7. No name: " + e.getMessage());}1. Free room: 102, double, €85 per night, taken2. Taken room: Room 102 is already taken.3. Someone else's reservation: Room 102 is reserved by another guest.4. Cancellation: 102, double, €85 per night, free5. Second cancellation: Room 102 is not reserved.6. No such room: There is no room 305.7. No name: The guest's name is required.Hotel hotel = new Hotel();hotel.Add(new Room(101, "single", 60));hotel.Add(new Room(102, "double", 85));hotel.Add(new Room(201, "double", 95));hotel.Add(new Room(202, "suite", 140));
hotel.Reserve(102, "Anna Petrova");Console.WriteLine("1. Free room: " + hotel.Check(102));try{ hotel.Reserve(102, "Boris Iliev");}catch (RoomTakenException e){ Console.WriteLine("2. Taken room: " + e.Message);}try{ hotel.Cancel(102, "Boris Iliev");}catch (HotelException e){ Console.WriteLine("3. Someone else's reservation: " + e.Message);}hotel.Cancel(102, "Anna Petrova");Console.WriteLine("4. Cancellation: " + hotel.Check(102));try{ hotel.Cancel(102, "Anna Petrova");}catch (HotelException e){ Console.WriteLine("5. Second cancellation: " + e.Message);}try{ hotel.Reserve(305, "Anna Petrova");}catch (RoomNotFoundException e){ Console.WriteLine("6. No such room: " + e.Message);}try{ hotel.Reserve(201, " ");}catch (HotelException e){ Console.WriteLine("7. No name: " + e.Message);}1. Free room: 102, double, €85 per night, taken2. Taken room: Room 102 is already taken.3. Someone else's reservation: Room 102 is reserved by another guest.4. Cancellation: 102, double, €85 per night, free5. Second cancellation: Room 102 is not reserved.6. No such room: There is no room 305.7. No name: The guest's name is required.hotel = Hotel()hotel.add(Room(101, "single", 60))hotel.add(Room(102, "double", 85))hotel.add(Room(201, "double", 95))hotel.add(Room(202, "suite", 140))
hotel.reserve(102, "Anna Petrova")print(f"1. Free room: {hotel.check(102)}")try: hotel.reserve(102, "Boris Iliev")except RoomTakenError as e: print(f"2. Taken room: {e}")try: hotel.cancel(102, "Boris Iliev")except HotelError as e: print(f"3. Someone else's reservation: {e}")hotel.cancel(102, "Anna Petrova")print(f"4. Cancellation: {hotel.check(102)}")try: hotel.cancel(102, "Anna Petrova")except HotelError as e: print(f"5. Second cancellation: {e}")try: hotel.reserve(305, "Anna Petrova")except RoomNotFoundError as e: print(f"6. No such room: {e}")try: hotel.reserve(201, " ")except HotelError as e: print(f"7. No name: {e}")1. Free room: 102, double, €85 per night, taken2. Taken room: Room 102 is already taken.3. Someone else's reservation: Room 102 is reserved by another guest.4. Cancellation: 102, double, €85 per night, free5. Second cancellation: Room 102 is not reserved.6. No such room: There is no room 305.7. No name: The guest's name is required.const hotel = new Hotel();hotel.add(new Room(101, "single", 60));hotel.add(new Room(102, "double", 85));hotel.add(new Room(201, "double", 95));hotel.add(new Room(202, "suite", 140));
hotel.reserve(102, "Anna Petrova");console.log(`1. Free room: ${hotel.check(102)}`);try { hotel.reserve(102, "Boris Iliev");} catch (e) { if (!(e instanceof RoomTakenError)) throw e; console.log(`2. Taken room: ${e.message}`);}try { hotel.cancel(102, "Boris Iliev");} catch (e) { if (!(e instanceof HotelError)) throw e; console.log(`3. Someone else's reservation: ${e.message}`);}hotel.cancel(102, "Anna Petrova");console.log(`4. Cancellation: ${hotel.check(102)}`);try { hotel.cancel(102, "Anna Petrova");} catch (e) { if (!(e instanceof HotelError)) throw e; console.log(`5. Second cancellation: ${e.message}`);}try { hotel.reserve(305, "Anna Petrova");} catch (e) { if (!(e instanceof RoomNotFoundError)) throw e; console.log(`6. No such room: ${e.message}`);}try { hotel.reserve(201, " ");} catch (e) { if (!(e instanceof HotelError)) throw e; console.log(`7. No name: ${e.message}`);}1. Free room: 102, double, €85 per night, taken2. Taken room: Room 102 is already taken.3. Someone else's reservation: Room 102 is reserved by another guest.4. Cancellation: 102, double, €85 per night, free5. Second cancellation: Room 102 is not reserved.6. No such room: There is no room 305.7. No name: The guest's name is required.The specific exception says what the problem is. HotelException catches all refusals at once: the server will catch only that one and turn it into a reply for the client.
More precisely, if you are curious
- C# has no checked exceptions. So the server has to catch them in one place, or a refusal by the rules goes out as a 500.
- Scenarios like these are natural tests. In C# there are libraries for this, such as xUnit: each scenario becomes a method, and
Assert.Throws<RoomTakenException>(...)checks the exception.
Try it
Who is in 201
What will the program print?
Hotel hotel = new Hotel();hotel.Add(new Room(101, "single", 60));hotel.Add(new Room(102, "double", 85));hotel.Add(new Room(201, "double", 95));hotel.Add(new Room(202, "suite", 140));
hotel.Reserve(101, "Anna Petrova");hotel.Reserve(201, "Boris Iliev");hotel.Cancel(101, "Anna Petrova");try{ hotel.Reserve(201, "Vera Koleva"); Console.WriteLine("Vera is in 201");}catch (RoomTakenException e){ Console.WriteLine("Vera is turned away");}Console.WriteLine(hotel.FreeRooms().Count);Anna takes 101 and then frees it. Boris takes 201, so Vera gets RoomTakenException, and the line "Vera is in 201" does not run. Only 201 is taken, so three rooms are free.
The idea
The protocol: addresses and JSON
Every action is a method and an address, the data is JSON, and the status says how it went:
| Request | Body | Response |
|---|---|---|
GET /rooms/free |
200 and the free rooms | |
GET /rooms/102 |
200 and the room, or 404 | |
POST /rooms/102/reservation |
{"guest":"Anna Petrova"} |
200 and a confirmation, 409 for a taken room, 404 for a room that does not exist |
DELETE /rooms/102/reservation?guest=Anna Petrova |
200 and a confirmation, or 400 with the reason |
Every refusal of the model has its own status. RoomNotFoundException is 404 Not Found, RoomTakenException is 409 Conflict: the request is fine, but it clashes with the current state. Any other HotelException is 400 Bad Request.
The body of the reservation is a small class just for carrying data:
public class ReservationRequest{ public string Guest { get; set; }}More precisely, if you are curious
-
The commands could be an enumeration:
enum Command { Free, Check, Reserve, Cancel }. Then they are a separate type with a closed list of values. In the course they are constants, because we have not covered enumerations. -
DELETEhas no body by convention, so the name is in the address. In a real system, instead of a name the client logs in with an account, and the server knows who it is. Then nobody can cancel someone else's reservation by typing someone else's name.
See it
The server
The start is as in the lesson on the first server: the port, no ASP.NET messages, and JSON that does not escape non-English letters:
var builder = WebApplication.CreateBuilder();builder.Logging.ClearProviders();builder.Services.ConfigureHttpJsonOptions(o => o.SerializerOptions.Encoder = JavaScriptEncoder.Create(UnicodeRanges.All));var app = builder.Build();app.Urls.Add("http://localhost:5331");The model's refusals become statuses in one place, in Safe:
IResult Safe(Func<IResult> action){ try { return action(); } catch (RoomNotFoundException e) { return Results.NotFound(e.Message); } catch (RoomTakenException e) { return Results.Conflict(e.Message); } catch (HotelException e) { return Results.BadRequest(e.Message); }}The addresses call the hotel. Reserving and canceling are lambdas with a body, because they do two things: call the model and return a confirmation:
app.MapGet("/rooms/free", () => hotel.FreeRooms());app.MapGet("/rooms/{number:int}", (int number) => Safe(() => Results.Ok(hotel.Check(number))));app.MapPost("/rooms/{number:int}/reservation", (int number, ReservationRequest request) => Safe(() =>{ hotel.Reserve(number, request.Guest); return Results.Ok("Room " + number + " is yours, " + request.Guest + ".");}));app.MapDelete("/rooms/{number:int}/reservation", (int number, string guest) => Safe(() =>{ hotel.Cancel(number, guest); return Results.Ok("The reservation for room " + number + " is canceled.");}));Here is what goes over the network:
using var http = new HttpClient { BaseAddress = new Uri("http://localhost:5331") };
async Task Show(string request, HttpResponseMessage response){ Console.WriteLine(request + " -> " + (int)response.StatusCode + " " + await response.Content.ReadAsStringAsync());}
var anna = new ReservationRequest { Guest = "Anna Petrova" };var boris = new ReservationRequest { Guest = "Boris Iliev" };await Show("POST /rooms/102/reservation", await http.PostAsJsonAsync("/rooms/102/reservation", anna));await Show("POST /rooms/102/reservation", await http.PostAsJsonAsync("/rooms/102/reservation", boris));await Show("GET /rooms/102", await http.GetAsync("/rooms/102"));await Show("DELETE /rooms/102/reservation?guest=Boris Iliev", await http.DeleteAsync("/rooms/102/reservation?guest=Boris Iliev"));await Show("DELETE /rooms/102/reservation?guest=Anna Petrova", await http.DeleteAsync("/rooms/102/reservation?guest=Anna Petrova"));await Show("GET /rooms/305", await http.GetAsync("/rooms/305"));POST /rooms/102/reservation -> 200 "Room 102 is yours, Anna Petrova."POST /rooms/102/reservation -> 409 "Room 102 is already taken."GET /rooms/102 -> 200 {"number":102,"type":"double","price":85,"isFree":false}DELETE /rooms/102/reservation?guest=Boris Iliev -> 400 "Room 102 is reserved by another guest."DELETE /rooms/102/reservation?guest=Anna Petrova -> 200 "The reservation for room 102 is canceled."GET /rooms/305 -> 404 "There is no room 305."See it
The client
The client hides HTTP behind methods. A response with an error becomes the same exception the server threw: 404, 409 and 400 come back as RoomNotFoundException, RoomTakenException and HotelException:
public class HotelClient{ private readonly HttpClient http;
public HotelClient(string address) { http = new HttpClient { BaseAddress = new Uri(address) }; }
public async Task<List<Room>> FreeRoomsAsync() { return await http.GetFromJsonAsync<List<Room>>("/rooms/free"); }
public async Task<Room> CheckAsync(int number) { HttpResponseMessage response = await http.GetAsync("/rooms/" + number); await ThrowIfError(response); return await response.Content.ReadFromJsonAsync<Room>(); }
public async Task<string> ReserveAsync(int number, string guest) { var request = new ReservationRequest { Guest = guest }; HttpResponseMessage response = await http.PostAsJsonAsync("/rooms/" + number + "/reservation", request); await ThrowIfError(response); return await response.Content.ReadFromJsonAsync<string>(); }
public async Task<string> CancelAsync(int number, string guest) { HttpResponseMessage response = await http.DeleteAsync("/rooms/" + number + "/reservation?guest=" + guest); await ThrowIfError(response); return await response.Content.ReadFromJsonAsync<string>(); }
private static async Task ThrowIfError(HttpResponseMessage response) { if (response.IsSuccessStatusCode) { return; } string message = await response.Content.ReadFromJsonAsync<string>(); int status = (int)response.StatusCode; if (status == 404) { throw new RoomNotFoundException(message); } if (status == 409) { throw new RoomTakenException(message); } throw new HotelException(message); }}var client = new HotelClient("http://localhost:5335");
Console.WriteLine(await client.ReserveAsync(102, "Anna Petrova"));Console.WriteLine(await client.CheckAsync(102));foreach (Room room in await client.FreeRoomsAsync()){ Console.WriteLine("Free: " + room);}Console.WriteLine(await client.CancelAsync(102, "Anna Petrova"));try{ await client.CheckAsync(305);}catch (RoomNotFoundException e){ Console.WriteLine("Refused: " + e.Message);}Room 102 is yours, Anna Petrova.102, double, €85 per night, takenFree: 101, single, €60 per night, freeFree: 201, double, €95 per night, freeFree: 202, suite, €140 per night, freeThe reservation for room 102 is canceled.Refused: There is no room 305.The idea
Two for one room
| Agency A | Agency B | |
|---|---|---|
| 1 | checks: 102 is free | |
| 2 | checks: 102 is free | |
| 3 | takes 102 for its guest | |
| 4 | takes 102 for its guest and records that guest |
Both get a confirmation. There is no mistake in any single line of code. The mistake is that the steps of the two requests interleave.
The fix: only one request at a time gets into the hotel. Then "check and take" is atomic: nobody can get in between the check and taking the room. In C#, alock in every public method of Hotel does this:private readonly List<Room> rooms = new List<Room>();private readonly Dictionary<int, string> guests = new Dictionary<int, string>();private readonly object sync = new object();public void Reserve(int number, string guest){ lock (sync) { if (string.IsNullOrWhiteSpace(guest)) { throw new HotelException("The guest's name is required."); } Room room = Find(number); if (!room.IsFree) { throw new RoomTakenException("Room " + number + " is already taken."); } room.Occupy(); guests[number] = guest; }}public void Reserve(int number, string guest){ lock (sync) { if (string.IsNullOrWhiteSpace(guest)) { throw new HotelException("The guest's name is required."); } Room room = Find(number); if (!room.IsFree) { throw new RoomTakenException("Room " + number + " is already taken."); } room.Occupy(); guests[number] = guest; }}Step by step, in words
- Room 102 is free. Anna Petrova and Boris Iliev reserve it at the same moment.
- First without lock. This is one possible order: Anna's request checks and sees "free".
- Boris's request checks before Anna has taken the room: it sees "free" too.
- Anna takes the room and records her name.
- Boris takes the room too and records his name. Both have a confirmation for the same room.
- From the start, with lock (sync): only one request at a time gets into the hotel.
- Say Anna is first: she takes the lock. The check and the taking are one step, and nobody gets in between them.
- Boris reaches the hotel and waits until the lock is free.
- Boris has the lock. Now the check sees "taken".
- RoomTakenException. The server sends it back as 409 Conflict, and the client turns it into RoomTakenException again.
- The program from the lesson counts the ones that succeed: 1 for each room. Who was first is different on every run.
The proof: two clients reserve 102 at once, then twenty agencies reserve 201 at once. The replies are collected, and the program prints how many succeeded:
var client = new HotelClient("http://localhost:5332");
async Task<bool> TryReserve(HotelClient client, int number, string guest){ try { await client.ReserveAsync(number, guest); return true; } catch (RoomTakenException) { return false; }}
async Task<int> Race(HotelClient client, int number, string[] guests){ var attempts = new List<Task<bool>>(); foreach (string guest in guests) { attempts.Add(TryReserve(client, number, guest)); } bool[] reserved = await Task.WhenAll(attempts); return reserved.Count(r => r);}
string[] two = { "Anna Petrova", "Boris Iliev" };Console.WriteLine("Two for room 102, succeeded: " + await Race(client, 102, two));
string[] agencies = new string[20];for (int i = 0; i < agencies.Length; i++){ agencies[i] = "Agency " + (i + 1);}Console.WriteLine("Twenty for room 201, succeeded: " + await Race(client, 201, agencies));Console.WriteLine("Free: " + string.Join("; ", await client.FreeRoomsAsync()));Two for room 102, succeeded: 1Twenty for room 201, succeeded: 1Free: 101, single, €60 per night, free; 202, suite, €140 per night, freeTask.WhenAll starts all the requests at once and waits for the replies. The refusal is RoomTakenException, and TryReserve turns it into false.
Who won the room is different on every run, so the program does not print it. How many succeeded is always the same: one for each room.
More precisely, if you are curious
- Without the locking the program would still almost always say 1: the window between the check and taking the room is small. But "almost always" means that once in thousands of reservations two guests arrive at the room. You do not catch a bug like that by running the program, but by thinking: which data is shared, and who changes it at the same time.
-
lock (sync)locks the whole hotel. While one request reserves 102, another waits even for 201. With four rooms that is fine. With thousands you lock per room, for examplelock (room) { ... }. - In a real system the rooms are in a database, and the guarding happens there: a transaction or a condition in the query itself (
UPDATE rooms SET free = false WHERE number = 102 AND free = true). Then it holds even with several servers, not only inside one program.
Try it
Locked, but not quite
lock. The server calls the check first, then the taking. With many requests at once, two people still sometimes get the same room. Which line is the bug on?Pick the line with the bug.
Reserve, as in our Hotel.See it
The whole hotel
The test scenarios from the brief, this time over the network, with two clients connected at once. At the end two people reserve 201 at the same moment:
var anna = new HotelClient("http://localhost:5333");var boris = new HotelClient("http://localhost:5333");
async Task Say(string who, Task<string> request){ try { Console.WriteLine(who + ": " + await request); } catch (HotelException e) { Console.WriteLine(who + ": refused, " + e.Message); }}
async Task<bool> TryReserve(HotelClient client, int number, string guest){ try { await client.ReserveAsync(number, guest); return true; } catch (RoomTakenException) { return false; }}
async Task<int> Race(HotelClient client, int number, string[] guests){ var attempts = new List<Task<bool>>(); foreach (string guest in guests) { attempts.Add(TryReserve(client, number, guest)); } bool[] reserved = await Task.WhenAll(attempts); return reserved.Count(r => r);}
await Say("Anna", anna.ReserveAsync(102, "Anna Petrova"));await Say("Boris", boris.ReserveAsync(102, "Boris Iliev"));Console.WriteLine("Boris: " + await boris.CheckAsync(102));await Say("Boris", boris.CancelAsync(102, "Boris Iliev"));await Say("Anna", anna.CancelAsync(102, "Anna Petrova"));await Say("Boris", boris.ReserveAsync(102, "Boris Iliev"));try{ await anna.CheckAsync(305);}catch (RoomNotFoundException e){ Console.WriteLine("Anna: refused, " + e.Message);}
string[] two = { "Anna Petrova", "Vera Koleva" };Console.WriteLine("Two for room 201 at once, succeeded: " + await Race(anna, 201, two));Console.WriteLine("Free: " + string.Join("; ", await anna.FreeRoomsAsync()));Anna: Room 102 is yours, Anna Petrova.Boris: refused, Room 102 is already taken.Boris: 102, double, €85 per night, takenBoris: refused, Room 102 is reserved by another guest.Anna: The reservation for room 102 is canceled.Boris: Room 102 is yours, Boris Iliev.Anna: refused, There is no room 305.Two for room 201 at once, succeeded: 1Free: 101, single, €60 per night, free; 202, suite, €140 per night, freeMore precisely, if you are curious
The whole program, from start to finish:
using System.Text.Encodings.Web;using System.Text.Unicode;
var builder = WebApplication.CreateBuilder();builder.Logging.ClearProviders();builder.Services.ConfigureHttpJsonOptions(o => o.SerializerOptions.Encoder = JavaScriptEncoder.Create(UnicodeRanges.All));var app = builder.Build();app.Urls.Add("http://localhost:5333");
Hotel hotel = new Hotel();hotel.Add(new Room(101, "single", 60));hotel.Add(new Room(102, "double", 85));hotel.Add(new Room(201, "double", 95));hotel.Add(new Room(202, "suite", 140));
IResult Safe(Func<IResult> action){ try { return action(); } catch (RoomNotFoundException e) { return Results.NotFound(e.Message); } catch (RoomTakenException e) { return Results.Conflict(e.Message); } catch (HotelException e) { return Results.BadRequest(e.Message); }}
app.MapGet("/rooms/free", () => hotel.FreeRooms());app.MapGet("/rooms/{number:int}", (int number) => Safe(() => Results.Ok(hotel.Check(number))));app.MapPost("/rooms/{number:int}/reservation", (int number, ReservationRequest request) => Safe(() =>{ hotel.Reserve(number, request.Guest); return Results.Ok("Room " + number + " is yours, " + request.Guest + ".");}));app.MapDelete("/rooms/{number:int}/reservation", (int number, string guest) => Safe(() =>{ hotel.Cancel(number, guest); return Results.Ok("The reservation for room " + number + " is canceled.");}));await app.StartAsync();
var anna = new HotelClient("http://localhost:5333");var boris = new HotelClient("http://localhost:5333");
async Task Say(string who, Task<string> request){ try { Console.WriteLine(who + ": " + await request); } catch (HotelException e) { Console.WriteLine(who + ": refused, " + e.Message); }}
async Task<bool> TryReserve(HotelClient client, int number, string guest){ try { await client.ReserveAsync(number, guest); return true; } catch (RoomTakenException) { return false; }}
async Task<int> Race(HotelClient client, int number, string[] guests){ var attempts = new List<Task<bool>>(); foreach (string guest in guests) { attempts.Add(TryReserve(client, number, guest)); } bool[] reserved = await Task.WhenAll(attempts); return reserved.Count(r => r);}
await Say("Anna", anna.ReserveAsync(102, "Anna Petrova"));await Say("Boris", boris.ReserveAsync(102, "Boris Iliev"));Console.WriteLine("Boris: " + await boris.CheckAsync(102));await Say("Boris", boris.CancelAsync(102, "Boris Iliev"));await Say("Anna", anna.CancelAsync(102, "Anna Petrova"));await Say("Boris", boris.ReserveAsync(102, "Boris Iliev"));try{ await anna.CheckAsync(305);}catch (RoomNotFoundException e){ Console.WriteLine("Anna: refused, " + e.Message);}
string[] two = { "Anna Petrova", "Vera Koleva" };Console.WriteLine("Two for room 201 at once, succeeded: " + await Race(anna, 201, two));Console.WriteLine("Free: " + string.Join("; ", await anna.FreeRoomsAsync()));
await app.StopAsync();
public class Room{ public int Number { get; } public string Type { get; } public int Price { get; } public bool IsFree { get; set; } = true;
public Room(int number, string type, int price) { Number = number; Type = type; Price = price; }
public void Occupy() { IsFree = false; }
public void Release() { IsFree = true; }
public override string ToString() { return Number + ", " + Type + ", €" + Price + " per night, " + (IsFree ? "free" : "taken"); }}
public class Hotel{ private readonly List<Room> rooms = new List<Room>(); private readonly Dictionary<int, string> guests = new Dictionary<int, string>(); private readonly object sync = new object();
public void Add(Room room) { lock (sync) { rooms.Add(room); } }
public List<Room> FreeRooms() { lock (sync) { return rooms.Where(room => room.IsFree).ToList(); } }
public Room Check(int number) { lock (sync) { return Find(number); } }
public void Reserve(int number, string guest) { lock (sync) { if (string.IsNullOrWhiteSpace(guest)) { throw new HotelException("The guest's name is required."); } Room room = Find(number); if (!room.IsFree) { throw new RoomTakenException("Room " + number + " is already taken."); } room.Occupy(); guests[number] = guest; } }
public void Cancel(int number, string guest) { lock (sync) { Room room = Find(number); if (room.IsFree) { throw new HotelException("Room " + number + " is not reserved."); } if (guests[number] != guest) { throw new HotelException("Room " + number + " is reserved by another guest."); } room.Release(); guests.Remove(number); } }
private Room Find(int number) { Room room = rooms.FirstOrDefault(r => r.Number == number); if (room == null) { throw new RoomNotFoundException("There is no room " + number + "."); } return room; }}
public class HotelException : Exception{ public HotelException(string message) : base(message) { }}
public class RoomNotFoundException : HotelException{ public RoomNotFoundException(string message) : base(message) { }}
public class RoomTakenException : HotelException{ public RoomTakenException(string message) : base(message) { }}
public class ReservationRequest{ public string Guest { get; set; }}
public class HotelClient{ private readonly HttpClient http;
public HotelClient(string address) { http = new HttpClient { BaseAddress = new Uri(address) }; }
public async Task<List<Room>> FreeRoomsAsync() { return await http.GetFromJsonAsync<List<Room>>("/rooms/free"); }
public async Task<Room> CheckAsync(int number) { HttpResponseMessage response = await http.GetAsync("/rooms/" + number); await ThrowIfError(response); return await response.Content.ReadFromJsonAsync<Room>(); }
public async Task<string> ReserveAsync(int number, string guest) { var request = new ReservationRequest { Guest = guest }; HttpResponseMessage response = await http.PostAsJsonAsync("/rooms/" + number + "/reservation", request); await ThrowIfError(response); return await response.Content.ReadFromJsonAsync<string>(); }
public async Task<string> CancelAsync(int number, string guest) { HttpResponseMessage response = await http.DeleteAsync("/rooms/" + number + "/reservation?guest=" + guest); await ThrowIfError(response); return await response.Content.ReadFromJsonAsync<string>(); }
private static async Task ThrowIfError(HttpResponseMessage response) { if (response.IsSuccessStatusCode) { return; } string message = await response.Content.ReadFromJsonAsync<string>(); int status = (int)response.StatusCode; if (status == 404) { throw new RoomNotFoundException(message); } if (status == 409) { throw new RoomTakenException(message); } throw new HotelException(message); }}Exercise
Keep going on your own
Work with the whole program from the previous card.
1. Changing rooms. The guest moves from one room to another with POST /rooms/102/move and the body {"guest":"Anna Petrova","to":202}. The reply is "Anna Petrova is in room 202.", and the client has a method MoveAsync. If the new room is taken, the guest stays in the old one. The move is one method in Hotel, in a lock: nobody should take the new room between freeing the old one and taking the new one.
Room 102 is yours, Anna Petrova.Room 201 is yours, Boris Iliev.Refused: Room 201 is already taken.Anna Petrova is in room 202.Free: 101, single, €60 per night, free; 102, double, €85 per night, freeMore ideas
- Nights and total. A reservation is for a number of nights, and the confirmation says the total: "3 nights, €255".
- Dates. A room is reserved for days, for example from December 14 to 16. Two reservations for the same room must not overlap. Whether the room is free depends on the dates.
- My reservations.
GET /reservations?guest=Anna Petrovasays which rooms belong to this guest. - Waiting list. If the room is taken, the guest signs up to wait. When it is canceled, it goes to the first one on the list.
-
A server that does not stop. Move the server into its own program with
await app.RunAsync(), and the client into another one, run in another terminal.
Test