server/test/unittest_datafeed.py
changeset 9469 032825bbacab
parent 9456 a79e88aad555
child 9798 1c105cf42904
equal deleted inserted replaced
9468:39b7a91a3f4c 9469:032825bbacab
     1 # copyright 2011-2012 LOGILAB S.A. (Paris, FRANCE), all rights reserved.
     1 # copyright 2011-2013 LOGILAB S.A. (Paris, FRANCE), all rights reserved.
     2 # contact http://www.logilab.fr/ -- mailto:contact@logilab.fr
     2 # contact http://www.logilab.fr/ -- mailto:contact@logilab.fr
     3 #
     3 #
     4 # This file is part of CubicWeb.
     4 # This file is part of CubicWeb.
     5 #
     5 #
     6 # CubicWeb is free software: you can redistribute it and/or modify it under the
     6 # CubicWeb is free software: you can redistribute it and/or modify it under the
    68                               'extid': 'http://www.cubicweb.org/'}
    68                               'extid': 'http://www.cubicweb.org/'}
    69                              )
    69                              )
    70             self.assertEqual(entity.absolute_url(), 'http://www.cubicweb.org/')
    70             self.assertEqual(entity.absolute_url(), 'http://www.cubicweb.org/')
    71             # test repo cache keys
    71             # test repo cache keys
    72             self.assertEqual(self.repo._type_source_cache[entity.eid],
    72             self.assertEqual(self.repo._type_source_cache[entity.eid],
    73                              ('Card', 'system', 'http://www.cubicweb.org/', 'myfeed'))
    73                              ('Card', 'http://www.cubicweb.org/', 'myfeed'))
    74             self.assertEqual(self.repo._extid_cache[('http://www.cubicweb.org/', 'system')],
    74             self.assertEqual(self.repo._extid_cache['http://www.cubicweb.org/'],
    75                              entity.eid)
    75                              entity.eid)
    76             # test repull
    76             # test repull
    77             session.set_cnxset()
    77             session.set_cnxset()
    78             stats = dfsource.pull_data(session, force=True)
    78             stats = dfsource.pull_data(session, force=True)
    79             self.assertEqual(stats['created'], set())
    79             self.assertEqual(stats['created'], set())
    84             session.set_cnxset()
    84             session.set_cnxset()
    85             stats = dfsource.pull_data(session, force=True)
    85             stats = dfsource.pull_data(session, force=True)
    86             self.assertEqual(stats['created'], set())
    86             self.assertEqual(stats['created'], set())
    87             self.assertEqual(stats['updated'], set((entity.eid,)))
    87             self.assertEqual(stats['updated'], set((entity.eid,)))
    88             self.assertEqual(self.repo._type_source_cache[entity.eid],
    88             self.assertEqual(self.repo._type_source_cache[entity.eid],
    89                              ('Card', 'system', 'http://www.cubicweb.org/', 'myfeed'))
    89                              ('Card', 'http://www.cubicweb.org/', 'myfeed'))
    90             self.assertEqual(self.repo._extid_cache[('http://www.cubicweb.org/', 'system')],
    90             self.assertEqual(self.repo._extid_cache['http://www.cubicweb.org/'],
    91                              entity.eid)
    91                              entity.eid)
    92 
    92 
    93         self.assertEqual(dfsource.source_cwuris(self.session),
    93         self.assertEqual(dfsource.source_cwuris(self.session),
    94                          {'http://www.cubicweb.org/': (entity.eid, 'Card')}
    94                          {'http://www.cubicweb.org/': (entity.eid, 'Card')}
    95                          )
    95                          )
   107                          {'type': 'Card',
   107                          {'type': 'Card',
   108                           'source': {'uri': 'myrenamedfeed', 'type': 'datafeed', 'use-cwuri-as-url': True},
   108                           'source': {'uri': 'myrenamedfeed', 'type': 'datafeed', 'use-cwuri-as-url': True},
   109                           'extid': 'http://www.cubicweb.org/'}
   109                           'extid': 'http://www.cubicweb.org/'}
   110                          )
   110                          )
   111         self.assertEqual(self.repo._type_source_cache[entity.eid],
   111         self.assertEqual(self.repo._type_source_cache[entity.eid],
   112                          ('Card', 'system', 'http://www.cubicweb.org/', 'myrenamedfeed'))
   112                          ('Card', 'http://www.cubicweb.org/', 'myrenamedfeed'))
   113         self.assertEqual(self.repo._extid_cache[('http://www.cubicweb.org/', 'system')],
   113         self.assertEqual(self.repo._extid_cache['http://www.cubicweb.org/'],
   114                          entity.eid)
   114                          entity.eid)
   115 
   115 
   116         # test_delete_source
   116         # test_delete_source
   117         req = self.request()
   117         req = self.request()
   118         req.execute('DELETE CWSource S WHERE S name "myrenamedfeed"')
   118         req.execute('DELETE CWSource S WHERE S name "myrenamedfeed"')