X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/400210f8c9d8b111a3efdaa76c8be579ea5666cb..dbaa58c1c806799435ca5741b3f61bc6b65b6569:/sdk/python/tests/fed-migrate/create_users.py diff --git a/sdk/python/tests/fed-migrate/create_users.py b/sdk/python/tests/fed-migrate/create_users.py index 08dec5cde3..0b5732293d 100644 --- a/sdk/python/tests/fed-migrate/create_users.py +++ b/sdk/python/tests/fed-migrate/create_users.py @@ -1,3 +1,7 @@ +# Copyright (C) The Arvados Authors. All rights reserved. +# +# SPDX-License-Identifier: Apache-2.0 + import arvados import json import sys @@ -11,13 +15,21 @@ apiC = arvados.api(host=j["arvados_api_hosts"][2], token=j["superuser_tokens"][2 def maketoken(newtok): return 'v2/' + newtok["uuid"] + '/' + newtok["api_token"] +def get_user_data(case_nr, is_active=True): + return { + "email": "case{}@test".format(case_nr), + "first_name": "Case{}".format(case_nr), + "last_name": "Testuser", + "is_active": is_active + } + # case 1 # user only exists on cluster A -apiA.users().create(body={"user": {"email": "case1@test"}}).execute() +apiA.users().create(body={"user": get_user_data(case_nr=1)}).execute() # case 2 # user exists on cluster A and has remotes on B and C -case2 = apiA.users().create(body={"user": {"email": "case2@test"}}).execute() +case2 = apiA.users().create(body={"user": get_user_data(case_nr=2)}).execute() newtok = apiA.api_client_authorizations().create(body={ "api_client_authorization": {'owner_uuid': case2["uuid"]}}).execute() arvados.api(host=j["arvados_api_hosts"][1], token=maketoken(newtok), insecure=True).users().current().execute() @@ -25,11 +37,11 @@ arvados.api(host=j["arvados_api_hosts"][2], token=maketoken(newtok), insecure=Tr # case 3 # user only exists on cluster B -case3 = apiB.users().create(body={"user": {"email": "case3@test"}}).execute() +case3 = apiB.users().create(body={"user": get_user_data(case_nr=3)}).execute() # case 4 # user only exists on cluster B and has remotes on A and C -case4 = apiB.users().create(body={"user": {"email": "case4@test"}}).execute() +case4 = apiB.users().create(body={"user": get_user_data(case_nr=4)}).execute() newtok = apiB.api_client_authorizations().create(body={ "api_client_authorization": {'owner_uuid': case4["uuid"]}}).execute() arvados.api(host=j["arvados_api_hosts"][0], token=maketoken(newtok), insecure=True).users().current().execute() @@ -38,18 +50,18 @@ arvados.api(host=j["arvados_api_hosts"][2], token=maketoken(newtok), insecure=Tr # case 5 # user exists on both cluster A and B -case5 = apiA.users().create(body={"user": {"email": "case5@test"}}).execute() -case5 = apiB.users().create(body={"user": {"email": "case5@test"}}).execute() +case5 = apiA.users().create(body={"user": get_user_data(case_nr=5)}).execute() +case5 = apiB.users().create(body={"user": get_user_data(case_nr=5)}).execute() # case 6 # user exists on both cluster A and B, with remotes on A, B and C -case6_A = apiA.users().create(body={"user": {"email": "case6@test"}}).execute() +case6_A = apiA.users().create(body={"user": get_user_data(case_nr=6)}).execute() newtokA = apiA.api_client_authorizations().create(body={ "api_client_authorization": {'owner_uuid': case6_A["uuid"]}}).execute() arvados.api(host=j["arvados_api_hosts"][1], token=maketoken(newtokA), insecure=True).users().current().execute() arvados.api(host=j["arvados_api_hosts"][2], token=maketoken(newtokA), insecure=True).users().current().execute() -case6_B = apiB.users().create(body={"user": {"email": "case6@test"}}).execute() +case6_B = apiB.users().create(body={"user": get_user_data(case_nr=6)}).execute() newtokB = apiB.api_client_authorizations().create(body={ "api_client_authorization": {'owner_uuid': case6_B["uuid"]}}).execute() arvados.api(host=j["arvados_api_hosts"][0], token=maketoken(newtokB), insecure=True).users().current().execute() @@ -57,13 +69,13 @@ arvados.api(host=j["arvados_api_hosts"][2], token=maketoken(newtokB), insecure=T # case 7 # user exists on both cluster B and A, with remotes on A, B and C -case7_B = apiB.users().create(body={"user": {"email": "case7@test"}}).execute() +case7_B = apiB.users().create(body={"user": get_user_data(case_nr=7)}).execute() newtokB = apiB.api_client_authorizations().create(body={ "api_client_authorization": {'owner_uuid': case7_B["uuid"]}}).execute() arvados.api(host=j["arvados_api_hosts"][0], token=maketoken(newtokB), insecure=True).users().current().execute() arvados.api(host=j["arvados_api_hosts"][2], token=maketoken(newtokB), insecure=True).users().current().execute() -case7_A = apiA.users().create(body={"user": {"email": "case7@test"}}).execute() +case7_A = apiA.users().create(body={"user": get_user_data(case_nr=7)}).execute() newtokA = apiA.api_client_authorizations().create(body={ "api_client_authorization": {'owner_uuid': case7_A["uuid"]}}).execute() arvados.api(host=j["arvados_api_hosts"][1], token=maketoken(newtokA), insecure=True).users().current().execute() @@ -71,14 +83,18 @@ arvados.api(host=j["arvados_api_hosts"][2], token=maketoken(newtokA), insecure=T # case 8 # user exists on both cluster B and C, with remotes on A, B and C -case8_B = apiB.users().create(body={"user": {"email": "case8@test"}}).execute() +case8_B = apiB.users().create(body={"user": get_user_data(case_nr=8)}).execute() newtokB = apiB.api_client_authorizations().create(body={ "api_client_authorization": {'owner_uuid': case8_B["uuid"]}}).execute() arvados.api(host=j["arvados_api_hosts"][0], token=maketoken(newtokB), insecure=True).users().current().execute() arvados.api(host=j["arvados_api_hosts"][2], token=maketoken(newtokB), insecure=True).users().current().execute() -case8_C = apiC.users().create(body={"user": {"email": "case8@test"}}).execute() +case8_C = apiC.users().create(body={"user": get_user_data(case_nr=8)}).execute() newtokC = apiC.api_client_authorizations().create(body={ "api_client_authorization": {'owner_uuid': case8_C["uuid"]}}).execute() arvados.api(host=j["arvados_api_hosts"][0], token=maketoken(newtokC), insecure=True).users().current().execute() arvados.api(host=j["arvados_api_hosts"][1], token=maketoken(newtokC), insecure=True).users().current().execute() + +# case 9 +# user only exists on cluster B, but is inactive +case9 = apiB.users().create(body={"user": get_user_data(case_nr=9, is_active=False)}).execute()