File.php 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763
  1. <?php
  2. /*
  3. * StatusNet - the distributed open-source microblogging tool
  4. * Copyright (C) 2008, 2009, StatusNet, Inc.
  5. *
  6. * This program is free software: you can redistribute it and/or modify
  7. * it under the terms of the GNU Affero General Public License as published by
  8. * the Free Software Foundation, either version 3 of the License, or
  9. * (at your option) any later version.
  10. *
  11. * This program is distributed in the hope that it will be useful,
  12. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14. * GNU Affero General Public License for more details.
  15. *
  16. * You should have received a copy of the GNU Affero General Public License
  17. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  18. */
  19. if (!defined('GNUSOCIAL')) { exit(1); }
  20. /**
  21. * Table Definition for file
  22. */
  23. class File extends Managed_DataObject
  24. {
  25. public $__table = 'file'; // table name
  26. public $id; // int(4) primary_key not_null
  27. public $urlhash; // varchar(64) unique_key
  28. public $url; // text
  29. public $filehash; // varchar(64) indexed
  30. public $mimetype; // varchar(50)
  31. public $size; // int(4)
  32. public $title; // text()
  33. public $date; // int(4)
  34. public $protected; // int(4)
  35. public $filename; // text()
  36. public $width; // int(4)
  37. public $height; // int(4)
  38. public $modified; // timestamp() not_null default_CURRENT_TIMESTAMP
  39. const URLHASH_ALG = 'sha256';
  40. const FILEHASH_ALG = 'sha256';
  41. public static function schemaDef()
  42. {
  43. return array(
  44. 'fields' => array(
  45. 'id' => array('type' => 'serial', 'not null' => true),
  46. 'urlhash' => array('type' => 'varchar', 'length' => 64, 'not null' => true, 'description' => 'sha256 of destination URL (url field)'),
  47. 'url' => array('type' => 'text', 'description' => 'destination URL after following possible redirections'),
  48. 'filehash' => array('type' => 'varchar', 'length' => 64, 'not null' => false, 'description' => 'sha256 of the file contents, only for locally stored files of course'),
  49. 'mimetype' => array('type' => 'varchar', 'length' => 50, 'description' => 'mime type of resource'),
  50. 'size' => array('type' => 'int', 'description' => 'size of resource when available'),
  51. 'title' => array('type' => 'text', 'description' => 'title of resource when available'),
  52. 'date' => array('type' => 'int', 'description' => 'date of resource according to http query'),
  53. 'protected' => array('type' => 'int', 'description' => 'true when URL is private (needs login)'),
  54. 'filename' => array('type' => 'text', 'description' => 'if file is stored locally (too) this is the filename'),
  55. 'width' => array('type' => 'int', 'description' => 'width in pixels, if it can be described as such and data is available'),
  56. 'height' => array('type' => 'int', 'description' => 'height in pixels, if it can be described as such and data is available'),
  57. 'modified' => array('type' => 'timestamp', 'not null' => true, 'description' => 'date this record was modified'),
  58. ),
  59. 'primary key' => array('id'),
  60. 'unique keys' => array(
  61. 'file_urlhash_key' => array('urlhash'),
  62. ),
  63. 'indexes' => array(
  64. 'file_filehash_idx' => array('filehash'),
  65. ),
  66. );
  67. }
  68. public static function isProtected($url) {
  69. $protected_urls_exps = array(
  70. 'https://www.facebook.com/login.php',
  71. common_path('main/login')
  72. );
  73. foreach ($protected_urls_exps as $protected_url_exp) {
  74. if (preg_match('!^'.preg_quote($protected_url_exp).'(.*)$!i', $url) === 1) {
  75. return true;
  76. }
  77. }
  78. return false;
  79. }
  80. /**
  81. * Save a new file record.
  82. *
  83. * @param array $redir_data lookup data eg from File_redirection::where()
  84. * @param string $given_url
  85. * @return File
  86. */
  87. public static function saveNew(array $redir_data, $given_url)
  88. {
  89. $file = null;
  90. try {
  91. // I don't know why we have to keep doing this but we run a last check to avoid
  92. // uniqueness bugs.
  93. $file = File::getByUrl($given_url);
  94. return $file;
  95. } catch (NoResultException $e) {
  96. // We don't have the file's URL since before, so let's continue.
  97. }
  98. // if the given url is an local attachment url and the id already exists, don't
  99. // save a new file record. This should never happen, but let's make it foolproof
  100. // FIXME: how about attachments servers?
  101. $u = parse_url($given_url);
  102. if (isset($u['host']) && $u['host'] === common_config('site', 'server')) {
  103. $r = Router::get();
  104. // Skip the / in the beginning or $r->map won't match
  105. try {
  106. $args = $r->map(mb_substr($u['path'], 1));
  107. if ($args['action'] === 'attachment') {
  108. try {
  109. // $args['attachment'] should always be set if action===attachment, given our routing rules
  110. $file = File::getByID($args['attachment']);
  111. return $file;
  112. } catch (EmptyIdException $e) {
  113. // ...but $args['attachment'] can also be 0...
  114. } catch (NoResultException $e) {
  115. // apparently this link goes to us, but is _not_ an existing attachment (File) ID?
  116. }
  117. }
  118. } catch (Exception $e) {
  119. // Some other exception was thrown from $r->map, likely a
  120. // ClientException (404) because of some malformed link to
  121. // our own instance. It's still a valid URL however, so we
  122. // won't abort anything... I noticed this when linking:
  123. // https://social.umeahackerspace.se/mmn/foaf' (notice the
  124. // apostrophe in the end, making it unrecognizable for our
  125. // URL routing.
  126. // That specific issue (the apostrophe being part of a link
  127. // is something that may or may not have been fixed since,
  128. // in lib/util.php in common_replace_urls_callback().
  129. }
  130. }
  131. $file = new File;
  132. $file->url = $given_url;
  133. if (!empty($redir_data['protected'])) $file->protected = $redir_data['protected'];
  134. if (!empty($redir_data['title'])) $file->title = $redir_data['title'];
  135. if (!empty($redir_data['type'])) $file->mimetype = $redir_data['type'];
  136. if (!empty($redir_data['size'])) $file->size = intval($redir_data['size']);
  137. if (isset($redir_data['time']) && $redir_data['time'] > 0) $file->date = intval($redir_data['time']);
  138. $file->saveFile();
  139. return $file;
  140. }
  141. public function saveFile() {
  142. $this->urlhash = self::hashurl($this->url);
  143. if (!Event::handle('StartFileSaveNew', array(&$this))) {
  144. throw new ServerException('File not saved due to an aborted StartFileSaveNew event.');
  145. }
  146. $this->id = $this->insert();
  147. if ($this->id === false) {
  148. throw new ServerException('File/URL metadata could not be saved to the database.');
  149. }
  150. Event::handle('EndFileSaveNew', array($this));
  151. }
  152. /**
  153. * Go look at a URL and possibly save data about it if it's new:
  154. * - follow redirect chains and store them in file_redirection
  155. * - if a thumbnail is available, save it in file_thumbnail
  156. * - save file record with basic info
  157. * - optionally save a file_to_post record
  158. * - return the File object with the full reference
  159. *
  160. * @param string $given_url the URL we're looking at
  161. * @param Notice $notice (optional)
  162. * @param bool $followRedirects defaults to true
  163. *
  164. * @return mixed File on success, -1 on some errors
  165. *
  166. * @throws ServerException on failure
  167. */
  168. public static function processNew($given_url, Notice $notice=null, $followRedirects=true) {
  169. if (empty($given_url)) {
  170. throw new ServerException('No given URL to process');
  171. }
  172. $given_url = File_redirection::_canonUrl($given_url);
  173. if (empty($given_url)) {
  174. throw new ServerException('No canonical URL from given URL to process');
  175. }
  176. $redir = File_redirection::where($given_url);
  177. $file = $redir->getFile();
  178. if (!$file instanceof File || empty($file->id)) {
  179. // This should not happen
  180. throw new ServerException('URL processing failed without new File object');
  181. }
  182. if ($notice instanceof Notice) {
  183. File_to_post::processNew($file, $notice);
  184. }
  185. return $file;
  186. }
  187. public static function respectsQuota(Profile $scoped, $fileSize) {
  188. if ($fileSize > common_config('attachments', 'file_quota')) {
  189. // TRANS: Message used to be inserted as %2$s in the text "No file may
  190. // TRANS: be larger than %1$d byte and the file you sent was %2$s.".
  191. // TRANS: %1$d is the number of bytes of an uploaded file.
  192. $fileSizeText = sprintf(_m('%1$d byte','%1$d bytes',$fileSize),$fileSize);
  193. $fileQuota = common_config('attachments', 'file_quota');
  194. // TRANS: Message given if an upload is larger than the configured maximum.
  195. // TRANS: %1$d (used for plural) is the byte limit for uploads,
  196. // TRANS: %2$s is the proper form of "n bytes". This is the only ways to have
  197. // TRANS: gettext support multiple plurals in the same message, unfortunately...
  198. throw new ClientException(
  199. sprintf(_m('No file may be larger than %1$d byte and the file you sent was %2$s. Try to upload a smaller version.',
  200. 'No file may be larger than %1$d bytes and the file you sent was %2$s. Try to upload a smaller version.',
  201. $fileQuota),
  202. $fileQuota, $fileSizeText));
  203. }
  204. $file = new File;
  205. $query = "select sum(size) as total from file join file_to_post on file_to_post.file_id = file.id join notice on file_to_post.post_id = notice.id where profile_id = {$scoped->id} and file.url like '%/notice/%/file'";
  206. $file->query($query);
  207. $file->fetch();
  208. $total = $file->total + $fileSize;
  209. if ($total > common_config('attachments', 'user_quota')) {
  210. // TRANS: Message given if an upload would exceed user quota.
  211. // TRANS: %d (number) is the user quota in bytes and is used for plural.
  212. throw new ClientException(
  213. sprintf(_m('A file this large would exceed your user quota of %d byte.',
  214. 'A file this large would exceed your user quota of %d bytes.',
  215. common_config('attachments', 'user_quota')),
  216. common_config('attachments', 'user_quota')));
  217. }
  218. $query .= ' AND EXTRACT(month FROM file.modified) = EXTRACT(month FROM now()) and EXTRACT(year FROM file.modified) = EXTRACT(year FROM now())';
  219. $file->query($query);
  220. $file->fetch();
  221. $total = $file->total + $fileSize;
  222. if ($total > common_config('attachments', 'monthly_quota')) {
  223. // TRANS: Message given id an upload would exceed a user's monthly quota.
  224. // TRANS: $d (number) is the monthly user quota in bytes and is used for plural.
  225. throw new ClientException(
  226. sprintf(_m('A file this large would exceed your monthly quota of %d byte.',
  227. 'A file this large would exceed your monthly quota of %d bytes.',
  228. common_config('attachments', 'monthly_quota')),
  229. common_config('attachments', 'monthly_quota')));
  230. }
  231. return true;
  232. }
  233. public function getFilename()
  234. {
  235. return self::tryFilename($this->filename);
  236. }
  237. // where should the file go?
  238. static function filename(Profile $profile, $origname, $mimetype)
  239. {
  240. $ext = self::guessMimeExtension($mimetype, $origname);
  241. // Normalize and make the original filename more URL friendly.
  242. $origname = basename($origname, ".$ext");
  243. if (class_exists('Normalizer')) {
  244. // http://php.net/manual/en/class.normalizer.php
  245. // http://www.unicode.org/reports/tr15/
  246. $origname = Normalizer::normalize($origname, Normalizer::FORM_KC);
  247. }
  248. $origname = preg_replace('/[^A-Za-z0-9\.\_]/', '_', $origname);
  249. $nickname = $profile->getNickname();
  250. $datestamp = strftime('%Y%m%d', time());
  251. do {
  252. // generate new random strings until we don't run into a filename collision.
  253. $random = strtolower(common_confirmation_code(16));
  254. $filename = "$nickname-$datestamp-$origname-$random.$ext";
  255. } while (file_exists(self::path($filename)));
  256. return $filename;
  257. }
  258. /**
  259. * @param $mimetype The mimetype we've discovered for this file.
  260. * @param $filename An optional filename which we can use on failure.
  261. */
  262. static function guessMimeExtension($mimetype, $filename=null)
  263. {
  264. try {
  265. // first see if we know the extension for our mimetype
  266. $ext = common_supported_mime_to_ext($mimetype);
  267. // we do, so use it!
  268. return $ext;
  269. } catch (Exception $e) { // FIXME: Make this exception more specific to "unknown mime=>ext relation"
  270. // We don't know the extension for this mimetype, but let's guess.
  271. // If we are very liberal with uploads ($config['attachments']['supported'] === true)
  272. // then we try to do some guessing based on the filename, if it was supplied.
  273. if (!is_null($filename) && common_config('attachments', 'supported')===true
  274. && preg_match('/^.+\.([A-Za-z0-9]+)$/', $filename, $matches)) {
  275. // we matched on a file extension, so let's see if it means something.
  276. $ext = mb_strtolower($matches[1]);
  277. $blacklist = common_config('attachments', 'extblacklist');
  278. // If we got an extension from $filename we want to check if it's in a blacklist
  279. // so we avoid people uploading .php files etc.
  280. if (array_key_exists($ext, $blacklist)) {
  281. if (!is_string($blacklist[$ext])) {
  282. // we don't have a safe replacement extension
  283. throw new ClientException(_('Blacklisted file extension.'));
  284. }
  285. common_debug('Found replaced extension for filename '._ve($filename).': '._ve($ext));
  286. // return a safe replacement extension ('php' => 'phps' for example)
  287. return $blacklist[$ext];
  288. }
  289. // the attachment extension based on its filename was not blacklisted so it's ok to use it
  290. return $ext;
  291. }
  292. }
  293. // If nothing else has given us a result, try to extract it from
  294. // the mimetype value (this turns .jpg to .jpeg for example...)
  295. $matches = array();
  296. // FIXME: try to build a regexp that will get jpeg from image/jpeg as well as json from application/jrd+json
  297. if (!preg_match('/\/([a-z0-9]+)/', mb_strtolower($mimetype), $matches)) {
  298. throw new Exception('Malformed mimetype: '.$mimetype);
  299. }
  300. return mb_strtolower($matches[1]);
  301. }
  302. /**
  303. * Validation for as-saved base filenames
  304. */
  305. static function validFilename($filename)
  306. {
  307. return preg_match('/^[A-Za-z0-9._-]+$/', $filename);
  308. }
  309. static function tryFilename($filename)
  310. {
  311. if (!self::validFilename($filename))
  312. {
  313. throw new InvalidFilenameException($filename);
  314. }
  315. // if successful, return the filename for easy if-statementing
  316. return $filename;
  317. }
  318. /**
  319. * @throws ClientException on invalid filename
  320. */
  321. static function path($filename)
  322. {
  323. self::tryFilename($filename);
  324. $dir = common_config('attachments', 'dir');
  325. if (!in_array($dir[mb_strlen($dir)-1], ['/', '\\'])) {
  326. $dir .= DIRECTORY_SEPARATOR;
  327. }
  328. return $dir . $filename;
  329. }
  330. static function url($filename)
  331. {
  332. self::tryFilename($filename);
  333. if (common_config('site','private')) {
  334. return common_local_url('getfile',
  335. array('filename' => $filename));
  336. }
  337. if (GNUsocial::useHTTPS()) {
  338. $sslserver = common_config('attachments', 'sslserver');
  339. if (empty($sslserver)) {
  340. // XXX: this assumes that background dir == site dir + /file/
  341. // not true if there's another server
  342. if (is_string(common_config('site', 'sslserver')) &&
  343. mb_strlen(common_config('site', 'sslserver')) > 0) {
  344. $server = common_config('site', 'sslserver');
  345. } else if (common_config('site', 'server')) {
  346. $server = common_config('site', 'server');
  347. }
  348. $path = common_config('site', 'path') . '/file/';
  349. } else {
  350. $server = $sslserver;
  351. $path = common_config('attachments', 'sslpath');
  352. if (empty($path)) {
  353. $path = common_config('attachments', 'path');
  354. }
  355. }
  356. $protocol = 'https';
  357. } else {
  358. $path = common_config('attachments', 'path');
  359. $server = common_config('attachments', 'server');
  360. if (empty($server)) {
  361. $server = common_config('site', 'server');
  362. }
  363. $ssl = common_config('attachments', 'ssl');
  364. $protocol = ($ssl) ? 'https' : 'http';
  365. }
  366. if ($path[strlen($path)-1] != '/') {
  367. $path .= '/';
  368. }
  369. if ($path[0] != '/') {
  370. $path = '/'.$path;
  371. }
  372. return $protocol.'://'.$server.$path.$filename;
  373. }
  374. static $_enclosures = array();
  375. function getEnclosure(){
  376. if (isset(self::$_enclosures[$this->getID()])) {
  377. return self::$_enclosures[$this->getID()];
  378. }
  379. $enclosure = (object) array();
  380. foreach (array('title', 'url', 'date', 'modified', 'size', 'mimetype', 'width', 'height') as $key) {
  381. if ($this->$key !== '') {
  382. $enclosure->$key = $this->$key;
  383. }
  384. }
  385. $needMoreMetadataMimetypes = array(null, 'application/xhtml+xml', 'text/html');
  386. if (!isset($this->filename) && in_array(common_bare_mime($enclosure->mimetype), $needMoreMetadataMimetypes)) {
  387. // This fetches enclosure metadata for non-local links with unset/HTML mimetypes,
  388. // which may be enriched through oEmbed or similar (implemented as plugins)
  389. Event::handle('FileEnclosureMetadata', array($this, &$enclosure));
  390. }
  391. if (empty($enclosure->mimetype)) {
  392. // This means we either don't know what it is, so it can't
  393. // be shown as an enclosure, or it is an HTML link which
  394. // does not link to a resource with further metadata.
  395. throw new ServerException('Unknown enclosure mimetype, not enough metadata');
  396. }
  397. self::$_enclosures[$this->getID()] = $enclosure;
  398. return $enclosure;
  399. }
  400. public function hasThumbnail()
  401. {
  402. try {
  403. $this->getThumbnail();
  404. } catch (Exception $e) {
  405. return false;
  406. }
  407. return true;
  408. }
  409. /**
  410. * Get the attachment's thumbnail record, if any.
  411. * Make sure you supply proper 'int' typed variables (or null).
  412. *
  413. * @param $width int Max width of thumbnail in pixels. (if null, use common_config values)
  414. * @param $height int Max height of thumbnail in pixels. (if null, square-crop to $width)
  415. * @param $crop bool Crop to the max-values' aspect ratio
  416. * @param $force_still bool Don't allow fallback to showing original (such as animated GIF)
  417. * @param $upscale mixed Whether or not to scale smaller images up to larger thumbnail sizes. (null = site default)
  418. *
  419. * @return File_thumbnail
  420. *
  421. * @throws UseFileAsThumbnailException if the file is considered an image itself and should be itself as thumbnail
  422. * @throws UnsupportedMediaException if, despite trying, we can't understand how to make a thumbnail for this format
  423. * @throws ServerException on various other errors
  424. */
  425. public function getThumbnail($width=null, $height=null, $crop=false, $force_still=true, $upscale=null)
  426. {
  427. // Get some more information about this file through our ImageFile class
  428. $image = ImageFile::fromFileObject($this);
  429. if ($image->animated && !common_config('thumbnail', 'animated')) {
  430. // null means "always use file as thumbnail"
  431. // false means you get choice between frozen frame or original when calling getThumbnail
  432. if (is_null(common_config('thumbnail', 'animated')) || !$force_still) {
  433. try {
  434. // remote files with animated GIFs as thumbnails will match this
  435. return File_thumbnail::byFile($this);
  436. } catch (NoResultException $e) {
  437. // and if it's not a remote file, it'll be safe to use the locally stored File
  438. throw new UseFileAsThumbnailException($this);
  439. }
  440. }
  441. }
  442. return $image->getFileThumbnail($width, $height, $crop,
  443. !is_null($upscale) ? $upscale : common_config('thumbnail', 'upscale'));
  444. }
  445. public function getPath()
  446. {
  447. $filepath = self::path($this->filename);
  448. if (!file_exists($filepath)) {
  449. throw new FileNotFoundException($filepath);
  450. }
  451. return $filepath;
  452. }
  453. public function getAttachmentUrl()
  454. {
  455. return common_local_url('attachment', array('attachment'=>$this->getID()));
  456. }
  457. public function getUrl($prefer_local=true)
  458. {
  459. if ($prefer_local && !empty($this->filename)) {
  460. // A locally stored file, so let's generate a URL for our instance.
  461. return self::url($this->getFilename());
  462. }
  463. // No local filename available, return the URL we have stored
  464. return $this->url;
  465. }
  466. static public function getByUrl($url)
  467. {
  468. $file = new File();
  469. $file->urlhash = self::hashurl($url);
  470. if (!$file->find(true)) {
  471. throw new NoResultException($file);
  472. }
  473. return $file;
  474. }
  475. /**
  476. * @param string $hashstr String of (preferrably lower case) hexadecimal characters, same as result of 'hash_file(...)'
  477. */
  478. static public function getByHash($hashstr)
  479. {
  480. $file = new File();
  481. $file->filehash = strtolower($hashstr);
  482. if (!$file->find(true)) {
  483. throw new NoResultException($file);
  484. }
  485. return $file;
  486. }
  487. public function updateUrl($url)
  488. {
  489. $file = File::getKV('urlhash', self::hashurl($url));
  490. if ($file instanceof File) {
  491. throw new ServerException('URL already exists in DB');
  492. }
  493. $sql = 'UPDATE %1$s SET urlhash=%2$s, url=%3$s WHERE urlhash=%4$s;';
  494. $result = $this->query(sprintf($sql, $this->tableName(),
  495. $this->_quote((string)self::hashurl($url)),
  496. $this->_quote((string)$url),
  497. $this->_quote((string)$this->urlhash)));
  498. if ($result === false) {
  499. common_log_db_error($this, 'UPDATE', __FILE__);
  500. throw new ServerException("Could not UPDATE {$this->tableName()}.url");
  501. }
  502. return $result;
  503. }
  504. /**
  505. * Blow the cache of notices that link to this URL
  506. *
  507. * @param boolean $last Whether to blow the "last" cache too
  508. *
  509. * @return void
  510. */
  511. function blowCache($last=false)
  512. {
  513. self::blow('file:notice-ids:%s', $this->id);
  514. if ($last) {
  515. self::blow('file:notice-ids:%s;last', $this->id);
  516. }
  517. self::blow('file:notice-count:%d', $this->id);
  518. }
  519. /**
  520. * Stream of notices linking to this URL
  521. *
  522. * @param integer $offset Offset to show; default is 0
  523. * @param integer $limit Limit of notices to show
  524. * @param integer $since_id Since this notice
  525. * @param integer $max_id Before this notice
  526. *
  527. * @return array ids of notices that link to this file
  528. */
  529. function stream($offset=0, $limit=NOTICES_PER_PAGE, $since_id=0, $max_id=0)
  530. {
  531. // FIXME: Try to get the Profile::current() here in some other way to avoid mixing
  532. // the current session user with possibly background/queue processing.
  533. $stream = new FileNoticeStream($this, Profile::current());
  534. return $stream->getNotices($offset, $limit, $since_id, $max_id);
  535. }
  536. function noticeCount()
  537. {
  538. $cacheKey = sprintf('file:notice-count:%d', $this->id);
  539. $count = self::cacheGet($cacheKey);
  540. if ($count === false) {
  541. $f2p = new File_to_post();
  542. $f2p->file_id = $this->id;
  543. $count = $f2p->count();
  544. self::cacheSet($cacheKey, $count);
  545. }
  546. return $count;
  547. }
  548. public function isLocal()
  549. {
  550. return !empty($this->filename);
  551. }
  552. public function delete($useWhere=false)
  553. {
  554. // Delete the file, if it exists locally
  555. if (!empty($this->filename) && file_exists(self::path($this->filename))) {
  556. $deleted = @unlink(self::path($this->filename));
  557. if (!$deleted) {
  558. common_log(LOG_ERR, sprintf('Could not unlink existing file: "%s"', self::path($this->filename)));
  559. }
  560. }
  561. // Clear out related things in the database and filesystem, such as thumbnails
  562. if (Event::handle('FileDeleteRelated', array($this))) {
  563. $thumbs = new File_thumbnail();
  564. $thumbs->file_id = $this->id;
  565. if ($thumbs->find()) {
  566. while ($thumbs->fetch()) {
  567. $thumbs->delete();
  568. }
  569. }
  570. $f2p = new File_to_post();
  571. $f2p->file_id = $this->id;
  572. if ($f2p->find()) {
  573. while ($f2p->fetch()) {
  574. $f2p->delete();
  575. }
  576. }
  577. }
  578. // And finally remove the entry from the database
  579. return parent::delete($useWhere);
  580. }
  581. public function getTitle()
  582. {
  583. $title = $this->title ?: $this->filename;
  584. return $title ?: null;
  585. }
  586. static public function hashurl($url)
  587. {
  588. if (empty($url)) {
  589. throw new Exception('No URL provided to hash algorithm.');
  590. }
  591. return hash(self::URLHASH_ALG, $url);
  592. }
  593. static public function beforeSchemaUpdate()
  594. {
  595. $table = strtolower(get_called_class());
  596. $schema = Schema::get();
  597. $schemadef = $schema->getTableDef($table);
  598. // 2015-02-19 We have to upgrade our table definitions to have the urlhash field populated
  599. if (isset($schemadef['fields']['urlhash']) && isset($schemadef['unique keys']['file_urlhash_key'])) {
  600. // We already have the urlhash field, so no need to migrate it.
  601. return;
  602. }
  603. echo "\nFound old $table table, upgrading it to contain 'urlhash' field...";
  604. $file = new File();
  605. $file->query(sprintf('SELECT id, LEFT(url, 191) AS shortenedurl, COUNT(*) AS c FROM %1$s WHERE LENGTH(url)>191 GROUP BY shortenedurl HAVING c > 1', $schema->quoteIdentifier($table)));
  606. print "\nFound {$file->N} URLs with too long entries in file table\n";
  607. while ($file->fetch()) {
  608. // We've got a URL that is too long for our future file table
  609. // so we'll cut it. We could save the original URL, but there is
  610. // no guarantee it is complete anyway since the previous max was 255 chars.
  611. $dupfile = new File();
  612. // First we find file entries that would be duplicates of this when shortened
  613. // ... and we'll just throw the dupes out the window for now! It's already so borken.
  614. $dupfile->query(sprintf('SELECT * FROM file WHERE LEFT(url, 191) = "%1$s"', $file->shortenedurl));
  615. // Leave one of the URLs in the database by using ->find(true) (fetches first entry)
  616. if ($dupfile->find(true)) {
  617. print "\nShortening url entry for $table id: {$file->id} [";
  618. $orig = clone($dupfile);
  619. $dupfile->url = $file->shortenedurl; // make sure it's only 191 chars from now on
  620. $dupfile->update($orig);
  621. print "\nDeleting duplicate entries of too long URL on $table id: {$file->id} [";
  622. // only start deleting with this fetch.
  623. while($dupfile->fetch()) {
  624. print ".";
  625. $dupfile->delete();
  626. }
  627. print "]\n";
  628. } else {
  629. print "\nWarning! URL suddenly disappeared from database: {$file->url}\n";
  630. }
  631. }
  632. echo "...and now all the non-duplicates which are longer than 191 characters...\n";
  633. $file->query('UPDATE file SET url=LEFT(url, 191) WHERE LENGTH(url)>191');
  634. echo "\n...now running hacky pre-schemaupdate change for $table:";
  635. // We have to create a urlhash that is _not_ the primary key,
  636. // transfer data and THEN run checkSchema
  637. $schemadef['fields']['urlhash'] = array (
  638. 'type' => 'varchar',
  639. 'length' => 64,
  640. 'not null' => false, // this is because when adding column, all entries will _be_ NULL!
  641. 'description' => 'sha256 of destination URL (url field)',
  642. );
  643. $schemadef['fields']['url'] = array (
  644. 'type' => 'text',
  645. 'description' => 'destination URL after following possible redirections',
  646. );
  647. unset($schemadef['unique keys']);
  648. $schema->ensureTable($table, $schemadef);
  649. echo "DONE.\n";
  650. $classname = ucfirst($table);
  651. $tablefix = new $classname;
  652. // urlhash is hash('sha256', $url) in the File table
  653. echo "Updating urlhash fields in $table table...";
  654. // Maybe very MySQL specific :(
  655. $tablefix->query(sprintf('UPDATE %1$s SET %2$s=%3$s;',
  656. $schema->quoteIdentifier($table),
  657. 'urlhash',
  658. // The line below is "result of sha256 on column `url`"
  659. 'SHA2(url, 256)'));
  660. echo "DONE.\n";
  661. echo "Resuming core schema upgrade...";
  662. }
  663. }