1. /**
  2. * Extracts task queue values for staging environments with basic sanity checks.
  3. *
  4. * @returns {Promise<object>} An object containing staging environment task queues and their values.
  5. * Returns an empty object if no staging environments are found.
  6. * @throws {Error} If there's an error accessing configuration or processing data.
  7. */
  8. async function getStagingTaskQueues() {
  9. try {
  10. // 1. Fetch configuration data (e.g., environment variables, config file)
  11. const config = await fetchConfig(); // Replace with your config fetching logic
  13. // 2. Filter for staging environments
  14. const stagingEnvironments = config?.environments?.filter(
  15. (env) => env.environment === 'staging'
  16. );
  18. if (!stagingEnvironments || stagingEnvironments.length === 0) {
  19. console.warn('No staging environments configured.');
  20. return {}; // Return empty object if no staging environments are found
  21. }
  23. // 3. Extract task queue values for each staging environment
  24. const stagingTaskQueues = {};
  25. for (const env of stagingEnvironments) {
  26. const taskQueues = env.taskQueues;
  28. if (!taskQueues || !Array.isArray(taskQueues)) {
  29. console.warn(`Invalid task queues for environment ${env.environment}. Skipping.`);
  30. continue;
  31. }
  33. const validatedQueues = taskQueues.map(queue => {
  34. //Basic sanity check: Ensure queue name is a string
  35. if (typeof queue !== 'string') {
  36. console.warn(`Invalid queue name: ${queue} for environment ${env.environment}. Skipping.`);
  37. return null;
  38. }
  39. return queue.trim(); //remove leading/trailing whitespace
  40. }).filter(queue => queue !== null); //filter out invalid queue names
  42. if (validatedQueues.length > 0) {
  43. stagingTaskQueues[env.environment] = validatedQueues;
  44. }
  45. }
  47. return stagingTaskQueues;
  49. } catch (error) {
  50. console.error('Error fetching or processing staging task queues:', error);
  51. throw error; // Re-throw the error for handling upstream
  52. }
  53. }
  56. /**
  57. * Placeholder function to fetch configuration data. Replace with your actual
  58. * configuration loading mechanism (e.g., reading environment variables,
  59. * reading a JSON file, calling an API).
  60. * @returns {Promise<object>} Configuration data.
  61. */
  62. async function fetchConfig() {
  63. // Replace with your actual configuration loading logic.
  64. //Example:
  65. return new Promise((resolve) => {
  66. setTimeout(() => {
  67. resolve({
  68. environments: [
  69. { environment: 'production', taskQueues: ['queue1', 'queue2'] },
  70. { environment: 'staging', taskQueues: ['stagingQueue1', 'stagingQueue2', 123, ' queue3 '] },
  71. { environment: 'development', taskQueues: ['devQueue1'] },
  72. ],
  73. });
  74. }, 50);
  75. });
  76. }
  78. export default getStagingTaskQueues;

Add your comment