Merge branch 'Release'

Author: devenes

.github/workflows/main.yml

@@ -0,0 +1,23 @@
+name: Dockerizing and Deployment
+on:
+  push:
+    branches:
+      - "release"
+jobs:
+  Docker:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Set up QEMU
+        uses: docker/setup-qemu-action@v1
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v1
+      - name: Login to DockerHub
+        uses: docker/login-action@v1
+        with:
+          username: ${{ secrets.DOCKERHUB_USERNAME }}
+          password: ${{ secrets.DOCKERHUB_TOKEN }}
+      - name: Build and push
+        uses: docker/build-push-action@v2
+        with:
+          push: true
+          tags: devenes/boto3-api:${{github.run_number}}

.gitignore

@@ -1,3 +1,4 @@
 __pycache__/
 env/
+logs/
 app.log

Dockerfile

@@ -0,0 +1,10 @@
+FROM python:3.8-slim-buster
+WORKDIR /app
+ADD requirements.txt .
+RUN pip3 install -r requirements.txt
+COPY . .
+RUN mkdir logs \ 
+    && touch ./logs/app.log \
+    && chmod 777 ./logs/app.log
+EXPOSE 8080
+CMD ["python", "./app.py"]

app.py

@@ -11,97 +11,86 @@
 )
 
 
+def get_aws_client(request):
+    aws_access_key_id = request.args.get("aws_access_key_id")
+    aws_secret_access_key = request.args.get("aws_secret_access_key")
+    region_name = request.args.get("region_name")
+    return boto3.client('ec2',
+                        aws_access_key_id=aws_access_key_id,
+                        aws_secret_access_key=aws_secret_access_key,
+                        region_name=region_name
+                        )
+
+
 # Endpoint: http://<api_host>:<api_port>/ec2/list
-@app.route('/ec2/list', methods=['POST', 'GET'])
+@ app.route('/ec2/list', methods=['GET'])
 def aws_list():
     try:
-        aws_access_key_id = request.args.get("aws_access_key_id")
-        aws_secret_access_key = request.args.get("aws_secret_access_key")
-        region_name = request.args.get("region_name")
-        client = boto3.client('ec2',
-                              aws_access_key_id=aws_access_key_id,
-                              aws_secret_access_key=aws_secret_access_key,
-                              region_name=region_name
-                              )
+        client = get_aws_client(request)
+
+        instances = client.describe_instances()
+        output = []
+        for reservation in instances['Reservations']:
+            for instance in reservation['Instances']:
+                output.append(
+                    {
+                        'id': instance['InstanceId'],
+                        "instance-type": instance['InstanceType'],
+                        "instance-state": instance['State']['Name'],
+                        "private-ip": instance['PrivateIpAddress'],
+                        "key-name": instance['KeyName'],
+                        "image-id": instance['ImageId'],
+                        "vpc-id": instance['VpcId'],
+                        "subnet-id": instance['SubnetId'],
+                        "security-group-ids": instance['SecurityGroups'],
+                    }
+                )
+
+        print(output)
+        return jsonify(output), 200
 
     except Exception as error:
         print(str(error))
-        return jsonify({'Error': "Unexpected Error occured"}), 500
-
-    instances = client.describe_instances()
-    output = []
-    for reservation in instances['Reservations']:
-        output.extend([
-            {
-                'id': instance['InstanceId'],
-                "instance-type": instance['InstanceType'],
-                "instance-state": instance['State']['Name']
-            }
-            for instance in reservation['Instances']])
-
-    # print(output)
-    return jsonify(output), 200
+        return jsonify({'Message': "Unexpected Error occured", 'Error': str(error)}), 500
 
 
 # Endpoint: http://<api_host>:<api_port>/ec2/start
-@app.route("/ec2/start", methods=["POST", "GET"])
+@app.route("/ec2/start", methods=["POST"])
 def start_ec2_instances():
     try:
-        aws_access_key_id = request.args.get("aws_access_key_id")
-        aws_secret_access_key = request.args.get("aws_secret_access_key")
-        region_name = request.args.get("region_name")
-        InstanceIds = request.args.get("InstanceId")
-        client = boto3.client('ec2',
-                              aws_access_key_id=aws_access_key_id,
-                              aws_secret_access_key=aws_secret_access_key,
-                              region_name=region_name,
-                              )
-
-    except Exception as error:
-        print(str(error))
-        return jsonify({'Error': "Unexpected Error occured"}), 500
+        client = get_aws_client(request)
+        InstanceId = request.args.get("InstanceId")
 
-    response = client.describe_instances()
-    InstanceIds = []
-    for instance in response["Reservations"][0]["Instances"]:
-        InstanceIds.append(instance["InstanceId"])
+        response = client.start_instances(
+            InstanceIds=[InstanceId]
+        )
 
-    response = client.start_instances(
-        InstanceIds=InstanceIds
-    )
+        return jsonify(response["StartingInstances"][0]), 200
 
-    return jsonify(response["StartingInstances"][0]), 200
+    except Exception as error:
+        print(str(error))
+        return jsonify({'Message': "Unexpected Error occured", 'Error': str(error)}), 500
 
 
 # Endpoint: http://<api_host>:<api_port>/ec2/stop
-@app.route("/ec2/stop", methods=["POST", "GET"])
+@app.route("/ec2/stop", methods=["POST"])
 def stop_ec2_instances():
     try:
-        aws_access_key_id = request.args.get("aws_access_key_id")
-        aws_secret_access_key = request.args.get("aws_secret_access_key")
-        region_name = request.args.get("region_name")
-        InstanceIds = request.args.get("InstanceId")
-        client = boto3.client('ec2',
-                              aws_access_key_id=aws_access_key_id,
-                              aws_secret_access_key=aws_secret_access_key,
-                              region_name=region_name,
-                              )
+        client = get_aws_client(request)
+        InstanceId = request.args.get("InstanceId")
 
-    except Exception as error:
-        print(str(error))
-        return jsonify({'Error': "Unexpected Error occured"}), 500
+        response = client.stop_instances(
+            InstanceIds=[InstanceId]
+        )
 
-    response = client.describe_instances()
-    InstanceIds = []
-    for instance in response["Reservations"][0]["Instances"]:
-        InstanceIds.append(instance["InstanceId"])
+        return jsonify(response["StoppingInstances"][0]), 200
 
-    response = client.stop_instances(
-        InstanceIds=InstanceIds
-    )
-
-    return jsonify(response["StoppingInstances"][0]), 200
+    except Exception as error:
+        print(str(error))
+        return jsonify({'Message': "Unexpected Error occured", 'Error': str(error)}), 500
 
 
 if __name__ == "__main__":
-    app.run(host=config["host"], port=config["port"], debug=True)
+    app.run(host=config["host"],
+            port=config["port"],
+            debug=False)

config.py

@@ -1,6 +1,6 @@
 config = {
     "host": "0.0.0.0",
     "port": 8080,
-    "log_file": "app.log",
-    "log_level": "INFO"
+    "log_file": "logs/app.log",
+    "log_level": "DEBUG",
 }