feat: Listen and handle new items in shop

src/CSGOEmpire.ts

@@ -197,14 +197,15 @@ export default class CSGOEmpire {
         return res.data;
     }
 
-    async queryWithdrawItems(options: WithdrawalFilters = { per_page: 160, page: 1, price_max_above: 15, sort: 'desc', order: 'market_value' }) {
+    async queryWithdrawItems(options: WithdrawalFilters = { per_page: 160, page: 1, price_max_above: 15, sort: 'desc', order: 'market_value' }, addNewItems: boolean = false) {
         const res = await this.get('/trading/items', {
             params: options
         });
 
         return new Shop(
             res.data.data.map((item: Object) => new WithdrawItem(item, this)),
             this,
+            addNewItems,
         );
     }
 

src/models/Shop.ts

@@ -1,20 +1,35 @@
+import { EventEmitter } from "events";
 import CSGOEmpire from "../CSGOEmpire";
 import WithdrawItem from "./WithdrawItem";
 
-export default class Shop {
+export default class Shop extends EventEmitter {
     items: WithdrawItem[];
     csgoempireInstance: CSGOEmpire;
+    addNewItems: boolean;
+
+    constructor(items: WithdrawItem[], csgoempireInstance: CSGOEmpire, addNewItems: boolean) {
+        super();
 
-    constructor(items: WithdrawItem[], csgoempireInstance: CSGOEmpire) {
         this.items = items;
         this.csgoempireInstance = csgoempireInstance;
+        this.addNewItems = addNewItems;
 
         if (this.csgoempireInstance.connectToSocket) {
             this.listenForEvents();
         }
     }
 
     listenForEvents() {
+        this.csgoempireInstance.tradingSocket.on('new_item', (data: any) => {
+            let item = new WithdrawItem(data, this.csgoempireInstance);
+
+            if (this.addNewItems) {
+                this.items.push(item);
+            }
+
+            this.emit('new-item', item);
+        });
+
         this.csgoempireInstance.tradingSocket.on('deleted_item', (itemId: number) => {
             this.items = this.items.filter((item: WithdrawItem) => item.id !== itemId);
         })