function og_og_migrate_group_membership in Organic groups 7

Add group membership enteties instead of field data.

1 string reference to 'og_og_migrate_group_membership'

group_membership.inc in plugins/og_migrate/group_membership.inc

File

plugins/og_migrate/group_membership.inc, line 15

Code

function og_og_migrate_group_membership(&$context) {
  if (empty($context['sandbox'])) {
    $context['sandbox']['progress'] = 0;
    $context['sandbox']['last'] = 0;

    // Add "User request" to the default group membership type.
    $field_name = OG_MEMBERSHIP_REQUEST_FIELD;
    if (!field_info_field($field_name)) {
      $field = array(
        'field_name' => $field_name,
        'type' => 'text_long',
        'entity_types' => array(
          'og_membership',
        ),
        'cardinality' => 1,
        // Although we would prefer to not allow deleting this field, we can not
        // lock it, as it will not allow adding it to other bundles.
        'locked' => FALSE,
      );
      $field = field_create_field($field);
    }
    if (!field_info_instance('og_membership', $field_name, OG_MEMBERSHIP_TYPE_DEFAULT)) {
      $instance = array(
        'field_name' => $field_name,
        'bundle' => OG_MEMBERSHIP_TYPE_DEFAULT,
        'entity_type' => 'og_membership',
        'label' => t('Request message'),
        'description' => t('This is the text a user may send to the group administrators.'),
        'required' => FALSE,
      );
      field_create_instance($instance);
    }

    // Calculate max items.
    $query = new EntityFieldQuery();
    $context['sandbox']['max'] = $query
      ->fieldCondition(OG_AUDIENCE_FIELD, 'gid', 1, '>=')
      ->count()
      ->execute();
    if (!$context['sandbox']['max']) {

      // No data to process, so return.
      $context['finished'] = 1;
      return;
    }
  }
  $batch_size = variable_get('og_batch_size', 200);
  $query = new EntityFieldQuery();
  $result = $query
    ->fieldCondition(OG_AUDIENCE_FIELD, 'gid', 1, '>=')
    ->range($context['sandbox']['progress'], $context['sandbox']['progress'] + $batch_size)
    ->execute();
  if (!empty($result)) {
    foreach ($result as $entity_type => $values) {
      foreach ($values as $etid => $value) {
        $entity = entity_load($entity_type, array(
          $etid,
        ));
        $entity = reset($entity);
        foreach ($entity->{OG_AUDIENCE_FIELD}[LANGUAGE_NONE] as $value) {

          // Check group membership doesn't exist already.
          if (!og_get_group_membership($value['gid'], $entity_type, $etid)) {
            $group_membership = og_membership_create($value['gid'], $entity_type, $etid, array(
              'state' => $value['state'],
              'created' => $value['created'],
            ));
            $group_membership
              ->save();
            $params = array(
              '@label' => og_label($value['gid']),
              '@type' => $entity_type,
              '@id' => $etid,
            );
            $context['results'][] = t('Membership of group @label for @type @id', $params);
          }
          $context['sandbox']['progress']++;
        }
      }
    }
  }
  if ($context['sandbox']['progress'] != $context['sandbox']['max']) {
    $context['finished'] = $context['sandbox']['progress'] / $context['sandbox']['max'];
  }
}