a lot of teamsnap sync work. not entirely happy with all of it
This commit is contained in:
@@ -1,156 +1,185 @@
|
||||
import os
|
||||
import sys
|
||||
|
||||
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "benchcoach.settings")
|
||||
os.environ["DJANGO_SETTINGS_MODULE"] = "benchcoach.settings"
|
||||
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "benchcoachproject.settings")
|
||||
os.environ["DJANGO_SETTINGS_MODULE"] = "benchcoachproject.settings"
|
||||
import django
|
||||
django.setup()
|
||||
|
||||
from teamsnap.teamsnap.api import TeamSnap
|
||||
import teamsnap.teamsnap.api
|
||||
from teamsnap.models import User, Member, Team, Event, Location, Availability, Opponent
|
||||
from teamsnap.models import User, Member, Team, Event, Location, Availability, Opponent, TeamsnapBaseModel
|
||||
from typing import List
|
||||
from benchcoach.models import Profile as BenchcoachUser
|
||||
from teams.models import Team as BenchcoachTeam
|
||||
from events.models import Event as BenchcoachEvent
|
||||
from benchcoachproject.models import Profile as BenchcoachUser
|
||||
import benchcoach.models
|
||||
from django.db import models
|
||||
import pytz
|
||||
|
||||
def update_object_from_teamsnap(
|
||||
TeamsnapApiObject: teamsnap.teamsnap.api.ApiObject,
|
||||
TeamsnapDbModelClass: teamsnap.models.TeamsnapBaseModel,
|
||||
TeamsnapClient: teamsnap.teamsnap.api.TeamSnap,
|
||||
teamsnap_search_kwargs: dict,
|
||||
fetching_keys: List[tuple] = ['id'],
|
||||
default_keys: List[tuple] = ['name']
|
||||
):
|
||||
def update_teamsnap_object(d, teamsnap_object: TeamsnapBaseModel, benchcoach_model: models.Model ,create_benchcoach_object: bool = True, create_related: bool = False):
|
||||
''' Function to update from a teamsnap object to Benchcoach object. This method is a simple method when there are no related objects
|
||||
|
||||
"""
|
||||
Import or Update database objects from TeamSnap API
|
||||
|
||||
additional_fetching_keys (key,) or (api_key, db_field_name) or (api_key, db_field_name, callable)
|
||||
Additional kwargs used to fetch an object from the database. ('id', 'teamsnap_id') are already included
|
||||
Callable will be run with the retrieved value as an argument. Example uses for this callable are to sanitize the value
|
||||
such as for a date, or to retrieve another database object
|
||||
|
||||
additional_default_keys
|
||||
Additional Keys used to update the object (key,) or (api_key, db_field_name) or (api_key, db_field_name, callable)
|
||||
('name',) is already included
|
||||
Callable will be run with the retrieved value as an argument. Example uses for this callable are to sanitize the value
|
||||
such as for a date, or to retrieve another database object
|
||||
|
||||
:rtype: object
|
||||
"""
|
||||
api_response = TeamsnapApiObject.search(client=TeamsnapClient, **teamsnap_search_kwargs)
|
||||
|
||||
# This routine allows, for convenience, simplers tuples in which the additional detail is not needed
|
||||
# for example [('key', 'key', None)] can be passed as ['key'] if the TeamsnapApi key is the same as the TeamsnapDb field/key
|
||||
# and doesn't need to be sanitized
|
||||
for d in [fetching_keys, fetching_keys, default_keys]:
|
||||
for i, key in enumerate(d):
|
||||
if isinstance(key, tuple):
|
||||
if len(key) == 1:
|
||||
d[i] = (key[0], key[0], None)
|
||||
if len(key) == 2:
|
||||
d[i] = (key[0], key[1], None)
|
||||
elif isinstance(key, str):
|
||||
d[i] = (key, key, None)
|
||||
:param d: The information to update.
|
||||
:param teamsnap_object: The teamsnap object from which to update.
|
||||
:param create_benchcoach_object: If true, will create the benchcoach object if it doesn't exist
|
||||
:param create_related: This is here for decoration only. It doesn't do anything.
|
||||
:return: a list of tuples in the form (obj, did_create) for created or modified objects.
|
||||
'''
|
||||
|
||||
r = []
|
||||
for data in [items.data for items in api_response]:
|
||||
kwargs, defaults = {}, {}
|
||||
for api_key, db_field_name, callable_function in fetching_keys:
|
||||
if api_key in data.keys():
|
||||
kwargs[db_field_name] = callable_function(data[api_key]) if callable_function else data[api_key]
|
||||
for api_key, db_field_name, callable_function in default_keys:
|
||||
if api_key in data.keys():
|
||||
defaults[db_field_name] = callable_function(data[api_key]) if callable_function else data[api_key]
|
||||
defaults ={k:v for k,v in defaults.items() if v is not None}
|
||||
obj, created = TeamsnapDbModelClass.objects.update_or_create(**kwargs, defaults=defaults)
|
||||
r.append((obj,created))
|
||||
|
||||
if teamsnap_object.benchcoach_object:
|
||||
#TODO I'm not sure this does anything. need to make sure.
|
||||
benchcoach_object = benchcoach_model.objects.filter(id=teamsnap_object.benchcoach_object.id).first()
|
||||
created = False
|
||||
r.append((benchcoach_object, created))
|
||||
elif not teamsnap_object.benchcoach_object and create_benchcoach_object:
|
||||
benchcoach_object = benchcoach_model(**d) # create new benchcoach object
|
||||
teamsnap_object.benchcoach_object = benchcoach_object
|
||||
benchcoach_object.save()
|
||||
teamsnap_object.save()
|
||||
created = True
|
||||
r.append((benchcoach_object, created))
|
||||
elif not teamsnap_object.benchcoach_object:
|
||||
raise benchcoach.models.Team.DoesNotExist
|
||||
|
||||
return r
|
||||
|
||||
def update_locations (client, **kwargs):
|
||||
return update_object_from_teamsnap(
|
||||
teamsnap.teamsnap.api.Location,
|
||||
Location,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys=[
|
||||
'name', 'created_at', 'updated_at',
|
||||
('team_id', 'managed_by_team_id')
|
||||
]
|
||||
)
|
||||
def update_event(event: Event, create_benchcoach_object: bool = True, create_related=False):
|
||||
benchcoach_model = benchcoach.models.Event
|
||||
|
||||
def update_teams (client, **kwargs):
|
||||
teams = update_object_from_teamsnap(
|
||||
teamsnap.teamsnap.api.Team,
|
||||
Team,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys=[
|
||||
'name', 'created_at', 'updated_at',
|
||||
('team_id', 'managed_by_team_id')
|
||||
]
|
||||
)
|
||||
opponents = update_object_from_teamsnap(
|
||||
teamsnap.teamsnap.api.Opponent,
|
||||
Opponent,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys= [
|
||||
'name', 'created_at', 'updated_at',
|
||||
('team_id', 'managed_by_team_id')
|
||||
]
|
||||
)
|
||||
return teams + opponents
|
||||
d = {
|
||||
'start': event.start_date,
|
||||
}
|
||||
|
||||
def update_members (client, **kwargs):
|
||||
return update_object_from_teamsnap(
|
||||
TeamsnapApiObject=teamsnap.teamsnap.api.Member,
|
||||
TeamsnapDbModelClass=Member,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys=['first_name','last_name','jersey_number','is_non_player', 'created_at', 'updated_at',
|
||||
('team_id', 'managed_by_team_id'),
|
||||
]
|
||||
)
|
||||
pass
|
||||
r = []
|
||||
|
||||
def update_availabilities(client, **kwargs):
|
||||
return update_object_from_teamsnap(
|
||||
TeamsnapApiObject=teamsnap.teamsnap.api.Availability,
|
||||
TeamsnapDbModelClass=Availability,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys=[ 'status_code',
|
||||
'member_id',
|
||||
'event_id',
|
||||
'created_at',
|
||||
'updated_at',
|
||||
('team_id', 'managed_by_team_id')
|
||||
]
|
||||
)
|
||||
if event.team:
|
||||
if event.team.benchcoach_object:
|
||||
if event.game_type == "Home":
|
||||
d['home_team'] = event.team.benchcoach_object
|
||||
elif event.game_type == "Away":
|
||||
d['away_team'] = event.team.benchcoach_object
|
||||
elif not event.team.benchcoach_object and create_related:
|
||||
# create team object
|
||||
# update_opponent
|
||||
# r.append
|
||||
pass
|
||||
elif not event.team.benchcoach_object:
|
||||
raise benchcoach.models.Team.DoesNotExist
|
||||
|
||||
def update_events(client, **kwargs):
|
||||
return update_object_from_teamsnap(
|
||||
TeamsnapApiObject=teamsnap.teamsnap.api.Event,
|
||||
TeamsnapDbModelClass=Event,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys=['formatted_title','label','points_for_opponent','points_for_team','is_game','opponent_id','location_id',
|
||||
'start_date', 'created_at', 'updated_at',
|
||||
('team_id', 'managed_by_team_id')
|
||||
]
|
||||
)
|
||||
if event.opponent:
|
||||
if event.opponent.benchcoach_object:
|
||||
if event.game_type == 'Home':
|
||||
d['away_team'] = event.opponent.benchcoach_object
|
||||
elif event.game_type == 'Away':
|
||||
d['home_team'] = event.opponent.benchcoach_object
|
||||
elif not event.opponent.benchcoach_object and create_related:
|
||||
# Create opponent object
|
||||
# update_opponent()
|
||||
# r.append
|
||||
pass
|
||||
elif not event.opponent.benchcoach_object:
|
||||
raise benchcoach.models.Team.DoesNotExist
|
||||
|
||||
if event.location:
|
||||
if event.location.benchcoach_object:
|
||||
if event.location:
|
||||
d['venue'] = event.location.benchcoach_object
|
||||
elif not event.location.benchcoach_object and create_related:
|
||||
# Need to account for if no loacation assigned to teamsnap object.
|
||||
# create team object
|
||||
# update_opponent
|
||||
# r.append
|
||||
pass
|
||||
elif not event.location.benchcoach_object:
|
||||
raise benchcoach.models.Venue.DoesNotExist
|
||||
|
||||
r += update_teamsnap_object(d, teamsnap_object=event, benchcoach_model=benchcoach_model, create_benchcoach_object=create_benchcoach_object)
|
||||
|
||||
return r
|
||||
|
||||
def update_opponent(opponent: Opponent, create_benchcoach_object: bool = True, create_related: bool = False):
|
||||
benchcoach_model = benchcoach.models.Team
|
||||
d = {
|
||||
'name': opponent.name,
|
||||
}
|
||||
|
||||
r = update_teamsnap_object(d, teamsnap_object=opponent, benchcoach_model=benchcoach_model, create_benchcoach_object= create_benchcoach_object, create_related = create_related)
|
||||
|
||||
return r
|
||||
|
||||
def update_team(teamsnap_object: Team, create_benchcoach_object: bool = True, create_related: bool = False):
|
||||
benchcoach_model = benchcoach.models.Team
|
||||
d = {
|
||||
'name': teamsnap_object.name,
|
||||
}
|
||||
|
||||
r = update_teamsnap_object(d, teamsnap_object=teamsnap_object, benchcoach_model=benchcoach_model, create_benchcoach_object=create_benchcoach_object,
|
||||
create_related=create_related)
|
||||
|
||||
return r
|
||||
|
||||
def update_location(teamsnap_object: Location, create_benchcoach_object: bool = True, create_related: bool = False):
|
||||
benchcoach_model = benchcoach.models.Venue
|
||||
d = {
|
||||
'name': teamsnap_object.name,
|
||||
}
|
||||
|
||||
r = update_teamsnap_object(d, teamsnap_object=teamsnap_object, benchcoach_model=benchcoach_model, create_benchcoach_object=create_benchcoach_object,
|
||||
create_related=create_related)
|
||||
|
||||
return r
|
||||
|
||||
def update_member(teamsnap_object: Member, create_benchcoach_object: bool = True, create_related: bool = False):
|
||||
benchcoach_model = benchcoach.models.Player
|
||||
d = {
|
||||
'first_name': teamsnap_object.first_name,
|
||||
'last_name': teamsnap_object.last_name,
|
||||
'jersey_number': teamsnap_object.jersey_number,
|
||||
}
|
||||
|
||||
r = update_teamsnap_object(d, teamsnap_object=teamsnap_object, benchcoach_model=benchcoach_model, create_benchcoach_object=create_benchcoach_object,
|
||||
create_related=create_related)
|
||||
|
||||
return r
|
||||
|
||||
def update_availability(availability: Availability, create_benchcoach_object: bool = True, create_related: bool = False):
|
||||
benchcoach_model = benchcoach.models.Availability
|
||||
translation = {
|
||||
Availability.YES: benchcoach.models.Availability.YES,
|
||||
Availability.NO: benchcoach.models.Availability.NO,
|
||||
Availability.MAYBE: benchcoach.models.Availability.MAYBE
|
||||
}
|
||||
|
||||
d = {
|
||||
'available': translation.get(availability.status_code, benchcoach.models.Availability.UNKNOWN),
|
||||
'player': availability.member.benchcoach_object,
|
||||
'event': availability.event.benchcoach_object
|
||||
}
|
||||
|
||||
r = []
|
||||
|
||||
if availability.member.benchcoach_object:
|
||||
d['player'] = availability.member.benchcoach_object
|
||||
elif not availability.member.benchcoach_object and create_related:
|
||||
r += update_member(availability.member, create_benchcoach_object = True)
|
||||
d['player'] = availability.member.benchcoach_object
|
||||
elif not availability.member.benchcoach_object and not create_related:
|
||||
raise benchcoach.models.Availability.DoesNotExist
|
||||
|
||||
if availability.event.benchcoach_object:
|
||||
d['event'] = availability.event.benchcoach_object
|
||||
elif not availability.event.benchcoach_object and create_related:
|
||||
r += update_event(availability.member, create_benchcoach_object = True)
|
||||
d['event'] = availability.event.benchcoach_object
|
||||
elif not availability.event.benchcoach_object and not create_related:
|
||||
raise benchcoach.models.Event.DoesNotExist
|
||||
|
||||
r += update_teamsnap_object(d, teamsnap_object=availability, benchcoach_model=benchcoach_model, create_benchcoach_object=create_benchcoach_object,
|
||||
create_related=create_related)
|
||||
|
||||
return r
|
||||
|
||||
def update_users(client, **kwargs):
|
||||
return update_object_from_teamsnap(
|
||||
TeamsnapApiObject=teamsnap.teamsnap.api.User,
|
||||
TeamsnapDbModelClass=User,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys=['first_name', 'last_name', 'email', 'created_at', 'updated_at',]
|
||||
)
|
||||
|
||||
def import_teamsnap():
|
||||
user = BenchcoachUser.objects.get(id=1)
|
||||
@@ -158,33 +187,25 @@ def import_teamsnap():
|
||||
USER_ID = user.teamsnap_user.id
|
||||
TEAM_ID = user.teamsnapsettings.managed_team.id
|
||||
CLIENT = TeamSnap(token=TOKEN)
|
||||
update_users(CLIENT, id=USER_ID)
|
||||
|
||||
l = []
|
||||
for team in Opponent.objects.filter(managed_by_team_id=TEAM_ID):
|
||||
d = {
|
||||
'name': team.name,
|
||||
}
|
||||
obj, created = BenchcoachTeam.objects.update_or_create(opponent=team, defaults=d)
|
||||
team.benchcoach_object = obj
|
||||
team.save()
|
||||
l.append((obj,created))
|
||||
for team in Opponent.objects.filter(team_id=TEAM_ID):
|
||||
l += update_opponent(team, create_benchcoach_object=True, create_related=True)
|
||||
|
||||
for team in Team.objects.filter(id=TEAM_ID):
|
||||
d = {
|
||||
'name': team.name,
|
||||
}
|
||||
obj_id = BenchcoachTeam.objects.filter(id=team.benchcoach_object.id).update(**d)
|
||||
team.benchcoach_object = BenchcoachTeam.objects.get(id=obj_id)
|
||||
team.save()
|
||||
l.append((obj,created))
|
||||
l += update_team(team, create_benchcoach_object=True, create_related=True)
|
||||
|
||||
for event in Event.objects.filter(managed_by_team_id=TEAM_ID):
|
||||
d = {
|
||||
'start':event.start_date,
|
||||
}
|
||||
obj, created = BenchcoachEvent.objects.update_or_create(teamsnap_event=event, defaults=d)
|
||||
# event.benchcoach_object = obj
|
||||
for location in Location.objects.filter(team_id=TEAM_ID):
|
||||
l += update_location(location, create_benchcoach_object=True, create_related=True)
|
||||
|
||||
for member in Member.objects.filter(team_id=TEAM_ID, is_non_player=False):
|
||||
l += update_member(member, create_benchcoach_object= True, create_related=True)
|
||||
|
||||
for event in Event.objects.filter(team_id=TEAM_ID):
|
||||
l += update_event(event, create_benchcoach_object=True, create_related=True)
|
||||
|
||||
for availability in Availability.objects.filter(team_id=TEAM_ID):
|
||||
l += update_availability(availability, create_benchcoach_object=True, create_related=True)
|
||||
|
||||
pass
|
||||
# l += update_teams(CLIENT, team_id=TEAM_ID)
|
||||
|
||||
198
teamsnap/utils/import_teamsnap_2.py
Normal file
198
teamsnap/utils/import_teamsnap_2.py
Normal file
@@ -0,0 +1,198 @@
|
||||
import os
|
||||
import sys
|
||||
|
||||
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "benchcoachproject.settings")
|
||||
os.environ["DJANGO_SETTINGS_MODULE"] = "benchcoachproject.settings"
|
||||
import django
|
||||
django.setup()
|
||||
|
||||
from teamsnap.teamsnap.api import TeamSnap
|
||||
import teamsnap.teamsnap.api
|
||||
from teamsnap.models import User, Member, Team, Event, Location, Availability, Opponent, TeamsnapBaseModel
|
||||
from typing import List, Type, Tuple
|
||||
from benchcoachproject.models import Profile as BenchcoachUser
|
||||
import benchcoach.models
|
||||
from django.db import models
|
||||
import pytz
|
||||
|
||||
def update_teamsnapbasemodel_from_teamsnap(
|
||||
TeamsnapModel: Type[TeamsnapBaseModel],
|
||||
teamsnap_client: teamsnap.teamsnap.api.TeamSnap,
|
||||
fields: List[str]= ['created_at', 'updated_at'],
|
||||
additional_fields: List[str] = [],
|
||||
related_fields: List[Tuple[str, Type[TeamsnapBaseModel]]] = [],
|
||||
create = True,
|
||||
create_related = True,
|
||||
**teamsnap_search_kwargs
|
||||
):
|
||||
api_response_objects = TeamsnapModel.ApiObject.search(
|
||||
client=teamsnap_client, **teamsnap_search_kwargs
|
||||
)
|
||||
|
||||
r = []
|
||||
|
||||
for response_object in api_response_objects:
|
||||
d = {k:response_object.data[k] for k in fields}
|
||||
d.update({k:response_object.data[k] for k in additional_fields})
|
||||
|
||||
for related_field_name, RelatedTeamSnapModel in related_fields:
|
||||
related_field_name = f"{related_field_name}_id"
|
||||
filter_criteria = {related_field_name:response_object.data[related_field_name]}
|
||||
if related_field_name == "team_id" and RelatedTeamSnapModel.__name__ == "Team":
|
||||
filter_criteria = {'id':response_object.data[related_field_name]}
|
||||
related_teamsnap_object = RelatedTeamSnapModel.objects.filter(**filter_criteria).first()
|
||||
if related_teamsnap_object:
|
||||
d[related_field_name] = related_teamsnap_object
|
||||
elif not related_teamsnap_object and create_related:
|
||||
related_teamsnap_object = RelatedTeamSnapModel(**{related_field_name:response_object.data[related_field_name]})
|
||||
related_teamsnap_object.save()
|
||||
elif not related_teamsnap_object and not create_related:
|
||||
raise RelatedTeamSnapModel.DoesNotExist
|
||||
|
||||
teamsnap_object = TeamsnapModel.objects.filter(id=response_object.data['id'])
|
||||
if teamsnap_object:
|
||||
teamsnap_object.update(**d)
|
||||
created = False
|
||||
r.append((teamsnap_object.first(), created))
|
||||
elif not teamsnap_object and create:
|
||||
new_teamsnap_object = TeamsnapModel(**d) # create new benchcoach object
|
||||
new_teamsnap_object.save()
|
||||
created = True
|
||||
r.append((new_teamsnap_object, created))
|
||||
elif not teamsnap_object and not create:
|
||||
raise TeamsnapModel.DoesNotExist
|
||||
|
||||
return r
|
||||
|
||||
def update_events(
|
||||
teamsnap_client: teamsnap.teamsnap.api.TeamSnap,
|
||||
create: bool = True,
|
||||
create_related: bool = False,
|
||||
**teamsnap_search_kwargs
|
||||
):
|
||||
r = update_teamsnapbasemodel_from_teamsnap(
|
||||
TeamsnapModel= Event,
|
||||
teamsnap_client= teamsnap_client,
|
||||
additional_fields=['label', 'start_date', 'formatted_title', 'points_for_opponent', 'points_for_team', 'is_game', 'game_type'],
|
||||
related_fields=[('location', Location), ('opponent', Opponent), ('team', Team)],
|
||||
create=create,
|
||||
create_related=create_related,
|
||||
**teamsnap_search_kwargs
|
||||
)
|
||||
|
||||
return r
|
||||
|
||||
def update_opponents(
|
||||
teamsnap_client: teamsnap.teamsnap.api.TeamSnap,
|
||||
create: bool = True,
|
||||
create_related: bool = False,
|
||||
**teamsnap_search_kwargs
|
||||
):
|
||||
r = update_teamsnapbasemodel_from_teamsnap(
|
||||
TeamsnapModel= Opponent,
|
||||
teamsnap_client= teamsnap_client,
|
||||
additional_fields=['name'],
|
||||
related_fields=[('team', Team)],
|
||||
create=create,
|
||||
create_related=create_related,
|
||||
**teamsnap_search_kwargs
|
||||
)
|
||||
|
||||
return r
|
||||
|
||||
def update_teams(
|
||||
teamsnap_client: teamsnap.teamsnap.api.TeamSnap,
|
||||
create: bool = True,
|
||||
create_related: bool = False,
|
||||
**teamsnap_search_kwargs
|
||||
):
|
||||
r = update_teamsnapbasemodel_from_teamsnap(
|
||||
TeamsnapModel=Team,
|
||||
teamsnap_client=teamsnap_client,
|
||||
additional_fields=['name'],
|
||||
create=create,
|
||||
create_related=create_related,
|
||||
**teamsnap_search_kwargs
|
||||
)
|
||||
|
||||
|
||||
def update_locations(
|
||||
teamsnap_client: teamsnap.teamsnap.api.TeamSnap,
|
||||
create: bool = True,
|
||||
create_related: bool = False,
|
||||
**teamsnap_search_kwargs
|
||||
):
|
||||
r = update_teamsnapbasemodel_from_teamsnap(
|
||||
TeamsnapModel=Location,
|
||||
teamsnap_client=teamsnap_client,
|
||||
additional_fields=['name'],
|
||||
related_fields=[('team', Team)],
|
||||
create=create,
|
||||
create_related=create_related,
|
||||
**teamsnap_search_kwargs
|
||||
)
|
||||
|
||||
def update_availabilities(teamsnap_client: teamsnap.teamsnap.api.TeamSnap,
|
||||
create: bool = True,
|
||||
create_related: bool = False,
|
||||
**teamsnap_search_kwargs
|
||||
):
|
||||
r = update_teamsnapbasemodel_from_teamsnap(
|
||||
TeamsnapModel= Availability,
|
||||
teamsnap_client= teamsnap_client,
|
||||
related_fields=[('event', Event), ('member', Member), ('team', Team)],
|
||||
create=create,
|
||||
create_related=create_related,
|
||||
**teamsnap_search_kwargs
|
||||
)
|
||||
|
||||
def import_teamsnap():
|
||||
user = BenchcoachUser.objects.get(id=1)
|
||||
TOKEN = user.teamsnap_access_token
|
||||
USER_ID = user.teamsnap_user.id
|
||||
TEAM_ID = user.teamsnapsettings.managed_team.id
|
||||
CLIENT = TeamSnap(token=TOKEN)
|
||||
|
||||
l = []
|
||||
for team in Opponent.objects.filter(managed_by_team_id=TEAM_ID):
|
||||
l += update_opponent(team, create_benchcoach_object=True, create_related=True)
|
||||
|
||||
for team in Team.objects.filter(id=TEAM_ID):
|
||||
l += update_team(team, create_benchcoach_object=True, create_related=True)
|
||||
|
||||
for location in Location.objects.filter(managed_by_team_id=TEAM_ID):
|
||||
l += update_location(location, create_benchcoach_object=True, create_related=True)
|
||||
|
||||
for member in Member.objects.filter(managed_by_team_id=TEAM_ID, is_non_player=False):
|
||||
l += update_member(member, create_benchcoach_object= True, create_related=True)
|
||||
|
||||
for event in Event.objects.filter(managed_by_team_id=TEAM_ID):
|
||||
l += update_event(event, create_benchcoach_object=True, create_related=True)
|
||||
|
||||
for availability in Availability.objects.filter(managed_by_team_id=TEAM_ID):
|
||||
l += update_availability(availability, create_benchcoach_object=True, create_related=True)
|
||||
|
||||
pass
|
||||
# l += update_teams(CLIENT, team_id=TEAM_ID)
|
||||
# l += update_members(CLIENT, team_id=TEAM_ID)
|
||||
# l += update_locations(CLIENT, team_id=TEAM_ID)
|
||||
# l += update_events(CLIENT, team_id=TEAM_ID)
|
||||
# l += update_availabilities(CLIENT, team_id=TEAM_ID)
|
||||
|
||||
if __name__ == "__main__":
|
||||
|
||||
TOKEN = BenchcoachUser.objects.get(id=1).teamsnap_access_token
|
||||
USER_ID = BenchcoachUser.objects.get(id=1).teamsnap_user_id
|
||||
TEAM_ID = BenchcoachUser.objects.get(id=1).teamsnapsettings.managed_team_id
|
||||
CLIENT = TeamSnap(token=TOKEN)
|
||||
for Obj in [User]:
|
||||
a = Obj.ApiObject.search(CLIENT, id=USER_ID)
|
||||
for _a in a:
|
||||
obj, created = Obj.update_or_create_from_teamsnap_api(_a.data)
|
||||
|
||||
for Obj in [Event, Availability, Location, Member, Opponent, Team]:
|
||||
a = Obj.ApiObject.search(CLIENT, team_id=TEAM_ID)
|
||||
for _a in a:
|
||||
obj, created = Obj.update_or_create_from_teamsnap_api(_a.data)
|
||||
# update_opponents(CLIENT, team_id=TEAM_ID)
|
||||
# update_events(CLIENT, team_id=TEAM_ID)
|
||||
165
teamsnap/utils/teamsnap_object_utils.py
Normal file
165
teamsnap/utils/teamsnap_object_utils.py
Normal file
@@ -0,0 +1,165 @@
|
||||
import os
|
||||
import sys
|
||||
|
||||
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "benchcoachproject.settings")
|
||||
os.environ["DJANGO_SETTINGS_MODULE"] = "benchcoachproject.settings"
|
||||
import django
|
||||
django.setup()
|
||||
|
||||
from teamsnap.teamsnap.api import TeamSnap
|
||||
import teamsnap.teamsnap.api
|
||||
from teamsnap.models import User, Member, Team, Event, Location, Availability, Opponent, TeamsnapBaseModel
|
||||
from typing import List
|
||||
from benchcoachproject.models import Profile as BenchcoachUser
|
||||
|
||||
|
||||
def update_object_from_teamsnap(
|
||||
TeamsnapApiObject: teamsnap.teamsnap.api.ApiObject,
|
||||
TeamsnapDbModelClass: teamsnap.models.TeamsnapBaseModel,
|
||||
TeamsnapClient: teamsnap.teamsnap.api.TeamSnap,
|
||||
teamsnap_search_kwargs: dict,
|
||||
fetching_keys: List[tuple] = ['id'],
|
||||
default_keys: List[tuple] = ['name'],
|
||||
related_objects: List[tuple] = []
|
||||
):
|
||||
|
||||
"""
|
||||
Import or Update database objects from TeamSnap API. Currently this depends on being run in a particular order when the database is empty.
|
||||
|
||||
additional_fetching_keys (key,) or (api_key, db_field_name) or (api_key, db_field_name, callable)
|
||||
Additional kwargs used to fetch an object from the database. ('id', 'teamsnap_id') are already included
|
||||
Callable will be run with the retrieved value as an argument. Example uses for this callable are to sanitize the value
|
||||
such as for a date, or to retrieve another database object
|
||||
|
||||
additional_default_keys
|
||||
Additional Keys used to update the object (key,) or (api_key, db_field_name) or (api_key, db_field_name, callable)
|
||||
('name',) is already included
|
||||
Callable will be run with the retrieved value as an argument. Example uses for this callable are to sanitize the value
|
||||
such as for a date, or to retrieve another database object
|
||||
|
||||
:rtype: object
|
||||
"""
|
||||
api_response = TeamsnapApiObject.search(client=TeamsnapClient, **teamsnap_search_kwargs)
|
||||
|
||||
# This routine allows, for convenience, simplers tuples in which the additional detail is not needed
|
||||
# for example [('key', 'key', None)] can be passed as ['key'] if the TeamsnapApi key is the same as the TeamsnapDb field/key
|
||||
# and doesn't need to be sanitized
|
||||
for d in [fetching_keys, fetching_keys, default_keys]:
|
||||
for i, key in enumerate(d):
|
||||
if isinstance(key, tuple):
|
||||
if len(key) == 1:
|
||||
d[i] = (key[0], key[0], None)
|
||||
if len(key) == 2:
|
||||
d[i] = (key[0], key[1], None)
|
||||
elif isinstance(key, str):
|
||||
d[i] = (key, key, None)
|
||||
|
||||
r = []
|
||||
for related_object in related_objects:
|
||||
pass
|
||||
|
||||
for data in [items.data for items in api_response]:
|
||||
kwargs, defaults = {}, {}
|
||||
for api_key, db_field_name, callable_function in fetching_keys:
|
||||
if api_key in data.keys():
|
||||
kwargs[db_field_name] = callable_function(data[api_key]) if callable_function else data[api_key]
|
||||
for api_key, db_field_name, callable_function in default_keys:
|
||||
if api_key in data.keys():
|
||||
defaults[db_field_name] = callable_function(data[api_key]) if callable_function else data[api_key]
|
||||
defaults ={k:v for k,v in defaults.items() if v is not None}
|
||||
obj, created = TeamsnapDbModelClass.objects.update_or_create(**kwargs, defaults=defaults)
|
||||
r.append((obj,created))
|
||||
return r
|
||||
|
||||
def update_locations (client, **kwargs):
|
||||
return update_object_from_teamsnap(
|
||||
teamsnap.teamsnap.api.Location,
|
||||
Location,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys=[
|
||||
'name', 'created_at', 'updated_at',
|
||||
('team_id', 'managed_by_team_id')
|
||||
]
|
||||
)
|
||||
|
||||
def update_teams (client, **kwargs):
|
||||
teams = update_object_from_teamsnap(
|
||||
teamsnap.teamsnap.api.Team,
|
||||
Team,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys=[
|
||||
'name', 'created_at', 'updated_at'
|
||||
],
|
||||
related_objects = [
|
||||
('team_id', 'managed_by_team_id')
|
||||
]
|
||||
)
|
||||
opponents = update_object_from_teamsnap(
|
||||
teamsnap.teamsnap.api.Opponent,
|
||||
Opponent,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys= [
|
||||
'name', 'created_at', 'updated_at',
|
||||
('team_id', 'managed_by_team_id')
|
||||
]
|
||||
)
|
||||
return teams + opponents
|
||||
|
||||
def update_members (client, **kwargs):
|
||||
return update_object_from_teamsnap(
|
||||
TeamsnapApiObject=teamsnap.teamsnap.api.Member,
|
||||
TeamsnapDbModelClass=Member,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys=['first_name','last_name','jersey_number','is_non_player', 'created_at', 'updated_at',
|
||||
('team_id', 'managed_by_team_id'),
|
||||
]
|
||||
)
|
||||
pass
|
||||
|
||||
def update_availabilities(client, **kwargs):
|
||||
return update_object_from_teamsnap(
|
||||
TeamsnapApiObject=teamsnap.teamsnap.api.Availability,
|
||||
TeamsnapDbModelClass=Availability,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys=[ 'status_code',
|
||||
'member_id',
|
||||
'event_id',
|
||||
'created_at',
|
||||
'updated_at',
|
||||
('team_id', 'managed_by_team_id')
|
||||
]
|
||||
)
|
||||
|
||||
def update_events(client, **kwargs):
|
||||
return update_object_from_teamsnap(
|
||||
TeamsnapApiObject=teamsnap.teamsnap.api.Event,
|
||||
TeamsnapDbModelClass=Event,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys=['formatted_title','label','points_for_opponent','points_for_team','is_game','opponent_id','location_id',
|
||||
'start_date', 'created_at', 'updated_at', 'game_type',
|
||||
('team_id', 'managed_by_team_id')
|
||||
]
|
||||
)
|
||||
|
||||
def update_users(client, **kwargs):
|
||||
return update_object_from_teamsnap(
|
||||
TeamsnapApiObject=teamsnap.teamsnap.api.User,
|
||||
TeamsnapDbModelClass=User,
|
||||
TeamsnapClient=client,
|
||||
teamsnap_search_kwargs=kwargs,
|
||||
default_keys=['first_name', 'last_name', 'email', 'created_at', 'updated_at',]
|
||||
)
|
||||
|
||||
if __name__ == "__main__":
|
||||
TOKEN = BenchcoachUser.objects.get(id=1).teamsnap_access_token
|
||||
USER_ID = BenchcoachUser.objects.get(id=1).teamsnap_user_id
|
||||
TEAM_ID = BenchcoachUser.objects.get(id=1).teamsnapsettings.managed_team_id
|
||||
CLIENT = TeamSnap(token=TOKEN)
|
||||
# update_users(CLIENT, id=USER_ID)
|
||||
update_teams(CLIENT, team_id=TEAM_ID)
|
||||
Reference in New Issue
Block a user