Function sendBuildLighthouseMessageQueue

src/server/mq/producer.ts:17–28

(
  workspaceId: string,
  websiteId: string,
  reportId: string,
  url: string
)

});

export async function sendBuildLighthouseMessageQueue(
  workspaceId: string,
  websiteId: string,
  reportId: string,
  url: string
) {
  promMQProduceCounter.inc({ type: 'lighthouse' });
  await sock.send([
    'lighthouse',
    JSON.stringify({ workspaceId, websiteId, reportId, url }),
  ]);
}

export async function sendBuildSurveyClassifyMessageQueue(
  options: z.infer<typeof classifySurveyMQSchema>