chore: move db creation to schema file

Author: mychidarko

src/Queue/Adapters/Database.php

@@ -50,10 +50,6 @@ public function connect($connection)
      */
     public function pushJobToQueue($job)
     {
-        if (!$this->db->tableExists($this->config['table'])) {
-            $this->setupAdapterStorage();
-        }
-
         $this->db
             ->insert($this->config['table'])
             ->params($job)
@@ -97,10 +93,10 @@ public function setJobStatus($id, $status)
         $this->db
             ->update($this->config['table'])
             ->params([
-                "status" => $status,
+                'status' => $status,
             ])
             ->where([
-                "id" => $id,
+                'id' => $id,
             ])
             ->execute();
 
@@ -118,50 +114,17 @@ public function setJobStatus($id, $status)
      */
     public function markJobAsFailed($id)
     {
-        $this->db
-            ->update($this->config['table'])
-            ->params([
-                "status" => "failed",
-            ])
-            ->where([
-                "id" => $id,
-            ])
-            ->execute();
-
-        if ($this->db->errors()) {
-            $this->errors = $this->db->errors();
-
-            return false;
-        }
-
-        return true;
-    }
-
-    /**
-     * Setup storage for the adapter
-     */
-    protected function setupAdapterStorage()
-    {
-        $this->db
-            ->createTable($this->config['table'], [
-                'id' => 'INT NOT NULL AUTO_INCREMENT',
-                'class' => 'VARCHAR(255)',
-                'config' => 'TEXT',
-                'status' => 'VARCHAR(50)',
-                'retry_count' => 'INT',
-                'created_at' => 'TIMESTAMP DEFAULT CURRENT_TIMESTAMP',
-                'updated_at' => 'DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP',
-                'PRIMARY KEY' => '(ID)',
-            ])
-            ->execute();
+        return $this->setJobStatus($id, 'failed');
     }
 
     /**
      * @inheritDoc
      */
     public function getJobs()
     {
-        return [];
+        return $this->db
+            ->select($this->config['table'])
+            ->get();
     }
 
     /**