Commit 0168c006 authored by Stavros-Anastasios Charismiadis's avatar Stavros-Anastasios Charismiadis
Browse files

[Not working commit] Migrate Invoker and Provider Management

parent 221d7369
Loading
Loading
Loading
Loading
Loading
+13 −10
Original line number Diff line number Diff line
@@ -2,10 +2,10 @@

import connexion
import logging
import encoder
import api_invoker_management.encoder
from flask_jwt_extended import JWTManager, jwt_required, create_access_token
from config import Config
from core.consumer_messager import Subscriber
from .config import Config
from .core.consumer_messager import Subscriber
from logging.handlers import RotatingFileHandler
import os
from fluent import sender
@@ -116,11 +116,12 @@ def verbose_formatter():
with open("/usr/src/app/api_invoker_management/pubkey.pem", "rb") as pub_file:
            pub_data = pub_file.read()

app = connexion.App(__name__, specification_dir='./openapi/')
app.app.json_encoder = encoder.JSONEncoder
app.add_api('openapi.yaml',
            arguments={'title': 'CAPIF_API_Invoker_Management_API'},
            pythonic_params=True)
# app = connexion.App(__name__, specification_dir='./openapi/')
app = connexion.App(__name__)
app.app.json_encoder = api_invoker_management.encoder.JSONEncoder
# app.add_api('openapi.yaml',
#             arguments={'title': 'CAPIF_API_Invoker_Management_API'},
#             pythonic_params=True)

app.app.config['JWT_ALGORITHM'] = 'RS256'
app.app.config['JWT_PUBLIC_KEY'] = pub_data
@@ -138,6 +139,8 @@ if monitoring_value == "true":
executor = Executor(app.app)
subscriber = Subscriber()

@app.app.before_first_request

# @app.app.before_first_request
def create_listener_message():
    with app.app.app_context():
        executor.submit(subscriber.listen)
 No newline at end of file
+1 −1
Original line number Diff line number Diff line
from app import app
from .app import app

if __name__ == "__main__":
    app.run()
+1 −1
Original line number Diff line number Diff line
@@ -5,7 +5,7 @@ import os
class Config:
	def __init__(self):
		self.cached = 0
		self.file="../config.yaml"
		self.file="./config.yaml"
		self.my_config = {}

		stamp = os.stat(self.file).st_mtime
+1 −1
Original line number Diff line number Diff line
from abc import ABC, abstractmethod
from db.db import MongoDatabse
from api_invoker_management.db.db import MongoDatabse

class Resource(ABC):

+1 −1
Original line number Diff line number Diff line
import time
from pymongo import MongoClient
from pymongo.errors import AutoReconnect
from config import Config
from api_invoker_management.config import Config
from bson.codec_options import CodecOptions
import os
from opentelemetry.instrumentation.pymongo import PymongoInstrumentor
Loading