node.inc

<?php


class TripNodeMigration extends DrupalNode6Migration {
  public function __construct(array $arguments) {
    
    $arguments += array('default_uid' => 0);
    
    parent::__construct($arguments);
    
    $this->addFieldMapping('nid', 'nid');    
    $this->addFieldMapping('is_new')->defaultValue(TRUE);    
    
    $this->addFieldMapping('field_destination', '6')
      ->sourceMigration('TripTermDestination')
      ->arguments(array('source_type' => 'tid'));
    
    $this->addFieldMapping('field_topic', '9')
      ->sourceMigration('TripTermTopic')
      ->arguments(array('source_type' => 'tid'));  
    
    $this->addFieldMapping('field_style', '5')
      ->sourceMigration('TripTermStyle')
      ->arguments(array('source_type' => 'tid'));     
    }

  protected function nodeQuery() {
    $query = Database::getConnection('default', $this->sourceConnection)
             ->select('node', 'n')
             ->fields('n', array('nid', 'vid', 'language', 'title', 'uid',
               'status', 'created', 'changed', 'comment', 'promote', 'moderate',
               'sticky'))
             ->condition('type', $this->sourceType)
             ->orderby('n.created', 'DESC');
    $query->innerJoin('node_revisions', 'nr', 'n.vid=nr.vid');
    $query->fields('nr', array('body', 'teaser', 'format'));
    return $query;
  }
  
    
/*
  public function complete($node, stdClass $row) {
   
    $flags = Database::getConnection('default', $this->sourceConnection)
      ->select('flag_content', 'fc')
      ->fields('fc', array('content_id','fid', 'uid', 'sid', 'timestamp'))
      ->condition('content_id', $node->nid)
      ->execute();

    $fcid = db_insert('flag_content')
      ->fields(array(
        'fid' => 2,
        'content_type' => 'node',
        'content_id' => $node->nid,
        'uid' => $node->uid,
        'sid' => 0,
        'timestamp' => REQUEST_TIME,
      ));
    }
*/  
}


/*

TODO

forum
voc:19 post_type, tid:821 -> blog

forum_travelmate
field_millistkaaslastsoovidleida
field_reisikestvus
field_reisitoimumine

forum_buysell
field_buysellprice
field_buysellcontact
voc:25 buysell category
voc:22 buysell type

*/

class TripNodeImageMigration extends TripNodeMigration {
  public function __construct(array $arguments) {
    parent::__construct($arguments);
 
    $this->addFieldMapping('field_image_image', 'image');
		$this->addFieldMapping('field_image_image:source_dir')
  		->defaultValue('http://trip.ee/files/imagecache/trip_image_small');
		$this->addFieldMapping('field_image_image:file_replace')
		  ->defaultValue(FILE_EXISTS_REPLACE);
  
   // TODO: voc:20 image_type
   
  }

  public function prepareRow($row) {
	  if (parent::prepareRow($row) === FALSE) {
	    return FALSE;
	  }
    
	  $row->image = TripNodeImageMigration::getImage($row->nid);
	}

  public function complete($node, stdClass $row) {
  
    $image_styles = array('image_small', 'image_medium', 'image_big');
    $styles = image_styles(); 
	  foreach ($styles as $key => $style) {
	    if (in_array($key, $image_styles)) {
        $file = file_load($node->field_image_image[LANGUAGE_NONE][0]['fid']);
	      image_style_create_derivative($styles[$key], $file->uri, image_style_path($key, $file->uri));
	      
	    }
	  }   
  }
  
  public function getImage($nid) {
    $query = Database::getConnection('default', $this->sourceConnection)
      ->select('content_field_image', 'cfi')
      ->condition('nid', $nid);
    $query->innerJoin('files', 'f', 'cfi.field_image_fid=f.fid');
    $query->fields('f', array('filepath'));
    $results = $query->execute();
    foreach ($results as $result) {
      $filename = basename($result->filepath);
    }
    return $filename;
  }

}