-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add task token and answer token checks
- Loading branch information
1 parent
50ee536
commit 66f5e36
Showing
9 changed files
with
305 additions
and
172 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
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,143 @@ | ||
| import got from 'got'; | ||
| import { | ||
| decodePlatformTaskToken, PlatformAnswerTokenPayload, | ||
| PlatformGenericTokenPayload, | ||
| PlatformTaskTokenPayload, | ||
| } from './tokenization'; | ||
| import appConfig from './config'; | ||
| import * as Db from './db'; | ||
| import {Platform} from './db_models'; | ||
| import {InvalidInputError, PlatformInteractionError} from './error_handler'; | ||
|
|
||
| export interface PlatformTaskTokenData { | ||
| payload: PlatformTaskTokenPayload, | ||
| idTaskLocal: string, | ||
| platform: Platform, | ||
| } | ||
|
|
||
| export interface PlatformAnswerTokenData { | ||
| payload: PlatformAnswerTokenPayload, | ||
| idTaskLocal: string, | ||
| platform: Platform, | ||
| } | ||
|
|
||
| export async function extractPlatformTaskTokenData(token: string|null|undefined, platformName: string|null|undefined, taskId: string|null = null): Promise<PlatformTaskTokenData> { | ||
| const platformEntity = await getPlatformByName(platformName); | ||
| let payload: PlatformTaskTokenPayload; | ||
| try { | ||
| payload = await decodePlatformTaskToken<PlatformTaskTokenPayload>(token, platformEntity); | ||
| } catch (e) { | ||
| if (appConfig.testMode.enabled && null !== taskId) { | ||
| payload = getTestTokenParameters(taskId); | ||
| } else { | ||
| throw e; | ||
| } | ||
| } | ||
|
|
||
| if (!payload.idUser || (!payload.idItem && !payload.itemUrl)) { | ||
| throw new InvalidInputError('Missing idUser or idItem in token'); | ||
| } | ||
|
|
||
| return { | ||
| payload: payload, | ||
| idTaskLocal: await getLocalIdTask(payload), | ||
| platform: platformEntity, | ||
| }; | ||
| } | ||
|
|
||
| export async function extractPlatformAnswerTaskTokenData(token: string|null|undefined, platformName: string|null|undefined, taskId: string|null = null): Promise<PlatformAnswerTokenData> { | ||
| const platformEntity = await getPlatformByName(platformName); | ||
| let payload: PlatformAnswerTokenPayload; | ||
| try { | ||
| payload = await decodePlatformTaskToken<PlatformAnswerTokenPayload>(token, platformEntity); | ||
| } catch (e) { | ||
| if (appConfig.testMode.enabled && null !== taskId) { | ||
| payload = getTestTokenParameters(taskId); | ||
| } else { | ||
| throw e; | ||
| } | ||
| } | ||
|
|
||
| if (!payload.idUser || (!payload.idItem && !payload.itemUrl)) { | ||
| throw new InvalidInputError('Missing idUser or idItem in token'); | ||
| } | ||
|
|
||
| return { | ||
| payload: payload, | ||
| idTaskLocal: await getLocalIdTask(payload), | ||
| platform: platformEntity, | ||
| }; | ||
| } | ||
|
|
||
| function getIdFromUrl(itemUrl: string): string|null { | ||
| const urlSearchParams = (new URL(itemUrl)).searchParams; | ||
| const params = Object.fromEntries(urlSearchParams.entries()); | ||
|
|
||
| return params['taskId'] ? params['taskId'] : null; | ||
| } | ||
|
|
||
| async function getLocalIdTask(params: PlatformGenericTokenPayload): Promise<string> { | ||
| const idItem = params.idItem || null; | ||
| const itemUrl = params.itemUrl || null; | ||
| if (itemUrl) { | ||
| const id = getIdFromUrl(itemUrl); | ||
| if (!id) { | ||
| throw new InvalidInputError('Cannot find ID in url ' + itemUrl); | ||
| } | ||
|
|
||
| return id; | ||
| } | ||
|
|
||
| const id = await Db.querySingleScalarResult<string>('SELECT ID FROM tm_tasks WHERE sTextId = ?', [idItem]); | ||
| if (!id) { | ||
| throw new InvalidInputError(`Cannot find task ${idItem || ''}`); | ||
| } | ||
|
|
||
| return id; | ||
| } | ||
|
|
||
| function getTestTokenParameters(taskId: string): PlatformTaskTokenPayload { | ||
| return { | ||
| idUser: appConfig.testMode.userId ? appConfig.testMode.userId : null, | ||
| bSubmissionPossible: true, | ||
| itemUrl: appConfig.baseUrl ? appConfig.baseUrl + '?taskId=' + taskId : null, | ||
| bAccessSolutions: appConfig.testMode.accessSolutions, | ||
| nbHintsGiven: appConfig.testMode.nbHintsGiven, | ||
| }; | ||
| } | ||
|
|
||
| export async function askPlatformAnswerToken(taskToken: string, answer: string, platform: Platform): Promise<string> { | ||
| const platformUrl = `${platform.api_url}/answers`; | ||
|
|
||
| const askAnswerTokenRequest = { | ||
| answer, | ||
| task_token: taskToken, | ||
| }; | ||
|
|
||
| const gotResponse = await got.post(platformUrl, { | ||
| headers: { | ||
| 'content-type': 'application/json', | ||
| Cookie: 'access_token=3!6iebvzan0hf3g5w8h34ang33c09pzrkm!beta.opentezos.com!/api/', | ||
| }, | ||
| json: askAnswerTokenRequest, | ||
| }).json<{success: boolean, data?: {answer_token: string}}>(); | ||
|
|
||
| if (!gotResponse.success) { | ||
| throw new PlatformInteractionError('Impossible to fetch answer token from platform'); | ||
| } | ||
|
|
||
| return gotResponse.data?.answer_token!; | ||
| } | ||
|
|
||
| export async function getPlatformByName(platformName?: string|null): Promise<Platform> { | ||
| if (!platformName && appConfig.testMode.enabled && appConfig.testMode.platformName) { | ||
| platformName = appConfig.testMode.platformName; | ||
| } | ||
|
|
||
| const platforms = await Db.execute<Platform[]>('SELECT * FROM tm_platforms WHERE name = ?', [platformName]); | ||
| if (!platforms.length) { | ||
| throw new InvalidInputError(`Cannot find platform ${platformName || ''}`); | ||
| } | ||
|
|
||
| return platforms[0]; | ||
| } |
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.