Page Menu
Home
c4science
Search
Configure Global Search
Log In
Files
F79445306
DifferentialReplyHandler.php
No One
Temporary
Actions
Download File
Edit File
Delete File
View Transforms
Subscribe
Mute Notifications
Award Token
Subscribers
None
File Metadata
Details
File Info
Storage
Attached
Created
Mon, Aug 26, 10:53
Size
5 KB
Mime Type
text/x-php
Expires
Wed, Aug 28, 10:53 (2 d)
Engine
blob
Format
Raw Data
Handle
20184043
Attached To
rPH Phabricator
DifferentialReplyHandler.php
View Options
<?php
class
DifferentialReplyHandler
extends
PhabricatorMailReplyHandler
{
private
$receivedMail
;
public
function
validateMailReceiver
(
$mail_receiver
)
{
if
(!(
$mail_receiver
instanceof
DifferentialRevision
))
{
throw
new
Exception
(
"Receiver is not a DifferentialRevision!"
);
}
}
public
function
getPrivateReplyHandlerEmailAddress
(
PhabricatorObjectHandle
$handle
)
{
return
$this
->
getDefaultPrivateReplyHandlerEmailAddress
(
$handle
,
'D'
);
}
public
function
getPublicReplyHandlerEmailAddress
()
{
return
$this
->
getDefaultPublicReplyHandlerEmailAddress
(
'D'
);
}
public
function
getReplyHandlerDomain
()
{
return
PhabricatorEnv
::
getEnvConfig
(
'metamta.differential.reply-handler-domain'
);
}
/*
* Generate text like the following from the supported commands.
* "
*
* ACTIONS
* Reply to comment, or !accept, !reject, !abandon, !resign, !reclaim.
*
* "
*/
public
function
getReplyHandlerInstructions
()
{
if
(!
$this
->
supportsReplies
())
{
return
null
;
}
$supported_commands
=
$this
->
getSupportedCommands
();
$text
=
''
;
if
(
empty
(
$supported_commands
))
{
return
$text
;
}
$comment_command_printed
=
false
;
if
(
in_array
(
DifferentialAction
::
ACTION_COMMENT
,
$supported_commands
))
{
$text
.=
pht
(
'Reply to comment'
);
$comment_command_printed
=
true
;
$supported_commands
=
array_diff
(
$supported_commands
,
array
(
DifferentialAction
::
ACTION_COMMENT
));
}
if
(!
empty
(
$supported_commands
))
{
if
(
$comment_command_printed
)
{
$text
.=
', or '
;
}
$modified_commands
=
array
();
foreach
(
$supported_commands
as
$command
)
{
$modified_commands
[]
=
'!'
.
$command
;
}
$text
.=
implode
(
', '
,
$modified_commands
);
}
$text
.=
"."
;
return
$text
;
}
public
function
getSupportedCommands
()
{
$actions
=
array
(
DifferentialAction
::
ACTION_COMMENT
,
DifferentialAction
::
ACTION_REJECT
,
DifferentialAction
::
ACTION_ABANDON
,
DifferentialAction
::
ACTION_RECLAIM
,
DifferentialAction
::
ACTION_RESIGN
,
DifferentialAction
::
ACTION_RETHINK
,
'unsubscribe'
,
);
if
(
PhabricatorEnv
::
getEnvConfig
(
'differential.enable-email-accept'
))
{
$actions
[]
=
DifferentialAction
::
ACTION_ACCEPT
;
}
return
$actions
;
}
protected
function
receiveEmail
(
PhabricatorMetaMTAReceivedMail
$mail
)
{
$this
->
receivedMail
=
$mail
;
$this
->
handleAction
(
$mail
->
getCleanTextBody
(),
$mail
->
getAttachments
());
}
public
function
handleAction
(
$body
,
array
$attachments
)
{
// all commands start with a bang and separated from the body by a newline
// to make sure that actual feedback text couldn't trigger an action.
// unrecognized commands will be parsed as part of the comment.
$command
=
DifferentialAction
::
ACTION_COMMENT
;
$supported_commands
=
$this
->
getSupportedCommands
();
$regex
=
"/
\A\n
*!("
.
implode
(
'|'
,
$supported_commands
)
.
")
\n
*/"
;
$matches
=
array
();
if
(
preg_match
(
$regex
,
$body
,
$matches
))
{
$command
=
$matches
[
1
];
$body
=
trim
(
str_replace
(
'!'
.
$command
,
''
,
$body
));
}
$actor
=
$this
->
getActor
();
if
(!
$actor
)
{
throw
new
Exception
(
'No actor is set for the reply action.'
);
}
switch
(
$command
)
{
case
'unsubscribe'
:
$this
->
unsubscribeUser
(
$this
->
getMailReceiver
(),
$actor
);
// TODO: Send the user a confirmation email?
return
null
;
}
$body
=
$this
->
enhanceBodyWithAttachments
(
$body
,
$attachments
);
try
{
$editor
=
new
DifferentialCommentEditor
(
$this
->
getMailReceiver
(),
$command
);
$editor
->
setActor
(
$actor
);
$editor
->
setExcludeMailRecipientPHIDs
(
$this
->
getExcludeMailRecipientPHIDs
());
// NOTE: We have to be careful about this because Facebook's
// implementation jumps straight into handleAction() and will not have
// a PhabricatorMetaMTAReceivedMail object.
if
(
$this
->
receivedMail
)
{
$content_source
=
PhabricatorContentSource
::
newForSource
(
PhabricatorContentSource
::
SOURCE_EMAIL
,
array
(
'id'
=>
$this
->
receivedMail
->
getID
(),
));
$editor
->
setContentSource
(
$content_source
);
$editor
->
setParentMessageID
(
$this
->
receivedMail
->
getMessageID
());
}
$editor
->
setMessage
(
$body
);
$comment
=
$editor
->
save
();
return
$comment
->
getID
();
}
catch
(
Exception
$ex
)
{
if
(
$this
->
receivedMail
)
{
$error_body
=
$this
->
receivedMail
->
getRawTextBody
();
}
else
{
$error_body
=
$body
;
}
$exception_mail
=
new
DifferentialExceptionMail
(
$this
->
getMailReceiver
(),
$ex
,
$error_body
);
$exception_mail
->
setActor
(
$this
->
getActor
());
$exception_mail
->
setToPHIDs
(
array
(
$this
->
getActor
()->
getPHID
()));
$exception_mail
->
send
();
throw
$ex
;
}
}
private
function
unsubscribeUser
(
DifferentialRevision
$revision
,
PhabricatorUser
$user
)
{
$revision
->
loadRelationships
();
DifferentialRevisionEditor
::
removeCCAndUpdateRevision
(
$revision
,
$user
->
getPHID
(),
$user
);
}
}
Event Timeline
Log In to Comment