jobProcess.py

import requests

with open("query.txt", "r") as query_file:
    query_lines = [line.rstrip("\n") for line in query_file]

response_lines = []
for dish in query_lines:
    try:
        print(f"{dish}")
        response_post = requests.post("http://localhost:8000/dishes", json={"name": dish},headers={"Content-Type": "application/json"})
        print(f"response post status: {response_post.status_code}")
        if response_post.status_code == 201:
            response_get = requests.get(f"http://localhost:8000/dishes/{dish}",headers={"Content-Type": "application/json"})
            print(f"response get status: {response_get.status_code}")
            if response_get.status_code == 200:
                data = response_get.json()
                print(f"data for {dish}:{data}")
                calories = data["cal"]
                sodium = data["sodium"]
                sugar = data["sugar"]
                
                response_lines.append(f"{dish} contains {calories} calories, {sodium} mgs of sodium, and {sugar} grams of sugar")
            else:
                print(f"get failed beacuse {response_get.status_code}")
                raise Exception()
        else:
            print(f"post failed beacuse {response_post.status_code}")
            raise Exception()        
    except Exception as e:
        print(f"exceptin: {e}")
        response_lines.append(f"Error: Failed to retrieve data for {dish}")
        

with open("response.txt", "w") as response_file:
    response_file.write("\n".join(response_lines))