Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Accommodate Typed Relation Display name Fields #810

Open
wants to merge 3 commits into
base: main
Choose a base branch
from
Open

Accommodate Typed Relation Display name Fields #810

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
11be6f8
Typed Relation Display name Fields
rosiel Aug 8, 2024
be509ab
Black linter.
rosiel Aug 8, 2024
7a77296
More linting.
rosiel Aug 8, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
63 changes: 63 additions & 0 deletions workbench
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -318,6 +318,18 @@ def create():
config, field_definitions, node, row, custom_field
)

# Typed relation with display name fields.
elif (
field_definitions[custom_field]["field_type"]
== "typed_relation_display_name"
):
typed_relation_display_name_field = (
workbench_fields.TypedRelationDisplayNameField()
)
node = typed_relation_display_name_field.create(
config, field_definitions, node, row, custom_field
)

# Geolocation fields.
elif field_definitions[custom_field]["field_type"] == "geolocation":
geolocation_field = workbench_fields.GeolocationField()
Expand Down Expand Up @@ -800,6 +812,23 @@ def update():
node_field_values[custom_field],
)

# Typed relation display name fields (currently, only taxonomy term).
elif (
field_definitions[custom_field]["field_type"]
== "typed_relation_display_name"
):
typed_relation_display_name_field = (
workbench_fields.TypedRelationDisplayNameField()
)
node = typed_relation_display_name_field.update(
config,
field_definitions,
node,
row,
custom_field,
node_field_values[custom_field],
)

# Geolocation fields.
elif field_definitions[custom_field]["field_type"] == "geolocation":
geolocation_field = workbench_fields.GeolocationField()
Expand Down Expand Up @@ -1978,6 +2007,23 @@ def update_media() -> None:
media_field_values[custom_field],
)

# Typed relation display name fields (currently, only taxonomy term).
elif (
field_definitions[custom_field]["field_type"]
== "typed_relation_display_name"
):
typed_relation_display_name_field = (
workbench_fields.TypedRelationDisplayNameField()
)
patch_request_json = typed_relation_display_name_field.update(
config,
field_definitions,
patch_request_json,
row,
custom_field,
media_field_values[custom_field],
)

# Geolocation fields.
elif field_definitions[custom_field]["field_type"] == "geolocation":
geolocation_field = workbench_fields.GeolocationField()
Expand Down Expand Up @@ -3239,6 +3285,23 @@ def update_terms():
term_field_values[custom_field],
)

# Typed relation display name fields (currently, only taxonomy term).
elif (
field_definitions[custom_field]["field_type"]
== "typed_relation_display_name"
):
typed_relation_display_name_field = (
workbench_fields.TypedRelationDisplaynameField()
)
term = typed_relation_display_name_field.update(
config,
field_definitions,
term,
row,
custom_field,
term_field_values[custom_field],
)

# Geolocation fields.
elif field_definitions[custom_field]["field_type"] == "geolocation":
geolocation_field = workbench_fields.GeolocationField()
Expand Down
209 changes: 209 additions & 0 deletions workbench_fields.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1256,6 +1256,215 @@ def serialize(self, config, field_definitions, field_name, field_data):
return subvalues[0]


class TypedRelationDisplayNameField(TypedRelationField):
"""Functions for handling fields with 'typed_relation_display_name' Drupal field data type.
All functions return an "entity" dictionary that is passed to Requests' "json"
parameter.

Currently this field type only supports Typed Relation Taxonomies (not other
Typed Relation entity types).

Note: this class assumes that the entity has the field identified in 'field_name'.
Callers should pre-emptively confirm that. For an example, see code near the top
of workbench.update().
"""

def create(self, config, field_definitions, entity, row, field_name):
"""Parameters
----------
config : dict
The configuration settings defined by workbench_config.get_config().
field_definitions : dict
The field definitions object defined by get_field_definitions().
entity : dict
The dict that will be POSTed to Drupal as JSON.
row : OrderedDict.
The current CSV record.
field_name : string
The Drupal fieldname/CSV column header.
Returns
-------
dictionary
A dictionary representing the entity that is POSTed to Drupal as JSON.
"""
if not row[field_name]:
return entity

id_field = row.get(config.get("id_field", "not_applicable"), "not_applicable")
# Currently only supports Typed Relation Display Name with taxonomy entities.
if field_definitions[field_name]["target_type"] == "taxonomy_term":
target_type = "taxonomy_term"
field_vocabs = get_field_vocabularies(config, field_definitions, field_name)
field_values = []
subvalues = split_typed_relation_display_name_string(
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I tried to make this class as short as possible as it inherits from TypedRelationField. This Class could be much shorter if we made the "split into subvalues" function a parameter of the class. In the create() and update() functions, the ONLY difference is using my custom "split_typed_relation_display_name_string" function.

config, row[field_name], target_type
)
subvalues = self.dedupe_values(subvalues)
cardinality = int(field_definitions[field_name].get("cardinality", -1))
if -1 < cardinality < len(subvalues):
log_field_cardinality_violation(field_name, id_field, str(cardinality))
subvalues = subvalues[:cardinality]
for subvalue in subvalues:
subvalue["target_id"] = prepare_term_id(
config, field_vocabs, field_name, subvalue["target_id"]
)
field_values.append(subvalue)
entity[field_name] = field_values

return entity

def update(
self, config, field_definitions, entity, row, field_name, entity_field_values
):
"""Note: this method appends incoming CSV values to existing values, replaces existing field
values with incoming values, or deletes all values from fields, depending on whether
config['update_mode'] is 'append', 'replace', or 'delete'. It doesn not replace individual
values within fields.
"""
"""Parameters
----------
config : dict
The configuration settings defined by workbench_config.get_config().
field_definitions : dict
The field definitions object defined by get_field_definitions().
entity : dict
The dict that will be POSTed to Drupal as JSON.
row : OrderedDict.
The current CSV record.
field_name : string
The Drupal fieldname/CSV column header.
entity_field_values : list
List of dictionaries containing existing value(s) for field_name in the entity being updated.
Returns
-------
dictionary
A dictionary represeting the entity that is PATCHed to Drupal as JSON.
"""
if config["update_mode"] == "delete":
entity[field_name] = []
return entity

if not row[field_name]:
return entity

if field_name not in entity:
entity[field_name] = []

if config["task"] == "update_terms":
entity_id_field = "term_id"
if config["task"] == "update":
entity_id_field = "node_id"
if config["task"] == "update_media":
entity_id_field = "media_id"

# Currently only supports Typed Relation taxonomy entities.
if field_definitions[field_name]["target_type"] == "taxonomy_term":
target_type = "taxonomy_term"
field_vocabs = get_field_vocabularies(config, field_definitions, field_name)

cardinality = int(field_definitions[field_name].get("cardinality", -1))
if config["update_mode"] == "replace":
subvalues = split_typed_relation_display_name_string(
config, row[field_name], target_type
)
subvalues = self.dedupe_values(subvalues)
field_values = []
for subvalue in subvalues:
subvalue["target_id"] = prepare_term_id(
config, field_vocabs, field_name, subvalue["target_id"]
)
field_values.append(subvalue)
if -1 < cardinality < len(field_values):
field_values = field_values[:cardinality]
log_field_cardinality_violation(
field_name, row[entity_id_field], str(cardinality)
)
entity[field_name] = field_values
if config["update_mode"] == "append":
field_values = []
subvalues = split_typed_relation_display_name_string(
config, row[field_name], target_type
)
for subvalue in subvalues:
subvalue["target_id"] = prepare_term_id(
config, field_vocabs, field_name, subvalue["target_id"]
)
entity_field_values.append(subvalue)
entity_field_values = self.dedupe_values(entity_field_values)
if -1 < cardinality < len(entity_field_values):
entity[field_name] = entity_field_values[:cardinality]
log_field_cardinality_violation(
field_name, row[entity_id_field], str(cardinality)
)
else:
entity[field_name] = entity_field_values

return entity

def serialize(self, config, field_definitions, field_name, field_data):
"""Serialized values into a format consistent with Workbench's CSV-field input format."""
"""Parameters
----------
config : dict
The configuration settings defined by workbench_config.get_config().
field_definitions : dict
The field definitions object defined by get_field_definitions().
field_name : string
The Drupal fieldname/CSV column header.
field_data : string
Raw JSON from the field named 'field_name'.
Returns
-------
string
A string structured same as the Workbench CSV field data for this field type,
or None if there is nothing to return.
"""
if "field_type" not in field_definitions[field_name]:
return None

subvalues = list()
for subvalue in field_data:
display_name = str(subvalue["display_name"])
if config["export_csv_term_mode"] == "name":
vocab_id = get_term_vocab(config, subvalue["target_id"])
term_name = get_term_name(config, subvalue["target_id"])
if display_name:
subvalues.append(
str(subvalue["rel_type"])
+ ":"
+ vocab_id
+ ":"
+ term_name
+ "~"
+ display_name
)
else:
subvalues.append(
str(subvalue["rel_type"]) + ":" + vocab_id + ":" + term_name
)
else:
# Term IDs.
if display_name:
subvalues.append(
str(subvalue["rel_type"])
+ ":"
+ str(subvalue["target_id"])
+ "~"
+ display_name
)
else:
subvalues.append(
str(subvalue["rel_type"]) + ":" + str(subvalue["target_id"])
)

if len(subvalues) > 1:
return config["subdelimiter"].join(subvalues)
elif len(subvalues) == 0:
return None
else:
return subvalues[0]


class AuthorityLinkField:
"""Functions for handling fields with 'authority_link' Drupal field data type.
All functions return a "entity" dictionary that is passed to Requests' "json"
Expand Down
Loading