diff --git a/deployment/docker/docker-compose.yaml b/deployment/docker/docker-compose.yaml index 2906f54..4a7b90f 100644 --- a/deployment/docker/docker-compose.yaml +++ b/deployment/docker/docker-compose.yaml @@ -94,7 +94,7 @@ services: condition: service_healthy env_file: stack.env hostname: knightcrawler-addon - image: gabisonfire/knightcrawler-addon:2.0.10 + image: gabisonfire/knightcrawler-addon:2.0.11 labels: logging: promtail networks: @@ -117,7 +117,7 @@ services: redis: condition: service_healthy env_file: stack.env - image: gabisonfire/knightcrawler-consumer:2.0.10 + image: gabisonfire/knightcrawler-consumer:2.0.11 labels: logging: promtail networks: @@ -138,7 +138,7 @@ services: redis: condition: service_healthy env_file: stack.env - image: gabisonfire/knightcrawler-debrid-collector:2.0.10 + image: gabisonfire/knightcrawler-debrid-collector:2.0.11 labels: logging: promtail networks: @@ -152,7 +152,7 @@ services: migrator: condition: service_completed_successfully env_file: stack.env - image: gabisonfire/knightcrawler-metadata:2.0.10 + image: gabisonfire/knightcrawler-metadata:2.0.11 networks: - knightcrawler-network restart: "no" @@ -163,7 +163,7 @@ services: postgres: condition: service_healthy env_file: stack.env - image: gabisonfire/knightcrawler-migrator:2.0.10 + image: gabisonfire/knightcrawler-migrator:2.0.11 networks: - knightcrawler-network restart: "no" @@ -182,7 +182,7 @@ services: redis: condition: service_healthy env_file: stack.env - image: gabisonfire/knightcrawler-producer:2.0.10 + image: gabisonfire/knightcrawler-producer:2.0.11 labels: logging: promtail networks: @@ -207,7 +207,7 @@ services: deploy: replicas: ${QBIT_REPLICAS:-0} env_file: stack.env - image: gabisonfire/knightcrawler-qbit-collector:2.0.10 + image: gabisonfire/knightcrawler-qbit-collector:2.0.11 labels: logging: promtail networks: diff --git a/deployment/docker/src/components/knightcrawler.yaml b/deployment/docker/src/components/knightcrawler.yaml index 830d0a7..274c1b2 100644 --- a/deployment/docker/src/components/knightcrawler.yaml +++ b/deployment/docker/src/components/knightcrawler.yaml @@ -20,7 +20,7 @@ x-depends: &knightcrawler-app-depends services: metadata: - image: gabisonfire/knightcrawler-metadata:2.0.10 + image: gabisonfire/knightcrawler-metadata:2.0.11 env_file: ../../.env networks: - knightcrawler-network @@ -30,7 +30,7 @@ services: condition: service_completed_successfully migrator: - image: gabisonfire/knightcrawler-migrator:2.0.10 + image: gabisonfire/knightcrawler-migrator:2.0.11 env_file: ../../.env networks: - knightcrawler-network @@ -40,7 +40,7 @@ services: condition: service_healthy addon: - image: gabisonfire/knightcrawler-addon:2.0.10 + image: gabisonfire/knightcrawler-addon:2.0.11 <<: [*knightcrawler-app, *knightcrawler-app-depends] restart: unless-stopped hostname: knightcrawler-addon @@ -48,22 +48,22 @@ services: - "7000:7000" consumer: - image: gabisonfire/knightcrawler-consumer:2.0.10 + image: gabisonfire/knightcrawler-consumer:2.0.11 <<: [*knightcrawler-app, *knightcrawler-app-depends] restart: unless-stopped debridcollector: - image: gabisonfire/knightcrawler-debrid-collector:2.0.10 + image: gabisonfire/knightcrawler-debrid-collector:2.0.11 <<: [*knightcrawler-app, *knightcrawler-app-depends] restart: unless-stopped producer: - image: gabisonfire/knightcrawler-producer:2.0.10 + image: gabisonfire/knightcrawler-producer:2.0.11 <<: [*knightcrawler-app, *knightcrawler-app-depends] restart: unless-stopped qbitcollector: - image: gabisonfire/knightcrawler-qbit-collector:2.0.10 + image: gabisonfire/knightcrawler-qbit-collector:2.0.11 <<: [*knightcrawler-app, *knightcrawler-app-depends] restart: unless-stopped depends_on: diff --git a/src/debrid-collector/Features/Worker/Requests.cs b/src/debrid-collector/Features/Worker/Requests.cs index b976dd7..6341da5 100644 --- a/src/debrid-collector/Features/Worker/Requests.cs +++ b/src/debrid-collector/Features/Worker/Requests.cs @@ -1,21 +1,21 @@ namespace DebridCollector.Features.Worker; -[EntityName("perform-metadata-request")] +[EntityName("perform-metadata-request-debrid-collector")] public record PerformMetadataRequest(Guid CorrelationId, string InfoHash) : CorrelatedBy; -[EntityName("torrent-metadata-response")] +[EntityName("torrent-metadata-response-debrid-collector")] public record GotMetadata(TorrentMetadataResponse Metadata) : CorrelatedBy { public Guid CorrelationId { get; init; } = Metadata.CorrelationId; } -[EntityName("write-metadata")] +[EntityName("write-metadata-debrid-collector")] public record WriteMetadata(Torrent Torrent, TorrentMetadataResponse Metadata, string ImdbId) : CorrelatedBy { public Guid CorrelationId { get; init; } = Metadata.CorrelationId; } -[EntityName("metadata-written")] +[EntityName("metadata-written-debrid-colloctor")] public record MetadataWritten(TorrentMetadataResponse Metadata) : CorrelatedBy { public Guid CorrelationId { get; init; } = Metadata.CorrelationId; diff --git a/src/qbit-collector/Features/Worker/Requests.cs b/src/qbit-collector/Features/Worker/Requests.cs index 6e03b0a..7cfdbb7 100644 --- a/src/qbit-collector/Features/Worker/Requests.cs +++ b/src/qbit-collector/Features/Worker/Requests.cs @@ -1,22 +1,24 @@ namespace QBitCollector.Features.Worker; -[EntityName("perform-metadata-request")] +[EntityName("perform-metadata-request-qbit-collector")] public record PerformQbitMetadataRequest(Guid CorrelationId, string InfoHash) : CorrelatedBy; -[EntityName("torrent-metadata-response")] +[EntityName("torrent-metadata-response-qbit-collector")] public record GotQbitMetadata(QBitMetadataResponse Metadata) : CorrelatedBy { public Guid CorrelationId { get; init; } = Metadata.CorrelationId; } -[EntityName("write-metadata")] +[EntityName("write-metadata-qbit-collector")] public record WriteQbitMetadata(Torrent Torrent, QBitMetadataResponse Metadata, string ImdbId) : CorrelatedBy { public Guid CorrelationId { get; init; } = Metadata.CorrelationId; } -[EntityName("metadata-written")] +[EntityName("metadata-written-qbit-collector")] public record QbitMetadataWritten(QBitMetadataResponse Metadata) : CorrelatedBy { public Guid CorrelationId { get; init; } = Metadata.CorrelationId; + + public QBitMetadataResponse Metadata { get; init; } = Metadata; } \ No newline at end of file