|
@ -70,14 +70,14 @@ export class AdminController { |
|
|
@UseGuards(AuthGuard('jwt')) |
|
|
@UseGuards(AuthGuard('jwt')) |
|
|
@HasPermission(permissions.accessAdminControl) |
|
|
@HasPermission(permissions.accessAdminControl) |
|
|
public async gather7Days(): Promise<void> { |
|
|
public async gather7Days(): Promise<void> { |
|
|
this.dataGatheringService.gather7Days(); |
|
|
this.dataGatheringService.gather7Days(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
@Post('gather/max') |
|
|
@Post('gather/max') |
|
|
@UseGuards(AuthGuard('jwt')) |
|
|
@UseGuards(AuthGuard('jwt')) |
|
|
@HasPermission(permissions.accessAdminControl) |
|
|
@HasPermission(permissions.accessAdminControl) |
|
|
public async gatherMax(): Promise<void> { |
|
|
public async gatherMax(): Promise<void> { |
|
|
const uniqueAssets = await this.dataGatheringService.getUniqueAssets(); |
|
|
const uniqueAssets = await this.dataGatheringService.getUniqueAssets(); |
|
|
|
|
|
|
|
|
await this.dataGatheringService.addJobsToQueue( |
|
|
await this.dataGatheringService.addJobsToQueue( |
|
|
uniqueAssets.map(({ dataSource, symbol }) => { |
|
|
uniqueAssets.map(({ dataSource, symbol }) => { |
|
@ -161,7 +161,7 @@ export class AdminController { |
|
|
@Param('dateString') dateString: string, |
|
|
@Param('dateString') dateString: string, |
|
|
@Param('symbol') symbol: string |
|
|
@Param('symbol') symbol: string |
|
|
): Promise<MarketData> { |
|
|
): Promise<MarketData> { |
|
|
const date = parseISO(dateString); |
|
|
const date = parseISO(dateString); |
|
|
|
|
|
|
|
|
if (!isDate(date)) { |
|
|
if (!isDate(date)) { |
|
|
throw new HttpException( |
|
|
throw new HttpException( |
|
@ -189,7 +189,7 @@ export class AdminController { |
|
|
@Query('sortDirection') sortDirection?: Prisma.SortOrder, |
|
|
@Query('sortDirection') sortDirection?: Prisma.SortOrder, |
|
|
@Query('take') take?: number |
|
|
@Query('take') take?: number |
|
|
): Promise<AdminMarketData> { |
|
|
): Promise<AdminMarketData> { |
|
|
const filters = this.apiService.buildFiltersFromQueryParams({ |
|
|
const filters = this.apiService.buildFiltersFromQueryParams({ |
|
|
filterByAssetSubClasses, |
|
|
filterByAssetSubClasses, |
|
|
filterBySearchQuery |
|
|
filterBySearchQuery |
|
|
}); |
|
|
}); |
|
@ -222,7 +222,7 @@ export class AdminController { |
|
|
@Param('dataSource') dataSource: DataSource, |
|
|
@Param('dataSource') dataSource: DataSource, |
|
|
@Param('symbol') symbol: string |
|
|
@Param('symbol') symbol: string |
|
|
) { |
|
|
) { |
|
|
const dataBulkUpdate: Prisma.MarketDataUpdateInput[] = data.marketData.map( |
|
|
const dataBulkUpdate: Prisma.MarketDataUpdateInput[] = data.marketData.map( |
|
|
({ date, marketPrice }) => ({ |
|
|
({ date, marketPrice }) => ({ |
|
|
dataSource, |
|
|
dataSource, |
|
|
marketPrice, |
|
|
marketPrice, |
|
|