-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathapp.py
More file actions
111 lines (90 loc) · 2.64 KB
/
Copy pathapp.py
File metadata and controls
111 lines (90 loc) · 2.64 KB
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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
from flask import Flask, request, jsonify, render_template
from flask_cors import CORS
from DHT import ConsistentHashDHT, P2PFileSharing, hash_fn
app = Flask(__name__)
CORS(app)
# Initialize
dht = ConsistentHashDHT()
p2p = P2PFileSharing(dht)
# Initial nodes
dht.add_node("Peer1")
dht.add_node("Peer2")
dht.add_node("Peer3")
# -----------------------------
# Home
# -----------------------------
@app.route('/')
def home():
# return "DHT Backend Running ✅"
return render_template("index.html")
# -----------------------------
# Upload
# -----------------------------
@app.route('/upload', methods=['POST'])
def upload():
print('uploading')
data = request.json
p2p.upload(data['file'], data['peer'])
return jsonify({"message": "Uploaded"})
# -----------------------------
# Download
# -----------------------------
@app.route('/download', methods=['GET'])
def download():
print('downloading')
file = request.args.get('file')
peers = p2p.download(file)
return jsonify({"peers": peers})
# -----------------------------
# Delete File
# -----------------------------
@app.route('/delete', methods=['POST'])
def delete():
print('deleting')
data = request.json
p2p.remove_file(data['file'])
return jsonify({"message": "Deleted"})
# -----------------------------
# Add Node
# -----------------------------
@app.route('/add_node', methods=['POST'])
def add_node():
print('add node')
name = request.json['name']
dht.add_node(name)
return jsonify({"message": "Node added"})
# -----------------------------
# Remove Node
# -----------------------------
@app.route('/remove_node', methods=['POST'])
def remove_node():
print('remove node')
name = request.json['name']
dht.remove_node(name)
return jsonify({"message": "Node removed"})
# -----------------------------
# State
# -----------------------------
@app.route('/state', methods=['GET'])
def state():
print('state')
max_hash = 2**160 - 1
result = {}
for key in dht.sorted_keys:
node = dht.nodes[key]
node_angle = (key / max_hash) * 360
file_list = []
for f in node.data.keys():
f_hash = hash_fn(f)
f_angle = (f_hash / max_hash) * 360
file_list.append({"name": f, "angle": f_angle})
result[node.name] = {
"angle": node_angle,
"files": file_list
}
return jsonify(result)
# -----------------------------
# Run
# -----------------------------
if __name__ == '__main__':
app.run(debug=True)