Browse code

added appinfo/info.xml appinfo/signature.json CHANGELOG.txt lib/AppInfo/Application.php css/style.css providers/Plivo

DoubleBastionAdmin authored on 05/11/2025 13:35:09
Showing 1 changed files
providers/Plivo/vendor/guzzlehttp/psr7/src/PumpStream.php
History View file @ 976eaee
1 1 
new file mode 100644
... ... 
@@ -0,0 +1,179 @@
1 
+<?php
2 
+
3 
+declare(strict_types=1);
4 
+
5 
+namespace GuzzleHttp\Psr7;
6 
+
7 
+use Psr\Http\Message\StreamInterface;
8 
+
9 
+/**
10 
+ * Provides a read only stream that pumps data from a PHP callable.
11 
+ *
12 
+ * When invoking the provided callable, the PumpStream will pass the amount of
13 
+ * data requested to read to the callable. The callable can choose to ignore
14 
+ * this value and return fewer or more bytes than requested. Any extra data
15 
+ * returned by the provided callable is buffered internally until drained using
16 
+ * the read() function of the PumpStream. The provided callable MUST return
17 
+ * false when there is no more data to read.
18 
+ */
19 
+final class PumpStream implements StreamInterface
20 
+{
21 
+    /** @var callable(int): (string|false|null)|null */
22 
+    private $source;
23 
+
24 
+    /** @var int|null */
25 
+    private $size;
26 
+
27 
+    /** @var int */
28 
+    private $tellPos = 0;
29 
+
30 
+    /** @var array */
31 
+    private $metadata;
32 
+
33 
+    /** @var BufferStream */
34 
+    private $buffer;
35 
+
36 
+    /**
37 
+     * @param callable(int): (string|false|null)  $source  Source of the stream data. The callable MAY
38 
+     *                                                     accept an integer argument used to control the
39 
+     *                                                     amount of data to return. The callable MUST
40 
+     *                                                     return a string when called, or false|null on error
41 
+     *                                                     or EOF.
42 
+     * @param array{size?: int, metadata?: array} $options Stream options:
43 
+     *                                                     - metadata: Hash of metadata to use with stream.
44 
+     *                                                     - size: Size of the stream, if known.
45 
+     */
46 
+    public function __construct(callable $source, array $options = [])
47 
+    {
48 
+        $this->source = $source;
49 
+        $this->size = $options['size'] ?? null;
50 
+        $this->metadata = $options['metadata'] ?? [];
51 
+        $this->buffer = new BufferStream();
52 
+    }
53 
+
54 
+    public function __toString(): string
55 
+    {
56 
+        try {
57 
+            return Utils::copyToString($this);
58 
+        } catch (\Throwable $e) {
59 
+            if (\PHP_VERSION_ID >= 70400) {
60 
+                throw $e;
61 
+            }
62 
+            trigger_error(sprintf('%s::__toString exception: %s', self::class, (string) $e), E_USER_ERROR);
63 
+
64 
+            return '';
65 
+        }
66 
+    }
67 
+
68 
+    public function close(): void
69 
+    {
70 
+        $this->detach();
71 
+    }
72 
+
73 
+    public function detach()
74 
+    {
75 
+        $this->tellPos = 0;
76 
+        $this->source = null;
77 
+
78 
+        return null;
79 
+    }
80 
+
81 
+    public function getSize(): ?int
82 
+    {
83 
+        return $this->size;
84 
+    }
85 
+
86 
+    public function tell(): int
87 
+    {
88 
+        return $this->tellPos;
89 
+    }
90 
+
91 
+    public function eof(): bool
92 
+    {
93 
+        return $this->source === null;
94 
+    }
95 
+
96 
+    public function isSeekable(): bool
97 
+    {
98 
+        return false;
99 
+    }
100 
+
101 
+    public function rewind(): void
102 
+    {
103 
+        $this->seek(0);
104 
+    }
105 
+
106 
+    public function seek($offset, $whence = SEEK_SET): void
107 
+    {
108 
+        throw new \RuntimeException('Cannot seek a PumpStream');
109 
+    }
110 
+
111 
+    public function isWritable(): bool
112 
+    {
113 
+        return false;
114 
+    }
115 
+
116 
+    public function write($string): int
117 
+    {
118 
+        throw new \RuntimeException('Cannot write to a PumpStream');
119 
+    }
120 
+
121 
+    public function isReadable(): bool
122 
+    {
123 
+        return true;
124 
+    }
125 
+
126 
+    public function read($length): string
127 
+    {
128 
+        $data = $this->buffer->read($length);
129 
+        $readLen = strlen($data);
130 
+        $this->tellPos += $readLen;
131 
+        $remaining = $length - $readLen;
132 
+
133 
+        if ($remaining) {
134 
+            $this->pump($remaining);
135 
+            $data .= $this->buffer->read($remaining);
136 
+            $this->tellPos += strlen($data) - $readLen;
137 
+        }
138 
+
139 
+        return $data;
140 
+    }
141 
+
142 
+    public function getContents(): string
143 
+    {
144 
+        $result = '';
145 
+        while (!$this->eof()) {
146 
+            $result .= $this->read(1000000);
147 
+        }
148 
+
149 
+        return $result;
150 
+    }
151 
+
152 
+    /**
153 
+     * @return mixed
154 
+     */
155 
+    public function getMetadata($key = null)
156 
+    {
157 
+        if (!$key) {
158 
+            return $this->metadata;
159 
+        }
160 
+
161 
+        return $this->metadata[$key] ?? null;
162 
+    }
163 
+
164 
+    private function pump(int $length): void
165 
+    {
166 
+        if ($this->source !== null) {
167 
+            do {
168 
+                $data = ($this->source)($length);
169 
+                if ($data === false || $data === null) {
170 
+                    $this->source = null;
171 
+
172 
+                    return;
173 
+                }
174 
+                $this->buffer->write($data);
175 
+                $length -= strlen($data);
176 
+            } while ($length > 0);
177 
+        }
178 
+    }
179 
+}
Browse code

removed appinfo/info.xml appinfo/signature.json CHANGELOG.txt lib/AppInfo/Application.php css/style.css providers/Plivo

DoubleBastionAdmin authored on 05/11/2025 13:12:22
Showing 1 changed files
providers/Plivo/vendor/guzzlehttp/psr7/src/PumpStream.php
History View file @ b79bd44
1 1 
deleted file mode 100644
... ... 
@@ -1,168 +0,0 @@
1 
-<?php
2 
-
3 
-namespace GuzzleHttp\Psr7;
4 
-
5 
-use Psr\Http\Message\StreamInterface;
6 
-
7 
-/**
8 
- * Provides a read only stream that pumps data from a PHP callable.
9 
- *
10 
- * When invoking the provided callable, the PumpStream will pass the amount of
11 
- * data requested to read to the callable. The callable can choose to ignore
12 
- * this value and return fewer or more bytes than requested. Any extra data
13 
- * returned by the provided callable is buffered internally until drained using
14 
- * the read() function of the PumpStream. The provided callable MUST return
15 
- * false when there is no more data to read.
16 
- */
17 
-class PumpStream implements StreamInterface
18 
-{
19 
-    /** @var callable */
20 
-    private $source;
21 
-
22 
-    /** @var int */
23 
-    private $size;
24 
-
25 
-    /** @var int */
26 
-    private $tellPos = 0;
27 
-
28 
-    /** @var array */
29 
-    private $metadata;
30 
-
31 
-    /** @var BufferStream */
32 
-    private $buffer;
33 
-
34 
-    /**
35 
-     * @param callable $source Source of the stream data. The callable MAY
36 
-     *                         accept an integer argument used to control the
37 
-     *                         amount of data to return. The callable MUST
38 
-     *                         return a string when called, or false on error
39 
-     *                         or EOF.
40 
-     * @param array $options   Stream options:
41 
-     *                         - metadata: Hash of metadata to use with stream.
42 
-     *                         - size: Size of the stream, if known.
43 
-     */
44 
-    public function __construct(callable $source, array $options = [])
45 
-    {
46 
-        $this->source = $source;
47 
-        $this->size = isset($options['size']) ? $options['size'] : null;
48 
-        $this->metadata = isset($options['metadata']) ? $options['metadata'] : [];
49 
-        $this->buffer = new BufferStream();
50 
-    }
51 
-
52 
-    public function __toString()
53 
-    {
54 
-        try {
55 
-            return Utils::copyToString($this);
56 
-        } catch (\Exception $e) {
57 
-            return '';
58 
-        }
59 
-    }
60 
-
61 
-    public function close()
62 
-    {
63 
-        $this->detach();
64 
-    }
65 
-
66 
-    public function detach()
67 
-    {
68 
-        $this->tellPos = false;
69 
-        $this->source = null;
70 
-
71 
-        return null;
72 
-    }
73 
-
74 
-    public function getSize()
75 
-    {
76 
-        return $this->size;
77 
-    }
78 
-
79 
-    public function tell()
80 
-    {
81 
-        return $this->tellPos;
82 
-    }
83 
-
84 
-    public function eof()
85 
-    {
86 
-        return !$this->source;
87 
-    }
88 
-
89 
-    public function isSeekable()
90 
-    {
91 
-        return false;
92 
-    }
93 
-
94 
-    public function rewind()
95 
-    {
96 
-        $this->seek(0);
97 
-    }
98 
-
99 
-    public function seek($offset, $whence = SEEK_SET)
100 
-    {
101 
-        throw new \RuntimeException('Cannot seek a PumpStream');
102 
-    }
103 
-
104 
-    public function isWritable()
105 
-    {
106 
-        return false;
107 
-    }
108 
-
109 
-    public function write($string)
110 
-    {
111 
-        throw new \RuntimeException('Cannot write to a PumpStream');
112 
-    }
113 
-
114 
-    public function isReadable()
115 
-    {
116 
-        return true;
117 
-    }
118 
-
119 
-    public function read($length)
120 
-    {
121 
-        $data = $this->buffer->read($length);
122 
-        $readLen = strlen($data);
123 
-        $this->tellPos += $readLen;
124 
-        $remaining = $length - $readLen;
125 
-
126 
-        if ($remaining) {
127 
-            $this->pump($remaining);
128 
-            $data .= $this->buffer->read($remaining);
129 
-            $this->tellPos += strlen($data) - $readLen;
130 
-        }
131 
-
132 
-        return $data;
133 
-    }
134 
-
135 
-    public function getContents()
136 
-    {
137 
-        $result = '';
138 
-        while (!$this->eof()) {
139 
-            $result .= $this->read(1000000);
140 
-        }
141 
-
142 
-        return $result;
143 
-    }
144 
-
145 
-    public function getMetadata($key = null)
146 
-    {
147 
-        if (!$key) {
148 
-            return $this->metadata;
149 
-        }
150 
-
151 
-        return isset($this->metadata[$key]) ? $this->metadata[$key] : null;
152 
-    }
153 
-
154 
-    private function pump($length)
155 
-    {
156 
-        if ($this->source) {
157 
-            do {
158 
-                $data = call_user_func($this->source, $length);
159 
-                if ($data === false || $data === null) {
160 
-                    $this->source = null;
161 
-                    return;
162 
-                }
163 
-                $this->buffer->write($data);
164 
-                $length -= strlen($data);
165 
-            } while ($length > 0);
166 
-        }
167 
-    }
168 
-}
Browse code

Added README.md appinfo/info.xml appinfo/signature.json lib/Controller/AuthorApiController.php and the providers directory

DoubleBastionAdmin authored on 20/08/2022 16:33:00
Showing 1 changed files
providers/Plivo/vendor/guzzlehttp/psr7/src/PumpStream.php
History View file @ f3755e3
1 1 
new file mode 100644
... ... 
@@ -0,0 +1,168 @@
1 
+<?php
2 
+
3 
+namespace GuzzleHttp\Psr7;
4 
+
5 
+use Psr\Http\Message\StreamInterface;
6 
+
7 
+/**
8 
+ * Provides a read only stream that pumps data from a PHP callable.
9 
+ *
10 
+ * When invoking the provided callable, the PumpStream will pass the amount of
11 
+ * data requested to read to the callable. The callable can choose to ignore
12 
+ * this value and return fewer or more bytes than requested. Any extra data
13 
+ * returned by the provided callable is buffered internally until drained using
14 
+ * the read() function of the PumpStream. The provided callable MUST return
15 
+ * false when there is no more data to read.
16 
+ */
17 
+class PumpStream implements StreamInterface
18 
+{
19 
+    /** @var callable */
20 
+    private $source;
21 
+
22 
+    /** @var int */
23 
+    private $size;
24 
+
25 
+    /** @var int */
26 
+    private $tellPos = 0;
27 
+
28 
+    /** @var array */
29 
+    private $metadata;
30 
+
31 
+    /** @var BufferStream */
32 
+    private $buffer;
33 
+
34 
+    /**
35 
+     * @param callable $source Source of the stream data. The callable MAY
36 
+     *                         accept an integer argument used to control the
37 
+     *                         amount of data to return. The callable MUST
38 
+     *                         return a string when called, or false on error
39 
+     *                         or EOF.
40 
+     * @param array $options   Stream options:
41 
+     *                         - metadata: Hash of metadata to use with stream.
42 
+     *                         - size: Size of the stream, if known.
43 
+     */
44 
+    public function __construct(callable $source, array $options = [])
45 
+    {
46 
+        $this->source = $source;
47 
+        $this->size = isset($options['size']) ? $options['size'] : null;
48 
+        $this->metadata = isset($options['metadata']) ? $options['metadata'] : [];
49 
+        $this->buffer = new BufferStream();
50 
+    }
51 
+
52 
+    public function __toString()
53 
+    {
54 
+        try {
55 
+            return Utils::copyToString($this);
56 
+        } catch (\Exception $e) {
57 
+            return '';
58 
+        }
59 
+    }
60 
+
61 
+    public function close()
62 
+    {
63 
+        $this->detach();
64 
+    }
65 
+
66 
+    public function detach()
67 
+    {
68 
+        $this->tellPos = false;
69 
+        $this->source = null;
70 
+
71 
+        return null;
72 
+    }
73 
+
74 
+    public function getSize()
75 
+    {
76 
+        return $this->size;
77 
+    }
78 
+
79 
+    public function tell()
80 
+    {
81 
+        return $this->tellPos;
82 
+    }
83 
+
84 
+    public function eof()
85 
+    {
86 
+        return !$this->source;
87 
+    }
88 
+
89 
+    public function isSeekable()
90 
+    {
91 
+        return false;
92 
+    }
93 
+
94 
+    public function rewind()
95 
+    {
96 
+        $this->seek(0);
97 
+    }
98 
+
99 
+    public function seek($offset, $whence = SEEK_SET)
100 
+    {
101 
+        throw new \RuntimeException('Cannot seek a PumpStream');
102 
+    }
103 
+
104 
+    public function isWritable()
105 
+    {
106 
+        return false;
107 
+    }
108 
+
109 
+    public function write($string)
110 
+    {
111 
+        throw new \RuntimeException('Cannot write to a PumpStream');
112 
+    }
113 
+
114 
+    public function isReadable()
115 
+    {
116 
+        return true;
117 
+    }
118 
+
119 
+    public function read($length)
120 
+    {
121 
+        $data = $this->buffer->read($length);
122 
+        $readLen = strlen($data);
123 
+        $this->tellPos += $readLen;
124 
+        $remaining = $length - $readLen;
125 
+
126 
+        if ($remaining) {
127 
+            $this->pump($remaining);
128 
+            $data .= $this->buffer->read($remaining);
129 
+            $this->tellPos += strlen($data) - $readLen;
130 
+        }
131 
+
132 
+        return $data;
133 
+    }
134 
+
135 
+    public function getContents()
136 
+    {
137 
+        $result = '';
138 
+        while (!$this->eof()) {
139 
+            $result .= $this->read(1000000);
140 
+        }
141 
+
142 
+        return $result;
143 
+    }
144 
+
145 
+    public function getMetadata($key = null)
146 
+    {
147 
+        if (!$key) {
148 
+            return $this->metadata;
149 
+        }
150 
+
151 
+        return isset($this->metadata[$key]) ? $this->metadata[$key] : null;
152 
+    }
153 
+
154 
+    private function pump($length)
155 
+    {
156 
+        if ($this->source) {
157 
+            do {
158 
+                $data = call_user_func($this->source, $length);
159 
+                if ($data === false || $data === null) {
160 
+                    $this->source = null;
161 
+                    return;
162 
+                }
163 
+                $this->buffer->write($data);
164 
+                $length -= strlen($data);
165 
+            } while ($length > 0);
166 
+        }
167 
+    }
168 
+}