|
|
@@ -267,6 +267,7 @@ export class G2GTransferPusherService implements Pusher {
|
|
|
public async transferAttachments(tk: TransferKey): Promise<void> {
|
|
|
const BATCH_SIZE = 100;
|
|
|
|
|
|
+ const socket = this.crowi.socketIoService.getAdminSocket();
|
|
|
const { fileUploadService } = this.crowi;
|
|
|
const Attachment = this.crowi.model('Attachment');
|
|
|
|
|
|
@@ -292,19 +293,8 @@ export class G2GTransferPusherService implements Pusher {
|
|
|
try {
|
|
|
await this.doTransferAttachment(tk, attachment, fileStream);
|
|
|
}
|
|
|
- catch (errs) {
|
|
|
- logger.error(`Error occured when uploading attachment(ID=${attachment.id})`, errs);
|
|
|
- if (!Array.isArray(errs)) {
|
|
|
- // TODO: socker.emit(failed_to_transfer);
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- const err = errs[0];
|
|
|
- logger.error(err);
|
|
|
-
|
|
|
-
|
|
|
- // TODO: socker.emit(failed_to_transfer);
|
|
|
- return;
|
|
|
+ catch (err) {
|
|
|
+ logger.error(`Error occured when uploading attachment(ID=${attachment.id})`, err);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -332,6 +322,7 @@ export class G2GTransferPusherService implements Pusher {
|
|
|
}
|
|
|
catch (err) {
|
|
|
logger.error(err);
|
|
|
+ socket.emit('admin:onG2gError', { message: 'Failed to generate GROWI archive file', key: 'error_generate_growi_archive' });
|
|
|
throw err;
|
|
|
}
|
|
|
|
|
|
@@ -348,19 +339,10 @@ export class G2GTransferPusherService implements Pusher {
|
|
|
form.append('uploadConfigs', JSON.stringify(uploadConfigs));
|
|
|
await rawAxios.post('/_api/v3/g2g-transfer/', form, generateAxiosRequestConfigWithTransferKey(tk, form.getHeaders()));
|
|
|
}
|
|
|
- catch (errs) {
|
|
|
- logger.error(errs);
|
|
|
- if (!Array.isArray(errs)) {
|
|
|
- // TODO: socker.emit(failed_to_transfer);
|
|
|
- throw errs;
|
|
|
- }
|
|
|
-
|
|
|
- const err = errs[0];
|
|
|
+ catch (err) {
|
|
|
logger.error(err);
|
|
|
-
|
|
|
-
|
|
|
- // TODO: socker.emit(failed_to_transfer);
|
|
|
- throw errs;
|
|
|
+ socket.emit('admin:onG2gError', { message: 'Failed to send GROWI archive file to new GROWI', key: 'error_send_growi_archive' });
|
|
|
+ throw err;
|
|
|
}
|
|
|
|
|
|
if (shouldEmit) socket.emit('admin:onStartTransferAttachments', {});
|
|
|
@@ -370,6 +352,7 @@ export class G2GTransferPusherService implements Pusher {
|
|
|
}
|
|
|
catch (err) {
|
|
|
logger.error(err);
|
|
|
+ socket.emit('admin:onG2gError', { message: 'Failed to transfer attachments', key: 'error_upload_attachment' });
|
|
|
throw err;
|
|
|
}
|
|
|
|