Function task

packages/queue/src/tasks/remove-community.ts:16–37

(logger: Logger, payload: { accountId: string })

};

async function task(logger: Logger, payload: { accountId: string }) {
  logger.info(payload);

  const account = await AccountsService.getMoreInfo(payload.accountId);
  const moreInfo = JSON.stringify(account);

  await sendNotification(
    `[INFO] Remove account ${payload.accountId} process started: ${moreInfo}`
  );
  try {
    await cleanUp({ accountId: payload.accountId, logger });
    await sendNotification(
      `[INFO] Remove account ${payload.accountId} process finished: ${moreInfo}`
    );
  } catch (error) {
    await sendNotification(
      `[ERROR] Remove account ${payload.accountId} process failed: ${moreInfo}`
    );
    logger.error({ error });
    throw error;
  }
}

async function cleanUp({
  accountId,