1. /**
  2. * Attaches metadata to task queues for staging environments with dry-run mode.
  3. *
  4. * @param {Object} options Configuration options.
  5. * @param {string} options.environment The environment (e.g., 'staging').
  6. * @param {boolean} options.dryRun Whether to perform a dry run (no actual changes).
  7. * @param {Array<string>} options.queueNames An array of queue names to process. If empty processes all.
  8. */
  9. function attachStagingMetadata(options) {
  10. const { environment, dryRun = false, queueNames = [] } = options;
  12. if (environment !== 'staging') {
  13. console.warn(`Skipping metadata attachment for environment: ${environment}. Expected 'staging'.`);
  14. return;
  15. }
  17. // Mock task queue object. Replace with your actual queue implementation.
  18. const taskQueues = {
  19. 'queue1': { name: 'Queue 1', messages: [] },
  20. 'queue2': { name: 'Queue 2', messages: [] },
  21. 'queue3': { name: 'Queue 3', messages: [] }
  22. };
  24. const queuesToProcess = queueNames.length > 0 ? queueNames : Object.keys(taskQueues);
  27. for (const queueName of queuesToProcess) {
  28. const queue = taskQueues[queueName];
  30. if (dryRun) {
  31. console.log(`Dry Run: Would attach staging metadata to queue: ${queueName}`);
  32. } else {
  33. // Attach staging metadata. Replace with your actual logic.
  34. queue.metadata = { environment: environment, staging: true };
  35. console.log(`Attached staging metadata to queue: ${queueName}`);
  37. // Example: Add a test message
  38. queue.messages.push({ data: `Staging test message for ${queueName}` });
  39. }
  40. }
  41. }
  43. // Example Usage:
  44. //attachStagingMetadata({ environment: 'staging' }); // Attach to all queues
  45. //attachStagingMetadata({ environment: 'staging', queueNames: ['queue1', 'queue2'] }); // Attach to specific queues
  46. //attachStagingMetadata({ environment: 'staging', dryRun: true }); // Dry run

Add your comment