xan/xenu_nntp
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix HEAD, BODY

Browse source
This commit is contained in:
XANTRONIX Development 2024-11-25 20:34:26 -05:00
parent 0fc03c3b21
commit dcd639e96d
1 changed files with 7 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
lib/nntp/tiny/session.py
View file

@ -408,28 +408,24 @@ class Session():
return self.end()
def _message_by_id(self, identifier: str):
cr = None
if identifier[0] == '<':
cr = self.db.query(Message, {
return self.db.get(Message, {
'newsgroup_id': self.newsgroup.id,
'message_id': identifier
})
else:
cr = self.db.query(Message, {
return self.db.get(Message, {
'newsgroup_id': self.newsgroup.id,
'id': int(identifier)
})
return cr.fetchone()
def _send_message_headers(self, message: Message):
for name in message.headers:
self.print("%s: %s" % (
name, message.headers[name]
))
def _serve_message(self, part: MessagePart, identifier: Optional[str]):
def _serve_message(self, part: MessagePart, identifier: Optional[str]=None):
if self.newsgroup is None:
return self.respond(ResponseCode.NNTP_NEWSGROUP_NOT_SELECTED)
@ -443,7 +439,7 @@ class Session():
self.article_id = message.id
else:
if identifier is None:
message = self._message_by_id(self.article_id)
message = self._message_by_id(str(self.article_id))
else:
message = self._message_by_id(identifier)
self.article_id = message.id
@ -466,13 +462,13 @@ class Session():
return self.end()
def _cmd_head(self, identifier: Optional[str]):
def _cmd_head(self, identifier: Optional[str]=None):
return self._serve_message(MessagePart.HEAD, identifier)
def _cmd_body(self, identifier: Optional[str]):
def _cmd_body(self, identifier: Optional[str]=None):
return self._serve_message(MessagePart.BODY, identifier)
def _cmd_article(self, identifier: Optional[str]):
def _cmd_article(self, identifier: Optional[str]=None):
return self._serve_message(MessagePart.WHOLE, identifier)
COMMANDS = {