FINISH

Author: hi-hi-ray

README.md

@@ -13,6 +13,12 @@ Assessment de Microserviços
 #### Criando o Banco de Dados local:
 Basta rodar o models.py de cada app.
 
+### Repo na nuvem
+```
+scp -i "hihiray.pem" ~/Documents/Programming/faculdade/microservice-at.zip ec2-user@ec2-52-67-178-65.sa-east-1.compute.amazonaws.com:/home/ec2-user
+```
+
+
 ### Acessando a Documentação 
 - Orders
 https://app.swaggerhub.com/apis/hi-hi-ray/Orders_API/1.0.0

app_order/send_to_sqs.py

@@ -10,7 +10,7 @@ def send_to_sqs(id, id_toy, quantity):
     queue = client.get_queue_by_name(QueueName=queue_name)
 
     message = ("id: " + str(id) +
-        " id_toy: "+  id_toy +
+        " id_toy: "+  str(id_toy) +
         " quantity: " + str(quantity))
 
     response = queue.send_message(MessageBody=message)

app_stock/toystock.py

@@ -49,11 +49,17 @@ def delete_item(id_req):
 
 
 def update_item(id_req, name_req, quantity_req):
-    query_update = (ToyStock.update({
-        'name': name_req,
-        'quantity': quantity_cal(id_req, quantity_req)
-    }).where(ToyStock.id == id_req))
-    rows_updated = query_update.execute()
+    if name_req != "NoneFila":
+        query_update = (ToyStock.update({
+            'name': name_req,
+            'quantity': quantity_cal(id_req, quantity_req)
+        }).where(ToyStock.id == id_req))
+        rows_updated = query_update.execute()
+    else:
+        query_update = (ToyStock.update({
+            'quantity': quantity_cal(id_req, quantity_req)
+        }).where(ToyStock.id == id_req))
+        rows_updated = query_update.execute()
     if rows_updated != 0:
         return "Toy Updated"
     else:

lambda.py

@@ -0,0 +1,31 @@
+import json
+import urllib3
+from botocore.vendored import requests
+
+def lambda_handler(event, context):
+    print(event)
+    data = event["Records"][0]["body"]
+    message = data
+
+    txt = message.split()
+    name = 'Filaignore'
+
+    order = {
+        "name": "Filaignore",
+        "quantity": int(txt[5])
+    }
+
+    jsonData = json.dumps(order)
+
+    print(order)
+    url = "http://18.228.238.155/toy/" + txt[3]
+    print(url)
+
+    http = urllib3.PoolManager()
+    r = http.request('PUT', url,
+                     headers={'Content-Type': 'application/json'},
+                     body=jsonData)
+
+    return {
+        'statusCode': r.status
+    }