diff --git a/demos/demo2/broker_api.py b/demos/demo2/broker_api.py index 8ead5ecc667ea9b2611211c0bfd688962c46efcd..26ba39f324efa3a997a512284d589fe6b58e98c5 100644 --- a/demos/demo2/broker_api.py +++ b/demos/demo2/broker_api.py @@ -42,14 +42,14 @@ s3ib_to_rest = {"getValueRequest": "READ", "setValueRequest": "WRITE", "createAt class S3IBServer: def __init__(self, access_token: str, provider: api.ModelProvider, id: str, - loop, security_id: str = None, security_enabled = False, opa_server_url="http://localhost:8181"): + loop, security_id: str = None, security_enabled = False): self.id = id self.provider = provider self.loop = loop self.broker = BrokerAMQP(access_token, "s3ibs://" + self.id, self.callback, loop) self.serializer = AASToJsonEncoder() self.deserializer = AASFromJsonDecoder() - self.opa = opa_api.Opa(opa_server_url) + self.opa = opa_api.Opa() self.security_id = base64.urlsafe_b64encode(security_id.encode()).decode() self.security_enabled = security_enabled self.callables: dict[str, Callable] = {} @@ -72,8 +72,6 @@ class S3IBServer: event: BasicEventElement = event obs_path = helpers.id_short_path_from_ref(event.observed) req_path = helpers.id_short_path_from_path(path) - print(obs_path) - print(req_path) if obs_path == req_path: triggered_events.append(event) logger.info(f"[Event] [{event.message_topic}] {event.id_short} was triggered") diff --git a/demos/demo2/demo2_forestmanager.py b/demos/demo2/demo2_forestmanager.py index 1a6f09f868a2b04d09f15505c46fbadf86e7f3a0..d9dc7a2b179290c19d0cd27bd9792fa66d9379c2 100644 --- a/demos/demo2/demo2_forestmanager.py +++ b/demos/demo2/demo2_forestmanager.py @@ -45,11 +45,11 @@ async def main(): access_token = idp.get_token(TokenType.ACCESS_TOKEN) # obtain dzwald's endpoint by checking its entry within the S3I-Directory - #s3i_dir = Directory("https://dir.s3i.vswf.dev/api/2/", access_token) - #dzwald_dir_entry = s3i_dir.queryThingIDBased(dzwald_id) - #s3ib_endpoints = [i for i in dzwald_dir_entry["attributes"]["allEndpoints"] if - # i.startswith('s3ib')] - dzwald_endpoint = "s3ib://s3i:bc30c279-02c5-4918-a2ad-761e927214dd" + s3i_dir = Directory("https://dir.s3i.vswf.dev/api/2/", access_token) + dzwald_dir_entry = s3i_dir.queryThingIDBased(dzwald_id) + s3ib_endpoints = [i for i in dzwald_dir_entry["attributes"]["allEndpoints"] if + i.startswith('s3ib')] + dzwald_endpoint = s3ib_endpoints[0] # use async client to access AAS and its submodels through their REST API asynchronously client = broker_api.S3IBAsyncClient(access_token, forestmanager_hmi_id, loop)