test: [#44] some more tests for Queu class

__tests__/unit/queue.test.ts

@@ -7,6 +7,7 @@ import {
 } from '../../src/__tests__/helpers'
 
 import {CommitAuthor} from '../../src/commit-author'
+import {CommitInfo} from '../../src/commit-info'
 import {CommitOptions} from '../../src/commit-options'
 import {Queue} from '../../src/queue'
 import {QueueName} from '../../src/queue-name'
@@ -49,6 +50,12 @@ async function createTestQueue(commitOptions: CommitOptions): Promise<Queue> {
 }
 
 describe('Queue', () => {
+  it('could be empty', async () => {
+    const queue = await createTestQueue(commitOptionsForTests())
+
+    expect(queue.isEmpty()).toBe(true)
+  })
+
   it('should dispatch a new job', async () => {
     const queue = await createTestQueue(commitOptionsForTests())
 
@@ -59,6 +66,20 @@ describe('Queue', () => {
     expect(nextJob.payload()).toBe(dummyPayload())
   })
 
+  it('should fail when trying to create a job if the previous job has not finished yet', async () => {
+    const queue = await createTestQueue(commitOptionsForTests())
+
+    const commit = await queue.createJob(dummyPayload())
+
+    const fn = async (): Promise<CommitInfo> => {
+      return queue.createJob(dummyPayload())
+    }
+
+    const expectedError = `Can't create a new job. There is already a pending job in commit: ${commit.hash}`
+
+    await expect(fn()).rejects.toThrowError(expectedError)
+  })
+
   it('should mark a job as finished', async () => {
     const queue = await createTestQueue(commitOptionsForTests())
 
@@ -70,6 +91,20 @@ describe('Queue', () => {
     expect(nextJob.isNull()).toBe(true)
   })
 
+  it('should fail when trying to finish a job without any pending to finish job', async () => {
+    const queue = await createTestQueue(commitOptionsForTests())
+
+    const fn = async (): Promise<CommitInfo> => {
+      return queue.markJobAsFinished(dummyPayload())
+    }
+
+    const expectedError = `Can't mark job as finished. There isn't any pending job in queue: ${queue
+      .getName()
+      .toString()}`
+
+    await expect(fn()).rejects.toThrowError(expectedError)
+  })
+
   it('should allow to specify the commit author', async () => {
     const queue = await createTestQueue(commitOptionsForTests())
 
@@ -133,4 +168,14 @@ describe('Queue', () => {
 
     await expect(fn()).rejects.toThrowError(expectedError)
   })
+
+  it('should return all the messages in the queue', async () => {
+    const queue = await createTestQueue(commitOptionsForTests())
+
+    await queue.createJob(dummyPayload())
+
+    const messages = queue.getMessages()
+
+    expect(messages).toContain(queue.getLatestMessage())
+  })
 })

src/queue.ts

@@ -111,6 +111,10 @@ export class Queue {
     )
   }
 
+  getName(): QueueName {
+    return this.name
+  }
+
   getGitRepoDir(): GitRepoDir {
     return this.gitRepo.getDir()
   }