PTV/v25
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

thread-safety and failing autoincrement

Browse Source
This commit is contained in:
AF 2020-08-05 23:26:49 +03:00
parent 94eb71488d
commit 055ca35e1d
1 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
v25/storage/dbstorage.py
View File

@ -1,7 +1,7 @@
from typing import Tuple, Optional, Iterable
from nacl.bindings import crypto_sign_PUBLICKEYBYTES
from sqlalchemy import create_engine, LargeBinary, Column, REAL, BLOB, String, or_, and_, BigInteger
from sqlalchemy import create_engine, LargeBinary, Column, REAL, BLOB, String, or_, and_, ForeignKeyConstraint, Integer
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker, Query
@ -24,14 +24,19 @@ class MsgSgn(Base):
class Msg(Base):
__tablename__ = 'msgs'
sf = Column(LargeBinary(crypto_sign_PUBLICKEYBYTES), primary_key=True)
st = Column(LargeBinary(crypto_sign_PUBLICKEYBYTES), primary_key=True)
idn = Column(LargeBinary(NONCE_SIZE), primary_key=True)
oid = Column(Integer, autoincrement=True, primary_key=True)
sf = Column(LargeBinary(crypto_sign_PUBLICKEYBYTES))
st = Column(LargeBinary(crypto_sign_PUBLICKEYBYTES))
idn = Column(LargeBinary(NONCE_SIZE))
ts = Column(REAL, nullable=False, index=True)
en = Column(LargeBinary(NONCE_SIZE), nullable=False)
ec = Column(BLOB, nullable=False)
flags = Column(String, nullable=False)
oid = Column(BigInteger, autoincrement=True, index=True, unique=True, nullable=False)
__table_args__ = (ForeignKeyConstraint((sf, st, idn,),
(MsgSgn.sf, MsgSgn.st, MsgSgn.idn,),
),
)
def sgn(self):
return MsgSgn(sf=self.sf, st=self.st, idn=self.idn)
@ -124,7 +129,9 @@ class DBStorage(AbstractStorage):
query = query.order_by(Msg.oid.desc())
if 'limit' in params:
query = query.limit(params['limit'])
return map(Msg.to_message, query.from_self().order_by(Msg.oid))
messages = map(Msg.to_message, list(query.from_self().order_by(Msg.oid)))
session.close()
return messages
def flags(self, m: Message, flags: str):
session = self.Session()