thelittlerocket/CAM4Recorder
1
0
Fork 0
mirror of https://github.com/thelittlerocket/CAM4Recorder.git synced 2025-01-31 01:58:18 +08:00
Code Issues Projects Releases Packages Wiki Activity

Update CAM4Recorder.py

Browse source
This commit is contained in:
beaston02 2017-05-29 21:26:18 -07:00 committed by GitHub
parent 0750e8faa8
commit efdd29a212
1 changed files with 34 additions and 31 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

65
CAM4Recorder.py
View file

@ -30,37 +30,40 @@ i = 1
def startRecording(model):
req = urllib.request.Request('https://www.cam4.com/' + model)
req.add_header('UserAgent', UserAgent)
resp = urllib.request.urlopen(req)
resp = resp.read().decode().splitlines()
videoPlayUrl = ""
videoAppUrl = ""
for line in resp:
if "videoPlayUrl" in line:
for part in line.split("&"):
if "videoPlayUrl" in part and videoPlayUrl == "":
videoPlayUrl = part[13:]
elif "videoAppUrl" in part and videoAppUrl == "":
videoAppUrl = part.split("//")[1]
session = Livestreamer()
session.set_option('http-headers', "referer=https://www.cam4.com/{}".format(model))
streams = session.streams("hlsvariant://https://{}/amlst:{}_aac/playlist.m3u8?referer=www.cam4.com&timestamp={}\" best"
.format(videoAppUrl, videoPlayUrl, str(int(time.time() * 1000))))
stream = streams["best"]
fd = stream.open()
ts = time.time()
st = datetime.datetime.fromtimestamp(ts).strftime("%Y.%m.%d_%H.%M.%S")
if not os.path.exists("{path}/{model}".format(path=save_directory, model=model)):
os.makedirs("{path}/{model}".format(path=save_directory, model=model))
with open("{path}/{model}/{st}_{model}.mp4".format(path=save_directory, model=model,
st=st), 'wb') as f:
recording.append(model.lower())
while True:
try:
data = fd.read(1024)
f.write(data)
except:
try:
req = urllib.request.Request('https://www.cam4.com/' + model)
req.add_header('UserAgent', UserAgent)
resp = urllib.request.urlopen(req)
resp = resp.read().decode().splitlines()
videoPlayUrl = ""
videoAppUrl = ""
for line in resp:
if "videoPlayUrl" in line:
for part in line.split("&"):
if "videoPlayUrl" in part and videoPlayUrl == "":
videoPlayUrl = part[13:]
elif "videoAppUrl" in part and videoAppUrl == "":
videoAppUrl = part.split("//")[1]
session = Livestreamer()
session.set_option('http-headers', "referer=https://www.cam4.com/{}".format(model))
streams = session.streams("hlsvariant://https://{}/amlst:{}_aac/playlist.m3u8?referer=www.cam4.com&timestamp={}\" best"
.format(videoAppUrl, videoPlayUrl, str(int(time.time() * 1000))))
stream = streams["best"]
fd = stream.open()
ts = time.time()
st = datetime.datetime.fromtimestamp(ts).strftime("%Y.%m.%d_%H.%M.%S")
if not os.path.exists("{path}/{model}".format(path=save_directory, model=model)):
os.makedirs("{path}/{model}".format(path=save_directory, model=model))
with open("{path}/{model}/{st}_{model}.mp4".format(path=save_directory, model=model,
st=st), 'wb') as f:
recording.append(model.lower())
while True:
try:
data = fd.read(1024)
f.write(data)
except:
pass
if model in recording:
recording.remove(model)