s3-tests/s3tests/fuzz_headers.py

from boto.s3.connection import S3Connection
from optparse import OptionParser
from boto import UserAgent
from . import common

import traceback
import itertools
import random
import string
import yaml
import sys


def assemble_decision(decision_graph, prng):
    """ Take in a graph describing the possible decision space and a random
        number generator and traverse the graph to build a decision
    """
    return descend_graph(decision_graph, 'start', prng)


def descend_graph(decision_graph, node_name, prng):
    """ Given a graph and a particular node in that graph, set the values in
        the node's "set" list, pick a choice from the "choice" list, and
        recurse.  Finally, return dictionary of values
    """
    node = decision_graph[node_name]

    try:
        choice = make_choice(node['choices'], prng)
        decision = descend_graph(decision_graph, choice, prng)
    except IndexError:
        decision = {}

    #TODO: Add in headers
    for key in node['set']:
        if decision.has_key(key):
            raise KeyError("Node %s tried to set '%s', but that key was already set by a lower node!" %(node_name, key))
        decision[key] = node['set'][key]
    return decision


def make_choice(choices, prng):
    weighted_choices = []
    for option in choices:
        fields = option.split(None, 1)
        if len(fields) == 1:
            weight = 1
            value = fields[0]
        else:
            weight = int(fields[0])
            value = fields[1]
        for _ in xrange(weight):
            weighted_choices.append(value)

    return prng.choice(weighted_choices)


def expand_decision(decision, prng):
    """ Take in a decision and a random number generator.  Expand variables in
        decision's values and headers until all values are fully expanded and
        build a request out of the information
    """
    special_decision = SpecialVariables(decision, prng)
    for key in special_decision:
        decision[key] = expand_key(special_decision, key)

    return decision


def expand_key(decision, key):
    c = itertools.count()
    fmt = string.Formatter()
    old = decision[key]
    while True:
        new = fmt.vformat(old, [], decision)
        if new == old:
            return old
        if next(c) > 5:
            raise RuntimeError
        old = new


class SpecialVariables(dict):
    charsets = {
        'printable': string.printable,
        'punctuation': string.punctuation,
        'whitespace': string.whitespace
    }

    def __init__(self, orig_dict, prng):
        self.update(orig_dict)
        self.prng = prng


    def __getitem__(self, key):
        fields = key.split(None, 1)
        fn = getattr(self, 'special_{name}'.format(name=fields[0]), None)
        if fn is None:
            return super(SpecialVariables, self).__getitem__(key)

        if len(fields) == 1:
            fields.apppend('')
        return fn(fields[1])


    def special_random(self, args):
        arg_list = args.split()
        try:
            size_min, size_max = [int(x) for x in arg_list[0].split('-')]
        except IndexError:
            size_min = 0
            size_max = 1000
        try:
            charset = self.charsets[arg_list[1]]
        except IndexError:
            charset = self.charsets['printable']

        length = self.prng.randint(size_min, size_max)
        return ''.join([self.prng.choice(charset) for _ in xrange(length)]) # Won't scale nicely



def parse_options():
    parser = OptionParser()
    parser.add_option('-O', '--outfile', help='write output to FILE. Defaults to STDOUT', metavar='FILE')
    parser.add_option('--seed', dest='seed', type='int',  help='initial seed for the random number generator', metavar='SEED')
    parser.add_option('--seed-file', dest='seedfile', help='read seeds for specific requests from FILE', metavar='FILE')
    parser.add_option('-n', dest='num_requests', type='int',  help='issue NUM requests before stopping', metavar='NUM')
    parser.add_option('--decision-graph', dest='graph_filename',  help='file in which to find the request decision graph', metavar='NUM')

    parser.set_defaults(num_requests=5)
    parser.set_defaults(graph_filename='request_decision_graph.yml')
    return parser.parse_args()


def randomlist(n, seed=None):
    """ Returns a generator function that spits out a list of random numbers n elements long.
    """
    rng = random.Random()
    rng.seed(seed if seed else None)
    for _ in xrange(n):
        yield rng.random()


def _main():
    """ The main script
    """
    (options, args) = parse_options()
    random.seed(options.seed if options.seed else None)
    s3_connection = common.s3.main

    request_seeds = None
    if options.seedfile:
        FH = open(options.seedfile, 'r')
        request_seeds = FH.readlines()
    else:
        request_seeds = randomlist(options.num_requests, options.seed)

    graph_file = open(options.graph_filename, 'r')
    decision_graph = yaml.safe_load(graph_file)

    constants = {
        'bucket_readable': 'TODO',
        'bucket_writable' : 'TODO',
        'bucket_nonexistant' : 'TODO',
        'object_readable' : 'TODO',
        'object_writable' : 'TODO',
        'object_nonexistant' : 'TODO'
    }

    for request_seed in request_seeds:
        prng = random.Random(request_seed)
        decision = assemble_decision(decision_graph, prng)
        decision.update(constants)
        request = expand_decision(decision, prng) 

        response = s3_connection.make_request(request['method'], request['path'], data=request['body'], headers=request['headers'], override_num_retries=0)

        if response.status == 500 or response.status == 503:
            print 'Request generated with seed %d failed:\n%s' % (request_seed, request)
        pass


def main():
    common.setup()
    try:
        _main()
    except Exception as e:
        traceback.print_exc()
        common.teardown()