From c19343d02f26bf03042c7cae2405d45ebebdcb89 Mon Sep 17 00:00:00 2001
From: Thomas Gelf <thomas@gelf.net>
Date: Sun, 30 Nov 2014 10:59:27 +0100
Subject: [PATCH] Storage\LegacyStorage: prepare to load processes

---
 library/Bpapp/Storage/LegacyStorage.php | 186 ++++++++++++++++++++++++
 1 file changed, 186 insertions(+)
 create mode 100644 library/Bpapp/Storage/LegacyStorage.php

diff --git a/library/Bpapp/Storage/LegacyStorage.php b/library/Bpapp/Storage/LegacyStorage.php
new file mode 100644
index 0000000..4a9b938
--- /dev/null
+++ b/library/Bpapp/Storage/LegacyStorage.php
@@ -0,0 +1,186 @@
+<?php
+
+namespace Icinga\Module\Bpapp\Storage;
+
+use Icinga\Application\Icinga;
+use Icinga\Data\ConfigObject;
+use Icinga\Module\Bpapp\BusinessProcess;
+use Icinga\Module\Bpapp\BpNode;
+use Icinga\Module\Bpapp\Storage\Storage;
+use DirectoryIterator;
+use Icinga\Exception\SystemPermissionException;
+
+class LegacyStorage extends Storage
+{
+    protected $configDir;
+
+    public function getConfigDir()
+    {
+        if ($this->configDir === null) {
+            $dir = Icinga::app()
+                ->getModuleManager()
+                ->getModule('bpapp')
+                ->getConfigDir();
+            if (! is_dir($dir)) {
+                if (! is_dir(dirname($dir))) {
+                    if (! @mkdir(dirname($dir))) {
+                        throw new SystemPermissionException('Could not create config directory "%s"', dirname($dir));
+                    }
+                }
+                if (! mkdir($dir)) {
+                    throw new SystemPermissionException('Could not create config directory "%s"', $dir);
+                }
+            }
+            $dir = $dir . '/processes';
+            if (! is_dir($dir)) {
+                if (! mkdir($dir)) {
+                    throw new SystemPermissionException('Could not create config directory "%s"', $dir);
+                }
+            }
+            $this->configDir = $dir;
+        }
+        return $this->configDir;
+    }
+
+    /**
+     * @return array
+     */
+    public function listProcesses()
+    {
+        $files = array();
+        foreach (new DirectoryIterator($this->getConfigDir()) as $file) {
+            if($file->isDot()) continue;
+            $filename = $file->getFilename();
+            if (substr($filename, -5) === '.conf') {
+                $name = substr($filename, 0, -5);
+                $files[$name] = $name;
+            }
+        }
+        return $files;
+    }
+
+    /**
+     * @return BusinessProcess
+     */
+    public function loadProcess($name)
+    {
+        // Parse
+        return $this->parse($this->getConfigDir() . '/' . $name . '.conf');
+    }
+
+    /**
+     */
+    public function storeProcess(BusinessProcess $name)
+    {
+    }
+
+
+    protected function parse($file)
+    {
+        $bp = new BusinessProcess();
+        $fh = @fopen($file, 'r');
+        if (! $fh) {
+            throw new \Exception('Could not open ' . $file);
+        }
+
+        $this->parsing_line_number = 0;
+        while ($line = fgets($fh)) {
+            $line = trim($line);
+
+            $this->parsing_line_number++;
+
+            if (empty($line)) {
+                continue;
+            }
+            if ($line[0] === '#') {
+                continue;
+            }
+
+            // TODO: substr?
+            if (preg_match('~^display~', $line)) {
+                list($display, $name, $desc) = preg_split('~\s*;\s*~', substr($line, 8), 3);
+                $node = $bp->getNode($name)->setAlias($desc)->setDisplay($display);
+                if ($display > 0) {
+                    $bp->addRootNode($name);
+                }
+            }
+
+            if (preg_match('~^external_info~', $line)) {
+                list($name, $script) = preg_split('~\s*;\s*~', substr($line, 14), 2);
+                $node = $bp->getNode($name)->setInfoCommand($script);
+            }
+
+            // New feature:
+            // if (preg_match('~^extra_info~', $line)) {
+            //     list($name, $script) = preg_split('~\s*;\s*~', substr($line, 14), 2);
+            //     $node = $this->getNode($name)->setExtraInfo($script);
+            // }
+
+            if (preg_match('~^info_url~', $line)) {
+                list($name, $url) = preg_split('~\s*;\s*~', substr($line, 9), 2);
+                $node = $bp->getNode($name)->setInfoUrl($url);
+            }
+
+            if (strpos($line, '=') === false) {
+                continue;
+            }
+            
+            list($name, $value) = preg_split('~\s*=\s*~', $line, 2);
+
+            if (strpos($name, ';') !== false) {
+                $this->parseError('No semicolon allowed in varname');
+            }
+
+            $op = '&';
+            if (preg_match_all('~([\|\+&])~', $value, $m)) {
+                $op = implode('', $m[1]);
+                for ($i = 1; $i < strlen($op); $i++) {
+                    if ($op[$i] !== $op[$i - 1]) {
+                        $this->parseError('Mixing operators is not allowed');
+                    }
+                }
+            }
+            $op = $op[0];
+            $op_name = $op;
+
+            if ($op === '+') {
+                if (! preg_match('~^(\d+)\s*of:\s*(.+?)$~', $value, $m)) {
+                    $this->parseError('syntax: <var> = <num> of: <var1> + <var2> [+ <varn>]*');
+                }
+                $op_name = $m[1];
+                $value   = $m[2];
+            }
+            $cmps = preg_split('~\s*\\' . $op . '\s*~', $value);
+
+            foreach ($cmps as & $val) {
+                if (strpos($val, ';') !== false) {
+                    list($host, $service) = preg_split('~;~', $val, 2);
+                    $this->all_checks[$val] = 1;
+                    $this->hosts[$host] = 1;
+                }
+            }
+            $node = new BpNode($bp, (object) array(
+                'name'        => $name,
+                'operator'    => $op_name,
+                'child_names' => $cmps
+            ));
+            $bp->addNode($name, $node);
+        }
+
+        fclose($fh);
+        unset($this->parsing_line_number);
+        return $bp;
+    }
+
+    protected function parseError($msg)
+    {
+        throw new Exception(
+            sprintf(
+                'Parse error on %s:%s: %s',
+                $this->filename,
+                $this->parsing_line_number,
+                $msg
+            )
+        );
+    }
+}