furnace: Add test fro queue

pkg/furnace/furnace.go

@@ -42,7 +42,6 @@ func (f *Furnace) Build(ctx context.Context, req *api.BuildRequest) (*api.BuildR
 	}, nil
 }
 
-// TODO(prmsrswt): Implement IsQueued.
 func (f *Furnace) IsQueued(ctx context.Context, req *api.IsQueuedRequest) (*api.IsQueuedResponse, error) {
 	return &api.IsQueuedResponse{
 		Status: f.buildQueue.isQueued(Package{Name: req.GetPackage().GetName()}),

pkg/furnace/furnace_test.go

@@ -14,23 +14,20 @@ func TestBuild(t *testing.T) {
 	cases := []struct {
 		name    string
 		req     *api.BuildRequest
-		want    *api.BuildResponse
 		wantErr bool
 	}{
 		{
 			name: "req with single package",
 			req: &api.BuildRequest{
 				Packages: []*api.Package{{Name: "yay"}},
 			},
-			want:    &api.BuildResponse{},
 			wantErr: false,
 		},
 		{
 			name: "req with empty packages array",
 			req: &api.BuildRequest{
 				Packages: []*api.Package{},
 			},
-			want:    &api.BuildResponse{},
 			wantErr: false,
 		},
 		{
@@ -44,7 +41,6 @@ func TestBuild(t *testing.T) {
 					{Name: "godot"},
 				},
 			},
-			want:    &api.BuildResponse{},
 			wantErr: false,
 		},
 	}
@@ -58,7 +54,7 @@ func TestBuild(t *testing.T) {
 				assert.NotNil(t, err, "error should not be nil")
 				assert.Nil(t, res, "response should be nil")
 			} else {
-				assert.Equal(t, res, tc.want)
+				assert.Nil(t, err)
 			}
 		})
 	}

pkg/furnace/queue_test.go

@@ -0,0 +1,73 @@
+package furnace
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+)
+
+var defaultPackages = []Package{{Name: "default"}, {Name: "test"}}
+
+func TestEnqueue(t *testing.T) {
+	cases := []struct {
+		name  string
+		input []Package
+	}{
+		{
+			name:  "enqueueing a few packages",
+			input: []Package{{Name: "yay"}, {Name: "polybar"}, {Name: "timeshift"}, {Name: "godot"}},
+		},
+		{
+			name:  "enqueueing zero packages",
+			input: []Package(nil),
+		},
+	}
+
+	for _, v := range cases {
+		tc := v
+		t.Run(tc.name, func(t *testing.T) {
+			t.Parallel()
+			q := &queue{}
+			q.enqueue(tc.input)
+
+			assert.Equal(t, tc.input, q.items)
+		})
+	}
+}
+
+func TestDequeue(t *testing.T) {
+	q := &queue{
+		items: defaultPackages,
+	}
+
+	for _, v := range defaultPackages {
+		pkg := v
+		t.Run("dequeueing concurrently", func(t *testing.T) {
+			got, ok := q.dequeue()
+			assert.True(t, ok)
+			assert.Equal(t, got, pkg)
+		})
+	}
+	_, ok := q.dequeue()
+	assert.False(t, ok)
+}
+
+func TestDequeueConcurrent(t *testing.T) {
+	q := &queue{
+		items: defaultPackages,
+	}
+
+	t.Run("group", func(t *testing.T) {
+		for i := 0; i < len(defaultPackages); i++ {
+			t.Run("dequeueing concurrently", func(t *testing.T) {
+				t.Parallel()
+				_, ok := q.dequeue()
+				assert.True(t, ok)
+			})
+		}
+	})
+
+	// This should be false as we already dequeued everything before this.
+	_, ok := q.dequeue()
+	assert.False(t, ok)
+}