Merge pull request #35 from ioet/feature/Create-repository-sql-database#25

Creates repository sql database#25

Author: EliuX

README.md

@@ -36,6 +36,35 @@ automatically [pip](https://pip.pypa.io/en/stable/) as well.
     
     The `stage` can be `dev` or `prod`. 
     Remember to do it with Python 3.
+    
+    
+- Install the [Microsoft ODBC Driver for SQL Server](https://docs.microsoft.com/en-us/sql/connect/odbc/microsoft-odbc-driver-for-sql-server?view=sql-server-ver15) 
+in your operative system. Then you have to check out what is the name of the SQL Driver installation. 
+Check it out with:
+
+```bash
+vim /usr/local/etc/odbcinst.ini
+```
+
+It may display something like
+
+```.ini
+[ODBC Driver 17 for SQL Server] 
+Description=Microsoft ODBC Driver 17 for SQL Server 
+Driver=/usr/local/lib/libmsodbcsql.17.dylib 
+UsageCount=2
+```
+
+Then specify the driver name, in this case _DBC Driver 17 for SQL Server_ in the `DATABASE_URI`, e.g.:
+
+```.dotenv
+DATABASE_URI=mssql+pyodbc://<user>:<password>@time-tracker-srv.database.windows.net/<database>?driver\=ODBC Driver 17 for SQL Server
+```
+
+To troubleshoot issues regarding this part please check out:
+- [Install the Microsoft ODBC driver for SQL Server (macOS)](https://docs.microsoft.com/en-us/sql/connect/odbc/linux-mac/install-microsoft-odbc-driver-sql-server-macos?view=sql-server-ver15).
+- Github issue [odbcinst: SQLRemoveDriver failed with Unable to find component name](https://github.com/Microsoft/homebrew-mssql-preview/issues/2).
+- Stack overflow solution to [Can't open lib 'ODBC Driver 13 for SQL Server'? Sym linking issue?](https://stackoverflow.com/questions/44527452/cant-open-lib-odbc-driver-13-for-sql-server-sym-linking-issue).
 
 ### How to use it
 - Set the env var `FLASK_APP` to `time_tracker_api` and start the app:
@@ -136,7 +165,6 @@ the win.
 [API import restrictions and known issues](https://docs.microsoft.com/en-us/azure/api-management/api-management-api-import-restrictions)
 in Azure.
 
-
 ## License
 
 Copyright 2020 ioet Inc. All Rights Reserved.

cli.py

@@ -6,9 +6,11 @@
 from flask_script import Manager
 
 from time_tracker_api import create_app
+
+app = create_app('time_tracker_api.config.CLIConfig')
+
 from time_tracker_api.api import api
 
-app = create_app()
 cli_manager = Manager(app)
 
 
@@ -44,6 +46,23 @@ def gen_postman_collection(filename='timetracker-api-postman-collection.json',
     save_data(parsed_json, filename)
 
 
+@cli_manager.command
+def seed():
+    from time_tracker_api.database import seeder as seed
+    seed()
+
+
+@cli_manager.command
+def re_create_db():
+    print('This is going to drop all tables and seed again the database')
+    confirm_answer = input('Do you confirm (Y) you want to remove all your data?\n')
+    if confirm_answer.upper() == 'Y':
+        from time_tracker_api.database import seeder
+        seeder.fresh()
+    else:
+        print('\nThis action was cancelled!')
+
+
 def save_data(data: str, filename: str) -> None:
     """ Save text content to a file """
     if filename:

requirements/dev.txt

@@ -12,4 +12,7 @@ pytest-mock==2.0.0
 Faker==4.0.2
 
 # Coverage
-coverage==4.5.1
+coverage==4.5.1
+
+# The Debug Toolbar
+Flask-DebugToolbar==0.11.0

requirements/prod.txt

@@ -13,10 +13,16 @@ Jinja2==2.11.1
 gunicorn==20.0.4
 
 #Swagger support for Restful API
-flask-restplus==0.13.0
+flask-restplus==0.12.1
 
 #Mocking
 Faker==4.0.2
 
 #CLI support
-Flask-Script==2.0.6
+Flask-Script==2.0.6
+
+# SQL database (MS SQL)
+flask_sqlalchemy==2.4.1
+
+# Handling requests
+requests==2.23.0

tests/conftest.py

@@ -1,18 +1,34 @@
 import pytest
+from _pytest.fixtures import FixtureRequest
 from flask import Flask
 from flask.testing import FlaskClient
 
 from time_tracker_api import create_app
 
+CONFIGURATIONS = ['AzureSQLDatabaseDevelopTestConfig']
 
-@pytest.fixture(scope='session')
-def app() -> Flask:
-    """An instance of the app for tests"""
-    return create_app()
+
+@pytest.fixture(scope='session', params=CONFIGURATIONS)
+def app(request: FixtureRequest) -> Flask:
+    return create_app("time_tracker_api.config.%s" % request.param)
 
 
 @pytest.fixture
 def client(app: Flask) -> FlaskClient:
-    """A test client for the app."""
     with app.test_client() as c:
         return c
+
+
+@pytest.fixture(scope="module")
+def sql_repository():
+    from .resources import PersonSQLModel
+    from time_tracker_api.database import seeder
+    from time_tracker_api.sql_repository import db
+
+    seeder.fresh()
+
+    from time_tracker_api.sql_repository import SQLRepository
+    yield SQLRepository(PersonSQLModel)
+
+    db.drop_all()
+    print("Models for test removed!")

tests/projects/projects_namespace_test.py

@@ -1,11 +1,16 @@
 from flask import json
+from flask.testing import FlaskClient
+from pytest_mock import MockFixture
 
 
-def test_list_should_return_nothing(client):
-    """Should return an empty array"""
+def test_list_all_elements(client: FlaskClient, mocker: MockFixture):
+    from time_tracker_api.projects.projects_namespace import project_dao
+    repository_find_all_mock = mocker.patch.object(project_dao.repository, 'find_all', return_value=[])
+
     response = client.get("/projects", follow_redirects=True)
 
     assert 200 == response.status_code
 
     json_data = json.loads(response.data)
     assert [] == json_data
+    repository_find_all_mock.assert_called_once()

tests/resources.py

@@ -0,0 +1,12 @@
+from time_tracker_api.sql_repository import db, AuditedSQLModel
+
+
+class PersonSQLModel(db.Model, AuditedSQLModel):
+    __tablename__ = 'tests'
+    id = db.Column(db.Integer, primary_key=True)
+    name = db.Column(db.String(80), unique=False, nullable=False)
+    email = db.Column(db.String(120), unique=True, nullable=False)
+    age = db.Column(db.Integer, nullable=False)
+
+    def __repr__(self):
+        return '<Test Model %r>' % self.name

tests/smoke_test.py

@@ -1,4 +1,2 @@
-
 def test_app_exists(app):
-    """Does app exists"""
     assert app is not None

tests/sql_repository_test.py

@@ -0,0 +1,83 @@
+from faker import Faker
+
+fake = Faker()
+
+existing_elements_registry = []
+last_deleted_element = None
+
+
+def test_create(sql_repository):
+    global sample_element
+    sample_element = dict(name=fake.name(),
+                          email=fake.safe_email(),
+                          age=fake.pyint(min_value=10, max_value=80))
+
+    result = sql_repository.create(sample_element)
+
+    assert result is not None
+    assert result.id is not None
+    assert result.created_at is not None
+    assert result.created_by is not None
+    assert result.updated_at is None
+    assert result.updated_by is None
+
+    existing_elements_registry.append(result)
+
+
+def test_find(sql_repository):
+    existing_element = existing_elements_registry[0]
+
+    found_element = sql_repository.find(existing_element.id)
+
+    assert found_element is not None
+    assert found_element.id is not None
+
+
+def test_update(sql_repository):
+    existing_element = existing_elements_registry[0]
+
+    updated_element = sql_repository.update(existing_element.id,
+                                            dict(name="Jon Snow", age=34))
+
+    assert updated_element is not None
+    assert updated_element.id == existing_element.id
+    assert updated_element.name == "Jon Snow"
+    assert updated_element.age == 34
+    assert updated_element.updated_at is not None
+    assert updated_element.updated_at > updated_element.created_at
+    assert updated_element.updated_by is not None
+
+
+def test_find_all(sql_repository):
+    existing_elements = sql_repository.find_all()
+
+    assert all(e in existing_elements_registry for e in existing_elements)
+
+
+def test_find_all_that_contains_property_with_string_case_insensitive(sql_repository):
+    fake_name = fake.name()
+    new_element = dict(name="%s Snow" % fake_name,
+                       email=fake.safe_email(),
+                       age=fake.pyint(min_value=10, max_value=80))
+    sql_repository.create(new_element)
+    existing_elements_registry.append(new_element)
+
+    search_snow_result = sql_repository.find_all_contain_str('name', 'Snow')
+    assert len(search_snow_result) == 2
+
+    search_jon_result = sql_repository.find_all_contain_str('name', 'Jon')
+    assert len(search_jon_result) == 1
+
+    search_ram_result = sql_repository.find_all_contain_str('name', fake_name)
+    assert search_ram_result[0].name == new_element['name']
+
+
+def test_delete_existing_element(sql_repository):
+    existing_element = existing_elements_registry[0]
+
+    result = sql_repository.remove(existing_element.id)
+
+    assert result is None
+
+    global last_deleted_model
+    last_deleted_model = existing_elements_registry.pop()