Skip to content

Commit 182b5e1

Browse files
Unit test for 'store_data_agreement_instance_metadata' function
Signed-off-by: George J Padayatti <[email protected]>
1 parent 23da3e8 commit 182b5e1

File tree

2 files changed

+51
-0
lines changed

2 files changed

+51
-0
lines changed

mydata_did/v1_0/tests/__init__.py

Whitespace-only changes.
Lines changed: 51 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,51 @@
1+
import uuid
2+
3+
from asynctest import TestCase as AsyncTestCase
4+
from asynctest import mock as async_mock
5+
6+
from aries_cloudagent.storage.base import BaseStorage
7+
from aries_cloudagent.storage.basic import BasicStorage
8+
from aries_cloudagent.wallet.base import BaseWallet
9+
from aries_cloudagent.wallet.basic import BasicWallet
10+
from aries_cloudagent.config.injection_context import InjectionContext
11+
12+
from ..manager import ADAManager
13+
14+
15+
class TestADAManager(AsyncTestCase):
16+
def setUp(self):
17+
self.storage = BasicStorage()
18+
self.wallet = BasicWallet()
19+
20+
self.context = InjectionContext(enforce_typing=False)
21+
self.context.injector.bind_instance(BaseStorage, self.storage)
22+
self.context.injector.bind_instance(BaseWallet, self.wallet)
23+
24+
self.manager = ADAManager(self.context)
25+
26+
async def test_store_data_agreement_instance_metadata(self):
27+
28+
data_agreement_id = str(uuid.uuid4())
29+
data_agreement_template_id = "c0c68a75-805b-4467-b425-ff968cd8d7eb"
30+
method_of_use = "data-source"
31+
data_exchange_record_id = str(uuid.uuid4())
32+
33+
await self.manager.store_data_agreement_instance_metadata(
34+
data_agreement_id=data_agreement_id,
35+
data_agreement_template_id=data_agreement_template_id,
36+
method_of_use=method_of_use,
37+
data_exchange_record_id=data_exchange_record_id,
38+
)
39+
40+
await self.manager.store_data_agreement_instance_metadata(
41+
data_agreement_id=data_agreement_id,
42+
data_agreement_template_id=data_agreement_template_id,
43+
method_of_use=method_of_use,
44+
data_exchange_record_id=data_exchange_record_id,
45+
)
46+
47+
storage_records = await self.manager.query_data_agreement_instance_metadata(
48+
tag_query={}
49+
)
50+
51+
assert len(storage_records) == 2

0 commit comments

Comments
 (0)