initial

src-lua · src-lua · commit b98bb0d54866 · 2025-02-18T14:45:40.000-03:00
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1 @@
+__pycache__
diff --git a/data/dns.json b/data/dns.json
@@ -0,0 +1,10 @@
+[
+    {
+        "name": "voting.com",
+        "type": "A",
+        "addr": [
+                    {"ip": "localhost", "port": 1010}, 
+                    {"ip": "localhost", "port": 1011}
+                ]
+    }
+]
diff --git a/data/election.json b/data/election.json
@@ -0,0 +1,6 @@
+[
+    { 
+        "candidato 1": 0,
+        "candidato 2": 0
+    }
+]
diff --git a/data/keys.json b/data/keys.json
@@ -0,0 +1 @@
+[]
diff --git a/src/backup_server.py b/src/backup_server.py
diff --git a/src/client.py b/src/client.py
@@ -0,0 +1,63 @@
+from env import DNS_ADDRESS, DNS_PORT
+from utils import http_parser_reply
+
+from socket import socket, AF_INET, SOCK_STREAM
+
+def send_get_request(client_socket):
+    msg = "GET / HTTP/1.1\r\nHost: localhost\r\n\r\n"
+    client_socket.send(msg.encode())
+
+def get_addr_from_name(name):
+    client_socket = socket(AF_INET, SOCK_STREAM)
+    client_socket.connect((DNS_ADDRESS, DNS_PORT))
+    client_socket.send(name.encode())
+    addr = client_socket.recv(1024).decode()
+    client_socket.close()
+    return addr
+
+def print_menu(idx):
+    menu_text = {
+    1:
+        'Bem vindo ao sistema de votação!\n' \
+        '[0] Fechar programa\n' \
+        '[1] Conectar-se ao servidor\n'
+    ,
+    2:
+        'Você tem certea que deseja sair? Você não poderá voltar a executar\n' \
+        '[0] Não, voltar à tela anterior\n' \
+        '[1] Sim, desejo encerrar a sessão\n'
+    }
+
+    print(menu_text[idx])
+
+
+def menu():
+    ...
+
+def main():
+    addr = get_addr_from_name("voting.com").split(':')
+    
+    client_socket = socket(AF_INET, SOCK_STREAM)
+    client_socket.connect((addr[0], int(addr[1])))
+    
+    i = 1
+    while(i):
+        send_get_request(client_socket)
+        print("OK")
+        # print(http_parser_reply(client_socket.recv(1024).decode()))
+        i = input()
+
+    # while (1):
+    #     try:
+    #         msg = input()
+    #     except EOFError:
+    #         break
+
+    #     client_socket = socket(AF_INET, SOCK_STREAM)
+    #     client_socket.connect(("127.0.0.1", 12345))
+
+    #     client_socket.send(msg.encode())
+    #     msg = http_parser(client_socket.recv(1024).decode())
+    #     print(f"Mensagem recebida {msg}")
+
+main()
diff --git a/src/dns.py b/src/dns.py
@@ -0,0 +1,39 @@
+from env import DNS_ADDRESS, DNS_PORT
+from utils import readjson
+
+from socket import socket, AF_INET, SOCK_STREAM
+from threading import Thread
+
+def handle_request(socket_client):
+    request = socket_client.recv(2048).decode()
+
+    dns_client = socket(AF_INET, SOCK_STREAM)
+
+    for site in readjson():
+        if site['name'] == request:
+            for addr in site['addr']: 
+                try:
+                    dns_client.connect((addr['ip'], addr['port']))
+                    dns_client.close()
+                    socket_client.send(f"{addr['ip']}:{addr['port']}".encode())
+                    socket_client.close()
+                except:
+                    print(f"{addr['ip']}:{addr['port']} is down.")
+                    continue
+                    
+    socket_client.close()
+    return
+
+def main():
+    server_socket = socket(AF_INET, SOCK_STREAM)
+    server_socket.bind((DNS_ADDRESS, DNS_PORT))
+
+    print("Server Socket initialized.")
+    server_socket.listen()
+
+    while 1:
+        socket_client, addr_client = server_socket.accept()
+        print(f"Established connection with {addr_client}")
+        Thread(target=handle_request, args=(socket_client,)).start()
+
+main()        
diff --git a/src/env.py b/src/env.py
@@ -0,0 +1,2 @@
+DNS_ADDRESS = "localhost"
+DNS_PORT = 8888
diff --git a/src/main_server.py b/src/main_server.py
@@ -0,0 +1,55 @@
+from utils import http_parser_request
+
+from socket import socket, AF_INET, SOCK_STREAM
+from threading import Thread
+
+def http_get(socket_client):
+    msgHeader = 'HTTP/1.1 200 OK \r\n' \
+                'Date: Tue, 09 Aug 2022 13:23:35 GMT\r\n' \
+                'Server: MyServer/0.0.1\r\n' \
+                'Content-Type: text/html\r\n' \
+                '\r\n'
+    msgBody = '<html>' \
+              '<head><title>Hello, World</title></head>' \
+              '<body><h1> Your first web server!</h1>' \
+              '<h3>Congratulation!!</h3>' \
+              '</body>' \
+              '</html>'
+
+    msgHtml = msgHeader + msgBody
+
+    socket_client.send(msgHtml.encode())
+
+def http_post():
+    ...
+
+def handle_request(socket_client):
+    req = socket_client.recv(2048).decode()
+    if(req == ''):
+        socket_client.close()
+        return
+    
+    request = http_parser_request(req)
+
+    if(request['Method'] == 'GET'):
+        http_get(socket_client)
+    
+    elif(request['Method'] == 'POST'):
+        http_post()
+    
+    return
+
+def main():
+    server_socket = socket(AF_INET, SOCK_STREAM)
+    server_socket.bind(("localhost", 1011))
+
+    print("Server Socket initialized.")
+    server_socket.listen()
+
+    while 1:
+        socket_client, addr_client = server_socket.accept()
+        print(f"Established connection with {addr_client}")
+        Thread(target=handle_request, args=(socket_client,)).start()
+
+if __name__ == '__main__':
+    main()        
diff --git a/src/utils.py b/src/utils.py
@@ -0,0 +1,67 @@
+import json
+
+def readjson():
+    f = open('./data/dns.json', 'r')
+    data = json.load(f)
+    f.close()
+    return data
+
+def http_parser_request(html_string):
+    
+    map = dict()
+    html_string = html_string.split('\r\n')
+    
+    map['body'] = ''
+
+    first = True
+    is_body = False
+
+    for i in (html_string):
+        if (first):
+            i = i.split(' ')
+            map['Method'] = i[0]
+            map['Path'] = i[1]
+            map['Version'] = i[2]
+            first = False
+
+        elif not is_body:
+            if (i == ''):
+                is_body = True
+            else:
+                i = i.split(':')
+                map[i[0]] = i[1]
+
+        else:
+            map['body'] += i +'\n'
+
+    return map
+
+def http_parser_reply(html_string):
+    
+    map = dict()
+    html_string = html_string.split('\r\n')
+    
+    map['body'] = ''
+
+    first = True
+    is_body = False
+
+    for i in (html_string):
+        if (first):
+            i = i.split(' ')
+            map['Version'] = i[0]
+            map['Status Code'] = i[1]
+            map['Status Message'] = i[2]
+            first = False
+
+        elif not is_body:
+            if (i == ''):
+                is_body = True
+            else:
+                i = i.split(':')
+                map[i[0]] = i[1]
+
+        else:
+            map['body'] += i +'\n'
+
+    return map

-Original file line number
+Diff line change
@@ @@ -0,0 +1,6 @@ @@
 +[
 +    {
 +        "candidato 1": 0,
 +        "candidato 2": 0
 +    }
 +]
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,2 @@`
	`1`	`+DNS_ADDRESS = "localhost"`
	`2`	`+DNS_PORT = 8888`