Congegni
/
libretime
mirror of https://github.com/libretime/libretime.git
7
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'saas-dashboard-provisioning' into saas

This commit is contained in:
Duncan Sommerville 2015-03-19 11:59:01 -04:00
parent b49e98693b 716244011a
commit 766f649f56
3 changed files with 71 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
airtime_mvc/application/Bootstrap.php
View File

@ -37,7 +37,7 @@ require_once (APPLICATION_PATH."/logging/Logging.php");
Logging::setLogPath('/var/log/airtime/zendphp.log'); Logging::setLogPath('/var/log/airtime/zendphp.log');
// We need to manually route because we can't load Zend without the database being initialized first. // We need to manually route because we can't load Zend without the database being initialized first.
if (array_key_exists("REQUEST_URI", $_SERVER) && (strpos($_SERVER["REQUEST_URI"], "/provisioning/create") !== false)) { if (array_key_exists("REQUEST_URI", $_SERVER) && (stripos($_SERVER["REQUEST_URI"], "/provisioning/create") !== false)) {
$provisioningHelper = new ProvisioningHelper($CC_CONFIG["apiKey"][0]); $provisioningHelper = new ProvisioningHelper($CC_CONFIG["apiKey"][0]);
$provisioningHelper->createAction(); $provisioningHelper->createAction();
die(); die();

86
airtime_mvc/application/common/ProvisioningHelper.php
View File

@ -10,6 +10,7 @@ class ProvisioningHelper
// Parameter values // Parameter values
private $dbuser, $dbpass, $dbname, $dbhost, $dbowner, $apikey; private $dbuser, $dbpass, $dbname, $dbhost, $dbowner, $apikey;
private $instanceId; private $instanceId;
private $station_name, $description;
public function __construct($apikey) public function __construct($apikey)
{ {
@ -34,34 +35,63 @@ class ProvisioningHelper
try { try {
$this->parsePostParams(); $this->parsePostParams();
//For security, the Airtime Pro provisioning system creates the database for the user. //For security, the Airtime Pro provisioning system creates the database for the user.
$this->setNewDatabaseConnection(); if ($this->dbhost && !empty($this->dbhost)) {
$this->setNewDatabaseConnection();
//if ($this->checkDatabaseExists()) { //if ($this->checkDatabaseExists()) {
// throw new Exception("ERROR: Airtime database already exists"); // throw new Exception("ERROR: Airtime database already exists");
//} //}
if (!$this->checkDatabaseExists()) { if (!$this->checkDatabaseExists()) {
throw new Exception("ERROR: $this->dbname database does not exist."); throw new Exception("ERROR: $this->dbname database does not exist.");
} }
//We really want to do this check because all the Propel-generated SQL starts with "DROP TABLE IF EXISTS". //We really want to do this check because all the Propel-generated SQL starts with "DROP TABLE IF EXISTS".
//If we don't check, then a second call to this API endpoint would wipe all the tables! //If we don't check, then a second call to this API endpoint would wipe all the tables!
if ($this->checkTablesExist()) { if ($this->checkTablesExist()) {
throw new Exception("ERROR: airtime tables already exists"); throw new Exception("ERROR: airtime tables already exists");
}
$this->createDatabaseTables();
$this->initializeMusicDirsTable($this->instanceId);
} }
//$this->createDatabase(); //$this->createDatabase();
//All we need to do is create the database tables. //All we need to do is create the database tables.
$this->createDatabaseTables(); $this->initializePrefs();
$this->initializeMusicDirsTable($this->instanceId);
} catch (Exception $e) { } catch (Exception $e) {
http_response_code(400); http_response_code(400);
Logging::error($e->getMessage() Logging::error($e->getMessage());
); echo $e->getMessage() . PHP_EOL;
return;
}
http_response_code(201);
}
/**
* Endpoint to change Airtime preferences remotely.
* Mainly for use with the dashboard right now.
*/
public function changeAction() {
$apikey = $_SERVER['PHP_AUTH_USER'];
if (!isset($apikey) || $apikey != $this->apikey) {
Logging::info("Invalid API Key: $apikey");
http_response_code(403);
echo "ERROR: Incorrect API key";
return;
}
try {
$this->parsePostParams();
$this->initializePrefs();
} catch (Exception $e) {
http_response_code(400);
Logging::error($e->getMessage());
echo $e->getMessage() . PHP_EOL; echo $e->getMessage() . PHP_EOL;
return; return;
} }
@ -102,6 +132,9 @@ class ProvisioningHelper
$this->dbhost = $_POST['dbhost']; $this->dbhost = $_POST['dbhost'];
$this->dbowner = $_POST['dbowner']; $this->dbowner = $_POST['dbowner'];
$this->instanceId = $_POST['instanceid']; $this->instanceId = $_POST['instanceid'];
$this->station_name = $_POST['station_name'];
$this->description = $_POST['description'];
} }
/** /**
@ -111,9 +144,9 @@ class ProvisioningHelper
private function setNewDatabaseConnection() private function setNewDatabaseConnection()
{ {
self::$dbh = new PDO("pgsql:host=" . $this->dbhost self::$dbh = new PDO("pgsql:host=" . $this->dbhost
. ";dbname=" . $this->dbname . ";dbname=" . $this->dbname
. ";port=5432" . ";user=" . $this->dbuser . ";port=5432" . ";user=" . $this->dbuser
. ";password=" . $this->dbpass); . ";password=" . $this->dbpass);
//Turn on PDO exceptions because they're off by default. //Turn on PDO exceptions because they're off by default.
//self::$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); //self::$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$err = self::$dbh->errorInfo(); $err = self::$dbh->errorInfo();
@ -130,8 +163,8 @@ class ProvisioningHelper
{ {
Logging::info("Creating database..."); Logging::info("Creating database...");
$statement = self::$dbh->prepare("CREATE DATABASE " . pg_escape_string($this->dbname) $statement = self::$dbh->prepare("CREATE DATABASE " . pg_escape_string($this->dbname)
. " WITH ENCODING 'UTF8' TEMPLATE template0" . " WITH ENCODING 'UTF8' TEMPLATE template0"
. " OWNER " . pg_escape_string($this->dbowner)); . " OWNER " . pg_escape_string($this->dbowner));
if (!$statement->execute()) { if (!$statement->execute()) {
throw new Exception("ERROR: Failed to create Airtime database"); throw new Exception("ERROR: Failed to create Airtime database");
} }
@ -182,5 +215,16 @@ class ProvisioningHelper
$musicDir->save(); $musicDir->save();
} }
/**
* Initialize preference values passed from the dashboard (if any exist)
*/
private function initializePrefs() {
if ($this->statio_name) {
Application_Model_Preference::SetStationName($this->station_name);
}
if ($this->descption) {
Application_Model_Preference::SetStationDescription($this->description);
}
}
} }

5
airtime_mvc/application/models/Preference.php
View File

@ -326,6 +326,11 @@ class Application_Model_Preference
return self::getValue("station_name"); return self::getValue("station_name");
} }
public static function SetStationName($station_name)
{
self::setValue("station_name", $station_name);
}
public static function SetAutoUploadRecordedShowToSoundcloud($upload) public static function SetAutoUploadRecordedShowToSoundcloud($upload)
{ {
self::setValue("soundcloud_auto_upload_recorded_show", $upload); self::setValue("soundcloud_auto_upload_recorded_show", $upload);