1 files changed, 0 insertions, 192 deletions

diff --git a/cli/internal/analytics/analytics_test.go b/cli/internal/analytics/analytics_test.go
deleted file mode 100644
index 0715fda..0000000
--- a/cli/internal/analytics/analytics_test.go
+++ /dev/null
@@ -1,192 +0,0 @@
-package analytics
-
-import (
-	"context"
-	"sync"
-	"testing"
-	"time"
-
-	"github.com/hashicorp/go-hclog"
-)
-
-type dummySink struct {
-	events []*Events
-	err    error
-	mu     sync.Mutex
-	ch     chan struct{}
-}
-
-type evt struct {
-	I int
-}
-
-func newDummySink() *dummySink {
-	return &dummySink{
-		events: []*Events{},
-		ch:     make(chan struct{}, 1),
-	}
-}
-
-func (d *dummySink) RecordAnalyticsEvents(events Events) error {
-	d.mu.Lock()
-	defer d.mu.Unlock()
-	// Make a copy in case a test is holding a copy too
-	eventsCopy := make([]*Events, len(d.events))
-	copy(eventsCopy, d.events)
-	d.events = append(eventsCopy, &events)
-	d.ch <- struct{}{}
-	return d.err
-}
-
-func (d *dummySink) Events() []*Events {
-	d.mu.Lock()
-	defer d.mu.Unlock()
-	return d.events
-}
-
-func (d *dummySink) ExpectImmediateMessage(t *testing.T) {
-	select {
-	case <-time.After(150 * time.Millisecond):
-		t.Errorf("expected to not wait out the flush timeout")
-	case <-d.ch:
-	}
-}
-
-func (d *dummySink) ExpectTimeoutThenMessage(t *testing.T) {
-	select {
-	case <-d.ch:
-		t.Errorf("Expected to wait out the flush timeout")
-	case <-time.After(150 * time.Millisecond):
-	}
-	<-d.ch
-}
-
-func Test_batching(t *testing.T) {
-	d := newDummySink()
-	ctx := context.Background()
-	c := NewClient(ctx, d, hclog.Default())
-	for i := 0; i < 2; i++ {
-		c.LogEvent(&evt{i})
-	}
-	found := d.Events()
-	if len(found) != 0 {
-		t.Errorf("got %v events, want 0 due to batching", len(found))
-	}
-	// Should timeout
-	d.ExpectTimeoutThenMessage(t)
-	found = d.Events()
-	if len(found) != 1 {
-		t.Errorf("got %v, want 1 batch to have been flushed", len(found))
-	}
-	payloads := *found[0]
-	if len(payloads) != 2 {
-		t.Errorf("got %v, want 2 payloads to have been flushed", len(payloads))
-	}
-}
-
-func Test_batchingAcrossTwoBatches(t *testing.T) {
-	d := newDummySink()
-	ctx := context.Background()
-	c := NewClient(ctx, d, hclog.Default())
-	for i := 0; i < 12; i++ {
-		c.LogEvent(&evt{i})
-	}
-	// We sent more than the batch size, expect a message immediately
-	d.ExpectImmediateMessage(t)
-	found := d.Events()
-	if len(found) != 1 {
-		t.Errorf("got %v, want 1 batch to have been flushed", len(found))
-	}
-	payloads := *found[0]
-	if len(payloads) != 10 {
-		t.Errorf("got %v, want 10 payloads to have been flushed", len(payloads))
-	}
-	// Should timeout second batch
-	d.ExpectTimeoutThenMessage(t)
-	found = d.Events()
-	if len(found) != 2 {
-		t.Errorf("got %v, want 2 batches to have been flushed", len(found))
-	}
-	payloads = *found[1]
-	if len(payloads) != 2 {
-		t.Errorf("got %v, want 2 payloads to have been flushed", len(payloads))
-	}
-}
-
-func Test_closing(t *testing.T) {
-	d := newDummySink()
-	ctx := context.Background()
-	c := NewClient(ctx, d, hclog.Default())
-	for i := 0; i < 2; i++ {
-		c.LogEvent(&evt{i})
-	}
-	found := d.Events()
-	if len(found) != 0 {
-		t.Errorf("got %v events, want 0 due to batching", len(found))
-	}
-	c.Close()
-	found = d.Events()
-	if len(found) != 1 {
-		t.Errorf("got %v, want 1 batch to have been flushed", len(found))
-	}
-	payloads := *found[0]
-	if len(payloads) != 2 {
-		t.Errorf("got %v, want 2 payloads to have been flushed", len(payloads))
-	}
-}
-
-func Test_closingByContext(t *testing.T) {
-	d := newDummySink()
-	ctx, cancel := context.WithCancel(context.Background())
-	c := NewClient(ctx, d, hclog.Default())
-	for i := 0; i < 2; i++ {
-		c.LogEvent(&evt{i})
-	}
-	found := d.Events()
-	if len(found) != 0 {
-		t.Errorf("got %v events, want 0 due to batching", len(found))
-	}
-	cancel()
-	d.ExpectImmediateMessage(t)
-	found = d.Events()
-	if len(found) != 1 {
-		t.Errorf("got %v, want 1 batch to have been flushed", len(found))
-	}
-	payloads := *found[0]
-	if len(payloads) != 2 {
-		t.Errorf("got %v, want 2 payloads to have been flushed", len(payloads))
-	}
-}
-
-func Test_addSessionId(t *testing.T) {
-	events := []struct {
-		Foo string `mapstructure:"foo"`
-	}{
-		{
-			Foo: "foo1",
-		},
-		{
-			Foo: "foo2",
-		},
-	}
-	arr := make([]interface{}, len(events))
-	for i, event := range events {
-		arr[i] = event
-	}
-	sessionID := "my-uuid"
-	output, err := addSessionID(sessionID, arr)
-	if err != nil {
-		t.Errorf("failed to encode analytics events: %v", err)
-	}
-	if len(output) != 2 {
-		t.Errorf("len output got %v, want 2", len(output))
-	}
-	if output[0]["foo"] != "foo1" {
-		t.Errorf("first event foo got %v, want foo1", output[0]["foo"])
-	}
-	for i, event := range output {
-		if event["sessionId"] != "my-uuid" {
-			t.Errorf("event %v sessionId got %v, want %v", i, event["sessionId"], sessionID)
-		}
-	}
-}