basis-company / framework.php

src/Job.php

Doc Comments +6 added lines

@@ -8,6 +8,9 @@ 
 {
     use Toolkit;
 
+    /**
+     * @param string $name
+     */
     protected function require($name)
     {
         if (!$this->$name) {
@@ -15,6 +18,9 @@ 
         }
     }
 
+    /**
+     * @param string $message
+     */
     protected function confirm($message)
     {
         $hash = md5($message);

src/Cache.php

Doc Comments +10 added lines

@@ -35,6 +35,9 @@ 
         }
     }
 
+    /**
+     * @param string $key
+     */
     public function get($key)
     {
         if ($this->exists($key)) {
@@ -42,6 +45,9 @@ 
         }
     }
 
+    /**
+     * @param string $key
+     */
     public function set($key, $value)
     {
         $filename = $this->path . '/' . $key;
@@ -55,6 +61,10 @@ 
         $this->cache[$key] = $data;
     }
 
+    /**
+     * @param string $key
+     * @param \Closure $callback
+     */
     public function wrap($key, $callback)
     {
         if (!is_string($key)) {

src/Application.php

Doc Comments +3 added lines

@@ -91,6 +91,9 @@
         return parent::get($alias, $new);
     }
 
+    /**
+     * @param string $id
+     */
     public function hasInstance($id) : bool
     {
         if ($this->definitions->has($id)) {

src/Test/Mapper.php

Doc Comments +3 added lines

@@ -18,6 +18,9 @@
         $this->serviceName = $service;
     }
 
+    /**
+     * @param string $space
+     */
     public function create($space, $params)
     {
         $key = $this->serviceName.'.'.$space;

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;
-    }
-}

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;
-    }
-}

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;
-    }
-}

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);