chore: modernize okta receiver (#181)

* modernize okta receiver

* ignore sdk janitor goroutine

* improve and test polling logic

* Update logs.go

* make tidy

* fix lint

* add how it works section

Author: colelaven

receiver/oktareceiver/README.md

@@ -1,5 +1,5 @@
 # Okta Receiver
-This receiver is capable of collecting logs from an Okta domain.
+This receiver collects system logs from an Okta domain.
 
 ## Minimum Agent Versions
 - Introduced: [v1.59.0](https://github.com/observIQ/bindplane-otel-collector/releases/tag/v1.59.0)
@@ -8,33 +8,26 @@ This receiver is capable of collecting logs from an Okta domain.
 - Logs
 
 ## How It Works
-1. The user configures this receiver in a pipeline.
-2. The user configures a supported component to route telemetry from this receiver.
+1. The receiver polls the Okta [System Log API](https://developer.okta.com/docs/reference/api/system-log/) once per `poll_interval` for events published since the previous poll.
+2. The receiver follows pagination links to retrieve all events within the poll window.
+3. The receiver converts each event to an OpenTelemetry log and sends it to the collector.
+   - Key event fields (such as UUID, event type, outcome, and actor details) are promoted to log attributes, and the Okta domain is set as a resource attribute.
 
 ## Prerequisites
 - An Okta API Token will be needed to authorize the receiver with your Okta Domain.
 
 ## Configuration
-| Field                | Type      | Default          | Required | Description                                                                                                                                                                            |
-|----------------------|-----------|------------------|----------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
-| okta_domain               |  string   |                  | `true`   | The Okta domain the receiver should collect logs from (Do not include "https://"): [Find your Okta Domain](https://developer.okta.com/docs/guides/find-your-domain/main/)                                   |
-| api_token            |  string   |                  | `true`   | An Okta API Token generated from the above Okta domain: [How to Create an Okta API Token](https://support.okta.com/help/s/article/How-to-create-an-API-token?language=en_US)                       |
-| poll_interval        |  string   | 1m               | `false`  | The rate at which this receiver will poll Okta for logs. This value must be in the range [1 second - 24 hours] and must be a string readable by Golang's [time.ParseDuration](https://pkg.go.dev/time#ParseDuration).     |
+| Field                | Type      | Default          | Required | Description                                                                                                                                                                                                           |
+|----------------------|-----------|------------------|----------|-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| okta_domain          |  string   |                  | `true`   | The Okta domain the receiver should collect logs from (Do not include "https://"): [Find your Okta Domain](https://developer.okta.com/docs/guides/find-your-domain/main/)                                             |
+| api_token            |  string   |                  | `true`   | An Okta API Token generated from the above Okta domain: [How to Create an Okta API Token](https://support.okta.com/help/s/article/How-to-create-an-API-token?language=en_US)                                          |
+| poll_interval        |  string   | 1m               | `false`  | The rate at which this receiver will poll Okta for logs. This value must be in the range [1 second - 24 hours] and must be a string readable by Golang's [time.ParseDuration](https://pkg.go.dev/time#ParseDuration). |
 
 ### Example Configuration
 ```yaml
 receivers:
   okta:
     okta_domain: example.okta.com
-    api_token: 11Z-XDEwgRIf4p0-RqbSFoplFh_84EOtC_ka4J7ylx
+    api_token: myAPIToken
     poll_interval: 2m
-exporters:
-  googlecloud:
-    project: my-gcp-project
-
-service:
-  pipelines:
-    logs:
-      receivers: [okta]
-      exporters: [googlecloud]
 ```

receiver/oktareceiver/config.go

@@ -23,11 +23,11 @@ import (
 	"go.opentelemetry.io/collector/config/configopaque"
 )
 
-var (
+const (
 	defaultPollInterval = time.Minute
 
-	// OktaTimeFormat ISO 8601 Format
-	OktaTimeFormat = "2006-01-02T15:04:05Z"
+	// oktaTimeFormat ISO 8601 Format
+	oktaTimeFormat = "2006-01-02T15:04:05Z"
 )
 
 // Config defines the configuration for an Okta receiver

receiver/oktareceiver/factory.go

@@ -4,7 +4,7 @@
 // you may not use this file except in compliance with the License.
 // You may obtain a copy of the License at
 //
-//      Okta://www.apache.org/licenses/LICENSE-2.0
+//      http://www.apache.org/licenses/LICENSE-2.0
 //
 // Unless required by applicable law or agreed to in writing, software
 // distributed under the License is distributed on an "AS IS" BASIS,
@@ -18,6 +18,7 @@ import (
 	"context"
 	"fmt"
 
+	"github.com/okta/okta-sdk-golang/v6/okta"
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/consumer"
 	"go.opentelemetry.io/collector/receiver"
@@ -41,16 +42,22 @@ func createLogsReceiver(
 	consumer consumer.Logs,
 ) (receiver.Logs, error) {
 	cfg := rConf.(*Config)
-	r, err := newOktaLogsReceiver(cfg, params.Logger, consumer)
+
+	oktaCfg, err := okta.NewConfiguration(
+		okta.WithOrgUrl("https://"+cfg.Domain),
+		okta.WithToken(string(cfg.APIToken)),
+		okta.WithCache(false),
+	)
 	if err != nil {
-		return nil, fmt.Errorf("unable to create an Okta log receiver instance: %w", err)
+		return nil, fmt.Errorf("failed to create okta client configuration: %w", err)
 	}
-	return r, nil
+
+	client := okta.NewAPIClient(oktaCfg)
+	return newOktaLogsReceiver(cfg, params.Logger, consumer, client), nil
 }
 
 func createDefaultConfig() component.Config {
-	c := &Config{
+	return &Config{
 		PollInterval: defaultPollInterval,
 	}
-	return c
 }

receiver/oktareceiver/generated_package_test.go

@@ -3,7 +3,7 @@ module github.com/observiq/bindplane-otel-contrib/receiver/oktareceiver
 go 1.25.7
 
 require (
-	github.com/okta/okta-sdk-golang/v2 v2.20.0
+	github.com/okta/okta-sdk-golang/v6 v6.1.6
 	github.com/open-telemetry/opentelemetry-collector-contrib/pkg/golden v0.149.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/pkg/pdatatest v0.149.0
 	github.com/stretchr/testify v1.11.1
@@ -18,27 +18,35 @@ require (
 )
 
 require (
-	github.com/BurntSushi/toml v1.6.0 // indirect
-	github.com/cenkalti/backoff/v4 v4.3.0 // indirect
+	github.com/cenkalti/backoff/v5 v5.0.3 // indirect
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect
-	github.com/go-jose/go-jose/v3 v3.0.5 // indirect
+	github.com/decred/dcrd/dcrec/secp256k1/v4 v4.4.0 // indirect
+	github.com/go-jose/go-jose/v4 v4.1.3 // indirect
 	github.com/go-logr/logr v1.4.3 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/go-viper/mapstructure/v2 v2.5.0 // indirect
 	github.com/gobwas/glob v0.2.3 // indirect
+	github.com/goccy/go-json v0.10.5 // indirect
 	github.com/google/uuid v1.6.0 // indirect
 	github.com/hashicorp/go-version v1.8.0 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
 	github.com/kelseyhightower/envconfig v1.4.0 // indirect
 	github.com/knadh/koanf/maps v0.1.2 // indirect
 	github.com/knadh/koanf/providers/confmap v1.0.0 // indirect
 	github.com/knadh/koanf/v2 v2.3.4 // indirect
+	github.com/lestrrat-go/blackmagic v1.0.4 // indirect
+	github.com/lestrrat-go/httpcc v1.0.1 // indirect
+	github.com/lestrrat-go/httprc/v3 v3.0.1 // indirect
+	github.com/lestrrat-go/jwx/v3 v3.0.12 // indirect
+	github.com/lestrrat-go/option v1.0.1 // indirect
+	github.com/lestrrat-go/option/v2 v2.0.0 // indirect
 	github.com/mitchellh/copystructure v1.2.0 // indirect
 	github.com/mitchellh/reflectwalk v1.0.2 // indirect
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.3-0.20250322232337-35a7c28c31ee // indirect
 	github.com/open-telemetry/opentelemetry-collector-contrib/pkg/pdatautil v0.149.0 // indirect
 	github.com/patrickmn/go-cache v2.1.0+incompatible // indirect
+	github.com/segmentio/asm v1.2.1 // indirect
 	go.opentelemetry.io/auto/sdk v1.2.1 // indirect
 	go.opentelemetry.io/collector/consumer/consumererror v0.149.0 // indirect
 	go.opentelemetry.io/collector/consumer/xconsumer v0.149.0 // indirect
@@ -56,6 +64,7 @@ require (
 	go.uber.org/multierr v1.11.0 // indirect
 	go.yaml.in/yaml/v3 v3.0.4 // indirect
 	golang.org/x/crypto v0.48.0 // indirect
+	golang.org/x/oauth2 v0.34.0 // indirect
 	golang.org/x/sys v0.42.0 // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20260226221140-a57be14db171 // indirect
 	google.golang.org/grpc v1.79.3 // indirect