async def run(
    client: InfrahubClient, log: logging.Logger, branch: str, **kwargs
) -> None:
    log.info("Generate all prefixes related data...")
    await create_prefixes(client=client, branch=branch, log=log)


async def create_prefixes(
    client: InfrahubClient, log: logging.Logger, branch: str
) -> None:
    # Create l2 domain
    l2_domain = await client.create(
        kind="IpamL2Domain",
        name="default",
    )
    await l2_domain.save(allow_upsert=True)

    # Create public prefix
    public_prefix = await client.create(
        kind="IpamPrefix",
        status="active",
        prefix="203.0.113.0/24",
        member_type="prefix",
        role="public",
    )
    await public_prefix.save(allow_upsert=True)

    # Create management prefix
    management_prefix = await client.create(
        kind="IpamPrefix",
        status="active",
        prefix="172.16.1.0/24",
        member_type="address",
        role="management",
    )
    await management_prefix.save(allow_upsert=True)

    # Create management ip pool
    management_pool = await client.create(
        kind="CoreIPAddressPool",
        name="Management IP pool",
        default_prefix_type="IpamIPPrefix",
        default_prefix_length=24,
        default_address_type="IpamIPAddress",
        default_member_type="address",
        ip_namespace="default",
        resources=[management_prefix],
    )
    await management_pool.save(allow_upsert=True)

    customer_prefix_pool = await client.create(
        kind="CoreIPPrefixPool",
        name="Customer prefixes pool",
        default_prefix_type="IpamPrefix",
        default_prefix_length=29,
        default_member_type="address",
        ip_namespace="default",
        resources=[public_prefix],
    )
    await customer_prefix_pool.save(allow_upsert=True)

    customer_vlan_pool = await client.create(
        kind="CoreNumberPool",
        name="Customer vlan pool",
        node="IpamVLAN",
        node_attribute="vlan_id",
        start_range=1000,
        end_range=2000,
    )
    await customer_vlan_pool.save(allow_upsert=True)