fluxRSS/DAL/FluxGateway.php

@@ -2,6 +2,7 @@
 
 namespace DAL;
 
+use metier\Flux;
 use PDO;
 
 class FluxGateway

fluxRSS/composer.json

@@ -1,7 +1,8 @@
 {
   "require": {
     "twig/twig": "^3.0",
-    "ext-pdo": "*"
+    "ext-pdo": "*",
+    "ext-dom": "*"
   },
   "autoload": {
     "psr-4": {

fluxRSS/controleur/Controleur.php

@@ -37,9 +37,10 @@ class Controleur
             }
         } catch (\PDOException $e) {
             //si erreur BD, pas le cas ici
-            $dVueEreur[] = 'Erreur inattendue!!! ';
+            $dVueEreur[] = 'Erreur PDO : ' . $e->getMessage();
+            echo $twig->render('erreur.html', ['dVueEreur' => $dVueEreur]);
         } catch (\Exception $e2) {
-            $dVueEreur[] = 'Erreur inattendue!!! ';
+            $dVueEreur[] = 'Erreur : ' . $e2->getMessage();
             echo $twig->render('erreur.html', ['dVueEreur' => $dVueEreur]);
         }
 
@@ -69,9 +70,11 @@ class Controleur
         $age = $_POST['txtAge'];
         \config\Validation::val_form($nom, $age, $dVueEreur);
 
+        /*
         $model = new \metier\Simplemodel();
         $data  = $model->get_data();
-
+        */
+        
         $dVue = [
             'nom'  => $nom,
             'age'  => $age,

fluxRSS/metier/Flux.php

@@ -4,6 +4,7 @@ namespace metier;
 
 class Flux
 {
+    private string $id;
     private string $flux;
 
     /**
@@ -21,4 +22,12 @@ class Flux
     {
         $this->flux = $flux;
     }
+
+    /**
+     * @return string
+     */
+    public function getId(): string
+    {
+        return $this->id;
+    }
 }

fluxRSS/model/Parser.php

@@ -0,0 +1,68 @@
+<?php
+
+namespace model;
+
+use DAL\ArticleGateway;
+use DAL\FluxGateway;
+use DOMDocument;
+use Exception;
+use metier\Article;
+use metier\Flux;
+
+class Parser
+{
+    private FluxGateway $fluxGateway;
+    private ArticleGateway $articleGateway;
+
+    public function __construct(FluxGateway $fluxGateway, ArticleGateway $articleGateway){
+        $this->fluxGateway = $fluxGateway;
+        $this->articleGateway = $articleGateway;
+    }
+    public function parseArticles(Flux $flux): array
+    {
+        $dom = new DOMDocument();
+        $tabArticle = array();
+
+        if ($dom->load($flux->getFlux())){
+            $items = $dom->getElementsByTagName('item');
+
+            foreach ($items as $item) {
+                $title = $item->getElementsByTagName('title')[0]->nodeValue;
+                $date = $item->getElementsByTagName('pubDate')[0]->nodeValue;
+                $guid = $item->getElementsByTagName('guid')[0]->nodeValue;
+                $link = $item->getElementsByTagName('link')[0]->nodeValue;
+                $description = $item->getElementsByTagName('description')[0]->nodeValue;
+
+                $media = $item->getElementsByTagName('media:content');
+                $mediaUrl = null;
+                if ($media->length > 0){
+                    $mediaUrl = $media->item(0)->getAttribute('url');
+                }
+
+                $tabArticle[] = new Article((int)null, $title, $date, $description, $guid, $link, $mediaUrl, $flux->getId());
+            }
+            return $tabArticle;
+        } else {
+            // En cas d'erreur lors du chargement du flux RSS, lever une exception
+            throw new Exception("Erreur lors du chargement du flux RSS");
+        }
+    }
+
+
+    public function parseAll($fluxes){
+        foreach ($fluxes as $flux){
+            $tabArticles[] =$this->parseArticles($flux);
+        }
+        return $tabArticles;
+    }
+
+    public function addAllArticles(){
+        $allFlux = $this->fluxGateway->findAllFlux();
+
+        $allArticles = $this->parseAll($allFlux);
+
+        foreach ($allArticles as $article) {
+            $this->articleGateway->addArticle($article);
+        }
+    }
+}