File tree Expand file tree Collapse file tree 3 files changed +8
-3
lines changed Expand file tree Collapse file tree 3 files changed +8
-3
lines changed Original file line number Diff line number Diff line change 11import constants from 'dotaconstants' ;
22import moment from 'moment' ;
3- import { Client } from 'pg' ;
3+ import pg from 'pg' ;
44import config from '../../config.ts' ;
55import { addJob , addReliableJob , getReliableJob } from '../store/queue.ts' ;
66import { search } from '../store/search.ts' ;
@@ -96,6 +96,7 @@ import TeamObjectResponse from './responses/TeamObjectResponse.ts';
9696import TeamPlayersResponse from './responses/TeamPlayersResponse.ts' ;
9797
9898const { heroes : heroesConstants , cluster } = constants ;
99+ const Client = pg . Client ;
99100
100101const parameters = {
101102 ...heroParams ,
Original file line number Diff line number Diff line change @@ -3,9 +3,11 @@ import redis from './redis.ts';
33import db from './db.ts' ;
44import { Redis } from 'ioredis' ;
55import config from '../../config.ts' ;
6- import { Client } from 'pg' ;
6+ import pg from 'pg' ;
77import c from 'ansi-colors' ;
88
9+ const Client = pg . Client ;
10+
911moment . relativeTimeThreshold ( 'ss' , 0 ) ;
1012
1113export async function runQueue (
Original file line number Diff line number Diff line change 11import config from '../../config.ts' ;
22import { matchArchive , playerArchive } from '../store/archive.ts' ;
33import QueryStream from 'pg-query-stream' ;
4- import { Client } from 'pg' ;
4+ import pg from 'pg' ;
55import db from '../store/db.ts' ;
66import type { PutObjectCommandOutput } from '@aws-sdk/client-s3' ;
77import { getFullPlayerMatchesWithMetadata } from './buildPlayer.ts' ;
88import { getMatchDataFromBlobWithMetadata } from './buildMatch.ts' ;
99import { isDataComplete , randomInt , redisCount } from './utility.ts' ;
1010
11+ const Client = pg . Client ;
12+
1113async function processMatch ( matchId : number ) {
1214 // Check if we should archive the blobs (should be parsed and not archived)
1315 // const isParsed = await checkIsParsed(matchId);
You can’t perform that action at this time.
0 commit comments