WIP, berths dont work yet
This commit is contained in:
parent
d4cad33513
commit
f64ea1b7cd
@ -69,9 +69,18 @@ CREATE TABLE `participant` (
|
|||||||
PRIMARY KEY (`id`)
|
PRIMARY KEY (`id`)
|
||||||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='An organization taking part';
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='An organization taking part';
|
||||||
|
|
||||||
|
|
||||||
CREATE TABLE `berth` (
|
CREATE TABLE `berth` (
|
||||||
`id` int(10) unsigned NOT NULL AUTO_INCREMENT,
|
`id` int(10) unsigned NOT NULL AUTO_INCREMENT,
|
||||||
`name1` varchar(128) DEFAULT NULL,
|
`name1` varchar(128) DEFAULT NULL,
|
||||||
`name2` varchar(128) DEFAULT NULL,
|
`name2` varchar(128) DEFAULT NULL,
|
||||||
PRIMARY KEY(`id`)
|
PRIMARY KEY(`id`)
|
||||||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='Place of ship for a ship call';
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='Place of ship for a ship call';
|
||||||
|
|
||||||
|
|
||||||
|
CREATE TABLE `shipcall_participant_map` (
|
||||||
|
`id` int(11) NOT NULL AUTO_INCREMENT,
|
||||||
|
`shipcall_id` int(10) unsigned DEFAULT NULL,
|
||||||
|
`participant_id` int(10) unsigned DEFAULT NULL,
|
||||||
|
PRIMARY KEY (`id`)
|
||||||
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='Associates a participant with a shipcall';
|
||||||
|
|||||||
@ -13,7 +13,6 @@ from .api import participant
|
|||||||
from .api import times
|
from .api import times
|
||||||
from .api import notifications
|
from .api import notifications
|
||||||
from .api import berths
|
from .api import berths
|
||||||
from .impl import util
|
|
||||||
|
|
||||||
|
|
||||||
def create_app(test_config=None):
|
def create_app(test_config=None):
|
||||||
|
|||||||
@ -9,5 +9,5 @@ bp = Blueprint('berths', __name__)
|
|||||||
|
|
||||||
@bp.route('/berths', methods=['get'])
|
@bp.route('/berths', methods=['get'])
|
||||||
def GetBerths():
|
def GetBerths():
|
||||||
|
token = request.headers.get('Authentication')
|
||||||
return impl.berths.GetBerths()
|
return impl.berths.GetBerths(token)
|
||||||
|
|||||||
@ -1,19 +1,27 @@
|
|||||||
import json
|
import json
|
||||||
import logging
|
import logging
|
||||||
|
import pydapper
|
||||||
|
|
||||||
def GetBerths():
|
from ..schemas import model
|
||||||
|
from ..schemas import __init__
|
||||||
|
|
||||||
|
def GetBerths(token):
|
||||||
|
"""
|
||||||
|
No parameters, gets all entries
|
||||||
"""
|
"""
|
||||||
|
|
||||||
"""
|
# TODO: validate token
|
||||||
|
|
||||||
# Implement your business logic here
|
try:
|
||||||
# All the parameters are present in the options argument
|
|
||||||
|
|
||||||
return json.dumps([{
|
commands = pydapper.using(__init__.connection_pool)
|
||||||
"id": "<integer>",
|
data = commands.query("SELECT id, name1, name2 FROM berth ORDER BY name1", model=model.BerthList)
|
||||||
"name1": "<string>",
|
|
||||||
"name2": "<string>",
|
except Exception as ex:
|
||||||
}]), 200
|
logging.error(ex)
|
||||||
|
return json.dumps("call failed"), 500
|
||||||
|
|
||||||
|
return json.dumps(data), 200
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@ -10,7 +10,7 @@ def GetVerify(apikey):
|
|||||||
:param apikey: the api-key registered with the user
|
:param apikey: the api-key registered with the user
|
||||||
"""
|
"""
|
||||||
|
|
||||||
if not apikey
|
if not apikey:
|
||||||
return json.dumps("missing api key"), 400
|
return json.dumps("missing api key"), 400
|
||||||
|
|
||||||
sentinel = object()
|
sentinel = object()
|
||||||
@ -21,8 +21,11 @@ def GetVerify(apikey):
|
|||||||
return json.dumps("wrong api key", 403)
|
return json.dumps("wrong api key", 403)
|
||||||
|
|
||||||
except Exception as ex:
|
except Exception as ex:
|
||||||
|
logging.error(ex)
|
||||||
return json.dumps("logon failed"), 500
|
return json.dumps("logon failed"), 500
|
||||||
logging.error(e)
|
|
||||||
|
|
||||||
|
# TODO: user authenticated: Create,store and transmit JWT token
|
||||||
|
|
||||||
return json.dumps("<integer>"), 200
|
return json.dumps("<integer>"), 200
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user