app package

Subpackages

• app.db package
  • Submodules
  • app.db.client module
    • init_mongo()
    • get_db()
  • Module contents
• app.models package
  • Submodules
  • app.models.asset module
    • Asset
      • Asset.asset_id
      • Asset.name
      • Asset.content_type
      • Asset.data_address_name
      • Asset._abc_impl
      • Asset.model_config
      • Asset.data_address_type
      • Asset.data_address_proxy
      • Asset.base_url
      • Asset.edc
  • app.models.connector module
    • PortConfig
      • PortConfig.http
      • PortConfig.management
      • PortConfig.protocol
      • PortConfig.control
      • PortConfig.public
      • PortConfig.version
      • PortConfig._abc_impl
      • PortConfig.model_config
    • Endpoints
      • Endpoints.management
      • Endpoints.protocol
      • Endpoints._abc_impl
      • Endpoints.model_config
    • Connector
      • Connector._abc_impl
      • Connector.model_config
      • Connector.name
      • Connector.description
      • Connector.type
      • Connector.ports
      • Connector.api_key
      • Connector.state
      • Connector.mode
      • Connector.endpoints_url
      • Connector.domain
  • app.models.contract module
    • Contract
      • Contract.edc
      • Contract.contract_id
      • Contract.accessPolicyId
      • Contract._abc_impl
      • Contract.model_config
      • Contract.contractPolicyId
      • Contract.assetsSelector
      • Contract.context
  • app.models.policy module
    • Operator
      • Operator.id
      • Operator._abc_impl
      • Operator.model_config
    • Constraint
      • Constraint.leftOperand
      • Constraint.operator
      • Constraint.rightOperand
      • Constraint._abc_impl
      • Constraint.model_config
    • Rule
      • Rule.action
      • Rule.constraint
      • Rule._abc_impl
      • Rule.model_config
    • PolicyDefinition
      • PolicyDefinition.permission
      • PolicyDefinition.prohibition
      • PolicyDefinition._abc_impl
      • PolicyDefinition.model_config
      • PolicyDefinition.obligation
      • PolicyDefinition.context
      • PolicyDefinition.type
    • Policy
      • Policy._abc_impl
      • Policy.model_config
      • Policy.edc
      • Policy.policy_id
      • Policy.policy
      • Policy.context
  • app.models.transfer module
    • Transfer
      • Transfer.consumer
      • Transfer.provider
      • Transfer.asset
      • Transfer.has_policy_id
      • Transfer.negotiate_contract_id
      • Transfer._abc_impl
      • Transfer.model_config
      • Transfer.contract_agreement_id
      • Transfer.transfer_process_id
      • Transfer.transfer_flow
      • Transfer.authorization
      • Transfer.endpoint
  • Module contents
• app.routes package
  • Submodules
  • app.routes.assets_routes module
    • create_asset_route()
    • list_assets_by_edc()
    • get_asset_by_asset_id()
    • update_asset_route()
    • delete_asset_route()
  • app.routes.connectors_routes module
    • create_connector_route()
    • start_edc()
    • stop_edc()
    • list_connectors()
    • get_connector()
    • update_connector_route()
    • delete_connector_route()
  • app.routes.contracts_routes module
    • create_contract_route()
    • list_contracts_by_edc()
    • get_contract_by_contract_id()
    • update_contract_route()
    • delete_contract_route()
  • app.routes.policies_routes module
    • create_policy_route()
    • list_policies_by_edc()
    • get_policy_by_policy_id()
    • delete_asset_route()
  • app.routes.transfers_routes module
    • catalog_request()
    • negotiate_contract()
    • contract_agreement()
    • start_http_server()
    • stop_http_server()
    • start_transfer()
    • check_transfer()
    • new_transfer()
    • get_all_transfers()
    • start_transfer_pull()
    • check_data_pull()
    • proxy_http_logger()
    • proxy_pull()
  • Module contents
• app.schemas package
  • Submodules
  • app.schemas.connector module
    • ConnectorResponse
      • ConnectorResponse.id
      • ConnectorResponse.name
      • ConnectorResponse.description
      • ConnectorResponse.type
      • ConnectorResponse.ports
      • ConnectorResponse.state
      • ConnectorResponse.mode
      • ConnectorResponse.endpoints_url
      • ConnectorResponse.api_key
      • ConnectorResponse.domain
      • ConnectorResponse._abc_impl
      • ConnectorResponse.model_config
    • ConnectorUpdate
      • ConnectorUpdate._abc_impl
      • ConnectorUpdate.model_config
      • ConnectorUpdate.name
      • ConnectorUpdate.description
      • ConnectorUpdate.type
      • ConnectorUpdate.ports
      • ConnectorUpdate.api_key
      • ConnectorUpdate.state
      • ConnectorUpdate.mode
      • ConnectorUpdate.endpoints_url
      • ConnectorUpdate.domain
  • app.schemas.transfer module
    • TransferResponse
      • TransferResponse.id
      • TransferResponse.consumer
      • TransferResponse.provider
      • TransferResponse.asset
      • TransferResponse.has_policy_id
      • TransferResponse.negotiate_contract_id
      • TransferResponse.contract_agreement_id
      • TransferResponse.transfer_process_id
      • TransferResponse.transfer_flow
      • TransferResponse.authorization
      • TransferResponse.endpoint
      • TransferResponse._abc_impl
      • TransferResponse.model_config
    • RequestCatalog
      • RequestCatalog.consumer
      • RequestCatalog.provider
      • RequestCatalog._abc_impl
      • RequestCatalog.model_config
    • NegotitateContract
      • NegotitateContract._abc_impl
      • NegotitateContract.model_config
      • NegotitateContract.consumer
      • NegotitateContract.provider
      • NegotitateContract.contract_offer_id
      • NegotitateContract.asset
    • ContractAgreement
      • ContractAgreement._abc_impl
      • ContractAgreement.model_config
      • ContractAgreement.consumer
      • ContractAgreement.id_contract_negotiation
    • StartTransfer
      • StartTransfer._abc_impl
      • StartTransfer.model_config
      • StartTransfer.consumer
      • StartTransfer.provider
      • StartTransfer.contract_agreement_id
    • CheckTransfer
      • CheckTransfer._abc_impl
      • CheckTransfer.model_config
      • CheckTransfer.consumer
      • CheckTransfer.transfer_process_id
  • Module contents
• app.services package
  • Submodules
  • app.services.assets_service module
    • create_asset()
    • register_asset_with_edc()
    • get_asset_by_asset_id_service()
    • update_asset()
    • delete_asset()
    • get_assets_by_edc_id()
  • app.services.connectors_service module
    • create_connector()
    • check_ports_unique()
    • is_port_in_use()
    • start_edc_service()
    • stop_edc_service()
    • get_all_connectors()
    • get_connector_by_id()
    • update_connector()
    • delete_connector()
  • app.services.contracts_service module
    • create_contract()
    • _register_contract_with_edc()
    • _convert_contract_to_edc_format()
    • get_contracts_by_edc_id()
    • get_contract_by_contract_id_service()
    • update_contract()
    • delete_contract()
    • _get_connector()
    • _parse_contract_item()
  • app.services.edc_launcher_service module
    • keystore_password
    • _generate_files()
    • _wait_for_postgres()
    • _run_docker_compose()
    • _run_docker_compose_down()
    • _create_docker_network_if_not_exists()
  • app.services.policies_service module
    • create_policy()
    • register_policy_with_edc()
    • convert_policy_to_edc_format()
    • _convert_rules()
    • normalize_odrl_list()
    • convert_rules_get()
    • get_policies_by_edc_id()
    • get_policy_by_policy_id_service()
    • delete_policy()
  • app.services.transfers_service module
    • catalog_request_service()
    • catalog_request_curl()
    • negotiate_contract_service()
    • negotiate_contract_curl()
    • get_contract_agreement_service()
    • get_contract_agreement_curl()
    • start_http_server_service()
    • stop_http_server_service()
    • start_transfer_service()
    • start_transfer_curl()
    • check_transfer_service()
    • check_transfer_curl()
    • create_transfer_service()
    • get_all_transfers_service()
    • convert_objectids()
    • start_transfer_service_pull()
    • start_transfer_curl_pull()
    • check_transfer_data_pull_service()
    • check_transfer_data_curl_pull()
  • Module contents
• app.util package
  • Submodules
  • app.util.edc_helpers module
    • get_base_url()
    • get_api_key()
  • Module contents

Submodules

app.main module

EDC Studio Backend — FastAPI application entry point.

This module initializes the FastAPI application that manages Eclipse Data Connectors (EDC). It configures CORS, connects to MongoDB, and registers all API routes related to connectors, assets, policies, contracts, and transfers.

The API acts as a centralized controller for EDC connector management.

async app.main.startup_db()

Initialize the MongoDB client on application startup.

This ensures that the database connection is ready before handling requests.

Module contents