remotivelabs.topology.namespaces.some_ip

import asyncio

from remotivelabs.broker import BrokerClient

from remotivelabs.topology.namespaces.some_ip import SomeIPError, SomeIPNamespace, SomeIPRequestReturn, SomeIPResponse


async def main():
    async with (
        BrokerClient(url="http://127.0.0.1:50051") as broker_client,
        SomeIPNamespace(
            "comsuming_service",
            broker_client,
            client_id=99,
        ) as some_ip_namespace,
    ):
        request_task = await some_ip_namespace.request(
            req=SomeIPRequestReturn(service_instance_name="SomeService", name="SomeMethod", parameters={"ParamIn": 42})
        )
        response = await request_task
        match response:
            case SomeIPResponse():
                params = response.parameters
                print("Got parameters:", params)

            case SomeIPError():
                print(f"SomeIP error: {response}")


if __name__ == "__main__":
    asyncio.run(main())

import asyncio

from remotivelabs.broker import BrokerClient

from remotivelabs.topology.namespaces.some_ip import SomeIPNamespace


async def main():
    async with (
        BrokerClient(url="http://127.0.0.1:50051") as broker_client,
        SomeIPNamespace(
            "comsuming_service",
            broker_client,
            client_id=99,
        ) as some_ip_namespace,
    ):
        events = await some_ip_namespace.subscribe(("SomeIPEventFromTestService", "TestService"))
        async for event in events:
            print(f"Received event: {event.name} with parameters {event.parameters}")


if __name__ == "__main__":
    asyncio.run(main())

import asyncio

from remotivelabs.broker import BrokerClient

from remotivelabs.topology.behavioral_model import BehavioralModel
from remotivelabs.topology.namespaces import filters
from remotivelabs.topology.namespaces.some_ip import SomeIPNamespace, SomeIPRequest, SomeIPResponse


async def echo_callback(req: SomeIPRequest) -> SomeIPResponse:
    return SomeIPResponse(parameters=req.parameters)


async def main():
    async with BrokerClient(url="http://127.0.0.1:50051") as broker_client:
        someip_ns = SomeIPNamespace(
            "hosted_service",
            broker_client,
            client_id=88,
        )
        async with BehavioralModel(
            "MyECU",
            namespaces=[someip_ns],
            broker_client=broker_client,
            input_handlers=[
                someip_ns.create_input_handler([filters.SomeIPRequestFilter(service_instance_name="TestService")], echo_callback)
            ],
        ) as server:
            await server.run_forever()


if __name__ == "__main__":
    asyncio.run(main())