import proxy
from proxy.http.proxy import HttpProxyBasePlugin
class CustomProxyRedirection(HttpProxyBasePlugin):
 currentProxy = {
 "address": "0.0.0.0"
 }
 
 def __init__(self, *args, **kwargs):
 super().__init__(*args, **kwargs)
 
 def before_upstream_connection(self, request):
 print(f'Proxy host: {CustomProxyRedirection.currentProxy['address']}')
 proxy_host, proxy_port = CustomProxyRedirection.currentProxy['address'].split(':')
 # Set the proxy for the request
 request.host = proxy_host
 request.port = int(proxy_port)
 return request
class ProxyManager:
 proxy = None
 def __init__(self):
 self.proxy = proxy.Proxy(port=8899, plugins=[
 CustomProxyRedirection,
 ])
 def nextProxy(self):
 CustomProxyRedirection.currentProxy['address'] ="154.94.5.241:7001"
 # EXTREME CASE WHERE I INSTANTIATE THE WHOLE PROXY AGAIN
 self.proxy = proxy.Proxy(port=8899, plugins=[
 CustomProxyRedirection,
 ])
# Example to run the proxy
def main():
 proxyManager = ProxyManager()
 proxyManager.nextProxy()
 with proxyManager.proxy as p:
 logger.info('Application started')
 proxy.sleep_loop()
if __name__ == '__main__':
 main()