-
Notifications
You must be signed in to change notification settings - Fork 5
/
deals.py
45 lines (35 loc) · 1.26 KB
/
deals.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
import time
from pygate_grpc.client import PowerGateClient
if __name__ == "__main__":
hostName = "127.0.0.1:5002"
# Create client
client = PowerGateClient(hostName)
# Create user
user = client.admin.users.create()
print("User created:")
print(user)
print("Applying storage config...")
stage_res = client.data.stage_bytes(
b"These are the contents of a test file", token=user.token
)
apply_res = client.config.apply(stage_res.cid, token=user.token)
# Check that cid is in the process of being stored by Powegate
check = client.data.cid_info(stage_res.cid, user.token)
print("Checking cid storage...")
print(check)
# Wait some time so that we can get some deals
time.sleep(10)
# Check information about the storage deal
storage_deals = client.deals.storage_deal_records(
include_pending=True, include_final=True, token=user.token
)
print("Storage deals: ")
for record in storage_deals:
print(record)
# Check information about the retrieval deals
retrieval_deals = client.deals.retrieval_deal_records(
include_pending=True, include_final=True, token=user.token
)
print("Retrieval deals: ")
for record in retrieval_deals:
print(record)