feat: implement device group subscriptions

- implement GraphQL subscriptions for device group changes

Signed-off-by: Osman Hadzic <osman.hadzic@secomind.com>

Author: osmanhadzic

frontend/src/api/schema.graphql

@@ -559,7 +559,7 @@ type Modem {
   "The cell tower's Mobile Network Code."
   mobileNetworkCode: Int
 
-  "The GSM/LTE registration status of the modem."
+  "The GSM\/LTE registration status of the modem."
   registrationStatus: ModemRegistrationStatus
 
   "Signal strength in dBm."
@@ -581,13 +581,7 @@ input CampaignMechanismInput {
   firmwareUpgrade: CampaignCampaignMechanismFirmwareUpgradeInput
 }
 
-union CampaignMechanism =
-  | DeploymentDelete
-  | DeploymentDeploy
-  | DeploymentStart
-  | DeploymentStop
-  | DeploymentUpgrade
-  | FirmwareUpgrade
+union CampaignMechanism = DeploymentDelete | DeploymentDeploy | DeploymentStart | DeploymentStop | DeploymentUpgrade | FirmwareUpgrade
 
 enum CampaignTargetStatus {
   "Something went wrong while attempting operation on the target."
@@ -741,7 +735,7 @@ enum ModemRegistrationStatus {
   "Not registered, but modem is currently searching a new operator to register to."
   SEARCHING_OPERATOR
 
-  "Unknown (e.g. out of GERAN/UTRAN/E-UTRAN coverage)."
+  "Unknown (e.g. out of GERAN\/UTRAN\/E-UTRAN coverage)."
   UNKNOWN
 }
 
@@ -900,6 +894,12 @@ type LocalizedAttribute {
   languageTag: String!
 }
 
+type base_image_collection_result {
+  created: BaseImageCollection
+  updated: BaseImageCollection
+  destroyed: ID
+}
+
 "The result of the :delete_base_image_collection mutation"
 type DeleteBaseImageCollectionResult {
   "The record that was successfully deleted"
@@ -1092,6 +1092,12 @@ type BaseImageCollection implements Node {
   ): BaseImageConnection!
 }
 
+type base_image_result {
+  created: BaseImage
+  updated: BaseImage
+  destroyed: ID
+}
+
 "The result of the :delete_base_image mutation"
 type DeleteBaseImageResult {
   "The record that was successfully deleted"
@@ -1279,9 +1285,7 @@ type BaseImage implements Node {
   localizedDescriptions(preferredLanguageTags: [String!]): [LocalizedAttribute!]
 
   "A list of release display names in different languages."
-  localizedReleaseDisplayNames(
-    preferredLanguageTags: [String!]
-  ): [LocalizedAttribute!]
+  localizedReleaseDisplayNames(preferredLanguageTags: [String!]): [LocalizedAttribute!]
 
   "Derived Base Image Name from version and localized release display name"
   name: String
@@ -4716,6 +4720,12 @@ type ForwarderConfig {
   secureSessions: Boolean!
 }
 
+type device_group_result {
+  created: DeviceGroup
+  updated: DeviceGroup
+  destroyed: ID
+}
+
 "The result of the :delete_device_group mutation"
 type DeleteDeviceGroupResult {
   "The record that was successfully deleted"
@@ -5005,6 +5015,15 @@ type Tag {
   name: String!
 }
 
+"The result of the :cancel_ota_operation mutation"
+type CancelOtaOperationResult {
+  "The successful result of the mutation"
+  result: OtaOperation
+
+  "Any errors generated, if the mutation failed"
+  errors: [MutationError!]!
+}
+
 "The result of the :create_manual_ota_operation mutation"
 type CreateManualOtaOperationResult {
   "The successful result of the mutation"
@@ -5867,7 +5886,10 @@ type Campaign implements Node {
 
 type RootQueryType {
   "Returns the desired campaign."
-  campaign("The id of the record" id: ID!): Campaign
+  campaign(
+    "The id of the record"
+    id: ID!
+  ): Campaign
 
   "Returns all update campaigns."
   updateCampaigns(
@@ -5937,7 +5959,10 @@ type RootQueryType {
   ): CampaignConnection
 
   "Returns a single channel."
-  channel("The id of the record" id: ID!): Channel
+  channel(
+    "The id of the record"
+    id: ID!
+  ): Channel
 
   "Returns a list of channels."
   channels(
@@ -5985,7 +6010,10 @@ type RootQueryType {
   ): TagConnection
 
   "Returns a single device group."
-  deviceGroup("The id of the record" id: ID!): DeviceGroup
+  deviceGroup(
+    "The id of the record"
+    id: ID!
+  ): DeviceGroup
 
   "Returns a list of device groups."
   deviceGroups(
@@ -6018,7 +6046,10 @@ type RootQueryType {
   forwarderSession(token: String!, deviceId: ID!): ForwarderSession
 
   "Returns a single device."
-  device("The id of the record" id: ID!): Device
+  device(
+    "The id of the record"
+    id: ID!
+  ): Device
 
   "Returns a list of devices."
   devices(
@@ -6042,7 +6073,10 @@ type RootQueryType {
   ): DeviceConnection
 
   "Returns a single hardware type."
-  hardwareType("The id of the record" id: ID!): HardwareType
+  hardwareType(
+    "The id of the record"
+    id: ID!
+  ): HardwareType
 
   "Returns a list of hardware types."
   hardwareTypes(
@@ -6066,7 +6100,10 @@ type RootQueryType {
   ): HardwareTypeConnection
 
   "Returns a single system model."
-  systemModel("The id of the record" id: ID!): SystemModel
+  systemModel(
+    "The id of the record"
+    id: ID!
+  ): SystemModel
 
   "Returns a list of system models."
   systemModels(
@@ -6111,7 +6148,10 @@ type RootQueryType {
   ): ApplicationConnection
 
   "Returns the desired application."
-  application("The id of the record" id: ID!): Application
+  application(
+    "The id of the record"
+    id: ID!
+  ): Application
 
   "Returns all available deployments."
   deployments(
@@ -6135,10 +6175,16 @@ type RootQueryType {
   ): DeploymentConnection
 
   "Returns the desired deployment."
-  deployment("The id of the record" id: ID!): Deployment
+  deployment(
+    "The id of the record"
+    id: ID!
+  ): Deployment
 
   "Returns the desired image credentials."
-  imageCredentials("The id of the record" id: ID!): ImageCredentials
+  imageCredentials(
+    "The id of the record"
+    id: ID!
+  ): ImageCredentials
 
   "Returns all available image credentials."
   listImageCredentials(
@@ -6162,10 +6208,16 @@ type RootQueryType {
   ): ImageCredentialsConnection
 
   "Returns the desired release."
-  release("The id of the record" id: ID!): Release
+  release(
+    "The id of the record"
+    id: ID!
+  ): Release
 
   "Returns the desired network."
-  network("The id of the record" id: ID!): Network
+  network(
+    "The id of the record"
+    id: ID!
+  ): Network
 
   "Returns all available networks."
   networks(
@@ -6189,7 +6241,10 @@ type RootQueryType {
   ): NetworkConnection
 
   "Returns the desired volume."
-  volume("The id of the record" id: ID!): Volume
+  volume(
+    "The id of the record"
+    id: ID!
+  ): Volume
 
   "Returns all available volumes."
   volumes(
@@ -6213,13 +6268,22 @@ type RootQueryType {
   ): VolumeConnection
 
   "Retrieves a Node from its global id"
-  node("The Node unique identifier" id: ID!): Node!
+  node(
+    "The Node unique identifier"
+    id: ID!
+  ): Node!
 
   "Returns a single base image."
-  baseImage("The id of the record" id: ID!): BaseImage
+  baseImage(
+    "The id of the record"
+    id: ID!
+  ): BaseImage
 
   "Returns a single base image collection."
-  baseImageCollection("The id of the record" id: ID!): BaseImageCollection
+  baseImageCollection(
+    "The id of the record"
+    id: ID!
+  ): BaseImageCollection
 
   "Returns a list of base image collections."
   baseImageCollections(
@@ -6257,18 +6321,16 @@ type RootMutationType {
   deleteChannel(id: ID!): DeleteChannelResult
 
   "Initiates an OTA update with a user provided OS image"
-  createManualOtaOperation(
-    input: CreateManualOtaOperationInput!
-  ): CreateManualOtaOperationResult
+  createManualOtaOperation(input: CreateManualOtaOperationInput!): CreateManualOtaOperationResult
+
+  "Cancels an OTA update operation"
+  cancelOtaOperation(id: ID!): CancelOtaOperationResult
 
   "Creates a new device group."
   createDeviceGroup(input: CreateDeviceGroupInput!): CreateDeviceGroupResult
 
   "Updates a device group."
-  updateDeviceGroup(
-    id: ID!
-    input: UpdateDeviceGroupInput
-  ): UpdateDeviceGroupResult
+  updateDeviceGroup(id: ID!, input: UpdateDeviceGroupInput): UpdateDeviceGroupResult
 
   "Deletes a device group."
   deleteDeviceGroup(id: ID!): DeleteDeviceGroupResult
@@ -6286,25 +6348,16 @@ type RootMutationType {
   addDeviceTags(id: ID!, input: AddDeviceTagsInput!): AddDeviceTagsResult
 
   "Remove tags from a device."
-  removeDeviceTags(
-    id: ID!
-    input: RemoveDeviceTagsInput!
-  ): RemoveDeviceTagsResult
+  removeDeviceTags(id: ID!, input: RemoveDeviceTagsInput!): RemoveDeviceTagsResult
 
   "Sets led behavior."
-  setDeviceLedBehavior(
-    id: ID!
-    input: SetDeviceLedBehaviorInput!
-  ): SetDeviceLedBehaviorResult
+  setDeviceLedBehavior(id: ID!, input: SetDeviceLedBehaviorInput!): SetDeviceLedBehaviorResult
 
   "Creates a hardware type."
   createHardwareType(input: CreateHardwareTypeInput!): CreateHardwareTypeResult
 
   "Updates a hardware type."
-  updateHardwareType(
-    id: ID!
-    input: UpdateHardwareTypeInput
-  ): UpdateHardwareTypeResult
+  updateHardwareType(id: ID!, input: UpdateHardwareTypeInput): UpdateHardwareTypeResult
 
   "Deletes a hardware type."
   deleteHardwareType(id: ID!): DeleteHardwareTypeResult
@@ -6313,10 +6366,7 @@ type RootMutationType {
   createSystemModel(input: CreateSystemModelInput!): CreateSystemModelResult
 
   "Updates an system model."
-  updateSystemModel(
-    id: ID!
-    input: UpdateSystemModelInput
-  ): UpdateSystemModelResult
+  updateSystemModel(id: ID!, input: UpdateSystemModelInput): UpdateSystemModelResult
 
   "Deletes a system model."
   deleteSystemModel(id: ID!): DeleteSystemModelResult
@@ -6344,15 +6394,10 @@ type RootMutationType {
   """
   sendDeployment(id: ID!): SendDeploymentResult
 
-  upgradeDeployment(
-    id: ID!
-    input: UpgradeDeploymentInput!
-  ): UpgradeDeploymentResult
+  upgradeDeployment(id: ID!, input: UpgradeDeploymentInput!): UpgradeDeploymentResult
 
   "Create image credentials."
-  createImageCredentials(
-    input: CreateImageCredentialsInput!
-  ): CreateImageCredentialsResult
+  createImageCredentials(input: CreateImageCredentialsInput!): CreateImageCredentialsResult
 
   deleteImageCredentials(id: ID!): DeleteImageCredentialsResult
 
@@ -6384,25 +6429,32 @@ type RootMutationType {
   deleteBaseImage(id: ID!): DeleteBaseImageResult
 
   "Creates a new base image collection."
-  createBaseImageCollection(
-    input: CreateBaseImageCollectionInput!
-  ): CreateBaseImageCollectionResult
+  createBaseImageCollection(input: CreateBaseImageCollectionInput!): CreateBaseImageCollectionResult
 
   "Updates a base image collection."
-  updateBaseImageCollection(
-    id: ID!
-    input: UpdateBaseImageCollectionInput
-  ): UpdateBaseImageCollectionResult
+  updateBaseImageCollection(id: ID!, input: UpdateBaseImageCollectionInput): UpdateBaseImageCollectionResult
 
   "Deletes a base image collection."
   deleteBaseImageCollection(id: ID!): DeleteBaseImageCollectionResult
 }
 
 type RootSubscriptionType {
+  deviceGroup(
+    "A filter to limit the results"
+    filter: DeviceGroupFilterInput
+  ): device_group_result
   deviceChanged(
     "A filter to limit the results"
     filter: DeviceFilterInput
   ): device_changed_result
+  baseImage(
+    "A filter to limit the results"
+    filter: BaseImageFilterInput
+  ): base_image_result
+  baseImageCollection(
+    "A filter to limit the results"
+    filter: BaseImageCollectionFilterInput
+  ): base_image_collection_result
 }
 
 """