Page Menu
Home
c4science
Search
Configure Global Search
Log In
Files
F81596906
ConpherenceEditor.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
Fri, Sep 6, 23:08
Size
8 KB
Mime Type
text/x-php
Expires
Sun, Sep 8, 23:08 (1 d, 23 h)
Engine
blob
Format
Raw Data
Handle
20599629
Attached To
rPH Phabricator
ConpherenceEditor.php
View Options
<?php
final
class
ConpherenceEditor
extends
PhabricatorApplicationTransactionEditor
{
const
ERROR_EMPTY_PARTICIPANTS
=
'error-empty-participants'
;
const
ERROR_EMPTY_MESSAGE
=
'error-empty-message'
;
public
function
getEditorApplicationClass
()
{
return
'PhabricatorConpherenceApplication'
;
}
public
function
getEditorObjectsDescription
()
{
return
pht
(
'Conpherence Rooms'
);
}
public
static
function
createThread
(
PhabricatorUser
$creator
,
array
$participant_phids
,
$title
,
$message
,
PhabricatorContentSource
$source
,
$topic
)
{
$conpherence
=
ConpherenceThread
::
initializeNewRoom
(
$creator
);
$errors
=
array
();
if
(
empty
(
$participant_phids
))
{
$errors
[]
=
self
::
ERROR_EMPTY_PARTICIPANTS
;
}
else
{
$participant_phids
[]
=
$creator
->
getPHID
();
$participant_phids
=
array_unique
(
$participant_phids
);
}
if
(
empty
(
$message
))
{
$errors
[]
=
self
::
ERROR_EMPTY_MESSAGE
;
}
if
(!
$errors
)
{
$xactions
=
array
();
$xactions
[]
=
id
(
new
ConpherenceTransaction
())
->
setTransactionType
(
ConpherenceThreadParticipantsTransaction
::
TRANSACTIONTYPE
)
->
setNewValue
(
array
(
'+'
=>
$participant_phids
));
if
(
$title
)
{
$xactions
[]
=
id
(
new
ConpherenceTransaction
())
->
setTransactionType
(
ConpherenceThreadTitleTransaction
::
TRANSACTIONTYPE
)
->
setNewValue
(
$title
);
}
if
(
strlen
(
$topic
))
{
$xactions
[]
=
id
(
new
ConpherenceTransaction
())
->
setTransactionType
(
ConpherenceThreadTopicTransaction
::
TRANSACTIONTYPE
)
->
setNewValue
(
$topic
);
}
$xactions
[]
=
id
(
new
ConpherenceTransaction
())
->
setTransactionType
(
PhabricatorTransactions
::
TYPE_COMMENT
)
->
attachComment
(
id
(
new
ConpherenceTransactionComment
())
->
setContent
(
$message
)
->
setConpherencePHID
(
$conpherence
->
getPHID
()));
id
(
new
ConpherenceEditor
())
->
setActor
(
$creator
)
->
setContentSource
(
$source
)
->
setContinueOnNoEffect
(
true
)
->
applyTransactions
(
$conpherence
,
$xactions
);
}
return
array
(
$errors
,
$conpherence
);
}
public
function
generateTransactionsFromText
(
PhabricatorUser
$viewer
,
ConpherenceThread
$conpherence
,
$text
)
{
$xactions
=
array
();
$xactions
[]
=
id
(
new
ConpherenceTransaction
())
->
setTransactionType
(
PhabricatorTransactions
::
TYPE_COMMENT
)
->
attachComment
(
id
(
new
ConpherenceTransactionComment
())
->
setContent
(
$text
)
->
setConpherencePHID
(
$conpherence
->
getPHID
()));
return
$xactions
;
}
public
function
getTransactionTypes
()
{
$types
=
parent
::
getTransactionTypes
();
$types
[]
=
PhabricatorTransactions
::
TYPE_COMMENT
;
$types
[]
=
PhabricatorTransactions
::
TYPE_VIEW_POLICY
;
$types
[]
=
PhabricatorTransactions
::
TYPE_EDIT_POLICY
;
return
$types
;
}
public
function
getCreateObjectTitle
(
$author
,
$object
)
{
return
pht
(
'%s created this room.'
,
$author
);
}
/**
* We really only need a read lock if we have a comment. In that case, we
* must update the messagesCount field on the conpherence and
* seenMessagesCount(s) for the participant(s).
*/
protected
function
shouldReadLock
(
PhabricatorLiskDAO
$object
,
PhabricatorApplicationTransaction
$xaction
)
{
$lock
=
false
;
switch
(
$xaction
->
getTransactionType
())
{
case
PhabricatorTransactions
::
TYPE_COMMENT
:
$lock
=
true
;
break
;
}
return
$lock
;
}
protected
function
applyBuiltinInternalTransaction
(
PhabricatorLiskDAO
$object
,
PhabricatorApplicationTransaction
$xaction
)
{
switch
(
$xaction
->
getTransactionType
())
{
case
PhabricatorTransactions
::
TYPE_COMMENT
:
$object
->
setMessageCount
((
int
)
$object
->
getMessageCount
()
+
1
);
break
;
}
return
parent
::
applyBuiltinInternalTransaction
(
$object
,
$xaction
);
}
protected
function
applyFinalEffects
(
PhabricatorLiskDAO
$object
,
array
$xactions
)
{
$acting_phid
=
$this
->
getActingAsPHID
();
$participants
=
$object
->
getParticipants
();
foreach
(
$participants
as
$participant
)
{
if
(
$participant
->
getParticipantPHID
()
==
$acting_phid
)
{
$participant
->
markUpToDate
(
$object
);
}
}
if
(
$participants
)
{
PhabricatorUserCache
::
clearCaches
(
PhabricatorUserMessageCountCacheType
::
KEY_COUNT
,
array_keys
(
$participants
));
}
if
(
$xactions
)
{
$data
=
array
(
'type'
=>
'message'
,
'threadPHID'
=>
$object
->
getPHID
(),
'messageID'
=>
last
(
$xactions
)->
getID
(),
'subscribers'
=>
array
(
$object
->
getPHID
()),
);
PhabricatorNotificationClient
::
tryToPostMessage
(
$data
);
}
return
$xactions
;
}
protected
function
requireCapabilities
(
PhabricatorLiskDAO
$object
,
PhabricatorApplicationTransaction
$xaction
)
{
parent
::
requireCapabilities
(
$object
,
$xaction
);
switch
(
$xaction
->
getTransactionType
())
{
case
ConpherenceThreadParticipantsTransaction
::
TRANSACTIONTYPE
:
$old_map
=
array_fuse
(
$xaction
->
getOldValue
());
$new_map
=
array_fuse
(
$xaction
->
getNewValue
());
$add
=
array_keys
(
array_diff_key
(
$new_map
,
$old_map
));
$rem
=
array_keys
(
array_diff_key
(
$old_map
,
$new_map
));
$actor_phid
=
$this
->
getActingAsPHID
();
$is_join
=
((
$add
===
array
(
$actor_phid
))
&&
!
$rem
);
$is_leave
=
((
$rem
===
array
(
$actor_phid
))
&&
!
$add
);
if
(
$is_join
)
{
// Anyone can join a thread they can see.
}
else
if
(
$is_leave
)
{
// Anyone can leave a thread.
}
else
{
// You need CAN_EDIT to add or remove participants. For additional
// discussion, see D17696 and T4411.
PhabricatorPolicyFilter
::
requireCapability
(
$this
->
requireActor
(),
$object
,
PhabricatorPolicyCapability
::
CAN_EDIT
);
}
break
;
case
ConpherenceThreadTitleTransaction
::
TRANSACTIONTYPE
:
case
ConpherenceThreadTopicTransaction
::
TRANSACTIONTYPE
:
PhabricatorPolicyFilter
::
requireCapability
(
$this
->
requireActor
(),
$object
,
PhabricatorPolicyCapability
::
CAN_EDIT
);
break
;
}
}
protected
function
shouldSendMail
(
PhabricatorLiskDAO
$object
,
array
$xactions
)
{
return
true
;
}
protected
function
buildReplyHandler
(
PhabricatorLiskDAO
$object
)
{
return
id
(
new
ConpherenceReplyHandler
())
->
setActor
(
$this
->
getActor
())
->
setMailReceiver
(
$object
);
}
protected
function
buildMailTemplate
(
PhabricatorLiskDAO
$object
)
{
$id
=
$object
->
getID
();
$title
=
$object
->
getTitle
();
if
(!
$title
)
{
$title
=
pht
(
'%s sent you a message.'
,
$this
->
getActor
()->
getUserName
());
}
$phid
=
$object
->
getPHID
();
return
id
(
new
PhabricatorMetaMTAMail
())
->
setSubject
(
"Z{$id}: {$title}"
)
->
addHeader
(
'Thread-Topic'
,
"Z{$id}: {$phid}"
);
}
protected
function
getMailTo
(
PhabricatorLiskDAO
$object
)
{
$to_phids
=
array
();
$participants
=
$object
->
getParticipants
();
if
(!
$participants
)
{
return
$to_phids
;
}
$participant_phids
=
mpull
(
$participants
,
'getParticipantPHID'
);
$users
=
id
(
new
PhabricatorPeopleQuery
())
->
setViewer
(
PhabricatorUser
::
getOmnipotentUser
())
->
withPHIDs
(
$participant_phids
)
->
needUserSettings
(
true
)
->
execute
();
$users
=
mpull
(
$users
,
null
,
'getPHID'
);
$notification_key
=
PhabricatorConpherenceNotificationsSetting
::
SETTINGKEY
;
$notification_email
=
PhabricatorConpherenceNotificationsSetting
::
VALUE_CONPHERENCE_EMAIL
;
foreach
(
$participants
as
$phid
=>
$participant
)
{
$user
=
idx
(
$users
,
$phid
);
if
(
$user
)
{
$default
=
$user
->
getUserSetting
(
$notification_key
);
}
else
{
$default
=
$notification_email
;
}
$settings
=
$participant
->
getSettings
();
$notifications
=
idx
(
$settings
,
'notifications'
,
$default
);
if
(
$notifications
==
$notification_email
)
{
$to_phids
[]
=
$phid
;
}
}
return
$to_phids
;
}
protected
function
getMailCC
(
PhabricatorLiskDAO
$object
)
{
return
array
();
}
protected
function
buildMailBody
(
PhabricatorLiskDAO
$object
,
array
$xactions
)
{
$body
=
parent
::
buildMailBody
(
$object
,
$xactions
);
$body
->
addLinkSection
(
pht
(
'CONPHERENCE DETAIL'
),
PhabricatorEnv
::
getProductionURI
(
'/'
.
$object
->
getMonogram
()));
return
$body
;
}
protected
function
addEmailPreferenceSectionToMailBody
(
PhabricatorMetaMTAMailBody
$body
,
PhabricatorLiskDAO
$object
,
array
$xactions
)
{
$href
=
PhabricatorEnv
::
getProductionURI
(
'/'
.
$object
->
getMonogram
().
'?settings'
);
$label
=
pht
(
'EMAIL PREFERENCES FOR THIS ROOM'
);
$body
->
addLinkSection
(
$label
,
$href
);
}
protected
function
getMailSubjectPrefix
()
{
return
PhabricatorEnv
::
getEnvConfig
(
'metamta.conpherence.subject-prefix'
);
}
protected
function
supportsSearch
()
{
return
true
;
}
}
Event Timeline
Log In to Comment