Dev

app/Blog.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace App;
+
+use Illuminate\Database\Eloquent\Model;
+
+class Blog extends Model
+{
+    public $timestamps = false;
+
+    protected $fillable = [
+        'name',
+        'categories',
+        'tags',
+        'description',
+        'content',
+        'thumbnail',
+        'path',
+        'date',
+        'modified',
+        'status',
+        'type',
+        'slug'
+    ];
+}

app/Console/Commands/Importers/Baden.php

@@ -44,7 +44,7 @@ public function handle(): void
 
         $techicalUser = ImporterHelper::getTechnicalUser('baden-technical');
 
-        $items = BadenRSSItem::whereNull('imported_at')->get();
+        $items = BadenRSSItem::all();
 
         foreach ($items as $item) {
 

app/Console/Commands/Importers/Bayern.php

@@ -44,7 +44,7 @@ public function handle(): void
 
         $techicalUser = ImporterHelper::getTechnicalUser('bayern-technical');
 
-        $items = BayernRSSItem::whereNull('imported_at')->get();
+        $items = BayernRSSItem::all();
 
         foreach ($items as $item) {
 

app/Console/Commands/Importers/Berlin.php

@@ -44,7 +44,7 @@ public function handle(): void
 
         $techicalUser = ImporterHelper::getTechnicalUser('berlin-technical');
 
-        $items = BerlinRSSItem::whereNull('imported_at')->get();
+        $items = BerlinRSSItem::all();
 
         foreach ($items as $item) {
 

app/Console/Commands/Importers/Bonn.php

@@ -43,7 +43,7 @@ public function handle(): void
         Log::info('Loading Bonn API Items in Database');
 
         $techicalUser = ImporterHelper::getTechnicalUser('bonn-technical');
-        $items = BonnRSSItem::whereNull('imported_at')->get();
+        $items = BonnRSSItem::all();
 
         foreach ($items as $item) {
             $item->createEvent($techicalUser);

app/Console/Commands/Importers/Bremen.php

@@ -43,7 +43,7 @@ public function handle(): void
         Log::info('Loading Bremen API Items in Database');
 
         $techicalUser = ImporterHelper::getTechnicalUser('bremen-technical');
-        $items = BremenRSSItem::whereNull('imported_at')->get();
+        $items = BremenRSSItem::all();
 
         foreach ($items as $item) {
             $item->createEvent($techicalUser);

app/Console/Commands/Importers/Dresden.php

@@ -43,7 +43,7 @@ public function handle(): void
         Log::info('Loading Dresden API Items in Database');
 
         $techicalUser = ImporterHelper::getTechnicalUser('dresden-technical');
-        $items = DresdenRSSItem::whereNull('imported_at')->get();
+        $items = DresdenRSSItem::all();
 
         foreach ($items as $item) {
             $item->createEvent($techicalUser);

app/Console/Commands/Importers/Hamburg.php

@@ -43,7 +43,7 @@ public function handle(): void
         Log::info('Loading Hamburg API Items in Database');
 
         $techicalUser = ImporterHelper::getTechnicalUser('hamburg-technical');
-        $items = HamburgRSSItem::whereNull('imported_at')->get();
+        $items = HamburgRSSItem::all();
 
         foreach ($items as $item) {
             $item->createEvent($techicalUser);

app/Console/Commands/Importers/Leipzig.php

@@ -44,7 +44,7 @@ public function handle(): void
 
         $techicalUser = ImporterHelper::getTechnicalUser('leipzig-technical');
 
-        $items = LeipzigRSSItem::whereNull('imported_at')->get();
+        $items = LeipzigRSSItem::all();
 
         foreach ($items as $item) {
 

app/Console/Commands/Importers/Muensterland.php

@@ -44,7 +44,7 @@ public function handle(): void
 
         $techicalUser = ImporterHelper::getTechnicalUser('muensterland-technical');
 
-        $items = MuensterlandRSSItem::whereNull('imported_at')->get();
+        $items = MuensterlandRSSItem::all();
 
         foreach ($items as $item) {
 

app/Console/Commands/Importers/Niedersachsen.php

@@ -45,7 +45,7 @@ public function handle(): void
 
         $technicalUser = ImporterHelper::getTechnicalUser('niedersachsen-technical');
 
-        $items = NiedersachsenRSSItem::whereNull('imported_at')->get();
+        $items = NiedersachsenRSSItem::all();
 
         foreach ($items as $item) {
 

app/Console/Commands/Importers/Nordhessen.php

@@ -44,7 +44,7 @@ public function handle(): void
 
         $techicalUser = ImporterHelper::getTechnicalUser('nordhessen-technical');
 
-        $items = NordhessenRSSItem::whereNull('imported_at')->get();
+        $items = NordhessenRSSItem::all();
 
         foreach ($items as $item) {
 

app/Console/Commands/Importers/Thueringen.php

@@ -44,7 +44,7 @@ public function handle(): void
 
         $techicalUser = ImporterHelper::getTechnicalUser('thueringen-technical');
 
-        $items = ThueringenRSSItem::whereNull('imported_at')->get();
+        $items = ThueringenRSSItem::all();
 
         foreach ($items as $item) {
 

app/Console/Commands/SyncBlogs.php

@@ -0,0 +1,93 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Blog;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Http;
+use Illuminate\Support\Facades\Log;
+
+class SyncBlogs extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'app:sync-blogs';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Fetch blogs from an API and store them in the database';
+
+    /**
+     * Execute the console command.
+     */
+    public function handle()
+    {
+        $url = config('codeweek.blog_url') . '/wp-json/wp/v2/posts';
+        $perPage = 10;
+        $page = 1;
+
+        try {
+            do {
+                $response = Http::get("{$url}?per_page={$perPage}&page={$page}");
+
+                if (!$response->successful()) {
+                    $this->error("Failed to fetch data from API: {$url}?per_page={$perPage}&page={$page}");
+                    break;
+                }
+
+                $data = $response->json();
+                $totalPages = $response->header('X-WP-TotalPages', 1);
+
+                foreach ($data as $item) {
+                    Blog::updateOrCreate(
+                        ['path' => $item['link']],
+                        [
+                            'name' => data_get($item, 'title.rendered', ''),
+                            'categories' => json_encode($item['categories']),
+                            'tags' => json_encode($item['tags']),
+                            'description' => strip_tags(data_get($item, 'excerpt.rendered', '')),
+                            'content' => data_get($item, 'content.rendered', ''),
+                            'thumbnail' => $this->fetchThumbnail(data_get($item, '_links.wp:featuredmedia', [])),
+                            'path' => $item['link'],
+                            'date' => $item['date'],
+                            'modified' => $item['modified'],
+                            'status' => $item['status'],
+                            'type' => $item['type'],
+                            'slug' => $item['slug'],
+                        ]
+                    );
+                }
+
+                $this->info("Page {$page} synchronized.");
+                $page++;
+            } while ($page <= $totalPages);
+
+            $this->info('Blogs synchronized successfully!');
+        } catch (\Exception $e) {
+            Log::error("Error syncing blogs: {$e->getMessage()}");
+            $this->error("Error: {$e->getMessage()}");
+        }
+    }
+
+    private function fetchThumbnail($mediaLinks)
+    {
+        if (!empty($mediaLinks) && isset($mediaLinks[0]['href'])) {
+            try {
+                $mediaResponse = Http::get($mediaLinks[0]['href']);
+                if ($mediaResponse->successful()) {
+                    return data_get($mediaResponse->json(), 'source_url', '');
+                }
+            } catch (\Exception $e) {
+                Log::error("Failed to fetch media data: {$e->getMessage()}");
+            }
+        }
+
+        return null;
+    }
+}

app/Console/Commands/api/GermanTraits.php

@@ -84,7 +84,7 @@ private function createRSSItem($json, $city): void
     private function createGermanEvent($city): void
     {
         $user = User::where(['email' => $this->user_email])->first();
-
+    
         if ($user == null) {
 
             //Create user
@@ -151,4 +151,5 @@ private function createGermanEvent($city): void
             $event->tags()->sync($tagsArray);
         }
     }
+
 }