1. <?php
  3. /**
  4. * File Buffer for Scheduled Runs
  5. *
  6. * Buffers file inputs for scheduled execution based on a configuration file.
  7. */
  9. class FileBuffer
  10. {
  11. private $config;
  12. private $buffer = [];
  14. public function __construct(array $config)
  15. {
  16. $this->config = $config;
  17. }
  19. /**
  20. * Adds a file path to the buffer.
  21. *
  22. * @param string $filePath The path to the file.
  23. * @return bool True on success, false on failure.
  24. */
  25. public function addFile(string $filePath): bool
  26. {
  27. if (file_exists($filePath) && is_readable($filePath)) {
  28. $this->buffer[] = $filePath;
  29. return true;
  30. }
  31. return false;
  32. }
  34. /**
  35. * Clears the buffer.
  36. */
  37. public function clearBuffer(): void
  38. {
  39. $this->buffer = [];
  40. }
  42. /**
  43. * Gets the buffered file paths.
  44. *
  45. * @return array An array of file paths.
  46. */
  47. public function getBuffer(): array
  48. {
  49. return $this->buffer;
  50. }
  52. /**
  53. * Processes the buffered files.
  54. *
  55. * @return array An array of processed file paths. Returns empty array on error.
  56. */
  57. public function processFiles(): array
  58. {
  59. $processedFiles = [];
  61. if (empty($this->buffer)) {
  62. return $processedFiles; // Return empty array if buffer is empty
  63. }
  65. foreach ($this->buffer as $filePath) {
  66. try {
  67. // Simulate file processing - replace with actual logic
  68. $processedFiles[] = $filePath . " - Processed";
  69. //Example: file_get_contents($filePath);
  70. } catch (Exception $e) {
  71. error_log("Error processing file " . $filePath . ": " . $e->getMessage());
  72. // Optionally, remove the failed file from the buffer.
  73. //unset($this->buffer[array_search($filePath, $this->buffer)]);
  74. }
  75. }
  77. $this->clearBuffer(); // Clear the buffer after processing
  78. return $processedFiles;
  79. }
  80. }
  82. /**
  83. * Configuration File Handling
  84. *
  85. * Reads configuration from a JSON file.
  86. *
  87. * @param string $configFile Path to the configuration file.
  88. * @return array|null An array of configuration settings, or null on error.
  89. */
  90. function getConfig(string $configFile): ?array
  91. {
  92. if (file_exists($configFile)) {
  93. $json = file_get_contents($configFile);
  94. $config = json_decode($json, true);
  96. if (json_last_error() === JSON_ERROR_NONE) {
  97. return $config;
  98. } else {
  99. error_log("Error decoding JSON from " . $configFile . ": " . json_last_error_msg());
  100. return null;
  101. }
  102. } else {
  103. error_log("Configuration file not found: " . $configFile);
  104. return null;
  105. }
  106. }
  110. // Example Usage (assuming config.json exists)
  111. $config = getConfig('config.json');
  113. if ($config) {
  114. $buffer = new FileBuffer($config);
  116. // Simulate adding files
  117. $buffer->addFile('/path/to/file1.txt');
  118. $buffer->addFile('/path/to/file2.csv');
  119. $buffer->addFile('/path/to/nonexistent_file.txt'); //Test error handling
  121. $processedFiles = $buffer->processFiles();
  123. print_r($processedFiles); //Output the processed file paths.
  124. } else {
  125. echo "Failed to load configuration. Exiting.\n";
  126. }
  129. ?>

Add your comment