Add API that monitors queue status

[MrOrz]

Related: TODO items in broken group chat https://g0v.hackmd.io/bhL6csQ8T1e81E2De7ZS5Q#%E7%BE%A4%E7%B5%84%E5%8A%9F%E8%83%BD%E5%A3%9E%E6%8E%89-update

1. Fixes "Missing process handler for job type __default__" when JOBQUEUE_CONCURRENCY is set #260
2. Moves queue instance to src/lib/queues.js so that it can be shared across webhook & GraphQL resolvers
3. Add queue open API that returns queue stats for monitor
   • Dunno know how to test "completed" queue QQ
   • Just added test case for "waiting"

Deployed to staging:

[MrOrz]

On localhost, src/graphql/__tests__/queue.js runs first, and src/webhook/__tests__/index.js silently fails with the following error:

    console.error src/webhook/handlers/groupHandler.js:107
      TypeError: Cannot read properties of undefined (reading 'timestamp')
          at _default.processJob (/Users/johnsonliang/workspace/rumors-line-bot/src/webhook/handlers/groupHandler.js:53:47)
          at processTicksAndRejections (node:internal/process/task_queues:96:5)

In groupHandler:53, it is trying to read job.data.otherFields.timestamp. However, job.data is actually { foo: 'bar' }, the
fixture inserted in returns waiting job info.

On github actions, src/webhook/__tests__/index.js runs first without this error, and there is open handles left after test.

[MrOrz]

If src/webhook/__tests__/index.js happened to run before src/graphql/__tests__/queue.js on localhost, there will be snapshot error:

  ● returns waiting job info

    expect(received).toMatchInlineSnapshot(snapshot)

    Snapshot name: `returns waiting job info 1`

    - Snapshot
    + Received

      Object {
        "data": Object {
          "queue": Array [
            Object {
              "jobCounts": Object {
    -           "waiting": 1,
    +           "waiting": 0,
              },
    -         "lastWaitingAt": 1989-06-04T00:00:00.000Z,
    +         "lastWaitingAt": null,
              "queueName": "groupEventQueue",
            },
            Object {
              "jobCounts": Object {
    -           "waiting": 1,
    +           "waiting": 0,
              },
    -         "lastWaitingAt": 1989-06-04T00:00:00.000Z,
    +         "lastWaitingAt": null,
              "queueName": "expiredGroupEventQueue",
            },
          ],
        },
      }

      88 |   MockDate.reset();
      89 |
    > 90 |   expect(resultQueued).toMatchInlineSnapshot(`
         |                        ^
      91 |     Object {
      92 |       "data": Object {
      93 |         "queue": Array [

      at Object.<anonymous> (src/graphql/__tests__/queue.js:90:24)
      at processTicksAndRejections (node:internal/process/task_queues:96:5)

Seems that the processor attached in src/webhook/__tests__/index kicks in.

[coveralls]

Pull Request Test Coverage Report for Build 1883147809

• 13 of 14 (92.86%) changed or added relevant lines in 5 files are covered.
• No unchanged relevant lines lost coverage.
• Overall coverage increased (+0.03%) to 87.365%

---

Changes Missing Coverage	Covered Lines	Changed/Added Lines	%
src/graphql/resolvers/QueueInfo.js	8	9	88.89%

Totals
Change from base Build 1337615961:	0.03%
Covered Lines:	980
Relevant Lines:	1107

---

💛 - Coveralls

[nonumpa]

LGTM!