Initial commit

Author: alessiovierti

.github/workflows/create-release.yml

@@ -0,0 +1,64 @@
+name: Update version and create release
+
+on:
+  pull_request:
+    types: [closed]
+    branches: 
+      - master
+
+jobs:
+
+  fetch-version:
+    if: github.event.pull_request.merged
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v2
+      - name: Fetch latest release version
+        id: fetch-latest-release
+        uses: reloc8/action-latest-release-version@1.0.0
+      - uses: actions/setup-python@v2
+        with:
+          python-version: 3.7
+      - name: Choose new release version
+        id: choose-release-version
+        uses: reloc8/action-choose-release-version@1.0.0
+        with:
+          source-branch: ${{ github.event.pull_request.head.ref }}
+          latest-version: ${{ steps.fetch-latest-release.outputs.latest-release }}
+    outputs:
+      new-version: ${{ steps.choose-release-version.outputs.new-version }}
+
+  update-version:
+    needs: fetch-version
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v2
+      - run: git pull --ff-only
+      - name: Update version file
+        run: echo ${{ needs.fetch-version.outputs.new-version }} > version
+      - name: Push local repository changes
+        id: push-local-repository-changes
+        uses: reloc8/action-push-local-changes@1.0.0
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+        with:
+          commit-message: "Version ${{ needs.fetch-version.outputs.new-version }}"
+    outputs:
+      commit-hash: ${{ steps.push-local-repository-changes.outputs.commit-hash }}
+
+  create-release:
+    needs: [fetch-version, update-version]
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v2
+      - run: git pull --ff-only
+      - name: Create new release
+        uses: actions/create-release@v1
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+        with:
+          tag_name: ${{ needs.fetch-version.outputs.new-version }}
+          release_name: ${{ needs.fetch-version.outputs.new-version }}
+          draft: false
+          prerelease: false
+          commitish: ${{ needs.update-version.outputs.commit-hash }}

.gitignore

@@ -0,0 +1,4 @@
+.DS_Store
+.idea
+.venv
+*.egg-info

LICENSE.txt

@@ -0,0 +1,27 @@
+## Development
+
+1. Create a virtual environment:
+
+    `$ python3 -m venv .venv`
+
+2. Activate the created environment:
+
+    `$ source .venv/bin/activate`
+
+3. Upgrade `pip`:
+
+    `$ python3 -m pip install --upgrade pip`
+
+4. Install the requirements:
+
+    `$ pip install --upgrade -r requirements.txt`
+    
+5. Mark the main package as Sources Root.
+
+## Test
+
+1. Install the testing requirements:
+
+    `$ pip install --upgrade -r requirements-test.txt`
+    
+2. Run all tests in package `tests`

README.md

@@ -0,0 +1,21 @@
+import graphene
+import logging
+from dataclasses import dataclass
+from typing import Any, AnyStr, Dict
+
+from .mongodb import MongoDBConnection
+from .schema.query import MongoDBQuery
+
+
+@dataclass
+class FetchPropertiesLambdaCore:
+
+    logger: logging.Logger
+    mongodb_connection: MongoDBConnection
+
+    @staticmethod
+    def query(query: AnyStr) -> Dict[AnyStr, Any]:
+
+        graphql_schema = graphene.Schema(query=MongoDBQuery)
+        result = graphql_schema.execute(query)
+        return result.to_dict()

fetch_properties/__init__.py

@@ -0,0 +1,41 @@
+import json
+import logging
+from dataclasses import dataclass
+from typing import Any, AnyStr, Dict
+
+from lambda_handler import LambdaHandler
+from .. import FetchPropertiesLambdaCore
+from ..mongodb import MongoDBConnection, MONGODB_CONNECTION
+
+
+@dataclass(init=False)
+class FetchPropertiesLambda(LambdaHandler):
+
+    logger: logging.Logger
+    mongodb_connection: MongoDBConnection
+
+    def __init__(self, logger, mongodb_connection):
+
+        super().__init__(logger=logger)
+        self.mongodb_connection = mongodb_connection
+        self.core = FetchPropertiesLambdaCore(
+            logger=self.logger,
+            mongodb_connection=mongodb_connection
+        )
+
+    def run(self, event: Any, context: Any) -> Dict[AnyStr, Any]:
+
+        query = event['queryStringParameters'].get('query')
+        response_body = self.core.query(query=query)
+
+        return dict(
+            statusCode=200,
+            body=json.dumps(response_body),
+            isBase64Encoded=False
+        )
+
+
+LAMBDA_HANDLER = FetchPropertiesLambda(
+    logger=logging.getLogger(),
+    mongodb_connection=MONGODB_CONNECTION
+)

fetch_properties/core/__init__.py

@@ -0,0 +1,37 @@
+from typing import Any, AnyStr, Dict, List
+
+from ..schema import Property, PropertyLocation, PropertiesPage
+
+
+class PropertyMapper:
+
+    @staticmethod
+    def map(property: Dict[AnyStr, Any]) -> Property:
+
+        cursor = property.get('cursor')
+        price = property.get('price')
+        location = property.get('location')
+
+        property_location = PropertyLocation()
+        property_location.latitude = location.get('point').get('coordinates')[1]
+        property_location.longitude = location.get('point').get('coordinates')[0]
+        property_location.geohash = location.get('geohash')
+
+        mapped = Property()
+        mapped.id = cursor
+        mapped.price = price
+        mapped.location = property_location
+
+        return mapped
+
+
+class PropertiesPageMapper:
+
+    @staticmethod
+    def map(properties: List[Property]) -> PropertiesPage:
+
+        properties_page = PropertiesPage()
+        properties_page.properties = properties
+        properties_page.page = properties[-1].id
+
+        return properties_page

fetch_properties/core/handler/__init__.py

@@ -0,0 +1,23 @@
+import os
+from dataclasses import dataclass
+from typing import AnyStr
+
+
+MONGODB_URI = os.getenv('MONGODB_URI')
+MONGODB_DATABASE = 'timeSeriesDB'
+MONGODB_COLLECTION = 'properties'
+
+
+@dataclass
+class MongoDBConnection:
+
+    uri: AnyStr
+    database: AnyStr
+    collection: AnyStr
+
+
+MONGODB_CONNECTION = MongoDBConnection(
+    uri=MONGODB_URI,
+    database=MONGODB_DATABASE,
+    collection=MONGODB_COLLECTION
+)

fetch_properties/core/mapper/__init__.py

@@ -0,0 +1,46 @@
+import graphene
+
+
+class PropertyLocation(graphene.ObjectType):
+
+    latitude = graphene.Float()
+    longitude = graphene.Float()
+    geohash = graphene.String()
+
+
+class Property(graphene.ObjectType):
+
+    id = graphene.String()
+    price = graphene.Int()
+    location = graphene.Field(PropertyLocation)
+
+
+class PropertiesPage(graphene.ObjectType):
+
+    properties = graphene.List(Property)
+    page = graphene.String()
+
+
+class Point(graphene.InputObjectType):
+
+    latitude = graphene.Float()
+    longitude = graphene.Float()
+
+
+class BoundingBox(graphene.InputObjectType):
+
+    bottom_left = graphene.InputField(Point)
+    top_right = graphene.InputField(Point)
+
+
+class IntRange(graphene.InputObjectType):
+
+    min = graphene.Int()
+    max = graphene.Int()
+
+
+class PropertyFilter(graphene.InputObjectType):
+
+    n_rooms = graphene.InputField(IntRange)
+    surface = graphene.InputField(IntRange)
+    condition = graphene.String()