|
|
|
@ -127,7 +127,7 @@ async def _video_worker(): |
|
|
|
|
text = 'New video' |
|
|
|
|
if is_late: |
|
|
|
|
text += ' (is late)' |
|
|
|
|
text += f': {video_json["title"]}' |
|
|
|
|
text += f': {video_json["title"]}\nhttps://youtube.com/watch?v={video_json["id"]}' |
|
|
|
|
with BytesIO(json.dumps(video_json, indent=4).encode()) as file: |
|
|
|
|
file.name = video_json['id'] + '.json' |
|
|
|
|
file.seek(0) |
|
|
|
@ -179,7 +179,7 @@ async def _upload_worker(): |
|
|
|
|
files = [video_filename] |
|
|
|
|
for i in files: |
|
|
|
|
message = await client.send_message(config['config']['storage_chat_id'], f'Uploading {os.path.split(i)[1]}...', parse_mode=None) |
|
|
|
|
await client.send_file(config['config']['storage_chat_id'], i) |
|
|
|
|
await client.send_file(config['config']['storage_chat_id'], i, caption=os.path.split(i)[1], parse_mode=None) |
|
|
|
|
asyncio.create_task(message.delete()) |
|
|
|
|
finally: |
|
|
|
|
tempdir_obj.cleanup() |
|
|
|
|