Merge pull request #1 from tonicospinelli/01-flat-php

guest user adds product at its wishlist

.gitignore

@@ -0,0 +1,2 @@
+/data/*
+!/data/.gitkeep

README.md

@@ -0,0 +1,26 @@
+Developing for Business
+=======================
+
+#### User Story
+
+I as a guest user, I want to add a product sold out in my wish list, so that I receive a notification when it becomes available.
+
+Eu como um usuário convidado, quero adicionar um produto esgotado em minha lista de desejos para que eu receba uma notificação quando ele estiver disponível.
+
+
+#### Requirements
+
+* PHP 5.6+
+* PDO + SQLite Driver
+
+#### Run Application
+
+create sqlite database
+```shell
+$ php cli/create_tables.php
+```
+
+start php built-in server
+```shell
+$ php -S localhost:8000 -t public
+```

cli/create_tables.php

@@ -0,0 +1,8 @@
+<?php
+
+require_once __DIR__ . '/../lib/dbconn.php';
+
+$db->query("CREATE TABLE IF NOT EXISTS wishlists (id INTEGER PRIMARY KEY AUTOINCREMENT, email varchar(255), product_id int, status VARCHAR(1) DEFAULT 'P');");
+$db->query('CREATE TABLE IF NOT EXISTS products (id INTEGER PRIMARY KEY AUTOINCREMENT, name varchar(255), unit_price DECIMAL(10,2), stock int);');
+$stm = $db->query("INSERT INTO products VALUES (null, 'Camiseta', 59.9, 10);");
+$stm = $db->query("INSERT INTO products VALUES (null, 'Bermuda', 69.9, 10);");

cli/wishlist_notification.php

@@ -0,0 +1,29 @@
+<?php
+
+require_once __DIR__ . '/../lib/functions.php';
+require_once __DIR__ . '/../lib/dbconn.php';
+
+$query = <<<SQL
+SELECT
+  wishlists.id, wishlists.email, products.name as product_name
+FROM
+  wishlists
+INNER JOIN
+  products ON products.id = product_id
+WHERE
+  products.stock > 0
+  AND wishlists.status = 'P'
+SQL;
+$stm = $db->prepare($query);
+$stm->execute();
+$wishlists = $stm->fetchAll(PDO::FETCH_ASSOC);
+
+foreach ($wishlists as $wishlist) {
+    echo sprintf(
+            'sending email for: %s with "%s".',
+            $wishlist['email'],
+            $wishlist['product_name']
+        ) . PHP_EOL;
+    $stm = $db->prepare("UPDATE wishlists SET status = 'S' WHERE id = ?");
+    $stm->execute([$wishlist['id']]);
+}

lib/dbconn.php

@@ -0,0 +1,6 @@
+<?php
+
+$database = __DIR__ . '/../data/business.db';
+$dsn = 'sqlite:' . $database;
+$db = new PDO($dsn);
+

lib/functions.php

@@ -0,0 +1,74 @@
+<?php
+
+/**
+ * validate wish list data
+ * @param array $data
+ * @return bool
+ */
+function isValidProduct(array $data)
+{
+    if (!isset($data['name']) || !assert(is_string($data['name']) !== false)) {
+        return false;
+    }
+    if (!isset($data['stock']) || !assert(is_numeric($data['stock']))) {
+        return false;
+    }
+    return true;
+}
+
+/**
+ * Gets wish list data.
+ * @param array $data
+ * @return array
+ */
+function getProduct(array $data)
+{
+    return array(
+        'id' => (isset($data['id']) ? $data['id'] : null),
+        'name' => $data['name'],
+        'price' => $data['price'],
+        'stock' => $data['stock']
+    );
+}
+
+/**
+ * Creates a url to remove product from wish list
+ * @param int $id
+ * @return string
+ */
+function removeUrl($uri, $id, array $extraQuery = array())
+{
+    $query = http_build_query(array_merge(['remove' => $id], $extraQuery));
+    return sprintf('<a href="/%s?%s">remove</a>', $uri, $query);
+}
+
+
+/**
+ * validate wish list data
+ * @param array $data
+ * @return bool
+ */
+function isValidWishList(array $data)
+{
+    if (!isset($data['product_id']) || !assert(is_numeric($data['product_id']))) {
+        return false;
+    }
+    if (!isset($data['email']) || !assert(filter_var($data['email'], FILTER_VALIDATE_EMAIL) !== false)) {
+        return false;
+    }
+    return true;
+}
+
+/**
+ * Gets wish list data.
+ * @param array $data
+ * @return array
+ */
+function getWishList(array $data)
+{
+    return array(
+        'email' => $data['email'],
+        'product_id' => $data['product_id'],
+        'status' => 'P',
+    );
+}

public/product.php

@@ -0,0 +1,58 @@
+<?php
+
+require_once __DIR__ . '/../lib/functions.php';
+require_once __DIR__ . '/../lib/dbconn.php';
+
+$errormsg = null;
+$successmsg = null;
+
+if (isset($_POST['submit']) && isValidProduct($_POST['product'])) {
+    $product = getProduct($_POST['product']);
+    $db->beginTransaction();
+    try {
+        $stm = $db->prepare('INSERT INTO products (name, unit_price, stock) VALUES (?, ?, ?)');
+        $stm->execute([$product['name'], $product['unit_price'], $product['stock']]);
+        $db->commit();
+        $successmsg = 'Product was saved successfully!';
+    } catch (Exception $e) {
+        $db->rollBack();
+        $errormsg = 'Product could not be added! :(';
+    }
+}
+$stm = $db->prepare('SELECT * FROM products');
+$stm->execute();
+$products = $stm->fetchAll(PDO::FETCH_ASSOC);
+?>
+<html>
+<head></head>
+<body>
+<?php if (null !== $errormsg): ?>
+    <div class="alert error"><?php echo $errormsg; ?> </div>
+<?php elseif (isset($product)): ?>
+    <div class="alert success"><?php echo $successmsg; ?></div>
+<?php endif; ?>
+<h3>Products</h3>
+<table>
+    <thead>
+    <tr>
+        <th>ID</th>
+        <th>PRODUCT</th>
+        <th>UNIT PRICE</th>
+        <th>STOCK</th>
+        <th>ACTIONS</th>
+    </tr>
+    </thead>
+    <tbody>
+    <?php foreach ($products as $product): ?>
+        <tr>
+            <td><?php echo $product['id']; ?> </td>
+            <td><?php echo $product['name']; ?> </td>
+            <td><?php echo $product['unit_price']; ?> </td>
+            <td><?php echo $product['stock']; ?> </td>
+            <td><?php echo removeUrl('product.php', $product['id']); ?> </td>
+        </tr>
+    <?php endforeach; ?>
+    </tbody>
+</table>
+</body>
+</html>

public/wishlist.php

@@ -0,0 +1,81 @@
+<?php
+
+require_once __DIR__ . '/../lib/functions.php';
+require_once __DIR__ . '/../lib/dbconn.php';
+
+$errormsg = null;
+$successmsg = null;
+
+if (isset($_POST['submit']) && isValidWishList($_POST['wish_item'])) {
+    $wishItem = getWishList($_POST['wish_item']);
+    $db->beginTransaction();
+    try {
+        $stm = $db->prepare('INSERT INTO wishlists (email, product_id) VALUES (?, ?)');
+        $stm->execute([$wishItem['email'], $wishItem['product_id']]);
+        $db->commit();
+        $successmsg = 'Product was added at wish list successfully!';
+    } catch (Exception $e) {
+        $db->rollBack();
+        $errormsg = 'Product could not be added at wishlist! :(';
+    }
+}
+
+if (isset($_GET['remove'])) {
+    $db->beginTransaction();
+    try {
+        $stm = $db->prepare('DELETE FROM wishlists WHERE id = ?');
+        $stm->execute([$_GET['remove']]);
+        $db->commit();
+        $successmsg = 'Product was removed from wish list successfully!';
+    } catch (Exception $e) {
+        $db->rollBack();
+        $errormsg = 'Product could not be removed at wishlist! :(';
+    }
+    header('Location: /wishlist.php?'.http_build_query(['email' => $_GET['email']]));
+}
+
+$query = <<<SQL
+SELECT
+  wishlists.id, products.name as product_name,  products.stock as product_stock, wishlists.status
+FROM
+  wishlists
+INNER JOIN 
+  products ON products.id = product_id 
+WHERE email = ?
+SQL;
+
+$stm = $db->prepare($query);
+$stm->execute([$_GET['email']]);
+$wishlist = $stm->fetchAll(PDO::FETCH_ASSOC);
+?>
+<html>
+<head></head>
+<body>
+<?php if (null !== $errormsg): ?>
+    <div class="alert error"><?php echo $errormsg; ?> </div>
+<?php elseif (isset($wishItem)): ?>
+    <div class="alert success"><?php echo $successmsg; ?></div>
+<?php endif; ?>
+<h3>My Wish List</h3>
+<table>
+    <thead>
+    <tr>
+        <th>ID</th>
+        <th>PRODUCT</th>
+        <th>STATUS</th>
+        <th>ACTIONS</th>
+    </tr>
+    </thead>
+    <tbody>
+    <?php foreach ($wishlist as $wish): ?>
+        <tr>
+            <td><?php echo $wish['id']; ?> </td>
+            <td><?php echo $wish['product_name']; ?> </td>
+            <td><?php echo ($wish['status'] == 'P' && $wish['product_stock'] == 0 ? 'Not Available' : 'Available'); ?> </td>
+            <td><?php echo removeUrl('wishlist.php', $wish['id'], ['email' => $_GET['email']]); ?> </td>
+        </tr>
+    <?php endforeach; ?>
+    </tbody>
+</table>
+</body>
+</html>