soap_server.php

<?php
/*
* This file is part of PEM package
*
* Copyright(c) Nicolas Roudaire  https://www.nikrou.net/
* Licensed under the GPL version 2.0 license.
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/

define('INTERNAL', true);
$root_path = './';
require_once($root_path.'include/common.inc.php');
require_once($root_path.'include/nusoap/nusoap.php');
$ns = $conf['website_url'].'/wsdl';

// First we must include our NuSOAP library and define the namespace of the
// service. It is usually recommended that you designate a distinctive URI
// for each one of your Web services.
$server = new soap_server();
$server->configureWSDL('getRevisionList',$ns);
$server->wsdl->schemaTargetNamespace = $ns;

// Next step, we instantiate the SOAP server and define the settings for our
// WSDL file such as the service name and the namespace.
$server->wsdl->addComplexType(
  'Revision',
  'complexType',
  'struct',
  'all',
  '',
  array(
    'revision_id' => array(
      'name' => 'revision_id',
      'type' => 'xsd:int'
      ),
    'extension_name' => array(
      'name' => 'extension_name',
      'type' => 'xsd:string'
      ),
    'extension_author' => array(
      'name' => 'extension_author',
      'type' => 'xsd:string'
      ),
    'extension_description' => array(
      'name' => 'extension_description',
      'type' => 'xsd:string'
      ),
    'revision_name' => array(
      'name' => 'revision_name',
      'type' => 'xsd:string'
      ),
    'revision_date' => array(
      'name' => 'revision_date',
      'type' => 'xsd:string'
      ),
    'revision_url' => array(
      'name' => 'revision_url',
      'type' => 'xsd:string'
      ),
    'revision_description' => array(
      'name' => 'revision_description',
      'type' => 'xsd:string'
      ),
    )
);

$server->wsdl->addComplexType(
  'RevisionList',
  'complexType',
  'array',
  '',
  'SOAP-ENC:Array',
  array(),
  array(
    array(
      'ref' => 'SOAP-ENC:arrayType',
      'wsdl:arrayType' => 'tns:Revision[]'
      )
  ),
  'tns:Revision'
);

$server->register(
  'getRevisionList',
  array(
   'version' => 'xsd:string',
   'category_id' => 'xsd:int',
    ),
  array(
    'result' => 'tns:RevisionList'
    ),
  $ns
);

function getRevisionList($version, $category_id) {
  global $db, $conf;

  $version = $db->escape($version);

  if ($category_id != abs(intval($category_id))) {
    die('unexpected category identifier');
  }

  $query = '
SELECT
    r.id_revision         AS revision_id,
    r.version             AS revision_name,
    e.id_extension        AS extension_id,
    e.name                AS extension_name,
    e.idx_user            AS author_id,
    e.description         AS extension_description,
    r.date                AS revision_date,
    r.url                 AS revision_url,
    r.description         AS revision_description
  FROM '.REV_TABLE.' AS r
    INNER JOIN '.EXT_TABLE.'      AS e  ON e.id_extension = r.idx_extension
    INNER JOIN '.COMP_TABLE.'     AS c  ON c.idx_revision = r.id_revision
    INNER JOIN '.VER_TABLE.'      AS v  ON v.id_version = c.idx_version
    INNER JOIN '.EXT_CAT_TABLE.'  AS ec ON ec.idx_extension = e.id_extension
  WHERE ec.idx_category = '.$category_id.'
    AND v.version = \''.$version.'\'
;';

  $author_ids = array();
  $revisions = array();
  $result = $db->query($query);
  while ($row = $db->fetch_assoc($result)) {
    $row['revision_date'] = date('Y-m-d H:i:s', $row['revision_date']);

    $row['revision_url'] = sprintf(
      '%s/%s',
      $conf['website_url'],
      get_revision_src(
        $row['extension_id'],
        $row['revision_id'],
        $row['revision_url']
        )
      );

    array_push($revisions, $row);
    array_push($author_ids, $row['author_id']);
  }

  $user_basic_infos_of = get_user_basic_infos_of($author_ids);

  foreach ($revisions as $revision_index => $revision) {
    $revisions[$revision_index]['extension_author']
        = $user_basic_infos_of[ $revision['author_id'] ]['username'];
  }

  // echo '<pre>'; print_r($revisions); echo '<pre/>';

  return $revisions;
}

$server->register(
  'getVersionList',
  array(
    ),
  array(
    'result' => 'xsd:string'
    ),
  $ns
);

function getVersionList()
{
  $query = '
SELECT
    version
  FROM '.VER_TABLE.'
;';

  return implode(',', versort(query2array($query, null, 'version')));
}

// new get_revision_list to replace getRevisionList because Talend Open
// Studio can't stand an addition in the answer format (I wanted to add
// filename and download_url)

$server->wsdl->addComplexType(
  'revision',
  'complexType',
  'struct',
  'all',
  '',
  array(
    'revision_id' => array(
      'name' => 'revision_id',
      'type' => 'xsd:int'
      ),
    'extension_name' => array(
      'name' => 'extension_name',
      'type' => 'xsd:string'
      ),
    'extension_author' => array(
      'name' => 'extension_author',
      'type' => 'xsd:string'
      ),
    'extension_description' => array(
      'name' => 'extension_description',
      'type' => 'xsd:string'
      ),
    'revision_name' => array(
      'name' => 'revision_name',
      'type' => 'xsd:string'
      ),
    'revision_date' => array(
      'name' => 'revision_date',
      'type' => 'xsd:string'
      ),
    'file_url' => array(
      'name' => 'file_url',
      'type' => 'xsd:string'
      ),
    'download_url' => array(
      'name' => 'download_url',
      'type' => 'xsd:string'
      ),
    'filename' => array(
      'name' => 'filename',
      'type' => 'xsd:string'
      ),
    'revision_description' => array(
      'name' => 'revision_description',
      'type' => 'xsd:string'
      ),
    )
);

$server->wsdl->addComplexType(
  'revision_list',
  'complexType',
  'array',
  '',
  'SOAP-ENC:Array',
  array(),
  array(
    array(
      'ref' => 'SOAP-ENC:arrayType',
      'wsdl:arrayType' => 'tns:revision[]'
      )
  ),
  'tns:revision'
);

$server->register(
  'get_revision_list',
  array(
   'version' => 'xsd:string',
   'category_id' => 'xsd:int',
    ),
  array(
    'result' => 'tns:revision_list'
    ),
  $ns
);

function get_revision_list($version, $category_id) {
  global $db, $conf;

  $version = $db->escape($version);

  if ($category_id != abs(intval($category_id))) {
    die('unexpected category identifier');
  }

  $query = '
SELECT
    r.id_revision         AS revision_id,
    r.version             AS revision_name,
    e.id_extension        AS extension_id,
    e.name                AS extension_name,
    e.idx_user            AS author_id,
    e.description         AS extension_description,
    r.date                AS revision_date,
    r.url                 AS filename,
    r.description         AS revision_description
  FROM '.REV_TABLE.' AS r
    INNER JOIN '.EXT_TABLE.'      AS e  ON e.id_extension = r.idx_extension
    INNER JOIN '.COMP_TABLE.'     AS c  ON c.idx_revision = r.id_revision
    INNER JOIN '.VER_TABLE.'      AS v  ON v.id_version = c.idx_version
    INNER JOIN '.EXT_CAT_TABLE.'  AS ec ON ec.idx_extension = e.id_extension
  WHERE ec.idx_category = '.$category_id.'
    AND v.version = \''.$version.'\'
;';

  $author_ids = array();
  $revisions = array();
  $result = $db->query($query);
  while ($row = $db->fetch_assoc($result)) {
    $row['revision_date'] = date('Y-m-d H:i:s', $row['revision_date']);

    $row['file_url'] = sprintf(
      '%s/%s',
      $conf['website_url'],
      get_revision_src(
        $row['extension_id'],
        $row['revision_id'],
        $row['filename']
        )
      );

    $row['download_url'] = sprintf(
      '%s/download.php?rid=%u',
      $conf['website_url'],
      $row['revision_id']
      );

    array_push($revisions, $row);
    array_push($author_ids, $row['author_id']);
  }

  $user_basic_infos_of = get_user_basic_infos_of($author_ids);

  foreach ($revisions as $revision_index => $revision) {
    $revisions[$revision_index]['extension_author']
        = $user_basic_infos_of[ $revision['author_id'] ]['username'];
  }

  // echo '<pre>'; print_r($revisions); echo '<pre/>';

  return $revisions;
}

//Then we invoke the service using the following line of code:
$HTTP_RAW_POST_DATA = isset($GLOBALS['HTTP_RAW_POST_DATA'])
  ? $GLOBALS['HTTP_RAW_POST_DATA']
  : ''
;
$server->service($HTTP_RAW_POST_DATA);
exit();