Page Menu
Home
Phabricator
Search
Configure Global Search
Log In
Files
F15407524
D21816.diff
No One
Temporary
Actions
View File
Edit File
Delete File
View Transforms
Subscribe
Mute Notifications
Award Token
Flag For Later
Size
14 KB
Referenced Files
None
Subscribers
None
D21816.diff
View Options
diff --git a/src/applications/files/storage/PhabricatorFile.php b/src/applications/files/storage/PhabricatorFile.php
--- a/src/applications/files/storage/PhabricatorFile.php
+++ b/src/applications/files/storage/PhabricatorFile.php
@@ -1422,6 +1422,26 @@
->addEdge($phid, $edge_type, $this->getPHID())
->save();
+ $attachment_table = new PhabricatorFileAttachment();
+ $attachment_conn = $attachment_table->establishConnection('w');
+
+ queryfx(
+ $attachment_conn,
+ 'INSERT INTO %R (objectPHID, filePHID, attachmentMode,
+ attacherPHID, dateCreated, dateModified)
+ VALUES (%s, %s, %s, %ns, %d, %d)
+ ON DUPLICATE KEY UPDATE
+ attachmentMode = VALUES(attachmentMode),
+ attacherPHID = VALUES(attacherPHID),
+ dateModified = VALUES(dateModified)',
+ $attachment_table,
+ $phid,
+ $this->getPHID(),
+ PhabricatorFileAttachment::MODE_ATTACH,
+ null,
+ PhabricatorTime::getNow(),
+ PhabricatorTime::getNow());
+
return $this;
}
diff --git a/src/applications/files/storage/PhabricatorFileAttachment.php b/src/applications/files/storage/PhabricatorFileAttachment.php
--- a/src/applications/files/storage/PhabricatorFileAttachment.php
+++ b/src/applications/files/storage/PhabricatorFileAttachment.php
@@ -8,6 +8,10 @@
protected $attacherPHID;
protected $attachmentMode;
+ const MODE_ATTACH = 'attach';
+ const MODE_REFERENCE = 'reference';
+ const MODE_DETACH = 'detach';
+
protected function getConfiguration() {
return array(
self::CONFIG_COLUMN_SCHEMA => array(
@@ -28,4 +32,12 @@
) + parent::getConfiguration();
}
+ public static function getModeList() {
+ return array(
+ self::MODE_ATTACH,
+ self::MODE_REFERENCE,
+ self::MODE_DETACH,
+ );
+ }
+
}
diff --git a/src/applications/transactions/constants/PhabricatorTransactions.php b/src/applications/transactions/constants/PhabricatorTransactions.php
--- a/src/applications/transactions/constants/PhabricatorTransactions.php
+++ b/src/applications/transactions/constants/PhabricatorTransactions.php
@@ -18,6 +18,7 @@
const TYPE_SUBTYPE = 'core:subtype';
const TYPE_HISTORY = 'core:history';
const TYPE_MFA = 'core:mfa';
+ const TYPE_FILE = 'core:file';
const COLOR_RED = 'red';
const COLOR_ORANGE = 'orange';
diff --git a/src/applications/transactions/editor/PhabricatorApplicationTransactionEditor.php b/src/applications/transactions/editor/PhabricatorApplicationTransactionEditor.php
--- a/src/applications/transactions/editor/PhabricatorApplicationTransactionEditor.php
+++ b/src/applications/transactions/editor/PhabricatorApplicationTransactionEditor.php
@@ -332,6 +332,8 @@
$types[] = PhabricatorTransactions::TYPE_CREATE;
$types[] = PhabricatorTransactions::TYPE_HISTORY;
+ $types[] = PhabricatorTransactions::TYPE_FILE;
+
if ($this->object instanceof PhabricatorEditEngineSubtypeInterface) {
$types[] = PhabricatorTransactions::TYPE_SUBTYPE;
}
@@ -388,6 +390,84 @@
$new = $this->getTransactionNewValue($object, $xaction);
$xaction->setNewValue($new);
+
+ // Apply an optional transformation to convert "external" tranaction
+ // values (provided by APIs) into "internal" values.
+
+ $old = $xaction->getOldValue();
+ $new = $xaction->getNewValue();
+
+ $type = $xaction->getTransactionType();
+ $xtype = $this->getModularTransactionType($type);
+ if ($xtype) {
+ $xtype = clone $xtype;
+ $xtype->setStorage($xaction);
+
+
+ // TODO: Provide a modular hook for modern transactions to do a
+ // transformation.
+ list($old, $new) = array($old, $new);
+
+ return;
+ } else {
+ switch ($type) {
+ case PhabricatorTransactions::TYPE_FILE:
+ list($old, $new) = $this->newFileTransactionInternalValues(
+ $object,
+ $xaction,
+ $old,
+ $new);
+ break;
+ }
+ }
+
+ $xaction->setOldValue($old);
+ $xaction->setNewValue($new);
+ }
+
+ private function newFileTransactionInternalValues(
+ PhabricatorLiskDAO $object,
+ PhabricatorApplicationTransaction $xaction,
+ $old,
+ $new) {
+
+ $old_map = array();
+
+ if (!$this->getIsNewObject()) {
+ $phid = $object->getPHID();
+
+ $attachment_table = new PhabricatorFileAttachment();
+ $attachment_conn = $attachment_table->establishConnection('w');
+
+ $rows = queryfx_all(
+ $attachment_conn,
+ 'SELECT filePHID, attachmentMode FROM %R WHERE objectPHID = %s',
+ $attachment_table,
+ $phid);
+ $old_map = ipull($rows, 'attachmentMode', 'filePHID');
+ }
+
+ $new_map = $old_map;
+
+ foreach ($new as $file_phid => $attachment_mode) {
+ if ($attachment_mode == PhabricatorFileAttachment::MODE_DETACH) {
+ unset($new_map[$file_phid]);
+ continue;
+ }
+
+ $new_map[$file_phid] = $attachment_mode;
+ }
+
+ foreach (array_keys($old_map + $new_map) as $key) {
+ if (isset($old_map[$key]) && isset($new_map[$key])) {
+ if ($old_map[$key] === $new_map[$key]) {
+ unset($old_map[$key]);
+ unset($new_map[$key]);
+ }
+ }
+ }
+
+ return array($old_map, $new_map);
}
private function getTransactionOldValue(
@@ -481,6 +561,8 @@
return $xaction->getOldValue();
case PhabricatorTransactions::TYPE_COMMENT:
return null;
+ case PhabricatorTransactions::TYPE_FILE:
+ return null;
default:
return $this->getCustomTransactionOldValue($object, $xaction);
}
@@ -512,6 +594,7 @@
case PhabricatorTransactions::TYPE_INLINESTATE:
case PhabricatorTransactions::TYPE_SUBTYPE:
case PhabricatorTransactions::TYPE_HISTORY:
+ case PhabricatorTransactions::TYPE_FILE:
return $xaction->getNewValue();
case PhabricatorTransactions::TYPE_MFA:
return true;
@@ -670,6 +753,7 @@
case PhabricatorTransactions::TYPE_EDGE:
case PhabricatorTransactions::TYPE_SPACE:
case PhabricatorTransactions::TYPE_COMMENT:
+ case PhabricatorTransactions::TYPE_FILE:
return $this->applyBuiltinInternalTransaction($object, $xaction);
}
@@ -733,6 +817,7 @@
case PhabricatorTransactions::TYPE_INLINESTATE:
case PhabricatorTransactions::TYPE_SPACE:
case PhabricatorTransactions::TYPE_COMMENT:
+ case PhabricatorTransactions::TYPE_FILE:
return $this->applyBuiltinExternalTransaction($object, $xaction);
}
@@ -857,6 +942,81 @@
case PhabricatorTransactions::TYPE_HISTORY:
$this->sendHistory = true;
break;
+ case PhabricatorTransactions::TYPE_FILE:
+ $this->applyFileTransaction($object, $xaction);
+ break;
+ }
+ }
+
+ private function applyFileTransaction(
+ PhabricatorLiskDAO $object,
+ PhabricatorApplicationTransaction $xaction) {
+
+ $old_map = $xaction->getOldValue();
+ $new_map = $xaction->getNewValue();
+
+ $add_phids = array();
+ $rem_phids = array();
+
+ foreach ($new_map as $phid => $mode) {
+ $add_phids[$phid] = $mode;
+ }
+
+ foreach ($old_map as $phid => $mode) {
+ if (!isset($new_map[$phid])) {
+ $rem_phids[] = $phid;
+ }
+ }
+
+ $now = PhabricatorTime::getNow();
+ $object_phid = $object->getPHID();
+ $attacher_phid = $this->getActingAsPHID();
+
+ $attachment_table = new PhabricatorFileAttachment();
+ $attachment_conn = $attachment_table->establishConnection('w');
+
+ $add_sql = array();
+ foreach ($add_phids as $add_phid => $add_mode) {
+ $add_sql[] = qsprintf(
+ $attachment_conn,
+ '(%s, %s, %s, %ns, %d, %d)',
+ $object_phid,
+ $add_phid,
+ $add_mode,
+ $attacher_phid,
+ $now,
+ $now);
+ }
+
+ $rem_sql = array();
+ foreach ($rem_phids as $rem_phid) {
+ $rem_sql[] = qsprintf(
+ $attachment_conn,
+ '%s',
+ $rem_phid);
+ }
+
+ foreach (PhabricatorLiskDAO::chunkSQL($add_sql) as $chunk) {
+ queryfx(
+ $attachment_conn,
+ 'INSERT INTO %R (objectPHID, filePHID, attachmentMode,
+ attacherPHID, dateCreated, dateModified)
+ VALUES %LQ
+ ON DUPLICATE KEY UPDATE
+ attachmentMode = VALUES(attachmentMode),
+ attacherPHID = VALUES(attacherPHID),
+ dateModified = VALUES(dateModified)',
+ $attachment_table,
+ $chunk);
+ }
+
+ foreach (PhabricatorLiskDAO::chunkSQL($rem_sql) as $chunk) {
+ queryfx(
+ $attachment_conn,
+ 'DELETE FROM %R WHERE objectPHID = %s AND filePHID in (%LQ)',
+ $attachment_table,
+ $object_phid,
+ $chunk);
}
}
@@ -1790,6 +1950,8 @@
// Signing a transaction group with MFA does not require permissions
// on its own.
return null;
+ case PhabricatorTransactions::TYPE_FILE:
+ return null;
case PhabricatorTransactions::TYPE_EDGE:
return $this->getLegacyRequiredEdgeCapabilities($xaction);
default:
@@ -2066,9 +2228,40 @@
$xactions[] = $xaction;
}
+ $file_xaction = $this->newFileTransaction(
+ $object,
+ $xactions);
+ if ($file_xaction) {
+ $xactions[] = $file_xaction;
+ }
+
return $xactions;
}
+
+ private function newFileTransaction(
+ PhabricatorLiskDAO $object,
+ array $xactions) {
+
+ $new_map = array();
+
+ $file_phids = $this->extractFilePHIDs($object, $xactions);
+ if (!$file_phids) {
+ return null;
+ }
+
+ foreach ($file_phids as $file_phid) {
+ $new_map[$file_phid] = PhabricatorFileAttachment::MODE_ATTACH;
+ }
+
+ $xaction = $object->getApplicationTransactionTemplate()
+ ->setTransactionType(PhabricatorTransactions::TYPE_FILE)
+ ->setNewValue($new_map);
+
+ return $xaction;
+ }
+
+
private function getRemarkupChanges(array $xactions) {
$changes = array();
@@ -2667,11 +2860,113 @@
idx($groups, $field->getFieldKey(), array()));
}
break;
+ case PhabricatorTransactions::TYPE_FILE:
+ $errors[] = $this->validateFileTransactions(
+ $object,
+ $xactions,
+ $type);
+ break;
}
return array_mergev($errors);
}
+ private function validateFileTransactions(
+ PhabricatorLiskDAO $object,
+ array $xactions,
+ $transaction_type) {
+
+ $errors = array();
+
+ $mode_map = PhabricatorFileAttachment::getModeList();
+ $mode_map = array_fuse($mode_map);
+
+ $file_phids = array();
+ foreach ($xactions as $xaction) {
+ $new = $xaction->getNewValue();
+
+ if (!is_array($new)) {
+ $errors[] = new PhabricatorApplicationTransactionValidationError(
+ $transaction_type,
+ pht('Invalid'),
+ pht(
+ 'File attachment transaction must have a map of files to '.
+ 'attachment modes, found "%s".',
+ phutil_describe_type($new)),
+ $xaction);
+ continue;
+ }
+
+ foreach ($new as $file_phid => $attachment_mode) {
+ $file_phids[$file_phid] = $file_phid;
+
+ if (is_string($attachment_mode) && isset($mode_map[$attachment_mode])) {
+ continue;
+ }
+
+ if (!is_string($attachment_mode)) {
+ $errors[] = new PhabricatorApplicationTransactionValidationError(
+ $transaction_type,
+ pht('Invalid'),
+ pht(
+ 'File attachment mode (for file "%s") is invalid. Expected '.
+ 'a string, found "%s".',
+ $file_phid,
+ phutil_describe_type($attachment_mode)),
+ $xaction);
+ } else {
+ $errors[] = new PhabricatorApplicationTransactionValidationError(
+ $transaction_type,
+ pht('Invalid'),
+ pht(
+ 'File attachment mode "%s" (for file "%s") is invalid. Valid '.
+ 'modes are: %s.',
+ $attachment_mode,
+ $file_phid,
+ pht_list($mode_map)),
+ $xaction);
+ }
+ }
+ }
+
+ if ($file_phids) {
+ $file_map = id(new PhabricatorFileQuery())
+ ->setViewer($this->getActor())
+ ->withPHIDs($file_phids)
+ ->execute();
+ $file_map = mpull($file_map, null, 'getPHID');
+ } else {
+ $file_map = array();
+ }
+
+ foreach ($xactions as $xaction) {
+ $new = $xaction->getNewValue();
+
+ if (!is_array($new)) {
+ continue;
+ }
+
+ foreach ($new as $file_phid => $attachment_mode) {
+ if (isset($file_map[$file_phid])) {
+ continue;
+ }
+
+ $errors[] = new PhabricatorApplicationTransactionValidationError(
+ $transaction_type,
+ pht('Invalid'),
+ pht(
+ 'File "%s" is invalid: it could not be loaded, or you do not '.
+ 'have permission to view it. You must be able to see a file to '.
+ 'attach it to an object.',
+ $file_phid),
+ $xaction);
+ }
+ }
+
+ return $errors;
+ }
+
+
public function validatePolicyTransaction(
PhabricatorLiskDAO $object,
array $xactions,
diff --git a/src/applications/transactions/storage/PhabricatorApplicationTransaction.php b/src/applications/transactions/storage/PhabricatorApplicationTransaction.php
--- a/src/applications/transactions/storage/PhabricatorApplicationTransaction.php
+++ b/src/applications/transactions/storage/PhabricatorApplicationTransaction.php
@@ -583,6 +583,11 @@
return true;
}
+ // Always hide file attach/detach transactions.
+ if ($xaction_type === PhabricatorTransactions::TYPE_FILE) {
+ return true;
+ }
+
// Hide creation transactions if the old value is empty. These are
// transactions like "alice set the task title to: ...", which are
// essentially never interesting.
@@ -711,7 +716,7 @@
switch ($this->getTransactionType()) {
case PhabricatorTransactions::TYPE_TOKEN:
return true;
- case PhabricatorTransactions::TYPE_EDGE:
+ case PhabricatorTransactions::TYPE_EDGE:
$edge_type = $this->getMetadataValue('edge:type');
switch ($edge_type) {
case PhabricatorObjectMentionsObjectEdgeType::EDGECONST:
File Metadata
Details
Attached
Mime Type
text/plain
Expires
Wed, Mar 19, 6:06 PM (2 w, 3 d ago)
Storage Engine
blob
Storage Format
Encrypted (AES-256-CBC)
Storage Handle
7643274
Default Alt Text
D21816.diff (14 KB)
Attached To
Mode
D21816: Double-write file attachment to old "edge" storage and new "attachment" storage
Attached
Detach File
Event Timeline
Log In to Comment