Fix some Bugs and add some Feathers

src/bots/handlers/webookHandlers.ts

@@ -36,6 +36,8 @@ export const setupWeBookHandlers = (bot: any) => {
   bot.action(/^webook_page_(\d+)$/, callbackReplyHandler(handleWeBookPageAction));
   bot.action('webook_back_to_menu', callbackReplyHandler(handleWeBookBackToMenuAction));
   bot.action('webook_book_by_url', callbackReplyHandler(handleWeBookBookByUrlAction));
+  bot.action(/^ticket_select_(.+)_(.+)$/, callbackReplyHandler(handleTicketSelectionAction));
+  bot.action('view_event_details', callbackReplyHandler(handleViewEventDetailsAction));
 };
 
 // Inject dependencies for filter handlers
@@ -82,6 +84,57 @@ export const handleWeBookBookByUrlAction = async (ctx: BotContext) => {
   return null;
 };
 
+export const handleTicketSelectionAction = async (ctx: BotContext) => {
+  const telegramId = ctx.from?.id;
+  if (!telegramId) return { message: messageManager.getMessage('error_user_not_found'), options: getBackToMainMenuButton() };
+  
+  // Extract ticket ID and event ID from callback data
+  const callbackData = (ctx.callbackQuery as any)?.data;
+  if (!callbackData) return { message: 'Invalid ticket selection', options: getBackToMainMenuButton() };
+  
+  const match = callbackData.match(/^ticket_select_(.+)_(.+)$/);
+  if (!match) return { message: 'Invalid ticket selection format', options: getBackToMainMenuButton() };
+  
+  const ticketId = match[1];
+  const eventId = match[2];
+  
+  // Delete the previous message with buttons
+  try {
+    await ctx.deleteMessage();
+  } catch (e) {
+    console.log('Could not delete previous message:', e);
+  }
+  
+  // Initialize booking state for this ticket
+  bookByUrlStates.set(telegramId, { 
+    step: 2, 
+    eventUrl: `https://api.webook.com/api/v2/event-detail/${eventId}`,
+    tickets: 1,
+    lastBotMessageId: undefined
+  });
+  
+  return {
+    message: `You selected a ticket. How many tickets would you like to purchase? (1-5)`,
+    options: getBackToMainMenuButton()
+  };
+};
+
+export const handleViewEventDetailsAction = async (ctx: BotContext) => {
+  const telegramId = ctx.from?.id;
+  if (!telegramId) return { message: messageManager.getMessage('error_user_not_found'), options: getBackToMainMenuButton() };
+  
+  // Delete the previous message with buttons
+  try {
+    await ctx.deleteMessage();
+  } catch (e) {
+    console.log('Could not delete previous message:', e);
+  }
+  
+  return {
+    message: `📋 <b>Event Details</b>\n\nThis feature will show comprehensive event information including:\n• Full event description\n• Detailed schedule\n• Venue information\n• Terms and conditions\n• Contact information\n\nPlease use the main menu to access this feature.`,
+    options: getBackToMainMenuButton()
+  };
+};
 
 // Export a handler for booking-by-URL text input
 export async function handleBookByUrlText(ctx: BotContext) {
@@ -287,8 +340,9 @@ export async function handleWeBookEventInfoByUrl(ctx: BotContext) {
   info += `<b>Title:</b> ${event.title || 'None'}\n`;
   // info += `<b>Subtitle:</b> ${event.subtitle || 'None'}\n`;
   info += `<b>ID:</b> ${event.id || 'None'}\n`;
-  // info += `<b>Slug:</b> ${event.slug || 'None'}\n`;
-  // info += `<b>Ticketing URL Slug:</b> ${event.ticketingUrlSlug || 'None'}\n`;
+  info += `<b>Slug:</b> ${event.slug || 'None'}\n`;
+
+  info += `<b>Ticketing URL Slug:</b> ${event.ticketingUrlSlug || 'None'}\n`;
   info += `<b>Starting Price:</b> ${event.startingPrice || 'None'} ${event.currencyCode || ''}\n`;
 
   info += `<b>Is Streaming Event:</b> ${event.isStreamingEvent ? 'Yes' : 'No'}\n`;
@@ -404,6 +458,144 @@ export async function handleWeBookEventInfoByUrl(ctx: BotContext) {
     await ctx.reply(info, { parse_mode: 'HTML' });
   }
   await ctx.deleteMessage(loadingMsg.message_id);
+
+  // Call REST API using ticketingUrlSlug if available
+  if (event.ticketingUrlSlug) {
+    try {
+      console.log("Attempting to fetch REST API data for ticketingUrlSlug:", event.ticketingUrlSlug);
+      // Call REST API directly using ticketingUrlSlug
+      const restEvent = event.ticketingUrlSlug
+        ? await (await import('axios')).default.get(
+            `https://api.webook.com/api/v2/event-detail/${event.ticketingUrlSlug}-tickets?lang=en&visible_in=rs`,
+            {
+              headers: {
+                "Accept": "*/*",
+                "Accept-Encoding": "gzip, deflate, br, zstd",
+                "Accept-Language": "en-US,en;q=0.9,ar;q=0.8",
+                "User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36",
+                "Origin": "https://webook.com",
+                "Referer": "https://webook.com/",
+                "Sec-Fetch-Dest": "empty",
+                "Sec-Fetch-Mode": "cors",
+                "Sec-Fetch-Site": "same-site",
+                "Cache-Control": "no-cache",
+                "Pragma": "no-cache"
+              },
+              timeout: 10000
+            }
+          ).then(res => res.data)
+        : null;
+      console.log("restEvent", restEvent);
+      
+      if (restEvent) {
+        // Format event info from REST API response
+        let restInfo = `<b>🎫 Event Information (REST API)</b>\n\n`;
+     
+    
+        // Additional event details
+        restInfo += `<b>❌ Is Sold Out:</b> ${restEvent.is_soldout ? 'Yes' : 'No'}\n`;
+
+        restInfo += `<b>🎫 Event Order Limit:</b> ${restEvent.event_order_limit || 'None'}\n\n`;
+
+        // Create ticket buttons
+        const ticketButtons: any[] = [];
+        
+        if (restEvent.event_tickets && Array.isArray(restEvent.event_tickets)) {
+          restInfo += `<b>🎟️ Available Tickets:</b>\n`;
+          
+          // Group tickets by availability and create buttons
+          const availableTickets = restEvent.event_tickets.filter((ticket: any) => !ticket.sold_out && ticket.remaining > 0);
+          const soldOutTickets = restEvent.event_tickets.filter((ticket: any) => ticket.sold_out || ticket.remaining <= 0);
+          
+
+
+          // Add available tickets as buttons (limit text length for Telegram)
+          availableTickets.forEach((ticket: any, index: number) => {
+            const buttonText = `${ticket.title} - ${ticket.price} ${ticket.currency}`;
+            const callbackData = `ticket_select_${ticket._id}_${restEvent._id}`;
+            ticketButtons.push([Markup.button.callback(buttonText, callbackData)]);
+            
+            // Add ticket details to the message text
+            restInfo += `• ${ticket.title}: ${ticket.price} ${ticket.currency} (${ticket.remaining} available)\n`;
+          });
+          
+          // Add sold out tickets as text
+          if (soldOutTickets.length > 0) {
+            restInfo += `\n<b>❌ Sold Out Tickets:</b>\n`;
+            soldOutTickets.forEach((ticket: any) => {
+              restInfo += `• ${ticket.title} - ${ticket.price} ${ticket.currency} (Sold Out)\n`;
+            });
+          }
+        }
+
+        // Add navigation buttons
+        ticketButtons.push([
+          Markup.button.callback('🔙 Back to Menu', 'webook_back_to_menu'),
+          Markup.button.callback('📋 View All Details', 'view_event_details')
+        ]);
+
+        // Send image if available, else send info as text
+        if (restEvent.poster) {
+          await ctx.replyWithPhoto(
+            { url: restEvent.poster }, 
+            { 
+              caption: restInfo, 
+              parse_mode: 'HTML',
+              ...Markup.inlineKeyboard(ticketButtons)
+            }
+          );
+        } else if (restEvent.mobile_poster) {
+          await ctx.replyWithPhoto(
+            { url: restEvent.mobile_poster }, 
+            { 
+              caption: restInfo, 
+              parse_mode: 'HTML',
+              ...Markup.inlineKeyboard(ticketButtons)
+            }
+          );
+        } else {
+          await ctx.reply(
+            restInfo, 
+            { 
+              parse_mode: 'HTML',
+              ...Markup.inlineKeyboard(ticketButtons)
+            }
+          );
+        }
+      } else {
+        // REST API returned null or failed, send a fallback message
+        console.log("REST API returned null, sending fallback message");
+        await ctx.reply(
+          `🎫 <b>Event Information</b>\n\n` +
+          `📋 <b>Title:</b> ${event.title || 'None'}\n` +
+          `🔗 <b>Slug:</b> ${event.slug || 'None'}\n` +
+          `🎫 <b>Ticketing URL Slug:</b> ${event.ticketingUrlSlug || 'None'}\n` +
+          `💰 <b>Starting Price:</b> ${event.startingPrice || 'None'} ${event.currencyCode || ''}\n\n` +
+          `ℹ️ <i>Detailed ticket information is currently unavailable. Please visit the event page for more details.</i>`,
+          { 
+            parse_mode: 'HTML',
+            ...getBackToMainMenuButton()
+          }
+        );
+      }
+    } catch (error) {
+      console.error('Error calling REST API with ticketingUrlSlug:', error);
+      // Send a fallback message when REST API fails
+      await ctx.reply(
+        `🎫 <b>Event Information</b>\n\n` +
+        `📋 <b>Title:</b> ${event.title || 'None'}\n` +
+        `🔗 <b>Slug:</b> ${event.slug || 'None'}\n` +
+        `🎫 <b>Ticketing URL Slug:</b> ${event.ticketingUrlSlug || 'None'}\n` +
+        `💰 <b>Starting Price:</b> ${event.startingPrice || 'None'} ${event.currencyCode || ''}\n\n` +
+        `ℹ️ <i>Detailed ticket information is currently unavailable. Please visit the event page for more details.</i>`,
+        { 
+          parse_mode: 'HTML',
+          ...getBackToMainMenuButton()
+        }
+      );
+    }
+  }
+
   return event;
 }
 

src/bots/services/WeBookBookingService.ts

@@ -42,8 +42,9 @@ export async function bookTicketsForAccount(
   withPayment: boolean,
   ticketsObtained: number,
   ticketsNeeded: number,
-  isLogin: boolean = true
+  isLogin: boolean = false
 ): Promise<BookingResult> {
+  
   let login: WeBookLogin | undefined;
   try {
     if (isLogin) {

src/index.ts

@@ -42,4 +42,4 @@ startServer();
 
 
 
-// handleAddTelegrafBot("1e186256-fdd6-453f-8344-fd824660b8bd")
+handleAddTelegrafBot("1e186256-fdd6-453f-8344-fd824660b8bd")

src/webook/book.ts

@@ -41,8 +41,8 @@ export class WeBookBooking extends WeBookBase {
       if (!(await this.areTicketsAvailable())) {
         return withPayment ? 0 : { ticketsCount: 0, paymentUrl: undefined };
       }
-
-      const ticketsCount = await this.selectMaxTickets();
+      // const ticketsCount = await this.selectMaxTickets();
+      const ticketsCount = await this.selectMaxTicketsSmart();
       await this.proceedToSummary();
       await this.skipToPaymentIfAvailable();
       await this.acceptTermsIfAvailable();
@@ -111,6 +111,50 @@ export class WeBookBooking extends WeBookBase {
     return clickCount ;
   }
 
+  /**
+   * Smart ticket selection: chooses seats from seat chart if present, otherwise uses plus button logic
+   * @param maxSeats number (default 10)
+   */
+  public async selectMaxTicketsSmart(maxSeats: number = 10): Promise<number> {
+    if (!this.page) throw new Error('Page not initialized');
+
+    // Check for seat chart
+    const seatChart = this.page.locator('[data-testid="seat-chart"]');
+    if (await seatChart.count() > 0) {
+      // Try to select seats from the chart
+      try {
+        // Wait for iframe inside seat chart
+        const iframeElement = seatChart.locator('iframe');
+        await iframeElement.waitFor({ state: 'attached', timeout: 10000 });
+        const frame = await iframeElement.first().contentFrame();
+        if (!frame) throw new Error('Could not get seat chart iframe content');
+
+        // Find available seats (update selector as needed)
+        const availableSeats = await frame.locator('.seatsio-seat.available, .seat.available').elementHandles();
+        let selected = 0;
+        for (const seat of availableSeats) {
+          if (selected >= maxSeats) break;
+          try {
+            await seat.click();
+            selected++;
+            await this.page.waitForTimeout(200);
+          } catch (e) {
+            continue;
+          }
+        }
+        console.info(`Selected ${selected} seats from seat chart`);
+        return selected;
+      } catch (e) {
+        console.warn('Failed to select from seat chart, falling back to plus button:', e);
+        // Fallback to plus button logic
+        return await this.selectMaxTickets();
+      }
+    } else {
+      // No seat chart, use plus button logic
+      return await this.selectMaxTickets();
+    }
+  }
+
   private async proceedToSummary() {
     const summaryButton = this.page.locator('[data-testid="ticketing_tickets_go_to_summary_button"]');
     await summaryButton.waitFor({ state: 'visible', timeout: 5000 });

src/webook/webookApi.ts

@@ -410,24 +410,68 @@ export async function getEventDetailsBySlug(
   visibleIn: string = 'rs'
 ): Promise<any | null> {
   try {
-    const url = `https://api.webook.com/api/v2/event-detail/${slug}?lang=${lang}&visible_in=${visibleIn}`;
+    // Try the public CDN endpoint first
+    const cdnUrl = `https://cdn.webook.com/api/v2/event-detail/${slug}?lang=${lang}&visible_in=${visibleIn}`;
     
-    const response = await axios.get(url, {
+    console.log('Trying CDN endpoint:', cdnUrl);
+    
+    const cdnResponse = await axios.get(cdnUrl, {
       headers: {
         "Accept": "*/*",
         "Accept-Encoding": "gzip, deflate, br, zstd",
         "Accept-Language": "en-US,en;q=0.9,ar;q=0.8",
         "User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36",
-      }
+        "Origin": "https://webook.com",
+        "Referer": "https://webook.com/",
+        "Sec-Fetch-Dest": "empty",
+        "Sec-Fetch-Mode": "cors",
+        "Sec-Fetch-Site": "same-site",
+        "Cache-Control": "no-cache",
+        "Pragma": "no-cache"
+      },
+      timeout: 10000
     });
 
-    if (response.data && response.data.status === 'success' && response.data.data) {
-      return response.data.data;
+    if (cdnResponse.data && cdnResponse.data.status === 'success' && cdnResponse.data.data) {
+      console.log('CDN endpoint successful');
+      return cdnResponse.data.data;
+    }
+    
+    // If CDN fails, try the API endpoint
+    const apiUrl = `https://api.webook.com/api/v2/event-detail/${slug}?lang=${lang}&visible_in=${visibleIn}`;
+    console.log('Trying API endpoint:', apiUrl);
+    
+    const apiResponse = await axios.get(apiUrl, {
+      headers: {
+        "Accept": "*/*",
+        "Accept-Encoding": "gzip, deflate, br, zstd",
+        "Accept-Language": "en-US,en;q=0.9,ar;q=0.8",
+        "User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36",
+        "Origin": "https://webook.com",
+        "Referer": "https://webook.com/",
+        "Sec-Fetch-Dest": "empty",
+        "Sec-Fetch-Mode": "cors",
+        "Sec-Fetch-Site": "same-site",
+        "Cache-Control": "no-cache",
+        "Pragma": "no-cache"
+      },
+      timeout: 10000
+    });
+
+    if (apiResponse.data && apiResponse.data.status === 'success' && apiResponse.data.data) {
+      console.log('API endpoint successful');
+      return apiResponse.data.data;
     }
     
     return null;
   } catch (error) {
     console.error('Error fetching event details by slug:', error);
+    // Log more details about the error
+    if (error.response) {
+      console.error('Response status:', error.response.status);
+      console.error('Response headers:', error.response.headers);
+      console.error('Response data:', error.response.data);
+    }
     return null;
   }
 }