pkg = lookup_package(pkginfo, create=True)

      # validate arches before running callbacks

      extra_arches = koji.parse_arches(extra_arches, strict=True, allow_none=True)

      # first check to see if package is:

      #   already present (via inheritance)

      #   blocked

          _pkglist_add(tag_id, pkg['id'], owner, block, extra_arches)

      elif changed_owner:

          _pkglist_owner_add(tag_id, pkg['id'], owner)

  def pkglist_remove(taginfo, pkginfo, force=False):

      """Remove package from the list for tag

          #don't check policy for admins using force

          if not (force and context.session.hasPerm('admin')):

              assert_policy('package_list', policy_data)

      _pkglist_remove(tag['id'], pkg['id'])

  def pkglist_block(taginfo, pkginfo, force=False):

      #don't check policy for admins using force

      if not (force and context.session.hasPerm('admin')):

          assert_policy('package_list', policy_data)

      tag_id = tag['id']

      pkg_id = pkg['id']

      pkglist = readPackageList(tag_id, pkgID=pkg_id, inherit=True)

          pkglist = readPackageList(tag_id, pkgID=pkg_id, inherit=True)

          if pkg_id not in pkglist or pkglist[pkg_id]['blocked']:

              _pkglist_add(tag_id, pkg_id, previous['owner_id'], False, previous['extra_arches'])

  def pkglist_setowner(taginfo, pkginfo, owner, force=False):

      """Set the owner for package in tag"""

      props = {'type': cbtype[4:],

               'tag': kws['tag']['name'],

               'package': kws['package']['name'],

      queue_msg(address, props, kws)

  @convert_datetime

      @mock.patch('kojihub.make_task')

      def test_DistRepo(self, make_task, dist_repo_init):

          session = kojihub.context.session = mock.MagicMock()

          # It seems MagicMock will not automatically handle attributes that

          # start with "assert"

          session.assertPerm = mock.MagicMock()

      def test_distRepoMove(self):

          exports = kojihub.HostExports()

          exports.distRepoMove(self.rinfo['id'], self.uploadpath, self.arch)

          # check result

  import koji

  import kojihub

  class TestPkglistBlock(unittest.TestCase):

      def setUp(self):

          self.context = mock.patch('kojihub.context').start()

          # It seems MagicMock will not automatically handle attributes that

          # start with "assert"

          self.context.session.assertLogin = mock.MagicMock()

          self.run_callbacks = mock.patch('koji.plugin.run_callbacks').start()

      def tearDown(self):

          _pkglist_remove.assert_called_once_with(tag['id'], pkg['id'])

          self.assertEqual(self.run_callbacks.call_count, 2)

          self.run_callbacks.assert_has_calls([

          ])

      @mock.patch('kojihub._pkglist_remove')

          policy=True

          tag = {'id': 1, 'name': 'tag'}

          pkg = {'id': 2, 'name': 'pkg', 'owner_id': 3}

          get_tag.return_value = tag

          lookup_package.return_value = pkg

          readPackageList.return_value = {}

          get_tag.assert_called_once_with(tag['name'], strict=True)

          lookup_package.assert_called_once_with(pkg['name'], strict=False)

          assert_policy.assert_called_once_with('package_list', {'tag': tag['id'],

              'action': 'add', 'package': pkg['name'], 'force': False})

          self.assertEqual(self.run_callbacks.call_count, 2)

          self.run_callbacks.assert_has_calls([

              mock.call('prePackageListChange', action='add', tag=tag,

                  package=pkg, owner=user['id'], block=block,

              mock.call('postPackageListChange', action='add', tag=tag,

                  package=pkg, owner=user['id'], block=block,

          ])

          _pkglist_add.assert_called_once_with(tag['id'], pkg['id'],

              user['id'], block, extra_arches)

          policy=True

          tag = {'id': 1, 'name': 'tag'}

          pkg = {'id': 2, 'name': 'pkg', 'owner_id': 3}

          get_tag.return_value = tag

          lookup_package.side_effect = [None, pkg]

          readPackageList.return_value = {}

              mock.call(pkg['name'], strict=False),

              mock.call(pkg['name'], create=True),

          )

          assert_policy.assert_called_once_with('package_list', {'tag': tag['id'],

              'action': 'add', 'package': pkg['name'], 'force': False})

          self.assertEqual(self.run_callbacks.call_count, 2)

          self.run_callbacks.assert_has_calls([

              mock.call('prePackageListChange', action='add', tag=tag,

                  package=pkg, owner=user['id'], block=block,

              mock.call('postPackageListChange', action='add', tag=tag,

                  package=pkg, owner=user['id'], block=block,

          ])

          _pkglist_add.assert_called_once_with(tag['id'], pkg['id'],

              user['id'], block, extra_arches)

          policy=True

          tag = {'id': 1, 'name': 'tag'}

          pkg = {'id': 2, 'name': 'pkg', 'owner_id': 3}

          get_tag.return_value = tag

          lookup_package.return_value = pkg

          readPackageList.return_value = {pkg['id']: {

              'owner_id': pkg['owner_id'],

              'blocked': True,

          get_tag.assert_called_once_with(tag['name'], strict=True)

          lookup_package.assert_called_once_with(pkg['name'], strict=False)

          assert_policy.assert_called_once_with('package_list', {'tag': tag['id'],

              'action': 'add', 'package': pkg['name'], 'force': False})

          self.run_callbacks.assert_called_once_with(

                  'prePackageListChange', action='add', tag=tag,

                  package=pkg, owner=user['id'], block=block,

          _pkglist_add.assert_not_called()

      @mock.patch('kojihub._pkglist_add')

          policy=True

          tag = {'id': 1, 'name': 'tag'}

          pkg = {'id': 2, 'name': 'pkg', 'owner_id': 3}

          get_tag.return_value = tag

          lookup_package.return_value = pkg

          readPackageList.return_value = {pkg['id']: {

              'owner_id': pkg['owner_id'],

              'blocked': True,

          get_tag.assert_called_once_with(tag['name'], strict=True)

          lookup_package.assert_called_once_with(pkg['name'], strict=False)

          # force + admin

          assert_policy.assert_not_called()

          self.run_callbacks.assert_has_calls([

              mock.call('prePackageListChange', action='add', tag=tag,

                  package=pkg, owner=user['id'], block=block,

              mock.call('postPackageListChange', action='add', tag=tag,

                  package=pkg, owner=user['id'], block=block,

          ])

          _pkglist_add.assert_called_once_with(tag['id'], pkg['id'],

              user['id'], block, extra_arches)

                                             package={'name': 'test-pkg'},

                                             owner=1,

                                             block=False, extra_arches='i386 x86_64',

          self.assertMsg('package.add', type='PackageListChange', tag='test-tag',

      def test_prep_package_list_change_update(self):

          protonmsg.prep_package_list_change('postPackageListChange',

                                             package={'name': 'test-pkg'},

                                             owner=1,

                                             block=False, extra_arches='i386 x86_64',

          self.assertMsg('package.update', type='PackageListChange', tag='test-tag',

      def test_prep_package_list_change_block(self):

          protonmsg.prep_package_list_change('postPackageListChange',

                                             package={'name': 'test-pkg'},

                                             owner=1,

                                             block=False, extra_arches='i386 x86_64',

          self.assertMsg('package.block', type='PackageListChange', tag='test-tag',

      def test_prep_package_list_change_unblock(self):

          protonmsg.prep_package_list_change('postPackageListChange',

                                             action='unblock', tag={'name': 'test-tag'},

          self.assertMsg('package.unblock', type='PackageListChange', tag='test-tag',

      def test_prep_package_list_change_remove(self):

          protonmsg.prep_package_list_change('postPackageListChange',

                                             action='remove', tag={'name': 'test-tag'},

          self.assertMsg('package.remove', type='PackageListChange', tag='test-tag',

      def test_prep_task_state_change(self):

          info = {'id': 5678,