@@ -12,20 +12,17 @@ import (
1212 "encoding/json"
1313 "fmt"
1414 "net/http"
15+ "net/http/httptest"
1516 "net/http/httputil"
1617 "os"
18+ "path"
1719 "path/filepath"
1820 "regexp"
1921 "strings"
2022 "testing"
2123 "text/template"
2224 "time"
2325
24- "github.com/google/uuid"
25- "github.com/hectane/go-acl"
26- "github.com/stretchr/testify/assert"
27- "github.com/stretchr/testify/require"
28-
2926 "github.com/elastic/elastic-agent-libs/kibana"
3027 "github.com/elastic/elastic-agent/pkg/control/v2/client"
3128 atesting "github.com/elastic/elastic-agent/pkg/testing"
@@ -36,6 +33,12 @@ import (
3633 "github.com/elastic/elastic-agent/pkg/testing/tools/fleettools"
3734 "github.com/elastic/elastic-agent/pkg/testing/tools/testcontext"
3835 "github.com/elastic/elastic-transport-go/v8/elastictransport"
36+ "github.com/google/uuid"
37+ "github.com/hectane/go-acl"
38+ "github.com/leehinman/mock-es/api"
39+ "github.com/rcrowley/go-metrics"
40+ "github.com/stretchr/testify/assert"
41+ "github.com/stretchr/testify/require"
3942)
4043
4144func TestLogIngestionFleetManaged (t * testing.T ) {
@@ -236,6 +239,94 @@ func TestRpmLogIngestFleetManaged(t *testing.T) {
236239 })
237240}
238241
242+ var eventLogConfig = `
243+ outputs:
244+ default:
245+ type: elasticsearch
246+ hosts:
247+ - %s
248+ protocol: http
249+ preset: balanced
250+
251+ inputs:
252+ - type: filestream
253+ id: your-input-id
254+ streams:
255+ - id: your-filestream-stream-id
256+ data_stream:
257+ dataset: generic
258+ paths:
259+ - %s
260+
261+ # Disable monitoring so there are less Beats running and less logs being generated.
262+ agent.monitoring:
263+ enabled: false
264+ logs: false
265+ metrics: false
266+ pprof.enabled: false
267+ use_output: default
268+ http: # Needed if you already have an Elastic-Agent running on your machine
269+ enabled: false
270+
271+ # This just reduces the amount of logs.
272+ agent.logging.metrics.enabled: false
273+ `
274+
275+ func TestEventLogFile (t * testing.T ) {
276+ // info := define.Require(t, define.Requirements{
277+ // Group: Default,
278+ // Stack: &define.Stack{},
279+ // Local: true,
280+ // Sudo: false,
281+ // })
282+
283+ ctx , cancel := testcontext .WithDeadline (t , context .Background (), time .Now ().Add (10 * time .Minute ))
284+ defer cancel ()
285+
286+ agentFixture , err := define .NewFixture (t , define .Version ())
287+ require .NoError (t , err )
288+
289+ esURL := startMockES (t )
290+
291+ logFilepath := path .Join (t .TempDir (), t .Name ())
292+ generateLogFile (t , logFilepath , time .Millisecond * 100 , 1 )
293+
294+ cfg := fmt .Sprintf (eventLogConfig , esURL , logFilepath )
295+
296+ // agentFixture.PrepareAgentCommand(ctx, nil)
297+ if err := agentFixture .Prepare (ctx ); err != nil {
298+ t .Fatalf ("cannot prepare Elastic-Agent fixture: %s" , err )
299+ }
300+ // if err := agentFixture.Configure(ctx, []byte(cfg)); err != nil {
301+ // t.Fatalf("cannot configure Elastic-Agent fixture: %s", err)
302+ // }
303+
304+ if err := agentFixture .Run (ctx , atesting.State {Configure : cfg }); err != nil {
305+ t .Fatalf ("error running Elastic-Agent fixture: %s" , err )
306+ }
307+
308+ for i := 0 ; i < 25 ; i ++ {
309+ t .Log ("sleeping" , i )
310+ time .Sleep (time .Second )
311+ }
312+
313+ cancel ()
314+ t .FailNow ()
315+ }
316+
317+ func startMockES (t * testing.T ) string {
318+ mux := http .NewServeMux ()
319+ registry := metrics .NewRegistry ()
320+ // go metrics.WriteJSON(metrics.DefaultRegistry, 5*time.Second, os.Stdout)
321+ uid := uuid .New ()
322+ mux .Handle ("/" , api .NewAPIHandler (uid , registry , time .Now ().Add (time .Hour ), 0 , 0 , 0 , 100 ))
323+ s := httptest .NewServer (mux )
324+ t .Log (s .URL )
325+ t .Cleanup (s .Close )
326+
327+ return s .URL
328+ }
329+
239330func testMonitoringLogsAreShipped (
240331 t * testing.T ,
241332 ctx context.Context ,
0 commit comments