                         query      : {file_use:obj[0]}
                         cb         : cb
                 (x, cb) ->
-                    expect(x).toEqual({insert: obj[0]})
+                    expect(x).toEqual({action:'insert', new_val: obj[0]})
 
                     db.user_query   # insert first object
                         account_id : accounts[0]
                         query      : {file_use:obj[1]}
                         cb         : cb
                 (x, cb) ->
-                    expect(x).toEqual({insert: obj[1]})
+                    expect(x).toEqual({action:'insert', new_val: obj[1]})
                     cb()
             ], done)
 

                        cb    : cb

                (x, cb) ->
                    expect(x).toEqual({"delete": {id:obj2.id, project_id:projects[0]}})

                    db.user_query_cancel_changefeed(id:id, cb:cb)
            ], done)

                                query      : {accounts:{account_id:account_id, first_name:'SAGE!'}}
                                cb         : cb
                        (x, cb) ->
                            expect(x).toEqual({ action:'update', new_val: { account_id:account_id, first_name:'SAGE!'}})
                            db.delete_account(account_id:account_id, cb:cb)
                        (x, cb) ->
                            expect(x).toEqual({ action: 'delete', old_val: { account_id:account_id } })
                            db.user_query_cancel_changefeed(id:changefeed_id, cb:cb)
                        ], cb)
        ], (err) ->
