HashicorpTerraform

Hashicorp Terraform provide infrastructure automation to provision and manage resources in any cloud or data center with Terraform.

IT Services · HashiCorp Terraform

Details

IDHashicorpTerraform
ProviderIBM
CategoryIT Services
From Version6.10.0
Docker Imagedemisto/auth-utils:1.0.0.10133006
Supported ModulesAgentix XSIAM

README

Hashicorp Terraform provide infrastructure automation to provision and manage resources in any cloud or data center with Terraform.
This integration was integrated and tested with version v1.4.4 of HashicorpTerraform.

Configure HashiCorp Terraform in Cortex

Parameter Description Required
Server URL   True
API Token The API Key to use for connection. True
Default Organization Name There is an option to override with a command input parameter. If not provided, policy commands should require the organization name. False
Default Workspace ID There is an option to override with an input parameter. If not provided, some commands should require the workspace ID. False
Trust any certificate (not secure)   False
Use system proxy settings   False
Fetch events   False
Maximum Number of Audit Events Per Fetch Default is 10000. False

Commands

You can execute these commands from the CLI, as part of an automation, or in a playbook.
After you successfully execute a command, a DBot message appears in the War Room with the command details.

terraform-runs-list


List runs in a workspace.

Base Command

terraform-runs-list

Permissions

This command requires a User or Team token that has admin level access to the workspace. Refer to HashiCorp Terraform API Token Access Levels.

Input

Argument Name Description Required
workspace_id The workspace ID to list runs for. Optional
run_id The run ID to get a specific run. Optional
filter_status The run status to filter by. Possible values are: pending, fetching, fetching_completed, pre_plan_running, pre_plan_completed, queuing, plan_queued, planning, planned, cost_estimating, cost_estimated, policy_checking, policy_override, policy_soft_failed, policy_checked, confirmed, post_plan_running, post_plan_completed, planned_and_finished, planned_and_saved, apply_queued, applying, applied, discarded, errored, canceled, force_canceled. Optional
page_number The page number of the results to return. Default is 1. Optional
page_size The number of results to return per page. Default is 20, maximum is 100. Optional

Context Output

Path Type Description
Terraform.Run.data.id String The run ID.
Terraform.Run.data.attributes.status String The run status.
Terraform.Run.data.relationships.plan.data.id String The plan ID.
Terraform.Run.data.attributes.status-timestamps.planned-at Date The datetime the plan was planned.
Terraform.Run.data.type String THe run type.
Terraform.Run.data.attributes.actions.is-cancelable Boolean Flag indicating whether the Terraform run can be canceled.
Terraform.Run.data.attributes.actions.is-confirmable Boolean Flag indicating whether the Terraform run can be confirmed.
Terraform.Run.data.attributes.actions.is-discardable Boolean Flag indicating whether the Terraform run can be discarded.
Terraform.Run.data.attributes.actions.is-force-cancelable Boolean Flag indicating whether the Terraform run can be force-canceled.
Terraform.Run.data.attributes.canceled-at Unknown Timestamp indicating when the Terraform run was canceled.
Terraform.Run.data.attributes.created-at Date Timestamp indicating when the Terraform run was created.
Terraform.Run.data.attributes.has-changes Boolean Flag indicating whether there are changes in the Terraform run.
Terraform.Run.data.attributes.auto-apply Boolean Flag indicating whether auto-apply is enabled for the Terraform run.
Terraform.Run.data.attributes.allow-empty-apply Boolean Flag indicating whether empty apply is allowed for the Terraform run.
Terraform.Run.data.attributes.allow-config-generation Boolean Flag indicating whether configuration generation is allowed for the Terraform run.
Terraform.Run.data.attributes.is-destroy Boolean Flag indicating whether the Terraform run is a destroy operation.
Terraform.Run.data.attributes.message String Text message associated with the Terraform run.
Terraform.Run.data.attributes.plan-only Boolean Flag indicating whether the Terraform run is for planning only.
Terraform.Run.data.attributes.source String Source of the Terraform run.
Terraform.Run.data.attributes.status-timestamps.plan-queueable-at Date Timestamp indicating when the Terraform run is queueable in the plan stage.
Terraform.Run.data.attributes.trigger-reason String Reason for triggering the Terraform run.
Terraform.Run.data.attributes.target-addrs Unknown Target addresses associated with the Terraform run.
Terraform.Run.data.attributes.permissions.can-apply Boolean Flag indicating whether the user has permission to apply changes.
Terraform.Run.data.attributes.permissions.can-cancel Boolean Flag indicating whether the user has permission to cancel the Terraform run.
Terraform.Run.data.attributes.permissions.can-comment Boolean Flag indicating whether the user has permission to add comments.
Terraform.Run.data.attributes.permissions.can-discard Boolean Flag indicating whether the user has permission to discard the Terraform run.
Terraform.Run.data.attributes.permissions.can-force-execute Boolean Flag indicating whether the user has permission to force execute the Terraform run.
Terraform.Run.data.attributes.permissions.can-force-cancel Boolean Flag indicating whether the user has permission to force cancel the Terraform run.
Terraform.Run.data.attributes.permissions.can-override-policy-check Boolean Flag indicating whether the user has permission to override policy checks.
Terraform.Run.data.attributes.refresh Boolean Flag indicating whether the Terraform run should perform a refresh.
Terraform.Run.data.attributes.refresh-only Boolean Flag indicating whether the Terraform run is for refresh only.
Terraform.Run.data.attributes.replace-addrs Unknown Replacement addresses associated with the Terraform run.
Terraform.Run.data.attributes.save-plan Boolean Flag indicating whether the Terraform run plan should be saved.
Terraform.Run.data.attributes.variables Unknown Variables associated with the Terraform run.
Terraform.Run.data.relationships.apply.data.id String The apply ID of the run.
Terraform.Run.data.relationships.comments String Relationship information for comments associated with the Terraform run.
Terraform.Run.data.relationships.configuration-version String Relationship information for the Terraform configuration version associated with the run.
Terraform.Run.data.relationships.cost-estimate String Relationship information for cost estimates associated with the Terraform run.
Terraform.Run.data.relationships.created-by String Relationship information for the user who created the Terraform run.
Terraform.Run.data.relationships.input-state-version String Relationship information for the input state version associated with the Terraform run.
Terraform.Run.data.relationships.run-events String Relationship information for events associated with the Terraform run.
Terraform.Run.data.relationships.policy-checks String Relationship information for policy checks associated with the Terraform run.
Terraform.Run.data.relationships.workspace String Relationship information for the Terraform workspace associated with the run.
Terraform.Run.data.relationships.workspace-run-alerts String Relationship information for alerts associated with the Terraform workspace run.
Terraform.Run.data.links.self String Link to the Terraform run data.

Command example


#### Context Example

```json
{
    "Terraform": {
        "Run": {
            "data": [
                {
                    "attributes": {
                        "actions": {
                            "is-cancelable": false,
                            "is-confirmable": true,
                            "is-discardable": true,
                            "is-force-cancelable": false
                        },
                        "allow-config-generation": false,
                        "allow-empty-apply": false,
                        "auto-apply": false,
                        "canceled-at": null,
                        "created-at": "2023-12-17T10:23:43.258Z",
                        "has-changes": true,
                        "is-destroy": false,
                        "message": "Triggered via UI",
                        "permissions": {
                            "can-apply": true,
                            "can-cancel": true,
                            "can-comment": true,
                            "can-discard": true,
                            "can-force-cancel": true,
                            "can-force-execute": true,
                            "can-override-policy-check": true
                        },
                        "plan-only": false,
                        "refresh": true,
                        "refresh-only": false,
                        "replace-addrs": [
                            "fakewebservices_load_balancer.primary_lb"
                        ],
                        "save-plan": false,
                        "source": "tfe-ui",
                        "status": "planned",
                        "status-timestamps": {
                            "plan-queueable-at": "2023-12-17T10:23:43+00:00",
                            "plan-queued-at": "2023-12-17T10:23:43+00:00",
                            "planned-at": "2023-12-17T10:23:52+00:00",
                            "planning-at": "2023-12-17T10:23:48+00:00",
                            "queuing-at": "2023-12-17T10:23:43+00:00"
                        },
                        "target-addrs": null,
                        "terraform-version": "1.4.4",
                        "trigger-reason": "manual",
                        "variables": []
                    },
                    "id": "run-8wpCneWr4TLSzfat",
                    "links": {
                        "self": "/api/v2/runs/run-8wpCneWr4TLSzfat"
                    },
                    "relationships": {
                        "apply": {
                            "data": {
                                "id": "apply-uEYtCmrtg5MvjgTr",
                                "type": "applies"
                            },
                            "links": {
                                "related": "/api/v2/runs/run-8wpCneWr4TLSzfat/apply"
                            }
                        },
                        "comments": {
                            "data": [],
                            "links": {
                                "related": "/api/v2/runs/run-8wpCneWr4TLSzfat/comments"
                            }
                        },
                        "configuration-version": {
                            "data": {
                                "id": "cv-YDcZaBNiRbrdy1w1",
                                "type": "configuration-versions"
                            },
                            "links": {
                                "related": "/api/v2/runs/run-8wpCneWr4TLSzfat/configuration-version"
                            }
                        },
                        "created-by": {
                            "data": {
                                "id": "user-LR5kedWrdZXBWF71",
                                "type": "users"
                            },
                            "links": {
                                "related": "/api/v2/runs/run-8wpCneWr4TLSzfat/created-by"
                            }
                        },
                        "plan": {
                            "data": {
                                "id": "plan-T7zpGYFEioRfWEAq",
                                "type": "plans"
                            },
                            "links": {
                                "related": "/api/v2/runs/run-8wpCneWr4TLSzfat/plan"
                            }
                        },
                        "policy-checks": {
                            "data": [],
                            "links": {
                                "related": "/api/v2/runs/run-8wpCneWr4TLSzfat/policy-checks"
                            }
                        },
                        "run-events": {
                            "data": [
                                {
                                    "id": "re-ga2h6eu41RqrmZRn",
                                    "type": "run-events"
                                },
                                {
                                    "id": "re-ciqzHkW3bDooRzcn",
                                    "type": "run-events"
                                },
                                {
                                    "id": "re-ENvbqnmE72YFj7Wq",
                                    "type": "run-events"
                                },
                                {
                                    "id": "re-xkz1fSTKM25GxkMk",
                                    "type": "run-events"
                                }
                            ],
                            "links": {
                                "related": "/api/v2/runs/run-8wpCneWr4TLSzfat/run-events"
                            }
                        },
                        "task-stages": {
                            "data": [],
                            "links": {
                                "related": "/api/v2/runs/run-8wpCneWr4TLSzfat/task-stages"
                            }
                        },
                        "workspace": {
                            "data": {
                                "id": "ws-ZTbNWsfXHRWRVNmE",
                                "type": "workspaces"
                            }
                        }
                    },
                    "type": "runs"
                }
            ],
            "links": {
                "first": "https://app.terraform.io/api/v2/workspaces/ws-ZTbNWsfXHRWRVNmE/runs?page%5Bnumber%5D=1&page%5Bsize%5D=20",
                "last": "https://app.terraform.io/api/v2/workspaces/ws-ZTbNWsfXHRWRVNmE/runs?page%5Bnumber%5D=1&page%5Bsize%5D=20",
                "next": null,
                "prev": null,
                "self": "https://app.terraform.io/api/v2/workspaces/ws-ZTbNWsfXHRWRVNmE/runs?page%5Bnumber%5D=1&page%5Bsize%5D=20"
            },
            "meta": {
                "pagination": {
                    "current-page": 1,
                    "next-page": null,
                    "page-size": 20,
                    "prev-page": null,
                    "total-count": 9,
                    "total-pages": 1
                },
                "status-counts": {
                    "applied": 1,
                    "apply-queued": 0,
                    "applying": 0,
                    "assessed": 0,
                    "assessing": 0,
                    "canceled": 2,
                    "confirmed": 0,
                    "cost-estimated": 0,
                    "cost-estimating": 0,
                    "discarded": 4,
                    "errored": 0,
                    "fetching": 0,
                    "fetching-completed": 0,
                    "pending": 0,
                    "plan-queued": 0,
                    "planned": 1,
                    "planned-and-finished": 4,
                    "planned-and-saved": 0,
                    "planning": 0,
                    "policy-checked": 0,
                    "policy-checking": 0,
                    "policy-override": 0,
                    "policy-soft-failed": 0,
                    "post-apply-completed": 0,
                    "post-apply-running": 0,
                    "post-plan-awaiting-decision": 0,
                    "post-plan-completed": 0,
                    "post-plan-running": 0,
                    "pre-apply-awaiting-decision": 0,
                    "pre-apply-completed": 0,
                    "pre-apply-running": 0,
                    "pre-plan-awaiting-decision": 0,
                    "pre-plan-completed": 0,
                    "pre-plan-running": 0,
                    "queuing": 0,
                    "queuing-apply": 0,
                    "total": 12
                }
            }
        }
    }
}

Human Readable Output

Terraform Runs

Plan id Planned at Run id Status
plan-T7zpGYFEioRfWEAq 2023-12-17T10:23:52+00:00 run-8wpCneWr4TLSzfat planned
plan-1JUTBdedobs1Absf 2023-12-11T11:35:35+00:00 run-kMNQfAmoDr1k8eaT discarded
plan-21bfTFiDJ6Rz1VTZ   run-jb2j5r3gBievUPfR canceled
plan-twBdAcLwiGwuE7kt 2023-12-11T11:29:38+00:00 run-g7ihSa71hCV9yZt7 discarded
plan-JEgrv5aBeNUDDRaA 2023-12-11T11:12:04+00:00 run-yCYvcx1ZEmmKGXnB discarded
plan-kJLmtoaywxkXM54P 2023-12-11T09:11:48+00:00 run-akCRvcJ6L5cQtAhc discarded
plan-ZunKDF28KpCyiZAn 2023-12-10T07:10:08+00:00 run-rpSjBkbhiKAfMuwX planned_and_finished
plan-V4fvpvCzGQrsZikD 2023-11-30T09:21:42+00:00 run-Q2kS54r6pJjdyYfk planned_and_finished
plan-ZYYZD69ESo16jENX 2023-10-25T10:33:11+00:00 run-wBdFQ6egn91GGRne applied

terraform-run-action


Perform an action on a Terraform run. The available actions are: apply, cancel, discard, force-cancel, force-execute.

Base Command

terraform-run-action

Permissions

This command requires a User or Team token that has admin level access to the workspace. Refer to HashiCorp Terraform API Token Access Levels.

Input

Argument Name Description Required
run_id The Terraform run ID to execute the action on. Required
action The action to execute on the Terraform run. Possible values are: apply, cancel, discard, force-cancel, force-execute. Required
comment An optional comment to associate with the action. Not available for the action “force-execute”. Optional

Context Output

There is no context output for this command.

Command example

!terraform-run-action run_id=run-8wpCneWr4TLSzfat action="discard" comment="test comment"

Human Readable Output

Successfully queued an discard request for run id run-8wpCneWr4TLSzfat

terraform-plan-get


Get the plan JSON file or the plan meta data.

Base Command

terraform-plan-get

Permissions

This command requires a User or Team token that has admin level access to the workspace. Refer to HashiCorp Terraform API Token Access Levels.

Input

Argument Name Description Required
plan_id The ID of the Terraform plan to retrieve. Required
json_output Whether to return the plan as a JSON fileResult. Possible values are: true, false. Default is false. Optional

Context Output

Path Type Description
Terraform.Plan.id String The plan ID.
Terraform.Plan.attributes.status String The plan status.
Terraform.Plan.type String Type of the Terraform plan data.
Terraform.Plan.attributes.has-changes Boolean Flag indicating whether the Terraform plan has changes.
Terraform.Plan.attributes.status-timestamps.started-at Date Timestamp indicating when the Terraform plan started.
Terraform.Plan.attributes.status-timestamps.finished-at Date Timestamp indicating when the Terraform plan finished.
Terraform.Plan.attributes.status-timestamps.agent-queued-at Date Timestamp indicating when the Terraform plan was queued for an agent.
Terraform.Plan.attributes.log-read-url String URL for reading the Terraform plan log.
Terraform.Plan.attributes.resource-additions Number Number of resource additions in the Terraform plan.
Terraform.Plan.attributes.resource-changes Number Number of resource changes in the Terraform plan.
Terraform.Plan.attributes.resource-destructions Number Number of resource destructions in the Terraform plan.
Terraform.Plan.attributes.resource-imports Number Number of resource imports in the Terraform plan.
Terraform.Plan.attributes.structured-run-output-enabled Boolean Flag indicating whether structured run output is enabled in the Terraform plan.
Terraform.Plan.attributes.generated-configuration Boolean Flag indicating whether the Terraform plan has generated configuration.
Terraform.Plan.attributes.actions.is-exportable Boolean Flag indicating whether the Terraform plan is exportable.
Terraform.Plan.attributes.execution-details.mode String Execution mode details for the Terraform plan.
Terraform.Plan.attributes.permissions.can-export Boolean Flag indicating whether the user has permission to export the Terraform plan.
Terraform.Plan.relationships.state-versions.data Unknown Relationship information for state versions associated with the Terraform plan.
Terraform.Plan.relationships.exports.data Unknown Relationship information for exports associated with the Terraform plan.
Terraform.Plan.links.self String Link to the Terraform plan data.
Terraform.Plan.links.json-output String Link to the JSON output of the Terraform plan.
Terraform.Plan.links.json-output-redacted String Link to the redacted JSON output of the Terraform plan.
Terraform.Plan.links.json-schema String Link to the JSON schema of the Terraform plan.

Command example

!terraform-plan-get plan_id=plan-V4fvpvCzGQrsZikD

Context Example

{
    "Terraform": {
        "Plan": {
            "attributes": {
                "actions": {
                    "is-exportable": true
                },
                "execution-details": {
                    "mode": "remote"
                },
                "generated-configuration": false,
                "has-changes": false,
                "log-read-url": "url",
                "permissions": {
                    "can-export": true
                },
                "resource-additions": 0,
                "resource-changes": 0,
                "resource-destructions": 0,
                "resource-imports": 0,
                "status": "finished",
                "status-timestamps": {
                    "agent-queued-at": "2023-11-30T09:21:33+00:00",
                    "finished-at": "2023-11-30T09:21:41+00:00",
                    "started-at": "2023-11-30T09:21:37+00:00"
                },
                "structured-run-output-enabled": true
            },
            "id": "plan-V4fvpvCzGQrsZikD",
            "links": {
                "json-output": "/api/v2/plans/plan-V4fvpvCzGQrsZikD/json-output",
                "json-output-redacted": "/api/v2/plans/plan-V4fvpvCzGQrsZikD/json-output-redacted",
                "json-schema": "/api/v2/plans/plan-V4fvpvCzGQrsZikD/json-schema",
                "self": "/api/v2/plans/plan-V4fvpvCzGQrsZikD"
            },
            "relationships": {
                "exports": {
                    "data": []
                },
                "state-versions": {
                    "data": []
                }
            },
            "type": "plans"
        }
    }
}

Human Readable Output

Terraform Plan

Agent Queued at Plan id Status
2023-11-30T09:21:33+00:00 plan-V4fvpvCzGQrsZikD finished

Command example

!terraform-plan-get plan_id=plan-V4fvpvCzGQrsZikD json_output="true"

Context Example

{
    "InfoFile": {
        "EntryID": "375@03d8b507-a516-4959-8133-979b2d80a807",
        "Extension": "json",
        "Info": "application/json",
        "Name": "plan-V4fvpvCzGQrsZikD.json",
        "Size": 3686,
        "Type": "JSON data"
    }
}

Human Readable Output

terraform-policies-list


List the policies for an organization or get a specific policy.

Base Command

terraform-policies-list

Permissions

This command requires a User or Team token that has admin level access to the workspace. Refer to HashiCorp Terraform API Token Access Levels.

Input

Argument Name Description Required
organization_name The name of the organization. Optional
policy_kind If specified, restricts results to those with the matching policy kind value. Possible values are: sentinel, opa. Optional
policy_name If specified, search the organization’s policies by name. Optional
policy_id If specified, get the specific policy. Optional

Context Output

Path Type Description
Terraform.Policy.id String The policy ID.
Terraform.Policy.type String The policy type.
Terraform.Policy.attributes.name String Name of the Terraform policy.
Terraform.Policy.attributes.description Unknown Description of the Terraform policy.
Terraform.Policy.attributes.enforce.path String Path for enforcing the Terraform policy.
Terraform.Policy.attributes.enforce.mode String Enforcement mode for the Terraform policy.
Terraform.Policy.attributes.policy-set-count Number Count of policy sets associated with the Terraform policy.
Terraform.Policy.attributes.updated-at Date Timestamp indicating when the Terraform policy was last updated.
Terraform.Policy.attributes.kind String Kind of the Terraform policy.
Terraform.Policy.attributes.enforcement-level String Enforcement level for the Terraform policy.
Terraform.Policy.relationships.organization.data.id String Unique identifier for the organization associated with the Terraform policy.
Terraform.Policy.relationships.organization.data.type String Type of the organization associated with the Terraform policy.
Terraform.Policy.relationships.policy-sets.data.id String The IDs of the policy sets that contain this policy.
Terraform.Policy.relationships.policy-sets.data.type String Type of the policy sets associated with the Terraform policy.
Terraform.Policy.links.self String Link to the Terraform policy data.
Terraform.Policy.links.upload String Link for uploading the Terraform policy.
Terraform.Policy.links.download String Link for downloading the Terraform policy.
Terraform.Policy.links.self String Link to the Terraform policy.
Terraform.Policy.links.first String Link to the first page of Terraform policies.
Terraform.Policy.links.prev Unknown Link to the previous page of Terraform policies.
Terraform.Policy.links.next Unknown Link to the next page of Terraform policies.
Terraform.Policy.links.last String Link to the last page of Terraform policies.
Terraform.Policy.meta.pagination.current-page Number Current page number in the pagination of Terraform policies.
Terraform.Policy.meta.pagination.page-size Number Number of policies displayed per page in pagination.
Terraform.Policy.meta.pagination.prev-page Unknown Previous page number in the pagination of Terraform policies.
Terraform.Policy.meta.pagination.next-page Unknown Next page number in the pagination of Terraform policies.
Terraform.Policy.meta.pagination.total-pages Number Total number of pages in the pagination of Terraform policies.
Terraform.Policy.meta.pagination.total-count Number Total count of Terraform policies.

Command example


#### Context Example

```json
{
    "Terraform": {
        "Policy": {
            "attributes": {
                "description": null,
                "enforce": [
                    {
                        "mode": "hard-mandatory",
                        "path": "nat-policies.sentinel"
                    }
                ],
                "enforcement-level": "hard-mandatory",
                "kind": "sentinel",
                "name": "nat-policies",
                "policy-set-count": 1,
                "updated-at": "2023-11-14T18:12:36.702Z"
            },
            "id": "pol-ycCqXorxsFjaH5aK",
            "links": {
                "download": "/api/v2/policies/pol-ycCqXorxsFjaH5aK/download",
                "self": "/api/v2/policies/pol-ycCqXorxsFjaH5aK",
                "upload": "/api/v2/policies/pol-ycCqXorxsFjaH5aK/upload"
            },
            "relationships": {
                "organization": {
                    "data": {
                        "id": "example-org-40dc3b",
                        "type": "organizations"
                    }
                },
                "policy-sets": {
                    "data": [
                        {
                            "id": "polset-hc2bvqDW8YRgHEt8",
                            "type": "policy-sets"
                        }
                    ]
                }
            },
            "type": "policies"
        }
    }
}

Human Readable Output

Terraform Policies

Kind Organization id Policy Set ids Policy id Policy name
sentinel example-org-40dc3b polset-hc2bvqDW8YRgHEt8 pol-ycCqXorxsFjaH5aK nat-policies

terraform-policy-set-list


List the policy sets for an organization or get a specific policy set.

Base Command

terraform-policy-set-list

Permissions

This command requires a User or Team token that has admin level access to the workspace. Refer to HashiCorp Terraform API Token Access Levels.

Input

Argument Name Description Required
organization_name The name of the organization. Optional
policy_set_id If specified, get the specific policy set. Optional
versioned Allows filtering policy sets based on whether they are versioned, or use individual policy relationships. A true value returns versioned sets, and a false value returns sets with individual policy relationships. If omitted, all policy sets are returned. Possible values are: true, false. Optional
policy_set_kind If specified, restricts results to those with the matching policy kind value. Possible values are: sentinel, opa. Optional
include Enables you to include related resource data. Value must be a comma-separated list containing one or more projects, workspaces, workspace-exclusions, policies, newest_version, or current_version. Optional
policy_set_name Allows searching the organization’s policy sets by name. Optional
page_number The page number of the results to return. Default is 1. Optional
page_size The number of results to return per page. Default is 20, maximum is 100. Optional

Context Output

Path Type Description
Terraform.PolicySet.id String The policy set ID.
Terraform.PolicySet.type String The policy set type.
Terraform.PolicySet.attributes.name String Name of the Terraform policy set.
Terraform.PolicySet.attributes.description Unknown Description of the Terraform policy set.
Terraform.PolicySet.attributes.global Boolean Flag indicating whether the Terraform policy set is global.
Terraform.PolicySet.attributes.workspace-count Number Number of workspaces associated with the Terraform policy set.
Terraform.PolicySet.attributes.project-count Number Number of projects associated with the Terraform policy set.
Terraform.PolicySet.attributes.created-at Date Timestamp indicating when the Terraform policy set was created.
Terraform.PolicySet.attributes.updated-at Date Timestamp indicating when the Terraform policy set was last updated.
Terraform.PolicySet.attributes.kind String Kind of the Terraform policy set.
Terraform.PolicySet.attributes.agent-enabled Boolean Flag indicating whether the Terraform policy set has agents enabled.
Terraform.PolicySet.attributes.policy-count Number Number of policies associated with the Terraform policy set.
Terraform.PolicySet.attributes.versioned Boolean Flag indicating whether the Terraform policy set is versioned.
Terraform.PolicySet.relationships.organization.data.id String ID of the organization associated with the Terraform policy set.
Terraform.PolicySet.relationships.organization.data.type String Type of the organization associated with the Terraform policy set.
Terraform.PolicySet.relationships.policies.data.id String ID of the policies associated with the Terraform policy set.
Terraform.PolicySet.relationships.policies.data.type String Type of the policies associated with the Terraform policy set.
Terraform.PolicySet.relationships.workspaces.data.id String ID of the workspaces associated with the Terraform policy set.
Terraform.PolicySet.relationships.workspaces.data.type String Type of the workspaces associated with the Terraform policy set.
Terraform.PolicySet.relationships.projects.data.id String Relationship information for projects associated with the Terraform policy set.
Terraform.PolicySet.relationships.workspace-exclusions.data Unknown Relationship information for workspace exclusions associated with the Terraform policy set.
Terraform.PolicySet.links.self String Link to the Terraform policy set data.
Terraform.PolicySet.links.self String Link to the Terraform policy set.
Terraform.PolicySet.links.first String Link to the first page of Terraform policy sets.
Terraform.PolicySet.links.prev Unknown Link to the previous page of Terraform policy sets.
Terraform.PolicySet.links.next Unknown Link to the next page of Terraform policy sets.
Terraform.PolicySet.links.last String Link to the last page of Terraform policy sets.
Terraform.PolicySet.meta.pagination.current-page Number Current page number in the pagination of Terraform policy sets.
Terraform.PolicySet.meta.pagination.page-size Number Number of items per page in the pagination of Terraform policy sets.
Terraform.PolicySet.meta.pagination.prev-page Unknown Link to the previous page in the pagination of Terraform policy sets.
Terraform.PolicySet.meta.pagination.next-page Unknown Link to the next page in the pagination of Terraform policy sets.
Terraform.PolicySet.meta.pagination.total-pages Number Total number of pages in the pagination of Terraform policy sets.
Terraform.PolicySet.meta.pagination.total-count Number Total number of Terraform policy sets.

Command example


#### Context Example

```json
{
    "Terraform": {
        "PolicySet": {
            "attributes": {
                "agent-enabled": false,
                "created-at": "2023-11-08T11:25:06.196Z",
                "description": null,
                "global": false,
                "kind": "sentinel",
                "name": "test-policy-set",
                "policy-count": 1,
                "project-count": 0,
                "updated-at": "2023-11-08T11:25:06.196Z",
                "versioned": false,
                "workspace-count": 1
            },
            "id": "polset-hc2bvqDW8YRgHEt8",
            "links": {
                "self": "/api/v2/policy-sets/polset-hc2bvqDW8YRgHEt8"
            },
            "relationships": {
                "organization": {
                    "data": {
                        "id": "example-org-40dc3b",
                        "type": "organizations"
                    }
                },
                "policies": {
                    "data": [
                        {
                            "id": "pol-ycCqXorxsFjaH5aK",
                            "type": "policies"
                        }
                    ]
                },
                "projects": {
                    "data": []
                },
                "workspace-exclusions": {
                    "data": []
                },
                "workspaces": {
                    "data": [
                        {
                            "id": "ws-u7kVixWpJYWiERMG",
                            "type": "workspaces"
                        }
                    ]
                }
            },
            "type": "policy-sets"
        }
    }
}

Human Readable Output

Terraform Policy Sets

Organization Policies ids Policy Set name Policy set id Workspaces
example-org-40dc3b pol-ycCqXorxsFjaH5aK test-policy-set polset-hc2bvqDW8YRgHEt8 ws-u7kVixWpJYWiERMG

terraform-policies-checks-list


List the policy checks for a Terraform run.

Base Command

terraform-policies-checks-list

Permissions

This command requires a User or Team token that has admin level access to the workspace. Refer to HashiCorp Terraform API Token Access Levels.

Input

Argument Name Description Required
run_id The run ID to list results for. Optional
policy_check_id The policy check ID to retrieve details for. Optional
page_number The page number of the results to return. Default is 1. Optional
page_size The number of results to return per page. Default is 20, maximum is 100. Optional

Context Output

Path Type Description
Terraform.PolicyCheck.id String The policy check ID.
Terraform.PolicyCheck.type String Type of the Terraform policy check data.
Terraform.PolicyCheck.attributes.result.result Boolean Overall result of the Terraform policy check.
Terraform.PolicyCheck.attributes.result.passed Number Number of policy checks that passed.
Terraform.PolicyCheck.attributes.result.total-failed Number Total number of policy checks that failed.
Terraform.PolicyCheck.attributes.result.hard-failed Number Number of policy checks that resulted in hard failures.
Terraform.PolicyCheck.attributes.result.soft-failed Number Number of policy checks that resulted in soft failures.
Terraform.PolicyCheck.attributes.result.advisory-failed Number Number of policy checks that resulted in advisory failures.
Terraform.PolicyCheck.attributes.result.duration-ms Number Duration of the policy check execution in milliseconds.
Terraform.PolicyCheck.attributes.result.sentinel Unknown Sentinel-specific result of the policy check.
Terraform.PolicyCheck.attributes.scope String Scope or context of the Terraform policy check.
Terraform.PolicyCheck.attributes.status String Status of the Terraform policy check.
Terraform.PolicyCheck.attributes.status-timestamps.queued-at Date Timestamp indicating when the Terraform policy check was queued.
Terraform.PolicyCheck.attributes.status-timestamps.soft-failed-at Date Timestamp indicating when the Terraform policy check encountered a soft failure.
Terraform.PolicyCheck.attributes.actions.is-overridable Boolean Flag indicating whether the Terraform policy check is overridable.
Terraform.PolicyCheck.attributes.permissions.can-override Boolean Flag indicating whether the user has permission to override the Terraform policy check.
Terraform.PolicyCheck.relationships.run.data.id String Unique identifier for the Terraform run associated with the policy check.
Terraform.PolicyCheck.relationships.run.data.type String Type of the Terraform run associated with the policy check.
Terraform.PolicyCheck.links.output String Link to the output of the Terraform policy check.

Command example

!terraform-policies-checks-list run_id=run-8wpCneWr4TLSzfat

Human Readable Output

Terraform Policy Checks

No entries.

terraform-get-events


Retrieves Terraform audit trail events. This command is supported in Cortex XSIAM only and is intended for development and debugging purposes, as it may produce duplicate events.

Base Command

terraform-get-events

Permissions

This command requires the audit-logging feature entitlement for the organization as well as an Audit trail or Organization token. Refer to HashiCorp Terraform API Token Access Levels.

Input

Argument Name Description Required
from_date The start date for the audit trails as a relative time expression (e.g., ‘3 days ago’) or an absolute time in ISO 8601 format (e.g., ‘2025-09-01T00:00:00Z’). Default is 1 hour ago. Optional
limit The maximum number of events to retrieve. Default is 10. Optional
should_push_events If true, the command will push the events to the Cortex XSIAM dataset; otherwise, it will only display them. Default is false. Optional

Context Output

There is no context output for this command.

Command example

!terraform-get-events limit=2

Human Readable Output

Terraform Audit Trail Events

timestamp id version type auth request
2025-09-21T11:24:26.541Z ae66e491-aaaa-457c-8445-9c908ee726aa 0 Resource {“accessor_id”: “user-xxxxxxxxxxxx”, “description”: “example-userA”} {“id”: “4df584d4-7e2a-aaaa-6cc0-4adbefa020e6”}
2025-09-21T11:24:26.541Z ae66e491-bbbb-457c-8445-9c908ee726bb 0 Resource {“accessor_id”: “user-yyyyyyyyyyyy”, “description”: “example-userB”} {“id”: “4df584d4-7e2a-bbbb-6cc0-4adbefa020e6”}

Troubleshooting

  • HTTP 429 (Too many requests) Errors
    • Typically occur when the 30 requests per second API limit is exceeded when paginating over audit trail events.
    • To avoid such errors, reduce the Maximum Number of Audit Events Per Fetch parameter value.
    • For additional information, refer to HashiCorp Terraform API Rate Limits.

<~PLATFORM>

License Requirements

The following configuration parameters require the Cortex XSIAM license:

  • Fetch events

</~PLATFORM>

Configuration parameters

  • server_url — Server URL (required)
  • credentials — (required)
  • default_organization_name — Default Organization Name
  • default_workspace_id — Default Workspace ID
  • insecure — Trust any certificate (not secure)
  • proxy — Use system proxy settings
  • isFetchEvents — Fetch events
  • eventFetchInterval — Events Fetch Interval
  • max_fetch — Maximum Number of Audit Events Per Fetch

Commands (7)

  • terraform-get-events

    Retrieves Terraform audit trail events. This command is supported in Cortex XSIAM only and is intended for development and debugging purposes, as it may produce duplicate events.

  • terraform-plan-get

    Get the plan JSON file or the plan meta data.

  • terraform-policies-checks-list

    List the policy checks for a Terraform run.

  • terraform-policies-list

    List the policies for an organization or get a specific policy.

  • terraform-policy-set-list

    List the policy sets for an organization or get a specific policy set.

  • terraform-run-action

    Perform an action on a Terraform run. The available actions are: apply, cancel, discard, force-cancel, force-execute.

  • terraform-runs-list

    List runs in a workspace.

import re

import pytest
from pytest_mock import MockerFixture
from requests_mock import Mocker as RequestsMocker
from aiohttp import ClientResponseError, RequestInfo
from unittest.mock import AsyncMock
from freezegun import freeze_time
from CommonServerPython import *
from HashiCorpTerraform import (
    Client,
    AsyncClient,
    plan_get_command,
    policies_checks_list_command,
    policies_list_command,
    policy_set_list_command,
    run_action_command,
    runs_list_command,
    DEFAULT_AUDIT_TRAIL_PAGE_SIZE,
)

SERVER_URL = "https://test_url.com"


def util_load_json(path):
    with open(path, encoding="utf-8") as f:
        return json.loads(f.read())


@pytest.fixture()
def client():
    return Client(url=SERVER_URL, token=None, default_organization_name=None, default_workspace_id=None, verify=None, proxy=None)


@pytest.fixture()
def async_client():
    return AsyncClient(base_url=SERVER_URL, token="test_token", verify=False, proxy=False)


def mock_async_session_response(
    response_json: dict | None = None,
    error_status_code: int | None = None,
    error_message: str = "Server error",
) -> AsyncMock | ClientResponseError:
    mock_response = AsyncMock()
    mock_response.json = AsyncMock(return_value=response_json)
    if error_status_code:
        return ClientResponseError(
            status=error_status_code,
            history=(),
            request_info=RequestInfo("", "GET", {}),
            message=error_message,
        )
    else:
        mock_response.raise_for_status = AsyncMock()
        mock_response.status_code = 200
    return AsyncMock(__aenter__=AsyncMock(return_value=mock_response))


def test_runs_list_command(client: Client, requests_mock: RequestsMocker):
    """
    Given:
        - Client object.
    When:
        - run the list runs command.
    Then:
        - validate the results are as expected.
    """
    mock_response = util_load_json("./test_data/runs_list_request.json")["mock_response"]
    requests_mock.get(re.compile(f"{SERVER_URL}.*"), json=mock_response)
    expected_results = util_load_json("./test_data/runs_list_request.json")["expected_results"]

    results = runs_list_command(client=client, args={"workspace_id": "workspace_id"})

    assert results.to_context() == expected_results


def test_run_action_command(client: Client, requests_mock: RequestsMocker):
    """
    Given:
        - Client object.
    When:
        - error occurred when run the run action command.
    Then:
        - validate the exception raised as expected.
    """
    mock_response = util_load_json("./test_data/run_action_request.json")["mock_response"]
    requests_mock.post(re.compile(f"{SERVER_URL}.*"), json=mock_response, status_code=409)

    run_id = "run-ABCABCABCABCABCa"
    with pytest.raises(DemistoException) as err:
        run_action_command(client=client, args={"run_id": run_id, "action": "apply", "comment": "comment"})
    assert f"Error occurred when queued an apply request for run id {run_id}" in str(err)


def test_plan_get_command(client: Client, requests_mock: RequestsMocker):
    """
    Given:
        - Client object.
    When:
        - run the get plan command to get the plan meta data.
    Then:
        - validate the results are as expected.
    """
    args = {"plan_id": "plan-Abcabcabcabcabc4"}

    mock_response = util_load_json("./test_data/plan_get_request.json")["mock_response"]
    expected_results = util_load_json("./test_data/plan_get_request.json")["expected_results"]

    requests_mock.get(re.compile(f"{SERVER_URL}.*"), json=mock_response)
    results = plan_get_command(client=client, args=args)
    assert results.to_context() == expected_results


def test_policies_list_command(client: Client, requests_mock, mocker: MockerFixture):
    """
    Given:
        - Client object.
    When:
        - run the get policies list command.
    Then:
        - validate the results are as expected.
    """
    organization_name = "organization_name"
    args = {"organization_name": organization_name}

    mock_response = util_load_json("./test_data/policies_list_request.json")["mock_response"]
    expected_results = util_load_json("./test_data/policies_list_request.json")["expected_results"]

    requests_mock.get(f"{SERVER_URL}/organizations/{organization_name}/policies", json=mock_response)
    mocker.patch.object(demisto, "dt", side_effect=lambda _, key: key)

    results = policies_list_command(client=client, args=args)
    assert results.to_context() == expected_results


def test_policy_set_list_command(client: Client, requests_mock, mocker: MockerFixture):
    """
    Given:
        - Client object.
    When:
        - run the get policy set list command.
    Then:
        - validate the results are as expected.
    """

    organization_name = "organization_name"
    args = {"organization_name": organization_name}

    mock_response = util_load_json("./test_data/policy_set_list_request.json")["mock_response"]
    expected_results = util_load_json("./test_data/policy_set_list_request.json")["expected_results"]

    requests_mock.get(f"{SERVER_URL}/organizations/{organization_name}/policy-sets", json=mock_response)
    mocker.patch.object(demisto, "dt", side_effect=lambda _, key: key)
    results = policy_set_list_command(client=client, args=args)
    assert results.to_context() == expected_results


def test_policies_checks_list_command(client: Client, requests_mock: RequestsMocker):
    """
    Given:
        - Client object.
    When:
        - run the get policies checks list command.
    Then:
        - validate the results are as expected.
    """
    run_id = "run-abcabcabcabcabc1"
    args = {"run_id": run_id}

    mock_response = util_load_json("./test_data/policies_check_list_request.json")["mock_response"]
    expected_results = util_load_json("./test_data/policies_check_list_request.json")["expected_results"]

    requests_mock.get(f"{SERVER_URL}/runs/{run_id}/policy-checks", json=mock_response)
    results = policies_checks_list_command(client=client, args=args)
    assert results.to_context() == expected_results


def test_test_module_command(client: Client, mocker: MockerFixture):
    """
    Given:
        - Client object with error occurred in test_connection.
    When:
        - run the test module command.
    Then:
        - validate the expected exception.
    """
    import HashiCorpTerraform

    mocker.patch.object(client, "test_connection", side_effect=Exception("Unauthorized"))

    with pytest.raises(DemistoException) as err:
        HashiCorpTerraform.test_module(client)

    assert "Unauthorized: Please be sure you put a valid API Token" in str(err)


@pytest.mark.asyncio
async def test_client_get_audit_trails(async_client: AsyncClient, mocker: MockerFixture):
    """
    Given:
     - An AsyncClient instance.
    When:
     - Calling client.get_audit_trails with a given from_date and page_number.
    Then:
     - Ensure the correct HTTP GET request is made and the correct JSON response is returned.
    """
    from_date = "2025-01-01T00:00:00Z"
    page_number = 1

    mock_response_json = {"data": [{"id": "event-1", "timestamp": "2025-01-01T00:00:00Z"}], "pagination": {"total_pages": 1}}

    mock_responses = [
        mock_async_session_response(error_status_code=429),  # mock rate limit error
        mock_async_session_response(mock_response_json),  # mock successful response
    ]

    async with async_client as _client:
        mocker.patch.object(_client._session, "get", side_effect=mock_responses)
        response_json = await _client.get_audit_trails(from_date=from_date, page_number=page_number)

    assert response_json == mock_response_json
    assert _client._session.get.call_args.kwargs == {
        "url": f"{SERVER_URL}/organization/audit-trail",
        "params": {"since": from_date, "page[number]": str(page_number), "page[size]": str(DEFAULT_AUDIT_TRAIL_PAGE_SIZE)},
        "proxy": None,
    }
    assert _client._session.get.call_count == 2  # First time failed, retry again


@pytest.mark.asyncio
async def test_get_audit_trail_events_pagination_success(async_client: AsyncClient, mocker: MockerFixture):
    """
    Given:
     - A limit that requires fetching two pages of events.
    When:
     - Calling get_audit_trail_events.
    Then:
     - Ensure that three API calls are made and the events are aggregated (one for pagination, two others for events).
    """
    from HashiCorpTerraform import get_audit_trail_events

    page_size = DEFAULT_AUDIT_TRAIL_PAGE_SIZE
    mock_response_jsons = [
        {  # Page 1 (Newest events)
            "data": [{"id": f"event-A{i}", "timestamp": "2025-01-01T00:02:00.000Z"} for i in range(page_size)],
            "pagination": {"current_page": 1, "total_pages": 3},
        },
        {  # Page 2
            "data": [{"id": f"event-B{i}", "timestamp": "2025-01-01T00:01:00.000Z"} for i in range(page_size)],
            "pagination": {"current_page": 2, "total_pages": 3},
        },
        {  # Page 3 (Oldest events)
            "data": [{"id": f"event-C{i}", "timestamp": "2025-01-01T00:00:00.000Z"} for i in range(page_size)],
            "pagination": {"current_page": 3, "total_pages": 3},
        },
    ]

    mock_responses = [
        mock_async_session_response(mock_response_jsons[0]),  # First call to find total pages
        mock_async_session_response(mock_response_jsons[2]),  # Second call to last page (oldest events)
        mock_async_session_response(mock_response_jsons[1]),  # Third call to second to last page (newer events than last page)
    ]

    limit = DEFAULT_AUDIT_TRAIL_PAGE_SIZE + 5
    async with async_client as _client:
        mocker.patch.object(_client._session, "get", side_effect=mock_responses)
        events = await get_audit_trail_events(async_client, from_date="2025-01-01T00:00:00Z", limit=limit)

    assert len(events) == limit
    assert events[0]["timestamp"] < events[-1]["timestamp"]
    assert events[-1]["_time"] == "2025-01-01T00:01:00Z"
    assert _client._session.get.call_count == 3


@pytest.mark.asyncio
async def test_get_audit_trail_events_pagination_error(async_client: AsyncClient, mocker: MockerFixture):
    """
    Given:
     - A limit that requires fetching two pages of events.
    When:
     - Calling get_audit_trail_events.
    Then:
     - Ensure that the correct error message appears if one of the pagination requests fails.
    """
    from HashiCorpTerraform import get_audit_trail_events

    page_size = DEFAULT_AUDIT_TRAIL_PAGE_SIZE
    mock_response_jsons = [
        {  # Page 1 (Newest events)
            "data": [{"id": f"event-A{i}", "timestamp": "2025-01-01T00:02:00.000Z"} for i in range(page_size)],
            "pagination": {"current_page": 1, "total_pages": 3},
        },
        {  # Page 3 (Oldest events)
            "data": [{"id": f"event-C{i}", "timestamp": "2025-01-01T00:00:00.000Z"} for i in range(page_size)],
            "pagination": {"current_page": 3, "total_pages": 3},
        },
    ]

    mock_responses = [
        mock_async_session_response(mock_response_jsons[0]),  # First call successful
        mock_async_session_response(error_status_code=500, error_message="Server error"),  # Second call fails
        mock_async_session_response(mock_response_jsons[1]),  # Third call successful
    ]

    mock_demisto_error = mocker.patch.object(demisto, "error")

    limit = DEFAULT_AUDIT_TRAIL_PAGE_SIZE + 5
    async with async_client as _client:
        mocker.patch.object(_client._session, "get", side_effect=mock_responses)
        with pytest.raises(Exception):
            await get_audit_trail_events(async_client, from_date="2025-01-01T00:00:00Z", limit=limit)

    assert mock_demisto_error.call_count == 1
    assert mock_demisto_error.call_args[0][0] == "Request failed with status 500: Server error"


@freeze_time("2025-01-02T00:00:00Z")
@pytest.mark.asyncio
async def test_get_events_command(async_client: AsyncClient, mocker: MockerFixture):
    """
    Given:
     - An AsyncClient and command arguments.
    When:
     - Calling get_events_command.
    Then:
     - Ensure get_audit_trail_events is called with the correct arguments and returns the correct events.
     - Ensure tableToMarkdown is called with the correct arguments.
    """
    from HashiCorpTerraform import get_events_command

    mock_events = [{"id": "event-1", "timestamp": "2025-01-01T00:00:00Z", "_time": "2025-01-01T00:00:00Z"}]

    mock_get_audit_events = mocker.patch("HashiCorpTerraform.get_audit_trail_events", return_value=mock_events)
    mock_table_to_markdown = mocker.patch("HashiCorpTerraform.tableToMarkdown")

    args = {"limit": "10", "from_date": "1 day ago"}
    events, _ = await get_events_command(async_client, args)

    assert events == mock_events
    assert mock_get_audit_events.call_args[0][1] == "2025-01-01T00:00:00Z"  # One day before frozen time
    assert mock_get_audit_events.call_args[0][2] == 10

    assert mock_table_to_markdown.call_args.kwargs == {"name": "Terraform Audit Trail Events", "t": mock_events}


@pytest.mark.parametrize(
    "raw_response, all_fetched_ids, expected_events_count, expected_all_ids_count",
    [
        pytest.param(
            {
                "data": [
                    {"id": "event-1", "timestamp": "2025-01-01T00:00:00Z"},
                    {"id": "event-2", "timestamp": "2025-01-01T01:00:00Z"},
                ]
            },
            set(),
            2,
            2,
            id="No duplicates",
        ),
        pytest.param(
            {
                "data": [
                    {"id": "event-1", "timestamp": "2025-01-01T00:00:00Z"},
                    {"id": "event-2", "timestamp": "2025-01-01T01:00:00Z"},
                ]
            },
            {"event-1"},
            1,
            2,
            id="With duplicates",
        ),
        pytest.param(
            {"data": []},
            {"event-1"},
            0,
            1,
            id="Empty raw response",
        ),
        pytest.param(
            {"data": [{"id": "event-1", "timestamp": "2025-01-01T00:00:00Z"}]},
            {"event-1"},
            0,
            1,
            id="All duplicates",
        ),
    ],
)
@freeze_time("2025-01-02T00:00:00Z")
def test_deduplicate_and_format_events(
    raw_response: dict[str, Any],
    all_fetched_ids: set[str],
    expected_events_count: int,
    expected_all_ids_count: int,
):
    """
    Given:
     - A raw API response and a set of already fetched event IDs.
    When:
     - Calling deduplicate_and_format_events.
    Then:
     - Ensure that events are correctly deduplicated and formatted.
     - Ensure that the set of fetched IDs is correctly updated.
    """
    from HashiCorpTerraform import deduplicate_and_format_events, DATE_FORMAT

    new_events = deduplicate_and_format_events(raw_response, all_fetched_ids)

    assert len(new_events) == expected_events_count
    assert len(all_fetched_ids) == expected_all_ids_count

    for event in new_events:
        assert event["_time"] == arg_to_datetime(event["timestamp"]).strftime(DATE_FORMAT)


@pytest.mark.parametrize(
    "last_run, max_fetch, mock_events, expected_next_run",
    [
        pytest.param(
            {},
            10,
            [
                {"id": "event-1", "timestamp": "2025-01-01T00:00:00Z"},
                {"id": "event-2", "timestamp": "2025-01-01T01:00:00Z"},
            ],
            {"from_date": "2025-01-01T01:00:00Z", "last_fetched_ids": ["event-2"]},
            id="Initial run",
        ),
        pytest.param(
            {"from_date": "2025-01-01T00:00:00Z", "last_fetched_ids": ["event-1"]},
            5,
            [
                {"id": "event-2", "timestamp": "2025-01-01T01:00:00Z"},
                {"id": "event-3", "timestamp": "2025-01-01T01:00:00Z"},
            ],
            {"from_date": "2025-01-01T01:00:00Z", "last_fetched_ids": ["event-2", "event-3"]},
            id="Subsequent run",
        ),
        pytest.param(
            {"from_date": "2025-01-01T01:00:00Z", "last_fetched_ids": ["event-2"]},
            10,
            [],
            {"from_date": "2025-01-01T01:00:00Z", "last_fetched_ids": ["event-2"]},
            id="No new events",
        ),
    ],
)
@pytest.mark.asyncio
async def test_fetch_events_command(
    async_client: AsyncClient,
    mocker: MockerFixture,
    last_run: dict,
    max_fetch: int,
    mock_events: list,
    expected_next_run: dict,
):
    """
    Given:
     - An AsyncClient, last_run, and max_fetch parameters.
    When:
     - Calling fetch_events_command.
    Then:
     - Ensure that get_audit_trail_events is called with the correct arguments.
     - Ensure that the next_run object and events are returned correctly.
    """
    from HashiCorpTerraform import fetch_events_command, DEFAULT_AUDIT_TRAIL_FROM_DATE, DATE_FORMAT

    get_audit_trail_events_mock = mocker.patch("HashiCorpTerraform.get_audit_trail_events", return_value=mock_events)

    next_run, events = await fetch_events_command(async_client, last_run, max_fetch)

    assert get_audit_trail_events_mock.call_args.kwargs == {
        "client": async_client,
        "from_date": last_run.get("from_date") or DEFAULT_AUDIT_TRAIL_FROM_DATE.strftime(DATE_FORMAT),
        "limit": max_fetch,
        "last_fetched_ids": last_run.get("last_fetched_ids", []),
    }

    assert next_run == expected_next_run
    assert events == mock_events