ESP Agent Basics

import asyncio
import esp.streams

async def processor_loop():
    # Grab an agent handle for the "github-stuff" role.
    agent = esp.streams.Agent("github-stuff")
    # Start reading entries assigned to 'github-stuff' role in a stream
    for entry in agent.read("some-stream"):
        # Process the entry somehow...
        some_data = process_entry(entry.data)
        
        # Let's make a new entry to another stream based on this entry 
        new_entry = entry.response()  # A new entry that tracks back to the original entry
        eid = await agent.write("some-other-stream", new_entry)
        print(f"Wrote an entry in some-other-stream, saved as {eid}, initiator was {new_entry.initiator}")
        #  > Wrote an entry in some-other-stream, saved as 1748358969481-0, initiator was external::github::webhook::someid
        
        # Now mark processing of the original entry as completed, removing it from the PEL
        await entry.complete()
        
        # And we are done, grab the next entry for processing.
        # Should we crash and burn, this will pick up where we left off
        # with the last entry not complete()'d.

asyncio.run(processor_loop())