bee3dea9c2
This adds a requirement for all definitions that have foreign keys to also require indices for all source (local) attributes mentioned in foreign keys. MariaDB/MySQL creates indices for source attributes automatically, so this serves as a way to get rid of those automatic indices and create clean explicit ones instead. In PostgreSQL, most of the time, indices on the source are necessary to decrease performance penalty of foreign keys (like in MariaDB), but they aren't created automatically, so this serves to remove that difference between PostgreSQL and MariaDB.
278 lines
10 KiB
PHP
278 lines
10 KiB
PHP
<?php
|
|
// This file is part of GNU social - https://www.gnu.org/software/social
|
|
//
|
|
// GNU social is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU Affero General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version.
|
|
//
|
|
// GNU social is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU Affero General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU Affero General Public License
|
|
// along with GNU social. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
/**
|
|
* Data class for happenings
|
|
*
|
|
* @category Data
|
|
* @package GNUsocial
|
|
* @author Evan Prodromou <evan@status.net>
|
|
* @copyright 2011 StatusNet, Inc.
|
|
* @license https://www.gnu.org/licenses/agpl.html GNU AGPL v3 or later
|
|
*/
|
|
|
|
defined('GNUSOCIAL') || die();
|
|
|
|
/**
|
|
* Data class for happenings
|
|
*
|
|
* There's already an Event class in lib/event.php, so we couldn't
|
|
* call this an Event without causing a hole in space-time.
|
|
*
|
|
* "Happening" seemed good enough.
|
|
*
|
|
* @category Event
|
|
* @package GNUsocial
|
|
* @author Evan Prodromou <evan@status.net>
|
|
* @license https://www.gnu.org/licenses/agpl.html GNU AGPL v3 or later
|
|
*
|
|
* @see Managed_DataObject
|
|
*/
|
|
class Happening extends Managed_DataObject
|
|
{
|
|
const OBJECT_TYPE = 'http://activitystrea.ms/schema/1.0/event';
|
|
|
|
public $__table = 'happening'; // table name
|
|
public $id; // varchar(36) UUID
|
|
public $uri; // varchar(191) not 255 because utf8mb4 takes more space
|
|
public $profile_id; // int
|
|
public $start_time; // datetime
|
|
public $end_time; // datetime
|
|
public $title; // varchar(191) not 255 because utf8mb4 takes more space
|
|
public $location; // varchar(191) not 255 because utf8mb4 takes more space
|
|
public $url; // varchar(191) not 255 because utf8mb4 takes more space
|
|
public $description; // text
|
|
public $created; // datetime
|
|
|
|
/**
|
|
* The One True Thingy that must be defined and declared.
|
|
*/
|
|
public static function schemaDef()
|
|
{
|
|
return array(
|
|
'description' => 'A real-world happening',
|
|
'fields' => array(
|
|
'id' => array('type' => 'char',
|
|
'length' => 36,
|
|
'not null' => true,
|
|
'description' => 'UUID'),
|
|
'uri' => array('type' => 'varchar',
|
|
'length' => 191,
|
|
'not null' => true),
|
|
'profile_id' => array('type' => 'int', 'not null' => true),
|
|
'start_time' => array('type' => 'datetime', 'not null' => true),
|
|
'end_time' => array('type' => 'datetime', 'not null' => true),
|
|
'title' => array('type' => 'varchar',
|
|
'length' => 191,
|
|
'not null' => true),
|
|
'location' => array('type' => 'varchar',
|
|
'length' => 191),
|
|
'url' => array('type' => 'varchar',
|
|
'length' => 191),
|
|
'description' => array('type' => 'text'),
|
|
'created' => array('type' => 'datetime',
|
|
'not null' => true),
|
|
),
|
|
'primary key' => array('id'),
|
|
'unique keys' => array(
|
|
'happening_uri_key' => array('uri'),
|
|
),
|
|
'foreign keys' => array(
|
|
'happening_profile_id_fkey' => array('profile', array('profile_id' => 'id')),
|
|
'happening_uri_fkey' => array('notice', array('uri' => 'uri'))
|
|
),
|
|
'indexes' => array(
|
|
'happening_profile_id_idx' => array('profile_id'),
|
|
'happening_created_idx' => array('created'),
|
|
'happening_start_time_end_time_idx' => array('start_time', 'end_time'),
|
|
),
|
|
);
|
|
}
|
|
|
|
public static function saveActivityObject(Activity $act, Notice $stored)
|
|
{
|
|
if (count($act->objects) !== 1) {
|
|
// TRANS: Exception thrown when there are too many activity objects.
|
|
throw new Exception(_m('Too many activity objects.'));
|
|
}
|
|
$actobj = $act->objects[0];
|
|
if (!ActivityUtils::compareTypes($actobj->type, [Happening::OBJECT_TYPE])) {
|
|
// TRANS: Exception thrown when event plugin comes across a non-event type object.
|
|
throw new Exception(_m('Wrong type for object.'));
|
|
}
|
|
|
|
try {
|
|
$other = Happening::getByKeys(['uri' => $actobj->id]);
|
|
throw AlreadyFulfilledException('Happening already exists.');
|
|
} catch (NoResultException $e) {
|
|
// alright, let's save this
|
|
}
|
|
|
|
$dtstart = null;
|
|
$dtend = null;
|
|
$location = null;
|
|
$url = null;
|
|
|
|
foreach ($actobj->extra as $extra) {
|
|
switch ($extra[0]) {
|
|
case 'dtstart':
|
|
$dtstart = $extra[2];
|
|
break;
|
|
case 'dtend':
|
|
$dtend = $extra[2];
|
|
break;
|
|
case 'location':
|
|
// location is optional
|
|
$location = $extra[2];
|
|
break;
|
|
case 'url':
|
|
// url is optional
|
|
$url = $extra[2];
|
|
}
|
|
}
|
|
if (empty($dtstart)) {
|
|
// TRANS: Exception thrown when has no start date
|
|
throw new Exception(_m('No start date for event.'));
|
|
}
|
|
if (empty($dtend)) {
|
|
// TRANS: Exception thrown when has no end date
|
|
throw new Exception(_m('No end date for event.'));
|
|
}
|
|
|
|
// convert RFC3339 dates delivered in Activity Stream to MySQL DATETIME date format
|
|
$start_time = new DateTime($dtstart);
|
|
$start_time->setTimezone(new DateTimeZone('UTC'));
|
|
$start_time = $start_time->format('Y-m-d H:i:s');
|
|
$end_time = new DateTime($dtend);
|
|
$end_time->setTimezone(new DateTimeZone('UTC'));
|
|
$end_time = $end_time->format('Y-m-d H:i:s');
|
|
|
|
$ev = new Happening();
|
|
|
|
$ev->id = UUID::gen();
|
|
$ev->uri = $actobj->id;
|
|
$ev->profile_id = $stored->getProfile()->getID();
|
|
$ev->start_time = $start_time;
|
|
$ev->end_time = $end_time;
|
|
$ev->title = $actobj->title;
|
|
$ev->location = $location;
|
|
$ev->description = $stored->getContent();
|
|
$ev->url = $url;
|
|
$ev->created = $stored->getCreated();
|
|
|
|
$ev->insert();
|
|
return $ev;
|
|
}
|
|
|
|
public function insert()
|
|
{
|
|
$result = parent::insert();
|
|
if ($result === false) {
|
|
common_log_db_error($this, 'INSERT', __FILE__);
|
|
throw new ServerException(_('Failed to insert '._ve(get_called_class()).' into database'));
|
|
}
|
|
return $result;
|
|
}
|
|
|
|
/**
|
|
* Returns the profile's canonical url, not necessarily a uri/unique id
|
|
*
|
|
* @return string $url
|
|
*/
|
|
public function getUrl()
|
|
{
|
|
if (empty($this->url) ||
|
|
!filter_var($this->url, FILTER_VALIDATE_URL)) {
|
|
throw new InvalidUrlException($this->url);
|
|
}
|
|
return $this->url;
|
|
}
|
|
|
|
public function getUri()
|
|
{
|
|
return $this->uri;
|
|
}
|
|
|
|
public function getStored()
|
|
{
|
|
return Notice::getByKeys(array('uri'=>$this->getUri()));
|
|
}
|
|
|
|
public static function fromStored(Notice $stored)
|
|
{
|
|
if (!ActivityUtils::compareTypes($stored->getObjectType(), [self::OBJECT_TYPE])) {
|
|
throw new ServerException('Notice is not of type '.self::OBJECT_TYPE);
|
|
}
|
|
return self::getByKeys(array('uri'=>$stored->getUri()));
|
|
}
|
|
|
|
public function getRSVPs()
|
|
{
|
|
return RSVP::forEvent($this);
|
|
}
|
|
|
|
public function getRSVP($profile)
|
|
{
|
|
return RSVP::pkeyGet([
|
|
'profile_id' => $profile->getID(),
|
|
'event_uri' => $this->getUri(),
|
|
]);
|
|
}
|
|
|
|
public static function getObjectType()
|
|
{
|
|
return self::OBJECT_TYPE;
|
|
}
|
|
|
|
public function asActivityObject()
|
|
{
|
|
$actobj = new ActivityObject();
|
|
$actobj->id = $this->getUri();
|
|
$actobj->type = self::getObjectType();
|
|
$actobj->title = $this->title;
|
|
$actobj->summary = $this->description;
|
|
$actobj->extra[] = array('dtstart',
|
|
array('xmlns' => 'urn:ietf:params:xml:ns:xcal'),
|
|
common_date_iso8601($this->start_time));
|
|
$actobj->extra[] = array('dtend',
|
|
array('xmlns' => 'urn:ietf:params:xml:ns:xcal'),
|
|
common_date_iso8601($this->end_time));
|
|
$actobj->extra[] = array('location',
|
|
array('xmlns' => 'urn:ietf:params:xml:ns:xcal'),
|
|
$this->location);
|
|
try {
|
|
$actobj->extra[] = array('url',
|
|
array('xmlns' => 'urn:ietf:params:xml:ns:xcal'),
|
|
$this->getUrl());
|
|
} catch (InvalidUrlException $e) {
|
|
// oh well, no URL for you!
|
|
}
|
|
|
|
/* We don't use these ourselves, but we add them to be nice RSS/XML citizens */
|
|
$actobj->extra[] = array('startdate',
|
|
array('xmlns' => 'http://purl.org/rss/1.0/plugins/event/'),
|
|
common_date_iso8601($this->start_time));
|
|
$actobj->extra[] = array('enddate',
|
|
array('xmlns' => 'http://purl.org/rss/1.0/plugins/event/'),
|
|
common_date_iso8601($this->end_time));
|
|
$actobj->extra[] = array('location',
|
|
array('xmlns' => 'http://purl.org/rss/1.0/plugins/event/'),
|
|
$this->location);
|
|
|
|
return $actobj;
|
|
}
|
|
}
|