Integrated new upload sys with main file
This commit is contained in:
16
main.py
16
main.py
@@ -2,20 +2,13 @@ import openDrive
|
|||||||
import time
|
import time
|
||||||
import os
|
import os
|
||||||
from imdb import Cinemagoer
|
from imdb import Cinemagoer
|
||||||
import paramiko
|
import uploadresults
|
||||||
from dotenv import load_dotenv
|
from dotenv import load_dotenv
|
||||||
|
|
||||||
load_dotenv()
|
load_dotenv()
|
||||||
|
|
||||||
DVD_DEVICE = "/dev/sr0"
|
DVD_DEVICE = "/dev/sr0"
|
||||||
|
|
||||||
uploadPath = os.getenv('UPLOAD_PATH')
|
|
||||||
|
|
||||||
sftpHost = os.getenv('SFTP_HOST')
|
|
||||||
sftpPort = int(os.getenv('SFTP_PORT'))
|
|
||||||
sftpUsername = os.getenv('SFTP_USERNAME')
|
|
||||||
sftpPassword = os.getenv('SFTP_PASSWORD')
|
|
||||||
|
|
||||||
def ripDvd(driveName):
|
def ripDvd(driveName):
|
||||||
print("- DVD has been detected")
|
print("- DVD has been detected")
|
||||||
print("- Searching IMDB for " + driveName)
|
print("- Searching IMDB for " + driveName)
|
||||||
@@ -30,13 +23,8 @@ def ripDvd(driveName):
|
|||||||
print("- Will now procede to ripping DVD")
|
print("- Will now procede to ripping DVD")
|
||||||
movieName = driveName
|
movieName = driveName
|
||||||
os.system('HandBrakeCLI -i /dev/sr0 -o output/"' + movieName + '.mp4" --preset-import-file preset.json')
|
os.system('HandBrakeCLI -i /dev/sr0 -o output/"' + movieName + '.mp4" --preset-import-file preset.json')
|
||||||
sftpTransport = paramiko.Transport((sftpHost, sftpPort))
|
|
||||||
sftpTransport.connect(username = sftpUsername, password = sftpPassword)
|
|
||||||
sftp = paramiko.SFTPClient.from_transport(sftpTransport)
|
|
||||||
print("- Movie has been ripped, will now procede to upload file")
|
print("- Movie has been ripped, will now procede to upload file")
|
||||||
sftp.put('output/"' + movieName + '.mp4"', uploadPath + movieName + '.mp4')
|
|
||||||
sftp.close()
|
|
||||||
sftpTransport.close()
|
|
||||||
print("- Movie has been uploaded")
|
print("- Movie has been uploaded")
|
||||||
|
|
||||||
def waitForDvd():
|
def waitForDvd():
|
||||||
|
|||||||
@@ -2,8 +2,8 @@ import paramiko
|
|||||||
import os
|
import os
|
||||||
from dotenv import load_dotenv
|
from dotenv import load_dotenv
|
||||||
|
|
||||||
|
def upload():
|
||||||
load_dotenv()
|
load_dotenv()
|
||||||
|
|
||||||
hostname = os.getenv('SFTP_HOST')
|
hostname = os.getenv('SFTP_HOST')
|
||||||
port = int(os.getenv('SFTP_PORT'))
|
port = int(os.getenv('SFTP_PORT'))
|
||||||
username = os.getenv('SFTP_USERNAME')
|
username = os.getenv('SFTP_USERNAME')
|
||||||
|
|||||||
Reference in New Issue
Block a user