AbstractQueueTransport::generate_rnd_postfix() - Code Metrics - Inspection of "* Выкидываем генерацию криптосекурных строк. Это С..." - nokitakaze/php-queue - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — developer ( 2584f0...ccb49a )

by Никита

created 2017-10-06 16:12 UTC

AbstractQueueTransport::generate_rnd_postfix() A

↳ Parent: AbstractQueueTransport

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes

Metric	Value
c	0
b	0
f	0
dl	0
loc	3
ccs	0
cts	0
cp	0
rs	10
cc	1
eloc	2
nc	1
nop	0
crap	2

<?php

    namespace NokitaKaze\Queue;

    abstract class AbstractQueueTransport implements QueueTransport {
        /**
         * @var iMessage[]|object[]
         */
        protected $_pushed_for_save = [];

        protected $_same_time_consumer_and_producer = 0;

        /**
         * @var callable|null
         */
        protected $_callback_closure = null;

        /**
         * @var integer[] В keys список индексов полученных сообщений
         */
        protected $_consumed_keys = [];

        /**
         * Удалить сообщение и сразу же записать это в БД
         *
         * @param iMessage|object $message
         *
         * @return boolean
         */
        function delete_message($message) {

            return !empty($this->delete_messages([$message]));
        }

        /**
         * Загоняем сообщение в очередь и явно сохраняем
         *
         * @param mixed       $data
         * @param string|null $name Название сообщения. Если null, то можно дублировать
         * @param integer     $sort
         *
         * @throws QueueException
         */
        function produce_message($data, $name = null, $sort = 5) {

            $this->push(Queue::build_message($data, $name, $sort));
            $this->save();
        }

        /**
         * Загоняем сообщение в очередь необходимых для сохранения сообщений
         *
         * @param iMessage[]|iMessage|object[]|object $stream
         *
         * @throws QueueException
         */
        function push($stream) {

            $this->set_same_time_flag(1);
            if (is_array($stream)) {
                foreach ($stream as &$message) {
                    $this->_pushed_for_save[] = Queue::sanify_event_object($message);
                }
            } else {
                $this->_pushed_for_save[] = Queue::sanify_event_object($stream);
            }
        }

        /**
         * @param integer $flag
         *
         * @throws QueueException
         */
        protected function set_same_time_flag($flag) {
            $this->_same_time_consumer_and_producer |= $flag;
            if ($this->_same_time_consumer_and_producer === 3) {
                throw new QueueException('Consumer and producer at the same time', 18);
            }
        }

        /**
         * @param callable $closure
         */
        function set_callback_closure($closure) {

            $this->_callback_closure = $closure;
        }

        /**
         * @param double|integer $wait_time
         *
         * @throws QueueException
         */
        function listen($wait_time = -1) {

            $start = microtime(true);
            if (is_null($this->_callback_closure)) {
                throw new QueueException('Event listener has not been set', 3);
            }
            $closure = $this->_callback_closure;
            do {
                $message = $this->consume_next_message($wait_time);
                if (!is_null($message)) {
                    call_user_func($closure, $message);
                } else {
                    usleep(10000);
                }
            } while (($wait_time === -1) or ($start + $wait_time >= microtime(true)));
        }

        function __clone() {

            foreach ($this->_pushed_for_save as &$message) {
                $message = clone $message;
            }
        }

        function clear_consumed_keys() {

            $this->_consumed_keys = [];
        }

        /**
         * @return boolean
         */
        function is_producer() {

            return (($this->_same_time_consumer_and_producer & 1) == 1);
        }

        /**
         * @return boolean
         */
        function is_consumer() {

            return (($this->_same_time_consumer_and_producer & 2) == 2);
        }

        /**
         * @param iMessage|object $message
         *
         * @return string
         */
        static function get_real_key_for_message($message) {

            return Queue::get_real_key_for_message($message);
        }

        /**
         * @param iMessage[] $messages
         * @param iMessage   $message
         * @param string     $message_key
         *
         * @return boolean
         */
        protected function change_message_in_array(array &$messages, $message, $message_key) {
            $exists = false;
            $message->is_read = true;
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            foreach ($messages as $inner_id => &$inner_message) {
                $inner_message_key = self::get_real_key_for_message($inner_message);
                if ($inner_message_key == $message_key) {
                    $message->time_last_update = microtime(true);
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
                    $messages[$inner_id] = $message;
                    $exists = true;
                } else {
                    $inner_message->is_read = true;
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
                }
            }

            return $exists;
        }

        /**
         * @param QueueTransport $queue
         *
         * @return boolean
         */
        function is_equal_to($queue) {

            return (get_class($this) == get_class($queue));
        }

        /**
         * @return string
         */
        static function generate_rnd_postfix() {

            return Queue::generate_rnd_postfix();
        }

        // @todo Удаление конкретных ключей из consumed. Причем туда передаётся кложур, в который передаётся название ключа
        // @todo Удаление конкретных ключей из индекса и очереди, с указанием max_create_timestamp,
        // чтобы не хранить в очереди те же сообщения, пришедшие ещё раз
    }

?>

1		<?php
2
3		namespace NokitaKaze\Queue;
4
5		abstract class AbstractQueueTransport implements QueueTransport {
6		/**
7		* @var iMessage[]\|object[]
8		*/
9		protected $_pushed_for_save = [];
10
11		protected $_same_time_consumer_and_producer = 0;
12
13		/**
14		* @var callable\|null
15		*/
16		protected $_callback_closure = null;
17
18		/**
19		* @var integer[] В keys список индексов полученных сообщений
20		*/
21		protected $_consumed_keys = [];
22
23		/**
24		* Удалить сообщение и сразу же записать это в БД
25		*
26		* @param iMessage\|object $message
27		*
28		* @return boolean
29		*/
30	312	function delete_message($message) {
		1 ignored issue – show Best Practice introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history...
31	312	return !empty($this->delete_messages([$message]));
32		}
33
34		/**
35		* Загоняем сообщение в очередь и явно сохраняем
36		*
37		* @param mixed $data
38		* @param string\|null $name Название сообщения. Если null, то можно дублировать
39		* @param integer $sort
40		*
41		* @throws QueueException
42		*/
43	216	function produce_message($data, $name = null, $sort = 5) {
		1 ignored issue – show Best Practice introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history...
44	216	$this->push(Queue::build_message($data, $name, $sort));
45	216	$this->save();
46	216	}
47
48		/**
49		* Загоняем сообщение в очередь необходимых для сохранения сообщений
50		*
51		* @param iMessage[]\|iMessage\|object[]\|object $stream
52		*
53		* @throws QueueException
54		*/
55	3678	function push($stream) {
		1 ignored issue – show Best Practice introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history...
56	3678	$this->set_same_time_flag(1);
57	3678	if (is_array($stream)) {
58	1389	foreach ($stream as &$message) {
59	1389	$this->_pushed_for_save[] = Queue::sanify_event_object($message);
60	463	}
61	463	} else {
62	3402	$this->_pushed_for_save[] = Queue::sanify_event_object($stream);
63		}
64	3678	}
65
66		/**
67		* @param integer $flag
68		*
69		* @throws QueueException
70		*/
71	3720	protected function set_same_time_flag($flag) {
72	3720	$this->_same_time_consumer_and_producer \|= $flag;
73	3720	if ($this->_same_time_consumer_and_producer === 3) {
74	9	throw new QueueException('Consumer and producer at the same time', 18);
75		}
76	3720	}
77
78		/**
79		* @param callable $closure
80		*/
81	3	function set_callback_closure($closure) {
		1 ignored issue – show Best Practice introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history...
82	3	$this->_callback_closure = $closure;
83	3	}
84
85		/**
86		* @param double\|integer $wait_time
87		*
88		* @throws QueueException
89		*/
90	3	function listen($wait_time = -1) {
		1 ignored issue – show Best Practice introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history...
91	3	$start = microtime(true);
92	3	if (is_null($this->_callback_closure)) {
93	3	throw new QueueException('Event listener has not been set', 3);
94		}
95	3	$closure = $this->_callback_closure;
96		do {
97	3	$message = $this->consume_next_message($wait_time);
98	3	if (!is_null($message)) {
99	3	call_user_func($closure, $message);
100	1	} else {
101	3	usleep(10000);
102		}
103	3	} while (($wait_time === -1) or ($start + $wait_time >= microtime(true)));
104	3	}
105
106	3429	function __clone() {
		1 ignored issue – show Best Practice introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history...
107	3429	foreach ($this->_pushed_for_save as &$message) {
108	9	$message = clone $message;
109	1143	}
110	3429	}
111
112	9	function clear_consumed_keys() {
		1 ignored issue – show Best Practice introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history...
113	9	$this->_consumed_keys = [];
114	9	}
115
116		/**
117		* @return boolean
118		*/
119	231	function is_producer() {
		1 ignored issue – show Best Practice introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history...
120	231	return (($this->_same_time_consumer_and_producer & 1) == 1);
121		}
122
123		/**
124		* @return boolean
125		*/
126	378	function is_consumer() {
		1 ignored issue – show Best Practice introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history...
127	378	return (($this->_same_time_consumer_and_producer & 2) == 2);
128		}
129
130		/**
131		* @param iMessage\|object $message
132		*
133		* @return string
134		*/
135	3672	static function get_real_key_for_message($message) {
		1 ignored issue – show Best Practice introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history...
136	3672	return Queue::get_real_key_for_message($message);
137		}
138
139		/**
140		* @param iMessage[] $messages
141		* @param iMessage $message
142		* @param string $message_key
143		*
144		* @return boolean
145		*/
146	338	protected function change_message_in_array(array &$messages, $message, $message_key) {
147	338	$exists = false;
148	338	$message->is_read = true;
		0 ignored issues – show Bug introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report Accessing `is_read` on the interface `NokitaKaze\Queue\iMessage` suggest that you code against a concrete implementation. How about adding an `instanceof` check? If you access a property on an interface, you most likely code against a concrete implementation of the interface. Available Fixes Adding an additional type check: interface SomeInterface { } class SomeClass implements SomeInterface { public $a; } function someFunction(SomeInterface $object) { if ($object instanceof SomeClass) { $a = $object->a; } } Changing the type hint: interface SomeInterface { } class SomeClass implements SomeInterface { public $a; } function someFunction(SomeClass $object) { $a = $object->a; } Loading history...
149	338	foreach ($messages as $inner_id => &$inner_message) {
150	338	$inner_message_key = self::get_real_key_for_message($inner_message);
151	338	if ($inner_message_key == $message_key) {
152	338	$message->time_last_update = microtime(true);
		0 ignored issues – show Bug introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report Accessing `time_last_update` on the interface `NokitaKaze\Queue\iMessage` suggest that you code against a concrete implementation. How about adding an `instanceof` check? If you access a property on an interface, you most likely code against a concrete implementation of the interface. Available Fixes Adding an additional type check: interface SomeInterface { } class SomeClass implements SomeInterface { public $a; } function someFunction(SomeInterface $object) { if ($object instanceof SomeClass) { $a = $object->a; } } Changing the type hint: interface SomeInterface { } class SomeClass implements SomeInterface { public $a; } function someFunction(SomeClass $object) { $a = $object->a; } Loading history...
153	338	$messages[$inner_id] = $message;
154	338	$exists = true;
155	111	} else {
156	338	$inner_message->is_read = true;
		0 ignored issues – show Bug introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report Accessing `is_read` on the interface `NokitaKaze\Queue\iMessage` suggest that you code against a concrete implementation. How about adding an `instanceof` check? If you access a property on an interface, you most likely code against a concrete implementation of the interface. Available Fixes Adding an additional type check: interface SomeInterface { } class SomeClass implements SomeInterface { public $a; } function someFunction(SomeInterface $object) { if ($object instanceof SomeClass) { $a = $object->a; } } Changing the type hint: interface SomeInterface { } class SomeClass implements SomeInterface { public $a; } function someFunction(SomeClass $object) { $a = $object->a; } Loading history...
157		}
158	111	}
159
160	338	return $exists;
161		}
162
163		/**
164		* @param QueueTransport $queue
165		*
166		* @return boolean
167		*/
168	1242	function is_equal_to($queue) {
		1 ignored issue – show Best Practice introduced 2017-10-05 11:47 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history...
169	1242	return (get_class($this) == get_class($queue));
170		}
171
172		/**
173		* @return string
174		*/
175		static function generate_rnd_postfix() {
		1 ignored issue – show Best Practice introduced 2017-10-06 16:14 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history...
176		return Queue::generate_rnd_postfix();
177		}
178
179		// @todo Удаление конкретных ключей из consumed. Причем туда передаётся кложур, в который передаётся название ключа
180		// @todo Удаление конкретных ключей из индекса и очереди, с указанием max_create_timestamp,
181		// чтобы не хранить в очереди те же сообщения, пришедшие ещё раз
182		}
183
184		?>

nokitakaze / php-queue

Push — developer ( 2584f0...ccb49a )

AbstractQueueTransport::generate_rnd_postfix() A

Complexity

Size

Duplication

Code Coverage

Importance

Available Fixes

Available Fixes

Available Fixes

Duplication Side-by-Side

Filter issues like