|
1 | 1 | from unittest import IsolatedAsyncioTestCase |
2 | 2 |
|
3 | | -from ....storage.base import StorageNotFoundError |
4 | 3 | from ....utils.testing import create_test_profile |
5 | 4 | from .. import issuer_cred_rev_record as test_module |
6 | 5 | from ..issuer_cred_rev_record import IssuerCredRevRecord |
@@ -84,13 +83,30 @@ async def test_rec_ops(self): |
84 | 83 | ) |
85 | 84 | ) |
86 | 85 |
|
| 86 | + await recs[1].set_state( # Save extra record |
| 87 | + session, |
| 88 | + IssuerCredRevRecord.STATE_REVOKED, |
| 89 | + ) |
| 90 | + # Fetch cred rev id as string |
| 91 | + assert await IssuerCredRevRecord.retrieve_by_ids( |
| 92 | + session, rev_reg_id=REV_REG_ID, cred_rev_id="1" |
| 93 | + ) == [recs[0]] |
| 94 | + |
| 95 | + # Fetch cred rev id as list |
| 96 | + assert await IssuerCredRevRecord.retrieve_by_ids( |
| 97 | + session, rev_reg_id=REV_REG_ID, cred_rev_id=["2"] |
| 98 | + ) == [recs[1]] |
| 99 | + |
| 100 | + # Fetch both |
87 | 101 | assert ( |
88 | 102 | await IssuerCredRevRecord.retrieve_by_ids( |
89 | | - session, rev_reg_id=REV_REG_ID, cred_rev_id="1" |
| 103 | + session, rev_reg_id=REV_REG_ID, cred_rev_id=["1", "2"] |
90 | 104 | ) |
91 | | - == recs[0] |
92 | | - ) |
93 | | - with self.assertRaises(StorageNotFoundError): |
| 105 | + ) == recs |
| 106 | + |
| 107 | + # Fetch cred rev id that doesn't exist |
| 108 | + assert ( |
94 | 109 | await IssuerCredRevRecord.retrieve_by_ids( |
95 | | - session, rev_reg_id=REV_REG_ID, cred_rev_id="2" |
| 110 | + session, rev_reg_id=REV_REG_ID, cred_rev_id=["3"] |
96 | 111 | ) |
| 112 | + ) == [] |
0 commit comments