inseret monthly forderungen

.gitlab-ci.yml

@@ -0,0 +1,37 @@
+stages:
+  - check
+  - dockerize
+
+variables:
+  IMAGE_NAME: $CI_REGISTRY/$CI_PROJECT_PATH
+
+  
+check:
+  image: registry.hottis.de/dockerized/base-build-env:latest
+  stage: check
+  tags:
+    - hottis
+    - linux
+    - docker
+  rules:
+    - if: $CI_COMMIT_TAG
+  script:
+    - checksemver.py -v
+        --versionToValidate "$CI_COMMIT_TAG"
+        --validateMessage
+        --messageToValidate "$CI_COMMIT_MESSAGE"
+
+dockerize:
+  image: registry.hottis.de/dockerized/docker-bash:latest
+  stage: dockerize
+  tags:
+    - hottis
+    - linux
+    - docker
+  rules:
+    - if: $CI_COMMIT_TAG
+  script:
+    - docker build --tag $IMAGE_NAME:latest --tag $IMAGE_NAME:$CI_COMMIT_TAG .
+    - docker login -u gitlab-ci-token -p $CI_JOB_TOKEN $CI_REGISTRY
+    - docker push $IMAGE_NAME:latest
+    - docker push $IMAGE_NAME:$CI_COMMIT_TAG

Dockerfile

@@ -10,10 +10,6 @@ ENV DB_HOST="172.16.10.18"
 ENV DB_NAME="hausverwaltung"
 ENV DB_USER="hausverwaltung-ui"
 ENV DB_PASS="test123"
-ENV JWT_ISSUER='de.hottis.hausverwaltung'
-ENV JWT_SECRET='streng_geheim'
-ENV JWT_LIFETIME_SECONDS=60
-ENV JWT_ALGORITHM='HS256'
 
 
 RUN \

ENV.tmpl

@@ -5,4 +5,3 @@ export DB_USER="hausverwaltung-ui"
 export DB_PASS="test123"
 export DB_NAME="hausverwaltung"
 
-export JWT_SECRET='streng_geheim'

Mieter.py

@@ -1,8 +1,6 @@
 from dbpool import getConnection, getMany, getOne
-from auth import check_scope
 
-def get_mieters(token_info):
+def get_mieters():
-    check_scope(token_info, [ "mieter/read", "wohnung/read", "objekt/read" ])
     return getMany("""
 SELECT m.id as id, 
        o.id as objekt,
@@ -23,8 +21,30 @@ SELECT m.id as id,
         w.id = m.wohnung
     """, [], "Mieter")
 
-def get_mieter(id, token_info):
+def get_mieters_active():
-    check_scope(token_info, [ "mieter/read", "wohnung/read", "objekt/read" ])
+    return getMany("""
+SELECT m.id as id, 
+       o.id as objekt,
+       w.id as wohnung,
+       w.shortname as wohnung_shortname, 
+       o.shortname as objekt_shortname,
+       COALESCE(m.anrede, '-') as anrede,
+       COALESCE(m.vorname, '-') as vorname,
+       m.nachname as nachname,
+       COALESCE(m.strasse, '-') as strasse,
+       COALESCE(m.plz, '-') as plz,
+       COALESCE(m.ort, '-') as ort,
+       COALESCE(m.telefon, '-') as telefon,
+       m.einzug as einzug,
+       COALESCE(m.auszug, '-') as auszug
+  FROM wohnung w, objekt o, mieter m
+  WHERE o.id = w.objekt AND
+        w.id = m.wohnung AND
+        m.einzug <= curdate() and
+        (m.auszug is null or m.auszug > curdate())
+    """, [], "Mieter")
+
+def get_mieter(id=None):
     return getOne("""
 SELECT m.id as id, 
        o.id as objekt,

Objekte.py

@@ -1,11 +1,8 @@
 from dbpool import getConnection, getMany, getOne
-from auth import check_scope
 
-def get_objekte(token_info):
+def get_objekte():
-    check_scope(token_info, "objekt/read")
     return getMany("SELECT id, shortname, flaeche FROM objekt", [], "Objekt")
 
-def get_objekt(id, token_info):
+def get_objekt(id=None):
-    check_scope(token_info, "objekt/read")
     return getOne("SELECT id, shortname, flaeche FROM objekt WHERE id = ?", 
                   (id,), "Objekt")

Wohnungen.py

@@ -1,9 +1,6 @@
 from dbpool import getConnection, getOne, getMany
-from auth import check_scope
 
-
+def get_wohnungen():
-def get_wohnungen(token_info):
-    check_scope(token_info, "wohnung/read")
     return getMany("""
 SELECT w.id as id, 
        w.objekt as objekt, 
@@ -14,8 +11,7 @@ SELECT w.id as id,
   WHERE o.id = w.objekt
 """, [], "Wohnung")
 
-def get_wohnung(id, token_info):
+def get_wohnung(id=None):
-    check_scope(token_info, [ "wohnung/read", "objekt/read" ])
     return getOne("""
 SELECT w.id as id, 
        w.objekt as objekt, 
@@ -27,8 +23,7 @@ SELECT w.id as id,
         w.id = ?
 """, (id, ), "Wohnung")
 
-def get_wohnungen_by_objekt(id, token_info):
+def get_wohnungen_by_objekt(id):
-    check_scope(token_info, [ "wohnung/read", "objekt/read" ])
     return getMany("""
 SELECT w.id as id, 
        w.objekt as objekt, 

ZahlungenForderungen.py

@@ -1,11 +1,9 @@
-from dbpool import getConnection, getOne, getMany, putOne
+from dbpool import getConnection, getOne, getMany, putOne, call
 import datetime
 import decimal
 import dateparser
-from auth import check_scope
 
-def get_zahlungen_by_mieter(mieter_id, token_info):
+def get_zahlungen_by_mieter(mieter_id):
-  check_scope(token_info, "zahlung/read")
   return getMany("""
 SELECT id, 
        mieter, 
@@ -30,8 +28,7 @@ SELECT id,
 """, [ id ], "Zahlung")
 
 
-def get_forderungen_by_mieter(mieter_id, token_info):
+def get_forderungen_by_mieter(mieter_id):
-  check_scope(token_info, "forderung/read")
   return getMany("""
 SELECT id, 
        mieter,
@@ -43,8 +40,7 @@ SELECT id,
   WHERE mieter = ?
 """, [ mieter_id ], "Forderung")
 
-def get_forderung(id, token_info):
+def get_forderung(id):
-  check_scope(token_info, "forderung/read")
   return getOne("""
 SELECT id, 
        mieter,
@@ -56,8 +52,7 @@ SELECT id,
   WHERE id = ?
 """, [ id ], "Forderung")
 
-def get_zahlungforderung_by_mieter_and_year(mieter_id, year, token_info):
+def get_zahlungforderung_by_mieter_and_year(mieter_id, year):
-  check_scope(token_info, [ "forderung/read", "zahlung/read", "mieter/read" ])
   if year == 0:
     year = datetime.datetime.now().year
   start_date = "{}-01-01".format(year)
@@ -77,8 +72,7 @@ WHERE mieter = ? AND
   datum_soll BETWEEN ? AND ?
 """, [mieter_id, start_date, end_date], "ZahlungForderung")
 
-def get_saldo_by_mieter_and_year(mieter_id, year, token_info):
+def get_saldo_by_mieter_and_year(mieter_id, year):
-  check_scope(token_info, [ "forderung/read", "zahlung/read", "mieter/read" ])
   if year == 0:
     year = datetime.datetime.now().year
   start_date = "{}-01-01".format(year)
@@ -112,12 +106,22 @@ WHERE mieter = ? AND
     "zahlungen": float(sumZ)
   }
 
-def put_zahlung(zahlung, token_info):
+def put_zahlung(**args):
-  check_scope(token_info, "zahlung/write")
+  try:
-  print("Input of put_zahlung: {} {}".format(type(zahlung), zahlung))
+    body = args["body"]
-  datum_soll = dateparser.parse(zahlung["datum_soll"], languages=["de"])
+    datum_soll_raw = body["datum_soll"]
-  datum_ist = dateparser.parse(zahlung["datum_ist"], languages=["de"])
+    datum_ist_raw = body["datum_ist"]
-  return putOne("""
+
+    print("Input of put_zahlung: {}".format(body))
+    datum_soll = dateparser.parse(datum_soll_raw, languages=["de"])
+    datum_ist = dateparser.parse(datum_ist_raw, languages=["de"])
+    return putOne("""
 INSERT INTO zahlung (datum_soll, datum_ist, mieter, betrag, kommentar)
   VALUES(?, ?, ?, ?, ?)
-""", [ datum_soll, datum_ist, zahlung["mieter"], zahlung["betrag"], zahlung["kommentar"] ], "Zahlung")
+""", [ datum_soll, datum_ist, body["mieter"], body["betrag"], body["kommentar"] ], "Zahlung")
+  except KeyError as e:
+    print("Some parameter missing: {}".format(e))
+    return str(e), 500
+
+def insertAllForMonth():
+  return call("insert_monatl_miet_forderung")

auth.py

@@ -1,44 +0,0 @@
-import time
-import connexion
-from werkzeug.exceptions import Unauthorized, Forbidden
-from jose import JWTError, jwt
-import os
-
-JWT_SECRET = os.environ['JWT_SECRET']
-
-
-
-def decode_token(token):
-    try:
-        print("DEBUG decode_token: try to decode")
-        token_info = jwt.decode(token, JWT_SECRET)
-        print("DEBUG decode_token: token_info: {}".format(token_info))
-        return token_info
-    except JWTError as e:
-        print("ERROR decode_token: error when decoding token: {}".format(e))
-        raise Unauthorized()
-
-def check_token(token, key, value):
-    if (key in token) and ((token[key] == value) or (isinstance(token[key], list) and (value in token[key]))):
-        return True
-    print("WARN: check_token: {} -> {} required but not granted".format(key, value))
-    raise Forbidden()
-
-def check_scope(token, value):
-    if isinstance(value, list):
-        for v in value:
-            check_token(token, "x-scope", v)
-    else:
-        check_token(token, "x-scope", value)
-
-def get_secret(user, token_info) -> str:
-    return '''
-    You are user_id {user} and the secret is 'wbevuec'.
-    Decoded token claims: {token_info}.
-    '''.format(user=user, token_info=token_info)
-
-
-
-def _current_timestamp() -> int:
-    return int(time.time())
-

build.sh

@@ -1,7 +1,7 @@
 #!/bin/bash
 
 IMAGE_NAME="registry.hottis.de/hv/hv-service"
-VERSION=0.0.3
+VERSION=0.0.4
 
 docker build -t ${IMAGE_NAME}:${VERSION} .
 docker push ${IMAGE_NAME}:${VERSION}

dbpool.py

@@ -83,6 +83,7 @@ def putOne(stmt, params, objName):
     except mariadb.Error as err:
         dbh.rollback()
         print("Database error in putOne({}): {}".format(objName, err))
+        return str(err), 500
     except Exception as err:
         dbh.rollback()
         print("Error in putOne({}): {}".format(objName, err))
@@ -94,3 +95,26 @@ def putOne(stmt, params, objName):
         if dbh:
             dbh.close()
 
+def call(procName):
+    dbh = None
+    cur = None
+    try:
+        dbh = getConnection()
+        cur = dbh.cursor(dictionary=True)
+        cur.execute("CALL {}(null)".format(procName))
+        dbh.commit()
+        return "{} successfully called {}".format(procName), 202
+    except mariadb.Error as err:
+        dbh.rollback()
+        print("Database error in call {}: {}".format(procName, err))
+        return str(err), 500
+    except Exception as err:
+        dbh.rollback()
+        print("Some error in call {}: {}".format(procName, err))
+        return str(err), 500
+    finally:
+        print("return connection in call {}".format(procName))
+        if cur:
+            cur.close()
+        if dbh:
+            dbh.close()

run.sh

@@ -15,8 +15,4 @@ docker run \
     -e DB_USER=$DB_USER \
     -e DB_PASS=$DB_PASS \
     -e DB_NAME=$DB_NAME \
-    -e JWT_ISSUER=$JWT_ISSUER \
-    -e JWT_SECRET=$JWT_SECRET \
-    -e JWT_LIFETIME_SECONDS=$JWT_LIFETIME_SECONDS \
-    -e JWT_ALGORITHM=$JWT_ALGORITHM
     ${IMAGE_NAME}:${VERSION}

server.py

@@ -3,7 +3,7 @@ from flask_cors import CORS
 
 # instantiate the webservice
 app = connexion.App(__name__)
-app.add_api('openapi.yaml')
+app.add_api('swagger.yaml')
 
 # CORSify it - otherwise Angular won't accept it
 CORS(app.app)

swagger.yaml

@@ -3,9 +3,6 @@ info:
   title: Hausverwaltung
   version: "0.1"
 
-security:
-  - jwt: []
-
 paths:
   /hv/objekte:
     get:
@@ -129,9 +126,24 @@ paths:
           description: No Mieter available
         500:
           description: Some server error
-      security:
+  /hv/mieters/active:
-      - jwt: ['secret']
+    get:
-
+      tags: [ "Mieter" ]
+      operationId: Mieter.get_mieters_active
+      summary: Returns all currently active Mieters
+      responses:
+        200:
+          description: Successful response.
+          content:
+            'application/json':
+              schema:
+                type: array
+                items:
+                  $ref: '#/components/schemas/Mieter'
+        404:
+          description: No Mieter available
+        500:
+          description: Some server error
   /hv/mieter/{id}:
     get:
       tags: [ "Mieter" ]
@@ -308,8 +320,9 @@ paths:
       operationId: ZahlungenForderungen.put_zahlung
       summary: Inserts a new Zahlung
       requestBody:
+        description: Zahlung
         content:
-          'application/json':
+          application/json:
             schema:
               $ref: '#/components/schemas/Zahlung'
       responses:
@@ -317,28 +330,20 @@ paths:
           description: Zahlung successfully inserted
         500:
           description: Some server or database error
-  /secret:
+  /hv/forderung/insertAllForMonth:
-    get:
+    post:
-      tags: [ "JWT" ]
+      tags: [ "Forderung" ]
-      summary: Return secret string
+      operationId: ZahlungenForderungen.insertAllForMonth
-      operationId: auth.get_secret
+      summary: Insert the Forderungen for the insertAllForMonth
       responses:
-        '200':
+        202:
-          description: secret response
+          description: Forderungen successfully inserted
-          content:
+        500:
-            'text/plain':
+          description: Some server or database error
-              schema:
-                type: string
 
 
 
 components:
-  securitySchemes:
-    jwt:
-      type: http
-      scheme: bearer
-      bearerFormat: JWT
-      x-bearerInfoFunc: auth.decode_token
   schemas:
     Objekt:
       description: Objekt type