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/AppendStream.php
History View file @ 976eaee
1 1 
new file mode 100644
... ... 
@@ -0,0 +1,248 @@
1 
+<?php
2 
+
3 
+declare(strict_types=1);
4 
+
5 
+namespace GuzzleHttp\Psr7;
6 
+
7 
+use Psr\Http\Message\StreamInterface;
8 
+
9 
+/**
10 
+ * Reads from multiple streams, one after the other.
11 
+ *
12 
+ * This is a read-only stream decorator.
13 
+ */
14 
+final class AppendStream implements StreamInterface
15 
+{
16 
+    /** @var StreamInterface[] Streams being decorated */
17 
+    private $streams = [];
18 
+
19 
+    /** @var bool */
20 
+    private $seekable = true;
21 
+
22 
+    /** @var int */
23 
+    private $current = 0;
24 
+
25 
+    /** @var int */
26 
+    private $pos = 0;
27 
+
28 
+    /**
29 
+     * @param StreamInterface[] $streams Streams to decorate. Each stream must
30 
+     *                                   be readable.
31 
+     */
32 
+    public function __construct(array $streams = [])
33 
+    {
34 
+        foreach ($streams as $stream) {
35 
+            $this->addStream($stream);
36 
+        }
37 
+    }
38 
+
39 
+    public function __toString(): string
40 
+    {
41 
+        try {
42 
+            $this->rewind();
43 
+
44 
+            return $this->getContents();
45 
+        } catch (\Throwable $e) {
46 
+            if (\PHP_VERSION_ID >= 70400) {
47 
+                throw $e;
48 
+            }
49 
+            trigger_error(sprintf('%s::__toString exception: %s', self::class, (string) $e), E_USER_ERROR);
50 
+
51 
+            return '';
52 
+        }
53 
+    }
54 
+
55 
+    /**
56 
+     * Add a stream to the AppendStream
57 
+     *
58 
+     * @param StreamInterface $stream Stream to append. Must be readable.
59 
+     *
60 
+     * @throws \InvalidArgumentException if the stream is not readable
61 
+     */
62 
+    public function addStream(StreamInterface $stream): void
63 
+    {
64 
+        if (!$stream->isReadable()) {
65 
+            throw new \InvalidArgumentException('Each stream must be readable');
66 
+        }
67 
+
68 
+        // The stream is only seekable if all streams are seekable
69 
+        if (!$stream->isSeekable()) {
70 
+            $this->seekable = false;
71 
+        }
72 
+
73 
+        $this->streams[] = $stream;
74 
+    }
75 
+
76 
+    public function getContents(): string
77 
+    {
78 
+        return Utils::copyToString($this);
79 
+    }
80 
+
81 
+    /**
82 
+     * Closes each attached stream.
83 
+     */
84 
+    public function close(): void
85 
+    {
86 
+        $this->pos = $this->current = 0;
87 
+        $this->seekable = true;
88 
+
89 
+        foreach ($this->streams as $stream) {
90 
+            $stream->close();
91 
+        }
92 
+
93 
+        $this->streams = [];
94 
+    }
95 
+
96 
+    /**
97 
+     * Detaches each attached stream.
98 
+     *
99 
+     * Returns null as it's not clear which underlying stream resource to return.
100 
+     */
101 
+    public function detach()
102 
+    {
103 
+        $this->pos = $this->current = 0;
104 
+        $this->seekable = true;
105 
+
106 
+        foreach ($this->streams as $stream) {
107 
+            $stream->detach();
108 
+        }
109 
+
110 
+        $this->streams = [];
111 
+
112 
+        return null;
113 
+    }
114 
+
115 
+    public function tell(): int
116 
+    {
117 
+        return $this->pos;
118 
+    }
119 
+
120 
+    /**
121 
+     * Tries to calculate the size by adding the size of each stream.
122 
+     *
123 
+     * If any of the streams do not return a valid number, then the size of the
124 
+     * append stream cannot be determined and null is returned.
125 
+     */
126 
+    public function getSize(): ?int
127 
+    {
128 
+        $size = 0;
129 
+
130 
+        foreach ($this->streams as $stream) {
131 
+            $s = $stream->getSize();
132 
+            if ($s === null) {
133 
+                return null;
134 
+            }
135 
+            $size += $s;
136 
+        }
137 
+
138 
+        return $size;
139 
+    }
140 
+
141 
+    public function eof(): bool
142 
+    {
143 
+        return !$this->streams
144 
+            || ($this->current >= count($this->streams) - 1
145 
+             && $this->streams[$this->current]->eof());
146 
+    }
147 
+
148 
+    public function rewind(): void
149 
+    {
150 
+        $this->seek(0);
151 
+    }
152 
+
153 
+    /**
154 
+     * Attempts to seek to the given position. Only supports SEEK_SET.
155 
+     */
156 
+    public function seek($offset, $whence = SEEK_SET): void
157 
+    {
158 
+        if (!$this->seekable) {
159 
+            throw new \RuntimeException('This AppendStream is not seekable');
160 
+        } elseif ($whence !== SEEK_SET) {
161 
+            throw new \RuntimeException('The AppendStream can only seek with SEEK_SET');
162 
+        }
163 
+
164 
+        $this->pos = $this->current = 0;
165 
+
166 
+        // Rewind each stream
167 
+        foreach ($this->streams as $i => $stream) {
168 
+            try {
169 
+                $stream->rewind();
170 
+            } catch (\Exception $e) {
171 
+                throw new \RuntimeException('Unable to seek stream '
172 
+                    .$i.' of the AppendStream', 0, $e);
173 
+            }
174 
+        }
175 
+
176 
+        // Seek to the actual position by reading from each stream
177 
+        while ($this->pos < $offset && !$this->eof()) {
178 
+            $result = $this->read(min(8096, $offset - $this->pos));
179 
+            if ($result === '') {
180 
+                break;
181 
+            }
182 
+        }
183 
+    }
184 
+
185 
+    /**
186 
+     * Reads from all of the appended streams until the length is met or EOF.
187 
+     */
188 
+    public function read($length): string
189 
+    {
190 
+        $buffer = '';
191 
+        $total = count($this->streams) - 1;
192 
+        $remaining = $length;
193 
+        $progressToNext = false;
194 
+
195 
+        while ($remaining > 0) {
196 
+            // Progress to the next stream if needed.
197 
+            if ($progressToNext || $this->streams[$this->current]->eof()) {
198 
+                $progressToNext = false;
199 
+                if ($this->current === $total) {
200 
+                    break;
201 
+                }
202 
+                ++$this->current;
203 
+            }
204 
+
205 
+            $result = $this->streams[$this->current]->read($remaining);
206 
+
207 
+            if ($result === '') {
208 
+                $progressToNext = true;
209 
+                continue;
210 
+            }
211 
+
212 
+            $buffer .= $result;
213 
+            $remaining = $length - strlen($buffer);
214 
+        }
215 
+
216 
+        $this->pos += strlen($buffer);
217 
+
218 
+        return $buffer;
219 
+    }
220 
+
221 
+    public function isReadable(): bool
222 
+    {
223 
+        return true;
224 
+    }
225 
+
226 
+    public function isWritable(): bool
227 
+    {
228 
+        return false;
229 
+    }
230 
+
231 
+    public function isSeekable(): bool
232 
+    {
233 
+        return $this->seekable;
234 
+    }
235 
+
236 
+    public function write($string): int
237 
+    {
238 
+        throw new \RuntimeException('Cannot write to an AppendStream');
239 
+    }
240 
+
241 
+    /**
242 
+     * @return mixed
243 
+     */
244 
+    public function getMetadata($key = null)
245 
+    {
246 
+        return $key ? null : [];
247 
+    }
248 
+}
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/AppendStream.php
History View file @ b79bd44
1 1 
deleted file mode 100644
... ... 
@@ -1,244 +0,0 @@
1 
-<?php
2 
-
3 
-namespace GuzzleHttp\Psr7;
4 
-
5 
-use Psr\Http\Message\StreamInterface;
6 
-
7 
-/**
8 
- * Reads from multiple streams, one after the other.
9 
- *
10 
- * This is a read-only stream decorator.
11 
- */
12 
-class AppendStream implements StreamInterface
13 
-{
14 
-    /** @var StreamInterface[] Streams being decorated */
15 
-    private $streams = [];
16 
-
17 
-    private $seekable = true;
18 
-    private $current = 0;
19 
-    private $pos = 0;
20 
-
21 
-    /**
22 
-     * @param StreamInterface[] $streams Streams to decorate. Each stream must
23 
-     *                                   be readable.
24 
-     */
25 
-    public function __construct(array $streams = [])
26 
-    {
27 
-        foreach ($streams as $stream) {
28 
-            $this->addStream($stream);
29 
-        }
30 
-    }
31 
-
32 
-    public function __toString()
33 
-    {
34 
-        try {
35 
-            $this->rewind();
36 
-            return $this->getContents();
37 
-        } catch (\Exception $e) {
38 
-            return '';
39 
-        }
40 
-    }
41 
-
42 
-    /**
43 
-     * Add a stream to the AppendStream
44 
-     *
45 
-     * @param StreamInterface $stream Stream to append. Must be readable.
46 
-     *
47 
-     * @throws \InvalidArgumentException if the stream is not readable
48 
-     */
49 
-    public function addStream(StreamInterface $stream)
50 
-    {
51 
-        if (!$stream->isReadable()) {
52 
-            throw new \InvalidArgumentException('Each stream must be readable');
53 
-        }
54 
-
55 
-        // The stream is only seekable if all streams are seekable
56 
-        if (!$stream->isSeekable()) {
57 
-            $this->seekable = false;
58 
-        }
59 
-
60 
-        $this->streams[] = $stream;
61 
-    }
62 
-
63 
-    public function getContents()
64 
-    {
65 
-        return Utils::copyToString($this);
66 
-    }
67 
-
68 
-    /**
69 
-     * Closes each attached stream.
70 
-     *
71 
-     * {@inheritdoc}
72 
-     */
73 
-    public function close()
74 
-    {
75 
-        $this->pos = $this->current = 0;
76 
-        $this->seekable = true;
77 
-
78 
-        foreach ($this->streams as $stream) {
79 
-            $stream->close();
80 
-        }
81 
-
82 
-        $this->streams = [];
83 
-    }
84 
-
85 
-    /**
86 
-     * Detaches each attached stream.
87 
-     *
88 
-     * Returns null as it's not clear which underlying stream resource to return.
89 
-     *
90 
-     * {@inheritdoc}
91 
-     */
92 
-    public function detach()
93 
-    {
94 
-        $this->pos = $this->current = 0;
95 
-        $this->seekable = true;
96 
-
97 
-        foreach ($this->streams as $stream) {
98 
-            $stream->detach();
99 
-        }
100 
-
101 
-        $this->streams = [];
102 
-
103 
-        return null;
104 
-    }
105 
-
106 
-    public function tell()
107 
-    {
108 
-        return $this->pos;
109 
-    }
110 
-
111 
-    /**
112 
-     * Tries to calculate the size by adding the size of each stream.
113 
-     *
114 
-     * If any of the streams do not return a valid number, then the size of the
115 
-     * append stream cannot be determined and null is returned.
116 
-     *
117 
-     * {@inheritdoc}
118 
-     */
119 
-    public function getSize()
120 
-    {
121 
-        $size = 0;
122 
-
123 
-        foreach ($this->streams as $stream) {
124 
-            $s = $stream->getSize();
125 
-            if ($s === null) {
126 
-                return null;
127 
-            }
128 
-            $size += $s;
129 
-        }
130 
-
131 
-        return $size;
132 
-    }
133 
-
134 
-    public function eof()
135 
-    {
136 
-        return !$this->streams ||
137 
-            ($this->current >= count($this->streams) - 1 &&
138 
-             $this->streams[$this->current]->eof());
139 
-    }
140 
-
141 
-    public function rewind()
142 
-    {
143 
-        $this->seek(0);
144 
-    }
145 
-
146 
-    /**
147 
-     * Attempts to seek to the given position. Only supports SEEK_SET.
148 
-     *
149 
-     * {@inheritdoc}
150 
-     */
151 
-    public function seek($offset, $whence = SEEK_SET)
152 
-    {
153 
-        if (!$this->seekable) {
154 
-            throw new \RuntimeException('This AppendStream is not seekable');
155 
-        } elseif ($whence !== SEEK_SET) {
156 
-            throw new \RuntimeException('The AppendStream can only seek with SEEK_SET');
157 
-        }
158 
-
159 
-        $this->pos = $this->current = 0;
160 
-
161 
-        // Rewind each stream
162 
-        foreach ($this->streams as $i => $stream) {
163 
-            try {
164 
-                $stream->rewind();
165 
-            } catch (\Exception $e) {
166 
-                throw new \RuntimeException('Unable to seek stream '
167 
-                    . $i . ' of the AppendStream', 0, $e);
168 
-            }
169 
-        }
170 
-
171 
-        // Seek to the actual position by reading from each stream
172 
-        while ($this->pos < $offset && !$this->eof()) {
173 
-            $result = $this->read(min(8096, $offset - $this->pos));
174 
-            if ($result === '') {
175 
-                break;
176 
-            }
177 
-        }
178 
-    }
179 
-
180 
-    /**
181 
-     * Reads from all of the appended streams until the length is met or EOF.
182 
-     *
183 
-     * {@inheritdoc}
184 
-     */
185 
-    public function read($length)
186 
-    {
187 
-        $buffer = '';
188 
-        $total = count($this->streams) - 1;
189 
-        $remaining = $length;
190 
-        $progressToNext = false;
191 
-
192 
-        while ($remaining > 0) {
193 
-
194 
-            // Progress to the next stream if needed.
195 
-            if ($progressToNext || $this->streams[$this->current]->eof()) {
196 
-                $progressToNext = false;
197 
-                if ($this->current === $total) {
198 
-                    break;
199 
-                }
200 
-                $this->current++;
201 
-            }
202 
-
203 
-            $result = $this->streams[$this->current]->read($remaining);
204 
-
205 
-            // Using a loose comparison here to match on '', false, and null
206 
-            if ($result == null) {
207 
-                $progressToNext = true;
208 
-                continue;
209 
-            }
210 
-
211 
-            $buffer .= $result;
212 
-            $remaining = $length - strlen($buffer);
213 
-        }
214 
-
215 
-        $this->pos += strlen($buffer);
216 
-
217 
-        return $buffer;
218 
-    }
219 
-
220 
-    public function isReadable()
221 
-    {
222 
-        return true;
223 
-    }
224 
-
225 
-    public function isWritable()
226 
-    {
227 
-        return false;
228 
-    }
229 
-
230 
-    public function isSeekable()
231 
-    {
232 
-        return $this->seekable;
233 
-    }
234 
-
235 
-    public function write($string)
236 
-    {
237 
-        throw new \RuntimeException('Cannot write to an AppendStream');
238 
-    }
239 
-
240 
-    public function getMetadata($key = null)
241 
-    {
242 
-        return $key ? null : [];
243 
-    }
244 
-}
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/AppendStream.php
History View file @ f3755e3
1 1 
new file mode 100644
... ... 
@@ -0,0 +1,244 @@
1 
+<?php
2 
+
3 
+namespace GuzzleHttp\Psr7;
4 
+
5 
+use Psr\Http\Message\StreamInterface;
6 
+
7 
+/**
8 
+ * Reads from multiple streams, one after the other.
9 
+ *
10 
+ * This is a read-only stream decorator.
11 
+ */
12 
+class AppendStream implements StreamInterface
13 
+{
14 
+    /** @var StreamInterface[] Streams being decorated */
15 
+    private $streams = [];
16 
+
17 
+    private $seekable = true;
18 
+    private $current = 0;
19 
+    private $pos = 0;
20 
+
21 
+    /**
22 
+     * @param StreamInterface[] $streams Streams to decorate. Each stream must
23 
+     *                                   be readable.
24 
+     */
25 
+    public function __construct(array $streams = [])
26 
+    {
27 
+        foreach ($streams as $stream) {
28 
+            $this->addStream($stream);
29 
+        }
30 
+    }
31 
+
32 
+    public function __toString()
33 
+    {
34 
+        try {
35 
+            $this->rewind();
36 
+            return $this->getContents();
37 
+        } catch (\Exception $e) {
38 
+            return '';
39 
+        }
40 
+    }
41 
+
42 
+    /**
43 
+     * Add a stream to the AppendStream
44 
+     *
45 
+     * @param StreamInterface $stream Stream to append. Must be readable.
46 
+     *
47 
+     * @throws \InvalidArgumentException if the stream is not readable
48 
+     */
49 
+    public function addStream(StreamInterface $stream)
50 
+    {
51 
+        if (!$stream->isReadable()) {
52 
+            throw new \InvalidArgumentException('Each stream must be readable');
53 
+        }
54 
+
55 
+        // The stream is only seekable if all streams are seekable
56 
+        if (!$stream->isSeekable()) {
57 
+            $this->seekable = false;
58 
+        }
59 
+
60 
+        $this->streams[] = $stream;
61 
+    }
62 
+
63 
+    public function getContents()
64 
+    {
65 
+        return Utils::copyToString($this);
66 
+    }
67 
+
68 
+    /**
69 
+     * Closes each attached stream.
70 
+     *
71 
+     * {@inheritdoc}
72 
+     */
73 
+    public function close()
74 
+    {
75 
+        $this->pos = $this->current = 0;
76 
+        $this->seekable = true;
77 
+
78 
+        foreach ($this->streams as $stream) {
79 
+            $stream->close();
80 
+        }
81 
+
82 
+        $this->streams = [];
83 
+    }
84 
+
85 
+    /**
86 
+     * Detaches each attached stream.
87 
+     *
88 
+     * Returns null as it's not clear which underlying stream resource to return.
89 
+     *
90 
+     * {@inheritdoc}
91 
+     */
92 
+    public function detach()
93 
+    {
94 
+        $this->pos = $this->current = 0;
95 
+        $this->seekable = true;
96 
+
97 
+        foreach ($this->streams as $stream) {
98 
+            $stream->detach();
99 
+        }
100 
+
101 
+        $this->streams = [];
102 
+
103 
+        return null;
104 
+    }
105 
+
106 
+    public function tell()
107 
+    {
108 
+        return $this->pos;
109 
+    }
110 
+
111 
+    /**
112 
+     * Tries to calculate the size by adding the size of each stream.
113 
+     *
114 
+     * If any of the streams do not return a valid number, then the size of the
115 
+     * append stream cannot be determined and null is returned.
116 
+     *
117 
+     * {@inheritdoc}
118 
+     */
119 
+    public function getSize()
120 
+    {
121 
+        $size = 0;
122 
+
123 
+        foreach ($this->streams as $stream) {
124 
+            $s = $stream->getSize();
125 
+            if ($s === null) {
126 
+                return null;
127 
+            }
128 
+            $size += $s;
129 
+        }
130 
+
131 
+        return $size;
132 
+    }
133 
+
134 
+    public function eof()
135 
+    {
136 
+        return !$this->streams ||
137 
+            ($this->current >= count($this->streams) - 1 &&
138 
+             $this->streams[$this->current]->eof());
139 
+    }
140 
+
141 
+    public function rewind()
142 
+    {
143 
+        $this->seek(0);
144 
+    }
145 
+
146 
+    /**
147 
+     * Attempts to seek to the given position. Only supports SEEK_SET.
148 
+     *
149 
+     * {@inheritdoc}
150 
+     */
151 
+    public function seek($offset, $whence = SEEK_SET)
152 
+    {
153 
+        if (!$this->seekable) {
154 
+            throw new \RuntimeException('This AppendStream is not seekable');
155 
+        } elseif ($whence !== SEEK_SET) {
156 
+            throw new \RuntimeException('The AppendStream can only seek with SEEK_SET');
157 
+        }
158 
+
159 
+        $this->pos = $this->current = 0;
160 
+
161 
+        // Rewind each stream
162 
+        foreach ($this->streams as $i => $stream) {
163 
+            try {
164 
+                $stream->rewind();
165 
+            } catch (\Exception $e) {
166 
+                throw new \RuntimeException('Unable to seek stream '
167 
+                    . $i . ' of the AppendStream', 0, $e);
168 
+            }
169 
+        }
170 
+
171 
+        // Seek to the actual position by reading from each stream
172 
+        while ($this->pos < $offset && !$this->eof()) {
173 
+            $result = $this->read(min(8096, $offset - $this->pos));
174 
+            if ($result === '') {
175 
+                break;
176 
+            }
177 
+        }
178 
+    }
179 
+
180 
+    /**
181 
+     * Reads from all of the appended streams until the length is met or EOF.
182 
+     *
183 
+     * {@inheritdoc}
184 
+     */
185 
+    public function read($length)
186 
+    {
187 
+        $buffer = '';
188 
+        $total = count($this->streams) - 1;
189 
+        $remaining = $length;
190 
+        $progressToNext = false;
191 
+
192 
+        while ($remaining > 0) {
193 
+
194 
+            // Progress to the next stream if needed.
195 
+            if ($progressToNext || $this->streams[$this->current]->eof()) {
196 
+                $progressToNext = false;
197 
+                if ($this->current === $total) {
198 
+                    break;
199 
+                }
200 
+                $this->current++;
201 
+            }
202 
+
203 
+            $result = $this->streams[$this->current]->read($remaining);
204 
+
205 
+            // Using a loose comparison here to match on '', false, and null
206 
+            if ($result == null) {
207 
+                $progressToNext = true;
208 
+                continue;
209 
+            }
210 
+
211 
+            $buffer .= $result;
212 
+            $remaining = $length - strlen($buffer);
213 
+        }
214 
+
215 
+        $this->pos += strlen($buffer);
216 
+
217 
+        return $buffer;
218 
+    }
219 
+
220 
+    public function isReadable()
221 
+    {
222 
+        return true;
223 
+    }
224 
+
225 
+    public function isWritable()
226 
+    {
227 
+        return false;
228 
+    }
229 
+
230 
+    public function isSeekable()
231 
+    {
232 
+        return $this->seekable;
233 
+    }
234 
+
235 
+    public function write($string)
236 
+    {
237 
+        throw new \RuntimeException('Cannot write to an AppendStream');
238 
+    }
239 
+
240 
+    public function getMetadata($key = null)
241 
+    {
242 
+        return $key ? null : [];
243 
+    }
244 
+}