Merge pull request #2361 from ondratra/query_node_storage_provider

Query node storage provider

query-node/generated/graphql-server/generated/binding.ts

@@ -45,7 +45,10 @@ export interface Query {
     videoMediaMetadataConnection: <T = VideoMediaMetadataConnection>(args: { first?: Int | null, after?: String | null, last?: Int | null, before?: String | null, where?: VideoMediaMetadataWhereInput | null, orderBy?: VideoMediaMetadataOrderByInput | null }, info?: GraphQLResolveInfo | string, options?: Options) => Promise<T> ,
     videos: <T = Array<Video>>(args: { offset?: Int | null, limit?: Int | null, where?: VideoWhereInput | null, orderBy?: VideoOrderByInput | null }, info?: GraphQLResolveInfo | string, options?: Options) => Promise<T> ,
     videoByUniqueInput: <T = Video | null>(args: { where: VideoWhereUniqueInput }, info?: GraphQLResolveInfo | string, options?: Options) => Promise<T | null> ,
-    videosConnection: <T = VideoConnection>(args: { first?: Int | null, after?: String | null, last?: Int | null, before?: String | null, where?: VideoWhereInput | null, orderBy?: VideoOrderByInput | null }, info?: GraphQLResolveInfo | string, options?: Options) => Promise<T> 
+    videosConnection: <T = VideoConnection>(args: { first?: Int | null, after?: String | null, last?: Int | null, before?: String | null, where?: VideoWhereInput | null, orderBy?: VideoOrderByInput | null }, info?: GraphQLResolveInfo | string, options?: Options) => Promise<T> ,
+    workers: <T = Array<Worker>>(args: { offset?: Int | null, limit?: Int | null, where?: WorkerWhereInput | null, orderBy?: WorkerOrderByInput | null }, info?: GraphQLResolveInfo | string, options?: Options) => Promise<T> ,
+    workerByUniqueInput: <T = Worker | null>(args: { where: WorkerWhereUniqueInput }, info?: GraphQLResolveInfo | string, options?: Options) => Promise<T | null> ,
+    workersConnection: <T = WorkerConnection>(args: { first?: Int | null, after?: String | null, last?: Int | null, before?: String | null, where?: WorkerWhereInput | null, orderBy?: WorkerOrderByInput | null }, info?: GraphQLResolveInfo | string, options?: Options) => Promise<T> 
   }
 
 export interface Mutation {}
@@ -90,8 +93,8 @@ export type ChannelCategoryOrderByInput =   'createdAt_ASC' |
   'deletedAt_DESC' |
   'name_ASC' |
   'name_DESC' |
-  'happenedIn_ASC' |
-  'happenedIn_DESC'
+  'createdInBlock_ASC' |
+  'createdInBlock_DESC'
 
 export type ChannelOrderByInput =   'createdAt_ASC' |
   'createdAt_DESC' |
@@ -125,8 +128,8 @@ export type ChannelOrderByInput =   'createdAt_ASC' |
   'isCensored_DESC' |
   'languageId_ASC' |
   'languageId_DESC' |
-  'happenedIn_ASC' |
-  'happenedIn_DESC'
+  'createdInBlock_ASC' |
+  'createdInBlock_DESC'
 
 export type CuratorGroupOrderByInput =   'createdAt_ASC' |
   'createdAt_DESC' |
@@ -143,8 +146,8 @@ export type DataObjectOrderByInput =   'createdAt_ASC' |
   'updatedAt_DESC' |
   'deletedAt_ASC' |
   'deletedAt_DESC' |
-  'addedAt_ASC' |
-  'addedAt_DESC' |
+  'createdInBlock_ASC' |
+  'createdInBlock_DESC' |
   'typeId_ASC' |
   'typeId_DESC' |
   'size_ASC' |
@@ -175,12 +178,11 @@ export type LanguageOrderByInput =   'createdAt_ASC' |
   'deletedAt_DESC' |
   'iso_ASC' |
   'iso_DESC' |
-  'happenedIn_ASC' |
-  'happenedIn_DESC'
+  'createdInBlock_ASC' |
+  'createdInBlock_DESC'
 
 export type LiaisonJudgement =   'PENDING' |
-  'ACCEPTED' |
-  'REJECTED'
+  'ACCEPTED'
 
 export type LicenseOrderByInput =   'createdAt_ASC' |
   'createdAt_DESC' |
@@ -215,10 +217,8 @@ export type MembershipOrderByInput =   'createdAt_ASC' |
   'controllerAccount_DESC' |
   'rootAccount_ASC' |
   'rootAccount_DESC' |
-  'registeredAtBlock_ASC' |
-  'registeredAtBlock_DESC' |
-  'registeredAtTime_ASC' |
-  'registeredAtTime_DESC' |
+  'createdInBlock_ASC' |
+  'createdInBlock_DESC' |
   'entry_ASC' |
   'entry_DESC' |
   'subscription_ASC' |
@@ -232,8 +232,8 @@ export type VideoCategoryOrderByInput =   'createdAt_ASC' |
   'deletedAt_DESC' |
   'name_ASC' |
   'name_DESC' |
-  'happenedIn_ASC' |
-  'happenedIn_DESC'
+  'createdInBlock_ASC' |
+  'createdInBlock_DESC'
 
 export type VideoMediaEncodingOrderByInput =   'createdAt_ASC' |
   'createdAt_DESC' |
@@ -262,8 +262,8 @@ export type VideoMediaMetadataOrderByInput =   'createdAt_ASC' |
   'pixelHeight_DESC' |
   'size_ASC' |
   'size_DESC' |
-  'happenedIn_ASC' |
-  'happenedIn_DESC'
+  'createdInBlock_ASC' |
+  'createdInBlock_DESC'
 
 export type VideoOrderByInput =   'createdAt_ASC' |
   'createdAt_DESC' |
@@ -305,11 +305,29 @@ export type VideoOrderByInput =   'createdAt_ASC' |
   'mediaAvailability_DESC' |
   'mediaMetadataId_ASC' |
   'mediaMetadataId_DESC' |
-  'happenedIn_ASC' |
-  'happenedIn_DESC' |
+  'createdInBlock_ASC' |
+  'createdInBlock_DESC' |
   'isFeatured_ASC' |
   'isFeatured_DESC'
 
+export type WorkerOrderByInput =   'createdAt_ASC' |
+  'createdAt_DESC' |
+  'updatedAt_ASC' |
+  'updatedAt_DESC' |
+  'deletedAt_ASC' |
+  'deletedAt_DESC' |
+  'isActive_ASC' |
+  'isActive_DESC' |
+  'workerId_ASC' |
+  'workerId_DESC' |
+  'type_ASC' |
+  'type_DESC' |
+  'metadata_ASC' |
+  'metadata_DESC'
+
+export type WorkerType =   'GATEWAY' |
+  'STORAGE'
+
 export interface BaseWhereInput {
   id_eq?: String | null
   id_in?: String[] | String | null
@@ -336,12 +354,12 @@ export interface BaseWhereInput {
 
 export interface ChannelCategoryCreateInput {
   name?: String | null
-  happenedIn: Float
+  createdInBlock: Float
 }
 
 export interface ChannelCategoryUpdateInput {
   name?: String | null
-  happenedIn?: Float | null
+  createdInBlock?: Float | null
 }
 
 export interface ChannelCategoryWhereInput {
@@ -374,12 +392,12 @@ export interface ChannelCategoryWhereInput {
   name_startsWith?: String | null
   name_endsWith?: String | null
   name_in?: String[] | String | null
-  happenedIn_eq?: Int | null
-  happenedIn_gt?: Int | null
-  happenedIn_gte?: Int | null
-  happenedIn_lt?: Int | null
-  happenedIn_lte?: Int | null
-  happenedIn_in?: Int[] | Int | null
+  createdInBlock_eq?: Int | null
+  createdInBlock_gt?: Int | null
+  createdInBlock_gte?: Int | null
+  createdInBlock_lt?: Int | null
+  createdInBlock_lte?: Int | null
+  createdInBlock_in?: Int[] | Int | null
 }
 
 export interface ChannelCategoryWhereUniqueInput {
@@ -402,7 +420,7 @@ export interface ChannelCreateInput {
   isPublic?: Boolean | null
   isCensored: Boolean
   languageId?: ID_Input | null
-  happenedIn: Float
+  createdInBlock: Float
 }
 
 export interface ChannelUpdateInput {
@@ -421,7 +439,7 @@ export interface ChannelUpdateInput {
   isPublic?: Boolean | null
   isCensored?: Boolean | null
   languageId?: ID_Input | null
-  happenedIn?: Float | null
+  createdInBlock?: Float | null
 }
 
 export interface ChannelWhereInput {
@@ -484,12 +502,12 @@ export interface ChannelWhereInput {
   isCensored_in?: Boolean[] | Boolean | null
   languageId_eq?: ID_Input | null
   languageId_in?: ID_Output[] | ID_Output | null
-  happenedIn_eq?: Int | null
-  happenedIn_gt?: Int | null
-  happenedIn_gte?: Int | null
-  happenedIn_lt?: Int | null
-  happenedIn_lte?: Int | null
-  happenedIn_in?: Int[] | Int | null
+  createdInBlock_eq?: Int | null
+  createdInBlock_gt?: Int | null
+  createdInBlock_gte?: Int | null
+  createdInBlock_lt?: Int | null
+  createdInBlock_lte?: Int | null
+  createdInBlock_in?: Int[] | Int | null
 }
 
 export interface ChannelWhereUniqueInput {
@@ -497,12 +515,12 @@ export interface ChannelWhereUniqueInput {
 }
 
 export interface CuratorGroupCreateInput {
-  curatorIds: Array<BigInt>
+  curatorIds: Array<Int>
   isActive: Boolean
 }
 
 export interface CuratorGroupUpdateInput {
-  curatorIds?: BigInt[] | BigInt | null
+  curatorIds?: Int[] | Int | null
   isActive?: Boolean | null
 }
 
@@ -541,22 +559,22 @@ export interface CuratorGroupWhereUniqueInput {
 
 export interface DataObjectCreateInput {
   owner: JSONObject
-  addedAt: Float
+  createdInBlock: Float
   typeId: Float
-  size: BigInt
-  liaisonId: BigInt
+  size: Float
+  liaisonId?: ID_Input | null
   liaisonJudgement: LiaisonJudgement
   ipfsContentId: String
   joystreamContentId: String
 }
 
 export interface DataObjectOwnerChannelCreateInput {
-  channel: BigInt
+  channel: Float
   dummy?: Float | null
 }
 
 export interface DataObjectOwnerChannelUpdateInput {
-  channel?: BigInt | null
+  channel?: Float | null
   dummy?: Float | null
 }
 
@@ -585,12 +603,12 @@ export interface DataObjectOwnerChannelWhereInput {
   deletedAt_gte?: DateTime | null
   deletedById_eq?: ID_Input | null
   deletedById_in?: ID_Output[] | ID_Output | null
-  channel_eq?: BigInt | null
-  channel_gt?: BigInt | null
-  channel_gte?: BigInt | null
-  channel_lt?: BigInt | null
-  channel_lte?: BigInt | null
-  channel_in?: BigInt[] | BigInt | null
+  channel_eq?: Int | null
+  channel_gt?: Int | null
+  channel_gte?: Int | null
+  channel_lt?: Int | null
+  channel_lte?: Int | null
+  channel_in?: Int[] | Int | null
   dummy_eq?: Int | null
   dummy_gt?: Int | null
   dummy_gte?: Int | null
@@ -649,11 +667,11 @@ export interface DataObjectOwnerCouncilWhereUniqueInput {
 }
 
 export interface DataObjectOwnerDaoCreateInput {
-  dao: BigInt
+  dao: Float
 }
 
 export interface DataObjectOwnerDaoUpdateInput {
-  dao?: BigInt | null
+  dao?: Float | null
 }
 
 export interface DataObjectOwnerDaoWhereInput {
@@ -681,12 +699,12 @@ export interface DataObjectOwnerDaoWhereInput {
   deletedAt_gte?: DateTime | null
   deletedById_eq?: ID_Input | null
   deletedById_in?: ID_Output[] | ID_Output | null
-  dao_eq?: BigInt | null
-  dao_gt?: BigInt | null
-  dao_gte?: BigInt | null
-  dao_lt?: BigInt | null
-  dao_lte?: BigInt | null
-  dao_in?: BigInt[] | BigInt | null
+  dao_eq?: Int | null
+  dao_gt?: Int | null
+  dao_gte?: Int | null
+  dao_lt?: Int | null
+  dao_lte?: Int | null
+  dao_in?: Int[] | Int | null
 }
 
 export interface DataObjectOwnerDaoWhereUniqueInput {
@@ -694,12 +712,12 @@ export interface DataObjectOwnerDaoWhereUniqueInput {
 }
 
 export interface DataObjectOwnerMemberCreateInput {
-  member: BigInt
+  member: Float
   dummy?: Float | null
 }
 
 export interface DataObjectOwnerMemberUpdateInput {
-  member?: BigInt | null
+  member?: Float | null
   dummy?: Float | null
 }
 
@@ -728,12 +746,12 @@ export interface DataObjectOwnerMemberWhereInput {
   deletedAt_gte?: DateTime | null
   deletedById_eq?: ID_Input | null
   deletedById_in?: ID_Output[] | ID_Output | null
-  member_eq?: BigInt | null
-  member_gt?: BigInt | null
-  member_gte?: BigInt | null
-  member_lt?: BigInt | null
-  member_lte?: BigInt | null
-  member_in?: BigInt[] | BigInt | null
+  member_eq?: Int | null
+  member_gt?: Int | null
+  member_gte?: Int | null
+  member_lt?: Int | null
+  member_lte?: Int | null
+  member_in?: Int[] | Int | null
   dummy_eq?: Int | null
   dummy_gt?: Int | null
   dummy_gte?: Int | null
@@ -747,11 +765,11 @@ export interface DataObjectOwnerMemberWhereUniqueInput {
 }
 
 export interface DataObjectOwnerWorkingGroupCreateInput {
-  dummy?: Float | null
+  workingGroup: Float
 }
 
 export interface DataObjectOwnerWorkingGroupUpdateInput {
-  dummy?: Float | null
+  workingGroup?: Float | null
 }
 
 export interface DataObjectOwnerWorkingGroupWhereInput {
@@ -779,12 +797,12 @@ export interface DataObjectOwnerWorkingGroupWhereInput {
   deletedAt_gte?: DateTime | null
   deletedById_eq?: ID_Input | null
   deletedById_in?: ID_Output[] | ID_Output | null
-  dummy_eq?: Int | null
-  dummy_gt?: Int | null
-  dummy_gte?: Int | null
-  dummy_lt?: Int | null
-  dummy_lte?: Int | null
-  dummy_in?: Int[] | Int | null
+  workingGroup_eq?: Int | null
+  workingGroup_gt?: Int | null
+  workingGroup_gte?: Int | null
+  workingGroup_lt?: Int | null
+  workingGroup_lte?: Int | null
+  workingGroup_in?: Int[] | Int | null
 }
 
 export interface DataObjectOwnerWorkingGroupWhereUniqueInput {
@@ -793,10 +811,10 @@ export interface DataObjectOwnerWorkingGroupWhereUniqueInput {
 
 export interface DataObjectUpdateInput {
   owner?: JSONObject | null
-  addedAt?: Float | null
+  createdInBlock?: Float | null
   typeId?: Float | null
-  size?: BigInt | null
-  liaisonId?: BigInt | null
+  size?: Float | null
+  liaisonId?: ID_Input | null
   liaisonJudgement?: LiaisonJudgement | null
   ipfsContentId?: String | null
   joystreamContentId?: String | null
@@ -828,30 +846,26 @@ export interface DataObjectWhereInput {
   deletedById_eq?: ID_Input | null
   deletedById_in?: ID_Output[] | ID_Output | null
   owner_json?: JSONObject | null
-  addedAt_eq?: Int | null
-  addedAt_gt?: Int | null
-  addedAt_gte?: Int | null
-  addedAt_lt?: Int | null
-  addedAt_lte?: Int | null
-  addedAt_in?: Int[] | Int | null
+  createdInBlock_eq?: Int | null
+  createdInBlock_gt?: Int | null
+  createdInBlock_gte?: Int | null
+  createdInBlock_lt?: Int | null
+  createdInBlock_lte?: Int | null
+  createdInBlock_in?: Int[] | Int | null
   typeId_eq?: Int | null
   typeId_gt?: Int | null
   typeId_gte?: Int | null
   typeId_lt?: Int | null
   typeId_lte?: Int | null
   typeId_in?: Int[] | Int | null
-  size_eq?: BigInt | null
-  size_gt?: BigInt | null
-  size_gte?: BigInt | null
-  size_lt?: BigInt | null
-  size_lte?: BigInt | null
-  size_in?: BigInt[] | BigInt | null
-  liaisonId_eq?: BigInt | null
-  liaisonId_gt?: BigInt | null
-  liaisonId_gte?: BigInt | null
-  liaisonId_lt?: BigInt | null
-  liaisonId_lte?: BigInt | null
-  liaisonId_in?: BigInt[] | BigInt | null
+  size_eq?: Int | null
+  size_gt?: Int | null
+  size_gte?: Int | null
+  size_lt?: Int | null
+  size_lte?: Int | null
+  size_in?: Int[] | Int | null
+  liaisonId_eq?: ID_Input | null
+  liaisonId_in?: ID_Output[] | ID_Output | null
   liaisonJudgement_eq?: LiaisonJudgement | null
   liaisonJudgement_in?: LiaisonJudgement[] | LiaisonJudgement | null
   ipfsContentId_eq?: String | null
@@ -913,12 +927,12 @@ export interface FeaturedVideoWhereUniqueInput {
 
 export interface LanguageCreateInput {
   iso: String
-  happenedIn: Float
+  createdInBlock: Float
 }
 
 export interface LanguageUpdateInput {
   iso?: String | null
-  happenedIn?: Float | null
+  createdInBlock?: Float | null
 }
 
 export interface LanguageWhereInput {
@@ -951,12 +965,12 @@ export interface LanguageWhereInput {
   iso_startsWith?: String | null
   iso_endsWith?: String | null
   iso_in?: String[] | String | null
-  happenedIn_eq?: Int | null
-  happenedIn_gt?: Int | null
-  happenedIn_gte?: Int | null
-  happenedIn_lt?: Int | null
-  happenedIn_lte?: Int | null
-  happenedIn_in?: Int[] | Int | null
+  createdInBlock_eq?: Int | null
+  createdInBlock_gt?: Int | null
+  createdInBlock_gte?: Int | null
+  createdInBlock_lt?: Int | null
+  createdInBlock_lte?: Int | null
+  createdInBlock_in?: Int[] | Int | null
 }
 
 export interface LanguageWhereUniqueInput {
@@ -1028,10 +1042,9 @@ export interface MembershipCreateInput {
   about?: String | null
   controllerAccount: String
   rootAccount: String
-  registeredAtBlock: Float
-  registeredAtTime: DateTime
+  createdInBlock: Float
   entry: MembershipEntryMethod
-  subscription?: BigInt | null
+  subscription?: Float | null
 }
 
 export interface MembershipUpdateInput {
@@ -1040,10 +1053,9 @@ export interface MembershipUpdateInput {
   about?: String | null
   controllerAccount?: String | null
   rootAccount?: String | null
-  registeredAtBlock?: Float | null
-  registeredAtTime?: DateTime | null
+  createdInBlock?: Float | null
   entry?: MembershipEntryMethod | null
-  subscription?: BigInt | null
+  subscription?: Float | null
 }
 
 export interface MembershipWhereInput {
@@ -1096,25 +1108,20 @@ export interface MembershipWhereInput {
   rootAccount_startsWith?: String | null
   rootAccount_endsWith?: String | null
   rootAccount_in?: String[] | String | null
-  registeredAtBlock_eq?: Int | null
-  registeredAtBlock_gt?: Int | null
-  registeredAtBlock_gte?: Int | null
-  registeredAtBlock_lt?: Int | null
-  registeredAtBlock_lte?: Int | null
-  registeredAtBlock_in?: Int[] | Int | null
-  registeredAtTime_eq?: DateTime | null
-  registeredAtTime_lt?: DateTime | null
-  registeredAtTime_lte?: DateTime | null
-  registeredAtTime_gt?: DateTime | null
-  registeredAtTime_gte?: DateTime | null
+  createdInBlock_eq?: Int | null
+  createdInBlock_gt?: Int | null
+  createdInBlock_gte?: Int | null
+  createdInBlock_lt?: Int | null
+  createdInBlock_lte?: Int | null
+  createdInBlock_in?: Int[] | Int | null
   entry_eq?: MembershipEntryMethod | null
   entry_in?: MembershipEntryMethod[] | MembershipEntryMethod | null
-  subscription_eq?: BigInt | null
-  subscription_gt?: BigInt | null
-  subscription_gte?: BigInt | null
-  subscription_lt?: BigInt | null
-  subscription_lte?: BigInt | null
-  subscription_in?: BigInt[] | BigInt | null
+  subscription_eq?: Int | null
+  subscription_gt?: Int | null
+  subscription_gte?: Int | null
+  subscription_lt?: Int | null
+  subscription_lte?: Int | null
+  subscription_in?: Int[] | Int | null
 }
 
 export interface MembershipWhereUniqueInput {
@@ -1124,12 +1131,12 @@ export interface MembershipWhereUniqueInput {
 
 export interface VideoCategoryCreateInput {
   name?: String | null
-  happenedIn: Float
+  createdInBlock: Float
 }
 
 export interface VideoCategoryUpdateInput {
   name?: String | null
-  happenedIn?: Float | null
+  createdInBlock?: Float | null
 }
 
 export interface VideoCategoryWhereInput {
@@ -1162,12 +1169,12 @@ export interface VideoCategoryWhereInput {
   name_startsWith?: String | null
   name_endsWith?: String | null
   name_in?: String[] | String | null
-  happenedIn_eq?: Int | null
-  happenedIn_gt?: Int | null
-  happenedIn_gte?: Int | null
-  happenedIn_lt?: Int | null
-  happenedIn_lte?: Int | null
-  happenedIn_in?: Int[] | Int | null
+  createdInBlock_eq?: Int | null
+  createdInBlock_gt?: Int | null
+  createdInBlock_gte?: Int | null
+  createdInBlock_lt?: Int | null
+  createdInBlock_lte?: Int | null
+  createdInBlock_in?: Int[] | Int | null
 }
 
 export interface VideoCategoryWhereUniqueInput {
@@ -1175,7 +1182,7 @@ export interface VideoCategoryWhereUniqueInput {
 }
 
 export interface VideoCreateInput {
-  channelId: ID_Output
+  channelId?: ID_Input | null
   categoryId?: ID_Input | null
   title?: String | null
   description?: String | null
@@ -1194,7 +1201,7 @@ export interface VideoCreateInput {
   mediaUrls: Array<String>
   mediaAvailability: AssetAvailability
   mediaMetadataId?: ID_Input | null
-  happenedIn: Float
+  createdInBlock: Float
   isFeatured: Boolean
 }
 
@@ -1260,16 +1267,16 @@ export interface VideoMediaMetadataCreateInput {
   encodingId?: ID_Input | null
   pixelWidth?: Float | null
   pixelHeight?: Float | null
-  size?: BigInt | null
-  happenedIn: Float
+  size?: Float | null
+  createdInBlock: Float
 }
 
 export interface VideoMediaMetadataUpdateInput {
   encodingId?: ID_Input | null
   pixelWidth?: Float | null
   pixelHeight?: Float | null
-  size?: BigInt | null
-  happenedIn?: Float | null
+  size?: Float | null
+  createdInBlock?: Float | null
 }
 
 export interface VideoMediaMetadataWhereInput {
@@ -1311,18 +1318,18 @@ export interface VideoMediaMetadataWhereInput {
   pixelHeight_lt?: Int | null
   pixelHeight_lte?: Int | null
   pixelHeight_in?: Int[] | Int | null
-  size_eq?: BigInt | null
-  size_gt?: BigInt | null
-  size_gte?: BigInt | null
-  size_lt?: BigInt | null
-  size_lte?: BigInt | null
-  size_in?: BigInt[] | BigInt | null
-  happenedIn_eq?: Int | null
-  happenedIn_gt?: Int | null
-  happenedIn_gte?: Int | null
-  happenedIn_lt?: Int | null
-  happenedIn_lte?: Int | null
-  happenedIn_in?: Int[] | Int | null
+  size_eq?: Int | null
+  size_gt?: Int | null
+  size_gte?: Int | null
+  size_lt?: Int | null
+  size_lte?: Int | null
+  size_in?: Int[] | Int | null
+  createdInBlock_eq?: Int | null
+  createdInBlock_gt?: Int | null
+  createdInBlock_gte?: Int | null
+  createdInBlock_lt?: Int | null
+  createdInBlock_lte?: Int | null
+  createdInBlock_in?: Int[] | Int | null
 }
 
 export interface VideoMediaMetadataWhereUniqueInput {
@@ -1349,7 +1356,7 @@ export interface VideoUpdateInput {
   mediaUrls?: String[] | String | null
   mediaAvailability?: AssetAvailability | null
   mediaMetadataId?: ID_Input | null
-  happenedIn?: Float | null
+  createdInBlock?: Float | null
   isFeatured?: Boolean | null
 }
 
@@ -1425,12 +1432,12 @@ export interface VideoWhereInput {
   mediaAvailability_in?: AssetAvailability[] | AssetAvailability | null
   mediaMetadataId_eq?: ID_Input | null
   mediaMetadataId_in?: ID_Output[] | ID_Output | null
-  happenedIn_eq?: Int | null
-  happenedIn_gt?: Int | null
-  happenedIn_gte?: Int | null
-  happenedIn_lt?: Int | null
-  happenedIn_lte?: Int | null
-  happenedIn_in?: Int[] | Int | null
+  createdInBlock_eq?: Int | null
+  createdInBlock_gt?: Int | null
+  createdInBlock_gte?: Int | null
+  createdInBlock_lt?: Int | null
+  createdInBlock_lte?: Int | null
+  createdInBlock_in?: Int[] | Int | null
   isFeatured_eq?: Boolean | null
   isFeatured_in?: Boolean[] | Boolean | null
 }
@@ -1439,6 +1446,65 @@ export interface VideoWhereUniqueInput {
   id: ID_Output
 }
 
+export interface WorkerCreateInput {
+  isActive: Boolean
+  workerId: String
+  type: WorkerType
+  metadata?: String | null
+}
+
+export interface WorkerUpdateInput {
+  isActive?: Boolean | null
+  workerId?: String | null
+  type?: WorkerType | null
+  metadata?: String | null
+}
+
+export interface WorkerWhereInput {
+  id_eq?: ID_Input | null
+  id_in?: ID_Output[] | ID_Output | null
+  createdAt_eq?: DateTime | null
+  createdAt_lt?: DateTime | null
+  createdAt_lte?: DateTime | null
+  createdAt_gt?: DateTime | null
+  createdAt_gte?: DateTime | null
+  createdById_eq?: ID_Input | null
+  createdById_in?: ID_Output[] | ID_Output | null
+  updatedAt_eq?: DateTime | null
+  updatedAt_lt?: DateTime | null
+  updatedAt_lte?: DateTime | null
+  updatedAt_gt?: DateTime | null
+  updatedAt_gte?: DateTime | null
+  updatedById_eq?: ID_Input | null
+  updatedById_in?: ID_Output[] | ID_Output | null
+  deletedAt_all?: Boolean | null
+  deletedAt_eq?: DateTime | null
+  deletedAt_lt?: DateTime | null
+  deletedAt_lte?: DateTime | null
+  deletedAt_gt?: DateTime | null
+  deletedAt_gte?: DateTime | null
+  deletedById_eq?: ID_Input | null
+  deletedById_in?: ID_Output[] | ID_Output | null
+  isActive_eq?: Boolean | null
+  isActive_in?: Boolean[] | Boolean | null
+  workerId_eq?: String | null
+  workerId_contains?: String | null
+  workerId_startsWith?: String | null
+  workerId_endsWith?: String | null
+  workerId_in?: String[] | String | null
+  type_eq?: WorkerType | null
+  type_in?: WorkerType[] | WorkerType | null
+  metadata_eq?: String | null
+  metadata_contains?: String | null
+  metadata_startsWith?: String | null
+  metadata_endsWith?: String | null
+  metadata_in?: String[] | String | null
+}
+
+export interface WorkerWhereUniqueInput {
+  id: ID_Output
+}
+
 export interface BaseGraphQLObject {
   id: ID_Output
   createdAt: DateTime
@@ -1507,7 +1573,7 @@ export interface Channel extends BaseGraphQLObject {
   language?: Language | null
   languageId?: String | null
   videos: Array<Video>
-  happenedIn: Int
+  createdInBlock: Int
 }
 
 export interface ChannelCategoriesByNameFTSOutput {
@@ -1532,7 +1598,7 @@ export interface ChannelCategory extends BaseGraphQLObject {
   version: Int
   name?: String | null
   channels: Array<Channel>
-  happenedIn: Int
+  createdInBlock: Int
 }
 
 export interface ChannelCategoryConnection {
@@ -1566,7 +1632,7 @@ export interface CuratorGroup extends BaseGraphQLObject {
   deletedAt?: DateTime | null
   deletedById?: String | null
   version: Int
-  curatorIds: Array<BigInt>
+  curatorIds: Array<Int>
   isActive: Boolean
   channels: Array<Channel>
 }
@@ -1596,10 +1662,11 @@ export interface DataObject extends BaseGraphQLObject {
   deletedById?: String | null
   version: Int
   owner: DataObjectOwner
-  addedAt: Int
+  createdInBlock: Int
   typeId: Int
-  size: BigInt
-  liaisonId: BigInt
+  size: Int
+  liaison?: Worker | null
+  liaisonId?: String | null
   liaisonJudgement: LiaisonJudgement
   ipfsContentId: String
   joystreamContentId: String
@@ -1621,7 +1688,7 @@ export interface DataObjectEdge {
 }
 
 export interface DataObjectOwnerChannel {
-  channel: BigInt
+  channel: Int
   dummy?: Int | null
 }
 
@@ -1630,16 +1697,16 @@ export interface DataObjectOwnerCouncil {
 }
 
 export interface DataObjectOwnerDao {
-  dao: BigInt
+  dao: Int
 }
 
 export interface DataObjectOwnerMember {
-  member: BigInt
+  member: Int
   dummy?: Int | null
 }
 
 export interface DataObjectOwnerWorkingGroup {
-  dummy?: Int | null
+  workingGroup: Int
 }
 
 export interface FeaturedVideo extends BaseGraphQLObject {
@@ -1676,7 +1743,7 @@ export interface Language extends BaseGraphQLObject {
   deletedById?: String | null
   version: Int
   iso: String
-  happenedIn: Int
+  createdInBlock: Int
   channellanguage?: Array<Channel> | null
   videolanguage?: Array<Video> | null
 }
@@ -1743,10 +1810,9 @@ export interface Membership extends BaseGraphQLObject {
   about?: String | null
   controllerAccount: String
   rootAccount: String
-  registeredAtBlock: Int
-  registeredAtTime: DateTime
+  createdInBlock: Int
   entry: MembershipEntryMethod
-  subscription?: BigInt | null
+  subscription?: Int | null
   channels: Array<Channel>
 }
 
@@ -1795,8 +1861,8 @@ export interface Video extends BaseGraphQLObject {
   deletedAt?: DateTime | null
   deletedById?: String | null
   version: Int
-  channel: Channel
-  channelId: String
+  channel?: Channel | null
+  channelId?: String | null
   category?: VideoCategory | null
   categoryId?: String | null
   title?: String | null
@@ -1821,7 +1887,7 @@ export interface Video extends BaseGraphQLObject {
   mediaAvailability: AssetAvailability
   mediaMetadata?: VideoMediaMetadata | null
   mediaMetadataId?: String | null
-  happenedIn: Int
+  createdInBlock: Int
   isFeatured: Boolean
   featured?: FeaturedVideo | null
 }
@@ -1844,7 +1910,7 @@ export interface VideoCategory extends BaseGraphQLObject {
   version: Int
   name?: String | null
   videos: Array<Video>
-  happenedIn: Int
+  createdInBlock: Int
 }
 
 export interface VideoCategoryConnection {
@@ -1908,9 +1974,9 @@ export interface VideoMediaMetadata extends BaseGraphQLObject {
   encodingId?: String | null
   pixelWidth?: Int | null
   pixelHeight?: Int | null
-  size?: BigInt | null
+  size?: Int | null
   video?: Video | null
-  happenedIn: Int
+  createdInBlock: Int
 }
 
 export interface VideoMediaMetadataConnection {
@@ -1924,10 +1990,32 @@ export interface VideoMediaMetadataEdge {
   cursor: String
 }
 
-/*
-GraphQL representation of BigInt
-*/
-export type BigInt = string
+export interface Worker extends BaseGraphQLObject {
+  id: ID_Output
+  createdAt: DateTime
+  createdById: String
+  updatedAt?: DateTime | null
+  updatedById?: String | null
+  deletedAt?: DateTime | null
+  deletedById?: String | null
+  version: Int
+  isActive: Boolean
+  workerId: String
+  type: WorkerType
+  metadata?: String | null
+  dataObjects: Array<DataObject>
+}
+
+export interface WorkerConnection {
+  totalCount: Int
+  edges: Array<WorkerEdge>
+  pageInfo: PageInfo
+}
+
+export interface WorkerEdge {
+  node: Worker
+  cursor: String
+}
 
 /*
 The `Boolean` scalar type represents `true` or `false`.

query-node/generated/graphql-server/generated/schema.graphql

@@ -61,9 +61,6 @@ input BaseWhereInput {
   deletedById_eq: String
 }
 
-"""GraphQL representation of BigInt"""
-scalar BigInt
-
 type Channel implements BaseGraphQLObject {
   id: ID!
   createdAt: DateTime!
@@ -113,7 +110,7 @@ type Channel implements BaseGraphQLObject {
   language: Language
   languageId: String
   videos: [Video!]!
-  happenedIn: Int!
+  createdInBlock: Int!
 }
 
 type ChannelCategoriesByNameFTSOutput {
@@ -139,7 +136,7 @@ type ChannelCategory implements BaseGraphQLObject {
   """The name of the category"""
   name: String
   channels: [Channel!]!
-  happenedIn: Int!
+  createdInBlock: Int!
 }
 
 type ChannelCategoryConnection {
@@ -150,7 +147,7 @@ type ChannelCategoryConnection {
 
 input ChannelCategoryCreateInput {
   name: String
-  happenedIn: Float!
+  createdInBlock: Float!
 }
 
 type ChannelCategoryEdge {
@@ -167,13 +164,13 @@ enum ChannelCategoryOrderByInput {
   deletedAt_DESC
   name_ASC
   name_DESC
-  happenedIn_ASC
-  happenedIn_DESC
+  createdInBlock_ASC
+  createdInBlock_DESC
 }
 
 input ChannelCategoryUpdateInput {
   name: String
-  happenedIn: Float
+  createdInBlock: Float
 }
 
 input ChannelCategoryWhereInput {
@@ -206,12 +203,12 @@ input ChannelCategoryWhereInput {
   name_startsWith: String
   name_endsWith: String
   name_in: [String!]
-  happenedIn_eq: Int
-  happenedIn_gt: Int
-  happenedIn_gte: Int
-  happenedIn_lt: Int
-  happenedIn_lte: Int
-  happenedIn_in: [Int!]
+  createdInBlock_eq: Int
+  createdInBlock_gt: Int
+  createdInBlock_gte: Int
+  createdInBlock_lt: Int
+  createdInBlock_lte: Int
+  createdInBlock_in: [Int!]
 }
 
 input ChannelCategoryWhereUniqueInput {
@@ -240,7 +237,7 @@ input ChannelCreateInput {
   isPublic: Boolean
   isCensored: Boolean!
   languageId: ID
-  happenedIn: Float!
+  createdInBlock: Float!
 }
 
 type ChannelEdge {
@@ -281,8 +278,8 @@ enum ChannelOrderByInput {
   isCensored_DESC
   languageId_ASC
   languageId_DESC
-  happenedIn_ASC
-  happenedIn_DESC
+  createdInBlock_ASC
+  createdInBlock_DESC
 }
 
 input ChannelUpdateInput {
@@ -301,7 +298,7 @@ input ChannelUpdateInput {
   isPublic: Boolean
   isCensored: Boolean
   languageId: ID
-  happenedIn: Float
+  createdInBlock: Float
 }
 
 input ChannelWhereInput {
@@ -364,12 +361,12 @@ input ChannelWhereInput {
   isCensored_in: [Boolean!]
   languageId_eq: ID
   languageId_in: [ID!]
-  happenedIn_eq: Int
-  happenedIn_gt: Int
-  happenedIn_gte: Int
-  happenedIn_lt: Int
-  happenedIn_lte: Int
-  happenedIn_in: [Int!]
+  createdInBlock_eq: Int
+  createdInBlock_gt: Int
+  createdInBlock_gte: Int
+  createdInBlock_lt: Int
+  createdInBlock_lte: Int
+  createdInBlock_in: [Int!]
 }
 
 input ChannelWhereUniqueInput {
@@ -387,7 +384,7 @@ type CuratorGroup implements BaseGraphQLObject {
   version: Int!
 
   """Curators belonging to this group"""
-  curatorIds: [BigInt!]!
+  curatorIds: [Int!]!
 
   """Is group active or not"""
   isActive: Boolean!
@@ -401,7 +398,7 @@ type CuratorGroupConnection {
 }
 
 input CuratorGroupCreateInput {
-  curatorIds: [BigInt!]!
+  curatorIds: [Int!]!
   isActive: Boolean!
 }
 
@@ -422,7 +419,7 @@ enum CuratorGroupOrderByInput {
 }
 
 input CuratorGroupUpdateInput {
-  curatorIds: [BigInt!]
+  curatorIds: [Int!]
   isActive: Boolean
 }
 
@@ -474,16 +471,15 @@ type DataObject implements BaseGraphQLObject {
   owner: DataObjectOwner!
 
   """Content added at"""
-  addedAt: Int!
+  createdInBlock: Int!
 
   """Content type id"""
   typeId: Int!
 
   """Content size in bytes"""
-  size: BigInt!
-
-  """Storage provider id of the liaison"""
-  liaisonId: BigInt!
+  size: Int!
+  liaison: Worker
+  liaisonId: String
 
   """Storage provider as liaison judgment"""
   liaisonJudgement: LiaisonJudgement!
@@ -507,10 +503,10 @@ type DataObjectConnection {
 
 input DataObjectCreateInput {
   owner: JSONObject!
-  addedAt: Float!
+  createdInBlock: Float!
   typeId: Float!
-  size: BigInt!
-  liaisonId: BigInt!
+  size: Float!
+  liaisonId: ID
   liaisonJudgement: LiaisonJudgement!
   ipfsContentId: String!
   joystreamContentId: String!
@@ -528,8 +524,8 @@ enum DataObjectOrderByInput {
   updatedAt_DESC
   deletedAt_ASC
   deletedAt_DESC
-  addedAt_ASC
-  addedAt_DESC
+  createdInBlock_ASC
+  createdInBlock_DESC
   typeId_ASC
   typeId_DESC
   size_ASC
@@ -548,19 +544,19 @@ union DataObjectOwner = DataObjectOwnerMember | DataObjectOwnerChannel | DataObj
 
 type DataObjectOwnerChannel {
   """Channel identifier"""
-  channel: BigInt!
+  channel: Int!
 
   """Variant needs to have at least one property. This value is not used."""
   dummy: Int
 }
 
 input DataObjectOwnerChannelCreateInput {
-  channel: BigInt!
+  channel: Float!
   dummy: Float
 }
 
 input DataObjectOwnerChannelUpdateInput {
-  channel: BigInt
+  channel: Float
   dummy: Float
 }
 
@@ -589,12 +585,12 @@ input DataObjectOwnerChannelWhereInput {
   deletedAt_gte: DateTime
   deletedById_eq: ID
   deletedById_in: [ID!]
-  channel_eq: BigInt
-  channel_gt: BigInt
-  channel_gte: BigInt
-  channel_lt: BigInt
-  channel_lte: BigInt
-  channel_in: [BigInt!]
+  channel_eq: Int
+  channel_gt: Int
+  channel_gte: Int
+  channel_lt: Int
+  channel_lte: Int
+  channel_in: [Int!]
   dummy_eq: Int
   dummy_gt: Int
   dummy_gte: Int
@@ -659,15 +655,15 @@ input DataObjectOwnerCouncilWhereUniqueInput {
 
 type DataObjectOwnerDao {
   """DAO identifier"""
-  dao: BigInt!
+  dao: Int!
 }
 
 input DataObjectOwnerDaoCreateInput {
-  dao: BigInt!
+  dao: Float!
 }
 
 input DataObjectOwnerDaoUpdateInput {
-  dao: BigInt
+  dao: Float
 }
 
 input DataObjectOwnerDaoWhereInput {
@@ -695,12 +691,12 @@ input DataObjectOwnerDaoWhereInput {
   deletedAt_gte: DateTime
   deletedById_eq: ID
   deletedById_in: [ID!]
-  dao_eq: BigInt
-  dao_gt: BigInt
-  dao_gte: BigInt
-  dao_lt: BigInt
-  dao_lte: BigInt
-  dao_in: [BigInt!]
+  dao_eq: Int
+  dao_gt: Int
+  dao_gte: Int
+  dao_lt: Int
+  dao_lte: Int
+  dao_in: [Int!]
 }
 
 input DataObjectOwnerDaoWhereUniqueInput {
@@ -709,19 +705,19 @@ input DataObjectOwnerDaoWhereUniqueInput {
 
 type DataObjectOwnerMember {
   """Member identifier"""
-  member: BigInt!
+  member: Int!
 
   """Variant needs to have at least one property. This value is not used."""
   dummy: Int
 }
 
 input DataObjectOwnerMemberCreateInput {
-  member: BigInt!
+  member: Float!
   dummy: Float
 }
 
 input DataObjectOwnerMemberUpdateInput {
-  member: BigInt
+  member: Float
   dummy: Float
 }
 
@@ -750,12 +746,12 @@ input DataObjectOwnerMemberWhereInput {
   deletedAt_gte: DateTime
   deletedById_eq: ID
   deletedById_in: [ID!]
-  member_eq: BigInt
-  member_gt: BigInt
-  member_gte: BigInt
-  member_lt: BigInt
-  member_lte: BigInt
-  member_in: [BigInt!]
+  member_eq: Int
+  member_gt: Int
+  member_gte: Int
+  member_lt: Int
+  member_lte: Int
+  member_in: [Int!]
   dummy_eq: Int
   dummy_gt: Int
   dummy_gte: Int
@@ -769,16 +765,16 @@ input DataObjectOwnerMemberWhereUniqueInput {
 }
 
 type DataObjectOwnerWorkingGroup {
-  """Variant needs to have at least one property. This value is not used."""
-  dummy: Int
+  """Working group identifier"""
+  workingGroup: Int!
 }
 
 input DataObjectOwnerWorkingGroupCreateInput {
-  dummy: Float
+  workingGroup: Float!
 }
 
 input DataObjectOwnerWorkingGroupUpdateInput {
-  dummy: Float
+  workingGroup: Float
 }
 
 input DataObjectOwnerWorkingGroupWhereInput {
@@ -806,12 +802,12 @@ input DataObjectOwnerWorkingGroupWhereInput {
   deletedAt_gte: DateTime
   deletedById_eq: ID
   deletedById_in: [ID!]
-  dummy_eq: Int
-  dummy_gt: Int
-  dummy_gte: Int
-  dummy_lt: Int
-  dummy_lte: Int
-  dummy_in: [Int!]
+  workingGroup_eq: Int
+  workingGroup_gt: Int
+  workingGroup_gte: Int
+  workingGroup_lt: Int
+  workingGroup_lte: Int
+  workingGroup_in: [Int!]
 }
 
 input DataObjectOwnerWorkingGroupWhereUniqueInput {
@@ -820,10 +816,10 @@ input DataObjectOwnerWorkingGroupWhereUniqueInput {
 
 input DataObjectUpdateInput {
   owner: JSONObject
-  addedAt: Float
+  createdInBlock: Float
   typeId: Float
-  size: BigInt
-  liaisonId: BigInt
+  size: Float
+  liaisonId: ID
   liaisonJudgement: LiaisonJudgement
   ipfsContentId: String
   joystreamContentId: String
@@ -855,30 +851,26 @@ input DataObjectWhereInput {
   deletedById_eq: ID
   deletedById_in: [ID!]
   owner_json: JSONObject
-  addedAt_eq: Int
-  addedAt_gt: Int
-  addedAt_gte: Int
-  addedAt_lt: Int
-  addedAt_lte: Int
-  addedAt_in: [Int!]
+  createdInBlock_eq: Int
+  createdInBlock_gt: Int
+  createdInBlock_gte: Int
+  createdInBlock_lt: Int
+  createdInBlock_lte: Int
+  createdInBlock_in: [Int!]
   typeId_eq: Int
   typeId_gt: Int
   typeId_gte: Int
   typeId_lt: Int
   typeId_lte: Int
   typeId_in: [Int!]
-  size_eq: BigInt
-  size_gt: BigInt
-  size_gte: BigInt
-  size_lt: BigInt
-  size_lte: BigInt
-  size_in: [BigInt!]
-  liaisonId_eq: BigInt
-  liaisonId_gt: BigInt
-  liaisonId_gte: BigInt
-  liaisonId_lt: BigInt
-  liaisonId_lte: BigInt
-  liaisonId_in: [BigInt!]
+  size_eq: Int
+  size_gt: Int
+  size_gte: Int
+  size_lt: Int
+  size_lte: Int
+  size_in: [Int!]
+  liaisonId_eq: ID
+  liaisonId_in: [ID!]
   liaisonJudgement_eq: LiaisonJudgement
   liaisonJudgement_in: [LiaisonJudgement!]
   ipfsContentId_eq: String
@@ -999,7 +991,7 @@ type Language implements BaseGraphQLObject {
 
   """Language identifier ISO 639-1"""
   iso: String!
-  happenedIn: Int!
+  createdInBlock: Int!
   channellanguage: [Channel!]
   videolanguage: [Video!]
 }
@@ -1012,7 +1004,7 @@ type LanguageConnection {
 
 input LanguageCreateInput {
   iso: String!
-  happenedIn: Float!
+  createdInBlock: Float!
 }
 
 type LanguageEdge {
@@ -1029,13 +1021,13 @@ enum LanguageOrderByInput {
   deletedAt_DESC
   iso_ASC
   iso_DESC
-  happenedIn_ASC
-  happenedIn_DESC
+  createdInBlock_ASC
+  createdInBlock_DESC
 }
 
 input LanguageUpdateInput {
   iso: String
-  happenedIn: Float
+  createdInBlock: Float
 }
 
 input LanguageWhereInput {
@@ -1068,12 +1060,12 @@ input LanguageWhereInput {
   iso_startsWith: String
   iso_endsWith: String
   iso_in: [String!]
-  happenedIn_eq: Int
-  happenedIn_gt: Int
-  happenedIn_gte: Int
-  happenedIn_lt: Int
-  happenedIn_lte: Int
-  happenedIn_in: [Int!]
+  createdInBlock_eq: Int
+  createdInBlock_gt: Int
+  createdInBlock_gte: Int
+  createdInBlock_lt: Int
+  createdInBlock_lte: Int
+  createdInBlock_in: [Int!]
 }
 
 input LanguageWhereUniqueInput {
@@ -1083,7 +1075,6 @@ input LanguageWhereUniqueInput {
 enum LiaisonJudgement {
   PENDING
   ACCEPTED
-  REJECTED
 }
 
 type License implements BaseGraphQLObject {
@@ -1228,16 +1219,13 @@ type Membership implements BaseGraphQLObject {
   rootAccount: String!
 
   """Blocknumber when member was registered"""
-  registeredAtBlock: Int!
-
-  """Timestamp when member was registered"""
-  registeredAtTime: DateTime!
+  createdInBlock: Int!
 
   """How the member was registered"""
   entry: MembershipEntryMethod!
 
   """The type of subscription the member has purchased if any."""
-  subscription: BigInt
+  subscription: Int
   channels: [Channel!]!
 }
 
@@ -1253,10 +1241,9 @@ input MembershipCreateInput {
   about: String
   controllerAccount: String!
   rootAccount: String!
-  registeredAtBlock: Float!
-  registeredAtTime: DateTime!
+  createdInBlock: Float!
   entry: MembershipEntryMethod!
-  subscription: BigInt
+  subscription: Float
 }
 
 type MembershipEdge {
@@ -1287,10 +1274,8 @@ enum MembershipOrderByInput {
   controllerAccount_DESC
   rootAccount_ASC
   rootAccount_DESC
-  registeredAtBlock_ASC
-  registeredAtBlock_DESC
-  registeredAtTime_ASC
-  registeredAtTime_DESC
+  createdInBlock_ASC
+  createdInBlock_DESC
   entry_ASC
   entry_DESC
   subscription_ASC
@@ -1303,10 +1288,9 @@ input MembershipUpdateInput {
   about: String
   controllerAccount: String
   rootAccount: String
-  registeredAtBlock: Float
-  registeredAtTime: DateTime
+  createdInBlock: Float
   entry: MembershipEntryMethod
-  subscription: BigInt
+  subscription: Float
 }
 
 input MembershipWhereInput {
@@ -1359,25 +1343,20 @@ input MembershipWhereInput {
   rootAccount_startsWith: String
   rootAccount_endsWith: String
   rootAccount_in: [String!]
-  registeredAtBlock_eq: Int
-  registeredAtBlock_gt: Int
-  registeredAtBlock_gte: Int
-  registeredAtBlock_lt: Int
-  registeredAtBlock_lte: Int
-  registeredAtBlock_in: [Int!]
-  registeredAtTime_eq: DateTime
-  registeredAtTime_lt: DateTime
-  registeredAtTime_lte: DateTime
-  registeredAtTime_gt: DateTime
-  registeredAtTime_gte: DateTime
+  createdInBlock_eq: Int
+  createdInBlock_gt: Int
+  createdInBlock_gte: Int
+  createdInBlock_lt: Int
+  createdInBlock_lte: Int
+  createdInBlock_in: [Int!]
   entry_eq: MembershipEntryMethod
   entry_in: [MembershipEntryMethod!]
-  subscription_eq: BigInt
-  subscription_gt: BigInt
-  subscription_gte: BigInt
-  subscription_lt: BigInt
-  subscription_lte: BigInt
-  subscription_in: [BigInt!]
+  subscription_eq: Int
+  subscription_gt: Int
+  subscription_gte: Int
+  subscription_lt: Int
+  subscription_lte: Int
+  subscription_in: [Int!]
 }
 
 input MembershipWhereUniqueInput {
@@ -1440,6 +1419,9 @@ type Query {
   videos(offset: Int, limit: Int = 50, where: VideoWhereInput, orderBy: VideoOrderByInput): [Video!]!
   videoByUniqueInput(where: VideoWhereUniqueInput!): Video
   videosConnection(first: Int, after: String, last: Int, before: String, where: VideoWhereInput, orderBy: VideoOrderByInput): VideoConnection!
+  workers(offset: Int, limit: Int = 50, where: WorkerWhereInput, orderBy: WorkerOrderByInput): [Worker!]!
+  workerByUniqueInput(where: WorkerWhereUniqueInput!): Worker
+  workersConnection(first: Int, after: String, last: Int, before: String, where: WorkerWhereInput, orderBy: WorkerOrderByInput): WorkerConnection!
 }
 
 type SearchFTSOutput {
@@ -1468,8 +1450,8 @@ type Video implements BaseGraphQLObject {
   deletedAt: DateTime
   deletedById: String
   version: Int!
-  channel: Channel!
-  channelId: String!
+  channel: Channel
+  channelId: String
   category: VideoCategory
   categoryId: String
 
@@ -1520,7 +1502,7 @@ type Video implements BaseGraphQLObject {
   mediaAvailability: AssetAvailability!
   mediaMetadata: VideoMediaMetadata
   mediaMetadataId: String
-  happenedIn: Int!
+  createdInBlock: Int!
 
   """Is video featured or not"""
   isFeatured: Boolean!
@@ -1549,7 +1531,7 @@ type VideoCategory implements BaseGraphQLObject {
   """The name of the category"""
   name: String
   videos: [Video!]!
-  happenedIn: Int!
+  createdInBlock: Int!
 }
 
 type VideoCategoryConnection {
@@ -1560,7 +1542,7 @@ type VideoCategoryConnection {
 
 input VideoCategoryCreateInput {
   name: String
-  happenedIn: Float!
+  createdInBlock: Float!
 }
 
 type VideoCategoryEdge {
@@ -1577,13 +1559,13 @@ enum VideoCategoryOrderByInput {
   deletedAt_DESC
   name_ASC
   name_DESC
-  happenedIn_ASC
-  happenedIn_DESC
+  createdInBlock_ASC
+  createdInBlock_DESC
 }
 
 input VideoCategoryUpdateInput {
   name: String
-  happenedIn: Float
+  createdInBlock: Float
 }
 
 input VideoCategoryWhereInput {
@@ -1616,12 +1598,12 @@ input VideoCategoryWhereInput {
   name_startsWith: String
   name_endsWith: String
   name_in: [String!]
-  happenedIn_eq: Int
-  happenedIn_gt: Int
-  happenedIn_gte: Int
-  happenedIn_lt: Int
-  happenedIn_lte: Int
-  happenedIn_in: [Int!]
+  createdInBlock_eq: Int
+  createdInBlock_gt: Int
+  createdInBlock_gte: Int
+  createdInBlock_lt: Int
+  createdInBlock_lte: Int
+  createdInBlock_in: [Int!]
 }
 
 input VideoCategoryWhereUniqueInput {
@@ -1635,7 +1617,7 @@ type VideoConnection {
 }
 
 input VideoCreateInput {
-  channelId: ID!
+  channelId: ID
   categoryId: ID
   title: String
   description: String
@@ -1654,7 +1636,7 @@ input VideoCreateInput {
   mediaUrls: [String!]!
   mediaAvailability: AssetAvailability!
   mediaMetadataId: ID
-  happenedIn: Float!
+  createdInBlock: Float!
   isFeatured: Boolean!
 }
 
@@ -1787,9 +1769,9 @@ type VideoMediaMetadata implements BaseGraphQLObject {
   pixelHeight: Int
 
   """Video media size in bytes"""
-  size: BigInt
+  size: Int
   video: Video
-  happenedIn: Int!
+  createdInBlock: Int!
 }
 
 type VideoMediaMetadataConnection {
@@ -1802,8 +1784,8 @@ input VideoMediaMetadataCreateInput {
   encodingId: ID
   pixelWidth: Float
   pixelHeight: Float
-  size: BigInt
-  happenedIn: Float!
+  size: Float
+  createdInBlock: Float!
 }
 
 type VideoMediaMetadataEdge {
@@ -1826,16 +1808,16 @@ enum VideoMediaMetadataOrderByInput {
   pixelHeight_DESC
   size_ASC
   size_DESC
-  happenedIn_ASC
-  happenedIn_DESC
+  createdInBlock_ASC
+  createdInBlock_DESC
 }
 
 input VideoMediaMetadataUpdateInput {
   encodingId: ID
   pixelWidth: Float
   pixelHeight: Float
-  size: BigInt
-  happenedIn: Float
+  size: Float
+  createdInBlock: Float
 }
 
 input VideoMediaMetadataWhereInput {
@@ -1877,18 +1859,18 @@ input VideoMediaMetadataWhereInput {
   pixelHeight_lt: Int
   pixelHeight_lte: Int
   pixelHeight_in: [Int!]
-  size_eq: BigInt
-  size_gt: BigInt
-  size_gte: BigInt
-  size_lt: BigInt
-  size_lte: BigInt
-  size_in: [BigInt!]
-  happenedIn_eq: Int
-  happenedIn_gt: Int
-  happenedIn_gte: Int
-  happenedIn_lt: Int
-  happenedIn_lte: Int
-  happenedIn_in: [Int!]
+  size_eq: Int
+  size_gt: Int
+  size_gte: Int
+  size_lt: Int
+  size_lte: Int
+  size_in: [Int!]
+  createdInBlock_eq: Int
+  createdInBlock_gt: Int
+  createdInBlock_gte: Int
+  createdInBlock_lt: Int
+  createdInBlock_lte: Int
+  createdInBlock_in: [Int!]
 }
 
 input VideoMediaMetadataWhereUniqueInput {
@@ -1936,8 +1918,8 @@ enum VideoOrderByInput {
   mediaAvailability_DESC
   mediaMetadataId_ASC
   mediaMetadataId_DESC
-  happenedIn_ASC
-  happenedIn_DESC
+  createdInBlock_ASC
+  createdInBlock_DESC
   isFeatured_ASC
   isFeatured_DESC
 }
@@ -1962,7 +1944,7 @@ input VideoUpdateInput {
   mediaUrls: [String!]
   mediaAvailability: AssetAvailability
   mediaMetadataId: ID
-  happenedIn: Float
+  createdInBlock: Float
   isFeatured: Boolean
 }
 
@@ -2038,12 +2020,12 @@ input VideoWhereInput {
   mediaAvailability_in: [AssetAvailability!]
   mediaMetadataId_eq: ID
   mediaMetadataId_in: [ID!]
-  happenedIn_eq: Int
-  happenedIn_gt: Int
-  happenedIn_gte: Int
-  happenedIn_lt: Int
-  happenedIn_lte: Int
-  happenedIn_in: [Int!]
+  createdInBlock_eq: Int
+  createdInBlock_gt: Int
+  createdInBlock_gte: Int
+  createdInBlock_lt: Int
+  createdInBlock_lte: Int
+  createdInBlock_in: [Int!]
   isFeatured_eq: Boolean
   isFeatured_in: [Boolean!]
 }
@@ -2051,3 +2033,119 @@ input VideoWhereInput {
 input VideoWhereUniqueInput {
   id: ID!
 }
+
+type Worker implements BaseGraphQLObject {
+  id: ID!
+  createdAt: DateTime!
+  createdById: String!
+  updatedAt: DateTime
+  updatedById: String
+  deletedAt: DateTime
+  deletedById: String
+  version: Int!
+
+  """Sign of worker still being active"""
+  isActive: Boolean!
+
+  """Runtime identifier"""
+  workerId: String!
+
+  """Associated working group"""
+  type: WorkerType!
+
+  """Custom metadata set by provider"""
+  metadata: String
+  dataObjects: [DataObject!]!
+}
+
+type WorkerConnection {
+  totalCount: Int!
+  edges: [WorkerEdge!]!
+  pageInfo: PageInfo!
+}
+
+input WorkerCreateInput {
+  isActive: Boolean!
+  workerId: String!
+  type: WorkerType!
+  metadata: String
+}
+
+type WorkerEdge {
+  node: Worker!
+  cursor: String!
+}
+
+enum WorkerOrderByInput {
+  createdAt_ASC
+  createdAt_DESC
+  updatedAt_ASC
+  updatedAt_DESC
+  deletedAt_ASC
+  deletedAt_DESC
+  isActive_ASC
+  isActive_DESC
+  workerId_ASC
+  workerId_DESC
+  type_ASC
+  type_DESC
+  metadata_ASC
+  metadata_DESC
+}
+
+enum WorkerType {
+  GATEWAY
+  STORAGE
+}
+
+input WorkerUpdateInput {
+  isActive: Boolean
+  workerId: String
+  type: WorkerType
+  metadata: String
+}
+
+input WorkerWhereInput {
+  id_eq: ID
+  id_in: [ID!]
+  createdAt_eq: DateTime
+  createdAt_lt: DateTime
+  createdAt_lte: DateTime
+  createdAt_gt: DateTime
+  createdAt_gte: DateTime
+  createdById_eq: ID
+  createdById_in: [ID!]
+  updatedAt_eq: DateTime
+  updatedAt_lt: DateTime
+  updatedAt_lte: DateTime
+  updatedAt_gt: DateTime
+  updatedAt_gte: DateTime
+  updatedById_eq: ID
+  updatedById_in: [ID!]
+  deletedAt_all: Boolean
+  deletedAt_eq: DateTime
+  deletedAt_lt: DateTime
+  deletedAt_lte: DateTime
+  deletedAt_gt: DateTime
+  deletedAt_gte: DateTime
+  deletedById_eq: ID
+  deletedById_in: [ID!]
+  isActive_eq: Boolean
+  isActive_in: [Boolean!]
+  workerId_eq: String
+  workerId_contains: String
+  workerId_startsWith: String
+  workerId_endsWith: String
+  workerId_in: [String!]
+  type_eq: WorkerType
+  type_in: [WorkerType!]
+  metadata_eq: String
+  metadata_contains: String
+  metadata_startsWith: String
+  metadata_endsWith: String
+  metadata_in: [String!]
+}
+
+input WorkerWhereUniqueInput {
+  id: ID!
+}

query-node/generated/graphql-server/model/index.ts

@@ -22,6 +22,8 @@ import { VideoMediaEncoding } from '../src/modules/video-media-encoding/video-me
 export { VideoMediaEncoding };
 import { VideoMediaMetadata } from '../src/modules/video-media-metadata/video-media-metadata.model';
 export { VideoMediaMetadata };
+import { Worker } from '../src/modules/worker/worker.model';
+export { Worker };
 
 import { Network } from '../src/modules/enums/enums';
 export { Network };
@@ -31,6 +33,8 @@ import { AssetAvailability } from '../src/modules/enums/enums';
 export { AssetAvailability };
 import { LiaisonJudgement } from '../src/modules/enums/enums';
 export { LiaisonJudgement };
+import { WorkerType } from '../src/modules/enums/enums';
+export { WorkerType };
 
 import { DataObjectOwnerChannel } from '../src/modules/variants/variants.model';
 export { DataObjectOwnerChannel };

query-node/generated/graphql-server/src/modules/data-object/data-object.model.ts

@@ -1,4 +1,4 @@
-import { BaseModel, IntField, Model, OneToMany, EnumField, StringField } from 'warthog';
+import { BaseModel, IntField, Model, ManyToOne, OneToMany, EnumField, StringField } from 'warthog';
 
 import { Column } from 'typeorm';
 import { Field } from 'type-graphql';
@@ -6,6 +6,7 @@ import { WarthogField } from 'warthog';
 
 import { DataObjectOwner } from '../variants/variants.model';
 
+import { Worker } from '../worker/worker.model';
 import { Channel } from '../channel/channel.model';
 import { Video } from '../video/video.model';
 
@@ -36,11 +37,11 @@ export class DataObject extends BaseModel {
   })
   size!: number;
 
-  @IntField({
+  @ManyToOne(() => Worker, (param: Worker) => param.dataObjects, {
+    skipGraphQLField: true,
     nullable: true,
-    description: `Storage provider id of the liaison`,
   })
-  liaisonId?: number;
+  liaison?: Worker;
 
   @EnumField('LiaisonJudgement', LiaisonJudgement, {
     description: `Storage provider as liaison judgment`,

query-node/generated/graphql-server/src/modules/data-object/data-object.resolver.ts

@@ -30,6 +30,7 @@ import {
 import { DataObject } from './data-object.model';
 import { DataObjectService } from './data-object.service';
 
+import { Worker } from '../worker/worker.model';
 import { Channel } from '../channel/channel.model';
 import { Video } from '../video/video.model';
 import { getConnection } from 'typeorm';
@@ -130,6 +131,17 @@ export class DataObjectResolver {
     return result as Promise<DataObjectConnection>;
   }
 
+  @FieldResolver(() => Worker)
+  async liaison(@Root() r: DataObject): Promise<Worker | null> {
+    const result = await getConnection()
+      .getRepository(DataObject)
+      .findOne(r.id, { relations: ['liaison'] });
+    if (result && result.liaison !== undefined) {
+      return result.liaison;
+    }
+    return null;
+  }
+
   @FieldResolver(() => Channel)
   async channelcoverPhotoDataObject(@Root() r: DataObject): Promise<Channel[] | null> {
     const result = await getConnection()

query-node/generated/graphql-server/src/modules/enums/enums.ts

@@ -17,3 +17,7 @@ export enum LiaisonJudgement {
   PENDING = 'PENDING',
   ACCEPTED = 'ACCEPTED',
 }
+export enum WorkerType {
+  GATEWAY = 'GATEWAY',
+  STORAGE = 'STORAGE',
+}

query-node/generated/graphql-server/src/modules/video/video.model.ts

@@ -25,7 +25,7 @@ export { AssetAvailability };
 
 @Model({ api: {} })
 export class Video extends BaseModel {
-  @ManyToOne(() => Channel, (param: Channel) => param.videos, { skipGraphQLField: true, cascade: ["insert", "update"] })
+  @ManyToOne(() => Channel, (param: Channel) => param.videos, { skipGraphQLField: true, nullable: true, cascade: ["insert", "update"] })
   channel!: Channel;
 
   @ManyToOne(() => VideoCategory, (param: VideoCategory) => param.videos, { skipGraphQLField: true, nullable: true, cascade: ["insert", "update"] })

query-node/generated/graphql-server/src/modules/worker/worker.model.ts

@@ -0,0 +1,38 @@
+import { BaseModel, BooleanField, Model, OneToMany, EnumField, StringField } from 'warthog';
+
+import { DataObject } from '../data-object/data-object.model';
+
+import { WorkerType } from '../enums/enums';
+export { WorkerType };
+
+@Model({ api: {} })
+export class Worker extends BaseModel {
+  @BooleanField({
+    description: `Sign of worker still being active`,
+  })
+  isActive!: boolean;
+
+  @StringField({
+    description: `Runtime identifier`,
+  })
+  workerId!: string;
+
+  @EnumField('WorkerType', WorkerType, {
+    description: `Associated working group`,
+  })
+  type!: WorkerType;
+
+  @StringField({
+    nullable: true,
+    description: `Custom metadata set by provider`,
+  })
+  metadata?: string;
+
+  @OneToMany(() => DataObject, (param: DataObject) => param.liaison)
+  dataObjects?: DataObject[];
+
+  constructor(init?: Partial<Worker>) {
+    super();
+    Object.assign(this, init);
+  }
+}

query-node/generated/graphql-server/src/modules/worker/worker.resolver.ts

@@ -0,0 +1,142 @@
+import {
+  Arg,
+  Args,
+  Mutation,
+  Query,
+  Root,
+  Resolver,
+  FieldResolver,
+  ObjectType,
+  Field,
+  Int,
+  ArgsType,
+  Info,
+} from 'type-graphql';
+import graphqlFields from 'graphql-fields';
+import { Inject } from 'typedi';
+import { Min } from 'class-validator';
+import { Fields, StandardDeleteResponse, UserId, PageInfo, RawFields } from 'warthog';
+
+import {
+  WorkerCreateInput,
+  WorkerCreateManyArgs,
+  WorkerUpdateArgs,
+  WorkerWhereArgs,
+  WorkerWhereInput,
+  WorkerWhereUniqueInput,
+  WorkerOrderByEnum,
+} from '../../../generated';
+
+import { Worker } from './worker.model';
+import { WorkerService } from './worker.service';
+
+import { DataObject } from '../data-object/data-object.model';
+import { getConnection } from 'typeorm';
+
+@ObjectType()
+export class WorkerEdge {
+  @Field(() => Worker, { nullable: false })
+  node!: Worker;
+
+  @Field(() => String, { nullable: false })
+  cursor!: string;
+}
+
+@ObjectType()
+export class WorkerConnection {
+  @Field(() => Int, { nullable: false })
+  totalCount!: number;
+
+  @Field(() => [WorkerEdge], { nullable: false })
+  edges!: WorkerEdge[];
+
+  @Field(() => PageInfo, { nullable: false })
+  pageInfo!: PageInfo;
+}
+
+@ArgsType()
+export class ConnectionPageInputOptions {
+  @Field(() => Int, { nullable: true })
+  @Min(0)
+  first?: number;
+
+  @Field(() => String, { nullable: true })
+  after?: string; // V3: TODO: should we make a RelayCursor scalar?
+
+  @Field(() => Int, { nullable: true })
+  @Min(0)
+  last?: number;
+
+  @Field(() => String, { nullable: true })
+  before?: string;
+}
+
+@ArgsType()
+export class WorkerConnectionWhereArgs extends ConnectionPageInputOptions {
+  @Field(() => WorkerWhereInput, { nullable: true })
+  where?: WorkerWhereInput;
+
+  @Field(() => WorkerOrderByEnum, { nullable: true })
+  orderBy?: WorkerOrderByEnum;
+}
+
+@Resolver(Worker)
+export class WorkerResolver {
+  constructor(@Inject('WorkerService') public readonly service: WorkerService) {}
+
+  @Query(() => [Worker])
+  async workers(
+    @Args() { where, orderBy, limit, offset }: WorkerWhereArgs,
+    @Fields() fields: string[]
+  ): Promise<Worker[]> {
+    return this.service.find<WorkerWhereInput>(where, orderBy, limit, offset, fields);
+  }
+
+  @Query(() => Worker, { nullable: true })
+  async workerByUniqueInput(
+    @Arg('where') where: WorkerWhereUniqueInput,
+    @Fields() fields: string[]
+  ): Promise<Worker | null> {
+    const result = await this.service.find(where, undefined, 1, 0, fields);
+    return result && result.length >= 1 ? result[0] : null;
+  }
+
+  @Query(() => WorkerConnection)
+  async workersConnection(
+    @Args() { where, orderBy, ...pageOptions }: WorkerConnectionWhereArgs,
+    @Info() info: any
+  ): Promise<WorkerConnection> {
+    const rawFields = graphqlFields(info, {}, { excludedFields: ['__typename'] });
+
+    let result: any = {
+      totalCount: 0,
+      edges: [],
+      pageInfo: {
+        hasNextPage: false,
+        hasPreviousPage: false,
+      },
+    };
+    // If the related database table does not have any records then an error is thrown to the client
+    // by warthog
+    try {
+      result = await this.service.findConnection<WorkerWhereInput>(where, orderBy, pageOptions, rawFields);
+    } catch (err) {
+      console.log(err);
+      // TODO: should continue to return this on `Error: Items is empty` or throw the error
+      if (!(err.message as string).includes('Items is empty')) throw err;
+    }
+
+    return result as Promise<WorkerConnection>;
+  }
+
+  @FieldResolver(() => DataObject)
+  async dataObjects(@Root() r: Worker): Promise<DataObject[] | null> {
+    const result = await getConnection()
+      .getRepository(Worker)
+      .findOne(r.id, { relations: ['dataObjects'] });
+    if (result && result.dataObjects !== undefined) {
+      return result.dataObjects;
+    }
+    return null;
+  }
+}

query-node/generated/graphql-server/src/modules/worker/worker.service.ts

@@ -0,0 +1,28 @@
+import { Service } from 'typedi';
+import { Repository } from 'typeorm';
+import { InjectRepository } from 'typeorm-typedi-extensions';
+import { BaseService, WhereInput } from 'warthog';
+
+import { Worker } from './worker.model';
+
+@Service('WorkerService')
+export class WorkerService extends BaseService<Worker> {
+  constructor(@InjectRepository(Worker) protected readonly repository: Repository<Worker>) {
+    super(Worker, repository);
+  }
+
+  async find<W extends WhereInput>(
+    where?: any,
+    orderBy?: string,
+    limit?: number,
+    offset?: number,
+    fields?: string[]
+  ): Promise<Worker[]> {
+    let f = fields;
+    if (f == undefined) {
+      f = [];
+    }
+
+    return super.find<W>(where, orderBy, limit, offset, f);
+  }
+}

query-node/generated/types/gateway-working-group.ts

@@ -0,0 +1,421 @@
+import { createTypeUnsafe } from "@polkadot/types/create";
+import { SubstrateEvent, SubstrateExtrinsic } from "@dzlzv/hydra-common";
+import { Codec } from "@polkadot/types/types";
+import { typeRegistry } from ".";
+
+import {
+  ApplicationIdSet,
+  ApplicationIdToWorkerIdMap,
+  OpeningId,
+  RationaleText,
+  RewardPolicy,
+  WorkerId
+} from "@joystream/types/augment";
+import { Bytes, Option, bool } from "@polkadot/types";
+
+export namespace GatewayWorkingGroup {
+  /**
+   *  Emits on updating the worker storage role.
+   *  Params:
+   *  - Id of the worker.
+   *  - Raw storage field.
+   *
+   *  Event parameters: [WorkerId, Vec<u8>, ]
+   */
+  export class WorkerStorageUpdatedEvent {
+    public readonly expectedParamTypes = ["WorkerId", "Vec<u8>"];
+
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get data(): WorkerStorageUpdated_Params {
+      return new WorkerStorageUpdated_Params(this.ctx);
+    }
+
+    validateParams(): boolean {
+      if (this.expectedParamTypes.length !== this.ctx.params.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedParamTypes.forEach((type, i) => {
+        if (type !== this.ctx.params[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class WorkerStorageUpdated_Params {
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get workerId(): WorkerId {
+      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
+        this.ctx.params[0].value
+      ]);
+    }
+
+    get bytes(): Bytes {
+      return createTypeUnsafe<Bytes & Codec>(typeRegistry, "Bytes", [
+        this.ctx.params[1].value
+      ]);
+    }
+  }
+  /**
+   *  Emits on filling the worker opening.
+   *  Params:
+   *  - Worker opening id
+   *  - Worker application id to the worker id dictionary
+   *
+   *  Event parameters: [OpeningId, ApplicationIdToWorkerIdMap, ]
+   */
+  export class OpeningFilledEvent {
+    public readonly expectedParamTypes = [
+      "OpeningId",
+      "ApplicationIdToWorkerIdMap"
+    ];
+
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get data(): OpeningFilled_Params {
+      return new OpeningFilled_Params(this.ctx);
+    }
+
+    validateParams(): boolean {
+      if (this.expectedParamTypes.length !== this.ctx.params.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedParamTypes.forEach((type, i) => {
+        if (type !== this.ctx.params[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class OpeningFilled_Params {
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get openingId(): OpeningId {
+      return createTypeUnsafe<OpeningId & Codec>(typeRegistry, "OpeningId", [
+        this.ctx.params[0].value
+      ]);
+    }
+
+    get applicationIdToWorkerIdMap(): ApplicationIdToWorkerIdMap {
+      return createTypeUnsafe<ApplicationIdToWorkerIdMap & Codec>(
+        typeRegistry,
+        "ApplicationIdToWorkerIdMap",
+        [this.ctx.params[1].value]
+      );
+    }
+  }
+  /**
+   *  Emits on terminating the worker.
+   *  Params:
+   *  - worker id.
+   *  - termination rationale text
+   *
+   *  Event parameters: [WorkerId, RationaleText, ]
+   */
+  export class TerminatedWorkerEvent {
+    public readonly expectedParamTypes = ["WorkerId", "RationaleText"];
+
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get data(): TerminatedWorker_Params {
+      return new TerminatedWorker_Params(this.ctx);
+    }
+
+    validateParams(): boolean {
+      if (this.expectedParamTypes.length !== this.ctx.params.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedParamTypes.forEach((type, i) => {
+        if (type !== this.ctx.params[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class TerminatedWorker_Params {
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get workerId(): WorkerId {
+      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
+        this.ctx.params[0].value
+      ]);
+    }
+
+    get rationaleText(): RationaleText {
+      return createTypeUnsafe<RationaleText & Codec>(
+        typeRegistry,
+        "RationaleText",
+        [this.ctx.params[1].value]
+      );
+    }
+  }
+  /**
+   *  Emits on exiting the worker.
+   *  Params:
+   *  - worker id.
+   *  - exit rationale text
+   *
+   *  Event parameters: [WorkerId, RationaleText, ]
+   */
+  export class WorkerExitedEvent {
+    public readonly expectedParamTypes = ["WorkerId", "RationaleText"];
+
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get data(): WorkerExited_Params {
+      return new WorkerExited_Params(this.ctx);
+    }
+
+    validateParams(): boolean {
+      if (this.expectedParamTypes.length !== this.ctx.params.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedParamTypes.forEach((type, i) => {
+        if (type !== this.ctx.params[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class WorkerExited_Params {
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get workerId(): WorkerId {
+      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
+        this.ctx.params[0].value
+      ]);
+    }
+
+    get rationaleText(): RationaleText {
+      return createTypeUnsafe<RationaleText & Codec>(
+        typeRegistry,
+        "RationaleText",
+        [this.ctx.params[1].value]
+      );
+    }
+  }
+
+  /**
+   *  Update the associated role storage.
+   */
+  export class UpdateRoleStorageCall {
+    public readonly extrinsic: SubstrateExtrinsic;
+    public readonly expectedArgTypes = ["WorkerId", "Bytes"];
+
+    constructor(public readonly ctx: SubstrateEvent) {
+      if (ctx.extrinsic === undefined) {
+        throw new Error(`No call data has been provided`);
+      }
+      this.extrinsic = ctx.extrinsic;
+    }
+
+    get args(): UpdateRoleStorage_Args {
+      return new UpdateRoleStorage_Args(this.extrinsic);
+    }
+
+    validateArgs(): boolean {
+      if (this.expectedArgTypes.length !== this.extrinsic.args.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedArgTypes.forEach((type, i) => {
+        if (type !== this.extrinsic.args[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class UpdateRoleStorage_Args {
+    constructor(public readonly extrinsic: SubstrateExtrinsic) {}
+
+    get workerId(): WorkerId {
+      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
+        this.extrinsic.args[0].value
+      ]);
+    }
+
+    get storage(): Bytes {
+      return createTypeUnsafe<Bytes & Codec>(typeRegistry, "Bytes", [
+        this.extrinsic.args[1].value
+      ]);
+    }
+  }
+  /**
+   *  Fill opening for worker/lead.
+   *  Require signed leader origin or the root (to fill opening for the leader position).
+   */
+  export class FillOpeningCall {
+    public readonly extrinsic: SubstrateExtrinsic;
+    public readonly expectedArgTypes = [
+      "OpeningId",
+      "ApplicationIdSet",
+      "Option<RewardPolicy>"
+    ];
+
+    constructor(public readonly ctx: SubstrateEvent) {
+      if (ctx.extrinsic === undefined) {
+        throw new Error(`No call data has been provided`);
+      }
+      this.extrinsic = ctx.extrinsic;
+    }
+
+    get args(): FillOpening_Args {
+      return new FillOpening_Args(this.extrinsic);
+    }
+
+    validateArgs(): boolean {
+      if (this.expectedArgTypes.length !== this.extrinsic.args.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedArgTypes.forEach((type, i) => {
+        if (type !== this.extrinsic.args[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class FillOpening_Args {
+    constructor(public readonly extrinsic: SubstrateExtrinsic) {}
+
+    get openingId(): OpeningId {
+      return createTypeUnsafe<OpeningId & Codec>(typeRegistry, "OpeningId", [
+        this.extrinsic.args[0].value
+      ]);
+    }
+
+    get successfulApplicationIds(): ApplicationIdSet {
+      return createTypeUnsafe<ApplicationIdSet & Codec>(
+        typeRegistry,
+        "ApplicationIdSet",
+        [this.extrinsic.args[1].value]
+      );
+    }
+
+    get rewardPolicy(): Option<RewardPolicy> {
+      return createTypeUnsafe<Option<RewardPolicy> & Codec>(
+        typeRegistry,
+        "Option<RewardPolicy>",
+        [this.extrinsic.args[2].value]
+      );
+    }
+  }
+  /**
+   *  Leave the role by the active worker.
+   */
+  export class LeaveRoleCall {
+    public readonly extrinsic: SubstrateExtrinsic;
+    public readonly expectedArgTypes = ["WorkerId", "Bytes"];
+
+    constructor(public readonly ctx: SubstrateEvent) {
+      if (ctx.extrinsic === undefined) {
+        throw new Error(`No call data has been provided`);
+      }
+      this.extrinsic = ctx.extrinsic;
+    }
+
+    get args(): LeaveRole_Args {
+      return new LeaveRole_Args(this.extrinsic);
+    }
+
+    validateArgs(): boolean {
+      if (this.expectedArgTypes.length !== this.extrinsic.args.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedArgTypes.forEach((type, i) => {
+        if (type !== this.extrinsic.args[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class LeaveRole_Args {
+    constructor(public readonly extrinsic: SubstrateExtrinsic) {}
+
+    get workerId(): WorkerId {
+      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
+        this.extrinsic.args[0].value
+      ]);
+    }
+
+    get rationaleText(): Bytes {
+      return createTypeUnsafe<Bytes & Codec>(typeRegistry, "Bytes", [
+        this.extrinsic.args[1].value
+      ]);
+    }
+  }
+  /**
+   *  Terminate the active worker by the lead.
+   *  Require signed leader origin or the root (to terminate the leader role).
+   */
+  export class TerminateRoleCall {
+    public readonly extrinsic: SubstrateExtrinsic;
+    public readonly expectedArgTypes = ["WorkerId", "Bytes", "bool"];
+
+    constructor(public readonly ctx: SubstrateEvent) {
+      if (ctx.extrinsic === undefined) {
+        throw new Error(`No call data has been provided`);
+      }
+      this.extrinsic = ctx.extrinsic;
+    }
+
+    get args(): TerminateRole_Args {
+      return new TerminateRole_Args(this.extrinsic);
+    }
+
+    validateArgs(): boolean {
+      if (this.expectedArgTypes.length !== this.extrinsic.args.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedArgTypes.forEach((type, i) => {
+        if (type !== this.extrinsic.args[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class TerminateRole_Args {
+    constructor(public readonly extrinsic: SubstrateExtrinsic) {}
+
+    get workerId(): WorkerId {
+      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
+        this.extrinsic.args[0].value
+      ]);
+    }
+
+    get rationaleText(): Bytes {
+      return createTypeUnsafe<Bytes & Codec>(typeRegistry, "Bytes", [
+        this.extrinsic.args[1].value
+      ]);
+    }
+
+    get slashStake(): bool {
+      return createTypeUnsafe<bool & Codec>(typeRegistry, "bool", [
+        this.extrinsic.args[2].value
+      ]);
+    }
+  }
+}

query-node/generated/types/index.ts

@@ -12,3 +12,5 @@ export { typeRegistry };
 export * from "./members";
 export * from "./content";
 export * from "./data-directory";
+export * from "./storage-working-group";
+export * from "./gateway-working-group";

query-node/generated/types/storage-working-group.ts

@@ -0,0 +1,421 @@
+import { createTypeUnsafe } from "@polkadot/types/create";
+import { SubstrateEvent, SubstrateExtrinsic } from "@dzlzv/hydra-common";
+import { Codec } from "@polkadot/types/types";
+import { typeRegistry } from ".";
+
+import {
+  ApplicationIdSet,
+  ApplicationIdToWorkerIdMap,
+  OpeningId,
+  RationaleText,
+  RewardPolicy,
+  WorkerId
+} from "@joystream/types/augment";
+import { Bytes, Option, bool } from "@polkadot/types";
+
+export namespace StorageWorkingGroup {
+  /**
+   *  Emits on updating the worker storage role.
+   *  Params:
+   *  - Id of the worker.
+   *  - Raw storage field.
+   *
+   *  Event parameters: [WorkerId, Vec<u8>, ]
+   */
+  export class WorkerStorageUpdatedEvent {
+    public readonly expectedParamTypes = ["WorkerId", "Vec<u8>"];
+
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get data(): WorkerStorageUpdated_Params {
+      return new WorkerStorageUpdated_Params(this.ctx);
+    }
+
+    validateParams(): boolean {
+      if (this.expectedParamTypes.length !== this.ctx.params.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedParamTypes.forEach((type, i) => {
+        if (type !== this.ctx.params[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class WorkerStorageUpdated_Params {
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get workerId(): WorkerId {
+      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
+        this.ctx.params[0].value
+      ]);
+    }
+
+    get bytes(): Bytes {
+      return createTypeUnsafe<Bytes & Codec>(typeRegistry, "Bytes", [
+        this.ctx.params[1].value
+      ]);
+    }
+  }
+  /**
+   *  Emits on filling the worker opening.
+   *  Params:
+   *  - Worker opening id
+   *  - Worker application id to the worker id dictionary
+   *
+   *  Event parameters: [OpeningId, ApplicationIdToWorkerIdMap, ]
+   */
+  export class OpeningFilledEvent {
+    public readonly expectedParamTypes = [
+      "OpeningId",
+      "ApplicationIdToWorkerIdMap"
+    ];
+
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get data(): OpeningFilled_Params {
+      return new OpeningFilled_Params(this.ctx);
+    }
+
+    validateParams(): boolean {
+      if (this.expectedParamTypes.length !== this.ctx.params.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedParamTypes.forEach((type, i) => {
+        if (type !== this.ctx.params[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class OpeningFilled_Params {
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get openingId(): OpeningId {
+      return createTypeUnsafe<OpeningId & Codec>(typeRegistry, "OpeningId", [
+        this.ctx.params[0].value
+      ]);
+    }
+
+    get applicationIdToWorkerIdMap(): ApplicationIdToWorkerIdMap {
+      return createTypeUnsafe<ApplicationIdToWorkerIdMap & Codec>(
+        typeRegistry,
+        "ApplicationIdToWorkerIdMap",
+        [this.ctx.params[1].value]
+      );
+    }
+  }
+  /**
+   *  Emits on terminating the worker.
+   *  Params:
+   *  - worker id.
+   *  - termination rationale text
+   *
+   *  Event parameters: [WorkerId, RationaleText, ]
+   */
+  export class TerminatedWorkerEvent {
+    public readonly expectedParamTypes = ["WorkerId", "RationaleText"];
+
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get data(): TerminatedWorker_Params {
+      return new TerminatedWorker_Params(this.ctx);
+    }
+
+    validateParams(): boolean {
+      if (this.expectedParamTypes.length !== this.ctx.params.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedParamTypes.forEach((type, i) => {
+        if (type !== this.ctx.params[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class TerminatedWorker_Params {
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get workerId(): WorkerId {
+      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
+        this.ctx.params[0].value
+      ]);
+    }
+
+    get rationaleText(): RationaleText {
+      return createTypeUnsafe<RationaleText & Codec>(
+        typeRegistry,
+        "RationaleText",
+        [this.ctx.params[1].value]
+      );
+    }
+  }
+  /**
+   *  Emits on exiting the worker.
+   *  Params:
+   *  - worker id.
+   *  - exit rationale text
+   *
+   *  Event parameters: [WorkerId, RationaleText, ]
+   */
+  export class WorkerExitedEvent {
+    public readonly expectedParamTypes = ["WorkerId", "RationaleText"];
+
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get data(): WorkerExited_Params {
+      return new WorkerExited_Params(this.ctx);
+    }
+
+    validateParams(): boolean {
+      if (this.expectedParamTypes.length !== this.ctx.params.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedParamTypes.forEach((type, i) => {
+        if (type !== this.ctx.params[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class WorkerExited_Params {
+    constructor(public readonly ctx: SubstrateEvent) {}
+
+    get workerId(): WorkerId {
+      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
+        this.ctx.params[0].value
+      ]);
+    }
+
+    get rationaleText(): RationaleText {
+      return createTypeUnsafe<RationaleText & Codec>(
+        typeRegistry,
+        "RationaleText",
+        [this.ctx.params[1].value]
+      );
+    }
+  }
+
+  /**
+   *  Update the associated role storage.
+   */
+  export class UpdateRoleStorageCall {
+    public readonly extrinsic: SubstrateExtrinsic;
+    public readonly expectedArgTypes = ["WorkerId", "Bytes"];
+
+    constructor(public readonly ctx: SubstrateEvent) {
+      if (ctx.extrinsic === undefined) {
+        throw new Error(`No call data has been provided`);
+      }
+      this.extrinsic = ctx.extrinsic;
+    }
+
+    get args(): UpdateRoleStorage_Args {
+      return new UpdateRoleStorage_Args(this.extrinsic);
+    }
+
+    validateArgs(): boolean {
+      if (this.expectedArgTypes.length !== this.extrinsic.args.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedArgTypes.forEach((type, i) => {
+        if (type !== this.extrinsic.args[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class UpdateRoleStorage_Args {
+    constructor(public readonly extrinsic: SubstrateExtrinsic) {}
+
+    get workerId(): WorkerId {
+      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
+        this.extrinsic.args[0].value
+      ]);
+    }
+
+    get storage(): Bytes {
+      return createTypeUnsafe<Bytes & Codec>(typeRegistry, "Bytes", [
+        this.extrinsic.args[1].value
+      ]);
+    }
+  }
+  /**
+   *  Fill opening for worker/lead.
+   *  Require signed leader origin or the root (to fill opening for the leader position).
+   */
+  export class FillOpeningCall {
+    public readonly extrinsic: SubstrateExtrinsic;
+    public readonly expectedArgTypes = [
+      "OpeningId",
+      "ApplicationIdSet",
+      "Option<RewardPolicy>"
+    ];
+
+    constructor(public readonly ctx: SubstrateEvent) {
+      if (ctx.extrinsic === undefined) {
+        throw new Error(`No call data has been provided`);
+      }
+      this.extrinsic = ctx.extrinsic;
+    }
+
+    get args(): FillOpening_Args {
+      return new FillOpening_Args(this.extrinsic);
+    }
+
+    validateArgs(): boolean {
+      if (this.expectedArgTypes.length !== this.extrinsic.args.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedArgTypes.forEach((type, i) => {
+        if (type !== this.extrinsic.args[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class FillOpening_Args {
+    constructor(public readonly extrinsic: SubstrateExtrinsic) {}
+
+    get openingId(): OpeningId {
+      return createTypeUnsafe<OpeningId & Codec>(typeRegistry, "OpeningId", [
+        this.extrinsic.args[0].value
+      ]);
+    }
+
+    get successfulApplicationIds(): ApplicationIdSet {
+      return createTypeUnsafe<ApplicationIdSet & Codec>(
+        typeRegistry,
+        "ApplicationIdSet",
+        [this.extrinsic.args[1].value]
+      );
+    }
+
+    get rewardPolicy(): Option<RewardPolicy> {
+      return createTypeUnsafe<Option<RewardPolicy> & Codec>(
+        typeRegistry,
+        "Option<RewardPolicy>",
+        [this.extrinsic.args[2].value]
+      );
+    }
+  }
+  /**
+   *  Leave the role by the active worker.
+   */
+  export class LeaveRoleCall {
+    public readonly extrinsic: SubstrateExtrinsic;
+    public readonly expectedArgTypes = ["WorkerId", "Bytes"];
+
+    constructor(public readonly ctx: SubstrateEvent) {
+      if (ctx.extrinsic === undefined) {
+        throw new Error(`No call data has been provided`);
+      }
+      this.extrinsic = ctx.extrinsic;
+    }
+
+    get args(): LeaveRole_Args {
+      return new LeaveRole_Args(this.extrinsic);
+    }
+
+    validateArgs(): boolean {
+      if (this.expectedArgTypes.length !== this.extrinsic.args.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedArgTypes.forEach((type, i) => {
+        if (type !== this.extrinsic.args[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class LeaveRole_Args {
+    constructor(public readonly extrinsic: SubstrateExtrinsic) {}
+
+    get workerId(): WorkerId {
+      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
+        this.extrinsic.args[0].value
+      ]);
+    }
+
+    get rationaleText(): Bytes {
+      return createTypeUnsafe<Bytes & Codec>(typeRegistry, "Bytes", [
+        this.extrinsic.args[1].value
+      ]);
+    }
+  }
+  /**
+   *  Terminate the active worker by the lead.
+   *  Require signed leader origin or the root (to terminate the leader role).
+   */
+  export class TerminateRoleCall {
+    public readonly extrinsic: SubstrateExtrinsic;
+    public readonly expectedArgTypes = ["WorkerId", "Bytes", "bool"];
+
+    constructor(public readonly ctx: SubstrateEvent) {
+      if (ctx.extrinsic === undefined) {
+        throw new Error(`No call data has been provided`);
+      }
+      this.extrinsic = ctx.extrinsic;
+    }
+
+    get args(): TerminateRole_Args {
+      return new TerminateRole_Args(this.extrinsic);
+    }
+
+    validateArgs(): boolean {
+      if (this.expectedArgTypes.length !== this.extrinsic.args.length) {
+        return false;
+      }
+      let valid = true;
+      this.expectedArgTypes.forEach((type, i) => {
+        if (type !== this.extrinsic.args[i].type) {
+          valid = false;
+        }
+      });
+      return valid;
+    }
+  }
+
+  class TerminateRole_Args {
+    constructor(public readonly extrinsic: SubstrateExtrinsic) {}
+
+    get workerId(): WorkerId {
+      return createTypeUnsafe<WorkerId & Codec>(typeRegistry, "WorkerId", [
+        this.extrinsic.args[0].value
+      ]);
+    }
+
+    get rationaleText(): Bytes {
+      return createTypeUnsafe<Bytes & Codec>(typeRegistry, "Bytes", [
+        this.extrinsic.args[1].value
+      ]);
+    }
+
+    get slashStake(): bool {
+      return createTypeUnsafe<bool & Codec>(typeRegistry, "bool", [
+        this.extrinsic.args[2].value
+      ]);
+    }
+  }
+}

query-node/manifest.yml

@@ -52,6 +52,17 @@ typegen:
     - data_directory.ContentAccepted
     - data_directory.ContentRejected
     - data_directory.ContentUploadingStatusUpdated
+
+    # working groups
+    - storage_working_group.WorkerStorageUpdated
+    - storage_working_group.OpeningFilled
+    - storage_working_group.TerminatedWorker
+    - storage_working_group.WorkerExited
+
+    - gateway_working_group.WorkerStorageUpdated
+    - gateway_working_group.OpeningFilled
+    - gateway_working_group.TerminatedWorker
+    - gateway_working_group.WorkerExited
   calls:
     # members
     - members.buyMembership
@@ -96,6 +107,16 @@ typegen:
     - data_directory.accept_content
     - data_directory.update_content_uploading_status
 
+    # working groups
+    - storage_working_group.update_role_storage
+    - storage_working_group.fill_opening
+    - storage_working_group.leave_role
+    - storage_working_group.terminate_role
+
+    - gateway_working_group.update_role_storage
+    - gateway_working_group.fill_opening
+    - gateway_working_group.leave_role
+    - gateway_working_group.terminate_role
   outDir: ./generated/types
   customTypes:
     lib: '@joystream/types/augment'
@@ -180,6 +201,27 @@ mappings:
     #- event: dataDirectory.ContentUploadingStatusUpdated
     #  handler: data_directory_ContentUploadingStatusUpdated(DatabaseManager, SubstrateEvent)
 
+    # working groups
+    - event: storageWorkingGroup.WorkerStorageUpdated
+      handler: storageWorkingGroup_WorkerStorageUpdated(DatabaseManager, SubstrateEvent)
+    - event: storageWorkingGroup.OpeningFilled
+      handler: storageWorkingGroup_OpeningFilled(DatabaseManager, SubstrateEvent)
+    - event: storageWorkingGroup.TerminatedWorker
+      handler: storageWorkingGroup_TerminatedWorker(DatabaseManager, SubstrateEvent)
+    - event: storageWorkingGroup.WorkerExited
+      handler: storageWorkingGroup_WorkerExited(DatabaseManager, SubstrateEvent)
+
+
+
+    - event: gatewayWorkingGroup.WorkerStorageUpdated
+      handler: gatewayWorkingGroup_WorkerStorageUpdated(DatabaseManager, SubstrateEvent)
+    - event: gatewayWorkingGroup.OpeningFilled
+      handler: gatewayWorkingGroup_OpeningFilled(DatabaseManager, SubstrateEvent)
+    - event: gatewayWorkingGroup.TerminatedWorker
+      handler: gatewayWorkingGroup_TerminatedWorker(DatabaseManager, SubstrateEvent)
+    - event: gatewayWorkingGroup.WorkerExited
+      handler: gatewayWorkingGroup_WorkerExited(DatabaseManager, SubstrateEvent)
+
   extrinsicHandlers:
     # infer defaults here
     #- extrinsic: Balances.Transfer

query-node/mappings/src/index.ts

@@ -1,3 +1,4 @@
 export * from './content'
 export * from './membership'
 export * from './storage'
+export * from './workingGroup'

query-node/mappings/src/storage.ts

@@ -34,6 +34,8 @@ import {
   DataObjectOwnerCouncil,
   DataObjectOwnerWorkingGroup,
   LiaisonJudgement,
+  Worker,
+  WorkerType,
 } from 'query-node'
 
 export async function dataDirectory_ContentAdded(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
@@ -87,8 +89,21 @@ export async function dataDirectory_ContentAccepted(db: DatabaseManager, event:
     return inconsistentState('Non-existing content acceptation requested', encodedContentId)
   }
 
+  // load storage provider
+  const worker = await db.get(Worker, {
+    where: {
+      workerId: storageProviderId.toString(),
+      type: WorkerType.STORAGE,
+    } as FindConditions<Worker>
+  })
+
+  // ensure object exists
+  if (!worker) {
+    return inconsistentState('Missing Storage Provider Id', storageProviderId)
+  }
+
   // update object
-  dataObject.liaisonId = storageProviderId.toNumber()
+  dataObject.liaison = worker
   dataObject.liaisonJudgement = LiaisonJudgement.ACCEPTED
 
   // set last update time

query-node/mappings/src/workingGroup.ts

@@ -0,0 +1,175 @@
+import { SubstrateEvent } from '@dzlzv/hydra-common'
+import { DatabaseManager } from '@dzlzv/hydra-db-utils'
+import { FindConditions } from 'typeorm'
+import { Bytes } from '@polkadot/types'
+
+import {
+  inconsistentState,
+  logger,
+} from './common'
+
+import {
+  Channel,
+  Worker,
+  WorkerType,
+} from 'query-node'
+import {
+  GatewayWorkingGroup,
+  StorageWorkingGroup,
+} from '../../generated/types'
+import {
+  ApplicationId,
+  ApplicationIdToWorkerIdMap,
+  WorkerId,
+} from "@joystream/types/augment";
+
+/////////////////// Storage working group //////////////////////////////////////
+
+export async function storageWorkingGroup_OpeningFilled(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
+  // read event data
+  const {applicationIdToWorkerIdMap} = new StorageWorkingGroup.OpeningFilledEvent(event).data
+
+  // call generic processing
+  await workingGroup_OpeningFilled(db, WorkerType.STORAGE, applicationIdToWorkerIdMap)
+}
+
+export async function storageWorkingGroup_WorkerStorageUpdated(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
+  // read event data
+  const {workerId, bytes: newMetadata} = new StorageWorkingGroup.WorkerStorageUpdatedEvent(event).data
+
+  // call generic processing
+  await workingGroup_WorkerStorageUpdated(db, WorkerType.STORAGE, workerId, newMetadata)
+}
+
+export async function storageWorkingGroup_TerminatedWorker(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
+  // read event data
+  const {workerId} = new StorageWorkingGroup.TerminatedWorkerEvent(event).data
+
+  // call generic processing
+  await workingGroup_TerminatedWorker(db, WorkerType.STORAGE, workerId)
+}
+
+export async function storageWorkingGroup_WorkerExited(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
+  // read event data
+  const {workerId} = new StorageWorkingGroup.WorkerExitedEvent(event).data
+
+  // call generic processing
+  await workingGroup_WorkerExited(db, WorkerType.STORAGE, workerId)
+}
+
+/////////////////// Gateway working group //////////////////////////////////////
+
+export async function gatewayWorkingGroup_OpeningFilled(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
+  // read event data
+  const {applicationIdToWorkerIdMap} = new GatewayWorkingGroup.OpeningFilledEvent(event).data
+
+  // call generic processing
+  await workingGroup_OpeningFilled(db, WorkerType.GATEWAY, applicationIdToWorkerIdMap)
+}
+
+export async function gatewayWorkingGroup_WorkerStorageUpdated(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
+  // read event data
+  const {workerId, bytes: newMetadata} = new GatewayWorkingGroup.WorkerStorageUpdatedEvent(event).data
+
+  // call generic processing
+  await workingGroup_WorkerStorageUpdated(db, WorkerType.GATEWAY, workerId, newMetadata)
+}
+
+export async function gatewayWorkingGroup_TerminatedWorker(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
+  // read event data
+  const {workerId} = new StorageWorkingGroup.TerminatedWorkerEvent(event).data
+
+  // call generic processing
+  await workingGroup_TerminatedWorker(db, WorkerType.GATEWAY, workerId)
+}
+
+export async function gatewayWorkingGroup_WorkerExited(db: DatabaseManager, event: SubstrateEvent): Promise<void> {
+  // read event data
+  const {workerId} = new StorageWorkingGroup.WorkerExitedEvent(event).data
+
+  // call generic processing
+  await workingGroup_WorkerExited(db, WorkerType.GATEWAY, workerId)
+}
+
+/////////////////// Generic working group processing ///////////////////////////
+
+export async function workingGroup_OpeningFilled(
+  db: DatabaseManager,
+  workerType: WorkerType,
+  applicationIdToWorkerIdMap: ApplicationIdToWorkerIdMap
+): Promise<void> {
+  const workerIds = [...applicationIdToWorkerIdMap.values()]
+
+  for (const workerId of workerIds) {
+    // create new worker
+    const newWorker = new Worker({
+      workerId: workerId.toString(),
+      type: workerType,
+      isActive: true,
+    })
+
+    await db.save<Worker>(newWorker)
+  }
+
+  // emit log event
+  logger.info("Worker has been created", {ids: workerIds.map(item => item.toString()), workerType})
+}
+
+export async function workingGroup_WorkerStorageUpdated(db: DatabaseManager, workerType: WorkerType, workerId: WorkerId, newMetadata: Bytes): Promise<void> {
+  // load worker
+  const worker = await db.get(Worker, {
+    where: {
+      workerId: workerId.toString(),
+      type: workerType,
+    } as FindConditions<Worker>
+  })
+
+  // ensure worker exists
+  if (!worker) {
+    return inconsistentState('Non-existing worker update requested', workerId)
+  }
+
+  worker.metadata = newMetadata.toUtf8()
+
+  await db.save<Worker>(worker)
+
+  // emit log event
+  logger.info("Storage provider has been updated", {workerId, workerType})
+}
+
+export async function workingGroup_TerminatedWorker(db: DatabaseManager, workerType: WorkerType, workerId: WorkerId): Promise<void> {
+  // do removal logic
+  await deactivateWorker(db, workerType, workerId)
+
+  // emit log event
+  logger.info("Storage provider has beed removed (worker terminated)", {workerId, workerType})
+}
+
+export async function workingGroup_WorkerExited(db: DatabaseManager, workerType: WorkerType, workerId: WorkerId): Promise<void> {
+  // do removal logic
+  await deactivateWorker(db, workerType, workerId)
+
+  // emit log event
+  logger.info("Storage provider has beed removed (worker exited)", {workerId, workerType})
+}
+
+/////////////////// Helpers ////////////////////////////////////////////////////
+
+async function deactivateWorker(db: DatabaseManager, workerType: WorkerType, workerId: WorkerId) {
+  // load worker
+  const worker = await db.get(Worker, {
+    where: {
+      workerId: workerId.toString(),
+      type: workerType,
+    } as FindConditions<Worker>
+  })
+
+  // ensure worker exists
+  if (!worker) {
+    return inconsistentState('Non-existing worker deletion requested', workerId)
+  }
+
+  worker.isActive = false
+
+  await db.save<Worker>(worker)
+}

query-node/schema.graphql

@@ -90,7 +90,7 @@ type DataObject @entity {
   size: Int!
 
   "Storage provider id of the liaison"
-  liaisonId: Int # liaison is unset until storage provider accepts or rejects the content
+  liaison: Worker # liaison is unset until storage provider accepts or rejects the content
 
   "Storage provider as liaison judgment"
   liaisonJudgement: LiaisonJudgement!
@@ -228,7 +228,7 @@ type Channel @entity {
 }
 
 type CuratorGroup @entity {
-  "Runtime entity identifier (EntityId)"
+  "Runtime identifier"
   id: ID!
 
   "Curators belonging to this group"
@@ -241,7 +241,7 @@ type CuratorGroup @entity {
 }
 
 type VideoCategory @entity {
-  "Runtime entity identifier (EntityId)"
+  "Runtime identifier"
   id: ID!
 
   "The name of the category"
@@ -253,7 +253,7 @@ type VideoCategory @entity {
 }
 
 type Video @entity {
-  "Runtime entity identifier (EntityId)"
+  "Runtime identifier"
   id: ID!
 
   "Reference to member's channel"
@@ -334,7 +334,7 @@ type Video @entity {
 }
 
 type VideoMediaMetadata @entity {
-  "Runtime entity identifier (EntityId)"
+  "Unique identifier"
   id: ID!
 
   "Encoding of the video media object"
@@ -366,7 +366,7 @@ type VideoMediaEncoding @entity {
 }
 
 type License @entity {
-  "Runtime entity identifier (EntityId)"
+  "Unique identifier"
   id: ID!
 
   "License code defined by Joystream"
@@ -380,9 +380,33 @@ type License @entity {
 }
 
 type FeaturedVideo @entity {
-  "Runtime entity identifier (EntityId)"
+  "Unique identifier"
   id: ID!
 
   "Reference to a video"
   video: Video!
 }
+
+enum WorkerType {
+  GATEWAY
+  STORAGE
+}
+
+type Worker @entity {
+  "Unique identifier"
+  id: ID!
+
+  "Sign of worker still being active"
+  isActive: Boolean!
+
+  "Runtime identifier"
+  workerId: String!
+
+  "Associated working group"
+  type: WorkerType!
+
+  "Custom metadata set by provider"
+  metadata: String
+
+  dataObjects: [DataObject!]! @derivedFrom(field: "liaison")
+}