query node - mappingsContent split V

query-node/mappings/src/content/channel.ts

@@ -2,62 +2,17 @@ import { SubstrateEvent } from '@dzlzv/hydra-common'
 import { DatabaseManager } from '@dzlzv/hydra-db-utils'
 import ISO6391 from 'iso-639-1';
 
-// protobuf definitions
-import {
-  ChannelMetadata,
-  ChannelCategoryMetadata,
-  PublishedBeforeJoystream as PublishedBeforeJoystreamMetadata,
-  License as LicenseMetadata,
-  MediaType as MediaTypeMetadata,
-  VideoMetadata,
-  VideoCategoryMetadata,
-} from '@joystream/content-metadata-protobuf'
-
-import {
-  Content,
-} from '../../../generated/types'
-
+import { Content } from '../../../generated/types'
 import { readProtobuf } from './utils'
 
 import {
   inconsistentState,
   prepareBlock,
-  prepareAssetDataObject,
 } from '../common'
 
 // primary entities
-import { Block } from 'query-node/src/modules/block/block.model'
-import { CuratorGroup } from 'query-node/src/modules/curator-group/curator-group.model'
 import { Channel } from 'query-node/src/modules/channel/channel.model'
 import { ChannelCategory } from 'query-node/src/modules/channel-category/channel-category.model'
-import { Video } from 'query-node/src/modules/video/video.model'
-import { VideoCategory } from 'query-node/src/modules/video-category/video-category.model'
-
-// secondary entities
-import { Language } from 'query-node/src/modules/language/language.model'
-import { License } from 'query-node/src/modules/license/license.model'
-import { VideoMediaEncoding } from 'query-node/src/modules/video-media-encoding/video-media-encoding.model'
-import { VideoMediaMetadata } from 'query-node/src/modules/video-media-metadata/video-media-metadata.model'
-
-// Asset
-import {
-  Asset,
-  AssetUrl,
-  AssetUploadStatus,
-  AssetStorage,
-  AssetOwner,
-  AssetOwnerMember,
-} from 'query-node/src/modules/variants/variants.model'
-import {
-  AssetDataObject,
-  LiaisonJudgement
-} from 'query-node/src/modules/asset-data-object/asset-data-object.model'
-
-// Joystream types
-import {
-  ContentParameters,
-  NewAsset,
-} from '@joystream/types/augment'
 
 // eslint-disable-next-line @typescript-eslint/naming-convention
 export async function content_ChannelCreated(db: DatabaseManager, event: SubstrateEvent): Promise<void> {

query-node/mappings/src/content/curatorGroup.ts

@@ -0,0 +1,100 @@
+import { SubstrateEvent } from '@dzlzv/hydra-common'
+import { DatabaseManager } from '@dzlzv/hydra-db-utils'
+
+import { CuratorGroup } from 'query-node/src/modules/curator-group/curator-group.model'
+import { Content } from '../../../generated/types'
+
+import {
+  inconsistentState,
+} from '../common'
+
+export async function content_CuratorGroupCreated(
+  db: DatabaseManager,
+  event: SubstrateEvent
+) {
+  // read event data
+  const {curatorGroupId} = new Content.CuratorGroupCreatedEvent(event).data
+
+  // create new curator group
+  const curatorGroup = new CuratorGroup({
+    id: curatorGroupId.toString(),
+    curatorIds: [],
+    isActive: false, // runtime creates inactive curator groups by default
+  })
+
+  // save curator group
+  await db.save<CuratorGroup>(curatorGroup)
+}
+
+export async function content_CuratorGroupStatusSet(
+  db: DatabaseManager,
+  event: SubstrateEvent
+) {
+  // read event data
+  const {curatorGroupId, bool: isActive} = new Content.CuratorGroupStatusSetEvent(event).data
+
+  // load curator group
+  const curatorGroup = await db.get(CuratorGroup, { where: { id: curatorGroupId }})
+
+  // ensure curator group exists
+  if (!curatorGroup) {
+    return inconsistentState()
+  }
+
+  // update curator group
+  curatorGroup.isActive = isActive.isTrue
+
+  // save curator group
+  await db.save<CuratorGroup>(curatorGroup)
+}
+
+export async function content_CuratorAdded(
+  db: DatabaseManager,
+  event: SubstrateEvent
+) {
+  // read event data
+  const {curatorGroupId, curatorId} = new Content.CuratorAddedEvent(event).data
+
+  // load curator group
+  const curatorGroup = await db.get(CuratorGroup, { where: { id: curatorGroupId }})
+
+  // ensure curator group exists
+  if (!curatorGroup) {
+    return inconsistentState()
+  }
+
+  // update curator group
+  curatorGroup.curatorIds.push(curatorId)
+
+  // save curator group
+  await db.save<CuratorGroup>(curatorGroup)
+}
+
+export async function content_CuratorRemoved(
+  db: DatabaseManager,
+  event: SubstrateEvent
+) {
+  // read event data
+  const {curatorGroupId, curatorId} = new Content.CuratorAddedEvent(event).data
+
+  // load curator group
+  const curatorGroup = await db.get(CuratorGroup, { where: { id: curatorGroupId }})
+
+  // ensure curator group exists
+  if (!curatorGroup) {
+    return inconsistentState()
+  }
+
+  const curatorIndex = curatorGroup.curatorIds.indexOf(curatorId)
+
+  // ensure curator group exists
+  if (curatorIndex < 0) {
+    return inconsistentState()
+  }
+
+  // update curator group
+  curatorGroup.curatorIds.splice(curatorIndex, 1)
+
+  // save curator group
+  await db.save<CuratorGroup>(curatorGroup)
+}

query-node/mappings/src/content/index.ts

@@ -1,2 +1,3 @@
 export * from './channel'
+export * from './curatorGroup'
 export * from './video'

query-node/mappings/src/content/video.ts

@@ -13,7 +13,6 @@ import {
 import { readProtobuf } from './utils'
 
 // primary entities
-import { CuratorGroup } from 'query-node/src/modules/curator-group/curator-group.model'
 import { Video } from 'query-node/src/modules/video/video.model'
 import { VideoCategory } from 'query-node/src/modules/video-category/video-category.model'
 
@@ -300,96 +299,3 @@ export async function content_FeaturedVideosSet(
     await db.save<Video>(video)
   }
 }
-
-/////////////////// Curator Group //////////////////////////////////////////////
-
-export async function content_CuratorGroupCreated(
-  db: DatabaseManager,
-  event: SubstrateEvent
-) {
-  // read event data
-  const {curatorGroupId} = new Content.CuratorGroupCreatedEvent(event).data
-
-  // create new curator group
-  const curatorGroup = new CuratorGroup({
-    id: curatorGroupId.toString(),
-    curatorIds: [],
-    isActive: false, // runtime creates inactive curator groups by default
-  })
-
-  // save curator group
-  await db.save<CuratorGroup>(curatorGroup)
-}
-
-export async function content_CuratorGroupStatusSet(
-  db: DatabaseManager,
-  event: SubstrateEvent
-) {
-  // read event data
-  const {curatorGroupId, bool: isActive} = new Content.CuratorGroupStatusSetEvent(event).data
-
-  // load curator group
-  const curatorGroup = await db.get(CuratorGroup, { where: { id: curatorGroupId }})
-
-  // ensure curator group exists
-  if (!curatorGroup) {
-    return inconsistentState()
-  }
-
-  // update curator group
-  curatorGroup.isActive = isActive.isTrue
-
-  // save curator group
-  await db.save<CuratorGroup>(curatorGroup)
-}
-
-export async function content_CuratorAdded(
-  db: DatabaseManager,
-  event: SubstrateEvent
-) {
-  // read event data
-  const {curatorGroupId, curatorId} = new Content.CuratorAddedEvent(event).data
-
-  // load curator group
-  const curatorGroup = await db.get(CuratorGroup, { where: { id: curatorGroupId }})
-
-  // ensure curator group exists
-  if (!curatorGroup) {
-    return inconsistentState()
-  }
-
-  // update curator group
-  curatorGroup.curatorIds.push(curatorId)
-
-  // save curator group
-  await db.save<CuratorGroup>(curatorGroup)
-}
-
-export async function content_CuratorRemoved(
-  db: DatabaseManager,
-  event: SubstrateEvent
-) {
-  // read event data
-  const {curatorGroupId, curatorId} = new Content.CuratorAddedEvent(event).data
-
-  // load curator group
-  const curatorGroup = await db.get(CuratorGroup, { where: { id: curatorGroupId }})
-
-  // ensure curator group exists
-  if (!curatorGroup) {
-    return inconsistentState()
-  }
-
-  const curatorIndex = curatorGroup.curatorIds.indexOf(curatorId)
-
-  // ensure curator group exists
-  if (curatorIndex < 0) {
-    return inconsistentState()
-  }
-
-  // update curator group
-  curatorGroup.curatorIds.splice(curatorIndex, 1)
-
-  // save curator group
-  await db.save<CuratorGroup>(curatorGroup)
-}