AiravataUtils.php

<?php

use Airavata\Model\Workspace\Project;
use Airavata\Model\Experiment\ExperimentModel;
use Airavata\Model\Experiment\UserConfigurationDataModel;
use Airavata\Model\Scheduling\ComputationalResourceSchedulingModel;
use Airavata\Model\Application\Io\InputDataObjectType;
use Airavata\Model\Data\Replica\DataProductModel;
use Airavata\Model\Data\Replica\DataProductType;
use Airavata\Model\Data\Replica\DataReplicaLocationModel;
use Airavata\Model\Data\Replica\ReplicaLocationCategory;
use Airavata\Model\Data\Replica\ReplicaPersistentType;

function fetch_projectid($airavataclient, $authToken, $gatewayid, $user)
{
    if ($airavataclient->isUserExists($authToken, $gatewayid, $user)) {
        $userProjects = $airavataclient->getUserProjects($authToken, $gatewayid, $user, -1, 0);
        if ($userProjects == null || count($userProjects) == 0) {
            $projectId = create_project();
        } else {
            $projectId = $userProjects[0]->projectID;
        }
    } else {
        $projectId = create_project($airavataclient, $authToken, $gatewayid, $user);
    }

    return $projectId;
}

function create_project($airavataclient, $authToken, $gatewayid, $user)
{
    $project = new Project();
    $project->owner = $user;
    $project->gatewayId=$gatewayid;
    $project->name = "Default_Project";
    $project->description = "Default project";

    $projectId = $airavataclient->createProject($authToken, $gatewayid, $project);
    if ($projectId) {
        return $projectId;
    } else {
        echo 'Project cannot be created, please report to Support';
    }
}

function create_experiment_model($airavataclient, $authToken,
                                 $airavataconfig, $gatewayId, $projectId, $limsHost, $limsUser, $experimentName, $requestId,
                                 $computeCluster, $queue, $cores, $nodes, $mGroupCount, $wallTime, $clusterUserName, $clusterScratch, $inputFile, $outputDataDirectory)
{
    $storageResourceId = null;
    switch ($limsHost) {
        case "uslims3.uthscsa.edu":
            $storageResourceId = $airavataconfig['USLIMS3_UTHSCSA_STORAGE_ID'];
            break;
        case "uslims3.iisc.ernet.in":
            $storageResourceId = $airavataconfig['USLIMS3_IISC_STORAGE_ID'];
            break;
        case "uslims3.mbu.iisc.ernet.in":
            $storageResourceId = $airavataconfig['USLIMS3_IISC_STORAGE_ID'];
            break;
        case "uslims3.latrobe.edu.au":
            $storageResourceId = $airavataconfig['USLIMS3_LATROBE_STORAGE_ID'];
            break;
        case "uslims3.fz-juelich.de":
            $storageResourceId = $airavataconfig['USLIMS3_JUELICH_STORAGE_ID'];
            break;
        case "gw143.iu.xsede.org":
            $storageResourceId = $airavataconfig['USLIMS3_GW143_STORAGE_ID'];
            break;
        case "gw54.iu.xsede.org":
            $storageResourceId = $airavataconfig['USLIMS3_GW54_STORAGE_ID'];
            break;
    }

    $applicationInterfaceId = $airavataconfig['US3_APP'];
//    if ($computeCluster != "jureca.fz-juelich.de") {
//        $applicationInterfaceId = $airavataconfig['US3_APP'];
//    } else {
//        $applicationInterfaceId = $airavataconfig['US3_APP_JURECA'];
//    }

    $applicationInputs = $airavataclient->getApplicationInputs($authToken, $applicationInterfaceId);
    foreach ($applicationInputs as $applicationInput) {
        $applicationInputName = $applicationInput->name;
        switch ($applicationInputName) {
            case "Input_Tar_File":
                $dataProductModel = new DataProductModel();
                $dataProductModel->gatewayId = $gatewayId;
                $dataProductModel->ownerName = $limsUser;
                $dataProductModel->productName = basename($inputFile);
                $dataProductModel->dataProductType = DataProductType::FILE;

                $dataReplicationModel = new DataReplicaLocationModel();
                $dataReplicationModel->storageResourceId = $storageResourceId;
                $dataReplicationModel->replicaName = basename($inputFile) . " gateway data store copy";
                $dataReplicationModel->replicaLocationCategory = ReplicaLocationCategory::GATEWAY_DATA_STORE;
                $dataReplicationModel->replicaPersistentType = ReplicaPersistentType::TRANSIENT;
                $dataReplicationModel->filePath = "file://" . $limsHost . ":" . $inputFile;

                $dataProductModel->replicaLocations[] = $dataReplicationModel;
                $replicaURI = $airavataclient->registerDataProduct($authToken, $dataProductModel);

                $applicationInput->value = $replicaURI;
                break;
            case "Wall_Time":
                $applicationInput->value = "-walltime=" . $wallTime;
                break;
            case "Parallel_Group_Count":
                $applicationInput->value = "-mgroupcount=" . $mGroupCount;
                break;
        }
    }

    $computeResourceId = null;
    switch ($computeCluster) {
        case "alamo.uthscsa.edu":
            $computeResourceId = $airavataconfig['ALAMO_COMPUTE_ID'];
            break;
        case "comet.sdsc.xsede.org":
            $computeResourceId = $airavataconfig['COMET_COMPUTE_ID'];
            break;
        case "gordon.sdsc.xsede.org":
            $computeResourceId = $airavataconfig['GORDON_COMPUTE_ID'];
            break;
        case "ls5.tacc.utexas.edu":
            $computeResourceId = $airavataconfig['LONESTAR5_COMPUTE_ID'];
            break;
        case "stampede.tacc.xsede.org":
            $computeResourceId = $airavataconfig['STAMPEDE_COMPUTE_ID'];
            break;
        case "jureca.fz-juelich.de":
            $computeResourceId = $airavataconfig['JURECA_COMPUTE_ID'];
            break;
    }

    $scheduling = new ComputationalResourceSchedulingModel();
    $scheduling->resourceHostId = $computeResourceId;
    $scheduling->totalCPUCount = $cores;
    $scheduling->nodeCount = $nodes;
    $scheduling->queueName = $queue;
    $scheduling->wallTimeLimit = $wallTime;

    $userConfigs = new UserConfigurationDataModel();
    $userConfigs->computationalResourceScheduling = $scheduling;
    $userConfigs->storageId = $storageResourceId;
    $userConfigs->experimentDataDir = $outputDataDirectory;

    if (($computeCluster == "jureca") || ($computeCluster == "jureca.fz-juelich.de")) {

//        $userDN = "CN=_USER_, O=Ultrascan Gateway, C=DE";
//        $userDN      = str_replace( '_USER_', $clusterUserName, $userDN );
//        $userConfigs->userDN = $userDN;
        $scheduling->overrideLoginUserName = $clusterUserName;
        $scheduling->overrideScratchLocation = $clusterScratch;

    }

    $experimentModel = new ExperimentModel();
    $experimentModel->projectId = $projectId;
    $experimentModel->gatewayId = $gatewayId;
    $experimentModel->userName = $limsUser;
    $experimentModel->experimentName = $experimentName;
    $experimentModel->executionId = $applicationInterfaceId;
    $experimentModel->gatewayExecutionId = $requestId;
    $experimentModel->gatewayInstanceId = $limsHost;
    $experimentModel->userConfigurationData = $userConfigs;
    $experimentModel->experimentInputs = $applicationInputs;
    $experimentModel->experimentOutputs = $airavataclient->getApplicationOutputs($authToken, $applicationInterfaceId);

    return $experimentModel;
}

?>