Compare commits
1 Commits
migrate-to
...
fix-retry-
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
de1bf4caff |
@@ -947,6 +947,15 @@ export class MediaRequestSubscriber implements EntitySubscriberInterface<MediaRe
|
|||||||
try {
|
try {
|
||||||
await this.sendToRadarr(event.entity as MediaRequest);
|
await this.sendToRadarr(event.entity as MediaRequest);
|
||||||
await this.sendToSonarr(event.entity as MediaRequest);
|
await this.sendToSonarr(event.entity as MediaRequest);
|
||||||
|
} catch (e) {
|
||||||
|
logger.error('Error while sending to *arr in afterUpdate subscriber', {
|
||||||
|
label: 'Media Request',
|
||||||
|
requestId: (event.entity as MediaRequest).id,
|
||||||
|
errorMessage: e instanceof Error ? e.message : String(e),
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
await this.updateParentStatus(event.entity as MediaRequest);
|
await this.updateParentStatus(event.entity as MediaRequest);
|
||||||
|
|
||||||
if (event.entity.status === MediaRequestStatus.COMPLETED) {
|
if (event.entity.status === MediaRequestStatus.COMPLETED) {
|
||||||
@@ -958,11 +967,14 @@ export class MediaRequestSubscriber implements EntitySubscriberInterface<MediaRe
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
logger.error('Error in afterUpdate subscriber', {
|
logger.error(
|
||||||
label: 'Media Request',
|
'Error while updating parent status in afterUpdate subscriber',
|
||||||
requestId: (event.entity as MediaRequest).id,
|
{
|
||||||
errorMessage: e instanceof Error ? e.message : String(e),
|
label: 'Media Request',
|
||||||
});
|
requestId: (event.entity as MediaRequest).id,
|
||||||
|
errorMessage: e instanceof Error ? e.message : String(e),
|
||||||
|
}
|
||||||
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -974,14 +986,26 @@ export class MediaRequestSubscriber implements EntitySubscriberInterface<MediaRe
|
|||||||
try {
|
try {
|
||||||
await this.sendToRadarr(event.entity as MediaRequest);
|
await this.sendToRadarr(event.entity as MediaRequest);
|
||||||
await this.sendToSonarr(event.entity as MediaRequest);
|
await this.sendToSonarr(event.entity as MediaRequest);
|
||||||
await this.updateParentStatus(event.entity as MediaRequest);
|
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
logger.error('Error in afterInsert subscriber', {
|
logger.error('Error while sending to *arr in afterInsert subscriber', {
|
||||||
label: 'Media Request',
|
label: 'Media Request',
|
||||||
requestId: (event.entity as MediaRequest).id,
|
requestId: (event.entity as MediaRequest).id,
|
||||||
errorMessage: e instanceof Error ? e.message : String(e),
|
errorMessage: e instanceof Error ? e.message : String(e),
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
await this.updateParentStatus(event.entity as MediaRequest);
|
||||||
|
} catch (e) {
|
||||||
|
logger.error(
|
||||||
|
'Error while updating parent status in afterInsert subscriber',
|
||||||
|
{
|
||||||
|
label: 'Media Request',
|
||||||
|
requestId: (event.entity as MediaRequest).id,
|
||||||
|
errorMessage: e instanceof Error ? e.message : String(e),
|
||||||
|
}
|
||||||
|
);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public async afterRemove(event: RemoveEvent<MediaRequest>): Promise<void> {
|
public async afterRemove(event: RemoveEvent<MediaRequest>): Promise<void> {
|
||||||
|
|||||||
Reference in New Issue
Block a user