[o365] Simplification of data fetching logic

[chrisberkhout]

Proposed commit message

[o365] Simplification of data fetching logic Flattens the structure of the CEL program. Simplifications: - Make only one request per evaluation (or none). - Expired items are skipped during fetching rather than filtering them out in multiple places. - The non-canonical header name `NextPageUri` is no longer considered, as it's always normalized by the HTTP client. - Assume that items can be fetched in the order they are listed. - Assume that content items will not be empty. - Update the `last_for` times once based on the listing range, rather than repeatedly (with the same value) for each followed listing link. - Unify handling of generated listing links (for initial requests) and received listing links (for later pages). - Subscribe once per input start (an alternative to once for the life of cursor data, as introduced in #15476). Other changes: - Moves some state into `state.cursor`, so that it persists across restarts: `state.work.todo_content` → `state.cursor.todo_content`, `state.work.next_list` (string) → `state.cursor.todo_links` (array). - Renames `state.work.todo_type` (array) → `state.todo_types` (plural name, array). This stays out of the cursor because it can be reconstructed. - Do all subscriptions first, then rotate types so everything is roughly chronological rather than type-by-type. - Adds `state.subscribed` (map). It's not in the cursor data because we want to resubscribe if restarted. - Keep querying until the time 3 seconds before the start has been reached (exclusive). The 3 second buffer avoids requesting times that may have unstable results. - Log an error if no type is configured. - The `max_executions` limit is raised. Getting up to date means hour-long listings for 168 hours of data, possibly over multiple pages each, likely for multiple content types, and fetching everything that was listed. 

Notes for the reviewer

I started this before the last 4 PRs, and I checked that there are no conflicts with those changes:

• o365: tolerate changed API next page URI behaviour #15325
  We no longer parse the next page URLs, since we have the endTime from the initial request.
• o365: fix handling of error conditions when requesting work continuation #15380
  o365: fix error propagation within cel program #15445
  This error handling logic isn't relevant in the new flattened structure.
• o365: Fix 429 due to multiple subscription start attempts. #15476
  The new code still limits subscription requests, but to a lesser degree, which I think is better overall.

The new CEL code passes with the original system tests.

The system tests have been updated to use a mock o365 server rather than the stream tool. The mock server has configurability, assertions and logging beyond what is used in the system test, which may be useful for future debugging. The amount of code is not insignificant, and the quality is just okay, so if this is a maintenance concern, it can be moved to a separate PR or removed entirely. Let me know what you think.
Introduction of a new mock server has been moved to a separate PR: #16190

Checklist

• I have reviewed tips for building integrations and this pull request is aligned with them.
• I have verified that all data streams collect metrics or logs.
• I have added an entry to my package's changelog.yml file.
• I have verified that Kibana version constraints are current according to guidelines.
• I have verified that any added dashboard complies with Kibana's Dashboard good practices

How to test this PR locally

You can manually run against the new mock server.

Get the o365mock.go file from #16190, then start the mock server like this:

go run o365mock.go chunks_with_gaps_and_1_expired 

In another terminal, run the CEL code in mito like this:

mito \ -cfg <(echo ' auth:  oauth2:  client.id: test-cel-client-id  client.secret: test-cel-client-secret  provider: azure  scopes:  - "https://manage.office.com/.default"  endpoint_params:  grant_type: ["client_credentials"]  token_url: http://localhost:9999/test-cel-tenant-id/oauth2/v2.0/token ') \ -data <(echo ' { "url": "http://localhost:9999", "want_more": false, "base": { "tenant_id": "test-cel-tenant-id", "list_contents_start_time": "15h", "batch_interval": "1h", "maximum_age": "167h55m", "content_types": "Audit.AzureActiveDirectory, Audit.Exchange" } } ') \ -log_requests \ <(awk '/^program:/{iscel=1; next} /^\{\{/{iscel=0} iscel' ./data_stream/audit/agent/stream/cel.yml.hbs)

Stop the mock server with Ctrl+C to trigger it's shutdown report.

You can remove the mito auth configuration if you disable CheckAccessToken in the mock server's inline configuration.

This version of mito will run faster than the following one, which rate limits to 1 rps:

go install github.com/elastic/mito/cmd/mito@835128 

Related issues

• Closes o365: flatten structure, one request per evaluation #15066
• Relates [o365] Use a mock server for system tests #16190

[elasticmachine]

Pinging @elastic/security-service-integrations (Team:Security-Service Integrations)

[efd6]

Because we lean on repeated input loops more now, I think it may be worth doing the dropping of the retry events in the agent with a beat processor, rather than sending the event to be dropped by the ingest pipeline. An example of this is here corresponding to this alternative way of saying {"retry": true}.

[chrisberkhout]

Sure. Done.

[elastic-vault-github-plugin-prod]

🚀 Benchmarks report

To see the full report comment with /test benchmark fullreport

[efd6]

On the basis of a support case, we may want to make this configurable, but defaulting to a higher value like this.

[chrisberkhout]

👍 Done.

[chrisberkhout]

@efd6 I split the mock server part into a separate draft PR.

[elasticmachine]

💚 Build Succeeded

• Buildkite Build
• Commit: 43ccbd7

History

• 💚 Build #34920 succeeded 8df8cae
• 💚 Build #34485 succeeded f2827ac
• 💚 Build #34466 succeeded 12244da
• 💔 Build #34464 failed d0e4387
• 💔 Build #34461 failed 3645b09
• 💔 Build #34432 failed aa3b3f0

cc @chrisberkhout

[elastic-vault-github-plugin-prod]

Package o365 - 3.1.0 containing this change is available at https://epr.elastic.co/package/o365/3.1.0/