Loading controllers/resources.py +20 −51 Original line number Diff line number Diff line Loading @@ -14,7 +14,7 @@ providers_ops = ProviderResources() events_ops = Events() @router.get("/resources/invokers",) @router.get("/resources/invokers") async def get_invokers(Authorize: AuthJWT = Depends()): """ Get list of all invokers registered in CAPIF Loading @@ -25,7 +25,7 @@ async def get_invokers(Authorize: AuthJWT = Depends()): return invokers_ops.get_all_invokers() @router.delete("/resources/invokers/{invoker_id}",) @router.delete("/resources/invokers/{invoker_id}") async def delete_invoker(invoker_id, Authorize: AuthJWT = Depends()): """ Get list of all invokers registered in CAPIF Loading @@ -37,7 +37,7 @@ async def delete_invoker(invoker_id, Authorize: AuthJWT = Depends()): @router.get('/resources/invokers/security/{invoker_id}') def get_invoker_security_context_resources(invoker_id, Authorize: AuthJWT = Depends()): def get_invoker_security_context_resource(invoker_id, Authorize: AuthJWT = Depends()): """ Retreive all resources of invoker, security context, event subscriptions """ Loading @@ -46,28 +46,28 @@ def get_invoker_security_context_resources(invoker_id, Authorize: AuthJWT = Depe return invokers_ops.get_security_context(invoker_id) @router.get('/resources/invokers/events/{invoker_id}') def get_invoker_event_subscription_resources(Authorize: AuthJWT = Depends()): @router.delete('/resources/invokers/security/{invoker_id}') def delete_invoker_security_context(invoker_id, Authorize: AuthJWT = Depends()): """ Retreive all resources of invoker, security context, event subscriptions Retreive all resources of provider, services, event subscriptions """ Authorize.jwt_required() return invokers_ops.get_event_subscription() return invokers_ops.remove_security_context(invoker_id) @router.get("/resources/providers",) async def get_all_providers(Authorize: AuthJWT = Depends()): async def get_providers(Authorize: AuthJWT = Depends()): """ Get list of all provider registered in CAPIF """ Authorize.jwt_required() return providers_ops.get_all_providers() return providers_ops.get_providers() @router.delete("/resources/providers/{provider_id}",) @router.delete("/resources/providers/{provider_id}") async def delete_provider(provider_id, Authorize: AuthJWT = Depends()): """ Get list of all provider registered in CAPIF Loading @@ -88,40 +88,29 @@ def get_provider_services_resources(apf_id, Authorize: AuthJWT = Depends()): return providers_ops.get_services_of_apf(apf_id) @router.get('/resources/events/{id}') def get_events(id, Authorize: AuthJWT = Depends()): """ Retreive one event by the subscriber id (apf_id, aef_id, provider_id or api_invoker_id) """ Authorize.jwt_required() return events_ops.get_events_by_id(id) @router.get('/resources/events') def get_events(Authorize: AuthJWT = Depends()): @router.delete('/resources/providers/services/{apf_id}/{service_id}') def delete_provider_service(apf_id, service_id, Authorize: AuthJWT = Depends()): """ Retreive all registered events Retreive all resources of provider, services, event subscriptions """ Authorize.jwt_required() return events_ops.get_events() return providers_ops.remove_service(apf_id, service_id) @router.delete("/resources/events") async def delete_events(Authorize: AuthJWT = Depends()): @router.get('/resources/events/{id}') def get_events(id, Authorize: AuthJWT = Depends()): """ Delete all events collection in DB Retreive one event by the subscriber id (apf_id, aef_id, provider_id or api_invoker_id) """ Authorize.jwt_required() return events_ops.remove_events() return events_ops.get_events_by_id(id) @router.delete('/resources/events/{subscriber_id}/{subscription_id}') async def delete_events_by_subscriber_id(subscriber_id, subscription_id, Authorize: AuthJWT = Depends()): async def delete_events(subscriber_id, subscription_id, Authorize: AuthJWT = Depends()): """ Delete events by subscriber id (apf_id, aef_id, provider_id or api_invoker_id) Loading @@ -130,23 +119,3 @@ async def delete_events_by_subscriber_id(subscriber_id, subscription_id, Authori Authorize.jwt_required() return events_ops.remove_events_by_subscriber_id(subscriber_id, subscription_id) @router.delete('/resources/providers/services/{apf_id}/{service_id}') def delete_provider_service(apf_id, service_id, Authorize: AuthJWT = Depends()): """ Retreive all resources of provider, services, event subscriptions """ Authorize.jwt_required() return providers_ops.remove_service(apf_id, service_id) @router.delete('/resources/invokers/security/{invoker_id}') def delete_invoker_security_context(invoker_id, Authorize: AuthJWT = Depends()): """ Retreive all resources of provider, services, event subscriptions """ Authorize.jwt_required() return invokers_ops.remove_security_context(invoker_id) Loading
controllers/resources.py +20 −51 Original line number Diff line number Diff line Loading @@ -14,7 +14,7 @@ providers_ops = ProviderResources() events_ops = Events() @router.get("/resources/invokers",) @router.get("/resources/invokers") async def get_invokers(Authorize: AuthJWT = Depends()): """ Get list of all invokers registered in CAPIF Loading @@ -25,7 +25,7 @@ async def get_invokers(Authorize: AuthJWT = Depends()): return invokers_ops.get_all_invokers() @router.delete("/resources/invokers/{invoker_id}",) @router.delete("/resources/invokers/{invoker_id}") async def delete_invoker(invoker_id, Authorize: AuthJWT = Depends()): """ Get list of all invokers registered in CAPIF Loading @@ -37,7 +37,7 @@ async def delete_invoker(invoker_id, Authorize: AuthJWT = Depends()): @router.get('/resources/invokers/security/{invoker_id}') def get_invoker_security_context_resources(invoker_id, Authorize: AuthJWT = Depends()): def get_invoker_security_context_resource(invoker_id, Authorize: AuthJWT = Depends()): """ Retreive all resources of invoker, security context, event subscriptions """ Loading @@ -46,28 +46,28 @@ def get_invoker_security_context_resources(invoker_id, Authorize: AuthJWT = Depe return invokers_ops.get_security_context(invoker_id) @router.get('/resources/invokers/events/{invoker_id}') def get_invoker_event_subscription_resources(Authorize: AuthJWT = Depends()): @router.delete('/resources/invokers/security/{invoker_id}') def delete_invoker_security_context(invoker_id, Authorize: AuthJWT = Depends()): """ Retreive all resources of invoker, security context, event subscriptions Retreive all resources of provider, services, event subscriptions """ Authorize.jwt_required() return invokers_ops.get_event_subscription() return invokers_ops.remove_security_context(invoker_id) @router.get("/resources/providers",) async def get_all_providers(Authorize: AuthJWT = Depends()): async def get_providers(Authorize: AuthJWT = Depends()): """ Get list of all provider registered in CAPIF """ Authorize.jwt_required() return providers_ops.get_all_providers() return providers_ops.get_providers() @router.delete("/resources/providers/{provider_id}",) @router.delete("/resources/providers/{provider_id}") async def delete_provider(provider_id, Authorize: AuthJWT = Depends()): """ Get list of all provider registered in CAPIF Loading @@ -88,40 +88,29 @@ def get_provider_services_resources(apf_id, Authorize: AuthJWT = Depends()): return providers_ops.get_services_of_apf(apf_id) @router.get('/resources/events/{id}') def get_events(id, Authorize: AuthJWT = Depends()): """ Retreive one event by the subscriber id (apf_id, aef_id, provider_id or api_invoker_id) """ Authorize.jwt_required() return events_ops.get_events_by_id(id) @router.get('/resources/events') def get_events(Authorize: AuthJWT = Depends()): @router.delete('/resources/providers/services/{apf_id}/{service_id}') def delete_provider_service(apf_id, service_id, Authorize: AuthJWT = Depends()): """ Retreive all registered events Retreive all resources of provider, services, event subscriptions """ Authorize.jwt_required() return events_ops.get_events() return providers_ops.remove_service(apf_id, service_id) @router.delete("/resources/events") async def delete_events(Authorize: AuthJWT = Depends()): @router.get('/resources/events/{id}') def get_events(id, Authorize: AuthJWT = Depends()): """ Delete all events collection in DB Retreive one event by the subscriber id (apf_id, aef_id, provider_id or api_invoker_id) """ Authorize.jwt_required() return events_ops.remove_events() return events_ops.get_events_by_id(id) @router.delete('/resources/events/{subscriber_id}/{subscription_id}') async def delete_events_by_subscriber_id(subscriber_id, subscription_id, Authorize: AuthJWT = Depends()): async def delete_events(subscriber_id, subscription_id, Authorize: AuthJWT = Depends()): """ Delete events by subscriber id (apf_id, aef_id, provider_id or api_invoker_id) Loading @@ -130,23 +119,3 @@ async def delete_events_by_subscriber_id(subscriber_id, subscription_id, Authori Authorize.jwt_required() return events_ops.remove_events_by_subscriber_id(subscriber_id, subscription_id) @router.delete('/resources/providers/services/{apf_id}/{service_id}') def delete_provider_service(apf_id, service_id, Authorize: AuthJWT = Depends()): """ Retreive all resources of provider, services, event subscriptions """ Authorize.jwt_required() return providers_ops.remove_service(apf_id, service_id) @router.delete('/resources/invokers/security/{invoker_id}') def delete_invoker_security_context(invoker_id, Authorize: AuthJWT = Depends()): """ Retreive all resources of provider, services, event subscriptions """ Authorize.jwt_required() return invokers_ops.remove_security_context(invoker_id)