FedoraConnect.php

<?php

/**
 * Class to make an initial connection to Fedora
 *  
 * @author Richard Wincewicz
 */
require_once 'tuque/Datastream.php';
require_once 'tuque/FedoraApi.php';
require_once 'tuque/FedoraApiSerializer.php';
require_once 'tuque/Object.php';
require_once 'tuque/RepositoryConnection.php';
require_once 'tuque/Cache.php';
require_once 'tuque/RepositoryException.php';
require_once 'tuque/Repository.php';
require_once 'tuque/FedoraRelationships.php';
require_once 'FedoraConnectStaticMethods.php';

class FedoraConnection {

  /**
   * Connection to the repository
   *
   * @var RepositoryConnection
   */
  public $connection = NULL;

  /**
   * The Fedora API we are using
   *
   * @var FedoraAPI
   */
  public $api = NULL;

  /**
   * The cache we use to connect.
   *
   * @var SimpleCache
   */
  public $cache = NULL;

  /**
   * The repository object.
   *
   * @var FedoraRepository
   */
  public $repository = NULL;

  function __construct($user = NULL, $url = NULL) {

    $user_string = $user->name;
    $pass_string = $user->pass;

    if (!isset($url)) {
      $url = 'http://localhost:8080/fedora';
    }

    //if (self::exists()) {
    try {
      $this->connection = new RepositoryConnection($url, $user_string, $pass_string);
      $this->connection->reuseConnection = TRUE;
      $this->api = new FedoraApi($this->connection);
      $this->cache = new SimpleCache();
      $this->repository = new FedoraRepository($this->api, $this->cache);
    } catch (Exception $e) {
		echo "Could not connect: $e";
      file_put_contents('php://stderr', "Could not connect to Fedora - $e");
    }
    //}
  }

	function getDatastream($pid = NULL, $dsid = NULL) {
		if (!isset($pid) || !isset($dsid))
			return;

		$fedora_object = new FedoraObject($pid, $this->repository);

		$datastream_array = array();

    	foreach ($fedora_object as $datastream)
      		$datastream_array[] = $datastream->id;

    	if (!in_array($dsid, $datastream_array))
      		print "Could not find the $dsid datastream!";

		try {
      		$datastream = $fedora_object->getDatastream($dsid);
    	} catch (Exception $e) {
      		print "Could not retrieve datastream - $e";
    	}

    	return $datastream;
	}

	function saveDatastream($datastream, $extension = NULL) {
		if (!$datastream)
			return;

    	try {
      		$mime_type = $datastream->mimetype;
      		if (!$extension) {
        		$extension = system_mime_type_extension($mime_type);
      		}	
      		$tempfile = temp_filename($extension);
      		$file_handle = fopen($tempfile, 'w');
      		fwrite($file_handle, $datastream->content);
      		fclose($file_handle);
    	} catch (Exception $e) {
      		print "Could not save datastream - $e";
    	}

    	return $tempfile;
	}

	function addDerivative($pid, $dsid, $label, $content, $mimetype, $log_message = NULL, $delete = TRUE, $from_file = TRUE, $stream_type = "M") {

    	$return = "success";
    	//we are don't seem to be sending custom log message for updates only ingests
		$fedora_object = $this->repository->getObject($pid);
    	if (isset($fedora_object[$dsid])) {
      		if ($from_file) {
        		$fedora_object[$dsid]->content = file_get_contents($content);
      		}
      		else {
        		$fedora_object[$dsid]->content = $content;
      		}
    	}
    	else {
      		$datastream = new NewFedoraDatastream($dsid, $stream_type, $fedora_object, $fedora_object->repository);
      		if ($from_file) {
        		$datastream->setContentFromFile($content);
      		}
      		else {
        		$datastream->setContentFromString($content);
      		}

      		$datastream->label = $label;
      		$datastream->mimetype = $mimetype;
      		$datastream->state = 'A';
      		$datastream->checksum = TRUE;
      		$datastream->checksumType = 'MD5';
      		if ($log_message) {
        		$datastream->logMessage = $log_message;
      		}
      		$return = $fedora_object->ingestDatastream($datastream);
    	}
    	if ($delete && $from_file) {
      		unlink($content);
    	}
    	//$this->log->lwrite('Finished processing', 'COMPLETE_DATASTREAM', $this->pid, $dsid);
    	return $return;
  	}

  static function exists() {
    return class_exists('RepositoryConnection');
  }

}
?>