Skip to content

Commit f52afd0

Browse files
committed
fix: use fixed jsforce autoFetch, restore ut
1 parent 9710b23 commit f52afd0

File tree

2 files changed

+3
-23
lines changed

2 files changed

+3
-23
lines changed

src/shared/remoteSourceTrackingService.ts

+2-22
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@ import { ConfigFile, Logger, Org, Messages, Lifecycle, SfError } from '@salesfor
1414
import { ComponentStatus } from '@salesforce/source-deploy-retrieve';
1515
import { Dictionary, Optional } from '@salesforce/ts-types';
1616
import { env, Duration } from '@salesforce/kit';
17-
import { QueryResult } from 'jsforce';
1817
import { ChangeResult, RemoteChangeElement, MemberRevision, SourceMember, RemoteSyncInput } from './types';
1918
import { getMetadataKeyFromFileResponse, mappingsForSourceMemberTypesToMetadataType } from './metadataKeys';
2019
import { getMetadataKey } from './functions';
@@ -643,27 +642,8 @@ export class RemoteSourceTrackingService extends ConfigFile<RemoteSourceTracking
643642
}
644643

645644
try {
646-
const result: QueryResult<SourceMember> = await new Promise((resolve, reject) => {
647-
const records: SourceMember[] = [];
648-
const res = this.org
649-
.getConnection()
650-
.tooling.query<SourceMember>(query)
651-
.on('record', (rec) => records.push(rec))
652-
.on('error', (err) => reject(err))
653-
.on('end', () => {
654-
resolve({
655-
done: true,
656-
totalSize: res.totalSize ?? 0,
657-
records,
658-
});
659-
})
660-
.run({
661-
autoFetch: true,
662-
maxFetch: 5000000,
663-
});
664-
});
665-
666-
return result.records;
645+
return (await this.org.getConnection().tooling.query<SourceMember>(query, { autoFetch: true, maxFetch: 50000 }))
646+
.records;
667647
} catch (error) {
668648
throw SfError.wrap(error as Error);
669649
}

test/unit/remoteSourceTracking.test.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ const getMemberRevisionEntries = (revision: number, synced = false): { [key: str
4040
return sourceMemberEntries;
4141
};
4242

43-
describe.skip('remoteSourceTrackingService', () => {
43+
describe('remoteSourceTrackingService', () => {
4444
const username = 'foo@bar.com';
4545
const orgId = '00D456789012345';
4646
const $$ = instantiateContext();

0 commit comments

Comments
 (0)