2 files changed, 40 insertions, 23 deletions

diff --git a/lib/sfIsisImporterLog.class.php b/lib/sfIsisImporterLog.class.php
index 34594a6..2dcd4a3 100644
--- a/lib/sfIsisImporterLog.class.php
+++ b/lib/sfIsisImporterLog.class.php
@@ -27,15 +27,10 @@ class sfIsisImporterLog
    *
    * @param string $loglevel Log level to use
    */
-  public static function getInstance($loglevel = null)
+  public static function getInstance($loglevel = 'info')
   {
     if(self::$instance == null) {
-      self::$instance = new self;
-    }
-
-    if ($loglevel != null)
-    {
-      self::$loglevel = $loglevel;
+      self::$instance = new self($loglevel);
     }
 
     return self::$instance;
@@ -46,10 +41,30 @@ class sfIsisImporterLog
    */
   private function __construct($loglevel = 'info')
   {
+    $this->level($loglevel);
+  }
+
+  /**
+   * Set the log level.
+   *
+   * @param string $loglevel Log level to use
+   */
+  public function level($loglevel)
+  {
     $this->loglevel = $loglevel;
   }
 
   /**
+   * Get the available log levels ordered by verbosity.
+   *
+   * @return array Log levels
+   */
+  public function levels()
+  {
+    return array_flip(array('notice', 'fatal', 'info', 'warn', 'error', 'debug'));
+  }
+
+  /**
    * Log dispatcher.
    *
    * @param string $message Log message
@@ -57,8 +72,8 @@ class sfIsisImporterLog
    */
   public function log($message, $level = 'info')
   {
-    // Available log levels ordered by verbosity.
-    $levels = array_flip(array('fatal', 'info', 'warn', 'error', 'debug'));
+    // Get the available log levels.
+    $levels = $this->levels();
 
     // Log level checking.
     if (array_search($level, $levels) === FALSE)
@@ -85,22 +100,24 @@ class sfIsisImporterLog
   /**
    * Progress notifier.
    *
-   * @param int $n Row number
+   * @param int $entry   Entry number
+   * @param int $entries Total number of entries
    */
-  public function progress($n)
+  public function progress($entry, $entries)
   {
-    $this->processed = $n;
+    $this->processed = $entry;
+    $levels          = $this->levels();
 
     if ($this->section == 'action')
     {
-      $this->caller->output .= "Saved item $n\n";
+      $this->caller->output .= "Saved item $entry\n";
     }
     else
     {
-      // Progress bar is just shown if loglevel is 'fatal'.
-      if ($this->loglevel == 'fatal')
+      // Progress bar is just shown if loglevel is 'fatal' or lower.
+      if ($levels['fatal'] >= $levels[$this->loglevel])
       {
-        $this->caller->progressBar($n, $this->entries);
+        $this->caller->progressBar($entry, $entries);
       }
     }
 
diff --git a/lib/sfIsisImporterManager.class.php b/lib/sfIsisImporterManager.class.php
index 7d5d9b3..d261f67 100644
--- a/lib/sfIsisImporterManager.class.php
+++ b/lib/sfIsisImporterManager.class.php
@@ -41,11 +41,11 @@ class sfIsisImporterManager extends IsisConnector
   /**
    * Progress notifier dispatcher.
    *
-   * @param int $n Row number
+   * @param int $entry Entry number
    */
-  public function progress($n)
+  public function progress($entry)
   {
-    $this->processed = $this->logger->progress($n);
+    $this->processed = $this->logger->progress($entry, $this->entries);
   }
 
   /**
@@ -104,8 +104,8 @@ class sfIsisImporterManager extends IsisConnector
       }
     }
 
-    $this->log("Finished mass import procedure.");
-    $this->log("Total entries processed: $this->processed.");
+    $this->log("Finished mass import procedure.", 'notice');
+    $this->log("Total entries processed: $this->processed.", 'notice');
   }
 
   /**
@@ -133,7 +133,7 @@ class sfIsisImporterManager extends IsisConnector
       if ($importer)
       {
         // Determine base model and max entries.
-        $this->log('Starting mass import procedure for config '. $database .'.');
+        $this->log('Starting mass import procedure for config '. $database .'.', 'notice');
         $base_model    = $importer->format['db']['base_model'];
         $this->entries = ($entries != NULL && $entries <= $importer->entries) ? $entries : $importer->entries;
 
@@ -141,7 +141,7 @@ class sfIsisImporterManager extends IsisConnector
           for ($entry = 1; $entry <= $this->entries; $entry++)
           {
             $importer->addEntry($base_model, $entry);
-            $this->progress($entry);
+            $this->processed = $this->progress($entry);
           }
         }