From aad5b0f6959775a01558790f07062477ba96dff6 Mon Sep 17 00:00:00 2001
From: luke <21106956+logburn@users.noreply.github.com>
Date: Tue, 2 Mar 2021 20:20:23 -0500
Subject: [PATCH] init

---
 .decrypt_test.py.swp        | Bin 0 -> 12288 bytes
 keys/.gitignore             |   4 ++
 prikey.pem                  |  27 +++++++++++
 recieve.py                  |  89 ++++++++++++++++++++++++++++++++++++
 videos/encrypted/.gitignore |   4 ++
 videos/plaintext/.gitignore |   4 ++
 6 files changed, 128 insertions(+)
 create mode 100644 .decrypt_test.py.swp
 create mode 100644 keys/.gitignore
 create mode 100644 prikey.pem
 create mode 100644 recieve.py
 create mode 100644 videos/encrypted/.gitignore
 create mode 100644 videos/plaintext/.gitignore

diff --git a/.decrypt_test.py.swp b/.decrypt_test.py.swp
new file mode 100644
index 0000000000000000000000000000000000000000..3e9bfb66217707f6242fe7749691aea02c6fa0cd
GIT binary patch
literal 12288
zcmeI2Pj4GV7{;eukP3y0KjO%AE$}W)*A8_<6cGe!R4J$=LP;x78?|fiyY{H--R<ny
z8xvAgapf~0BrebkJt2Yk0vwRI(tB^*IC0~d-K}F+K&q&hR_{npcI}yY=9%Bj9IQ;Y
zeR=&Ox$G|rl#@c-|Lwi&e~UZf&7XycM>oiReONI;FFmY{t-oarTU)(Bn#Qfp<qujR
z_4Fh&*9_&x&nA!J!EKlT6F35ak%`VMpSX1P?Zvk3-EdCHmtVSc1S9Uk1egF5U;<2l
z2`~XBzyz4UlS;s3$HW&1|4coBM*TeY(6j!?4<^6_m;e)C0!)AjFaajO1egF5U;<3w
z2_z7NLfkzr#3#=oJpTXx;P?L@FADJsbQk&o`Ud(E+JUY@uR*`RfO_b2h@cR<4sAp4
zLVunR;ydUX^gi@D^w;x3{0QBKde9rtv(T>?|6Ay5=qu<pv=7-_uR^at_mJ}^=nnKf
z#Dxhk0Vco%m;e)C0!-j(CeV<%QKmPLk%}po4}COgpUi-?bhkIxHf0=`LmQCxM6=lx
z5`}h^alP_2(~YBdRf%z%YiUA{!J=8^DMQ(enYQkc<L;^b)?Q4BJ62&%#@qLts_9&-
zkh-J39Ht?8vPeg9C<noqWJoa?3gzAnnxOL)wX;9dyOHL;reQiJcUpf0?<&}Tdr#{R
zylr;e2afzgD?@I5HTVM7x}GN77G#7}-a)5AnSo3*pm1PGY2M1>0F-Fgw4Bqq(XR3q
zq*I)BJQ?Jr|BA39*<!uqYSn!@S+v$&#{+~QtT#lIYN@13qz;lkxijFs%B)%#XRW%;
ztdf4UMg5v<LyZ9%BVDmOS6aLB1&;kV?fUkQ>(~S>HEzA-EJ#hgk<JxXYgKOR5qUep
z2ChOrlF^*Y>WoK4{xFXkCMD(lYzpU7&H6PgRC|eA;`CMX7RA8M(+;{)9<Va}?AqeO
z_pb58|E*rzA7&k(aEk8S;)P{j<gbU_hLdaU7Azi5*jLncC%9AY+6^$bI}Rpf{d?A5
zPZt|IrCHvR#leHu)WzBSw4HCADK0Lx7bjbK<9yKRy;I!m_cwxbHwPDs(eiry;m65m
z8|k_ARaj0<%6V%tBb~?#q!YsFwITgFdzsr4Aw~Z(o3iDKnBj|=3898rs!h3ZM5NQ9
k>;^e4b!7d0cc}w&ocXG<T$!}5gKRMIqcXySmQ^6}4`R;ang9R*

literal 0
HcmV?d00001

diff --git a/keys/.gitignore b/keys/.gitignore
new file mode 100644
index 0000000..5e7d273
--- /dev/null
+++ b/keys/.gitignore
@@ -0,0 +1,4 @@
+# Ignore everything in this directory
+*
+# Except this file
+!.gitignore
diff --git a/prikey.pem b/prikey.pem
new file mode 100644
index 0000000..b6b628f
--- /dev/null
+++ b/prikey.pem
@@ -0,0 +1,27 @@
+-----BEGIN RSA PRIVATE KEY-----
+MIIEpQIBAAKCAQEAuk5egzauVPCxuNvWcJAAISIxcvsdXQFFB5lYUdOgv8Dcyva/
+9kh76R2TEay0K3kEpXBx/M4YdiAIg0XoTYUxWNR3vGy4sWuAkF1WPF0hCJcx/GGC
+Cszl7NqMDz7uedBSkJG4sIyOCnmxJli/Y7O+xoENb1DvJ4U7b0n3AHkovlsfkw8z
+wOVsc9dUnPbZmrzbd99HYoRFPKnAVgF+vGY62qRj2GvsJzRAC0K8HMxJv0r/V+3O
++fwqGCnJlCcadgMJUuHPDVdYVXgEZZ1iYdwFpPHLML2DEOd3y3DJAy1F59IkEGAr
+ULQbu7SdqwaFkU1Y2euZXb/J1q/9C/GhppQH9QIDAQABAoIBACxgf3W8wCC+Zm7U
+eos8WbOKvAGZ3AArzcAGIDn5cUhLjawQw1/MGyvHXiEvJIlYXal0k8o2YzA76Bsw
+uyk/6SWyEkVBFms4YprAiMp/Gl+79+2YYkvlS30z/3mgMVi1rPz/oOD40dqf6vjp
+2cjLZ01MLyGNQzIEM8iJ8zpbIb/Zd496n6awH+am4+9tD5o87aI0mx0PwS0zCUfX
+bFg6ns42XS2FuAiKeqMkmNcoo6G0E/6zDw7dk4MfJ5UNDIkSJ+r3UHjXOi1Zn4BW
+0uNYIV9BdJlyiKTB+edTxe0IzSpaBnPp+3f5CKeR9V/T3apLet/EFbYzyJ0KSi31
+MTUW64ECgYEA0FJ++cqVSUz2AtBOY9yF362LlRH60DQe7JiDHAFZmhN/iMw+VBOr
+KsSOAtSx01Cr5iD9KO/CqJCVFmdM4lzvJklcpOyNhNwt8B8kc8R+QLi+wfBCLy3q
+ODp7UcWhKAV3hsAGx1ct8fWNtkfI7v+BaPN6ablNFYKHJa5RvUTsizUCgYEA5PH1
+ezOLDukj+QRf3DE2u0HZRWmv807gA1+tuicDn9JAbK7FFLbdANDwd2TC5wYGGUaR
+Trk6CGKlp0H/P0VJbjUIHQOtLz4Xao91wU8iLdrcKeVoELgJqO0em3YUdOEpcdUT
+y06SBImz3T+NS/NP7GcxbSJ+Fqc07p2iAUGAYcECgYEAonQixuK/JklY83rEFsXq
+tDKeziIWSHTMxM5uN9GpsSiRZPl5hZFNAu4CnJyHC/Y2ByEkqt7GGzOcv7rQzxmP
++XhuQcKi3b/iJwXyJEFP/2LSh2S4CBizNSQN9Qe8E/ynaDKpVpxanPxThZlXTWF8
+5n4wsO+q+CIxCCZ3YbS1Dh0CgYEAuOWwG4/E/oXLR5EA2hPk39aOYkC4mQdaY18i
+LvTTOH/VB/EduVz1n3MewU3fGjUDN+aF884j0CHbJvll6vNKGnc51jTh6QV8Y9L4
+huYh9GaM6EkdgmMfag4WafczDjHKBuTO16Lcyk1rtYNd2bjnE0VD5Z+1tRXU6eDk
+tZ7w0AECgYEAo+tRkqj12gVWYFNK5Ij7zfzn7Iv0pGiyq+sa+8PBEeziKGGRPyjn
+KlpAYmOlSr9aKAtE8JKCvrAfrQHFo3dQRxWQAppiuY38zu2dxXUOpdF3Wb9Tfk4Y
+MMDhzybUSNa0tq4rVg6xaeQvIwNx2SGk93tUul0JBh6vzrF+eB7WYu8=
+-----END RSA PRIVATE KEY-----
diff --git a/recieve.py b/recieve.py
new file mode 100644
index 0000000..101d7ca
--- /dev/null
+++ b/recieve.py
@@ -0,0 +1,89 @@
+import socket
+from Crypto.Cipher import PKCS1_OAEP as RSA
+from Crypto.Cipher import AES
+from cryptography.fernet import Fernet
+import os
+import glob
+
+# global vars
+endmessage = "---endmessage---"
+HEADERSIZE = 20
+BYTELEN = 1024
+BYTELENBIG = 4096
+
+# helper functions
+def get_ip():
+    return [l for l in ([ip for ip in socket.gethostbyname_ex(socket.gethostname())[2]
+    if not ip.startswith("127.")][:1], [[(s.connect(('1.1.1.1', 53)),
+    s.getsockname()[0], s.close()) for s in [socket.socket(socket.AF_INET,
+    socket.SOCK_DGRAM)]][0][1]]) if l][0][0]
+
+def getStream(bytelen):
+    newmsg = True
+    done = False
+    fullmsg = ""
+    while not done:
+        msg = c.recv(bytelen)
+        if newmsg:
+            msglen = int(msg[:HEADERSIZE])
+            newmsg = False
+        fullmsg += msg.decode("utf-8")
+        if len(fullmsg) - HEADERSIZE == msglen:
+            done = True
+            return fullmsg[HEADERSIZE:]
+
+# TODO decrypt text with PGP key
+def decryptPGP(text):
+    return text
+    # keytext = open("prikey.pem", "r").read()
+    keytext = "-----BEGIN RSA PRIVATE KEY-----\nMIIEpQIBAAKCAQEAuk5egzauVPCxuNvWcJAAISIxcvsdXQFFB5lYUdOgv8Dcyva/\n9kh76R2TEay0K3kEpXBx/M4YdiAIg0XoTYUxWNR3vGy4sWuAkF1WPF0hCJcx/GGC\nCszl7NqMDz7uedBSkJG4sIyOCnmxJli/Y7O+xoENb1DvJ4U7b0n3AHkovlsfkw8z\nwOVsc9dUnPbZmrzbd99HYoRFPKnAVgF+vGY62qRj2GvsJzRAC0K8HMxJv0r/V+3O\n+fwqGCnJlCcadgMJUuHPDVdYVXgEZZ1iYdwFpPHLML2DEOd3y3DJAy1F59IkEGAr\nULQbu7SdqwaFkU1Y2euZXb/J1q/9C/GhppQH9QIDAQABAoIBACxgf3W8wCC+Zm7U\neos8WbOKvAGZ3AArzcAGIDn5cUhLjawQw1/MGyvHXiEvJIlYXal0k8o2YzA76Bsw\nuyk/6SWyEkVBFms4YprAiMp/Gl+79+2YYkvlS30z/3mgMVi1rPz/oOD40dqf6vjp\n2cjLZ01MLyGNQzIEM8iJ8zpbIb/Zd496n6awH+am4+9tD5o87aI0mx0PwS0zCUfX\nbFg6ns42XS2FuAiKeqMkmNcoo6G0E/6zDw7dk4MfJ5UNDIkSJ+r3UHjXOi1Zn4BW\n0uNYIV9BdJlyiKTB+edTxe0IzSpaBnPp+3f5CKeR9V/T3apLet/EFbYzyJ0KSi31\nMTUW64ECgYEA0FJ++cqVSUz2AtBOY9yF362LlRH60DQe7JiDHAFZmhN/iMw+VBOr\nKsSOAtSx01Cr5iD9KO/CqJCVFmdM4lzvJklcpOyNhNwt8B8kc8R+QLi+wfBCLy3q\nODp7UcWhKAV3hsAGx1ct8fWNtkfI7v+BaPN6ablNFYKHJa5RvUTsizUCgYEA5PH1\nezOLDukj+QRf3DE2u0HZRWmv807gA1+tuicDn9JAbK7FFLbdANDwd2TC5wYGGUaR\nTrk6CGKlp0H/P0VJbjUIHQOtLz4Xao91wU8iLdrcKeVoELgJqO0em3YUdOEpcdUT\ny06SBImz3T+NS/NP7GcxbSJ+Fqc07p2iAUGAYcECgYEAonQixuK/JklY83rEFsXq\ntDKeziIWSHTMxM5uN9GpsSiRZPl5hZFNAu4CnJyHC/Y2ByEkqt7GGzOcv7rQzxmP\n+XhuQcKi3b/iJwXyJEFP/2LSh2S4CBizNSQN9Qe8E/ynaDKpVpxanPxThZlXTWF8\n5n4wsO+q+CIxCCZ3YbS1Dh0CgYEAuOWwG4/E/oXLR5EA2hPk39aOYkC4mQdaY18i\nLvTTOH/VB/EduVz1n3MewU3fGjUDN+aF884j0CHbJvll6vNKGnc51jTh6QV8Y9L4\nhuYh9GaM6EkdgmMfag4WafczDjHKBuTO16Lcyk1rtYNd2bjnE0VD5Z+1tRXU6eDk\ntZ7w0AECgYEAo+tRkqj12gVWYFNK5Ij7zfzn7Iv0pGiyq+sa+8PBEeziKGGRPyjn\nKlpAYmOlSr9aKAtE8JKCvrAfrQHFo3dQRxWQAppiuY38zu2dxXUOpdF3Wb9Tfk4Y\nMMDhzybUSNa0tq4rVg6xaeQvIwNx2SGk93tUul0JBh6vzrF+eB7WYu8=\n-----END RSA PRIVATE KEY-----"
+    key = RSA.importKey(keytext)
+    return key.decrypt(text)[0]
+
+# decrypt text
+def decryptText(text, fkey):
+    return Fernet(fkey).decrypt(text)
+
+# establish connection with client and download files
+s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+host = get_ip()
+print(host)
+port = 12352
+s.bind((host, port))
+s.listen(5)
+
+while True:
+    # initial vars, connect with client device
+    c, addr = s.accept()
+    print(f'Got connection from {addr}')
+
+    # get number of files and recieve that num of files
+    numFiles = 2 # int(c.recv(80).decode()) TODO
+    for i in range(numFiles):
+        # get video and key data from remote, store both in respective files
+        open("videos/encrypted/" + str(i+1) + ".mpc", "w+").write(getStream(BYTELEN))
+        open("keys/" + str(i+1) + ".asc", "w+").write(getStream(BYTELEN))
+        # update user because this might take some time
+        print("Recieved data (" + str(i+1) + "/" + str(numFiles) + ")")
+    c.close()
+
+    # decrypt the files
+    print("Decrypting files...")
+    # get all video and key files in array (strings of file locations)
+    vidset = [file for file in glob.glob("videos/encrypted/*", recursive=False)]
+    keyset = [file for file in glob.glob("keys/*", recursive=False)]
+    for i in range(len(vidset)):
+        # read the key and video file into vars
+        key = bytes(open(keyset[i], "r").read(), 'utf-8')
+        text = bytes(str(open(vidset[i], "r").read()), 'utf-8')
+        # write the decrypted video file info into an mp4 file
+        with open("videos/plaintext/"+str(i+1)+".mp4", "wb+") as mp4:
+            mp4.write(decryptText(text, key))
+        # delete the old files
+        os.remove(vidset[i])
+        os.remove(keyset[i])
+
+    print('Done')
+    exit()
+
+# stitch files together (TODO later)
diff --git a/videos/encrypted/.gitignore b/videos/encrypted/.gitignore
new file mode 100644
index 0000000..5e7d273
--- /dev/null
+++ b/videos/encrypted/.gitignore
@@ -0,0 +1,4 @@
+# Ignore everything in this directory
+*
+# Except this file
+!.gitignore
diff --git a/videos/plaintext/.gitignore b/videos/plaintext/.gitignore
new file mode 100644
index 0000000..5e7d273
--- /dev/null
+++ b/videos/plaintext/.gitignore
@@ -0,0 +1,4 @@
+# Ignore everything in this directory
+*
+# Except this file
+!.gitignore