[8.12](backport #37591) x-pack/filebeat/input/httpjson: Fix nil pointer deref

CHANGELOG.next.asciidoc

@@ -71,6 +71,7 @@ https://github.com/elastic/beats/compare/v8.8.1\...main[Check the HEAD diff]
 
 *Filebeat*
 
+- Fix nil pointer dereference in the httpjson input {pull}37591[37591]
 - [Gcs Input] - Added missing locks for safe concurrency {pull}34914[34914]
 - Fix the ignore_inactive option being ignored in Filebeat's filestream input {pull}34770[34770]
 - Fix TestMultiEventForEOFRetryHandlerInput unit test of CometD input {pull}34903[34903]

x-pack/filebeat/input/httpjson/request.go

@@ -316,13 +316,8 @@ func newRequestFactory(ctx context.Context, config config, log *logp.Logger, met
 			if err != nil {
 				return nil, fmt.Errorf("failed in creating chain http client with error: %w", err)
 			}
-			if ch.Step.Auth != nil && ch.Step.Auth.Basic.isEnabled() {
-				rf.user = ch.Step.Auth.Basic.User
-				rf.password = ch.Step.Auth.Basic.Password
-			}
 
 			responseProcessor := newChainResponseProcessor(ch, client, xmlDetails, metrics, log)
-
 			rf = &requestFactory{
 				url:                    *ch.Step.Request.URL.URL,
 				method:                 ch.Step.Request.Method,
@@ -336,6 +331,10 @@ func newRequestFactory(ctx context.Context, config config, log *logp.Logger, met
 				chainClient:            client,
 				chainResponseProcessor: responseProcessor,
 			}
+			if ch.Step.Auth != nil && ch.Step.Auth.Basic.isEnabled() {
+				rf.user = ch.Step.Auth.Basic.User
+				rf.password = ch.Step.Auth.Basic.Password
+			}
 		} else if ch.While != nil {
 			ts, _ := newBasicTransformsFromConfig(registeredTransforms, ch.While.Request.Transforms, requestNamespace, log)
 			policy := newHTTPPolicy(evaluateResponse, ch.While.Until, log)
@@ -344,10 +343,6 @@ func newRequestFactory(ctx context.Context, config config, log *logp.Logger, met
 			if err != nil {
 				return nil, fmt.Errorf("failed in creating chain http client with error: %w", err)
 			}
-			if ch.While.Auth != nil && ch.While.Auth.Basic.isEnabled() {
-				rf.user = ch.While.Auth.Basic.User
-				rf.password = ch.While.Auth.Basic.Password
-			}
 
 			responseProcessor := newChainResponseProcessor(ch, client, xmlDetails, metrics, log)
 			rf = &requestFactory{
@@ -364,6 +359,10 @@ func newRequestFactory(ctx context.Context, config config, log *logp.Logger, met
 				chainClient:            client,
 				chainResponseProcessor: responseProcessor,
 			}
+			if ch.While.Auth != nil && ch.While.Auth.Basic.isEnabled() {
+				rf.user = ch.While.Auth.Basic.User
+				rf.password = ch.While.Auth.Basic.Password
+			}
 		}
 		rfs = append(rfs, rf)
 	}

x-pack/filebeat/input/httpjson/request_test.go

@@ -135,6 +135,76 @@ func TestCtxAfterDoRequest(t *testing.T) {
 	)
 }
 
+func Test_newRequestFactory_UsesBasicAuthInChainedRequests(t *testing.T) {
+	ctx := context.Background()
+	log := logp.NewLogger("")
+	cfg := defaultChainConfig()
+
+	url, _ := url.Parse("https://example.com")
+	cfg.Request.URL = &urlConfig{
+		URL: url,
+	}
+
+	enabled := true
+	user := "basicuser"
+	password := "basicuser"
+	cfg.Auth = &authConfig{
+		Basic: &basicAuthConfig{
+			Enabled:  &enabled,
+			User:     user,
+			Password: password,
+		},
+	}
+
+	step := cfg.Chain[0].Step
+	step.Auth = cfg.Auth
+
+	while := cfg.Chain[0].While
+	while.Auth = cfg.Auth
+
+	type args struct {
+		cfg   config
+		step  *stepConfig
+		while *whileConfig
+	}
+	tests := []struct {
+		name string
+		args args
+	}{
+		{
+			name: "Step",
+			args: args{
+				cfg:   cfg,
+				step:  step,
+				while: nil,
+			},
+		},
+		{
+			name: "While",
+			args: args{
+				cfg:   cfg,
+				step:  nil,
+				while: while,
+			},
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+
+			tt.args.cfg.Chain[0].Step = tt.args.step
+			tt.args.cfg.Chain[0].While = tt.args.while
+			requestFactories, err := newRequestFactory(ctx, tt.args.cfg, log, nil, nil)
+			assert.NoError(t, err)
+			assert.NotNil(t, requestFactories)
+			for _, rf := range requestFactories {
+				assert.Equal(t, rf.user, user)
+				assert.Equal(t, rf.password, password)
+			}
+
+		})
+	}
+}
+
 func Test_newChainHTTPClient(t *testing.T) {
 	cfg := defaultChainConfig()
 	cfg.Request.URL = &urlConfig{URL: &url.URL{}}