basis-company / framework.php

src/Executor.php

Unused Use Statements -2 removed lines

@@ -8,8 +8,6 @@
 use Exception;
 use Tarantool\Mapper\Entity;
 use Tarantool\Mapper\Plugin\Procedure;
-use Tarantool\Mapper\Procedure\FindOrCreate;
-use Tarantool\Mapper\Repository;
 
 class Executor
 {

src/Procedure/JobQueue/Cleanup.php

Doc Comments -11 removed lines

@@ -14,14 +14,3 @@
     public function getBody(): string
     {
         return <<<LUA
-        box.begin()
-        for i, t in box.space.job_queue.index.status_id:pairs('transfered') do
-            local result = box.space.job_result.index.service_hash:count({t.recipient, t.hash})
-            if result > 0 then
-                box.space.job_queue:delete(t.id)
-            end
-        end
-        box.commit()
-        LUA;
-    }
-}

Unused Use Statements -11 removed lines

@@ -14,14 +14,3 @@
     public function getBody(): string
     {
         return <<<LUA
-        box.begin()
-        for i, t in box.space.job_queue.index.status_id:pairs('transfered') do
-            local result = box.space.job_result.index.service_hash:count({t.recipient, t.hash})
-            if result > 0 then
-                box.space.job_queue:delete(t.id)
-            end
-        end
-        box.commit()
-        LUA;
-    }
-}

src/Procedure/JobQueue/Take.php

Doc Comments -11 removed lines

@@ -14,14 +14,3 @@
     public function getBody(): string
     {
         return <<<LUA
-        box.begin()
-        local tuples = box.space.job_queue.index.status_id:select({'new'}, { limit = 1})
-        if #tuples > 0 then
-            local request = box.space.job_queue:update(tuples[1].id, {{'=', 2, 'processing'}})
-            box.commit()
-            return request
-        end
-        box.rollback()
-        LUA;
-    }
-}

Unused Use Statements -11 removed lines

@@ -14,14 +14,3 @@
     public function getBody(): string
     {
         return <<<LUA
-        box.begin()
-        local tuples = box.space.job_queue.index.status_id:select({'new'}, { limit = 1})
-        if #tuples > 0 then
-            local request = box.space.job_queue:update(tuples[1].id, {{'=', 2, 'processing'}})
-            box.commit()
-            return request
-        end
-        box.rollback()
-        LUA;
-    }
-}

src/Procedure/JobResult/Foreign.php

Doc Comments -6 removed lines

@@ -14,9 +14,3 @@
     public function getBody(): string
     {
         return <<<LUA
-        return box.space.job_result:pairs()
-            :filter(function(r) return r.service ~= service end)
-            :totable()
-        LUA;
-    }
-}

Unused Use Statements -6 removed lines

@@ -14,9 +14,3 @@
     public function getBody(): string
     {
         return <<<LUA
-        return box.space.job_result:pairs()
-            :filter(function(r) return r.service ~= service end)
-            :totable()
-        LUA;
-    }
-}

src/Toolkit.php

Doc Comments +9 added lines

@@ -79,6 +79,9 @@ 
         return $this->get(Mapper::class)->getRepository($space);
     }
 
+    /**
+     * @param string $tube
+     */
     public function getQueue($tube)
     {
         $alias = "queue.$tube";
@@ -105,6 +108,9 @@ 
         return $this->getRepository($space)->remove($params);
     }
 
+    /**
+     * @param string $fields
+     */
     protected function select($fields, string $table, array $params)
     {
         return $this->get(Clickhouse::class)->select($fields, $table, $params);
@@ -115,6 +121,9 @@ 
         return $this->get(Clickhouse::class)->insert($table, $data, $headers);
     }
 
+    /**
+     * @param string $contents
+     */
     protected function upload(string $filename, $contents) : string
     {
         return $this->get(Storage::class)->upload($filename, $contents);