server_controller.py 5.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180
  1. import json
  2. from bottle import request, response
  3. import model
  4. from util import debug, str2bool
  5. def missing_attributes(attributes):
  6. for attr in attributes:
  7. if attr not in request.json:
  8. if str(attr) == 'session_id':
  9. return 'You are not signed in.'
  10. return 'Missing value for attribute ' + str(attr)
  11. if str(attr) == 'session_id':
  12. if not model.valid_session_id(request.json['session_id']):
  13. return 'You are not signed in.'
  14. return False
  15. def login():
  16. missing = missing_attributes(['username', 'password'])
  17. if missing:
  18. return bad_request(missing)
  19. username = request.json['username']
  20. password = request.json['password']
  21. session_id = model.login(username, password)
  22. if session_id:
  23. return {'session_id': session_id}
  24. else:
  25. return forbidden('Invalid login data')
  26. def depot():
  27. missing = missing_attributes(['session_id'])
  28. if missing:
  29. return bad_request(missing)
  30. data = model.get_user_ownership(model.get_user_id_by_session_id(request.json['session_id']))
  31. return {'data': data}
  32. def register():
  33. missing = missing_attributes(['username', 'password'])
  34. if missing:
  35. return bad_request(missing)
  36. username = request.json['username']
  37. password = request.json['password']
  38. if model.user_exists(username):
  39. return forbidden('User already exists.')
  40. game_key = ''
  41. if 'game_key' in request.json:
  42. game_key = request.json['game_key'].strip().upper()
  43. if game_key != '' and game_key not in model.unused_keys():
  44. return bad_request('Game key is not valid.')
  45. if model.register(username, password, game_key):
  46. return {'message': "successfully registered user"}
  47. else:
  48. return bad_request('registration not successful')
  49. def activate_key():
  50. missing = missing_attributes(['key', 'session_id'])
  51. if missing:
  52. return bad_request(missing)
  53. if model.valid_key(request.json['key']):
  54. user_id = model.get_user_id_by_session_id(request.json['session_id'])
  55. model.activate_key(request.json['key'], user_id)
  56. return {'message': "successfully activated key"}
  57. else:
  58. return bad_request('Invalid key.')
  59. def order():
  60. missing = missing_attributes(['buy', 'session_id', 'amount', 'ownable', 'time_until_expiration'])
  61. if missing:
  62. return bad_request(missing)
  63. if not model.ownable_name_exists(request.json['ownable']):
  64. return bad_request('This kind of object can not be ordered.')
  65. buy = request.json['buy']
  66. sell = not buy
  67. session_id = request.json['session_id']
  68. amount = request.json['amount']
  69. ownable_name = request.json['ownable']
  70. time_until_expiration = float(request.json['time_until_expiration'])
  71. if time_until_expiration < 0:
  72. return bad_request('Invalid expiration time.')
  73. ownable_id = model.ownable_id_by_name(ownable_name)
  74. user_id = model.get_user_id_by_session_id(session_id)
  75. model.own(user_id, ownable_name)
  76. ownership_id = model.get_ownership_id(ownable_id, user_id)
  77. try:
  78. if request.json['limit'] == '':
  79. limit = None
  80. else:
  81. limit = float(request.json['limit'])
  82. except ValueError: # for example when float fails
  83. limit = None
  84. except KeyError: # for example when limit was not specified
  85. limit = None
  86. try:
  87. if request.json['stop_loss'] == '':
  88. stop_loss = None
  89. else:
  90. stop_loss = 'stop_loss' in request.json and str2bool(request.json['stop_loss'])
  91. if stop_loss is not None and limit is None:
  92. return bad_request('Can only set stop loss for limit orders')
  93. except ValueError: # for example when bool fails
  94. return bad_request('Invalid value for stop loss')
  95. except KeyError: # for example when stop_loss was not specified
  96. limit = None
  97. # TODO test if stop loss works
  98. if sell:
  99. if not model.user_owns_at_least(user_id, amount, ownership_id):
  100. return bad_request('You can not sell more than you own.')
  101. model.place_order(buy, ownership_id, limit, stop_loss, amount, time_until_expiration)
  102. return {'message': "Order placed."}
  103. def orders():
  104. missing = missing_attributes(['session_id'])
  105. if missing:
  106. return bad_request(missing)
  107. data = model.get_user_orders(model.get_user_id_by_session_id(request.json['session_id']))
  108. return {'data': data}
  109. def orders_on():
  110. missing = missing_attributes(['session_id', 'ownable'])
  111. if missing:
  112. return bad_request(missing)
  113. if not model.ownable_name_exists(request.json['ownable']):
  114. return bad_request('This kind of object can not be ordered.')
  115. data = model.get_ownable_orders(model.ownable_id_by_name(request.json['ownable']))
  116. return {'data': data}
  117. def news():
  118. missing = missing_attributes(['session_id'])
  119. if missing:
  120. return bad_request(missing)
  121. return {'data': model.news()}
  122. def transactions():
  123. missing = missing_attributes(['session_id', 'ownable'])
  124. if missing:
  125. return bad_request(missing)
  126. if not model.ownable_name_exists(request.json['ownable']):
  127. return bad_request('This kind of object can not have transactions.')
  128. return {'data': model.transactions(model.ownable_id_by_name(request.json['ownable']))}
  129. def not_found(msg=''):
  130. response.status = 404
  131. if debug:
  132. msg = str(response.status) + ': ' + msg
  133. response.content_type = 'application/json'
  134. return json.dumps({"error_message": msg})
  135. def forbidden(msg=''):
  136. response.status = 403
  137. if debug:
  138. msg = str(response.status) + ' Forbidden: ' + msg
  139. response.content_type = 'application/json'
  140. return json.dumps({"error_message": msg})
  141. def bad_request(msg=''):
  142. response.status = 400
  143. if debug:
  144. msg = str(response.status) + ' Bad request: ' + msg
  145. response.content_type = 'application/json'
  146. return json.dumps({"error_message": msg})