# -*- coding: utf-8 -*-

"""

 (c) 2015-2018 - Copyright Red Hat Inc

 Authors:

   Pierre-Yves Chibon <pingou@pingoured.fr></pingou@pingoured.fr>

"""

from __future__ import unicode_literals, absolute_import

import datetime

import os

import pytz

import shutil

import sys

import unittest

import json

from mock import patch

sys.path.insert(0, os.path.join(os.path.dirname(

    os.path.abspath(__file__)), '..'))

import pagure.api

import pagure.config

import pagure.lib.model as model

import pagure.lib.query

import tests

class PagureFlaskApiUSertests(tests.Modeltests):

    """ Tests for the flask API of pagure for issue """

    maxDiff = None

    def setUp(self):

        """ Set up the environnment, ran before every tests. """

        super(PagureFlaskApiUSertests, self).setUp()

        pagure.config.config['REQUESTS_FOLDER'] = None

    def test_api_users(self):

        """ Test the api_users function.  """

        output = self.app.get('/api/0/users')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        self.assertEqual(sorted(data['users']), ['foo', 'pingou'])

        self.assertEqual(sorted(data.keys()), ['mention', 'total_users', 'users'])

        self.assertEqual(data['total_users'], 2)

        output = self.app.get('/api/0/users?pattern=p')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        self.assertEqual(data['users'], ['pingou'])

        self.assertEqual(sorted(data.keys()), ['mention', 'total_users', 'users'])

        self.assertEqual(data['total_users'], 1)

    def test_api_view_user(self):

        """

            Test the api_view_user method of the flask api

            The tested user has no project or forks.

        """

        output = self.app.get('/api/0/user/pingou')

        self.assertEqual(output.status_code, 200)

        exp = {

            "forks": [],

            'forks_pagination': {

              'first': 'http://localhost...',

              'last': 'http://localhost...',

              'next': None,

              'forkpage': 1,

              'pages': 0,

              'per_page': 20,

              'prev': None},

            "repos": [],

            'repos_pagination': {

              'first': 'http://localhost...',

              'last': 'http://localhost...',

              'next': None,

              'repopage': 1,

              'pages': 0,

              'per_page': 20,

              'prev': None},

            "user": { "fullname": "PY C",

                      "name": "pingou",

                      'avatar_url': 'https://seccdn.libravatar.org/avatar/...'}}

        data = json.loads(output.get_data(as_text=True))

        data["user"]["avatar_url"] = "https://seccdn.libravatar.org/avatar/..."

        for k in ['forks_pagination', 'repos_pagination']:

            for k2 in ['first', 'last']:

                self.assertIsNotNone(data[k][k2])

                data[k][k2] = 'http://localhost...'

        self.assertEqual(data, exp)

    def test_api_view_user_with_project(self):

        """

            Test the api_view_user method of the flask api,

            this time the user has some project defined.

        """

        tests.create_projects(self.session)

        output = self.app.get('/api/0/user/pingou')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        data['repos'][0]['date_created'] = "1490272832"

        data['repos'][0]['date_modified'] = "1490272832"

        data['repos'][1]['date_created'] = "1490272832"

        data['repos'][1]['date_modified'] = "1490272832"

        data['repos'][2]['date_created'] = "1490272832"

        data['repos'][2]['date_modified'] = "1490272832"

        for k in ['forks_pagination', 'repos_pagination']:

            for k2 in ['first', 'last']:

                self.assertIsNotNone(data[k][k2])

                data[k][k2] = 'http://localhost...'

        expected_data = {

            "forks": [],

            'forks_pagination': {

              'first': 'http://localhost...',

              'last': 'http://localhost...',

              'next': None,

              'forkpage': 1,

              'pages': 0,

              'per_page': 20,

              'prev': None},

            "repos": [

                {

                    "access_groups": {

                        "admin": [],

                        "commit": [],

                        "ticket": []

                    },

                    "access_users": {

                        "admin": [],

                        "commit": [],

                        "owner": ["pingou"],

                        "ticket": []

                    },

                    "close_status": [

                        "Invalid",

                        "Insufficient data",

                        "Fixed",

                        "Duplicate"

                    ],

                    "custom_keys": [],

                    "date_created": "1490272832",

                    "date_modified": "1490272832",

                    "description": "test project #1",

                    "fullname": "test",

                    "url_path": "test",

                    "id": 1,

                    "milestones": {},

                    "name": "test",

                    "namespace": None,

                    "parent": None,

                    "priorities": {},

                    "tags": [],

                    "user": {

                        "fullname": "PY C",

                        "name": "pingou"

                    }

                },

                {

                    "access_groups": {

                        "admin": [],

                        "commit": [],

                        "ticket": []

                    },

                    "access_users": {

                        "admin": [],

                        "commit": [],

                        "owner": ["pingou"],

                        "ticket": []

                    },

                    "close_status": [

                        "Invalid",

                        "Insufficient data",

                        "Fixed",

                        "Duplicate"

                    ],

                    "custom_keys": [],

                    "date_created": "1490272832",

                    "date_modified": "1490272832",

                    "description": "test project #2",

                    "fullname": "test2",

                    "url_path": "test2",

                    "id": 2,

                    "milestones": {},

                    "name": "test2",

                    "namespace": None,

                    "parent": None,

                    "priorities": {},

                    "tags": [],

                    "user": {

                        "fullname": "PY C",

                        "name": "pingou"

                    }

                },

                {

                    "access_groups": {

                        "admin": [],

                        "commit": [],

                        "ticket": []},

                    "access_users": {

                        "admin": [],

                        "commit": [],

                        "owner": ["pingou"],

                        "ticket": []

                    },

                    "close_status": [

                        "Invalid",

                        "Insufficient data",

                        "Fixed",

                        "Duplicate"

                    ],

                    "custom_keys": [],

                    "date_created": "1490272832",

                    "date_modified": "1490272832",

                    "description": "namespaced test project",

                    "fullname": "somenamespace/test3",

                    "url_path": "somenamespace/test3",

                    "id": 3,

                    "milestones": {},

                    "name": "test3",

                    "namespace": "somenamespace",

                    "parent": None,

                    "priorities": {},

                    "tags": [],

                    "user": {

                        "fullname": "PY C",

                        "name": "pingou"

                    }

                }

            ],

            'repos_pagination': {

              'first': 'http://localhost...',

              'last': 'http://localhost...',

              'next': None,

              'repopage': 1,

              'pages': 1,

              'per_page': 20,

              'prev': None},

            "user": {

                "fullname": "PY C",

                "name": "pingou",

                'avatar_url': 'https://seccdn.libravatar.org/avatar/...'

            }

        }

        data["user"]["avatar_url"] = "https://seccdn.libravatar.org/avatar/..."

        self.assertEqual(data, expected_data)

    @patch('pagure.lib.notify.send_email')

    def test_api_view_user_activity_stats(self, mockemail):

        """ Test the api_view_user_activity_stats method of the flask user

        api. """

        mockemail.return_value = True

        tests.create_projects(self.session)

        tests.create_tokens(self.session)

        tests.create_tokens_acl(self.session)

        headers = {'Authorization': 'token aaabbbcccddd'}

        # Create a pull-request

        repo = pagure.lib.query._get_project(self.session, 'test')

        forked_repo = pagure.lib.query._get_project(self.session, 'test')

        req = pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='test pull-request',

            user='pingou',

        )

        self.session.commit()

        self.assertEqual(req.id, 1)

        self.assertEqual(req.title, 'test pull-request')

        # Check comments before

        self.session.commit()

        request = pagure.lib.query.search_pull_requests(

            self.session, project_id=1, requestid=1)

        self.assertEqual(len(request.comments), 0)

        data = {

            'comment': 'This is a very interesting question',

        }

        # Valid request

        output = self.app.post(

            '/api/0/test/pull-request/1/comment', data=data, headers=headers)

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        self.assertDictEqual(

            data,

            {'message': 'Comment added'}

        )

        # One comment added

        self.session.commit()

        request = pagure.lib.query.search_pull_requests(

            self.session, project_id=1, requestid=1)

        self.assertEqual(len(request.comments), 1)

        # Close PR

        output = self.app.post(

            '/api/0/test/pull-request/1/close', headers=headers)

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        self.assertDictEqual(

            data,

            {"message": "Pull-request closed!"}

        )

        # PR closed

        self.session.commit()

        request = pagure.lib.query.search_pull_requests(

            self.session, project_id=1, requestid=1)

        self.assertEqual(request.status, 'Closed')

        # Finally retrieve the user's logs

        output = self.app.get('/api/0/user/pingou/activity/stats')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        date = datetime.datetime.utcnow().date().strftime('%Y-%m-%d')

        self.assertDictEqual(data, {date: 4})

    @patch('pagure.lib.notify.send_email')

    def test_api_view_user_activity_date(self, mockemail):

        """ Test the api_view_user_activity_date method of the flask user

        api. """

        self.test_api_view_user_activity_stats()

        # Invalid date

        output = self.app.get('/api/0/user/pingou/activity/AABB')

        self.assertEqual(output.status_code, 400)

        # Invalid date

        output = self.app.get('/api/0/user/pingou/activity/2016asd')

        self.assertEqual(output.status_code, 200)

        exp = {

          "activities": [],

          "date": "2016-01-01"

        }

        self.assertEqual(json.loads(output.get_data(as_text=True)), exp)

        # Date parsed, just not really as expected

        output = self.app.get('/api/0/user/pingou/activity/20161245')

        self.assertEqual(output.status_code, 200)

        exp = {

          "activities": [],

          "date": "1970-08-22"

        }

        self.assertEqual(json.loads(output.get_data(as_text=True)), exp)

        date = datetime.datetime.utcnow().date().strftime('%Y-%m-%d')

        # Retrieve the user's logs for today

        output = self.app.get('/api/0/user/pingou/activity/%s' % date)

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        exp = {

          "activities": [

            {

              "date": date,

              "date_created": "1477558752",

              "type": "pull-request",

              "description_mk": "
pingou created PR test#1
",

              "id": 1,

              "ref_id": "1",

              "type": "created",

              "user": {

                "fullname": "PY C",

                "name": "pingou"

              }

            },

            {

              "date": date,

              "date_created": "1477558752",

              "type": "pull-request",

              "description_mk": "
pingou commented on PR test#1
",

              "id": 2,

              "ref_id": "1",

              "type": "commented",

              "user": {

                "fullname": "PY C",

                "name": "pingou"

              }

            },

            {

              "date": date,

              "date_created": "1477558752",

              "type": "pull-request",

              "description_mk": "
pingou closed PR test#1
",

              "id": 3,

              "ref_id": "1",

              "type": "closed",

              "user": {

                "fullname": "PY C",

                "name": "pingou"

              }

            },

            {

              "date": date,

              "date_created": "1477558752",

              "type": "pull-request",

              "description_mk": "
pingou commented on PR test#1
",

              "id": 4,

              "ref_id": "1",

              "type": "commented",

              "user": {

                "fullname": "PY C",

                "name": "pingou"

              }

            }

          ],

          "date": date,

        }

        for idx, act in enumerate(data['activities']):

            act['date_created'] = '1477558752'

            data['activities'][idx] = act

        self.assertEqual(data, exp)

    @patch('pagure.lib.notify.send_email')

    def test_api_view_user_activity_date_1_activity(self, mockemail):

        """ Test the api_view_user_activity_date method of the flask user

        api when the user only did one action. """

        tests.create_projects(self.session)

        repo = pagure.lib.query._get_project(self.session, 'test')

        now = datetime.datetime.utcnow()

        date = now.date().strftime('%Y-%m-%d')

        # Create a single commit log

        log = model.PagureLog(

            user_id=1,

            user_email='foo@bar.com',

            project_id=1,

            log_type='committed',

            ref_id='githash',

            date=now.date(),

            date_created=now

        )

        self.session.add(log)

        self.session.commit()

        # Retrieve the user's logs for today

        output = self.app.get(

            '/api/0/user/pingou/activity/%s?grouped=1' % date)

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        exp = {

          "activities": [

            {

              "description_mk": "
pingou committed on test#githash
"

            }

          ],

          "date": date,

        }

        self.assertEqual(data, exp)

    @patch('pagure.lib.notify.send_email')

    def test_api_view_user_activity_timezone_negative(self, mockemail):

        """Test api_view_user_activity{_stats,_date} with the America/

        New York timezone, which is 5 hours behind UTC in winter and

        4 hours behind UTC in summer (daylight savings). The events

        will occur on XXXX-02-15 in UTC, but on XXXX-02-14 local.

        """

        tests.create_projects(self.session)

        repo = pagure.lib.query._get_project(self.session, 'test')

        today = datetime.datetime.utcnow().date()

        year = today.year

        if today.year == 2 and today.date <=15:

            year = year - 1

        elif today.year < 2:

            year = year - 1

        dateobj = datetime.datetime(year, 2, 15, 3, 30)

        utcdate = '%s-02-15' % year

        # the Unix timestamp for YYYY-02-15 12:00 UTC

        utcts = str(int(

            (

                datetime.datetime(year, 2, 15, 12, 0, tzinfo=pytz.UTC)

                - datetime.datetime(1970, 1, 1, tzinfo=pytz.UTC)

            ).total_seconds()

        ))

        localdate = '%s-02-14' % today.year

        # the Unix timestamp for YYYY-02-15 18:00 America/New_York

        localts = str(int(

            (

                datetime.datetime(

                    year, 2, 14, 17, 0, tzinfo=pytz.timezone('America/New_York'))

                - datetime.datetime(

                    1970, 1, 1 , tzinfo=pytz.timezone('America/New_York'))

            ).total_seconds()

        ))

        # Create a single commit log

        log = model.PagureLog(

            user_id=1,

            user_email='foo@bar.com',

            project_id=1,

            log_type='committed',

            ref_id='githash',

            date=dateobj.date(),

            date_created=dateobj

        )

        self.session.add(log)

        self.session.commit()

        # Retrieve the user's stats with no timezone specified (==UTC)

        output = self.app.get('/api/0/user/pingou/activity/stats')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        # date in output should be UTC date

        self.assertDictEqual(data, {utcdate: 1})

        # Now in timestamp format...

        output = self.app.get('/api/0/user/pingou/activity/stats?format=timestamp')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        # timestamp in output should be UTC ts

        self.assertDictEqual(data, {utcts: 1})

        # Retrieve the user's stats with local timezone specified

        output = self.app.get('/api/0/user/pingou/activity/stats?tz=America/New_York')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        # date in output should be local date

        self.assertDictEqual(data, {localdate: 1})

        # Now in timestamp format...

        output = self.app.get('/api/0/user/pingou/activity/stats?format=timestamp&tz=America/New_York')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        # timestamp in output should be local ts

        self.assertDictEqual(data, {localts: 1})

        # Retrieve the user's logs for 2018-02-15 with no timezone

        output = self.app.get(

            '/api/0/user/pingou/activity/%s?grouped=1' % utcdate)

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        exp = {

          "activities": [

            {

              "description_mk": "
pingou committed on test#githash
"

            }

          ],

          "date": utcdate,

        }

        self.assertEqual(data, exp)

        # Now retrieve the user's logs for 2018-02-14 with local time

        output = self.app.get(

            '/api/0/user/pingou/activity/%s?grouped=1&tz=America/New_York' % localdate)

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        exp['date'] = localdate

        self.assertEqual(data, exp)

    @patch('pagure.lib.notify.send_email')

    def test_api_view_user_activity_timezone_positive(self, mockemail):

        """Test api_view_user_activity{_stats,_date} with the Asia/

        Dubai timezone, which is 4 hours ahead of UTC. The events will

        occur on XXXX-02-15 in UTC, but on XXXX-02-16 in local time.

        """

        tests.create_projects(self.session)

        repo = pagure.lib.query._get_project(self.session, 'test')

        today = datetime.datetime.utcnow().date()

        year = today.year

        if today.year == 2 and today.date <=15:

            year = year - 1

        elif today.year < 2:

            year = year - 1

        dateobj = datetime.datetime(year, 2, 15, 22, 30)

        utcdate = '%s-02-15' % year

        # the Unix timestamp for YYYY-02-15 12:00 UTC

        utcts = str(int(

            (

                datetime.datetime(year, 2, 15, 12, 0, tzinfo=pytz.UTC)

                - datetime.datetime(1970, 1, 1, tzinfo=pytz.UTC)

            ).total_seconds()

        ))

        localdate = '%s-02-16' % year

        # the Unix timestamp for YYYY-02-16 9:00 Asia/Dubai

        localts = str(int(

            (

                datetime.datetime(

                    year, 2, 16, 8, 0, tzinfo=pytz.timezone('Asia/Dubai'))

                - datetime.datetime(

                    1970, 1, 1 , tzinfo=pytz.timezone('Asia/Dubai'))

            ).total_seconds()

        ))

        # Create a single commit log

        log = model.PagureLog(

            user_id=1,

            user_email='foo@bar.com',

            project_id=1,

            log_type='committed',

            ref_id='githash',

            date=dateobj.date(),

            date_created=dateobj

        )

        self.session.add(log)

        self.session.commit()

        # Retrieve the user's stats with no timezone specified (==UTC)

        output = self.app.get('/api/0/user/pingou/activity/stats')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        # date in output should be UTC date

        self.assertDictEqual(data, {utcdate: 1})

        # Now in timestamp format...

        output = self.app.get('/api/0/user/pingou/activity/stats?format=timestamp')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        # timestamp in output should be UTC ts

        self.assertDictEqual(data, {utcts: 1})

        # Retrieve the user's stats with local timezone specified

        output = self.app.get('/api/0/user/pingou/activity/stats?tz=Asia/Dubai')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        # date in output should be local date

        self.assertDictEqual(data, {localdate: 1})

        # Now in timestamp format...

        output = self.app.get('/api/0/user/pingou/activity/stats?format=timestamp&tz=Asia/Dubai')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        # timestamp in output should be local ts

        self.assertDictEqual(data, {localts: 1})

        # Retrieve the user's logs for 2018-02-15 with no timezone

        output = self.app.get(

            '/api/0/user/pingou/activity/%s?grouped=1' % utcdate)

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        exp = {

          "activities": [

            {

              "description_mk": "
pingou committed on test#githash
"

            }

          ],

          "date": utcdate,

        }

        self.assertEqual(data, exp)

        # Now retrieve the user's logs for 2018-02-16 with local time

        output = self.app.get(

            '/api/0/user/pingou/activity/%s?grouped=1&tz=Asia/Dubai' % localdate)

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        exp['date'] = localdate

        self.assertEqual(data, exp)

class PagureFlaskApiUsertestrequests(tests.Modeltests):

    """ Tests for the user requests endpoints """

    maxDiff = None

    def setUp(self):

        """ Set up the environnment, ran before every tests. """

        super(PagureFlaskApiUsertestrequests, self).setUp()

        pagure.config.config['REQUESTS_FOLDER'] = None

        tests.create_projects(self.session)

        # Create few pull-requests

        repo = pagure.lib.query.get_authorized_project(self.session, 'test')

        forked_repo = pagure.lib.query.get_authorized_project(self.session, 'test')

        pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='open pullrequest by user foo on repo test',

            user='foo',

        )

        repo = pagure.lib.query.get_authorized_project(self.session, 'test2')

        forked_repo = pagure.lib.query.get_authorized_project(self.session, 'test2')

        pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='open pullrequest by user foo on repo test2',

            user='foo',

        )

        self.session.commit()

        repo = pagure.lib.query.get_authorized_project(self.session, 'test')

        forked_repo = pagure.lib.query.get_authorized_project(self.session, 'test')

        pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='closed pullrequest by user foo on repo test',

            user='foo',

            status='Closed',

        )

        repo = pagure.lib.query.get_authorized_project(self.session, 'test2')

        forked_repo = pagure.lib.query.get_authorized_project(self.session, 'test2')

        pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='closed pullrequest by user foo on repo test2',

            user='foo',

            status='Closed',

        )

        self.session.commit()

        repo = pagure.lib.query.get_authorized_project(self.session, 'test')

        forked_repo = pagure.lib.query.get_authorized_project(self.session, 'test')

        pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='merged pullrequest by user foo on repo test',

            user='foo',

            status='Merged',

        )

        repo = pagure.lib.query.get_authorized_project(self.session, 'test2')

        forked_repo = pagure.lib.query.get_authorized_project(self.session, 'test2')

        pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='merged pullrequest by user foo on repo test2',

            user='foo',

            status='Merged',

        )

        self.session.commit()

        repo = pagure.lib.query.get_authorized_project(self.session, 'test')

        forked_repo = pagure.lib.query.get_authorized_project(self.session, 'test')

        pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='open pullrequest by user pingou on repo test',

            user='pingou',

        )

        self.session.commit()

        repo = pagure.lib.query.get_authorized_project(self.session, 'test2')

        forked_repo = pagure.lib.query.get_authorized_project(self.session, 'test2')

        pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='open pullrequest by user pingou on repo test2',

            user='pingou',

        )

        self.session.commit()

        repo = pagure.lib.query.get_authorized_project(self.session, 'test')

        forked_repo = pagure.lib.query.get_authorized_project(self.session, 'test')

        pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='closed pullrequest by user pingou on repo test',

            user='pingou',

            status="Closed",

        )

        self.session.commit()

        repo = pagure.lib.query.get_authorized_project(self.session, 'test2')

        forked_repo = pagure.lib.query.get_authorized_project(self.session, 'test2')

        pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='closed pullrequest by user pingou on repo test2',

            user='pingou',

            status="Closed",

        )

        self.session.commit()

        repo = pagure.lib.query.get_authorized_project(self.session, 'test')

        forked_repo = pagure.lib.query.get_authorized_project(self.session, 'test')

        pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='merged pullrequest by user pingou on repo test',

            user='pingou',

            status="Merged",

        )

        self.session.commit()

        repo = pagure.lib.query.get_authorized_project(self.session, 'test2')

        forked_repo = pagure.lib.query.get_authorized_project(self.session, 'test2')

        pagure.lib.query.new_pull_request(

            session=self.session,

            repo_from=forked_repo,

            branch_from='master',

            repo_to=repo,

            branch_to='master',

            title='merged pullrequest by user pingou on repo test2',

            user='pingou',

            status="Merged",

        )

        self.session.commit()

    @patch('pagure.lib.notify.send_email')

    def test_api_view_user_requests_filed(self, mockemail):

        """ Test the api_view_user_requests_filed method of the flask user

        api """

        # First we test without the status parameter. It should default to `open`

        output = self.app.get(

            '/api/0/user/pingou/requests/filed')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        self.assertEqual(len(data['requests']), 2)

        self.assertEqual(

            sorted(data.keys()),

            [u'args', u'pagination', u'requests', u'total_requests'])

        self.assertEqual(data['requests'][0]['user']['name'], "pingou")

        self.assertEqual(data['requests'][1]['user']['name'], "pingou")

        self.assertEqual(data['requests'][0]['status'], "Open")

        self.assertEqual(data['requests'][1]['status'], "Open")

        self.assertEqual(data['requests'][0]['title'], "open pullrequest by user pingou on repo test2")

        self.assertEqual(data['requests'][1]['title'], "open pullrequest by user pingou on repo test")

        self.assertEqual(data['args']['status'], "open")

        self.assertEqual(data['args']['page'], 1)

        # Next test with the status parameter set to `open`.

        output = self.app.get(

            '/api/0/user/pingou/requests/filed?status=open')

        self.assertEqual(output.status_code, 200)

        data = json.loads(output.get_data(as_text=True))

        self.assertEqual(len(data['requests']), 2)

        self.assertEqual(

            sorted(data.keys()),

            [u'args', u'pagination', u'requests', u'total_requests'])

        self.assertEqual(data['requests'][0]['user']['name'], "pingou")

        self.assertEqual(data['requests'][1]['user']['name'], "pingou")

        self.assertEqual(data['requests'][0]['status'], "Open")

        self.assertEqual(data['requests'][1]['status'], "Open")

        self.assertEqual(data['requests'][0]['title'], "open pullrequest by user pingou on repo test2")

        self.assertEqual(data['requests'][1]['title'], "open pullrequest by user pingou on repo test")

        self.assertEqual(data['args']['status'], "open")

        self.assertEqual(data['args']['page'], 1)