Commit ec44a7a6 authored by Mohammad Ismaeel's avatar Mohammad Ismaeel
Browse files

API for configuring openroadm

parent 5935a40d

.context.log.swn

deleted100644 → 0
−24 KiB

File deleted.

View file

.context.log.swo

deleted100644 → 0
−16 KiB

File deleted.

View file

.context.log.swp

deleted100644 → 0
−40 KiB

File deleted.

View file

proto/context.proto

+3 −0
Original line number Diff line number Diff line
@@ -560,6 +560,9 @@ message Location { 
  oneof location {

    string region = 1;

    GPS_Position gps_position = 2;

    

    string interface=3;

    string circuit_pack=4;

  }

}

src/context/service/database/OpticalConfig.py

+5 −5
Original line number Diff line number Diff line
@@ -207,7 +207,7 @@ def set_opticalconfig(db_engine : Engine, request : OpticalConfig): 
        )

            

        LOGGER.info(f"added OpticalConfig_data {OpticalConfig_data}")

        LOGGER.info(f"added channels {channels}")

        LOGGER.info(f"added interfaces {interfaces}")



    def callback(session:Session)->bool:

        stmt = insert(OpticalConfigModel).values(OpticalConfig_data)
@@ -260,7 +260,7 @@ def set_opticalconfig(db_engine : Engine, request : OpticalConfig): 
                stmt = stmt.on_conflict_do_update(

                        index_elements=[RoadmTypeModel.roadm_uuid],

                        set_=dict(

                            circuits=stmt.excluded.circuits

                            opticalconfig_uuid=stmt.excluded.opticalconfig_uuid

                        )

                    )

                stmt = stmt.returning(RoadmTypeModel.roadm_uuid)
@@ -298,14 +298,14 @@ def set_opticalconfig(db_engine : Engine, request : OpticalConfig): 
                stmt = stmt.on_conflict_do_update(

                        index_elements=[RoadmTypeModel.roadm_uuid],

                        set_=dict(

                            interfaces=stmt.excluded.interfaces

                            opticalconfig_uuid=stmt.excluded.opticalconfig_uuid

                        )

                    )

                stmt = stmt.returning(RoadmTypeModel.roadm_uuid)

                roadm_id = session.execute(stmt).fetchone() 

                

             if len(interface) >0 :      

                stmt = insert(ORInterfaceModel).values(interface)

             if len(interfaces) >0 :      

                stmt = insert(ORInterfaceModel).values(interfaces)

                stmt = stmt.on_conflict_do_update(

                        index_elements=[ORInterfaceModel.interface_uuid ],

                        set_=dict(