<?php
/*
* Copyright (c) 2009, Francis Li and Simona Brusa Pasque'
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
*     * Redistributions of source code must retain the above copyright
*       notice, this list of conditions and the following disclaimer.
*     * Redistributions in binary form must reproduce the above copyright
*       notice, this list of conditions and the following disclaimer in the
*       documentation and/or other materials provided with the distribution.
*     * Neither the name of the organization nor the
*       names of its contributors may be used to endorse or promote products
*       derived from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY Francis Li and Simona Brusa Pasque' ''AS IS''
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, 
* THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
* PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL Francis Li nor Simona Brusa Pasque'
* BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, 
* OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 
* PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
* OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
* WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
* OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
* ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/

require_once dirname(__FILE__) ."/../settings.inc.php";
require_once dirname(__FILE__) ."/../utilities.inc.php";
require_once dirname(__FILE__) ."/../model.inc.php";
require_once dirname(__FILE__) ."/../sunlight.inc.php";

function parseRepFromSunlight($id) {
  if ($id == 0) {
    return;
  }
  echo "Processing {$id}: ";
  //// Query the Sunlight API
  $response = sunlight_legislators_get($id);
  //// create a new Rep object
  $rep = new Rep();
  $rep->id = $id;
  $rep->bioguide_id = $response->bioguide_id;
  $rep->party = $response->party;
  $rep->state = $response->state;
  $rep->district = $response->district;
  $rep->gender = $response->gender;
  $rep->title = $response->title;
  if ($rep->title == 'Sen') {
    $rep->district = 0;
  }
  $rep->firstname = $response->firstname;
  $rep->middlename = $response->middlename;
  $rep->lastname = $response->lastname;
  $rep->name_suffix = $response->name_suffix;
  $rep->nickname = $response->nickname;
  $rep->phone = $response->phone;
  $rep->fax = $response->fax;
  $rep->website = $response->website;
  $rep->webform = $response->webform;
  $rep->email = $response->email;
  $rep->congress_office = $response->congress_office;
  $rep->twitter_id = $response->twitter_id;
  $rep->youtube_url = $response->youtube_url;
  $rep->save();
  echo "{$rep->id} {$rep->lastname} {$rep->party} {$rep->state}\n";
}

function parseRepFromGovtrack($person) {
  $rep = new Rep();
  $rep->id = (int) $person['id'];
  echo "Processing {$rep->id}: ";
  $rep->bioguide_id = $person['bioguideid'];
  $rep->gender = $person['gender'];
  $rep->firstname = $person['firstname'];
  $rep->middlename = $person['middlename'];
  $rep->lastname = $person['lastname'];
  $rep->name_suffix = $person['namemod'];
  $rep->nickname = $person['nickname'];
  $rep->phone = '';
  $rep->fax = '';
  $rep->website = '';
  $rep->webform = '';
  $rep->email = '';
  $rep->congress_office = '';
  $rep->twitter_id = '';
  $rep->youtube_url = '';
  foreach ($person->role as $role) {
    $rep->party = substr((string) $role['party'], 0, 1);
    $rep->state = (string) $role['state'];
    $rep->title = ucfirst((string) $role['type']);
    if ($rep->title == 'Rep') {
      $rep->district = (int) $role['district'];
    } else {
      $rep->district = 0;
    }
  }
  $rep->save();
  echo "{$rep->id} {$rep->lastname} {$rep->party} {$rep->state}\n";
}

function updateReps() {
  //// process the database
  require_once dirname(__FILE__) ."/../db.inc.php";
  $params = array(
		  array('vote_rep', 'rep_id'),
		  array('bill', 'sponsor_rep_id'),
		  array('bill_sponsor', 'rep_id'),
		  array('amendment', 'sponsor_rep_id'),
		  array('record', 'speaker_rep_id')
		  );

  //// get missing reps and fetch from sunlight
  foreach ($params as $param) {
    $query =<<<EOQ
SELECT DISTINCT {$param[0]}.{$param[1]} 
FROM {$param[0]} 
LEFT JOIN rep ON {$param[0]}.{$param[1]}=rep.id 
WHERE rep.id IS NULL
EOQ;
    $result = mysql_query($query);
    if ($result) {
      while ($row = mysql_fetch_row($result)) {	
	parseRepFromSunlight($row[0]);
      }
    }
  }

  //// fill in the gaps in sunlight's db from govtrack
  $ids = array();
  foreach ($params as $param) {
    $query =<<<EOQ
SELECT DISTINCT {$param[0]}.{$param[1]} 
FROM {$param[0]} 
LEFT JOIN rep ON {$param[0]}.{$param[1]}=rep.id 
WHERE rep.id IS NULL
EOQ;
    $result = mysql_query($query);
    if ($result) {
      while ($row = mysql_fetch_row($result)) {
	$ids[$row[0]] = 1;
      }
    }
  }
  $current = get_current_congress_session();
  $data_dir = dirname(__FILE__) ."/../data";
  $path = "{$data_dir}/us/{$current['congress']}/repstats/people.xml";
  $doc = simplexml_load_file($path);
  foreach ($doc->person as $person) {
    if (isset($ids[(int) $person['id']])) {
      parseRepFromGovtrack($person);
    }
  }
}

if (isset($_SERVER['argv'])) {
  if ($_SERVER['argv'][0] != 'rep.php') {
    return;
  }
  if (count($_SERVER['argv']) > 1) {
    //// parse arguments
    parseRepFromSunlight($_SERVER['argv'][1]);
  } else {
    updateReps();
  }
}

?>