22
33import jwt
44import structlog
5+ from sqlalchemy .orm import exc
6+
57from opentaxii .auth import OpenTAXIIAuthAPI
68from opentaxii .common .sqldb import BaseSQLDatabaseAPI
79from opentaxii .entities import Account as AccountEntity
8- from sqlalchemy .orm import exc
910
1011from .models import Account , Base
1112
@@ -32,16 +33,19 @@ class SQLDatabaseAPI(BaseSQLDatabaseAPI, OpenTAXIIAuthAPI):
3233 BASEMODEL = Base
3334
3435 def __init__ (
35- self ,
36- db_connection ,
37- create_tables = False ,
38- secret = None ,
39- token_ttl_secs = None ,
40- ** engine_parameters ):
36+ self ,
37+ db_connection ,
38+ create_tables = False ,
39+ secret = None ,
40+ token_ttl_secs = None ,
41+ ** engine_parameters ,
42+ ):
4143 super ().__init__ (db_connection , create_tables , ** engine_parameters )
4244 if not secret :
43- raise ValueError ('Secret is not defined for %s.%s' % (
44- self .__module__ , self .__class__ .__name__ ))
45+ raise ValueError (
46+ 'Secret is not defined for %s.%s'
47+ % (self .__module__ , self .__class__ .__name__ )
48+ )
4549 self .secret = secret
4650 self .token_ttl_secs = token_ttl_secs or 60 * 60 # 60min
4751
@@ -71,18 +75,25 @@ def get_account(self, token):
7175 return account_to_account_entity (account )
7276
7377 def delete_account (self , username ):
74- account = self .db .session .query (Account ).filter_by (username = username ).one_or_none ()
78+ account = (
79+ self .db .session .query (Account ).filter_by (username = username ).one_or_none ()
80+ )
7581 if account :
7682 self .db .session .delete (account )
7783 self .db .session .commit ()
7884
7985 def get_accounts (self ):
8086 return [
8187 account_to_account_entity (account )
82- for account in self .db .session .query (Account ).all ()]
88+ for account in self .db .session .query (Account ).all ()
89+ ]
8390
8491 def update_account (self , obj , password = None ):
85- account = self .db .session .query (Account ).filter_by (username = obj .username ).one_or_none ()
92+ account = (
93+ self .db .session .query (Account )
94+ .filter_by (username = obj .username )
95+ .one_or_none ()
96+ )
8697 if not account :
8798 account = Account (username = obj .username )
8899 self .db .session .add (account )
@@ -120,4 +131,5 @@ def account_to_account_entity(account):
120131 id = account .id ,
121132 username = account .username ,
122133 is_admin = account .is_admin ,
123- permissions = account .permissions )
134+ permissions = account .permissions ,
135+ )
0 commit comments