410 lines
18 KiB
JavaScript
410 lines
18 KiB
JavaScript
import _ from 'lodash';
|
|
import { outBid, pushPrice, updateBid } from '../../system/apis/bid.js';
|
|
import { sendMessage } from '../../system/apis/notification.js';
|
|
import { createOutBidLog } from '../../system/apis/out-bid-log.js';
|
|
import configs from '../../system/config.js';
|
|
import CONSTANTS from '../../system/constants.js';
|
|
import { convertAETtoUTC, isTimeReached, removeFalsyValues, takeSnapshot } from '../../system/utils.js';
|
|
import { ProductBid } from '../product-bid.js';
|
|
|
|
export class LangtonsProductBid extends ProductBid {
|
|
constructor({ ...prev }) {
|
|
super(prev);
|
|
}
|
|
|
|
// Hàm lấy thời gian kết thúc từ trang web
|
|
async getCloseTime() {
|
|
try {
|
|
// Kiểm tra xem có context của trang web không, nếu không thì trả về null
|
|
if (!this.page_context) return null;
|
|
|
|
await this.page_context.waitForSelector('.site-timezone', { timeout: 2000 });
|
|
const time = await this.page_context.evaluate(() => {
|
|
const el = document.querySelector('.site-timezone');
|
|
return el ? el.innerText : null;
|
|
});
|
|
|
|
return time ? convertAETtoUTC(time) : null;
|
|
|
|
// return new Date(Date.now() + 6 * 60 * 1000).toUTCString();
|
|
} catch (error) {
|
|
// Nếu có lỗi xảy ra trong quá trình lấy thời gian, trả về null
|
|
return null;
|
|
}
|
|
}
|
|
|
|
async waitForApiResponse(timeout = 15000) {
|
|
if (!this.page_context) {
|
|
console.error(`❌ [${this.id}] Error: page_context is undefined.`);
|
|
return null;
|
|
}
|
|
|
|
return new Promise((resolve) => {
|
|
const onResponse = async (response) => {
|
|
try {
|
|
if (!response || !response.request().url().includes(configs.WEB_CONFIGS.LANGTONS.API_CALL_TO_TRACKING)) {
|
|
return;
|
|
}
|
|
|
|
clearTimeout(timer); // Hủy timeout nếu có phản hồi
|
|
this.page_context.off('response', onResponse); // Gỡ bỏ listener
|
|
|
|
const data = await response.json();
|
|
resolve(data);
|
|
} catch (error) {
|
|
console.error(`❌ [${this.id}] Error while parsing response:`, error?.message);
|
|
resolve(null);
|
|
}
|
|
};
|
|
|
|
const timer = setTimeout(async () => {
|
|
console.log(`⏳ [${this.id}] Timeout: No response received within ${timeout / 1000}s`);
|
|
this.page_context.off('response', onResponse); // Gỡ bỏ listener khi timeout
|
|
|
|
await this.page_context.reload({ waitUntil: 'networkidle0' }); // reload page
|
|
|
|
console.log(`🔁 [${this.id}] Reload page in waitForApiResponse`);
|
|
resolve(null);
|
|
}, timeout);
|
|
|
|
this.page_context.on('response', onResponse);
|
|
});
|
|
}
|
|
|
|
async getName() {
|
|
try {
|
|
if (!this.page_context) return null;
|
|
|
|
await this.page_context.waitForSelector('.product-name', { timeout: 3000 });
|
|
|
|
return await this.page_context.evaluate(() => {
|
|
const el = document.querySelector('.product-name');
|
|
return el ? el.innerText : null;
|
|
});
|
|
} catch (error) {
|
|
return null;
|
|
}
|
|
}
|
|
|
|
async handleUpdateBid({ lot_id, close_time, name, current_price, reserve_price, model }) {
|
|
const response = await updateBid(this.id, { lot_id, close_time, name, current_price, reserve_price: Number(reserve_price) || 0, model });
|
|
|
|
if (response) {
|
|
this.lot_id = response.lot_id;
|
|
this.close_time = response.close_time;
|
|
this.start_bid_time = response.start_bid_time;
|
|
}
|
|
}
|
|
|
|
update = async () => {
|
|
if (!this.page_context) return;
|
|
|
|
console.log(`🔄 [${this.id}] Call update for ID: ${this.id}`);
|
|
|
|
// 📌 Lấy thời gian kết thúc đấu giá từ giao diện
|
|
const close_time = await this.getCloseTime();
|
|
console.log(`⏳ [${this.id}] Retrieved close time: ${close_time}`);
|
|
|
|
// 📌 Lấy tên sản phẩm hoặc thông tin liên quan
|
|
const name = await this.getName();
|
|
console.log(`📌 [${this.id}] Retrieved name: ${name}`);
|
|
|
|
// 📌 Chờ phản hồi API từ trang, tối đa 10 giây
|
|
const result = await this.waitForApiResponse();
|
|
|
|
// 📌 Nếu không có dữ liệu trả về thì dừng
|
|
if (!result) {
|
|
console.log(`⚠️ [${this.id}] No valid data received, skipping update.`);
|
|
return;
|
|
}
|
|
|
|
// 📌 Loại bỏ các giá trị không hợp lệ và bổ sung thông tin cần thiết
|
|
const data = removeFalsyValues(
|
|
{
|
|
model: result?.pid || null,
|
|
lot_id: result?.lotId || null,
|
|
reserve_price: 21, //test
|
|
// reserve_price: result.lotData?.minimumBid || null,
|
|
// current_price: result.lotData?.currentMaxBid || null,
|
|
current_price: 20, // test
|
|
// close_time: close_time && !this.close_time ? String(close_time) : null,
|
|
close_time: close_time ? String(close_time) : null,
|
|
name,
|
|
},
|
|
// [],
|
|
['close_time'],
|
|
);
|
|
|
|
console.log(`🚀 [${this.id}] Processed data ready for update`);
|
|
|
|
// 📌 Gửi dữ liệu cập nhật lên hệ thống
|
|
await this.handleUpdateBid(data);
|
|
|
|
console.log('✅ Update successful!');
|
|
|
|
return { ...response, name, close_time };
|
|
};
|
|
|
|
async getContinueShopButton() {
|
|
try {
|
|
if (!this.page_context) return null;
|
|
|
|
await this.page_context.waitForSelector('.btn.btn-block.btn-primary.error.continue-shopping', { timeout: 3000 });
|
|
|
|
return await this.page_context.evaluate(() => {
|
|
const el = document.querySelector('.btn.btn-block.btn-primary.error.continue-shopping');
|
|
|
|
return el;
|
|
});
|
|
} catch (error) {
|
|
return null;
|
|
}
|
|
}
|
|
|
|
async handlePlaceBid() {
|
|
if (!this.page_context) {
|
|
console.log(`⚠️ [${this.id}] No page context found, aborting bid process.`);
|
|
return;
|
|
}
|
|
const page = this.page_context;
|
|
|
|
if (global[`IS_PLACE_BID-${this.id}`]) {
|
|
console.log(`⚠️ [${this.id}] Bid is already in progress, skipping.`);
|
|
return;
|
|
}
|
|
|
|
try {
|
|
console.log(`🔄 [${this.id}] Starting bid process...`);
|
|
global[`IS_PLACE_BID-${this.id}`] = true;
|
|
|
|
const continueShopBtn = await this.getContinueShopButton();
|
|
if (continueShopBtn) {
|
|
console.log(`⚠️ [${this.id}] Outbid detected, calling outBid function.`);
|
|
await outBid(this.id);
|
|
return;
|
|
}
|
|
|
|
// Kiểm tra nếu giá hiện tại lớn hơn giá tối đa cộng thêm giá cộng thêm
|
|
if (this.current_price > this.max_price + this.plus_price) {
|
|
console.log(`⚠️ [${this.id}] Outbid bid`); // Ghi log cảnh báo nếu giá hiện tại vượt quá mức tối đa cho phép
|
|
return; // Dừng hàm nếu giá đã vượt qua giới hạn
|
|
}
|
|
|
|
// Kiểm tra thời gian bid
|
|
if (this.start_bid_time && !isTimeReached(this.start_bid_time)) {
|
|
console.log(`⏳ [${this.id}] Not yet time to bid. Skipping Product: ${this.name || 'None'}`);
|
|
return;
|
|
}
|
|
|
|
// Đợi phản hồi từ API
|
|
const response = await this.waitForApiResponse();
|
|
|
|
// Kiểm tra nếu phản hồi không tồn tại hoặc nếu giá đấu của người dùng bằng với giá tối đa hiện tại
|
|
if (!response || (response?.lotData?.myBid && response.lotData.myBid == this.max_price) || response?.lotData?.minimumBid > this.max_price) {
|
|
console.log(`⚠️ [${this.id}] No response or myBid equals max_price:`, response); // Ghi log nếu không có phản hồi hoặc giá đấu của người dùng bằng giá tối đa
|
|
return; // Nếu không có phản hồi hoặc giá đấu bằng giá tối đa thì dừng hàm
|
|
}
|
|
|
|
// Kiểm tra nếu dữ liệu trong response có tồn tại và trạng thái đấu giá (bidStatus) không phải là 'None'
|
|
if (response.lotData && response.lotData?.bidStatus !== 'None' && this.max_price == response?.lotData.myBid) {
|
|
console.log(`✔️ [${this.id}] Bid status is not 'None'. Current bid status:`, response.lotData?.bidStatus); // Ghi log nếu trạng thái đấu giá không phải 'None'
|
|
return; // Nếu trạng thái đấu giá không phải là 'None', dừng hàm
|
|
}
|
|
|
|
const bidHistoriesItem = _.maxBy(this.histories, 'price');
|
|
console.log(`📜 [${this.id}] Current bid history:`, this.histories);
|
|
|
|
if (bidHistoriesItem && bidHistoriesItem?.price === this.current_price && this.max_price == response?.lotData.myBid) {
|
|
console.log(`🔄 [${this.id}] You have already bid on this item! (Bid Price: ${bidHistoriesItem.price})`);
|
|
return;
|
|
}
|
|
|
|
console.log(`💰 [${this.id}] Placing a bid with amount: ${this.reserve_price}`);
|
|
|
|
// 📌 Làm rỗng ô input trước khi nhập giá đấu
|
|
await page.evaluate(() => {
|
|
document.querySelector('#place-bid').value = '';
|
|
});
|
|
|
|
console.log(`📝 [${this.id}] Cleared bid input field.`);
|
|
|
|
// 📌 Nhập giá đấu vào ô input
|
|
await page.type('#place-bid', String(this.max_price), { delay: 800 });
|
|
console.log(`✅ [${this.id}] Entered bid amount: ${this.max_price}`);
|
|
|
|
// 📌 Lấy giá trị thực tế từ ô input sau khi nhập
|
|
const bidValue = await page.evaluate(() => document.querySelector('#place-bid').value);
|
|
console.log(`🔍 Entered bid value: ${bidValue}`);
|
|
|
|
// 📌 Kiểm tra nếu giá trị nhập vào không khớp với giá trị mong muốn
|
|
if (!bidValue || bidValue !== String(this.max_price)) {
|
|
console.log(`❌ Incorrect bid amount! Received: ${bidValue}`);
|
|
return; // Dừng thực hiện nếu giá trị nhập sai
|
|
}
|
|
|
|
// 📌 Nhấn nút "Place Bid"
|
|
await page.click('.place-bid-submit .btn.btn-primary.btn-block.place-bid-btn', { delay: 5000 });
|
|
console.log(`🖱️ [${this.id}] Clicked "Place Bid" button.`);
|
|
|
|
console.log(`📩 [${this.id}] Bid submitted, waiting for navigation...`);
|
|
|
|
// 📌 Chờ trang load lại để cập nhật trạng thái đấu giá
|
|
await page.waitForNavigation({ timeout: 8000, waitUntil: 'domcontentloaded' });
|
|
|
|
console.log(`🔄 [${this.id}] Page reloaded, checking bid status...`);
|
|
|
|
const { lotData } = await this.waitForApiResponse();
|
|
console.log(`📡 [${this.id}] API Response received:`, lotData);
|
|
|
|
// 📌 Kiểm tra trạng thái đấu giá từ API
|
|
if (lotData?.myBid == this.max_price) {
|
|
console.log(`📸 [${this.id}] Taking bid success snapshot...`);
|
|
await takeSnapshot(page, this, 'bid-success', CONSTANTS.TYPE_IMAGE.SUCCESS);
|
|
|
|
sendMessage(this);
|
|
|
|
console.log(`✅ [${this.id}] Bid placed successfully!`);
|
|
return;
|
|
}
|
|
|
|
console.log(`⚠️ [${this.id}] Bid action completed, but status is still "None".`);
|
|
} catch (error) {
|
|
console.log(`🚨 [${this.id}] Error placing bid: ${error.message}`);
|
|
} finally {
|
|
console.log(`🔚 [${this.id}] Resetting bid flag.`);
|
|
global[`IS_PLACE_BID-${this.id}`] = false;
|
|
}
|
|
}
|
|
|
|
async handleCreateLogsOnServer(data) {
|
|
const values = data.map((item) => {
|
|
return {
|
|
model: item.pid,
|
|
lot_id: item.lotId,
|
|
out_price: item.lotData.minimumBid || 0,
|
|
raw_data: JSON.stringify(item),
|
|
};
|
|
});
|
|
|
|
await createOutBidLog(values);
|
|
}
|
|
|
|
async gotoLink() {
|
|
const page = this.page_context;
|
|
|
|
if (page.isClosed()) {
|
|
console.error(`❌ [${this.id}] Page has been closed, cannot navigate.`);
|
|
return;
|
|
}
|
|
|
|
console.log(`🔄 [${this.id}] Starting the bidding process...`);
|
|
|
|
try {
|
|
console.log(`🌐 [${this.id}] Navigating to: ${this.url} ...`);
|
|
await page.goto(this.url, { waitUntil: 'networkidle2' });
|
|
console.log(`✅ [${this.id}] Successfully navigated to: ${this.url}`);
|
|
|
|
console.log(`🖥️ [${this.id}] Bringing tab to the foreground...`);
|
|
await page.bringToFront();
|
|
|
|
console.log(`🛠️ [${this.id}] Setting custom user agent...`);
|
|
await page.setUserAgent('Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36');
|
|
|
|
console.log(`🎯 [${this.id}] Listening for API responses...`);
|
|
|
|
// // 🔥 Xóa tất cả event chặn request trước khi thêm mới
|
|
// page.removeAllListeners('request');
|
|
|
|
// await page.setRequestInterception(true);
|
|
|
|
// page.on('request', (request) => {
|
|
// if (request.url().includes(configs.WEB_CONFIGS.LANGTONS.API_CALL_TO_TRACKING)) {
|
|
// console.log('🚀 Fake response cho request:', request.url());
|
|
|
|
// const fakeData = fs.readFileSync('./data/fake-out-lot-langtons.json', 'utf8');
|
|
|
|
// request.respond({
|
|
// status: 200,
|
|
// contentType: 'application/json',
|
|
// body: fakeData,
|
|
// });
|
|
// } else {
|
|
// try {
|
|
// request.continue(); // ⚠️ Chỉ tiếp tục nếu request chưa bị chặn
|
|
// } catch (error) {
|
|
// console.error('⚠️ Lỗi khi tiếp tục request:', error.message);
|
|
// }
|
|
// }
|
|
// });
|
|
|
|
const onResponse = async (response) => {
|
|
const url = response?.request()?.url();
|
|
if (!url || !url.includes(configs.WEB_CONFIGS.LANGTONS.API_CALL_TO_TRACKING)) {
|
|
return;
|
|
}
|
|
|
|
try {
|
|
const { lotData, ...prev } = await response.json();
|
|
console.log(`📜 [${this.id}] Received lotData:`, lotData);
|
|
|
|
if (!lotData || lotData.lotId !== this.lot_id) {
|
|
console.log(`⚠️ [${this.id}] Ignored response for lotId: ${lotData?.lotId}`);
|
|
await this.page_context.reload({ waitUntil: 'networkidle0' });
|
|
console.log(`🔁 [${this.id}] Reload page in gotoLink`);
|
|
return;
|
|
}
|
|
|
|
console.log(`🔍 [${this.id}] Checking bid status...`);
|
|
|
|
if (['Outbid'].includes(lotData?.bidStatus)) {
|
|
console.log(`⚠️ [${this.id}] Outbid detected, attempting to place a new bid...`);
|
|
|
|
this.handleCreateLogsOnServer([{ lotData, ...prev }]);
|
|
} else if (['Winning'].includes(lotData?.bidStatus)) {
|
|
const bidHistoriesItem = _.maxBy(this.histories, 'price');
|
|
|
|
if (!bidHistoriesItem || bidHistoriesItem?.price != lotData?.currentMaxBid) {
|
|
pushPrice({
|
|
bid_id: this.id,
|
|
price: lotData?.currentMaxBid,
|
|
});
|
|
}
|
|
}
|
|
|
|
if (lotData.myBid && this.max_price && this.max_price != lotData.myBid) {
|
|
this.handlePlaceBid();
|
|
}
|
|
} catch (error) {
|
|
console.error(`🚨 [${this.id}] Error parsing API response:`, error);
|
|
}
|
|
};
|
|
|
|
console.log(`🔄 [${this.id}] Removing previous response listeners...`);
|
|
this.page_context.off('response', onResponse);
|
|
|
|
console.log(`📡 [${this.id}] Attaching new response listener...`);
|
|
this.page_context.on('response', onResponse);
|
|
|
|
console.log(`✅ [${this.id}] Navigation setup complete.`);
|
|
} catch (error) {
|
|
console.error(`❌ [${this.id}] Error during navigation:`, error);
|
|
}
|
|
}
|
|
|
|
action = async () => {
|
|
try {
|
|
const page = this.page_context;
|
|
|
|
// 📌 Kiểm tra nếu trang chưa tải đúng URL thì điều hướng đến URL mục tiêu
|
|
if (!page.url() || !page.url().includes(this.url)) {
|
|
console.log(`🔄 [${this.id}] Navigating to target URL: ${this.url}`);
|
|
await this.gotoLink();
|
|
}
|
|
|
|
await this.handlePlaceBid();
|
|
} catch (error) {
|
|
console.error(`🚨 [${this.id}] Error navigating the page: ${error}`);
|
|
}
|
|
};
|
|
}
|