882 req.cnx.commit() |
882 req.cnx.commit() |
883 with self.temporary_permissions( |
883 with self.temporary_permissions( |
884 (self.schema['tags'].rdefs['Tag', 'CWUser'], |
884 (self.schema['tags'].rdefs['Tag', 'CWUser'], |
885 {'delete': (RRQLExpression('S owned_by U'), )}, )): |
885 {'delete': (RRQLExpression('S owned_by U'), )}, )): |
886 with self.admin_access.web_request(rql='CWUser P WHERE P login "John"', |
886 with self.admin_access.web_request(rql='CWUser P WHERE P login "John"', |
887 pageid='123', fname='view') as req: |
887 pageid='123', fname='view', |
|
888 session=req.session) as req: |
888 ctrl = self.ctrl(req) |
889 ctrl = self.ctrl(req) |
889 rset = self.john.as_rset() |
890 rset = self.john.as_rset() |
890 rset.req = req |
891 rset.req = req |
891 source = ctrl.publish() |
892 source = ctrl.publish() |
892 # maydel jscall |
893 # maydel jscall |
896 with self.remote_calling('add_pending_inserts', [['12', 'tags', '13']]) as (_, req): |
897 with self.remote_calling('add_pending_inserts', [['12', 'tags', '13']]) as (_, req): |
897 deletes = get_pending_deletes(req) |
898 deletes = get_pending_deletes(req) |
898 self.assertEqual(deletes, []) |
899 self.assertEqual(deletes, []) |
899 inserts = get_pending_inserts(req) |
900 inserts = get_pending_inserts(req) |
900 self.assertEqual(inserts, ['12:tags:13']) |
901 self.assertEqual(inserts, ['12:tags:13']) |
901 with self.remote_calling('add_pending_inserts', [['12', 'tags', '14']]) as (_, req): |
902 with self.remote_calling('add_pending_inserts', [['12', 'tags', '14']], |
|
903 session=req.session) as (_, req): |
902 deletes = get_pending_deletes(req) |
904 deletes = get_pending_deletes(req) |
903 self.assertEqual(deletes, []) |
905 self.assertEqual(deletes, []) |
904 inserts = get_pending_inserts(req) |
906 inserts = get_pending_inserts(req) |
905 self.assertCountEqual(inserts, ['12:tags:13', '12:tags:14']) |
907 self.assertCountEqual(inserts, ['12:tags:13', '12:tags:14']) |
906 inserts = get_pending_inserts(req, 12) |
908 inserts = get_pending_inserts(req, 12) |
915 with self.remote_calling('add_pending_delete', ['12', 'tags', '13']) as (_, req): |
917 with self.remote_calling('add_pending_delete', ['12', 'tags', '13']) as (_, req): |
916 inserts = get_pending_inserts(req) |
918 inserts = get_pending_inserts(req) |
917 self.assertEqual(inserts, []) |
919 self.assertEqual(inserts, []) |
918 deletes = get_pending_deletes(req) |
920 deletes = get_pending_deletes(req) |
919 self.assertEqual(deletes, ['12:tags:13']) |
921 self.assertEqual(deletes, ['12:tags:13']) |
920 with self.remote_calling('add_pending_delete', ['12', 'tags', '14']) as (_, req): |
922 with self.remote_calling('add_pending_delete', ['12', 'tags', '14'], |
|
923 session=req.session) as (_, req): |
921 inserts = get_pending_inserts(req) |
924 inserts = get_pending_inserts(req) |
922 self.assertEqual(inserts, []) |
925 self.assertEqual(inserts, []) |
923 deletes = get_pending_deletes(req) |
926 deletes = get_pending_deletes(req) |
924 self.assertCountEqual(deletes, ['12:tags:13', '12:tags:14']) |
927 self.assertCountEqual(deletes, ['12:tags:13', '12:tags:14']) |
925 deletes = get_pending_deletes(req, 12) |
928 deletes = get_pending_deletes(req, 12) |
929 deletes = get_pending_deletes(req, 14) |
932 deletes = get_pending_deletes(req, 14) |
930 self.assertEqual(deletes, ['12:tags:14']) |
933 self.assertEqual(deletes, ['12:tags:14']) |
931 req.remove_pending_operations() |
934 req.remove_pending_operations() |
932 |
935 |
933 def test_remove_pending_operations(self): |
936 def test_remove_pending_operations(self): |
934 with self.remote_calling('add_pending_delete', ['12', 'tags', '13']): |
937 with self.remote_calling('add_pending_delete', ['12', 'tags', '13']) as (_, req): |
935 pass |
938 pass |
936 with self.remote_calling('add_pending_inserts', [['12', 'tags', '14']]) as (_, req): |
939 with self.remote_calling('add_pending_inserts', [['12', 'tags', '14']], |
|
940 session=req.session) as (_, req): |
937 inserts = get_pending_inserts(req) |
941 inserts = get_pending_inserts(req) |
938 self.assertEqual(inserts, ['12:tags:14']) |
942 self.assertEqual(inserts, ['12:tags:14']) |
939 deletes = get_pending_deletes(req) |
943 deletes = get_pending_deletes(req) |
940 self.assertEqual(deletes, ['12:tags:13']) |
944 self.assertEqual(deletes, ['12:tags:13']) |
941 req.remove_pending_operations() |
945 req.remove_pending_operations() |