refactor: ♻️ use the @axinom/mosaic-video-messages library where necessary (#445)

EmperorRXF · web-flow · commit 6e304ffb272d · 2025-06-04T11:43:24.000+02:00
diff --git a/libs/media-messages/package.json b/libs/media-messages/package.json
@@ -21,7 +21,7 @@
     "build:compile": "tsc"
   },
   "devDependencies": {
-    "@axinom/mosaic-cli": "0.45.0-rc.4",
+    "@axinom/mosaic-cli": "0.46.0-rc.2",
     "@axinom/mosaic-message-bus-abstractions": "0.24.0-rc.9",
     "@types/glob": "^7.2.0",
     "chokidar-cli": "^3.0.0",
diff --git a/package.json b/package.json
@@ -56,7 +56,7 @@
     "yarn:de-dupe": "npx yarn-deduplicate yarn.lock"
   },
   "devDependencies": {
-    "@axinom/mosaic-cli": "0.45.0-rc.4",
+    "@axinom/mosaic-cli": "0.46.0-rc.2",
     "@jest/globals": "^29.5.0",
     "@types/jest": "^29.4.1",
     "@types/node": "^18.11.19",
@@ -112,4 +112,4 @@
     "jest-cli": "^29",
     "jsonpath-plus": "^10.2.0"
   }
-}
+}
diff --git a/services/catalog/service/package.json b/services/catalog/service/package.json
@@ -42,13 +42,13 @@
   },
   "dependencies": {
     "@axinom/mosaic-db-common": "0.47.0-rc.9",
-    "@axinom/mosaic-graphql-common": "0.23.4-rc.4",
-    "@axinom/mosaic-id-guard": "0.42.4-rc.4",
-    "@axinom/mosaic-messages": "0.56.0-rc.4",
-    "@axinom/mosaic-message-bus": "0.39.0-rc.4",
+    "@axinom/mosaic-graphql-common": "0.23.5-rc.2",
+    "@axinom/mosaic-id-guard": "0.42.5-rc.2",
+    "@axinom/mosaic-messages": "0.57.0-rc.2",
+    "@axinom/mosaic-message-bus": "0.40.0-rc.2",
     "@axinom/mosaic-message-bus-abstractions": "0.24.0-rc.9",
-    "@axinom/mosaic-service-common": "0.59.4-rc.4",
-    "@axinom/mosaic-transactional-inbox-outbox": "0.19.4-rc.4",
+    "@axinom/mosaic-service-common": "0.59.5-rc.2",
+    "@axinom/mosaic-transactional-inbox-outbox": "0.19.5-rc.2",
     "@graphile-contrib/pg-simplify-inflector": "^6.1.0",
     "add": "^2.0.6",
     "dotenv": "^8.6.0",
diff --git a/services/channel/service/package.json b/services/channel/service/package.json
@@ -45,14 +45,15 @@
   },
   "dependencies": {
     "@axinom/mosaic-db-common": "0.47.0-rc.9",
-    "@axinom/mosaic-graphql-common": "0.23.4-rc.4",
-    "@axinom/mosaic-id-guard": "0.42.4-rc.4",
-    "@axinom/mosaic-id-link-be": "0.31.4-rc.4",
-    "@axinom/mosaic-message-bus": "0.39.0-rc.4",
+    "@axinom/mosaic-graphql-common": "0.23.5-rc.2",
+    "@axinom/mosaic-id-guard": "0.42.5-rc.2",
+    "@axinom/mosaic-id-link-be": "0.31.5-rc.2",
+    "@axinom/mosaic-message-bus": "0.40.0-rc.2",
     "@axinom/mosaic-message-bus-abstractions": "0.24.0-rc.9",
-    "@axinom/mosaic-messages": "0.56.0-rc.4",
-    "@axinom/mosaic-service-common": "0.59.4-rc.4",
-    "@axinom/mosaic-transactional-inbox-outbox": "0.19.4-rc.4",
+    "@axinom/mosaic-messages": "0.57.0-rc.2",
+    "@axinom/mosaic-video-messages": "0.1.0-rc.0",
+    "@axinom/mosaic-service-common": "0.59.5-rc.2",
+    "@axinom/mosaic-transactional-inbox-outbox": "0.19.5-rc.2",
     "@graphile-contrib/pg-simplify-inflector": "^6.1.0",
     "dotenv": "^8.6.0",
     "env-cmd": "^10.1.0",
@@ -81,7 +82,7 @@
     "zapatos": "^3.6.0"
   },
   "devDependencies": {
-    "@axinom/mosaic-cli": "0.45.0-rc.4",
+    "@axinom/mosaic-cli": "0.46.0-rc.2",
     "@graphql-codegen/cli": "^4.0.1",
     "@graphql-codegen/typescript": "^2.7.3",
     "@graphql-codegen/typescript-graphql-request": "^4.5.5",
@@ -104,4 +105,4 @@
     "tsc-watch": "^4.6.2",
     "typescript": "^4.9.4"
   }
-}
+}
diff --git a/services/channel/service/src/common/setup/register-video-cue-point-types.ts b/services/channel/service/src/common/setup/register-video-cue-point-types.ts
@@ -1,8 +1,8 @@
+import { StoreOutboxMessage } from '@axinom/mosaic-transactional-inbox-outbox';
 import {
   DeclareCuePointTypesCommand,
   VideoServiceMultiTenantMessagingSettings,
-} from '@axinom/mosaic-messages';
-import { StoreOutboxMessage } from '@axinom/mosaic-transactional-inbox-outbox';
+} from '@axinom/mosaic-video-messages';
 import { ClientBase } from 'pg';
 import { Config } from '../config/config-definitions';
 import { requestServiceAccountToken } from '../utils';
diff --git a/services/channel/service/src/messaging/handlers/cue-point-types-declare-failed-handler.ts b/services/channel/service/src/messaging/handlers/cue-point-types-declare-failed-handler.ts
@@ -1,9 +1,9 @@
+import { Logger } from '@axinom/mosaic-service-common';
+import { TypedTransactionalMessage } from '@axinom/mosaic-transactional-inbox-outbox';
 import {
   CuePointTypesDeclareFailedEvent,
   VideoServiceMultiTenantMessagingSettings,
-} from '@axinom/mosaic-messages';
-import { Logger } from '@axinom/mosaic-service-common';
-import { TypedTransactionalMessage } from '@axinom/mosaic-transactional-inbox-outbox';
+} from '@axinom/mosaic-video-messages';
 import { Config } from '../../common';
 import { ChannelTransactionalInboxMessageHandler } from '../transactional-outbox-inbox';
 
diff --git a/services/channel/service/src/messaging/handlers/cue-point-types-declared-handler.ts b/services/channel/service/src/messaging/handlers/cue-point-types-declared-handler.ts
@@ -1,9 +1,9 @@
+import { Logger } from '@axinom/mosaic-service-common';
+import { TypedTransactionalMessage } from '@axinom/mosaic-transactional-inbox-outbox';
 import {
   CuePointTypesDeclaredEvent,
   VideoServiceMultiTenantMessagingSettings,
-} from '@axinom/mosaic-messages';
-import { Logger } from '@axinom/mosaic-service-common';
-import { TypedTransactionalMessage } from '@axinom/mosaic-transactional-inbox-outbox';
+} from '@axinom/mosaic-video-messages';
 import { Config } from '../../common';
 import { ChannelTransactionalInboxMessageHandler } from '../transactional-outbox-inbox';
 
diff --git a/services/channel/service/src/messaging/register-messaging.ts b/services/channel/service/src/messaging/register-messaging.ts
@@ -12,7 +12,6 @@ import {
 import {
   ImageServiceMultiTenantMessagingSettings,
   LocalizationServiceMultiTenantMessagingSettings,
-  VideoServiceMultiTenantMessagingSettings,
 } from '@axinom/mosaic-messages';
 import {
   Logger,
@@ -29,6 +28,7 @@ import {
   StoreOutboxMessage,
   TransactionalLogMapper,
 } from '@axinom/mosaic-transactional-inbox-outbox';
+import { VideoServiceMultiTenantMessagingSettings } from '@axinom/mosaic-video-messages';
 import { Express } from 'express';
 import {
   ChannelServiceMessagingSettings,
diff --git a/services/channel/workflows/package.json b/services/channel/workflows/package.json
@@ -27,8 +27,8 @@
   ],
   "dependencies": {
     "@apollo/client": "^3.7.10",
-    "@axinom/mosaic-managed-workflow-integration": "0.25.3-rc.4",
-    "@axinom/mosaic-ui": "0.60.0-rc.4",
+    "@axinom/mosaic-managed-workflow-integration": "0.25.4-rc.2",
+    "@axinom/mosaic-ui": "0.61.0-rc.2",
     "clsx": "^1.2.1",
     "env-cmd": "^10.1.0",
     "formik": "^2.2.9",
@@ -40,7 +40,7 @@
     "yup": "^0.32.11"
   },
   "devDependencies": {
-    "@axinom/mosaic-portal": "0.41.3-rc.4",
+    "@axinom/mosaic-portal": "0.41.4-rc.2",
     "@graphql-codegen/cli": "^4.0.1",
     "@graphql-codegen/typescript": "^2.7.3",
     "@graphql-codegen/typescript-operations": "^2.5.3",
diff --git a/services/entitlement/service/package.json b/services/entitlement/service/package.json
@@ -47,13 +47,14 @@
   },
   "dependencies": {
     "@axinom/mosaic-db-common": "0.47.0-rc.9",
-    "@axinom/mosaic-graphql-common": "0.23.4-rc.4",
-    "@axinom/mosaic-id-guard": "0.42.4-rc.4",
+    "@axinom/mosaic-graphql-common": "0.23.5-rc.2",
+    "@axinom/mosaic-id-guard": "0.42.5-rc.2",
     "@axinom/mosaic-id-utils": "0.23.0-rc.9",
-    "@axinom/mosaic-message-bus": "0.39.0-rc.4",
-    "@axinom/mosaic-messages": "0.56.0-rc.4",
-    "@axinom/mosaic-service-common": "0.59.4-rc.4",
-    "@axinom/mosaic-transactional-inbox-outbox": "0.19.4-rc.4",
+    "@axinom/mosaic-message-bus": "0.40.0-rc.2",
+    "@axinom/mosaic-messages": "0.57.0-rc.2",
+    "@axinom/mosaic-video-messages": "0.1.0-rc.0",
+    "@axinom/mosaic-service-common": "0.59.5-rc.2",
+    "@axinom/mosaic-transactional-inbox-outbox": "0.19.5-rc.2",
     "ajv": "^7.2.4",
     "ajv-formats": "^1.6.1",
     "@graphile-contrib/pg-simplify-inflector": "^6.1.0",
diff --git a/services/entitlement/service/src/domains/video/video-playback-middlewares.ts b/services/entitlement/service/src/domains/video/video-playback-middlewares.ts
@@ -1,9 +1,3 @@
-import {
-  EntitlementWebhookResponsePayload,
-  ManifestWebhookResponsePayload,
-  PlaybackVideoWebhookRequestPayload,
-  PlaybackVideoWebhookRequestPayloadSchema,
-} from '@axinom/mosaic-messages';
 import {
   Dict,
   generateWebhookResponse,
@@ -15,6 +9,12 @@ import {
   WebhookErrors,
   WebhookRequestMessage,
 } from '@axinom/mosaic-service-common';
+import {
+  EntitlementWebhookResponsePayload,
+  ManifestWebhookResponsePayload,
+  PlaybackVideoWebhookRequestPayload,
+  PlaybackVideoWebhookRequestPayloadSchema,
+} from '@axinom/mosaic-video-messages';
 import Ajv from 'ajv';
 import addFormats from 'ajv-formats';
 import { Express, json, NextFunction, Request, Response } from 'express';
diff --git a/services/media/service/package.json b/services/media/service/package.json
@@ -46,14 +46,15 @@
   },
   "dependencies": {
     "@axinom/mosaic-db-common": "0.47.0-rc.9",
-    "@axinom/mosaic-graphql-common": "0.23.4-rc.4",
-    "@axinom/mosaic-id-guard": "0.42.4-rc.4",
-    "@axinom/mosaic-id-link-be": "0.31.4-rc.4",
-    "@axinom/mosaic-message-bus": "0.39.0-rc.4",
+    "@axinom/mosaic-graphql-common": "0.23.5-rc.2",
+    "@axinom/mosaic-id-guard": "0.42.5-rc.2",
+    "@axinom/mosaic-id-link-be": "0.31.5-rc.2",
+    "@axinom/mosaic-message-bus": "0.40.0-rc.2",
     "@axinom/mosaic-message-bus-abstractions": "0.24.0-rc.9",
-    "@axinom/mosaic-messages": "0.56.0-rc.4",
-    "@axinom/mosaic-service-common": "0.59.4-rc.4",
-    "@axinom/mosaic-transactional-inbox-outbox": "0.19.4-rc.4",
+    "@axinom/mosaic-messages": "0.57.0-rc.2",
+    "@axinom/mosaic-video-messages": "0.1.0-rc.0",
+    "@axinom/mosaic-service-common": "0.59.5-rc.2",
+    "@axinom/mosaic-transactional-inbox-outbox": "0.19.5-rc.2",
     "@faker-js/faker": "^7.6.0",
     "@graphile-contrib/pg-simplify-inflector": "^6.1.0",
     "ajv": "^7.2.4",
diff --git a/services/media/service/src/domains/common/handlers/cue-point-types-declare-failed-handler.ts b/services/media/service/src/domains/common/handlers/cue-point-types-declare-failed-handler.ts
@@ -1,12 +1,12 @@
-import {
-  CuePointTypesDeclareFailedEvent,
-  VideoServiceMultiTenantMessagingSettings,
-} from '@axinom/mosaic-messages';
 import { Logger } from '@axinom/mosaic-service-common';
 import {
   TransactionalInboxMessageHandler,
   TypedTransactionalMessage,
 } from '@axinom/mosaic-transactional-inbox-outbox';
+import {
+  CuePointTypesDeclareFailedEvent,
+  VideoServiceMultiTenantMessagingSettings,
+} from '@axinom/mosaic-video-messages';
 import { Config } from '../../../common';
 
 export class CuePointTypesDeclareFailedHandler extends TransactionalInboxMessageHandler<
diff --git a/services/media/service/src/domains/common/handlers/cue-point-types-declared-handler.ts b/services/media/service/src/domains/common/handlers/cue-point-types-declared-handler.ts
@@ -1,12 +1,12 @@
-import {
-  CuePointTypesDeclaredEvent,
-  VideoServiceMultiTenantMessagingSettings,
-} from '@axinom/mosaic-messages';
 import { Logger } from '@axinom/mosaic-service-common';
 import {
   TransactionalInboxMessageHandler,
   TypedTransactionalMessage,
 } from '@axinom/mosaic-transactional-inbox-outbox';
+import {
+  CuePointTypesDeclaredEvent,
+  VideoServiceMultiTenantMessagingSettings,
+} from '@axinom/mosaic-video-messages';
 import { Config } from '../../../common';
 
 export class CuePointTypesDeclaredHandler extends TransactionalInboxMessageHandler<
diff --git a/services/media/service/src/domains/common/handlers/default-ingest-entity-processor.ts b/services/media/service/src/domains/common/handlers/default-ingest-entity-processor.ts
@@ -1,16 +1,18 @@
 import { UNKNOWN_AGGREGATE_ID } from '@axinom/mosaic-message-bus';
 import {
   EnsureImageExistsCommand,
-  EnsureVideoExistsCommand,
   ImageServiceMultiTenantMessagingSettings,
-  VideoServiceMultiTenantMessagingSettings,
 } from '@axinom/mosaic-messages';
 import {
   difference,
   isEmptyObject,
   MosaicError,
   normalizeRelativePath,
 } from '@axinom/mosaic-service-common';
+import {
+  EnsureVideoExistsCommand,
+  VideoServiceMultiTenantMessagingSettings,
+} from '@axinom/mosaic-video-messages';
 import {
   ImageMessageContext,
   ImagesIngestElement,
diff --git a/services/media/service/src/domains/movies/handlers/ingest-movie-processor-orchestration.spec.ts b/services/media/service/src/domains/movies/handlers/ingest-movie-processor-orchestration.spec.ts
@@ -1,8 +1,6 @@
 import { UNKNOWN_AGGREGATE_ID } from '@axinom/mosaic-message-bus';
-import {
-  ImageServiceMultiTenantMessagingSettings,
-  VideoServiceMultiTenantMessagingSettings,
-} from '@axinom/mosaic-messages';
+import { ImageServiceMultiTenantMessagingSettings } from '@axinom/mosaic-messages';
+import { VideoServiceMultiTenantMessagingSettings } from '@axinom/mosaic-video-messages';
 import 'jest-extended';
 import {
   MediaServiceMessagingSettings,
diff --git a/services/media/service/src/domains/register-video-cue-point-types.ts b/services/media/service/src/domains/register-video-cue-point-types.ts
@@ -1,8 +1,8 @@
+import { StoreOutboxMessage } from '@axinom/mosaic-transactional-inbox-outbox';
 import {
   DeclareCuePointTypesCommand,
   VideoServiceMultiTenantMessagingSettings,
-} from '@axinom/mosaic-messages';
-import { StoreOutboxMessage } from '@axinom/mosaic-transactional-inbox-outbox';
+} from '@axinom/mosaic-video-messages';
 import { ClientBase } from 'pg';
 import { Config, requestServiceAccountToken } from '../common';
 
diff --git a/services/media/service/src/ingest/handlers/start-ingest-item-handler.db.spec.ts b/services/media/service/src/ingest/handlers/start-ingest-item-handler.db.spec.ts
@@ -1,7 +1,6 @@
 import { DEFAULT_SYSTEM_USERNAME } from '@axinom/mosaic-db-common';
 import { AuthenticatedManagementSubject } from '@axinom/mosaic-id-guard';
 import { MessagingSettings } from '@axinom/mosaic-message-bus-abstractions';
-import { VideoServiceMultiTenantMessagingSettings } from '@axinom/mosaic-messages';
 import {
   createOffsetDate,
   dateToBeInRange,
@@ -12,6 +11,7 @@ import {
   StoreOutboxMessage,
   TypedTransactionalMessage,
 } from '@axinom/mosaic-transactional-inbox-outbox';
+import { VideoServiceMultiTenantMessagingSettings } from '@axinom/mosaic-video-messages';
 import { stub } from 'jest-auto-stub';
 import 'jest-extended';
 import {
diff --git a/services/media/service/src/ingest/handlers/video-already-existed-handler.ts b/services/media/service/src/ingest/handlers/video-already-existed-handler.ts
@@ -1,7 +1,7 @@
 import {
   EnsureVideoExistsAlreadyExistedEvent,
   VideoServiceMultiTenantMessagingSettings,
-} from '@axinom/mosaic-messages';
+} from '@axinom/mosaic-video-messages';
 import { Config } from '../../common';
 import { IngestEntityProcessor } from '../models';
 import { VideoSucceededHandler } from './video-succeeded-handler';
diff --git a/services/media/service/src/ingest/handlers/video-creation-started-handler.ts b/services/media/service/src/ingest/handlers/video-creation-started-handler.ts
@@ -1,7 +1,7 @@
 import {
   EnsureVideoExistsCreationStartedEvent,
   VideoServiceMultiTenantMessagingSettings,
-} from '@axinom/mosaic-messages';
+} from '@axinom/mosaic-video-messages';
 import { Config } from '../../common';
 import { IngestEntityProcessor } from '../models';
 import { VideoSucceededHandler } from './video-succeeded-handler';
diff --git a/services/media/service/src/ingest/handlers/video-failed-handler.db.spec.ts b/services/media/service/src/ingest/handlers/video-failed-handler.db.spec.ts
@@ -1,7 +1,7 @@
 import { AuthenticatedManagementSubject } from '@axinom/mosaic-id-guard';
-import { EnsureVideoExistsFailedEvent } from '@axinom/mosaic-messages';
 import { MosaicError } from '@axinom/mosaic-service-common';
 import { TypedTransactionalMessage } from '@axinom/mosaic-transactional-inbox-outbox';
+import { EnsureVideoExistsFailedEvent } from '@axinom/mosaic-video-messages';
 import { stub } from 'jest-auto-stub';
 import 'jest-extended';
 import { randomUUID } from 'node:crypto';
diff --git a/services/media/service/src/ingest/handlers/video-failed-handler.ts b/services/media/service/src/ingest/handlers/video-failed-handler.ts
@@ -1,9 +1,9 @@
+import { Logger } from '@axinom/mosaic-service-common';
+import { TypedTransactionalMessage } from '@axinom/mosaic-transactional-inbox-outbox';
 import {
   EnsureVideoExistsFailedEvent,
   VideoServiceMultiTenantMessagingSettings,
-} from '@axinom/mosaic-messages';
-import { Logger } from '@axinom/mosaic-service-common';
-import { TypedTransactionalMessage } from '@axinom/mosaic-transactional-inbox-outbox';
+} from '@axinom/mosaic-video-messages';
 import { ImageMessageContext, VideoMessageContext } from 'media-messages';
 import { ClientBase } from 'pg';
 import { update } from 'zapatos/db';
diff --git a/services/media/service/src/ingest/handlers/video-succeeded-handler.db.spec.ts b/services/media/service/src/ingest/handlers/video-succeeded-handler.db.spec.ts
@@ -1,7 +1,7 @@
 import { AuthenticatedManagementSubject } from '@axinom/mosaic-id-guard';
-import { EnsureVideoExistsCreationStartedEvent } from '@axinom/mosaic-messages';
 import { MosaicError } from '@axinom/mosaic-service-common';
 import { TypedTransactionalMessage } from '@axinom/mosaic-transactional-inbox-outbox';
+import { EnsureVideoExistsCreationStartedEvent } from '@axinom/mosaic-video-messages';
 import { stub } from 'jest-auto-stub';
 import 'jest-extended';
 import { v4 as uuid } from 'uuid';
diff --git a/services/media/service/src/ingest/handlers/video-succeeded-handler.ts b/services/media/service/src/ingest/handlers/video-succeeded-handler.ts
@@ -1,10 +1,10 @@
 import { MessagingSettings } from '@axinom/mosaic-message-bus-abstractions';
+import { Logger, MosaicError } from '@axinom/mosaic-service-common';
+import { TypedTransactionalMessage } from '@axinom/mosaic-transactional-inbox-outbox';
 import {
   EnsureVideoExistsAlreadyExistedEvent,
   EnsureVideoExistsCreationStartedEvent,
-} from '@axinom/mosaic-messages';
-import { Logger, MosaicError } from '@axinom/mosaic-service-common';
-import { TypedTransactionalMessage } from '@axinom/mosaic-transactional-inbox-outbox';
+} from '@axinom/mosaic-video-messages';
 import { VideoMessageContext } from 'media-messages';
 import { ClientBase } from 'pg';
 import { selectExactlyOne, update } from 'zapatos/db';
diff --git a/services/media/service/src/messaging/register-messaging.ts b/services/media/service/src/messaging/register-messaging.ts
@@ -12,7 +12,6 @@ import { getMessagingMiddleware } from './middleware';
 import {
   ImageServiceMultiTenantMessagingSettings,
   LocalizationServiceMultiTenantMessagingSettings,
-  VideoServiceMultiTenantMessagingSettings,
 } from '@axinom/mosaic-messages';
 import { ShutdownActionsMiddleware } from '@axinom/mosaic-service-common';
 import {
@@ -25,6 +24,7 @@ import {
   StoreOutboxMessage,
   TransactionalLogMapper,
 } from '@axinom/mosaic-transactional-inbox-outbox';
+import { VideoServiceMultiTenantMessagingSettings } from '@axinom/mosaic-video-messages';
 import { MediaServiceMessagingSettings } from 'media-messages';
 import {
   getInboxPollingListenerSettings,
diff --git a/services/media/service/src/tests/ingest/upload.db.spec.ts b/services/media/service/src/tests/ingest/upload.db.spec.ts
diff --git a/services/media/workflows/package.json b/services/media/workflows/package.json
diff --git a/services/vod-to-live/service/package.json b/services/vod-to-live/service/package.json
diff --git a/yarn.lock b/yarn.lock
