Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: retry logic for nvidia session token and adding to cart (#347)
- Loading branch information
1 parent
3bde805
commit 1bac1b9
Showing
6 changed files
with
224 additions
and
110 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,174 @@ | ||
| import {NvidiaRegionInfo, regionInfos} from '../nvidia-api'; | ||
| import {usingPage, usingResponse} from '../../../util'; | ||
| import {Browser} from 'puppeteer'; | ||
| import {Config} from '../../../config'; | ||
| import {Logger} from '../../../logger'; | ||
| import open from 'open'; | ||
|
|
||
| interface NvidiaSessionTokenJSON { | ||
| session_token: string; | ||
| } | ||
|
|
||
| interface NvidiaAddToCardJSON { | ||
| location: string; | ||
| } | ||
|
|
||
| export class NvidiaCart { | ||
| protected readonly browser: Browser; | ||
| protected isKeepAlive = false; | ||
| protected sessionToken: string | null = null; | ||
|
|
||
| public constructor(browser: Browser) { | ||
| this.browser = browser; | ||
| } | ||
|
|
||
| public keepAlive() { | ||
| if (this.isKeepAlive) { | ||
| return; | ||
| } | ||
|
|
||
| const callback = async () => { | ||
| if (!this.isKeepAlive) { | ||
| return; | ||
| } | ||
|
|
||
| await this.refreshSessionToken(); | ||
|
|
||
| setTimeout(callback, Config.nvidia.sessionTtl); | ||
| }; | ||
|
|
||
| this.isKeepAlive = true; | ||
|
|
||
| void callback(); | ||
| } | ||
|
|
||
| public get fallbackCartUrl(): string { | ||
| return `https://www.nvidia.com/${this.regionInfo.siteLocale}/geforce/`; | ||
| } | ||
|
|
||
| public get regionInfo(): NvidiaRegionInfo { | ||
| const country = Config.store.country; | ||
| const regionInfo = regionInfos.get(country); | ||
| if (!regionInfo) { | ||
| throw new Error(`Unknown country ${country}`); | ||
| } | ||
|
|
||
| return regionInfo; | ||
| } | ||
|
|
||
| public get sessionUrl(): string { | ||
| return `https://store.nvidia.com/store/nvidia/SessionToken?format=json&locale=${this.regionInfo.drLocale}`; | ||
| } | ||
|
|
||
| public async addToCard(productId: number, name: string): Promise<string> { | ||
| let cartUrl: string | undefined; | ||
| Logger.info(`🚀🚀🚀 [nvidia] ${name}, starting auto add to cart 🚀🚀🚀`); | ||
| try { | ||
| Logger.info(`🚀🚀🚀 [nvidia] ${name}, adding to cart 🚀🚀🚀`); | ||
| let lastError: Error | string | undefined; | ||
|
|
||
| /* eslint-disable no-await-in-loop */ | ||
| for (let i = 0; i < Config.nvidia.addToCardAttempts; i++) { | ||
| try { | ||
| cartUrl = await this.addToCartAndGetLocationRedirect(productId); | ||
|
|
||
| break; | ||
| } catch (error) { | ||
| Logger.error(`✖ [nvidia] ${name} could not automatically add to cart, attempt ${i + 1} of ${Config.nvidia.addToCardAttempts}`, error); | ||
| Logger.debug(error); | ||
|
|
||
| lastError = error; | ||
| } | ||
| } | ||
| /* eslint-enable no-await-in-loop */ | ||
|
|
||
| if (!cartUrl) { | ||
| // eslint-disable-next-line @typescript-eslint/no-throw-literal | ||
| throw lastError; | ||
| } | ||
|
|
||
| Logger.info(`🚀🚀🚀 [nvidia] ${name}, opening checkout page 🚀🚀🚀`); | ||
| Logger.info(cartUrl); | ||
|
|
||
| await open(cartUrl); | ||
| } catch (error) { | ||
| Logger.error(`✖ [nvidia] ${name} could not automatically add to cart, opening page`); | ||
| Logger.debug(error); | ||
|
|
||
| cartUrl = this.fallbackCartUrl; | ||
|
|
||
| await open(cartUrl); | ||
| } | ||
|
|
||
| return cartUrl; | ||
| } | ||
|
|
||
| public async getSessionToken(): Promise<string> { | ||
| if (!this.sessionToken) { | ||
| await this.refreshSessionToken(); | ||
| } | ||
|
|
||
| if (!this.sessionToken) { | ||
| throw new Error('Failed to create the session_token'); | ||
| } | ||
|
|
||
| return this.sessionToken; | ||
| } | ||
|
|
||
| public async refreshSessionToken(): Promise<void> { | ||
| Logger.debug('ℹ [nvidia] refreshing session token'); | ||
| try { | ||
| const result = await usingResponse(this.browser, this.sessionUrl, async response => { | ||
| return response?.json() as NvidiaSessionTokenJSON | undefined; | ||
| }); | ||
| if (typeof result !== 'object' || result === null || !('session_token' in result)) { | ||
| throw new Error('malformed response'); | ||
| } | ||
|
|
||
| this.sessionToken = result.session_token; | ||
| Logger.debug(`ℹ [nvidia] session_token=${result.session_token}`); | ||
| } catch (error) { | ||
| const message: string = typeof error === 'object' ? error.message : error; | ||
| Logger.error(`✖ [nvidia] ${message}`); | ||
| } | ||
| } | ||
|
|
||
| protected async addToCartAndGetLocationRedirect(productId: number): Promise<string> { | ||
| const url = 'https://api-prod.nvidia.com/direct-sales-shop/DR/add-to-cart'; | ||
| const sessionToken = await this.getSessionToken(); | ||
|
|
||
| Logger.info(`ℹ [nvidia] session_token=${sessionToken}`); | ||
|
|
||
| const locationData = await usingPage(this.browser, async page => { | ||
| page.removeAllListeners('request'); | ||
|
|
||
| await page.setRequestInterception(true); | ||
|
|
||
| page.on('request', interceptedRequest => { | ||
| void interceptedRequest.continue({ | ||
| headers: { | ||
| ...interceptedRequest.headers(), | ||
| 'content-type': 'application/json', | ||
| nvidia_shop_id: sessionToken | ||
| }, | ||
| method: 'POST', | ||
| postData: JSON.stringify({ | ||
| products: [ | ||
| {productId, quantity: 1} | ||
| ] | ||
| }) | ||
| }); | ||
| }); | ||
|
|
||
| const response = await page.goto(url, {waitUntil: 'networkidle0'}); | ||
|
|
||
| if (response === null) { | ||
| throw new Error('NvidiaAddToCartUnavailable'); | ||
| } | ||
|
|
||
| return response.json() as Promise<NvidiaAddToCardJSON>; | ||
| }); | ||
|
|
||
| return locationData.location; | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.