upload.py

import requests
import json

# IPFS gateway and API endpoints
gateway_url = 'http://localhost:8080'
api_url = 'http://localhost:5001/api/v0'

# Add a file to IPFS
def add_file(filename):
 with open(filename, 'rb') as f:
 files = {'file': f}
 response = requests.post(f'{api_url}/add', files=files)
 file_hash = json.loads(response.text)['Hash']
 print(f'Added file to IPFS with CID: {file_hash}')
 return file_hash

# Retrieve a file from IPFS
def get_file(file_hash, output_file):
 response = requests.get(f'{gateway_url}/ipfs/{file_hash}')
 with open(output_file, 'wb') as f:
 f.write(response.content)
 print(f'File retrieved from IPFS and saved as {output_file}')

# Test the functions
file_hash = add_file('myfile.txt')
get_file(file_hash, 'output.txt')