This lesson's interactive features are locked, please to keep using them

Consume Logs

Now let's consume the logs and save them to disk.

Assignment

Create a .gitignore file if you don't already have one and ignore all files ending in .log:

*.log

Add a subscribeMsgPack function to the src/internal/pubsub/consume.ts file. It should be similar to the subscribeJSON function, but decode from msgpack instead of JSON.

I created a generic function to share duplicate code between subscribeJSON and subscribeMsgPack. If you're curious this is the function signature:

export async function subscribe<T>(
  conn: amqp.ChannelModel,
  exchange: string,
  queueName: string,
  routingKey: string,
  simpleQueueType: SimpleQueueType,
  handler: (data: T) => Promise<AckType> | AckType,
  deserializer: (data: Buffer) => T,
): Promise<void>;

Update the server to subscribeMsgPack to the game_logs queue instead of just declaring it. Use a wildcard in the routing key to make sure you capture logs from all clients, no matter the username. The handler should:
1. Use the writeLog function from src/internal/gamelogic/logs.js to write the log to disk.
2. Print a new prompt to the console.
Test the code.
- Because your queue has some logs in it, you should see them get consumed as soon as you restart the server.
- Make sure that the game.log file contains the logs you expect.
- Ensure all the messages from the game_logs queue are consumed using the Rabbit UI.

Run and submit the CLI tests.