Changes for manage dataproducts

API_OASEES/app/utils/connector_utils.py

-"""
-MIT License
-
-Copyright (c) 2024 Tecnalia, Basque Research & Technology Alliance (BRTA)
-
-Permission is hereby granted, free of charge, to any person obtaining a copy
-of this software and associated documentation files (the "Software"), to deal
-in the Software without restriction, including without limitation the rights
-to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
-copies of the Software, and to permit persons to whom the Software is
-furnished to do so, subject to the following conditions:
-
-The above copyright notice and this permission notice shall be included in all
-copies or substantial portions of the Software.
-
-THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
-IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
-FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
-AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
-LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
-OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
-SOFTWARE.
-"""
-
-import json
-import os
-import uuid
-from tecnalia.models.dataProductResourcesBody import DataProductResourcesModel
-from fastapi import HTTPException
-
-from app.utils.create_asset import invoke_create_asset
-from app.utils.create_policy import invoke_create_policy, checkPolicyId
-from app.utils.create_contract_definition import invoke_create_contract_definition
-
 logger = logging.getLogger("uvicorn.error")
 
 def load_asset_edc(body:DataProductResourcesModel, dataResouceAPi_URL:str):

API_OASEES/app/utils/create_asset.py

@@ -21,12 +21,11 @@ LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 SOFTWARE.
 """
-
+import logging
 import os
 import json
 import requests
 
-
 logger = logging.getLogger("uvicorn.error")
 
 def invoke_create_asset(dataProductId: str, dataProductName: str, dataProductFormatType: str,

API_OASEES/app/utils/create_contract_definition.py

@@ -21,12 +21,11 @@ LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 SOFTWARE.
 """
+import logging
 import os
 import json
 import requests
 
-
-
 logger = logging.getLogger("uvicorn.error")
 
 

API_OASEES/app/utils/create_policy.py

@@ -22,6 +22,7 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 SOFTWARE.
 """
 import json
+import logging
 import os
 import requests
 

API_OASEES/oasees.env

@@ -89,27 +89,7 @@ Deq1z6oR/H7RyLnT5Rcx1adFJO7yOcw87Qb7+QiOV0JY05192YUiGRowfBEFZ8YQ
 hV7DajftAlzvTh7dSUp4rIhvNxud9DNbnaOi9951MM/sJ1jpEBzQPTLKUjLLt2Fr
 Qyz+0SOjXS+hNYheMsU8EhZMg+E6X2M678VY7GIHXGtUhbM6DuvWfGl1FikEb4UU
 b8QMN8kJkBpTEzJhDKDP3j/AkISj5HLkX8Q2Sgw8/H2DwPfyfk4gRxcXc1Y1V1J4
-HsTo26TNMqtuRhi6wCIOTROslcX/8uKuQLKQMgJ9kbtXeT4QfZ2/PltCqXjmmBJs
-mzdttyM9AgMBAAECggEBANcRXNq9pAnT7S+eAmLiC6RN8LFnYTsUGXuOo90Cjw+I
-b8UeKdR0aHR/k2rhr90qQ+wScte0wwPHfAP6hAMWSHHi4e20CjGt3BIIVaPz0d27
-UDmxwu/lp/k84zS1JjRmEpi0Bvq28egxIOov0GW3zUzAlyUzM3MSiZWEc9zuIZnL
-/AM+AR4cBHTBThBaQIg4Gj+IrDulilEYjNvc1D5s7Y1GMB/fEjs7L7s/AISQEEkD
-7H1CgeWqEKlNSQ23mLen2cN9d41tz5gI1/RIFfZSJSZKxMq6LYT+TRV8aaSsEVzD
-gTcwA3y/wn4a6Imiqcj8yUK53plKK1S45ysBGKWot0ECgYEA/Qpiz1Sv2KtAhU22
-93fuKels0fZo9V/2L0irPs6rp5B4kko/HgRGuHJtgjTPoAcw1/y6BEqJ7oV6T7pe
-ok4F0uOSiuSEvNgwhXliNwj+bUJZcTiJqwDTF/IwsflyGC848mCaRGTp8J070wUq
-BNHYTMaGXL08ctnUISZZuyuRyq0CgYEA2aEvqetCIhQXevu22qk527u8Kn3SYpE4
-fYxfnQJ/9eCtDTqIaGq9MvXLvmc7dPz0SK9J5BlqeQrHdfMLzNBFIzXk+J2KpkP2
-FYhLf+O/To2UcqIa9kewavQ93EVHY5ggMoRR+jShTCpuROp3v+HVCCWCI3Yker7M
-v9TWdiwU3NECgYB1txcwjJ0hlsl1OiocBdbt+IF/S7qYLARDCvNfTJXeZf8xTwj9
-1c9wjwsSv663K6E1WYTP6j0wkTfNT04nA1UCPow1wQlfMNOhxE5EfBKgkXU6jqq8
-uq15PloY8Yp6Zb2ARCCAINIT9ZGXIZfilhyh2tk223H7nAprQYQM5r/0IQKBgQCl
-5/w3FDL5WcnApq3yKfoCqi67UeoV3FFtXJrzThmQrvQd1pZwy5Zqh/kHsRkhiUkN
-NBwneLyzg+Uk5OEFBWz/d7GTWj59m+e46Itt9og78TDO5weY4nP6RTH3fxT6Ntms
-yTTZgk/IibxAa2JY9Gd762Q3dnQ+4r+iKjZIJjjNUQKBgQCpNJkwNE092BQ8ByA0
-zRPLAxW/ntX4QzySB4eqe0BHYRfADDw+DCwJBQLlluyb8DJn2GoyY7GMsEBXXxSI
-I765ki7y1MVcai3vVjS91mL3pGbDfYg1r3fS0ShUKqcEu7ZE2TvtpXwOMTa12MXa
-Urbz/GqWw2FUqcJLFloRodkVaA==
+
 -----END PRIVATE KEY-----"
 
 
@@ -118,20 +98,7 @@ Urbz/GqWw2FUqcJLFloRodkVaA==
 #EDC INFO
 
 
-
-POLICY_ID=no-restriction-policy
-CONTRACT_ID=contract_no_restriction
-#POLICY_TIME_INTERVAL=true
-#POLICY_TIME_INTERVAL_START_DATE=2022-12-31T23:00:00.000Z
-#POLICY_TIME_INTERVAL_END_DATE=2026-09-30T23:00:00.000Z
-
-
-PROVIDER_HOST=oasees.tri.lan
-PROVIDER_CONTROL_PORT=9192
-PROVIDER_MANAGEMENT_PORT=9193
-
-#PROVIDER_HOST_PORT=mgmt.connector.prov.hx001.digital.tecnalia.dev
-
+PROVIDER_MANAGEMENT_URL=http://oasees.tri.lan:9193/management/v3
 
 HEADER_AUTHORIZATION=2dSXJqNXgKAf08PINHOpwTgbcIE5tNgS
 

GAIAX_DATAPRODUCT_OASEES_DOCKER_COMPOSE/docker-compose.yml

@@ -58,26 +58,27 @@ services:
     networks:
       - oasees-network
 
-  postgres:
-     image: postgres:10.5
-     container_name: oasees_postgres
-     restart: always
-     environment:
-       - POSTGRES_USER=postgres
-       - POSTGRES_PASSWORD=12345
-     logging:
-       options:
-         max-size: 10m
-         max-file: "3"
-     ports:
+
+
+    postgres:
+      image: postgres:10.5
+      container_name: oasees_postgres
+      restart: always
+
+      ports:
         - '5432:5432'
-     
-     volumes: 
+
+      env_file:
+        - ./postgres.env
+
+      volumes:
         - ./postgres-data:/var/lib/postgresql/data
         # copy the sql script to create tables
         - ./sql/create_tables.sql:/docker-entrypoint-initdb.d/create_tables.sql
-     networks:
-       - oasees-network 
+      networks:
+        - oasees-network
+
+
 volumes:
   app: {}
 

GAIAX_DATAPRODUCT_OASEES_DOCKER_COMPOSE/gaiax-selfdescriptor-module/app/utils/connector_utils.py

-"""
-MIT License
-
-Copyright (c) 2024 Tecnalia, Basque Research & Technology Alliance (BRTA)
-
-Permission is hereby granted, free of charge, to any person obtaining a copy
-of this software and associated documentation files (the "Software"), to deal
-in the Software without restriction, including without limitation the rights
-to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
-copies of the Software, and to permit persons to whom the Software is
-furnished to do so, subject to the following conditions:
-
-The above copyright notice and this permission notice shall be included in all
-copies or substantial portions of the Software.
-
-THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
-IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
-FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
-AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
-LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
-OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
-SOFTWARE.
-"""
-
-import json
-import os
-import uuid
-from tecnalia.models.dataProductResourcesBody import DataProductResourcesModel
-from fastapi import HTTPException
-
-from app.utils.create_asset import invoke_create_asset
-from app.utils.create_policy import invoke_create_policy, checkPolicyId
-from app.utils.create_contract_definition import invoke_create_contract_definition
-
 logger = logging.getLogger("uvicorn.error")
 
 def load_asset_edc(body:DataProductResourcesModel, dataResouceAPi_URL:str):

GAIAX_DATAPRODUCT_OASEES_DOCKER_COMPOSE/gaiax-selfdescriptor-module/app/utils/create_asset.py

@@ -21,12 +21,11 @@ LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 SOFTWARE.
 """
-
+import logging
 import os
 import json
 import requests
 
-
 logger = logging.getLogger("uvicorn.error")
 
 def invoke_create_asset(dataProductId: str, dataProductName: str, dataProductFormatType: str,

GAIAX_DATAPRODUCT_OASEES_DOCKER_COMPOSE/gaiax-selfdescriptor-module/app/utils/create_contract_definition.py

@@ -21,12 +21,11 @@ LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 SOFTWARE.
 """
+import logging
 import os
 import json
 import requests
 
-
-
 logger = logging.getLogger("uvicorn.error")
 
 

GAIAX_DATAPRODUCT_OASEES_DOCKER_COMPOSE/gaiax-selfdescriptor-module/app/utils/create_policy.py

@@ -22,6 +22,7 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 SOFTWARE.
 """
 import json
+import logging
 import os
 import requests
 

GAIAX_DATAPRODUCT_OASEES_DOCKER_COMPOSE/gaiax-selfdescriptor-module/oasees.env

@@ -116,22 +116,7 @@ Urbz/GqWw2FUqcJLFloRodkVaA==
 
 
 #EDC INFO
-
-
-
-POLICY_ID=no-restriction-policy
-CONTRACT_ID=contract_no_restriction
-#POLICY_TIME_INTERVAL=true
-#POLICY_TIME_INTERVAL_START_DATE=2022-12-31T23:00:00.000Z
-#POLICY_TIME_INTERVAL_END_DATE=2026-09-30T23:00:00.000Z
-
-
-PROVIDER_HOST=oasees.tri.lan
-PROVIDER_CONTROL_PORT=9192
-PROVIDER_MANAGEMENT_PORT=9193
-
-#PROVIDER_HOST_PORT=mgmt.connector.prov.hx001.digital.tecnalia.dev
-
+PROVIDER_MANAGEMENT_URL=http://oasees.tri.lan:9193/management/v3
 
 HEADER_AUTHORIZATION=2dSXJqNXgKAf08PINHOpwTgbcIE5tNgS