118
119
async createSyncTask(manifest: IUserDataManifest | null, disableCache?: boolean): Promise<IUserDataSyncTask> {
121
>
122
>
this.logService.info('Sync started.');
123
>
const startTime = new Date().getTime();
124
>
const executionId = generateUuid();
125
>
try {
126
>
const syncHeaders = createSyncHeaders(executionId);
127
>
if (disableCache) {
128
syncHeaders['Cache-Control'] = 'no-cache';
129
}
130
>
manifest = await this.userDataSyncStoreService.manifest(manifest, syncHeaders);
userDataSyncService.ts
131
>
} catch (error) {
132
const userDataSyncError = UserDataSyncError.toUserDataSyncError(error);
133
reportUserDataSyncError(userDataSyncError, executionId, this.userDataSyncStoreManagementService, this.telemetryService);
134
throw userDataSyncError;
135
}
137
>
const executed = false;
138
>
const that = this;
139
>
let cancellablePromise: CancelablePromise<void> | undefined;
140
>
return {
141
>
manifest,
142
>
async run(): Promise<void> {
143
>
if (executed) {
144
throw new Error('Can run a task only once');
145
}
146
>
cancellablePromise = createCancelablePromise(token => that.sync(manifest, false, executionId, token));
userDataSyncService.ts
147
>
await cancellablePromise.finally(() => cancellablePromise = undefined);
148
that.logService.info(`Sync done. Took ${new Date().getTime() - startTime}ms`);
149
that.updateLastSyncTime();
151
>
stop(): Promise<void> {
152
cancellablePromise?.cancel();
153
return that.stop();
154
}
156
>
}
157
158
async createManualSyncTask(): Promise<IUserDataManualSyncTask> {