Industry 4.0 Car Parking Marketplace (IOTA+iBeacon+ML)

import flask
from flask import request, jsonify
from flask_cors import CORS
from iotamp import IndustryMarketplace
import pprint
import sys
import threading
import sqlite3
import json


class ServiceRequesterApi(IndustryMarketplace):
    name = 'Robocops'
    service_provider = False
    fund_wallet = False
    gps_coords = '54.000, 4.000'

    endpoint = 'http://localhost:4000'
    con = sqlite3.connect('requestor-database.db',check_same_thread=False)

    def find_conversation(self, con,conversationId, messageId):
        cursorObj = con.cursor()
        cursorObj.execute('SELECT * FROM CONVERSATION_LOG WHERE id =? and messageId=?',[conversationId,messageId])
        rows = cursorObj.fetchall()
        return len(rows)
    
    def find_conversation_data(self,conversationId, messageId):
        cursorObj = self.con.cursor()
        cursorObj.execute('SELECT * FROM CONVERSATION_LOG WHERE id =? and messageId=?',[conversationId,messageId])
        rows = cursorObj.fetchall()
        return json.loads(rows[0][3])

    def log_conversation(self,con,entity):
        cursorObj = con.cursor()
        cursorObj.execute('INSERT INTO CONVERSATION_LOG(id,messageId,type,data ) VALUES(?, ?, ?,?)', entity)
        con.commit()
    
    def on_proposal(self, data, irdi, submodels):
        '''
        Accept only if the price is between 5 and 15
        '''
        self.log('on proposal called!')
        try:
            #self.log(data)
            price = self.get_price(irdi, submodels)
            beacon = self.get_beacon(irdi, submodels)
            vin = self.get_vin(irdi, submodels)
            location = self.get_location(irdi, submodels)
            userName = data['userName']
            conversationId = data['frame']['conversationId']
            messageId = data['frame']['messageId']
            messageType = data['frame']['type']

            count = self.find_conversation(self.con,conversationId,messageId)
            self.log('Count '+ str(count))

            if count == 0:
                self.log('Received proposal for %si for irdi %s' % (price, irdi))
                self.log_conversation(self.con,(conversationId,messageId,messageType,json.dumps(data)))
                if not price:
                    self.log('Price not found, submodels: %s' % submodels)
            
                self.publish('/iotamp/car/%s/tx' % (vin),json.dumps({'price':price,'type':'prop-recv','user':userName,'conversationId':conversationId,'messageId':messageId,'loc':location,'vin':vin}))
            

            

            # if price >= 5 and price <= 15:
            #     self.log('Accepting proposal')
            #     self.accept_proposal(data)
            # else:
            #     self.log('Rejecting proposal')
            #     self.reject_proposal(data)
        except Exception as e:
            self.log('Error on accepting: %s' % e)

    def on_inform_confirm(self, data, irdi, submodels):

        conversationId = data['frame']['conversationId']
        messageId = data['frame']['messageId']
        messageType = data['frame']['type']
        vin = self.get_vin(irdi, submodels)
        userName = data['userName']
        count = self.find_conversation(self.con,conversationId,messageId)
        self.log('Count '+ str(count))
        if count == 0:
            self.log('Offer confirmed, time to pay')
            self.log_conversation(self.con,(conversationId,messageId,messageType,json.dumps(data)))
            #self.inform_payment(data)
            self.publish('/iotamp/car/%s/pay' % (vin),json.dumps({'user':userName,'conversationId':conversationId,'messageId':messageId}))


app = flask.Flask(__name__)
app.config["DEBUG"] = True
CORS(app)
conn = sqlite3.connect('requestor-database.db',check_same_thread=False)

def find_conversation_data(con,conversationId, messageId):
        cursorObj = con.cursor()
        cursorObj.execute('SELECT * FROM CONVERSATION_LOG WHERE id =? and messageId=?',[conversationId,messageId])
        rows = cursorObj.fetchall()
        return json.loads(rows[0][3])


@app.route('/api/v1/user', methods=['GET'])
def api_user():
    return imp.user()


# 0173-1#02-AAF631#001 - used for VIN
# 0173-1#02-AAO742#002 - used for iBeacon advertisement 

@app.route('/api/v1/parking', methods=['POST'])
def request_for_parking():
    # values = {
    #         "0173-1#02-AAO742#002":"74278BDA-7427-8BDD-8F0C-720EAF059935",
    #         "0173-1#02-AAJ102#003":10,
    #         "0173-1#02-AAJ101#003":84,
    #         "0173-1#02-BAF464#008":True,
    #         "0173-1#02-AAF631#001":"WP0CB29858U731930",
    #         "0173-1#02-AAB733#007":3,
    #         "0173-1#02-AAP397#001":1,
    #         "0173-1#02-BAF163#002":"51.4121278, 13.0547193"

    #     }

    values = {
            "0173-1#02-AAO742#002":request.json['uuid'],
            "0173-1#02-AAJ102#003":10,
            "0173-1#02-AAJ101#003":84,
            "0173-1#02-BAF464#008":True,
            "0173-1#02-AAF631#001":request.json['vin'],
            "0173-1#02-AAB733#007":3,
            "0173-1#02-AAP397#001":1,
            "0173-1#02-BAF163#002":request.json['location']

        }
    

    ret = imp.cfp(irdi='0173-1#01-AAO742#002', values=values, location=request.json['location'])
    return jsonify(ret)

@app.route('/api/v1/proposal/accept', methods=['POST'])
def accept_proposal_manually():
    data = imp.find_conversation_data(request.json['conversationId'],request.json['messageId'])
    ret = imp.accept_proposal(data)

    imp.publish('/iotamp/car/%s/ibeacon/write' % (request.json['vin']),'on')
    return ret

@app.route('/api/v1/proposal/reject', methods=['POST'])
def reject_proposal_manually():
    data = imp.find_conversation_data(request.json['conversationId'],request.json['messageId'])
    return imp.reject_proposal(data)

@app.route('/api/v1/pay', methods=['POST'])
def pay_manually():
    data = imp.find_conversation_data(request.json['conversationId'],request.json['messageId'])
    return imp.inform_payment(data)

if __name__ == '__main__':
    imp = ServiceRequesterApi()
    threading.Thread(target=imp.listen,daemon=False).start()
    app.run(port=5000,threaded=True,debug=False)
    

CREATE TABLE "CONVERSATION_LOG" (
	"id"	TEXT,
	"messageId"	TEXT,
	"type"	TEXT,
	"data"	TEXT,
	"status"	INTEGER DEFAULT 0
);

from imp import IndustryMarketplace
import pprint
import sys

class ServiceRequester(IndustryMarketplace):
    name = 'ProSumer'
    service_provider = False
    fund_wallet = True
    gps_coords = '54.000, 4.000'

    endpoint = 'http://localhost:4000'
    
    def on_proposal(self, data, irdi, submodels):
        '''
        Accept only if the price is between 5 and 15
        '''
        self.log('on proposal called!')
        try:
            price = self.get_price(irdi, submodels)
            self.log('Received proposal for %si for irdi %s' % (price, irdi))
            if not price:
                self.log('Price not found, submodels: %s' % submodels)

            if price >= 5 and price <= 15:
                self.log('Accepting proposal')
                self.accept_proposal(data)
            else:
                self.log('Rejecting proposal')
                self.reject_proposal(data)
        except Exception as e:
            self.log('Error on accepting: %s' % e)

    def on_inform_confirm(self, data, irdi, submodels):
        self.log('Offer confirmed, time to pay')
        self.inform_payment(data)


if __name__ == '__main__':

    imp = ServiceRequester()
    
    # Either run it as a listeing service
    if len(sys.argv) == 1:
        imp.listen()
    
    # Or as a one time command requesting a drone!
    if len(sys.argv) == 2 and sys.argv[1] == 'request_drone':

        values = {
            '0173-1#02-AAJ336#002': 2,
            '0173-1#02-BAF163#002': '54.1234, 4.3210',
            '0173-1#02-AAO631#002': '54.4321, 4.5210',

        }

        ret = imp.cfp(irdi='0173-1#01-AAJ336#002', values=values, location='54.321, 4.123')
        #pprint.pprint(ret)
    
    if len(sys.argv) == 2 and sys.argv[1] == 'drone_inspection':

        values = {
            '0173-1#02-AAP788#001': 2,
            '0173-1#02-AAY979#001': 10,
            '0173-1#02-BAF163#002': '54.4321, 4.5210',
        }

        ret = imp.cfp(irdi='0173-1#01-AAP788#001', values=values, location='54.321, 4.123')
        pprint.pprint(ret)

    if len(sys.argv) == 2 and sys.argv[1] == 'ev_charging':

        values = {
            "0173-1#02-AAO742#002":"74278BDA-7427-8BDD-8F0C-720EAF059935",
            "0173-1#02-AAJ102#003":10,
            "0173-1#02-AAJ101#003":84,
            "0173-1#02-AAF631#001":"kthxhkjkxf",
            "0173-1#02-AAB733#007":3,
            "0173-1#02-AAP397#001":1,
            "0173-1#02-BAF163#002":"51.4121278, 13.0547193"

        }

        ret = imp.cfp(irdi='0173-1#01-AAO742#002', values=values, location='54.321, 4.123')