Added enum for other messages

src/game/gameFlow.ts

@@ -1,4 +1,5 @@
 import GameState, { PHASE_ENUM } from './gameState';
+import { MessageService, MessageFileName } from '../utils/MessageService'
 
 class GameFlow {
     gameState: GameState;
@@ -59,21 +60,10 @@ class GameFlow {
                 // Weapons Purchase Subphase
                 if (!userInput) {
                     // Send instructions to the user for the current subphase
-                    responseMessage = `
-🔫 **Choose Your Weapon for the Journey** 🔫
-
-Please select from the following options by replying with **!!Oregon [choice]**:
-
-1. **Frontiersman's Sharpshooter Rifle** - $200 (Best accuracy and range)
-2. **Pioneer's Long Rifle** - $150 (Improved accuracy and range)
-3. **Settler's Carbine** - $100 (Good balance of cost and performance)
-4. **Homesteader's Musket** - $75 (Reliable but not as accurate)
-5. **Grandpa's Rusty Shotgun** - Free (Least accurate but no cost)
-
-**Note:** Your choice of weapon can greatly affect your hunting success and defense against threats on the trail. Choose wisely!
-
-Reply with the choice number, for example: **!!Oregon 3** to select the Settler's Carbine.
-`;
+                    responseMessage = `${MessageService.getRandomMessage(
+                        MessageFileName.Oregon_WeaponPurchase,
+                        {}
+                    )}`;
                     // The lack of userInput argument triggers a request for input.
                 } else {
                     // Process user input here and decide whether to advance subphase or send an error message
@@ -81,6 +71,7 @@ Reply with the choice number, for example: **!!Oregon 3** to select the Settler'
                     if (purchaseResult.success) {
                         // If the purchase was successful, advance to the next subphase and recursively call handleSetupPhase without userInput to get the next set of instructions
                         this.gameState.subPhase++;
+                        //TODO next we will need to add a wrapper methood that will dump the game object and the message back to the player
                         return this.handleSetupPhase();
                     } else {
                         // If there was an error, include the error message in responseMessage
@@ -91,18 +82,93 @@ Reply with the choice number, for example: **!!Oregon 3** to select the Settler'
                 break;
             case 1:
                 //OXEN TEAM Purchase
+                if (!userInput) {
+                    responseMessage = `${MessageService.getRandomMessage(
+                        MessageFileName.Oregon_OxenPurchase,
+                        {}
+                    )}`;
+                } else {
+                    const purchaseResult = this.handleGenericPurchase(PurchaseOption.OXEN, userInput, 200, 300);
+                    if (purchaseResult.success) {
+                        this.gameState.subPhase++;
+                        //TODO next we will need to add a wrapper methood that will dump the game object and the message back to the player
+                        return this.handleSetupPhase(); // Call setup phase again for next subphase
+                    } else {
+                        responseMessage = purchaseResult.errorMessage || '';
+                    }
+                }
                 break;
             case 2:
                 //FOOD Purchase
+                if (!userInput) {
+                    responseMessage = `${MessageService.getRandomMessage(
+                        MessageFileName.Oregon_FoodPurchase,
+                        {}
+                    )}`;
+                } else {
+                    const purchaseResult = this.handleGenericPurchase(PurchaseOption.FOOD, userInput);
+                    if (purchaseResult.success) {
+                        this.gameState.subPhase++;
+                        //TODO next we will need to add a wrapper methood that will dump the game object and the message back to the player
+                        return this.handleSetupPhase(); // Call setup phase again for next subphase
+                    } else {
+                        responseMessage = purchaseResult.errorMessage || '';
+                    }
+                }
                 break;
             case 3:
                 //AMMUNITION Purchase
+                if (!userInput) {
+                    responseMessage = `${MessageService.getRandomMessage(
+                        MessageFileName.Oregon_AmmoPurchase,
+                        {}
+                    )}`;
+                } else {
+                    const purchaseResult = this.handleGenericPurchase(PurchaseOption.AMMO, userInput);
+                    if (purchaseResult.success) {
+                        this.gameState.subPhase++;
+                        //TODO next we will need to add a wrapper methood that will dump the game object and the message back to the player
+                        return this.handleSetupPhase(); // Call setup phase again for next subphase
+                    } else {
+                        responseMessage = purchaseResult.errorMessage || '';
+                    }
+                }
                 break;
             case 4:
                 //CLOTHING Purchase
+                if (!userInput) {
+                    responseMessage = `${MessageService.getRandomMessage(
+                        MessageFileName.Oregon_ClothingPurchase,
+                        {}
+                    )}`;
+                } else {
+                    const purchaseResult = this.handleGenericPurchase(PurchaseOption.CLOTHING, userInput);
+                    if (purchaseResult.success) {
+                        this.gameState.subPhase++;
+                        //TODO next we will need to add a wrapper methood that will dump the game object and the message back to the player
+                        return this.handleSetupPhase(); // Call setup phase again for next subphase
+                    } else {
+                        responseMessage = purchaseResult.errorMessage || '';
+                    }
+                }
                 break;
             case 5:
                 //MISCELLANEOUS SUPPLIES Purchase
+                if (!userInput) {
+                    responseMessage = `${MessageService.getRandomMessage(
+                        MessageFileName.Oregon_MiscSuppliesPurchase,
+                        {}
+                    )}`;
+                } else {
+                    const purchaseResult = this.handleGenericPurchase(PurchaseOption.MISC, userInput);
+                    if (purchaseResult.success) {
+                        this.gameState.subPhase++;
+                        //TODO next we will need to add a wrapper methood that will dump the game object and the message back to the player
+                        return this.handleSetupPhase(); // Call setup phase again for next subphase
+                    } else {
+                        responseMessage = purchaseResult.errorMessage || '';
+                    }
+                }
                 break;
             default:
                 //Advance Phase
@@ -142,6 +208,59 @@ Reply with the choice number, for example: **!!Oregon 3** to select the Settler'
         };
     }
 
+    handleGenericPurchase(itemType: PurchaseOption, userInput: string, minAmount?: number, maxAmount?: number): { success: boolean; errorMessage?: string; responseMessage?: string } {
+        const amount = parseInt(userInput);
+        if (isNaN(amount) || amount < 0) {
+            return {
+                success: false,
+                errorMessage: "⚠️ Invalid input. Please enter a positive number."
+            };
+        }
+
+        if ((maxAmount && amount > maxAmount) || (minAmount && amount < minAmount)) {
+            return {
+                success: false,
+                errorMessage: `⚠️ Invalid input. Please enter a number between ${minAmount} and ${maxAmount}.`
+            };
+        }
+
+        const totalCost = amount
+        if (this.gameState.cashLeftAfterInitialPurchases < totalCost) {
+            return {
+                success: false,
+                errorMessage: `⚠️ You do not have enough money to purchase ${amount} units of ${itemType}. You have $${this.gameState.cashLeftAfterInitialPurchases} remaining.`
+            };
+        }
+
+        // Update gameState based on itemType
+        switch (itemType) {
+            case PurchaseOption.OXEN:
+                this.gameState.amountSpentOnAnimals += totalCost;
+                break;
+            case PurchaseOption.FOOD:
+                this.gameState.amountSpentOnFood += totalCost;
+                break;
+            case PurchaseOption.AMMO:
+                this.gameState.amountSpentOnAmmunition += totalCost * 50;
+                break;
+            case PurchaseOption.CLOTHING:
+                this.gameState.amountSpentOnClothing += totalCost;
+                break;
+            case PurchaseOption.MISC:
+                this.gameState.amountSpentOnMiscellaneousSupplies += totalCost;
+                break;
+            // Add cases for other item types
+        }
+
+        this.gameState.cashLeftAfterInitialPurchases -= totalCost;
+
+        // Optionally, return a success message
+        return {
+            success: true
+        };
+    }
+
+
 
     private async handleRidersAttack(userInput?: string | number): Promise<void> {
         // Logic for handling a riders attack, may involve checking userInput for response to attack
@@ -192,3 +311,11 @@ const weaponOptions: Record<string, WeaponOption> = {
     "4": { name: "Homesteader's Musket", cost: 75 },
     "5": { name: "Grandpa's Rusty Shotgun", cost: 0 }
 };
+
+enum PurchaseOption {
+    OXEN = 'oxen',
+    FOOD = 'food',
+    AMMO = 'ammo',
+    CLOTHING = 'clothing',
+    MISC = 'misc',
+};

src/messages/oregon_AmmoPurchase.txt

@@ -0,0 +1 @@
+🔫 How much do you want to spend on ammunition? $1 buys a belt of 50 bullets. You will need bullets for attacks by animals and bandits, and for hunting food. Reply with !!Oregon [amount].

src/messages/oregon_ClothingPurchase.txt

@@ -0,0 +1 @@
+🧥 How much do you want to spend on clothing? This is especially important for the cold weather you will encounter when crossing the mountains. Reply with !!Oregon [amount].

src/messages/oregon_FoodPurchase.txt

@@ -0,0 +1 @@
+🍞 How much do you want to spend on food? The more you have, the less chance there is of getting sick. Reply with !!Oregon [amount].

src/messages/oregon_MiscSuppliesPurchase.txt

@@ -0,0 +1 @@
+🔧 How much do you want to spend on miscellaneous supplies? This includes medicine and other things you will need for sickness and emergency repairs. Reply with !!Oregon [amount].

src/messages/oregon_OxenPurchase.txt

@@ -0,0 +1 @@
+🐂 How much do you want to spend on your oxen team? You can spend $200-$300. Reply with !!Oregon [amount].

src/messages/oregon_WeaponPurchase.txt

@@ -0,0 +1,13 @@
+🔫 **Choose Your Weapon for the Journey** 🔫
+
+Please select from the following options by replying with **!!Oregon [choice]**:
+
+1. **Frontiersman's Sharpshooter Rifle** - $200 (Best accuracy and range)
+2. **Pioneer's Long Rifle** - $150 (Improved accuracy and range)
+3. **Settler's Carbine** - $100 (Good balance of cost and performance)
+4. **Homesteader's Musket** - $75 (Reliable but not as accurate)
+5. **Grandpa's Rusty Shotgun** - Free (Least accurate but no cost)
+
+**Note:** Your choice of weapon can greatly affect your hunting success and defense against threats on the trail. Choose wisely!
+
+Reply with the choice number, for example: **!!Oregon 3** to select the Settler's Carbine.

src/rdrama/session/SessionManager.ts

@@ -26,7 +26,13 @@ class SessionManager {
                 enableOfflineQueue: true
             },
             maxConcurrent: 1, // Maximum number of concurrent requests
-            minTime: 1000 // Minimum time between dispatches of requests in milliseconds
+            minTime: 1000, // Minimum time between dispatches of requests in milliseconds
+            reservoir: 41, // Initial reservoir value for the first hour
+            reservoirRefreshAmount: 41, // Reservoir value to reset to every hour
+            reservoirRefreshInterval: 60 * 60 * 1000, // Interval to reset the reservoir (1 hour in milliseconds)
+            //For now will reply to every comment given enoug time even if severely rate limited
+            //highWater: 5, // Maximum number of queued jobs.
+            //strategy: Bottleneck.strategy.OVERFLOW_PRIORITY // Strategy to drop the oldest jobs in the queue when highWater is reached
         });
 
         this.axiosInstance = axios.create({
@@ -82,13 +88,13 @@ class SessionManager {
         // Wrap the post method
         const originalPost = instance.post;
         instance.post = <T = any, R = AxiosResponse<T>>(url: string, data?: any, config?: AxiosRequestConfig): Promise<R> => {
-            return this.limiter.schedule(() => originalPost.apply(instance, [url, data, config])) as Promise<R>;
+            return this.limiter.schedule({ priority: 1 }, () => originalPost.apply(instance, [url, data, config])) as Promise<R>;
         };
 
         // Wrap the put method
         const originalPut = instance.put;
         instance.put = <T = any, R = AxiosResponse<T>>(url: string, data?: any, config?: AxiosRequestConfig): Promise<R> => {
-            return this.limiter.schedule(() => originalPut.apply(instance, [url, data, config])) as Promise<R>;
+            return this.limiter.schedule({ priority: 1 }, () => originalPut.apply(instance, [url, data, config])) as Promise<R>;
         };
 
         // Wrap the delete method

src/utils/MessageService.ts

@@ -3,10 +3,12 @@ import path from 'path';
 
 // Define an enum for message file names
 export enum MessageFileName {
-    RdramaPreviousMessage = 'rdrama_PreviousMessage.txt',
-    RdramaShouldntNotify = 'rdrama_ShouldntNotify.txt',
-    RedditMessages = 'reddit_messages.txt',
-    RdramaMessages = 'rdrama_messages.txt',
+    Oregon_WeaponPurchase = 'oregon_WeaponPurchase.txt',
+    Oregon_OxenPurchase = 'oregon_OxenPurchase.txt',
+    Oregon_FoodPurchase = 'oregon_FoodPurchase.txt',
+    Oregon_AmmoPurchase = 'oregon_AmmoPurchase.txt',
+    Oregon_ClothingPurchase = 'oregon_ClothingPurchase.txt',
+    Oregon_MiscSuppliesPurchase = 'oregon_MiscSuppliesPurchase.txt',
 }
 
 export class MessageService {