FR 330 add switch to layer

src/external-api/topology-discovery-graphql.ts

@@ -30,6 +30,7 @@ import {
   MplsPathQueryVariables,
   NeighborsQuery,
   NeighborsQueryVariables,
+  TopologiesQuery,
 } from '../__generated__/topology-discovery.graphql';
 import { TopologyDiffOutput, decodeTopologyDiffOutput } from './topology-network-types';
 
@@ -576,6 +577,15 @@ const MAP_NEIGHBORS = gql`
   }
 `;
 
+const TOPOLOGIES = gql`
+  query Topologies($deviceName: String!) {
+    topologies(deviceName: $deviceName) {
+      topologyId
+      deviceId
+    }
+  }
+`;
+
 function getTopologyDiscoveryApi() {
   if (!config.topologyEnabled) {
     return undefined;
@@ -615,6 +625,13 @@ function getTopologyDiscoveryApi() {
     return response;
   }
 
+  async function getTopologyOfDevice(deviceName: string): Promise<TopologiesQuery> {
+    const response = await client.request<TopologiesQuery>(TOPOLOGIES, {
+      deviceName,
+    });
+    return response;
+  }
+
   async function getTopologyDiff(version: string, collectionType: TopologyType): Promise<TopologyDiffOutput> {
     const response = await client.request<TopologyDiffQuery, TopologyDiffQueryVariables>(GET_TOPOLOGY_DIFF, {
       // eslint-disable-next-line @typescript-eslint/naming-convention
@@ -759,6 +776,7 @@ function getTopologyDiscoveryApi() {
     getMplsLspCount,
     getLspPath,
     getMapNeighbors,
+    getTopologyOfDevice,
   };
 }
 

src/schema/api.graphql

@@ -776,6 +776,7 @@ type Query {
     last: Int
     orderBy: DeviceOrderByInput
   ): DeviceConnection!
+  devicesTopology(deviceName: String!): Topologies
   kafkaHealthCheck: IsOkResponse
   labels(after: String, before: String, filter: FilterLabelsInput, first: Int, last: Int): LabelConnection!
   locations(
@@ -937,6 +938,10 @@ type SynceTopologyVersionData {
   nodes: [SynceGraphNode!]!
 }
 
+type Topologies {
+  topologies: [TopologyOfDevice]
+}
+
 type Topology {
   edges: [GraphEdge!]!
   nodes: [GraphNode!]!
@@ -953,6 +958,11 @@ enum TopologyLayer {
   PTP_TOPOLOGY
 }
 
+type TopologyOfDevice {
+  deviceId: String!
+  topologyId: String!
+}
+
 enum TopologyType {
   ETH_TOPOLOGY
   MPLS_TOPOLOGY

src/schema/nexus-typegen.ts

@@ -809,6 +809,10 @@ export interface NexusGenObjects {
     edges: NexusGenRootTypes['GraphVersionEdge'][]; // [GraphVersionEdge!]!
     nodes: NexusGenRootTypes['SynceGraphNode'][]; // [SynceGraphNode!]!
   };
+  Topologies: {
+    // root type
+    topologies?: Array<NexusGenRootTypes['TopologyOfDevice'] | null> | null; // [TopologyOfDevice]
+  };
   Topology: {
     // root type
     edges: NexusGenRootTypes['GraphEdge'][]; // [GraphEdge!]!
@@ -818,6 +822,11 @@ export interface NexusGenObjects {
     // root type
     commonNodes: string[]; // [String!]!
   };
+  TopologyOfDevice: {
+    // root type
+    deviceId: string; // String!
+    topologyId: string; // String!
+  };
   Transaction: {
     // root type
     changes: NexusGenRootTypes['TransactionChange'][]; // [TransactionChange!]!
@@ -1484,6 +1493,7 @@ export interface NexusGenFieldTypes {
     deviceMetadata: NexusGenRootTypes['DeviceMetadata'] | null; // DeviceMetadata
     deviceNeighbor: NexusGenRootTypes['DeviceNeighbors'] | null; // DeviceNeighbors
     devices: NexusGenRootTypes['DeviceConnection']; // DeviceConnection!
+    devicesTopology: NexusGenRootTypes['Topologies'] | null; // Topologies
     kafkaHealthCheck: NexusGenRootTypes['IsOkResponse'] | null; // IsOkResponse
     labels: NexusGenRootTypes['LabelConnection']; // LabelConnection!
     locations: NexusGenRootTypes['LocationConnection']; // LocationConnection!
@@ -1599,6 +1609,10 @@ export interface NexusGenFieldTypes {
     edges: NexusGenRootTypes['GraphVersionEdge'][]; // [GraphVersionEdge!]!
     nodes: NexusGenRootTypes['SynceGraphNode'][]; // [SynceGraphNode!]!
   };
+  Topologies: {
+    // field return type
+    topologies: Array<NexusGenRootTypes['TopologyOfDevice'] | null> | null; // [TopologyOfDevice]
+  };
   Topology: {
     // field return type
     edges: NexusGenRootTypes['GraphEdge'][]; // [GraphEdge!]!
@@ -1608,6 +1622,11 @@ export interface NexusGenFieldTypes {
     // field return type
     commonNodes: string[]; // [String!]!
   };
+  TopologyOfDevice: {
+    // field return type
+    deviceId: string; // String!
+    topologyId: string; // String!
+  };
   Transaction: {
     // field return type
     changes: NexusGenRootTypes['TransactionChange'][]; // [TransactionChange!]!
@@ -2274,6 +2293,7 @@ export interface NexusGenFieldTypeNames {
     deviceMetadata: 'DeviceMetadata';
     deviceNeighbor: 'DeviceNeighbors';
     devices: 'DeviceConnection';
+    devicesTopology: 'Topologies';
     kafkaHealthCheck: 'IsOkResponse';
     labels: 'LabelConnection';
     locations: 'LocationConnection';
@@ -2389,6 +2409,10 @@ export interface NexusGenFieldTypeNames {
     edges: 'GraphVersionEdge';
     nodes: 'SynceGraphNode';
   };
+  Topologies: {
+    // field return type name
+    topologies: 'TopologyOfDevice';
+  };
   Topology: {
     // field return type name
     edges: 'GraphEdge';
@@ -2398,6 +2422,11 @@ export interface NexusGenFieldTypeNames {
     // field return type name
     commonNodes: 'String';
   };
+  TopologyOfDevice: {
+    // field return type name
+    deviceId: 'String';
+    topologyId: 'String';
+  };
   Transaction: {
     // field return type name
     changes: 'TransactionChange';
@@ -2689,6 +2718,10 @@ export interface NexusGenArgTypes {
       last?: number | null; // Int
       orderBy?: NexusGenInputs['DeviceOrderByInput'] | null; // DeviceOrderByInput
     };
+    devicesTopology: {
+      // args
+      deviceName: string; // String!
+    };
     labels: {
       // args
       after?: string | null; // String

src/schema/topology.ts

@@ -1009,6 +1009,35 @@ export const deviceNeighborQuery = queryField('deviceNeighbor', {
   },
 });
 
+export const TopologyOfDevice = objectType({
+  name: 'TopologyOfDevice',
+  definition: (t) => {
+    t.nonNull.string('topologyId');
+    t.nonNull.string('deviceId');
+  },
+});
+
+export const Topologies = objectType({
+  name: 'Topologies',
+  definition: (t) => {
+    t.list.field('topologies', {
+      type: TopologyOfDevice,
+    });
+  },
+});
+
+export const TopologyOfDevicesQuery = queryField('devicesTopology', {
+  type: Topologies,
+  args: {
+    deviceName: nonNull(stringArg()),
+  },
+  resolve: async (_, args, { topologyDiscoveryGraphQLAPI }) => {
+    const topologyOfDevicesResult = await topologyDiscoveryGraphQLAPI?.getTopologyOfDevice(args.deviceName);
+
+    return topologyOfDevicesResult ?? { topologies: [] };
+  },
+});
+
 export const MplsTopology = objectType({
   name: 'MplsTopology',
   definition: (t) => {