def test_valid_submission(context, injected_submission=None):

    # to avoid errors re/ uninitialized object  
    proxydict = {}
    
    if injected_submission is None:
        injected_submission = "(None)"  # For user readability only

    logging.getLogger("requests").setLevel(logging.WARNING)
    if hasattr(context, 'proxy_address'):
        if context.proxy_address:
            proxydict = {'http': 'http://' + context.proxy_address,
                         'https': 'https://' + context.proxy_address}
    else:
        context.proxy = None
        proxydict = None

    if context.type == 'json':
        data = json.dumps(context.submission[0])
    if context.type == 'urlencode':
        data = serialise_to_url(context.submission[0], encode=True)
        if context.submission_method == 'GET':
            data = '?' + data
    if context.type == 'url-parameters':
        data = dict_to_urlparams(context.submission[0])

    # In the following loop, we try to send the valid case to the target.
    # If the response code indicates an auth failure, we acquire new auth
    # material (e.g., relogin), implemented in authenticate() in
    # authenticate.py.
    # If authentication fails twice in a row, we bail out.
    # If the valid case fails for other reasons (unsuccessful status code,
    # timeout, HTTP error), we bail out.
    # We report the previous injection (if any) in the error message.

    retry = 0
    while True:
        if retry == 1:  # On second try, recreate auth material
            auth = authenticate(context, context.authentication_id,
                                acquire_new_authenticator=True)
        else:
            auth = authenticate(context, context.authentication_id)
        retry += 1  # How many retries
        try:
            req = create_http_request(context.submission_method,
                                      context.targeturi,
                                      context.content_type,
                                      data,
                                      auth,
                                      valid_case=True)
            session = requests.Session()
            resp = session.send(req,
                                timeout=context.timeout,
                                verify=False, proxies=proxydict)
        except requests.exceptions.Timeout:
            assert False, "Valid case %s request to URI %s timed out after an " \
                          "injection %s" % (
                              context.submission_method, context.targeturi,
                              injected_submission)
        except requests.exceptions.ConnectionError as error:
            assert False, "Valid case %s request to URI %s after an injected " \
                          "submission %s failed: %s" % (
                              context.submission_method, context.targeturi,
                              injected_submission, error)
        if resp.status_code in [401, 403, 405, 407, 419, 440]:
            if retry > 1:  # Unauthorised two times in a row?
                assert False, "Valid case %s request to URI %s failed " \
                              "authorisation twice in a row after injected " \
                              "submission %s: Response status code %s" % (
                                  context.submission_method, context.targeturi,
                                  injected_submission, resp.status_code)
            else:
                continue  # Unauthorised. Retry
        if hasattr(context, "valid_cases"):
            if resp.status_code not in context.valid_cases:
                assert False, "Valid case %s request to URI %s after injected " \
                              "submission %s did not work: Response status " \
                              "code %s" % (context.submission_method,
                                           context.targeturi,
                                           injected_submission, resp.status_code)

        # If we are here, the request was successful
        break  # Stop trying, continue with the test run
Test if we're unsubscribed (using id only for subscription), we don't get messages
dataset/ETHPy150Open F-Secure/mittn/mittn/httpfuzzer/injector.py/test_valid_submission--crossover with--dataset/ETHPy150Open ebu/radiodns-plugit/RadioVisServer/tests.py/MainTests.test_unsubscribe_dontmessage_withsubid