lab3, нужно читать README.md
This commit is contained in:
commit
4bbfbd5947
7
.gitignore
vendored
Normal file
7
.gitignore
vendored
Normal file
@ -0,0 +1,7 @@
|
|||||||
|
.venv
|
||||||
|
.idea
|
||||||
|
/venv
|
||||||
|
.venv/
|
||||||
|
.env
|
||||||
|
*.token
|
||||||
|
.env/
|
66
API.py
Normal file
66
API.py
Normal file
@ -0,0 +1,66 @@
|
|||||||
|
import os
|
||||||
|
from dotenv import load_dotenv
|
||||||
|
import requests
|
||||||
|
|
||||||
|
# 1. Загрузка токена
|
||||||
|
load_dotenv()
|
||||||
|
TOKEN = os.getenv("GITEA_TOKEN")
|
||||||
|
|
||||||
|
if not TOKEN:
|
||||||
|
print("ОШИБКА: Токен не найден в .env файле!")
|
||||||
|
print("Убедитесь, что в папке с скриптом есть файл .env с содержимым:")
|
||||||
|
print("GITEA_TOKEN=ваш_токен_здесь")
|
||||||
|
exit(1)
|
||||||
|
|
||||||
|
headers = {"Authorization": f"token {TOKEN}"}
|
||||||
|
|
||||||
|
# 2. Проверка токена
|
||||||
|
print("Проверяем токен...")
|
||||||
|
try:
|
||||||
|
user_info = requests.get(
|
||||||
|
"https://git.vyatsu.ru/api/v1/user",
|
||||||
|
headers=headers,
|
||||||
|
timeout=10
|
||||||
|
)
|
||||||
|
user_info.raise_for_status() # Проверит HTTP ошибки
|
||||||
|
|
||||||
|
# Проверка структуры ответа
|
||||||
|
if not user_info.json().get("login"):
|
||||||
|
print("Неожиданный формат ответа от API:")
|
||||||
|
print(user_info.json())
|
||||||
|
exit(1)
|
||||||
|
|
||||||
|
print(f"Токен работает. Ваш логин: {user_info.json()['login']}")
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
print(f"ОШИБКА при проверке токена: {e}")
|
||||||
|
print("Ответ сервера:", user_info.text if 'user_info' in locals() else "Нет ответа")
|
||||||
|
exit(1)
|
||||||
|
|
||||||
|
# 3. Создание issue
|
||||||
|
print("\nПытаемся создать issue...")
|
||||||
|
repo_owner = "stud179126"
|
||||||
|
repo_name = "lab3"
|
||||||
|
|
||||||
|
new_issue = {
|
||||||
|
"title": "Тестовый issue из Python",
|
||||||
|
"body": "Этот issue создан через API скриптом!"
|
||||||
|
}
|
||||||
|
|
||||||
|
try:
|
||||||
|
response = requests.post(
|
||||||
|
f"https://git.vyatsu.ru/api/v1/repos/{repo_owner}/{repo_name}/issues",
|
||||||
|
headers=headers,
|
||||||
|
json=new_issue,
|
||||||
|
timeout=10
|
||||||
|
)
|
||||||
|
|
||||||
|
if response.status_code == 201:
|
||||||
|
print("✅ Issue успешно создан!")
|
||||||
|
print("Ссылка:", response.json().get("html_url", "не найдена"))
|
||||||
|
else:
|
||||||
|
print(f"❌ Ошибка {response.status_code}:")
|
||||||
|
print(response.text)
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
print(f"ОШИБКА при создании issue: {e}")
|
BIN
HTTP - соединение в vyatsu.ru .jpg
Normal file
BIN
HTTP - соединение в vyatsu.ru .jpg
Normal file
Binary file not shown.
After Width: | Height: | Size: 257 KiB |
31
HTTP_request.py
Normal file
31
HTTP_request.py
Normal file
@ -0,0 +1,31 @@
|
|||||||
|
import socket
|
||||||
|
import ssl
|
||||||
|
|
||||||
|
# Создаём соединение
|
||||||
|
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||||
|
secure_client = ssl.create_default_context().wrap_socket(
|
||||||
|
client, server_hostname='vyatsu.ru'
|
||||||
|
)
|
||||||
|
secure_client.connect(('vyatsu.ru', 443))
|
||||||
|
|
||||||
|
# HTTP-запрос с заголовками
|
||||||
|
request = (
|
||||||
|
"GET / HTTP/1.1\r\n"
|
||||||
|
"Host: vyatsu.ru\r\n"
|
||||||
|
"User-Agent: python-requests/2.28.1\r\n"
|
||||||
|
"Accept: */*\r\n"
|
||||||
|
"Accept-Encoding: gzip, deflate\r\n"
|
||||||
|
"Connection: keep-alive\r\n"
|
||||||
|
"\r\n"
|
||||||
|
)
|
||||||
|
secure_client.sendall(request.encode())
|
||||||
|
|
||||||
|
# Получаем и распаковываем ответ
|
||||||
|
response = secure_client.recv(8192)
|
||||||
|
headers, body = response.split(b'\r\n\r\n', 1)
|
||||||
|
|
||||||
|
|
||||||
|
print(headers.decode())
|
||||||
|
print(body.decode())
|
||||||
|
|
||||||
|
secure_client.close()
|
4
README.md
Normal file
4
README.md
Normal file
@ -0,0 +1,4 @@
|
|||||||
|
Сделан захват пакетов TCP и изменён код клиента/сервера для ручного отключения
|
||||||
|
Установлено UDP соединение , в отличаии от TCP тут мы отправляем запрос в один путь и не ждем ответа ,мы не узнаем дойдёт он или нет,т.к никаких ошибок не увидим.
|
||||||
|
Использовал requests и socket для сравнения
|
||||||
|
API - написан скрипт(API.py) ,который создаёт issues (задачи)
|
Binary file not shown.
After Width: | Height: | Size: 216 KiB |
BIN
TCP - завершение соединения 1.jpg
Normal file
BIN
TCP - завершение соединения 1.jpg
Normal file
Binary file not shown.
After Width: | Height: | Size: 172 KiB |
16
TCP_Client.py
Normal file
16
TCP_Client.py
Normal file
@ -0,0 +1,16 @@
|
|||||||
|
import socket
|
||||||
|
|
||||||
|
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||||
|
client.connect(('127.0.0.1', 10000))
|
||||||
|
|
||||||
|
while True:
|
||||||
|
message = input("Введите сообщение (или 'e' для выхода): ")
|
||||||
|
if message.lower() == 'e':
|
||||||
|
client.sendall(b'EXIT') # Отправляем серверу команду на завершение
|
||||||
|
break
|
||||||
|
else:
|
||||||
|
client.sendall(message.encode())
|
||||||
|
data = client.recv(1024)
|
||||||
|
print(f"Ответ от сервера: {data.decode()}")
|
||||||
|
|
||||||
|
client.close()
|
28
TCP_Server.py
Normal file
28
TCP_Server.py
Normal file
@ -0,0 +1,28 @@
|
|||||||
|
import socket
|
||||||
|
|
||||||
|
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||||
|
server.bind(("0.0.0.0", 10000))
|
||||||
|
server.listen(1)
|
||||||
|
print("TCP сервер запущен")
|
||||||
|
|
||||||
|
while True:
|
||||||
|
conn, addr = server.accept()
|
||||||
|
print(f"Подключение от {addr}")
|
||||||
|
|
||||||
|
data = conn.recv(1024)
|
||||||
|
if not data:
|
||||||
|
conn.close()
|
||||||
|
continue
|
||||||
|
|
||||||
|
print(f"Получено: {data.decode()}")
|
||||||
|
|
||||||
|
if data.upper() == b'EXIT':
|
||||||
|
conn.sendall(b"Server shutting down...")
|
||||||
|
conn.close()
|
||||||
|
break # Выходим из цикла и завершаем сервер
|
||||||
|
|
||||||
|
conn.sendall(data.upper())
|
||||||
|
conn.close()
|
||||||
|
|
||||||
|
server.close() # Закрываем серверный сокет
|
||||||
|
print("Сервер остановлен")
|
BIN
UDP - соединение (мод).jpg
Normal file
BIN
UDP - соединение (мод).jpg
Normal file
Binary file not shown.
After Width: | Height: | Size: 149 KiB |
BIN
UDP - соединение (просто 1 запрос).jpg
Normal file
BIN
UDP - соединение (просто 1 запрос).jpg
Normal file
Binary file not shown.
After Width: | Height: | Size: 146 KiB |
14
UDP_Client.py
Normal file
14
UDP_Client.py
Normal file
@ -0,0 +1,14 @@
|
|||||||
|
import socket
|
||||||
|
|
||||||
|
client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
||||||
|
|
||||||
|
while True:
|
||||||
|
message = input("Введите сообщение (или 'exit' для выхода): ")
|
||||||
|
if message.lower() == 'exit':
|
||||||
|
break
|
||||||
|
|
||||||
|
client.sendto(message.encode(), ('127.0.0.1', 20000)) # Новый порт 20000
|
||||||
|
data, _ = client.recvfrom(1024)
|
||||||
|
print(f"Ответ от сервера: {data.decode()}")
|
||||||
|
|
||||||
|
client.close()
|
16
UDP_Server.py
Normal file
16
UDP_Server.py
Normal file
@ -0,0 +1,16 @@
|
|||||||
|
import socket
|
||||||
|
|
||||||
|
server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
||||||
|
server.bind(('0.0.0.0', 20000)) # Новый порт 20000
|
||||||
|
print("UDP сервер запущен на порту 20000")
|
||||||
|
|
||||||
|
while True:
|
||||||
|
data, addr = server.recvfrom(1024)
|
||||||
|
decoded_data = data.decode()
|
||||||
|
print(f"Получено от {addr}: {decoded_data}")
|
||||||
|
|
||||||
|
# Модификация данных:
|
||||||
|
modified_data = decoded_data.upper().replace('O', '0') # Замена 'O' на '0'
|
||||||
|
response = f"MODIFIED: {modified_data}" # Добавляем префикс
|
||||||
|
|
||||||
|
server.sendto(response.encode(), addr)
|
BIN
requirements.txt
Normal file
BIN
requirements.txt
Normal file
Binary file not shown.
Binary file not shown.
After Width: | Height: | Size: 205 KiB |
Loading…
Reference in New Issue
Block a user