-
Notifications
You must be signed in to change notification settings - Fork 2
/
upload.py
88 lines (86 loc) · 2.1 KB
/
upload.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
from socket import *
import os
from threading import Thread
from time import sleep
import sys
s= socket()
port = 12345
send_size = 500
def update_hashes():
file = open('C:/droplet/dpl/hashes.txt','r')
hashes = file.read().splitlines()[1:]
hashes= [hash.split('~') for hash in hashes]
file.close()
print hashes
return hashes
def send_text(input):
input_text = str(input)
send_text = input_text + "-"*(send_size-len(input_text))
return send_text
def handler(c):
sent = 0
path = ""
available = False
while True:
command = c.recv(send_size).strip('-')
if(command ==""):
break
print command
if (command == "info"):
hashes = update_hashes()
h = c.recv(send_size).strip('-')
for hash in hashes:
if hash[0] == h:
path = hash[1]
available = True
size = str(os.path.getsize(path))
size_send = size + "-"*(send_size-len(size))
c.send(size_send)
print size
name = os.path.split(path)[-1]
print path
name_send = name + "-"*(send_size-len(name))
c.send(name_send)
if not available:
c.send("0")
sleep(0.1)
c.send("0")
if(command=="quit"):
c.close()
break
if(command =="init_download"):
print "got init download"
seekTo =0
seekRecv = False
sizeRecv = False
if(path ==""):
c.send(send_text('file_not_init'))
else:
c.send(send_text('ready'))
FiletoSend = open(path,'rb')
got = c.recv(send_size).strip('-')
print got
if(got=="seek"):
seekTo = int(c.recv(send_size).strip('-'))
got = c.recv(send_size).strip('-')
print got
if(got=="size"):
readSize = int(c.recv(send_size).strip('-'))
print 'willsend'
c.send(send_text('willsend'))
print "seek = ",seekTo," size= ",readSize
FiletoSend.seek(seekTo)
toSend = FiletoSend.read(readSize)
print len(toSend)
print c.sendall(toSend)
def uploader():
hostname = gethostname()
ip = gethostbyname(hostname)
s.bind((ip,12345))
s.listen(5)
while True:
c,addr= s.accept()
handler(c)
print "Done handling"
uploader()
#python C:\Code\droplet\out.py drop:sha1_hash=d91d0805a09886d8840d2052a86a01c1fac907ef