ub_total + self.vat 147 
+        super(Purchase, self).save(*args, **kwargs)
148 
+
149 
+class Sale(GenericModel, models.Model):
150 
+    product = models.ForeignKey('Product', on_delete=models.DO_NOTHING, null=False, blank=False)
151 
+    store = models.ForeignKey('Store', on_delete=models.DO_NOTHING, null=False, blank=False)
152 
+    sku = models.ForeignKey('ProductSKU', on_delete=models.DO_NOTHING, null=False, blank=False)
153 
+    price = models.DecimalField(null=True, blank=True, decimal_places=2, max_digits=7)
154 
+    n_unit = models.DecimalField(blank=True, decimal_places=2, max_digits=7, null=True)
155 
+    unit_name = models.CharField(max_length=200, null=True)
156 
+    buyer = models.ForeignKey('Buyer', on_delete=models.DO_NOTHING, null=False, blank=False)
157 
+
158 
+
159 
+    sub_total = models.DecimalField(null=True, blank=True, decimal_places=2, max_digits=10)
160 
+    vat = models.DecimalField(null=True, blank=True, decimal_places=2, max_digits=10)
161 
+    total = models.DecimalField(null=True, blank=True, decimal_places=2, max_digits=10)
162 
+
163 
+    def save(self, *args, **kwargs):
164 
+        self.sub_total = self.price * self.n_unit
165 
+        self.vat  = self.sub_total * decimal.Decimal(VAT)
166 
+        self.total = self.sub_total + self.vat
167 
+        super(Sale, self).save(*args, **kwargs)
168 
+
93 169 
 class Product(GenericModel, models.Model ):
94 170 
     name = models.CharField(max_length=200)
95 171 
     code = models.CharField(max_length=200)
96 172 
     product_type = TreeForeignKey('ProductType', on_delete=models.SET_NULL, null=True)
97 173 
     description = models.TextField(blank=True, null=True)
98 174 
     store = models.ForeignKey('Store', on_delete=models.CASCADE, null=True, blank=False)
99 
-    price = models.DecimalField(null=True, blank=True, decimal_places=2, max_digits=7)
175 
+    price = models.DecimalField(null=True, blank=True, decimal_places=2, max_digits=10)
176 
+
177 
+
178 
+    details  = models.JSONField(null=True, blank=True)
179 
+
180 
+    n_unit = models.DecimalField(blank=True, decimal_places=2, max_digits=7, null=True)
181 
+    unit_name = models.CharField(max_length=200, null=True)
182 
+
183 
+    def __str__(self):
184 
+        return f"{self.name} {self.code}"
185 
+
186 
+class Vendor(GenericModel, models.Model ):
187 
+    name = models.CharField(max_length=200)
188 
+    code = models.CharField(max_length=200)
189 
+    #product_type = TreeForeignKey('ProductType', on_delete=models.SET_NULL, null=True)
190 
+    product = models.ForeignKey('Product', on_delete=models.CASCADE)
191 
+    description = models.TextField(blank=True, null=True)
192 
+    store = models.ForeignKey('Store', on_delete=models.CASCADE, null=True, blank=False)
193 
+    price = models.DecimalField(null=True, blank=True, decimal_places=2, max_digits=10)
194 
+
100 195
101 196 
     details  = models.JSONField(null=True, blank=True)
102 197
103 198 
     n_unit = models.DecimalField(blank=True, decimal_places=2, max_digits=7, null=True)
104 199 
     unit_name = models.CharField(max_length=200, null=True)
105 200
201 
+    tel = models.CharField(max_length=100, null=True, blank=True)
202 
+    line_id = models.CharField(max_length=100, null=True, blank=True)
203 
+    email = models.EmailField(null=True, blank=True)
204 
+
205 
+    address_text = models.TextField(blank=False, null=False)
206 
+    address = map_fields.AddressField(max_length=200)
207 
+    geolocation = map_fields.GeoLocationField(max_length=100)
208 
+
209 
+
106 210 
     def __str__(self):
107 211 
         return f"{self.name} {self.code}"
108 212
213 
+
109 214 
 class ProductSKU(GenericModel, models.Model ):
110 215 
     sku = models.CharField(max_length=200)
111 216 
     product  = models.ForeignKey('Product', on_delete=models.CASCADE, null=True)
@@ -117,8 +222,12 @@ class ProductSKU(GenericModel, models.Model ):
117 222 
     n_unit = models.DecimalField(blank=True, decimal_places=2, max_digits=7, null=True)
118 223 
     unit_name = models.CharField(max_length=200, null=True)
119 224
225 
+    def __str__(self):
226 
+        return f"{self.sku} {self.product} @{self.price}(THB)"
227 
+
120 228 
 class Photo(GenericModel, models.Model):
121 229 
     name = models.CharField(max_length=200,  blank=True)
230 
+    order_n = models.IntegerField(default=0, blank=True)
122 231 
     photo  = models.ImageField(upload_to="uploads/%Y/%m/%d/", blank=False, verbose_name="Photo")
123 232 
     product = models.ForeignKey('Product', on_delete=models.CASCADE, null=True)
124 233

+ 17 - 0
app/fruit/templates/fruit/_paging.html
Näytä tiedosto 

@@ -0,0 +1,17 @@
1 
+<div class="pagination">
2 
+    <span class="step-links">
3 
+        {% if page_obj.has_previous %}
4 
+            <a href="?page=1">&laquo; first</a>
5 
+            <a href="?page={{ page_obj.previous_page_number }}">previous</a>
6 
+        {% endif %}
7 
+
8 
+        <span class="current">
9 
+            Page {{ page_obj.number }} of {{ page_obj.paginator.num_pages }}.
10 
+        </span>
11 
+
12 
+        {% if page_obj.has_next %}
13 
+            <a href="?page={{ page_obj.next_page_number }}">next</a>
14 
+            <a href="?page={{ page_obj.paginator.num_pages }}">last &raquo;</a>
15 
+        {% endif %}
16 
+    </span>
17 
+</div>

+ 13 - 0
app/fruit/templates/fruit/_searchcenter.html
Näytä tiedosto 

@@ -0,0 +1,13 @@
1 
+{% load crispy_forms_tags %}
2 
+<form method="get">
3 
+    <div class='row'>
4 
+        <!--
5 
+            {{ filter.form.fields }} -->
6 
+    {% for f0  in filter.form %}
7 
+        <div class='col-md-3'>
8 
+            {{ f0 | as_crispy_field}}
9 
+        </div>
10 
+    {% endfor %}
11 
+    </div>
12 
+    <input type="submit" class='btn btn-primary' value='Search'/>
13 
+</form>

+ 25 - 0
app/fruit/templates/fruit/inbox_form.html
Näytä tiedosto 

@@ -0,0 +1,25 @@
1 
+{% extends "fruit/inbox_index.html" %}
2 
+{% load static %}
3 
+{% load crispy_forms_tags %}
4 
+{% load django_bootstrap_breadcrumbs %}
5 
+
6 
+{% block header %}
7 
+{{ form.media  }}
8 
+{% endblock %}
9 
+
10 
+{% block breadcrumbs %}
11 
+    {{ block.super }}
12 
+    {% breadcrumb "Inbox Form" "fruit:inbox_edit" form.instance.pk %}
13 
+{% endblock %}
14 
+
15 
+{% block store_main %}
16 
+<h2>Inbox Form</h2>
17 
+<form  method="post" enctype="multipart/form-data">
18 
+    {% csrf_token %}
19 
+    {{ form | crispy  }}
20 
+    <br>
21 
+    <input type='submit' class='btn btn-primary' value="Update" />
22 
+
23 
+</form>
24 
+
25 
+{% endblock %}

+ 50 - 0
app/fruit/templates/fruit/inbox_index.html
Näytä tiedosto 

@@ -0,0 +1,50 @@
1 
+{% extends "fruit/mystore.html" %}
2 
+{% load static %}
3 
+{% load crispy_forms_tags %}
4 
+
5 
+{% block header %}
6 
+{% endblock %}
7 
+
8 
+{% load django_bootstrap_breadcrumbs %}
9 
+{% block breadcrumbs %}
10 
+    {{ block.super }}
11 
+    {% breadcrumb "Inboxes" "fruit:inbox_index" %}
12 
+{% endblock %}
13 
+
14 
+{% block store_main %}
15 
+<!--
16 
+<a  class='btn btn-primary' href="{% url "fruit:product_create" %}">Create Product</a> -->
17 
+<hr>
18 
+<h2>
19 
+    Inbox Index</h2>
20 
+{% include "fruit/_searchcenter.html" %}
21 
+<hr>
22 
+<table class='table table-borded table-striped'>
23 
+    <thead>
24 
+        <tr>
25 
+            <th>ID</th>
26 
+            <th>Store</th>
27 
+            <th>Product</th>
28 
+            <th>Buyer</th>
29 
+            <th>Subject</th>
30 
+            <th>Body</th>
31 
+            <th>Status</th>
32 
+            <th>Created At</th></tr>
33 
+    </thead>
34 
+    <tbody>
35 
+{% for p in page_obj %}
36 
+        <tr>
37 
+            <td><a href="{% url "fruit:inbox_edit" pk=p.pk %}">{{ p.id }}</a></td><td>{{ p.product }}</td>
38 
+            <td>{{ p.store}}</td>
39 
+            <td>{{ p.product }}</td>
40 
+            <td>{{ p.buyer }}</td>
41 
+            <td>{{ p.subject }}</td>
42 
+            <td>{{ p.body }}</td>
43 
+            <td>{{ p.status }}</td>
44 
+            <td>{{ p.created_at }}</td>
45 
+        </tr>
46 
+{% endfor %}
47 
+    </tbody>
48 
+</table>
49 
+{% include "fruit/_paging.html" %}
50 
+{% endblock %}

+ 12 - 3
app/fruit/templates/fruit/mystore.html
Näytä tiedosto 

@@ -1,6 +1,7 @@
1 1 
 {% extends "front/base.html" %}
2 2 
 {% load static %}
3 3 
 {% load crispy_forms_tags %}
4 
+{% load django_bootstrap_breadcrumbs %}
4 5
5 6 
 {% block header %}
6 7 
 {{ storeForm.media  }}
 
@@ -8,21 +9,29 @@
8 9
9 10 
 {% block content %}
10 11 
 <h1>My Store</h1>
12 
+<!--
11 13 
 <form method=post>
12 14 
     {% csrf_token %}
13 15 
     <input type='text' name='name' class='form-control' placeholder='Store Name'/>
14 16 
     <input type='submit' class='btn btn-primary' name='createStore' value="Create Store" />
15 17 
 </form>
16 
-<hr>
18 
+<hr> -->
17 19 
 <div class="d-flex align-items-start">
18 20 
   <div class="nav flex-column nav-pills me-3 col-md-3 col-lg-2" id="v-pills-tab" role="tablist" aria-orientation="vertical">
19 21 
       <a class="nav-link {{ mystore|yesno:"active," }}" id="v-pills-home-tab"  href="{% url "fruit:mystore" %}" type="button" role="tab" aria-controls="v-pills-home" aria-selected="true">Info</a>
20 22 
       <a class="nav-link {{ product|yesno:"active," }}" id="v-pills-profile-tab"  href="{% url "fruit:product_index" %}" type="button" role="tab" aria-controls="v-pills-profile" aria-selected="false">Products</a>
21 
-    <a class="nav-link" id="v-pills-messages-tab" data-toggle="pill" data-bs-target="#v-pills-messages" type="button" role="tab" aria-controls="v-pills-messages" aria-selected="false">Inbox</a>
22 
-    <a class="nav-link" id="v-pills-settings-tab" data-toggle="pill" data-bs-target="#v-pills-settings" type="button" role="tab" aria-controls="v-pills-settings" aria-selected="false">Saled Items</a>
23 
+    <a class="nav-link" id="v-pills-messages-tab" href="{% url "fruit:inbox_index" %}" type="button" role="tab" aria-controls="v-pills-messages" aria-selected="false">Inbox</a>
24 
+    <a class="nav-link {{ sale_active|yesno:"active," }}" id="v-pills-settings-tab" href="{% url "fruit:sale_index" %}"  type="button" role="tab" aria-controls="v-pills-settings" aria-selected="false">Saled Items</a>
23 25 
     <a class="nav-link" id="v-pills-vendor-tab" data-toggle="pill" data-bs-target="#v-pills-vendor" type="button" role="tab" aria-controls="v-pills-vendor" aria-selected="false">Vendors</a>
24 26 
   </div>
25 27 
   <div class="tab-content p-3 col-md-9 col-lg-10" id="v-pills-tabContent">
28 
+      {% block breadcrumbs %}
29 
+          {% clear_breadcrumbs %}
30 
+          {% breadcrumb "My Store" "fruit:mystore" %}
31 
+      {% endblock %}
32 
+
33 
+
34 
+    {% render_breadcrumbs %}
26 35 
       {% block store_main %}
27 36 
       {% endblock %}
28 37 
   </div>

+ 36 - 30
app/fruit/templates/fruit/product_form.html
Näytä tiedosto 

@@ -1,4 +1,4 @@
1 
-{% extends "fruit/mystore.html" %}
1 
+{% extends "fruit/product_index.html" %}
2 2 
 {% load static %}
3 3 
 {% load crispy_forms_tags %}
4 4 
 
@@ -7,41 +7,47 @@
7 7 
 {{ form2.media  }}
8 8 
 {% endblock %}
9 9
10 
+{% load django_bootstrap_breadcrumbs %}
11 
+{% block breadcrumbs %}
12 
+    {{ block.super }}
13 
+    {% breadcrumb "Product Edit" "fruit:product_edit" pid  %}
14 
+{% endblock %}
15 
+
10 16 
 {% block store_main %}
11 17 
     Create Product
12 18
19 
+
13 20 
 <form  method="post" enctype="multipart/form-data">
14 21 
     {% csrf_token %}
15 22 
     {{ form | crispy  }}
16 
-    <fieldset class="border p-2">
17 
-        <legend class='w-auto d-inline-block form-legend p-3'>Photos</legend>
18 
-        {{ form2.management_form }}
19 
-        <div class='row'>
20 
-        {% for f0  in form2 %}
21 
-        <div class='col-md-3'>
22 
-        <!-- {{ f0.fields }} -->
23 
-
24 
-            {{ f0.id  | as_crispy_field }}
25 
-            {{ f0.name | as_crispy_field }}
26 
-            {% if f0.instance.photo %}
27 
-            <a href="{{ f0.instance.photo.url }}" target="_blank">
28 
-                <img src="{{ f0.instance.photo.url  }}" width='100%' style='max-height:200px'></a>
29 
-            {% endif %}
30 
-            {{ f0.photo | as_crispy_field }}
31 
-
32 
-            {{ f0.product | as_crispy_field }}
33 
-            {{ f0.DELETE | as_crispy_field }}
34 
-        </div>
35 
-        {% endfor %}
36 
-        </div>
37 
-    </fieldset>
38 
-    <br>
39 
-    <input type='submit' class='btn btn-primary' name='updateStore' value="Update" />
23 
+        <fieldset class="border p-2 row">
24 
+            <legend class='w-auto d-inline-block form-legend p-3'>Photos</legend>
25 
+            {{ form2.management_form }}
26 
+            {% for f0  in form2 %}
27 
+            <div class='col-md-3 border'>
28 
+            <!-- {{ f0.fields }} -->
29 
+
30 
+                {{ f0.id  | as_crispy_field }}
31 
+                {{ f0.name | as_crispy_field }}
32 
+                {% if f0.instance.photo %}
33 
+                <a href="{{ f0.instance.photo.url }}" target="_blank">
34 
+                    <img src="{{ f0.instance.photo.url  }}" width='100%' style='max-height:200px'></a>
35 
+                {% endif %}
36 
+                {{ f0.photo | as_crispy_field }}
37 
+
38 
+                {{ f0.order_n  | as_crispy_field }}
39 
+                {{ f0.product | as_crispy_field }}
40 
+                {{ f0.DELETE | as_crispy_field }}
41 
+            </div>
42 
+            {% endfor %}
43 
+        </fieldset>
44 
+        <br>
45 
+        <input type='submit' class='btn btn-primary' name='updateStore' value="Update" />
40 46
41 
-</form>
42 
-<hr>
43 
-<h2>SKUs</h2>
44 
-<a href="{% url "fruit:create_sku" pk=object.pk %}" class='btn btn-primary'>Create SKU</a><br><br>
47 
+    </form>
48 
+    <hr>
49 
+    <h2>SKUs</h2>
50 
+    <a href="{% url "fruit:create_sku" pk=obj.pk %}" class='btn btn-primary'>Create SKU</a><br><br>
45 51
46 52 
 <table class='table table-bordered  table-striped'>
47 53 
     <thead>
 
@@ -50,7 +56,7 @@
50 56 
     </thead>
51 57 
     <tbody>
52 58
53 
-        {% for o in  object.productsku_set.all %}
59 
+        {% for o in  obj.productsku_set.all %}
54 60 
             <tr>
55 61 
                 <td><a href="{% url "fruit:edit_sku" pk=o.pk %}">{{ o.sku }}</a></td>
56 62 
                 <td>{{ o.created_at }}</td>

+ 17 - 6
app/fruit/templates/fruit/product_index.html
Näytä tiedosto 

@@ -5,21 +5,32 @@
5 5 
 {% block header %}
6 6 
 {% endblock %}
7 7
8 
+{% load django_bootstrap_breadcrumbs %}
9 
+{% block breadcrumbs %}
10 
+    {{ block.super }}
11 
+    {% breadcrumb "Products" "fruit:product_index" %}
12 
+{% endblock %}
13 
+
8 14 
 {% block store_main %}
9 
-<a  href="{% url "fruit:product_create" %}">Create Product</a>
15 
+<a  class='btn btn-primary' href="{% url "fruit:product_create" %}">Create Product</a>
16 
+<hr>
17 
+<h2>
18 
+    Product Index</h2>
19 
+{% include "fruit/_searchcenter.html" %}
10 20 
 <hr>
11 
-Product Index
12 
-{{ products }}
21 
+<!--
22 
+    {{ products }} -->
13 23 
 <table class='table table-borded table-striped'>
14 24 
     <thead>
15 
-        <tr><th>ID</th><th>Name</th><th>Created At</th></tr>
25 
+        <tr><th>ID</th><th>Name</th><th>Price</th><th>Created At</th></tr>
16 26 
     </thead>
17 27 
     <tbody>
18 
-{% for p in products %}
28 
+{% for p in page_obj %}
19 29 
         <tr>
20 
-            <td><a href="{% url "fruit:product_edit" pk=p.pk %}">{{ p.id }}</a></td><td>{{ p.name }}</td><td>{{ p.created_at }}</td>
30 
+            <td><a href="{% url "fruit:product_edit" pk=p.pk %}">{{ p.id }}</a></td><td>{{ p.name }}</td><td>{% firstof p.price  "-" %}</td><td>{{ p.created_at }}</td>
21 31 
         </tr>
22 32 
 {% endfor %}
23 33 
     </tbody>
24 34 
 </table>
35 
+{% include "fruit/_paging.html" %}
25 36 
 {% endblock %}

+ 25 - 0
app/fruit/templates/fruit/sale_form.html
Näytä tiedosto 

@@ -0,0 +1,25 @@
1 
+{% extends "fruit/sale_index.html" %}
2 
+{% load static %}
3 
+{% load crispy_forms_tags %}
4 
+{% load django_bootstrap_breadcrumbs %}
5 
+
6 
+{% block header %}
7 
+{{ form.media  }}
8 
+{% endblock %}
9 
+
10 
+{% block breadcrumbs %}
11 
+    {{ block.super }}
12 
+    {% breadcrumb "Sales Form" "fruit:sale_edit" form.instance.pk %}
13 
+{% endblock %}
14 
+
15 
+{% block store_main %}
16 
+<h2>Sale Form</h2>
17 
+<form  method="post" enctype="multipart/form-data">
18 
+    {% csrf_token %}
19 
+    {{ form | crispy  }}
20 
+    <br>
21 
+    <input type='submit' class='btn btn-primary' value="Update" />
22 
+
23 
+</form>
24 
+
25 
+{% endblock %}

+ 41 - 0
app/fruit/templates/fruit/sale_index.html
Näytä tiedosto 

@@ -0,0 +1,41 @@
1 
+{% extends "fruit/mystore.html" %}
2 
+{% load static %}
3 
+{% load crispy_forms_tags %}
4 
+
5 
+{% block header %}
6 
+{% endblock %}
7 
+
8 
+{% load django_bootstrap_breadcrumbs %}
9 
+{% block breadcrumbs %}
10 
+    {{ block.super }}
11 
+    {% breadcrumb "Sales" "fruit:sale_index" %}
12 
+{% endblock %}
13 
+
14 
+{% block store_main %}
15 
+<!--
16 
+<a  class='btn btn-primary' href="{% url "fruit:product_create" %}">Create Product</a> -->
17 
+<hr>
18 
+<h2>
19 
+    Sale Index</h2>
20 
+{% include "fruit/_searchcenter.html" %}
21 
+<hr>
22 
+<table class='table table-borded table-striped'>
23 
+    <thead>
24 
+        <tr><th>ID</th><th>Product</th><th>SKU</th><th>Price</th><th>Unit(s)</th><th>UName</th><th>Total</th><th>Buyer</th><th>Created At</th></tr>
25 
+    </thead>
26 
+    <tbody>
27 
+{% for p in page_obj %}
28 
+        <tr>
29 
+            <td><a href="{% url "fruit:sale_edit" pk=p.pk %}">{{ p.id }}</a></td><td>{{ p.product }}</td>
30 
+            <td>{{ p.sku }}</td>
31 
+            <td>{{ p.n_unit }}</td>
32 
+            <td>{{ p.unit_name }}</td>
33 
+            <td>{{ p.total }}</td>
34 
+            <td>{{ p.buyer }}</td>
35 
+            <td>{% firstof p.price  "-" %}</td><td>{{ p.created_at }}</td>
36 
+        </tr>
37 
+{% endfor %}
38 
+    </tbody>
39 
+</table>
40 
+{% include "fruit/_paging.html" %}
41 
+{% endblock %}

+ 7 - 1
app/fruit/templates/fruit/sku_form.html
Näytä tiedosto 

@@ -1,4 +1,4 @@
1 
-{% extends "fruit/mystore.html" %}
1 
+{% extends "fruit/product_form.html" %}
2 2 
 {% load static %}
3 3 
 {% load crispy_forms_tags %}
4 4 
 
@@ -6,6 +6,12 @@
6 6 
 {{ form.media  }}
7 7 
 {% endblock %}
8 8
9 
+{% load django_bootstrap_breadcrumbs %}
10 
+{% block breadcrumbs %}
11 
+    {{ block.super }}
12 
+    {% breadcrumb "SKU Edit" "fruit:sku_edit" pk=form.instance.pk  %}
13 
+{% endblock %}
14 
+
9 15 
 {% block store_main %}
10 16 
     SKU Form
11 17

+ 4 - 0
app/fruit/urls.py
Näytä tiedosto 

@@ -11,6 +11,10 @@ urlpatterns = [
11 11 
     path('sku/<pk>', views.edit_sku, name='edit_sku'),
12 12 
     path('products/', views.product_index, name='product_index'),
13 13 
     path('products/<pk>', views.product_edit, name='product_edit'),
14 
+    path('sales/', views.sale_index, name='sale_index'),
15 
+    path('sales/<pk>', views.sale_edit, name='sale_edit'),
16 
+    path('inbox/', views.inbox_index, name='inbox_index'),
17 
+    path('inbox/<pk>', views.inbox_edit, name='inbox_edit'),
14 18 
     path('signup', views.signup, name='signup'),
15 19 
 ]
16 20

+ 98 - 6
app/fruit/views.py
Näytä tiedosto 

@@ -6,9 +6,10 @@ from django.contrib.auth.forms import UserCreationForm
6 6 
 from django.urls import reverse
7 7 
 from django.contrib.auth.decorators import login_required
8 8
9 
-from fruit.models import Store, Product, Photo, ProductSKU
10 
-from .forms import StoreForm, ProductForm, PhotoFormSet, InlinePhotoFormset, ProductSKUForm
9 
+from fruit.models import Store, Product, Photo, ProductSKU, Sale, Inbox
10 
+from .forms import StoreForm, ProductForm, InboxForm, SaleForm,  PhotoFormSet, InlinePhotoFormset, ProductSKUForm, ProductFilter, SaleFilter, InboxFilter
11 11 
 from django.contrib import messages
12 
+from django.core.paginator import Paginator
12 13
13 14
14 15 
 def index(request):
 
@@ -48,7 +49,27 @@ def mystore(request):
48 49 
 def product_index(request):
49 50 
     stores = request.user.store_created.all().order_by("-created_at")
50 51 
     products = stores[0].product_set.all().order_by("-created_at")
51 
-    return render(request, 'fruit/product_index.html', {'products': products, 'product': True})
52 
+
53 
+    f = ProductFilter(request.GET, queryset=products)
54 
+
55 
+    paginator = Paginator(f.qs, 25)
56 
+    page_number = request.GET.get('page')
57 
+    page_obj = paginator.get_page(page_number)
58 
+
59 
+    return render(request, 'fruit/product_index.html', {'products': products, 'product': True, 'page_obj': page_obj, 'filter': f})
60 
+
61 
+@login_required
62 
+def sale_index(request):
63 
+    stores = request.user.store_created.all().order_by("-created_at")
64 
+    o_qs = stores[0].sale_set.all().order_by("-created_at")
65 
+
66 
+    f = SaleFilter(request.GET, queryset=o_qs)
67 
+
68 
+    paginator = Paginator(f.qs, 25)
69 
+    page_number = request.GET.get('page')
70 
+    page_obj = paginator.get_page(page_number)
71 
+
72 
+    return render(request, 'fruit/sale_index.html', {'o_qs': o_qs, 'sale_active': True, 'page_obj': page_obj, 'filter': f})
52 73
53 74 
 @login_required
54 75 
 def create_product(request):
 
@@ -97,11 +118,14 @@ def create_sku(request, pk):
97 118 
             message.error(request, "SKU  created failed")
98 119 
             return redirect("fruit:create_sku", pk=int(pk))
99 120
100 
-    return render(request, 'fruit/sku_form.html', {'form': form})
121 
+    return render(request, 'fruit/sku_form.html', {'form': form, 'pid': p.pk})
101 122
102 123 
 @login_required
103 124 
 def edit_sku(request, pk):
125 
+
104 126 
     p = ProductSKU.objects.get(pk=pk)
127 
+    p0 = p.product
128 
+
105 129 
     form = ProductSKUForm(instance=p)
106 130 
     if request.method == "POST":
107 131 
         form = ProductSKUForm(request.POST)
 
@@ -113,7 +137,7 @@ def edit_sku(request, pk):
113 137 
             message.error(request, "SKU  created failed")
114 138 
             return redirect("fruit:create_sku", pk=int(pk))
115 139
116 
-    return render(request, 'fruit/sku_form.html', {'form': form})
140 
+    return render(request, 'fruit/sku_form.html', {'form': form, 'pid': p0.pk})
117 141
118 142 
 @login_required
119 143 
 def product_edit(request, pk):
 
@@ -151,7 +175,75 @@ def product_edit(request, pk):
151 175
152 176 
         return redirect("fruit:product_edit", pk =  int(pk))
153 177
154 
-    return render(request, 'fruit/product_form.html', {'product': True, 'form': form, 'form2': form2, 'object': product })
178 
+    return render(request, 'fruit/product_form.html', {'product': True, 'form': form, 'form2': form2, 'obj': product })
179 
+
180 
+@login_required
181 
+def sale_edit(request, pk):
182 
+    stores = request.user.store_created.all().order_by("-created_at")
183 
+
184 
+    obj = Sale.objects.get(pk=pk)
185 
+    form = SaleForm(instance = obj)
186 
+
187 
+    if request.method == "POST":
188 
+        form = SaleForm(request.POST)
189 
+        if form.is_valid():
190 
+            instance1 = form.save()
191 
+            '''
192 
+            print(instances)
193 
+            for s in instances:
194 
+                s.product = instance1
195 
+                s.save()
196 
+            '''
197 
+            messages.success(request, "Sale Save")
198 
+        else:
199 
+            print("Invalid ")
200 
+            if form.errors:
201 
+                messages.error(request, form.errors)
202 
+
203 
+        return redirect("fruit:sale_edit", pk =  int(pk))
204 
+
205 
+    return render(request, 'fruit/sale_form.html', {'sale_active': True, 'form': form, 'object': obj})
206 
+
207 
+
208 
+@login_required
209 
+def inbox_index(request):
210 
+    stores = request.user.store_created.all().order_by("-created_at")
211 
+    o_qs = stores[0].inbox_set.all().order_by("-created_at")
212 
+
213 
+    f = InboxFilter(request.GET, queryset=o_qs)
214 
+
215 
+    paginator = Paginator(f.qs, 25)
216 
+    page_number = request.GET.get('page')
217 
+    page_obj = paginator.get_page(page_number)
218 
+
219 
+    return render(request, 'fruit/inbox_index.html', {'o_qs': o_qs, 'inbox_active': True, 'page_obj': page_obj, 'filter': f})
220 
+
221 
+@login_required
222 
+def inbox_edit(request, pk):
223 
+    stores = request.user.store_created.all().order_by("-created_at")
224 
+
225 
+    obj = Inbox.objects.get(pk=pk)
226 
+    form = InboxForm(instance = obj)
227 
+
228 
+    if request.method == "POST":
229 
+        form = InboxForm(request.POST)
230 
+        if form.is_valid():
231 
+            instance1 = form.save()
232 
+            '''
233 
+            print(instances)
234 
+            for s in instances:
235 
+                s.product = instance1
236 
+                s.save()
237 
+            '''
238 
+            messages.success(request, "Sale Save")
239 
+        else:
240 
+            print("Invalid ")
241 
+            if form.errors:
242 
+                messages.error(request, form.errors)
243 
+
244 
+        return redirect("fruit:sale_edit", pk =  int(pk))
245 
+
246 
+    return render(request, 'fruit/inbox_form.html', {'inbox_active': True, 'form': form, 'object': obj})
155 247
156 248 
 def signup(request):
157 249 
     if request.method == 'POST':

+ 3 - 0
app/requirements.txt
Näytä tiedosto 

@@ -14,3 +14,6 @@ Pillow
14 14 
 django-quill-editor
15 15 
 django-taggit
16 16 
 django-crispy-forms
17 
+django-filter
18 
+django-paypal
19 
+django-bootstrap-breadcrumbs

BIN
app/shaqfindbed/__pycache__/settings.cpython-39.pyc
Näytä tiedosto


+ 3 - 0
app/shaqfindbed/settings.py
Näytä tiedosto 

@@ -47,12 +47,14 @@ INSTALLED_APPS = [
47 47 
     'dal_select2',
48 48 
     'mptt',
49 49 
     'django_google_maps',
50 
+    'django_bootstrap_breadcrumbs',
50 51 
     'django.contrib.admin',
51 52 
     'django.contrib.auth',
52 53 
     'django.contrib.contenttypes',
53 54 
     'django.contrib.sessions',
54 55 
     'django.contrib.messages',
55 56 
     'import_export',
57 
+    'django_filters',
56 58 
     'django_quill',
57 59 
     'crispy_forms',
58 60 
     'taggit',
 
@@ -171,3 +173,4 @@ LOGIN_REDIRECT_URL = '/fruit/mystore'
171 173 
 LOGIN_URL = '/login'
172 174
173 175 
 CRISPY_TEMPLATE_PACK = "bootstrap4"
176 
+BREADCRUMBS_TEMPLATE = "django_bootstrap_breadcrumbs/bootstrap4.html"

tum/whitesports - Gogs: Simplico Git Service
首頁 探索 說明
登入
tum
/
whitesports
關註 1
讚好 0
複刻 0
代碼 問題管理 0 合併請求 0 提交歷史 5 版本發佈 0 Wiki

暫無描述

目錄樹: 0b697c9ce1
分支列表 標籤列表
whitesports
/
app
/
wp-includes
/
class-reques...

class-requests.php 30KB
文件歷史 原始文件

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002 
  1. <?php
    2. 

  2. /**
    3. 

  3.  * Requests for PHP
    4. 

  4.  *
    5. 

  5.  * Inspired by Requests for Python.
    6. 

  6.  *
    7. 

  7.  * Based on concepts from SimplePie_File, RequestCore and WP_Http.
    8. 

  8.  *
    9. 

  9.  * @package Requests
    10. 

  10.  */
    11. 

  11. 

  12. /**
    13. 

  13.  * Requests for PHP
    14. 

  14.  *
    15. 

  15.  * Inspired by Requests for Python.
    16. 

  16.  *
    17. 

  17.  * Based on concepts from SimplePie_File, RequestCore and WP_Http.
    18. 

  18.  *
    19. 

  19.  * @package Requests
    20. 

  20.  */
    21. 

  21. class Requests {
    22. 

  22. 	/**
    23. 

  23. 	 * POST method
    24. 

  24. 	 *
    25. 

  25. 	 * @var string
    26. 

  26. 	 */
    27. 

  27. 	const POST = 'POST';
    28. 

  28. 

  29. 	/**
    30. 

  30. 	 * PUT method
    31. 

  31. 	 *
    32. 

  32. 	 * @var string
    33. 

  33. 	 */
    34. 

  34. 	const PUT = 'PUT';
    35. 

  35. 

  36. 	/**
    37. 

  37. 	 * GET method
    38. 

  38. 	 *
    39. 

  39. 	 * @var string
    40. 

  40. 	 */
    41. 

  41. 	const GET = 'GET';
    42. 

  42. 

  43. 	/**
    44. 

  44. 	 * HEAD method
    45. 

  45. 	 *
    46. 

  46. 	 * @var string
    47. 

  47. 	 */
    48. 

  48. 	const HEAD = 'HEAD';
    49. 

  49. 

  50. 	/**
    51. 

  51. 	 * DELETE method
    52. 

  52. 	 *
    53. 

  53. 	 * @var string
    54. 

  54. 	 */
    55. 

  55. 	const DELETE = 'DELETE';
    56. 

  56. 

  57. 	/**
    58. 

  58. 	 * OPTIONS method
    59. 

  59. 	 *
    60. 

  60. 	 * @var string
    61. 

  61. 	 */
    62. 

  62. 	const OPTIONS = 'OPTIONS';
    63. 

  63. 

  64. 	/**
    65. 

  65. 	 * TRACE method
    66. 

  66. 	 *
    67. 

  67. 	 * @var string
    68. 

  68. 	 */
    69. 

  69. 	const TRACE = 'TRACE';
    70. 

  70. 

  71. 	/**
    72. 

  72. 	 * PATCH method
    73. 

  73. 	 *
    74. 

  74. 	 * @link https://tools.ietf.org/html/rfc5789
    75. 

  75. 	 * @var string
    76. 

  76. 	 */
    77. 

  77. 	const PATCH = 'PATCH';
    78. 

  78. 

  79. 	/**
    80. 

  80. 	 * Default size of buffer size to read streams
    81. 

  81. 	 *
    82. 

  82. 	 * @var integer
    83. 

  83. 	 */
    84. 

  84. 	const BUFFER_SIZE = 1160;
    85. 

  85. 

  86. 	/**
    87. 

  87. 	 * Current version of Requests
    88. 

  88. 	 *
    89. 

  89. 	 * @var string
    90. 

  90. 	 */
    91. 

  91. 	const VERSION = '1.8.1';
    92. 

  92. 

  93. 	/**
    94. 

  94. 	 * Registered transport classes
    95. 

  95. 	 *
    96. 

  96. 	 * @var array
    97. 

  97. 	 */
    98. 

  98. 	protected static $transports = array();
    99. 

  99. 

  100. 	/**
    101. 

  101. 	 * Selected transport name
    102. 

  102. 	 *
    103. 

  103. 	 * Use {@see get_transport()} instead
    104. 

  104. 	 *
    105. 

  105. 	 * @var array
    106. 

  106. 	 */
    107. 

  107. 	public static $transport = array();
    108. 

  108. 

  109. 	/**
    110. 

  110. 	 * Default certificate path.
    111. 

  111. 	 *
    112. 

  112. 	 * @see Requests::get_certificate_path()
    113. 

  113. 	 * @see Requests::set_certificate_path()
    114. 

  114. 	 *
    115. 

  115. 	 * @var string
    116. 

  116. 	 */
    117. 

  117. 	protected static $certificate_path;
    118. 

  118. 

  119. 	/**
    120. 

  120. 	 * This is a static class, do not instantiate it
    121. 

  121. 	 *
    122. 

  122. 	 * @codeCoverageIgnore
    123. 

  123. 	 */
    124. 

  124. 	private function __construct() {}
    125. 

  125. 

  126. 	/**
    127. 

  127. 	 * Autoloader for Requests
    128. 

  128. 	 *
    129. 

  129. 	 * Register this with {@see register_autoloader()} if you'd like to avoid
    130. 

  130. 	 * having to create your own.
    131. 

  131. 	 *
    132. 

  132. 	 * (You can also use `spl_autoload_register` directly if you'd prefer.)
    133. 

  133. 	 *
    134. 

  134. 	 * @codeCoverageIgnore
    135. 

  135. 	 *
    136. 

  136. 	 * @param string $class Class name to load
    137. 

  137. 	 */
    138. 

  138. 	public static function autoloader($class) {
    139. 

  139. 		// Check that the class starts with "Requests"
    140. 

  140. 		if (strpos($class, 'Requests') !== 0) {
    141. 

  141. 			return;
    142. 

  142. 		}
    143. 

  143. 

  144. 		$file = str_replace('_', '/', $class);
    145. 

  145. 		if (file_exists(dirname(__FILE__) . '/' . $file . '.php')) {
    146. 

  146. 			require_once dirname(__FILE__) . '/' . $file . '.php';
    147. 

  147. 		}
    148. 

  148. 	}
    149. 

  149. 

  150. 	/**
    151. 

  151. 	 * Register the built-in autoloader
    152. 

  152. 	 *
    153. 

  153. 	 * @codeCoverageIgnore
    154. 

  154. 	 */
    155. 

  155. 	public static function register_autoloader() {
    156. 

  156. 		spl_autoload_register(array('Requests', 'autoloader'));
    157. 

  157. 	}
    158. 

  158. 

  159. 	/**
    160. 

  160. 	 * Register a transport
    161. 

  161. 	 *
    162. 

  162. 	 * @param string $transport Transport class to add, must support the Requests_Transport interface
    163. 

  163. 	 */
    164. 

  164. 	public static function add_transport($transport) {
    165. 

  165. 		if (empty(self::$transports)) {
    166. 

  166. 			self::$transports = array(
    167. 

  167. 				'Requests_Transport_cURL',
    168. 

  168. 				'Requests_Transport_fsockopen',
    169. 

  169. 			);
    170. 

  170. 		}
    171. 

  171. 

  172. 		self::$transports = array_merge(self::$transports, array($transport));
    173. 

  173. 	}
    174. 

  174. 

  175. 	/**
    176. 

  176. 	 * Get a working transport
    177. 

  177. 	 *
    178. 

  178. 	 * @throws Requests_Exception If no valid transport is found (`notransport`)
    179. 

  179. 	 * @return Requests_Transport
    180. 

  180. 	 */
    181. 

  181. 	protected static function get_transport($capabilities = array()) {
    182. 

  182. 		// Caching code, don't bother testing coverage
    183. 

  183. 		// @codeCoverageIgnoreStart
    184. 

  184. 		// array of capabilities as a string to be used as an array key
    185. 

  185. 		ksort($capabilities);
    186. 

  186. 		$cap_string = serialize($capabilities);
    187. 

  187. 

  188. 		// Don't search for a transport if it's already been done for these $capabilities
    189. 

  189. 		if (isset(self::$transport[$cap_string]) && self::$transport[$cap_string] !== null) {
    190. 

  190. 			$class = self::$transport[$cap_string];
    191. 

  191. 			return new $class();
    192. 

  192. 		}
    193. 

  193. 		// @codeCoverageIgnoreEnd
    194. 

  194. 

  195. 		if (empty(self::$transports)) {
    196. 

  196. 			self::$transports = array(
    197. 

  197. 				'Requests_Transport_cURL',
    198. 

  198. 				'Requests_Transport_fsockopen',
    199. 

  199. 			);
    200. 

  200. 		}
    201. 

  201. 

  202. 		// Find us a working transport
    203. 

  203. 		foreach (self::$transports as $class) {
    204. 

  204. 			if (!class_exists($class)) {
    205. 

  205. 				continue;
    206. 

  206. 			}
    207. 

  207. 

  208. 			$result = call_user_func(array($class, 'test'), $capabilities);
    209. 

  209. 			if ($result) {
    210. 

  210. 				self::$transport[$cap_string] = $class;
    211. 

  211. 				break;
    212. 

  212. 			}
    213. 

  213. 		}
    214. 

  214. 		if (self::$transport[$cap_string] === null) {
    215. 

  215. 			throw new Requests_Exception('No working transports found', 'notransport', self::$transports);
    216. 

  216. 		}
    217. 

  217. 

  218. 		$class = self::$transport[$cap_string];
    219. 

  219. 		return new $class();
    220. 

  220. 	}
    221. 

  221. 

  222. 	/**#@+
    223. 

  223. 	 * @see request()
    224. 

  224. 	 * @param string $url
    225. 

  225. 	 * @param array $headers
    226. 

  226. 	 * @param array $options
    227. 

  227. 	 * @return Requests_Response
    228. 

  228. 	 */
    229. 

  229. 	/**
    230. 

  230. 	 * Send a GET request
    231. 

  231. 	 */
    232. 

  232. 	public static function get($url, $headers = array(), $options = array()) {
    233. 

  233. 		return self::request($url, $headers, null, self::GET, $options);
    234. 

  234. 	}
    235. 

  235. 

  236. 	/**
    237. 

  237. 	 * Send a HEAD request
    238. 

  238. 	 */
    239. 

  239. 	public static function head($url, $headers = array(), $options = array()) {
    240. 

  240. 		return self::request($url, $headers, null, self::HEAD, $options);
    241. 

  241. 	}
    242. 

  242. 

  243. 	/**
    244. 

  244. 	 * Send a DELETE request
    245. 

  245. 	 */
    246. 

  246. 	public static function delete($url, $headers = array(), $options = array()) {
    247. 

  247. 		return self::request($url, $headers, null, self::DELETE, $options);
    248. 

  248. 	}
    249. 

  249. 

  250. 	/**
    251. 

  251. 	 * Send a TRACE request
    252. 

  252. 	 */
    253. 

  253. 	public static function trace($url, $headers = array(), $options = array()) {
    254. 

  254. 		return self::request($url, $headers, null, self::TRACE, $options);
    255. 

  255. 	}
    256. 

  256. 	/**#@-*/
    257. 

  257. 

  258. 	/**#@+
    259. 

  259. 	 * @see request()
    260. 

  260. 	 * @param string $url
    261. 

  261. 	 * @param array $headers
    262. 

  262. 	 * @param array $data
    263. 

  263. 	 * @param array $options
    264. 

  264. 	 * @return Requests_Response
    265. 

  265. 	 */
    266. 

  266. 	/**
    267. 

  267. 	 * Send a POST request
    268. 

  268. 	 */
    269. 

  269. 	public static function post($url, $headers = array(), $data = array(), $options = array()) {
    270. 

  270. 		return self::request($url, $headers, $data, self::POST, $options);
    271. 

  271. 	}
    272. 

  272. 	/**
    273. 

  273. 	 * Send a PUT request
    274. 

  274. 	 */
    275. 

  275. 	public static function put($url, $headers = array(), $data = array(), $options = array()) {
    276. 

  276. 		return self::request($url, $headers, $data, self::PUT, $options);
    277. 

  277. 	}
    278. 

  278. 

  279. 	/**
    280. 

  280. 	 * Send an OPTIONS request
    281. 

  281. 	 */
    282. 

  282. 	public static function options($url, $headers = array(), $data = array(), $options = array()) {
    283. 

  283. 		return self::request($url, $headers, $data, self::OPTIONS, $options);
    284. 

  284. 	}
    285. 

  285. 

  286. 	/**
    287. 

  287. 	 * Send a PATCH request
    288. 

  288. 	 *
    289. 

  289. 	 * Note: Unlike {@see post} and {@see put}, `$headers` is required, as the
    290. 

  290. 	 * specification recommends that should send an ETag
    291. 

  291. 	 *
    292. 

  292. 	 * @link https://tools.ietf.org/html/rfc5789
    293. 

  293. 	 */
    294. 

  294. 	public static function patch($url, $headers, $data = array(), $options = array()) {
    295. 

  295. 		return self::request($url, $headers, $data, self::PATCH, $options);
    296. 

  296. 	}
    297. 

  297. 	/**#@-*/
    298. 

  298. 

  299. 	/**
    300. 

  300. 	 * Main interface for HTTP requests
    301. 

  301. 	 *
    302. 

  302. 	 * This method initiates a request and sends it via a transport before
    303. 

  303. 	 * parsing.
    304. 

  304. 	 *
    305. 

  305. 	 * The `$options` parameter takes an associative array with the following
    306. 

  306. 	 * options:
    307. 

  307. 	 *
    308. 

  308. 	 * - `timeout`: How long should we wait for a response?
    309. 

  309. 	 *    Note: for cURL, a minimum of 1 second applies, as DNS resolution
    310. 

  310. 	 *    operates at second-resolution only.
    311. 

  311. 	 *    (float, seconds with a millisecond precision, default: 10, example: 0.01)
    312. 

  312. 	 * - `connect_timeout`: How long should we wait while trying to connect?
    313. 

  313. 	 *    (float, seconds with a millisecond precision, default: 10, example: 0.01)
    314. 

  314. 	 * - `useragent`: Useragent to send to the server
    315. 

  315. 	 *    (string, default: php-requests/$version)
    316. 

  316. 	 * - `follow_redirects`: Should we follow 3xx redirects?
    317. 

  317. 	 *    (boolean, default: true)
    318. 

  318. 	 * - `redirects`: How many times should we redirect before erroring?
    319. 

  319. 	 *    (integer, default: 10)
    320. 

  320. 	 * - `blocking`: Should we block processing on this request?
    321. 

  321. 	 *    (boolean, default: true)
    322. 

  322. 	 * - `filename`: File to stream the body to instead.
    323. 

  323. 	 *    (string|boolean, default: false)
    324. 

  324. 	 * - `auth`: Authentication handler or array of user/password details to use
    325. 

  325. 	 *    for Basic authentication
    326. 

  326. 	 *    (Requests_Auth|array|boolean, default: false)
    327. 

  327. 	 * - `proxy`: Proxy details to use for proxy by-passing and authentication
    328. 

  328. 	 *    (Requests_Proxy|array|string|boolean, default: false)
    329. 

  329. 	 * - `max_bytes`: Limit for the response body size.
    330. 

  330. 	 *    (integer|boolean, default: false)
    331. 

  331. 	 * - `idn`: Enable IDN parsing
    332. 

  332. 	 *    (boolean, default: true)
    333. 

  333. 	 * - `transport`: Custom transport. Either a class name, or a
    334. 

  334. 	 *    transport object. Defaults to the first working transport from
    335. 

  335. 	 *    {@see getTransport()}
    336. 

  336. 	 *    (string|Requests_Transport, default: {@see getTransport()})
    337. 

  337. 	 * - `hooks`: Hooks handler.
    338. 

  338. 	 *    (Requests_Hooker, default: new Requests_Hooks())
    339. 

  339. 	 * - `verify`: Should we verify SSL certificates? Allows passing in a custom
    340. 

  340. 	 *    certificate file as a string. (Using true uses the system-wide root
    341. 

  341. 	 *    certificate store instead, but this may have different behaviour
    342. 

  342. 	 *    across transports.)
    343. 

  343. 	 *    (string|boolean, default: library/Requests/Transport/cacert.pem)
    344. 

  344. 	 * - `verifyname`: Should we verify the common name in the SSL certificate?
    345. 

  345. 	 *    (boolean, default: true)
    346. 

  346. 	 * - `data_format`: How should we send the `$data` parameter?
    347. 

  347. 	 *    (string, one of 'query' or 'body', default: 'query' for
    348. 

  348. 	 *    HEAD/GET/DELETE, 'body' for POST/PUT/OPTIONS/PATCH)
    349. 

  349. 	 *
    350. 

  350. 	 * @throws Requests_Exception On invalid URLs (`nonhttp`)
    351. 

  351. 	 *
    352. 

  352. 	 * @param string $url URL to request
    353. 

  353. 	 * @param array $headers Extra headers to send with the request
    354. 

  354. 	 * @param array|null $data Data to send either as a query string for GET/HEAD requests, or in the body for POST requests
    355. 

  355. 	 * @param string $type HTTP request type (use Requests constants)
    356. 

  356. 	 * @param array $options Options for the request (see description for more information)
    357. 

  357. 	 * @return Requests_Response
    358. 

  358. 	 */
    359. 

  359. 	public static function request($url, $headers = array(), $data = array(), $type = self::GET, $options = array()) {
    360. 

  360. 		if (empty($options['type'])) {
    361. 

  361. 			$options['type'] = $type;
    362. 

  362. 		}
    363. 

  363. 		$options = array_merge(self::get_default_options(), $options);
    364. 

  364. 

  365. 		self::set_defaults($url, $headers, $data, $type, $options);
    366. 

  366. 

  367. 		$options['hooks']->dispatch('requests.before_request', array(&$url, &$headers, &$data, &$type, &$options));
    368. 

  368. 

  369. 		if (!empty($options['transport'])) {
    370. 

  370. 			$transport = $options['transport'];
    371. 

  371. 

  372. 			if (is_string($options['transport'])) {
    373. 

  373. 				$transport = new $transport();
    374. 

  374. 			}
    375. 

  375. 		}
    376. 

  376. 		else {
    377. 

  377. 			$need_ssl     = (stripos($url, 'https://') === 0);
    378. 

  378. 			$capabilities = array('ssl' => $need_ssl);
    379. 

  379. 			$transport    = self::get_transport($capabilities);
    380. 

  380. 		}
    381. 

  381. 		$response = $transport->request($url, $headers, $data, $options);
    382. 

  382. 

  383. 		$options['hooks']->dispatch('requests.before_parse', array(&$response, $url, $headers, $data, $type, $options));
    384. 

  384. 

  385. 		return self::parse_response($response, $url, $headers, $data, $options);
    386. 

  386. 	}
    387. 

  387. 

  388. 	/**
    389. 

  389. 	 * Send multiple HTTP requests simultaneously
    390. 

  390. 	 *
    391. 

  391. 	 * The `$requests` parameter takes an associative or indexed array of
    392. 

  392. 	 * request fields. The key of each request can be used to match up the
    393. 

  393. 	 * request with the returned data, or with the request passed into your
    394. 

  394. 	 * `multiple.request.complete` callback.
    395. 

  395. 	 *
    396. 

  396. 	 * The request fields value is an associative array with the following keys:
    397. 

  397. 	 *
    398. 

  398. 	 * - `url`: Request URL Same as the `$url` parameter to
    399. 

  399. 	 *    {@see Requests::request}
    400. 

  400. 	 *    (string, required)
    401. 

  401. 	 * - `headers`: Associative array of header fields. Same as the `$headers`
    402. 

  402. 	 *    parameter to {@see Requests::request}
    403. 

  403. 	 *    (array, default: `array()`)
    404. 

  404. 	 * - `data`: Associative array of data fields or a string. Same as the
    405. 

  405. 	 *    `$data` parameter to {@see Requests::request}
    406. 

  406. 	 *    (array|string, default: `array()`)
    407. 

  407. 	 * - `type`: HTTP request type (use Requests constants). Same as the `$type`
    408. 

  408. 	 *    parameter to {@see Requests::request}
    409. 

  409. 	 *    (string, default: `Requests::GET`)
    410. 

  410. 	 * - `cookies`: Associative array of cookie name to value, or cookie jar.
    411. 

  411. 	 *    (array|Requests_Cookie_Jar)
    412. 

  412. 	 *
    413. 

  413. 	 * If the `$options` parameter is specified, individual requests will
    414. 

  414. 	 * inherit options from it. This can be used to use a single hooking system,
    415. 

  415. 	 * or set all the types to `Requests::POST`, for example.
    416. 

  416. 	 *
    417. 

  417. 	 * In addition, the `$options` parameter takes the following global options:
    418. 

  418. 	 *
    419. 

  419. 	 * - `complete`: A callback for when a request is complete. Takes two
    420. 

  420. 	 *    parameters, a Requests_Response/Requests_Exception reference, and the
    421. 

  421. 	 *    ID from the request array (Note: this can also be overridden on a
    422. 

  422. 	 *    per-request basis, although that's a little silly)
    423. 

  423. 	 *    (callback)
    424. 

  424. 	 *
    425. 

  425. 	 * @param array $requests Requests data (see description for more information)
    426. 

  426. 	 * @param array $options Global and default options (see {@see Requests::request})
    427. 

  427. 	 * @return array Responses (either Requests_Response or a Requests_Exception object)
    428. 

  428. 	 */
    429. 

  429. 	public static function request_multiple($requests, $options = array()) {
    430. 

  430. 		$options = array_merge(self::get_default_options(true), $options);
    431. 

  431. 

  432. 		if (!empty($options['hooks'])) {
    433. 

  433. 			$options['hooks']->register('transport.internal.parse_response', array('Requests', 'parse_multiple'));
    434. 

  434. 			if (!empty($options['complete'])) {
    435. 

  435. 				$options['hooks']->register('multiple.request.complete', $options['complete']);
    436. 

  436. 			}
    437. 

  437. 		}
    438. 

  438. 

  439. 		foreach ($requests as $id => &$request) {
    440. 

  440. 			if (!isset($request['headers'])) {
    441. 

  441. 				$request['headers'] = array();
    442. 

  442. 			}
    443. 

  443. 			if (!isset($request['data'])) {
    444. 

  444. 				$request['data'] = array();
    445. 

  445. 			}
    446. 

  446. 			if (!isset($request['type'])) {
    447. 

  447. 				$request['type'] = self::GET;
    448. 

  448. 			}
    449. 

  449. 			if (!isset($request['options'])) {
    450. 

  450. 				$request['options']         = $options;
    451. 

  451. 				$request['options']['type'] = $request['type'];
    452. 

  452. 			}
    453. 

  453. 			else {
    454. 

  454. 				if (empty($request['options']['type'])) {
    455. 

  455. 					$request['options']['type'] = $request['type'];
    456. 

  456. 				}
    457. 

  457. 				$request['options'] = array_merge($options, $request['options']);
    458. 

  458. 			}
    459. 

  459. 

  460. 			self::set_defaults($request['url'], $request['headers'], $request['data'], $request['type'], $request['options']);
    461. 

  461. 

  462. 			// Ensure we only hook in once
    463. 

  463. 			if ($request['options']['hooks'] !== $options['hooks']) {
    464. 

  464. 				$request['options']['hooks']->register('transport.internal.parse_response', array('Requests', 'parse_multiple'));
    465. 

  465. 				if (!empty($request['options']['complete'])) {
    466. 

  466. 					$request['options']['hooks']->register('multiple.request.complete', $request['options']['complete']);
    467. 

  467. 				}
    468. 

  468. 			}
    469. 

  469. 		}
    470. 

  470. 		unset($request);
    471. 

  471. 

  472. 		if (!empty($options['transport'])) {
    473. 

  473. 			$transport = $options['transport'];
    474. 

  474. 

  475. 			if (is_string($options['transport'])) {
    476. 

  476. 				$transport = new $transport();
    477. 

  477. 			}
    478. 

  478. 		}
    479. 

  479. 		else {
    480. 

  480. 			$transport = self::get_transport();
    481. 

  481. 		}
    482. 

  482. 		$responses = $transport->request_multiple($requests, $options);
    483. 

  483. 

  484. 		foreach ($responses as $id => &$response) {
    485. 

  485. 			// If our hook got messed with somehow, ensure we end up with the
    486. 

  486. 			// correct response
    487. 

  487. 			if (is_string($response)) {
    488. 

  488. 				$request = $requests[$id];
    489. 

  489. 				self::parse_multiple($response, $request);
    490. 

  490. 				$request['options']['hooks']->dispatch('multiple.request.complete', array(&$response, $id));
    491. 

  491. 			}
    492. 

  492. 		}
    493. 

  493. 

  494. 		return $responses;
    495. 

  495. 	}
    496. 

  496. 

  497. 	/**
    498. 

  498. 	 * Get the default options
    499. 

  499. 	 *
    500. 

  500. 	 * @see Requests::request() for values returned by this method
    501. 

  501. 	 * @param boolean $multirequest Is this a multirequest?
    502. 

  502. 	 * @return array Default option values
    503. 

  503. 	 */
    504. 

  504. 	protected static function get_default_options($multirequest = false) {
    505. 

  505. 		$defaults = array(
    506. 

  506. 			'timeout'          => 10,
    507. 

  507. 			'connect_timeout'  => 10,
    508. 

  508. 			'useragent'        => 'php-requests/' . self::VERSION,
    509. 

  509. 			'protocol_version' => 1.1,
    510. 

  510. 			'redirected'       => 0,
    511. 

  511. 			'redirects'        => 10,
    512. 

  512. 			'follow_redirects' => true,
    513. 

  513. 			'blocking'         => true,
    514. 

  514. 			'type'             => self::GET,
    515. 

  515. 			'filename'         => false,
    516. 

  516. 			'auth'             => false,
    517. 

  517. 			'proxy'            => false,
    518. 

  518. 			'cookies'          => false,
    519. 

  519. 			'max_bytes'        => false,
    520. 

  520. 			'idn'              => true,
    521. 

  521. 			'hooks'            => null,
    522. 

  522. 			'transport'        => null,
    523. 

  523. 			'verify'           => self::get_certificate_path(),
    524. 

  524. 			'verifyname'       => true,
    525. 

  525. 		);
    526. 

  526. 		if ($multirequest !== false) {
    527. 

  527. 			$defaults['complete'] = null;
    528. 

  528. 		}
    529. 

  529. 		return $defaults;
    530. 

  530. 	}
    531. 

  531. 

  532. 	/**
    533. 

  533. 	 * Get default certificate path.
    534. 

  534. 	 *
    535. 

  535. 	 * @return string Default certificate path.
    536. 

  536. 	 */
    537. 

  537. 	public static function get_certificate_path() {
    538. 

  538. 		if (!empty(self::$certificate_path)) {
    539. 

  539. 			return self::$certificate_path;
    540. 

  540. 		}
    541. 

  541. 

  542. 		return dirname(__FILE__) . '/Requests/Transport/cacert.pem';
    543. 

  543. 	}
    544. 

  544. 

  545. 	/**
    546. 

  546. 	 * Set default certificate path.
    547. 

  547. 	 *
    548. 

  548. 	 * @param string $path Certificate path, pointing to a PEM file.
    549. 

  549. 	 */
    550. 

  550. 	public static function set_certificate_path($path) {
    551. 

  551. 		self::$certificate_path = $path;
    552. 

  552. 	}
    553. 

  553. 

  554. 	/**
    555. 

  555. 	 * Set the default values
    556. 

  556. 	 *
    557. 

  557. 	 * @param string $url URL to request
    558. 

  558. 	 * @param array $headers Extra headers to send with the request
    559. 

  559. 	 * @param array|null $data Data to send either as a query string for GET/HEAD requests, or in the body for POST requests
    560. 

  560. 	 * @param string $type HTTP request type
    561. 

  561. 	 * @param array $options Options for the request
    562. 

  562. 	 * @return array $options
    563. 

  563. 	 */
    564. 

  564. 	protected static function set_defaults(&$url, &$headers, &$data, &$type, &$options) {
    565. 

  565. 		if (!preg_match('/^http(s)?:\/\//i', $url, $matches)) {
    566. 

  566. 			throw new Requests_Exception('Only HTTP(S) requests are handled.', 'nonhttp', $url);
    567. 

  567. 		}
    568. 

  568. 

  569. 		if (empty($options['hooks'])) {
    570. 

  570. 			$options['hooks'] = new Requests_Hooks();
    571. 

  571. 		}
    572. 

  572. 

  573. 		if (is_array($options['auth'])) {
    574. 

  574. 			$options['auth'] = new Requests_Auth_Basic($options['auth']);
    575. 

  575. 		}
    576. 

  576. 		if ($options['auth'] !== false) {
    577. 

  577. 			$options['auth']->register($options['hooks']);
    578. 

  578. 		}
    579. 

  579. 

  580. 		if (is_string($options['proxy']) || is_array($options['proxy'])) {
    581. 

  581. 			$options['proxy'] = new Requests_Proxy_HTTP($options['proxy']);
    582. 

  582. 		}
    583. 

  583. 		if ($options['proxy'] !== false) {
    584. 

  584. 			$options['proxy']->register($options['hooks']);
    585. 

  585. 		}
    586. 

  586. 

  587. 		if (is_array($options['cookies'])) {
    588. 

  588. 			$options['cookies'] = new Requests_Cookie_Jar($options['cookies']);
    589. 

  589. 		}
    590. 

  590. 		elseif (empty($options['cookies'])) {
    591. 

  591. 			$options['cookies'] = new Requests_Cookie_Jar();
    592. 

  592. 		}
    593. 

  593. 		if ($options['cookies'] !== false) {
    594. 

  594. 			$options['cookies']->register($options['hooks']);
    595. 

  595. 		}
    596. 

  596. 

  597. 		if ($options['idn'] !== false) {
    598. 

  598. 			$iri       = new Requests_IRI($url);
    599. 

  599. 			$iri->host = Requests_IDNAEncoder::encode($iri->ihost);
    600. 

  600. 			$url       = $iri->uri;
    601. 

  601. 		}
    602. 

  602. 

  603. 		// Massage the type to ensure we support it.
    604. 

  604. 		$type = strtoupper($type);
    605. 

  605. 

  606. 		if (!isset($options['data_format'])) {
    607. 

  607. 			if (in_array($type, array(self::HEAD, self::GET, self::DELETE), true)) {
    608. 

  608. 				$options['data_format'] = 'query';
    609. 

  609. 			}
    610. 

  610. 			else {
    611. 

  611. 				$options['data_format'] = 'body';
    612. 

  612. 			}
    613. 

  613. 		}
    614. 

  614. 	}
    615. 

  615. 

  616. 	/**
    617. 

  617. 	 * HTTP response parser
    618. 

  618. 	 *
    619. 

  619. 	 * @throws Requests_Exception On missing head/body separator (`requests.no_crlf_separator`)
    620. 

  620. 	 * @throws Requests_Exception On missing head/body separator (`noversion`)
    621. 

  621. 	 * @throws Requests_Exception On missing head/body separator (`toomanyredirects`)
    622. 

  622. 	 *
    623. 

  623. 	 * @param string $headers Full response text including headers and body
    624. 

  624. 	 * @param string $url Original request URL
    625. 

  625. 	 * @param array $req_headers Original $headers array passed to {@link request()}, in case we need to follow redirects
    626. 

  626. 	 * @param array $req_data Original $data array passed to {@link request()}, in case we need to follow redirects
    627. 

  627. 	 * @param array $options Original $options array passed to {@link request()}, in case we need to follow redirects
    628. 

  628. 	 * @return Requests_Response
    629. 

  629. 	 */
    630. 

  630. 	protected static function parse_response($headers, $url, $req_headers, $req_data, $options) {
    631. 

  631. 		$return = new Requests_Response();
    632. 

  632. 		if (!$options['blocking']) {
    633. 

  633. 			return $return;
    634. 

  634. 		}
    635. 

  635. 

  636. 		$return->raw  = $headers;
    637. 

  637. 		$return->url  = (string) $url;
    638. 

  638. 		$return->body = '';
    639. 

  639. 

  640. 		if (!$options['filename']) {
    641. 

  641. 			$pos = strpos($headers, "\r\n\r\n");
    642. 

  642. 			if ($pos === false) {
    643. 

  643. 				// Crap!
    644. 

  644. 				throw new Requests_Exception('Missing header/body separator', 'requests.no_crlf_separator');
    645. 

  645. 			}
    646. 

  646. 

  647. 			$headers = substr($return->raw, 0, $pos);
    648. 

  648. 			// Headers will always be separated from the body by two new lines - `\n\r\n\r`.
    649. 

  649. 			$body = substr($return->raw, $pos + 4);
    650. 

  650. 			if (!empty($body)) {
    651. 

  651. 				$return->body = $body;
    652. 

  652. 			}
    653. 

  653. 		}
    654. 

  654. 		// Pretend CRLF = LF for compatibility (RFC 2616, section 19.3)
    655. 

  655. 		$headers = str_replace("\r\n", "\n", $headers);
    656. 

  656. 		// Unfold headers (replace [CRLF] 1*( SP | HT ) with SP) as per RFC 2616 (section 2.2)
    657. 

  657. 		$headers = preg_replace('/\n[ \t]/', ' ', $headers);
    658. 

  658. 		$headers = explode("\n", $headers);
    659. 

  659. 		preg_match('#^HTTP/(1\.\d)[ \t]+(\d+)#i', array_shift($headers), $matches);
    660. 

  660. 		if (empty($matches)) {
    661. 

  661. 			throw new Requests_Exception('Response could not be parsed', 'noversion', $headers);
    662. 

  662. 		}
    663. 

  663. 		$return->protocol_version = (float) $matches[1];
    664. 

  664. 		$return->status_code      = (int) $matches[2];
    665. 

  665. 		if ($return->status_code >= 200 && $return->status_code < 300) {
    666. 

  666. 			$return->success = true;
    667. 

  667. 		}
    668. 

  668. 

  669. 		foreach ($headers as $header) {
    670. 

  670. 			list($key, $value) = explode(':', $header, 2);
    671. 

  671. 			$value             = trim($value);
    672. 

  672. 			preg_replace('#(\s+)#i', ' ', $value);
    673. 

  673. 			$return->headers[$key] = $value;
    674. 

  674. 		}
    675. 

  675. 		if (isset($return->headers['transfer-encoding'])) {
    676. 

  676. 			$return->body = self::decode_chunked($return->body);
    677. 

  677. 			unset($return->headers['transfer-encoding']);
    678. 

  678. 		}
    679. 

  679. 		if (isset($return->headers['content-encoding'])) {
    680. 

  680. 			$return->body = self::decompress($return->body);
    681. 

  681. 		}
    682. 

  682. 

  683. 		//fsockopen and cURL compatibility
    684. 

  684. 		if (isset($return->headers['connection'])) {
    685. 

  685. 			unset($return->headers['connection']);
    686. 

  686. 		}
    687. 

  687. 

  688. 		$options['hooks']->dispatch('requests.before_redirect_check', array(&$return, $req_headers, $req_data, $options));
    689. 

  689. 

  690. 		if ($return->is_redirect() && $options['follow_redirects'] === true) {
    691. 

  691. 			if (isset($return->headers['location']) && $options['redirected'] < $options['redirects']) {
    692. 

  692. 				if ($return->status_code === 303) {
    693. 

  693. 					$options['type'] = self::GET;
    694. 

  694. 				}
    695. 

  695. 				$options['redirected']++;
    696. 

  696. 				$location = $return->headers['location'];
    697. 

  697. 				if (strpos($location, 'http://') !== 0 && strpos($location, 'https://') !== 0) {
    698. 

  698. 					// relative redirect, for compatibility make it absolute
    699. 

  699. 					$location = Requests_IRI::absolutize($url, $location);
    700. 

  700. 					$location = $location->uri;
    701. 

  701. 				}
    702. 

  702. 

  703. 				$hook_args = array(
    704. 

  704. 					&$location,
    705. 

  705. 					&$req_headers,
    706. 

  706. 					&$req_data,
    707. 

  707. 					&$options,
    708. 

  708. 					$return,
    709. 

  709. 				);
    710. 

  710. 				$options['hooks']->dispatch('requests.before_redirect', $hook_args);
    711. 

  711. 				$redirected            = self::request($location, $req_headers, $req_data, $options['type'], $options);
    712. 

  712. 				$redirected->history[] = $return;
    713. 

  713. 				return $redirected;
    714. 

  714. 			}
    715. 

  715. 			elseif ($options['redirected'] >= $options['redirects']) {
    716. 

  716. 				throw new Requests_Exception('Too many redirects', 'toomanyredirects', $return);
    717. 

  717. 			}
    718. 

  718. 		}
    719. 

  719. 

  720. 		$return->redirects = $options['redirected'];
    721. 

  721. 

  722. 		$options['hooks']->dispatch('requests.after_request', array(&$return, $req_headers, $req_data, $options));
    723. 

  723. 		return $return;
    724. 

  724. 	}
    725. 

  725. 

  726. 	/**
    727. 

  727. 	 * Callback for `transport.internal.parse_response`
    728. 

  728. 	 *
    729. 

  729. 	 * Internal use only. Converts a raw HTTP response to a Requests_Response
    730. 

  730. 	 * while still executing a multiple request.
    731. 

  731. 	 *
    732. 

  732. 	 * @param string $response Full response text including headers and body (will be overwritten with Response instance)
    733. 

  733. 	 * @param array $request Request data as passed into {@see Requests::request_multiple()}
    734. 

  734. 	 * @return null `$response` is either set to a Requests_Response instance, or a Requests_Exception object
    735. 

  735. 	 */
    736. 

  736. 	public static function parse_multiple(&$response, $request) {
    737. 

  737. 		try {
    738. 

  738. 			$url      = $request['url'];
    739. 

  739. 			$headers  = $request['headers'];
    740. 

  740. 			$data     = $request['data'];
    741. 

  741. 			$options  = $request['options'];
    742. 

  742. 			$response = self::parse_response($response, $url, $headers, $data, $options);
    743. 

  743. 		}
    744. 

  744. 		catch (Requests_Exception $e) {
    745. 

  745. 			$response = $e;
    746. 

  746. 		}
    747. 

  747. 	}
    748. 

  748. 

  749. 	/**
    750. 

  750. 	 * Decoded a chunked body as per RFC 2616
    751. 

  751. 	 *
    752. 

  752. 	 * @see https://tools.ietf.org/html/rfc2616#section-3.6.1
    753. 

  753. 	 * @param string $data Chunked body
    754. 

  754. 	 * @return string Decoded body
    755. 

  755. 	 */
    756. 

  756. 	protected static function decode_chunked($data) {
    757. 

  757. 		if (!preg_match('/^([0-9a-f]+)(?:;(?:[\w-]*)(?:=(?:(?:[\w-]*)*|"(?:[^\r\n])*"))?)*\r\n/i', trim($data))) {
    758. 

  758. 			return $data;
    759. 

  759. 		}
    760. 

  760. 

  761. 		$decoded = '';
    762. 

  762. 		$encoded = $data;
    763. 

  763. 

  764. 		while (true) {
    765. 

  765. 			$is_chunked = (bool) preg_match('/^([0-9a-f]+)(?:;(?:[\w-]*)(?:=(?:(?:[\w-]*)*|"(?:[^\r\n])*"))?)*\r\n/i', $encoded, $matches);
    766. 

  766. 			if (!$is_chunked) {
    767. 

  767. 				// Looks like it's not chunked after all
    768. 

  768. 				return $data;
    769. 

  769. 			}
    770. 

  770. 

  771. 			$length = hexdec(trim($matches[1]));
    772. 

  772. 			if ($length === 0) {
    773. 

  773. 				// Ignore trailer headers
    774. 

  774. 				return $decoded;
    775. 

  775. 			}
    776. 

  776. 

  777. 			$chunk_length = strlen($matches[0]);
    778. 

  778. 			$decoded     .= substr($encoded, $chunk_length, $length);
    779. 

  779. 			$encoded      = substr($encoded, $chunk_length + $length + 2);
    780. 

  780. 

  781. 			if (trim($encoded) === '0' || empty($encoded)) {
    782. 

  782. 				return $decoded;
    783. 

  783. 			}
    784. 

  784. 		}
    785. 

  785. 

  786. 		// We'll never actually get down here
    787. 

  787. 		// @codeCoverageIgnoreStart
    788. 

  788. 	}
    789. 

  789. 	// @codeCoverageIgnoreEnd
    790. 

  790. 

  791. 	/**
    792. 

  792. 	 * Convert a key => value array to a 'key: value' array for headers
    793. 

  793. 	 *
    794. 

  794. 	 * @param array $array Dictionary of header values
    795. 

  795. 	 * @return array List of headers
    796. 

  796. 	 */
    797. 

  797. 	public static function flatten($array) {
    798. 

  798. 		$return = array();
    799. 

  799. 		foreach ($array as $key => $value) {
    800. 

  800. 			$return[] = sprintf('%s: %s', $key, $value);
    801. 

  801. 		}
    802. 

  802. 		return $return;
    803. 

  803. 	}
    804. 

  804. 

  805. 	/**
    806. 

  806. 	 * Convert a key => value array to a 'key: value' array for headers
    807. 

  807. 	 *
    808. 

  808. 	 * @codeCoverageIgnore
    809. 

  809. 	 * @deprecated Misspelling of {@see Requests::flatten}
    810. 

  810. 	 * @param array $array Dictionary of header values
    811. 

  811. 	 * @return array List of headers
    812. 

  812. 	 */
    813. 

  813. 	public static function flattern($array) {
    814. 

  814. 		return self::flatten($array);
    815. 

  815. 	}
    816. 

  816. 

  817. 	/**
    818. 

  818. 	 * Decompress an encoded body
    819. 

  819. 	 *
    820. 

  820. 	 * Implements gzip, compress and deflate. Guesses which it is by attempting
    821. 

  821. 	 * to decode.
    822. 

  822. 	 *
    823. 

  823. 	 * @param string $data Compressed data in one of the above formats
    824. 

  824. 	 * @return string Decompressed string
    825. 

  825. 	 */
    826. 

  826. 	public static function decompress($data) {
    827. 

  827. 		if (substr($data, 0, 2) !== "\x1f\x8b" && substr($data, 0, 2) !== "\x78\x9c") {
    828. 

  828. 			// Not actually compressed. Probably cURL ruining this for us.
    829. 

  829. 			return $data;
    830. 

  830. 		}
    831. 

  831. 

  832. 		if (function_exists('gzdecode')) {
    833. 

  833. 			// phpcs:ignore PHPCompatibility.FunctionUse.NewFunctions.gzdecodeFound -- Wrapped in function_exists() for PHP 5.2.
    834. 

  834. 			$decoded = @gzdecode($data);
    835. 

  835. 			if ($decoded !== false) {
    836. 

  836. 				return $decoded;
    837. 

  837. 			}
    838. 

  838. 		}
    839. 

  839. 

  840. 		if (function_exists('gzinflate')) {
    841. 

  841. 			$decoded = @gzinflate($data);
    842. 

  842. 			if ($decoded !== false) {
    843. 

  843. 				return $decoded;
    844. 

  844. 			}
    845. 

  845. 		}
    846. 

  846. 

  847. 		$decoded = self::compatible_gzinflate($data);
    848. 

  848. 		if ($decoded !== false) {
    849. 

  849. 			return $decoded;
    850. 

  850. 		}
    851. 

  851. 

  852. 		if (function_exists('gzuncompress')) {
    853. 

  853. 			$decoded = @gzuncompress($data);
    854. 

  854. 			if ($decoded !== false) {
    855. 

  855. 				return $decoded;
    856. 

  856. 			}
    857. 

  857. 		}
    858. 

  858. 

  859. 		return $data;
    860. 

  860. 	}
    861. 

  861. 

  862. 	/**
    863. 

  863. 	 * Decompression of deflated string while staying compatible with the majority of servers.
    864. 

  864. 	 *
    865. 

  865. 	 * Certain Servers will return deflated data with headers which PHP's gzinflate()
    866. 

  866. 	 * function cannot handle out of the box. The following function has been created from
    867. 

  867. 	 * various snippets on the gzinflate() PHP documentation.
    868. 

  868. 	 *
    869. 

  869. 	 * Warning: Magic numbers within. Due to the potential different formats that the compressed
    870. 

  870. 	 * data may be returned in, some "magic offsets" are needed to ensure proper decompression
    871. 

  871. 	 * takes place. For a simple progmatic way to determine the magic offset in use, see:
    872. 

  872. 	 * https://core.trac.wordpress.org/ticket/18273
    873. 

  873. 	 *
    874. 

  874. 	 * @since 2.8.1
    875. 

  875. 	 * @link https://core.trac.wordpress.org/ticket/18273
    876. 

  876. 	 * @link https://secure.php.net/manual/en/function.gzinflate.php#70875
    877. 

  877. 	 * @link https://secure.php.net/manual/en/function.gzinflate.php#77336
    878. 

  878. 	 *
    879. 

  879. 	 * @param string $gz_data String to decompress.
    880. 

  880. 	 * @return string|bool False on failure.
    881. 

  881. 	 */
    882. 

  882. 	public static function compatible_gzinflate($gz_data) {
    883. 

  883. 		// Compressed data might contain a full zlib header, if so strip it for
    884. 

  884. 		// gzinflate()
    885. 

  885. 		if (substr($gz_data, 0, 3) === "\x1f\x8b\x08") {
    886. 

  886. 			$i   = 10;
    887. 

  887. 			$flg = ord(substr($gz_data, 3, 1));
    888. 

  888. 			if ($flg > 0) {
    889. 

  889. 				if ($flg & 4) {
    890. 

  890. 					list($xlen) = unpack('v', substr($gz_data, $i, 2));
    891. 

  891. 					$i         += 2 + $xlen;
    892. 

  892. 				}
    893. 

  893. 				if ($flg & 8) {
    894. 

  894. 					$i = strpos($gz_data, "\0", $i) + 1;
    895. 

  895. 				}
    896. 

  896. 				if ($flg & 16) {
    897. 

  897. 					$i = strpos($gz_data, "\0", $i) + 1;
    898. 

  898. 				}
    899. 

  899. 				if ($flg & 2) {
    900. 

  900. 					$i += 2;
    901. 

  901. 				}
    902. 

  902. 			}
    903. 

  903. 			$decompressed = self::compatible_gzinflate(substr($gz_data, $i));
    904. 

  904. 			if ($decompressed !== false) {
    905. 

  905. 				return $decompressed;
    906. 

  906. 			}
    907. 

  907. 		}
    908. 

  908. 

  909. 		// If the data is Huffman Encoded, we must first strip the leading 2
    910. 

  910. 		// byte Huffman marker for gzinflate()
    911. 

  911. 		// The response is Huffman coded by many compressors such as
    912. 

  912. 		// java.util.zip.Deflater, Ruby’s Zlib::Deflate, and .NET's
    913. 

  913. 		// System.IO.Compression.DeflateStream.
    914. 

  914. 		//
    915. 

  915. 		// See https://decompres.blogspot.com/ for a quick explanation of this
    916. 

  916. 		// data type
    917. 

  917. 		$huffman_encoded = false;
    918. 

  918. 

  919. 		// low nibble of first byte should be 0x08
    920. 

  920. 		list(, $first_nibble) = unpack('h', $gz_data);
    921. 

  921. 

  922. 		// First 2 bytes should be divisible by 0x1F
    923. 

  923. 		list(, $first_two_bytes) = unpack('n', $gz_data);
    924. 

  924. 

  925. 		if ($first_nibble === 0x08 && ($first_two_bytes % 0x1F) === 0) {
    926. 

  926. 			$huffman_encoded = true;
    927. 

  927. 		}
    928. 

  928. 

  929. 		if ($huffman_encoded) {
    930. 

  930. 			$decompressed = @gzinflate(substr($gz_data, 2));
    931. 

  931. 			if ($decompressed !== false) {
    932. 

  932. 				return $decompressed;
    933. 

  933. 			}
    934. 

  934. 		}
    935. 

  935. 

  936. 		if (substr($gz_data, 0, 4) === "\x50\x4b\x03\x04") {
    937. 

  937. 			// ZIP file format header
    938. 

  938. 			// Offset 6: 2 bytes, General-purpose field
    939. 

  939. 			// Offset 26: 2 bytes, filename length
    940. 

  940. 			// Offset 28: 2 bytes, optional field length
    941. 

  941. 			// Offset 30: Filename field, followed by optional field, followed
    942. 

  942. 			// immediately by data
    943. 

  943. 			list(, $general_purpose_flag) = unpack('v', substr($gz_data, 6, 2));
    944. 

  944. 

  945. 			// If the file has been compressed on the fly, 0x08 bit is set of
    946. 

  946. 			// the general purpose field. We can use this to differentiate
    947. 

  947. 			// between a compressed document, and a ZIP file
    948. 

  948. 			$zip_compressed_on_the_fly = ((0x08 & $general_purpose_flag) === 0x08);
    949. 

  949. 

  950. 			if (!$zip_compressed_on_the_fly) {
    951. 

  951. 				// Don't attempt to decode a compressed zip file
    952. 

  952. 				return $gz_data;
    953. 

  953. 			}
    954. 

  954. 

  955. 			// Determine the first byte of data, based on the above ZIP header
    956. 

  956. 			// offsets:
    957. 

  957. 			$first_file_start = array_sum(unpack('v2', substr($gz_data, 26, 4)));
    958. 

  958. 			$decompressed     = @gzinflate(substr($gz_data, 30 + $first_file_start));
    959. 

  959. 			if ($decompressed !== false) {
    960. 

  960. 				return $decompressed;
    961. 

  961. 			}
    962. 

  962. 			return false;
    963. 

  963. 		}
    964. 

  964. 

  965. 		// Finally fall back to straight gzinflate
    966. 

  966. 		$decompressed = @gzinflate($gz_data);
    967. 

  967. 		if ($decompressed !== false) {
    968. 

  968. 			return $decompressed;
    969. 

  969. 		}
    970. 

  970. 

  971. 		// Fallback for all above failing, not expected, but included for
    972. 

  972. 		// debugging and preventing regressions and to track stats
    973. 

  973. 		$decompressed = @gzinflate(substr($gz_data, 2));
    974. 

  974. 		if ($decompressed !== false) {
    975. 

  975. 			return $decompressed;
    976. 

  976. 		}
    977. 

  977. 

  978. 		return false;
    979. 

  979. 	}
    980. 

  980. 

  981. 	public static function match_domain($host, $reference) {
    982. 

  982. 		// Check for a direct match
    983. 

  983. 		if ($host === $reference) {
    984. 

  984. 			return true;
    985. 

  985. 		}
    986. 

  986. 

  987. 		// Calculate the valid wildcard match if the host is not an IP address
    988. 

  988. 		// Also validates that the host has 3 parts or more, as per Firefox's
    989. 

  989. 		// ruleset.
    990. 

  990. 		$parts = explode('.', $host);
    991. 

  991. 		if (ip2long($host) === false && count($parts) >= 3) {
    992. 

  992. 			$parts[0] = '*';
    993. 

  993. 			$wildcard = implode('.', $parts);
    994. 

  994. 			if ($wildcard === $reference) {
    995. 

  995. 				return true;
    996. 

  996. 			}
    997. 

  997. 		}
    998. 

  998. 

  999. 		return false;
    1000. 

  1000. 	}
    1001. 

  1001. }
    1002. 

  1002.