def test_plumbing(inq, outq, proc):
    data = get_simple_data(100)
    i = 0
    for sample in send_get_data(data, inq, outq):
        t.eq(sample, data[i])
        i += 1
    t.eq(i, 100)

def test_filter(inq, outq, proc):
    data = get_simple_data(100)
    i = 0
    for sample in send_get_data(data, inq, outq):
        t.eq(sample[2] % 2, 1)
        i += 1
    t.eq(i, 50)

def test_syntax_error(cx):
    try:
        cx.execute("function(asdf;")
        t.eq(1, 0)
    except:
        line = traceback.format_exc().split("\n")[-3].strip()
        t.eq(line, ERROR)

def test_016(u, c):
    fn = os.path.join(os.path.dirname(__file__), "1M")
    with open(fn, "rb") as f:
        l = int(os.fstat(f.fileno())[6])
        r = c.request(u, 'POST', body=f)
        t.eq(r.status_int, 200)
        t.eq(int(r.body), l)

 def test_ok(self):
     self.TestResource.conflict = False
     self.env.method = 'PUT'
     self.env.content_type = 'text/html'
     self.go()
     t.eq(self.rsp.status_code, 200)
     t.eq(self.rsp.response, ['bar'])

def test_compiled_contexts(rt):
    "Check to be sure multiple contexts can be used for compiled execution."
    ctx1 = rt.new_context({"a": 111})
    ctx2 = rt.new_context({"a": 222})
    expr1 = ctx1.compile("a * 3;")
    t.eq(expr1.execute(), 333)
    t.eq(expr1.execute(ctx2), 666)

def test_update_user(api):
    data = {
        "username": "blossom",
        "firstname": "Blossom",
        "lastname": "Utonium",
        "password1": "ng5qhhbiwozcANc3",
        "password2": "ng5qhhbiwozcANc3",
        "email": "[email protected]",
        "timezone": "Africa/Johannesburg",
        "account_type": "3",
        "domains": "9",
        "active": "y",
        "send_report": "y",
        "spam_checks": "y",
        "low_score": "5.0",
        "high_score": "10.0",
    }
    req = api.update_user(data)
    path = ENDPOINTS["users"]["update"]["name"]
    t.eq(api.response.final_url, "%s%s%s" % (BASE_URL, API_PATH, path))
    t.eq(api.response.request.method, ENDPOINTS["users"]["update"]["method"])
    t.eq(api.response.status_int, 201)
    t.eq(req["low_score"], "5.0")
    t.eq(req["high_score"], "10.0")
    t.isnotin("password1", req)

 def test_ok(self):
     self.TestResource.conflict = False
     self.req.method = 'PUT'
     self.req.content_type = 'text/html'
     self.go()
     t.eq(self.rsp.status, '200 OK')
     t.eq(self.rsp.body, 'bar')

def test_from_func():
    @t.task
    def foo():
        "Hi"
        pass
    t.desc(foo, "yay")
    t.eq(t.app.mgr.lookup("foo").descr, "yay")

 def test_post_is_create_no_redirect(self):
     self.TestResource.create = True
     self.TestResource.location = None
     self.req.method = 'POST'
     self.go()
     t.eq(self.rsp.status, '200 OK')
     t.eq(self.rsp.body, 'created')

def test_override_docstring():
    @t.task
    def foo():
        "Not the description"
        pass
    t.desc("foo", "wheeee")
    t.eq(t.app.mgr.lookup("foo").descr, "wheeee")

def test_add_description_first():
    t.desc("foo", "bazinga")
    @t.task
    def foo():
        "Not used as a description"
        pass
    t.eq(t.app.mgr.lookup("foo").descr, "bazinga")

def test_003():
     u = "http://test:[email protected]%s:%s/auth" % (HOST, PORT)
     r = request(u)
     t.eq(r.status_int, 200)
     u = "http://test:[email protected]%s:%s/auth" % (HOST, PORT)
     r = request(u)
     t.eq(r.status_int, 403)

def second(rec):
    t.eq(rec.meta, {
        'ids': [
            ('gi', '66816243'),
            ('ref', 'XP_642131.1'),
            ('gi', '1705556'),
            ('sp', 'P54670.1|CAF1_DICDI'),
            ('gi', '793761'),
            ('dbj', 'BAA06266.1'),
            ('gi', '60470106'),
            ('gb', 'EAL68086.1')
        ],
        'desc': [
            'calfumirin-1 [Dictyostelium discoideum AX4]',
            'RecName: Full=Calfumirin-1; Short=CAF-1',
            'calfumirin-1 [Dictyostelium discoideum]'
        ]
    })
    t.eq(rec.id, ('gi', '66816243'))
    t.eq(rec.desc, 'calfumirin-1 [Dictyostelium discoideum AX4]')
    t.eq(rec.sequence, ''.join("""
        MASTQNIVEEVQKMLDTYDTNKDGEITKAEAVEYFKGKKAFNPERSAIYLFQVYDKDNDGKITIKELA
        GDIDFDKALKEYKEKQAKSKQQEAEVEEDIEAFILRHNKDDNTDITKDELIQGFKETGAKDPEKSANF
        ILTEMDTNKDGTITVKELRVYYQKVQKLLNPDQ
    """.split()))
    t.eq(rec.hash, "7D6B32F721E2E8BF34A37015C11E3FBAA0C791B8")

def test_raw_yaml():
    yaml = dedent("""\
        name: test
        sql: SELECT 'x' as "foo"
        """)
    conn = t.sheba.connect(yaml, driver='sqlite3', args=(":memory:",))
    t.eq(isinstance(conn, t.Connection), True)

def test_py_del_global(rt):
    glbl = ActiveGlobalWithDel()
    cx = rt.new_context(glbl)
    cx.execute("foo = 4;")
    t.eq(glbl.data["foo"], 8)
    cx.execute("delete foo;")
    t.isnotin("foo", glbl.data)

def test_nworkers_changed():
    c = config.Config()
    def nworkers_changed_3(server, new_value, old_value):
        return 3

    c.set("nworkers_changed", nworkers_changed_3)
    t.eq(3, c.nworkers_changed(1, 2, 3))

def test_statement_error():
    obj = {"name": "test"}
    try:
        t.Statement(obj)
    except t.IncompleteStatementError, e:
        t.eq(e.name, "sql")
        str(e)  # Doesn't raise

def test_py_no_del_item(rt):
    glbl = ActiveGlobal()
    cx = rt.new_context(glbl)
    cx.execute('foo = 4;')
    t.eq(glbl.data["foo"], 8)
    cx.execute("delete foo;")
    t.isin("foo", glbl.data)

def test_invalid_native_case(conn, cursor):
    try:
        t.dbwrapper.DB_INFO['sqlite'].native_case = "foo"
        cursor.execute("select 1 as a")
    except t.dbwrapper.InvalidNativeCase, inst:
        t.eq(inst.name, "foo")
        str(inst) # Doesn't raise