[AAP-91390] Add inventory, host, inventory_source, inventory_source_update, schedule, job_launch modules

.ansible-lint

@@ -9,5 +9,11 @@ exclude_paths:
   - 'extensions/molecule/inventory.yml'
   - 'extensions/molecule/organization_mock/inventory.yml'
   - 'extensions/molecule/users_mock/inventory.yml'
+  - 'extensions/molecule/inventory_mock/inventory.yml'
+  - 'extensions/molecule/host_mock/inventory.yml'
+  - 'extensions/molecule/inventory_source_mock/inventory.yml'
+  - 'extensions/molecule/inventory_source_update_mock/inventory.yml'
+  - 'extensions/molecule/schedule_mock/inventory.yml'
+  - 'extensions/molecule/job_launch_mock/inventory.yml'
 use_default_rules: true
 ...

changelogs/fragments/aap_91390_host.yml

@@ -0,0 +1,3 @@
+minor_changes:
+  - host - add module migrated from awx.awx/ansible.controller
+    (https://issues.redhat.com/browse/AAP-91390).

changelogs/fragments/aap_91390_inventory.yml

@@ -0,0 +1,4 @@
+minor_changes:
+  - inventory - add module migrated from awx.awx/ansible.controller, including copy_from,
+    instance_groups/input_inventories associations, and constructed inventory support
+    (https://issues.redhat.com/browse/AAP-91390).

changelogs/fragments/aap_91390_inventory_source.yml

@@ -0,0 +1,4 @@
+minor_changes:
+  - inventory_source - add module migrated from awx.awx/ansible.controller, including
+    notification_templates_started/success/error associations
+    (https://issues.redhat.com/browse/AAP-91390).

changelogs/fragments/aap_91390_inventory_source_update.yml

@@ -0,0 +1,10 @@
+minor_changes:
+  - inventory_source_update - add module migrated from awx.awx/ansible.controller
+    to launch an inventory source update (sync)
+    (https://issues.redhat.com/browse/AAP-91390).
+bugfixes:
+  - Fix the SDK layer's shared operation executor to actually call the API for
+    an endpoint operation intentionally declared with no request-body fields
+    (a launch-trigger sub-action), and to resolve any custom path parameter
+    name declared on an EndpointOperation instead of only ever substituting
+    a param literally named C(id).

changelogs/fragments/aap_91390_job_launch.yml

@@ -0,0 +1,10 @@
+minor_changes:
+  - job_launch - add module migrated from awx.awx/ansible.controller to launch
+    an Ansible job template (https://issues.redhat.com/browse/AAP-91390).
+bugfixes:
+  - Fix the SDK layer's shared operation executor to still call the API for a
+    primary create/launch operation when all of its optional body fields
+    happen to be unset (e.g. job_launch with no prompt overrides) — it was
+    only correctly distinguishing this from an unused optional secondary
+    endpoint (like an association or sub-resource) in one of the two
+    connection-mode implementations.

changelogs/fragments/aap_91390_schedule.yml

@@ -0,0 +1,4 @@
+minor_changes:
+  - schedule - add module migrated from awx.awx/ansible.controller, including
+    credentials/labels/instance_groups associations
+    (https://issues.redhat.com/browse/AAP-91390).

docs/03-sdk-architecture.md

@@ -525,6 +525,64 @@ class LookupModule(LookupBase):
 This allows dynamic lookups (e.g., "find all users whose username contains 'admin'")
 without spawning additional processes or triggering SSL fork safety issues.
 
+### Generic Methods for Associations, Copy, and Launch/Wait
+
+Beyond `execute()` and `search_api()`, three more generic methods live on
+`BaseAPIClient` (and are implemented identically in `PlatformService` and
+`DirectHTTPClient`, with thin `ManagerRPCClient` wrappers) so that association
+sub-endpoints, secondary sub-resources, and copy operations never require an
+action plugin to touch `manager.session`/HTTP directly:
+
+```python
+def manage_associations(self, base_path, resource_id, association_field,
+                         desired_items, lookup_endpoint, lookup_field) -> bool:
+    """Sync an association sub-endpoint (e.g. a resource's instance_groups).
+
+    Resolves desired_items (names or IDs) to integer IDs, diffs against the
+    current association list, and issues associate/disassociate POSTs for
+    the difference. Returns True if anything changed.
+    """
+
+def manage_sub_resource(self, base_path, resource_id, sub_path, data=None) -> bool:
+    """GET/compare/POST a secondary sub-resource (e.g. survey_spec).
+
+    data=None is a no-op; data=={} DELETEs the sub-resource; otherwise POSTs
+    only if the current value differs. Returns True if changed.
+    """
+
+def copy_resource(self, module_name, source_name_or_id, new_name,
+                   copy_endpoint_path) -> dict:
+    """POST to a resource's /copy/ sub-endpoint.
+
+    Finds the source via execute('find', ...), falling back to an ID-based
+    lookup, then POSTs {'name': new_name} to {copy_endpoint_path}/{id}/copy/.
+    Returns the copied resource's raw API response.
+    """
+```
+
+See `plugins/action/inventory.py` for a full Pattern C example combining
+`copy_resource` (for `copy_from`) and `manage_associations` (for
+`instance_groups`/`input_inventories`).
+
+**Launch/wait** (Shape 2 resources like `ad_hoc_command`, `job_launch`,
+`inventory_source_update`) is handled inside `execute()` itself rather than as
+a separate method: `wait`/`interval`/`timeout` are popped off the incoming
+`ansible_data` dict before the resource dataclass is built (only when the
+target dataclass doesn't declare a field of that name — so a resource with a
+genuine `timeout` field, e.g. `job_template`, keeps it), and — when
+`wait=True` — `_wait_for_resource_completion()` polls the newly-created
+resource via `_find_resource()` until `from_api()` reports a truthy
+`finished` (or `event_processing_finished`), raising `WaitTimeoutError`
+(carrying the last poll result, so the caller can still report `id`/`status`)
+if `timeout` elapses first. `DEFAULT_WAIT_TIMEOUT` (3600s) applies when
+`wait=True` but no `timeout` was given.
+
+Adding a new generic method follows the same four-layer rule as everything
+else in this SDK: `base_client.py` (abstract, raises `NotImplementedError`) →
+`platform_manager.py` → `direct_client.py` → `rpc_client.py`. Skipping the
+`rpc_client.py` wrapper is the most common miss — the method works in direct
+mode but silently isn't reachable from the action plugin in persistent mode.
+
 ---
 
 ## SECTION 7: Directory Structure

extensions/molecule/host_mock/cleanup.yml

@@ -0,0 +1,150 @@
+---
+# Cleanup: delete hosts/inventories/organizations created by converge.
+- name: Cleanup — delete host, inventory, organization (mock, connection local)
+  hosts: localhost
+  connection: local
+  gather_facts: false
+  vars:
+    gateway_hostname: "http://127.0.0.1:8000"
+    gateway_username: "mock"
+    gateway_password: "testpass"
+    gateway_validate_certs: false
+    molecule_org_name: "Molecule Test Org Host Local"
+    molecule_inv_name: "Molecule Test Inventory Host Local"
+    molecule_host_name: "molecule-host-local"
+  tasks:
+    - name: Delete host (connection local)
+      ansible.platform.host:
+        name: "{{ molecule_host_name }}"
+        inventory: "{{ molecule_inv_name }}"
+        state: absent
+      register: delete_result_local
+      failed_when: false
+      vars:
+        ansible_connection: local
+
+    - name: Assert host removed or already absent (connection local)
+      ansible.builtin.assert:
+        that: delete_result_local is not failed
+        fail_msg: "Cleanup: failed to delete host {{ molecule_host_name }}."
+      vars:
+        ansible_connection: local
+
+    - name: Delete inventory (connection local)
+      ansible.platform.inventory:
+        name: "{{ molecule_inv_name }}"
+        organization: "{{ molecule_org_name }}"
+        state: absent
+      failed_when: false
+      vars:
+        ansible_connection: local
+
+    - name: Delete organization (connection local)
+      ansible.platform.organization:
+        name: "{{ molecule_org_name }}"
+        state: absent
+      failed_when: false
+      vars:
+        ansible_connection: local
+
+    - name: Remove manager survive flag (signals manager to shut down)
+      ansible.builtin.file:
+        path: /tmp/ap/.survive
+        state: absent
+      vars:
+        ansible_connection: local
+
+- name: Cleanup — delete host, inventory, organization (mock, http direct)
+  hosts: localhost
+  connection: ansible.platform.http
+  gather_facts: false
+  vars:
+    gateway_hostname: "http://127.0.0.1:8000"
+    gateway_username: "mock"
+    gateway_password: "testpass"
+    gateway_validate_certs: false
+    ansible_platform_use_persistent_connection: false
+    molecule_org_name: "Molecule Test Org Host HTTP Direct"
+    molecule_inv_name: "Molecule Test Inventory Host HTTP Direct"
+    molecule_host_name: "molecule-host-http-direct"
+  tasks:
+    - name: Delete host (http direct)
+      ansible.platform.host:
+        name: "{{ molecule_host_name }}"
+        inventory: "{{ molecule_inv_name }}"
+        state: absent
+      register: delete_result_http_direct
+      failed_when: false
+
+    - name: Assert host removed or already absent (http direct)
+      ansible.builtin.assert:
+        that: delete_result_http_direct is not failed
+        fail_msg: "Cleanup: failed to delete host {{ molecule_host_name }}."
+
+    - name: Delete inventory (http direct)
+      ansible.platform.inventory:
+        name: "{{ molecule_inv_name }}"
+        organization: "{{ molecule_org_name }}"
+        state: absent
+      failed_when: false
+
+    - name: Delete organization (http direct)
+      ansible.platform.organization:
+        name: "{{ molecule_org_name }}"
+        state: absent
+      failed_when: false
+
+    - name: Remove manager survive flag (signals manager to shut down)
+      ansible.builtin.file:
+        path: /tmp/ap/.survive
+        state: absent
+      vars:
+        ansible_connection: local
+
+- name: Cleanup — delete host, inventory, organization (mock, http persistent)
+  hosts: localhost
+  connection: ansible.platform.http
+  gather_facts: false
+  vars:
+    gateway_hostname: "http://127.0.0.1:8000"
+    gateway_username: "mock"
+    gateway_password: "testpass"
+    gateway_validate_certs: false
+    ansible_platform_use_persistent_connection: true
+    molecule_org_name: "Molecule Test Org Host HTTP Persistent"
+    molecule_inv_name: "Molecule Test Inventory Host HTTP Persistent"
+    molecule_host_name: "molecule-host-http-persistent"
+  tasks:
+    - name: Delete host (http persistent)
+      ansible.platform.host:
+        name: "{{ molecule_host_name }}"
+        inventory: "{{ molecule_inv_name }}"
+        state: absent
+      register: delete_result_http_persistent
+      failed_when: false
+
+    - name: Assert host removed or already absent (http persistent)
+      ansible.builtin.assert:
+        that: delete_result_http_persistent is not failed
+        fail_msg: "Cleanup: failed to delete host {{ molecule_host_name }}."
+
+    - name: Delete inventory (http persistent)
+      ansible.platform.inventory:
+        name: "{{ molecule_inv_name }}"
+        organization: "{{ molecule_org_name }}"
+        state: absent
+      failed_when: false
+
+    - name: Delete organization (http persistent)
+      ansible.platform.organization:
+        name: "{{ molecule_org_name }}"
+        state: absent
+      failed_when: false
+
+    - name: Remove manager survive flag (signals manager to shut down)
+      ansible.builtin.file:
+        path: /tmp/ap/.survive
+        state: absent
+      vars:
+        ansible_connection: local
+...