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

delete multiple services tapi

parent c075cdc1

src/tapi/service/service/routes.py

+32 −28
Original line number Diff line number Diff line
@@ -132,16 +132,17 @@ def create_service (): 
@service.route('/delete_service',methods= ['POST'])

def delete_service (): 

    data = request.json

    service_uuid = data.get('service_uuid',None)

    service_id = ServiceId()

    if isinstance(service_uuid, str):

        service_id.service_uuid.uuid = service_uuid

    else:

        return make_response("service_uuid must be a string", 400)

    if not service_uuid:

    service_uuids = data.get('service_uuid',[])

   

    if  len(service_uuids) ==0 :

        return make_response("service_uuid is required", 400)

    

    try : 

        

        service_client.connect()

        for service_uuid in service_uuids :

            service_id = ServiceId()

            service_id.service_uuid.uuid = service_uuid

            service_client.DeleteService(service_id)

        return make_response(f"Service {service_uuid} deleted successfully !!", 200)

    except Exception as e :
@@ -151,28 +152,31 @@ def delete_service (): 
        if service_client: 

            service_client.close()         

            

@service.route('/delete_child_service',methods= ['POST'])    

@service.route('/delete_child_service',methods= ['DELETE'])    

def delete_child_service (): 

    data = request.json

    service_uuid = data.get('service_uuid',None)

    port = data.get('port',8008)

    host = data.get('host',None)

    topologies = data.get('topologies',[])

    if len(topologies) ==0 :

        return make_response("topologies is required", 400)

    for topology in topologies :

        host = topology.get('host',None)

        port = topology.get('port',8008)

        service_uuids = topology.get('service_uuid',[])

        if not host:    

            return make_response("host is required", 400)

    if not service_uuid:

        if len(service_uuids) ==0 :

            return make_response("service_uuid is required", 400)

    

        url = ('http://{}:{}/service/delete_service').format(host,port)

        try : 

        response = requests.post(url,json={'service_uuid': service_uuid})

     

            response = requests.post(url,json={'service_uuid': service_uuids})

            if response.status_code != 200:

                return make_response(f"Failed to delete child service: {response.text}", response.status_code)

            

        return make_response(f"Child Service {service_uuid} deleted successfully !!", 200)

        except Exception as e : 

            logging.info(f"error in deleting child service {e}") 

            return make_response(f'Error !! {e}' ,400)

    

    return make_response("Child services deleted successfully !!", 200)

@service.route('/get_list_service/<context_uuid>', methods=['GET'])

def get_list_service(context_uuid):

src/tapi/service/topology/routes.py

+3 −3
Original line number Diff line number Diff line
@@ -115,10 +115,10 @@ def add_children () : 
                        child_topo.endpoints.append(endpoint_proto)

                if len(child_topo.endpoints)> 0:

                    try : 

                        context_client.connect()

                        context_client.SetChildTopology(child_topo)

                        # context_client.connect()

                        # context_client.SetChildTopology(child_topo)

                       

                        return make_response( response.json, 200)

                        return make_response( response.json(), 200)

                    except Exception as e : 

                        logging.info(f'error {e}')