Completed
Push — master ( 3041fb...0ec14e )
by Dmitry
03:31
created
test/php/Test/EventTest.php 1 patch
Unused Use Statements   -1 removed lines patch added patch discarded remove patch
@@ -2,7 +2,6 @@
 block discarded – undo
2 2
 
3 3
 namespace Test;
4 4
 
5
-use Basis\Converter;
6 5
 use Basis\Event;
7 6
 use Basis\Http;
8 7
 use Basis\Test;
Please login to merge, or discard this patch.
src/Executor.php 1 patch
Unused Use Statements   -2 removed lines patch added patch discarded remove patch
@@ -8,8 +8,6 @@
 block discarded – undo
8 8
 use Exception;
9 9
 use Tarantool\Mapper\Entity;
10 10
 use Tarantool\Mapper\Plugin\Procedure;
11
-use Tarantool\Mapper\Procedure\FindOrCreate;
12
-use Tarantool\Mapper\Repository;
13 11
 
14 12
 class Executor
15 13
 {
Please login to merge, or discard this patch.
src/Procedure/JobQueue/Cleanup.php 2 patches
Doc Comments   -11 removed lines patch added patch discarded remove patch
@@ -14,14 +14,3 @@
 block discarded – undo
14 14
     public function getBody(): string
15 15
     {
16 16
         return <<<LUA
17
-        box.begin()
18
-        for i, t in box.space.job_queue.index.status_id:pairs('transfered') do
19
-            local result = box.space.job_result.index.service_hash:count({t.recipient, t.hash})
20
-            if result > 0 then
21
-                box.space.job_queue:delete(t.id)
22
-            end
23
-        end
24
-        box.commit()
25
-        LUA;
26
-    }
27
-}
Please login to merge, or discard this patch.
Unused Use Statements   -11 removed lines patch added patch discarded remove patch
@@ -14,14 +14,3 @@
 block discarded – undo
14 14
     public function getBody(): string
15 15
     {
16 16
         return <<<LUA
17
-        box.begin()
18
-        for i, t in box.space.job_queue.index.status_id:pairs('transfered') do
19
-            local result = box.space.job_result.index.service_hash:count({t.recipient, t.hash})
20
-            if result > 0 then
21
-                box.space.job_queue:delete(t.id)
22
-            end
23
-        end
24
-        box.commit()
25
-        LUA;
26
-    }
27
-}
Please login to merge, or discard this patch.
src/Procedure/JobQueue/Take.php 2 patches
Doc Comments   -11 removed lines patch added patch discarded remove patch
@@ -14,14 +14,3 @@
 block discarded – undo
14 14
     public function getBody(): string
15 15
     {
16 16
         return <<<LUA
17
-        box.begin()
18
-        local tuples = box.space.job_queue.index.status_id:select({'new'}, { limit = 1})
19
-        if #tuples > 0 then
20
-            local request = box.space.job_queue:update(tuples[1].id, {{'=', 2, 'processing'}})
21
-            box.commit()
22
-            return request
23
-        end
24
-        box.rollback()
25
-        LUA;
26
-    }
27
-}
Please login to merge, or discard this patch.
Unused Use Statements   -11 removed lines patch added patch discarded remove patch
@@ -14,14 +14,3 @@
 block discarded – undo
14 14
     public function getBody(): string
15 15
     {
16 16
         return <<<LUA
17
-        box.begin()
18
-        local tuples = box.space.job_queue.index.status_id:select({'new'}, { limit = 1})
19
-        if #tuples > 0 then
20
-            local request = box.space.job_queue:update(tuples[1].id, {{'=', 2, 'processing'}})
21
-            box.commit()
22
-            return request
23
-        end
24
-        box.rollback()
25
-        LUA;
26
-    }
27
-}
Please login to merge, or discard this patch.
src/Procedure/JobResult/Foreign.php 2 patches
Doc Comments   -6 removed lines patch added patch discarded remove patch
@@ -14,9 +14,3 @@
 block discarded – undo
14 14
     public function getBody(): string
15 15
     {
16 16
         return <<<LUA
17
-        return box.space.job_result:pairs()
18
-            :filter(function(r) return r.service ~= service end)
19
-            :totable()
20
-        LUA;
21
-    }
22
-}
Please login to merge, or discard this patch.
Unused Use Statements   -6 removed lines patch added patch discarded remove patch
@@ -14,9 +14,3 @@
 block discarded – undo
14 14
     public function getBody(): string
15 15
     {
16 16
         return <<<LUA
17
-        return box.space.job_result:pairs()
18
-            :filter(function(r) return r.service ~= service end)
19
-            :totable()
20
-        LUA;
21
-    }
22
-}
Please login to merge, or discard this patch.