Page Menu
Home
c4science
Search
Configure Global Search
Log In
Files
F115402279
ConpherenceThread.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
Sat, May 31, 17:36
Size
12 KB
Mime Type
text/x-php
Expires
Mon, Jun 2, 17:36 (1 d, 23 h)
Engine
blob
Format
Raw Data
Handle
26487716
Attached To
rPH Phabricator
ConpherenceThread.php
View Options
<?php
final
class
ConpherenceThread
extends
ConpherenceDAO
implements
PhabricatorPolicyInterface
,
PhabricatorApplicationTransactionInterface
,
PhabricatorMentionableInterface
,
PhabricatorDestructibleInterface
{
protected
$title
;
protected
$imagePHIDs
=
array
();
protected
$messageCount
;
protected
$recentParticipantPHIDs
=
array
();
protected
$mailKey
;
protected
$viewPolicy
;
protected
$editPolicy
;
protected
$joinPolicy
;
private
$participants
=
self
::
ATTACHABLE
;
private
$transactions
=
self
::
ATTACHABLE
;
private
$handles
=
self
::
ATTACHABLE
;
private
$filePHIDs
=
self
::
ATTACHABLE
;
private
$widgetData
=
self
::
ATTACHABLE
;
private
$images
=
self
::
ATTACHABLE
;
public
static
function
initializeNewRoom
(
PhabricatorUser
$sender
)
{
$default_policy
=
id
(
new
ConpherenceThreadMembersPolicyRule
())
->
getObjectPolicyFullKey
();
return
id
(
new
ConpherenceThread
())
->
setMessageCount
(
0
)
->
setTitle
(
''
)
->
attachParticipants
(
array
())
->
attachFilePHIDs
(
array
())
->
attachImages
(
array
())
->
setViewPolicy
(
$default_policy
)
->
setEditPolicy
(
$default_policy
)
->
setJoinPolicy
(
$default_policy
);
}
protected
function
getConfiguration
()
{
return
array
(
self
::
CONFIG_AUX_PHID
=>
true
,
self
::
CONFIG_SERIALIZATION
=>
array
(
'recentParticipantPHIDs'
=>
self
::
SERIALIZATION_JSON
,
'imagePHIDs'
=>
self
::
SERIALIZATION_JSON
,
),
self
::
CONFIG_COLUMN_SCHEMA
=>
array
(
'title'
=>
'text255?'
,
'messageCount'
=>
'uint64'
,
'mailKey'
=>
'text20'
,
'joinPolicy'
=>
'policy'
,
),
self
::
CONFIG_KEY_SCHEMA
=>
array
(
'key_phid'
=>
null
,
'phid'
=>
array
(
'columns'
=>
array
(
'phid'
),
'unique'
=>
true
,
),
),
)
+
parent
::
getConfiguration
();
}
public
function
generatePHID
()
{
return
PhabricatorPHID
::
generateNewPHID
(
PhabricatorConpherenceThreadPHIDType
::
TYPECONST
);
}
public
function
save
()
{
if
(!
$this
->
getMailKey
())
{
$this
->
setMailKey
(
Filesystem
::
readRandomCharacters
(
20
));
}
return
parent
::
save
();
}
public
function
getMonogram
()
{
return
'Z'
.
$this
->
getID
();
}
public
function
getImagePHID
(
$size
)
{
$image_phids
=
$this
->
getImagePHIDs
();
return
idx
(
$image_phids
,
$size
);
}
public
function
setImagePHID
(
$phid
,
$size
)
{
$image_phids
=
$this
->
getImagePHIDs
();
$image_phids
[
$size
]
=
$phid
;
return
$this
->
setImagePHIDs
(
$image_phids
);
}
public
function
getImage
(
$size
)
{
$images
=
$this
->
getImages
();
return
idx
(
$images
,
$size
);
}
public
function
setImage
(
PhabricatorFile
$file
,
$size
)
{
$files
=
$this
->
getImages
();
$files
[
$size
]
=
$file
;
return
$this
->
attachImages
(
$files
);
}
public
function
attachImages
(
array
$files
)
{
assert_instances_of
(
$files
,
'PhabricatorFile'
);
$this
->
images
=
$files
;
return
$this
;
}
private
function
getImages
()
{
return
$this
->
assertAttached
(
$this
->
images
);
}
public
function
attachParticipants
(
array
$participants
)
{
assert_instances_of
(
$participants
,
'ConpherenceParticipant'
);
$this
->
participants
=
$participants
;
return
$this
;
}
public
function
getParticipants
()
{
return
$this
->
assertAttached
(
$this
->
participants
);
}
public
function
getParticipant
(
$phid
)
{
$participants
=
$this
->
getParticipants
();
return
$participants
[
$phid
];
}
public
function
getParticipantIfExists
(
$phid
,
$default
=
null
)
{
$participants
=
$this
->
getParticipants
();
return
idx
(
$participants
,
$phid
,
$default
);
}
public
function
getParticipantPHIDs
()
{
$participants
=
$this
->
getParticipants
();
return
array_keys
(
$participants
);
}
public
function
attachHandles
(
array
$handles
)
{
assert_instances_of
(
$handles
,
'PhabricatorObjectHandle'
);
$this
->
handles
=
$handles
;
return
$this
;
}
public
function
getHandles
()
{
return
$this
->
assertAttached
(
$this
->
handles
);
}
public
function
attachTransactions
(
array
$transactions
)
{
assert_instances_of
(
$transactions
,
'ConpherenceTransaction'
);
$this
->
transactions
=
$transactions
;
return
$this
;
}
public
function
getTransactions
(
$assert_attached
=
true
)
{
return
$this
->
assertAttached
(
$this
->
transactions
);
}
public
function
hasAttachedTransactions
()
{
return
$this
->
transactions
!==
self
::
ATTACHABLE
;
}
public
function
getTransactionsFrom
(
$begin
=
0
,
$amount
=
null
)
{
$length
=
count
(
$this
->
transactions
);
return
array_slice
(
$this
->
getTransactions
(),
$length
-
$begin
-
$amount
,
$amount
);
}
public
function
attachFilePHIDs
(
array
$file_phids
)
{
$this
->
filePHIDs
=
$file_phids
;
return
$this
;
}
public
function
getFilePHIDs
()
{
return
$this
->
assertAttached
(
$this
->
filePHIDs
);
}
public
function
attachWidgetData
(
array
$widget_data
)
{
$this
->
widgetData
=
$widget_data
;
return
$this
;
}
public
function
getWidgetData
()
{
return
$this
->
assertAttached
(
$this
->
widgetData
);
}
public
function
loadImageURI
(
$size
)
{
$file
=
$this
->
getImage
(
$size
);
if
(
$file
)
{
return
$file
->
getBestURI
();
}
return
PhabricatorUser
::
getDefaultProfileImageURI
();
}
/**
* Get a thread title which doesn't require handles to be attached.
*
* This is a less rich title than @{method:getDisplayTitle}, but does not
* require handles to be attached. We use it to build thread handles without
* risking cycles or recursion while querying.
*
* @return string Lower quality human-readable title.
*/
public
function
getStaticTitle
()
{
$title
=
$this
->
getTitle
();
if
(
strlen
(
$title
))
{
return
$title
;
}
return
pht
(
'Private Room'
);
}
/**
* Get the thread's display title for a user.
*
* If a thread doesn't have a title set, this will return a string describing
* recent participants.
*
* @param PhabricatorUser Viewer.
* @return string Thread title.
*/
public
function
getDisplayTitle
(
PhabricatorUser
$viewer
)
{
$title
=
$this
->
getTitle
();
if
(
strlen
(
$title
))
{
return
$title
;
}
return
$this
->
getRecentParticipantsString
(
$viewer
);
}
/**
* Get recent participants (other than the viewer) as a string.
*
* For example, this method might return "alincoln, htaft, gwashington...".
*
* @param PhabricatorUser Viewer.
* @return string Description of other participants.
*/
private
function
getRecentParticipantsString
(
PhabricatorUser
$viewer
)
{
$handles
=
$this
->
getHandles
();
$phids
=
$this
->
getOtherRecentParticipantPHIDs
(
$viewer
);
if
(
count
(
$phids
)
==
0
)
{
$phids
[]
=
$viewer
->
getPHID
();
$more
=
false
;
}
else
{
$limit
=
3
;
$more
=
(
count
(
$phids
)
>
$limit
);
$phids
=
array_slice
(
$phids
,
0
,
$limit
);
}
$names
=
array_select_keys
(
$handles
,
$phids
);
$names
=
mpull
(
$names
,
'getName'
);
$names
=
implode
(
', '
,
$names
);
if
(
$more
)
{
$names
=
$names
.
'...'
;
}
return
$names
;
}
/**
* Get PHIDs for recent participants who are not the viewer.
*
* @param PhabricatorUser Viewer.
* @return list<phid> Participants who are not the viewer.
*/
private
function
getOtherRecentParticipantPHIDs
(
PhabricatorUser
$viewer
)
{
$phids
=
$this
->
getRecentParticipantPHIDs
();
$phids
=
array_fuse
(
$phids
);
unset
(
$phids
[
$viewer
->
getPHID
()]);
return
array_values
(
$phids
);
}
public
function
getDisplayData
(
PhabricatorUser
$viewer
)
{
$handles
=
$this
->
getHandles
();
if
(
$this
->
hasAttachedTransactions
())
{
$transactions
=
$this
->
getTransactions
();
}
else
{
$transactions
=
array
();
}
if
(
$transactions
)
{
$subtitle_mode
=
'message'
;
}
else
{
$subtitle_mode
=
'recent'
;
}
$lucky_phid
=
head
(
$this
->
getOtherRecentParticipantPHIDs
(
$viewer
));
if
(
$lucky_phid
)
{
$lucky_handle
=
$handles
[
$lucky_phid
];
}
else
{
// This will be just the user talking to themselves. Weirdo.
$lucky_handle
=
reset
(
$handles
);
}
$img_src
=
null
;
$size
=
ConpherenceImageData
::
SIZE_CROP
;
if
(
$this
->
getImagePHID
(
$size
))
{
$img_src
=
$this
->
getImage
(
$size
)->
getBestURI
();
}
else
if
(
$lucky_handle
)
{
$img_src
=
$lucky_handle
->
getImageURI
();
}
$message_title
=
null
;
if
(
$subtitle_mode
==
'message'
)
{
$message_transaction
=
null
;
foreach
(
$transactions
as
$transaction
)
{
switch
(
$transaction
->
getTransactionType
())
{
case
PhabricatorTransactions
::
TYPE_COMMENT
:
$message_transaction
=
$transaction
;
break
2
;
default
:
break
;
}
}
if
(
$message_transaction
)
{
$message_handle
=
$handles
[
$message_transaction
->
getAuthorPHID
()];
$message_title
=
sprintf
(
'%s: %s'
,
$message_handle
->
getName
(),
id
(
new
PhutilUTF8StringTruncator
())
->
setMaximumGlyphs
(
60
)
->
truncateString
(
$message_transaction
->
getComment
()->
getContent
()));
}
}
switch
(
$subtitle_mode
)
{
case
'recent'
:
$subtitle
=
$this
->
getRecentParticipantsString
(
$viewer
);
break
;
case
'message'
:
if
(
$message_title
)
{
$subtitle
=
$message_title
;
}
else
{
$subtitle
=
$this
->
getRecentParticipantsString
(
$viewer
);
}
break
;
}
$user_participation
=
$this
->
getParticipantIfExists
(
$viewer
->
getPHID
());
if
(
$user_participation
)
{
$user_seen_count
=
$user_participation
->
getSeenMessageCount
();
}
else
{
$user_seen_count
=
0
;
}
$unread_count
=
$this
->
getMessageCount
()
-
$user_seen_count
;
$title
=
$this
->
getDisplayTitle
(
$viewer
);
return
array
(
'title'
=>
$title
,
'subtitle'
=>
$subtitle
,
'unread_count'
=>
$unread_count
,
'epoch'
=>
$this
->
getDateModified
(),
'image'
=>
$img_src
,
);
}
/* -( PhabricatorPolicyInterface Implementation )-------------------------- */
public
function
getCapabilities
()
{
return
array
(
PhabricatorPolicyCapability
::
CAN_VIEW
,
PhabricatorPolicyCapability
::
CAN_EDIT
,
PhabricatorPolicyCapability
::
CAN_JOIN
,
);
}
public
function
getPolicy
(
$capability
)
{
switch
(
$capability
)
{
case
PhabricatorPolicyCapability
::
CAN_VIEW
:
return
$this
->
getViewPolicy
();
case
PhabricatorPolicyCapability
::
CAN_EDIT
:
return
$this
->
getEditPolicy
();
case
PhabricatorPolicyCapability
::
CAN_JOIN
:
return
$this
->
getJoinPolicy
();
}
return
PhabricatorPolicies
::
POLICY_NOONE
;
}
public
function
hasAutomaticCapability
(
$capability
,
PhabricatorUser
$user
)
{
// this bad boy isn't even created yet so go nuts $user
if
(!
$this
->
getID
())
{
return
true
;
}
switch
(
$capability
)
{
case
PhabricatorPolicyCapability
::
CAN_EDIT
:
case
PhabricatorPolicyCapability
::
CAN_JOIN
:
return
false
;
}
$participants
=
$this
->
getParticipants
();
return
isset
(
$participants
[
$user
->
getPHID
()]);
}
public
function
describeAutomaticCapability
(
$capability
)
{
switch
(
$capability
)
{
case
PhabricatorPolicyCapability
::
CAN_VIEW
:
return
pht
(
'Participants in a room can always view it.'
);
break
;
}
}
public
static
function
loadViewPolicyObjects
(
PhabricatorUser
$viewer
,
array
$conpherences
)
{
assert_instances_of
(
$conpherences
,
__CLASS__
);
$policies
=
array
();
foreach
(
$conpherences
as
$room
)
{
$policies
[
$room
->
getViewPolicy
()]
=
1
;
}
$policy_objects
=
array
();
if
(
$policies
)
{
$policy_objects
=
id
(
new
PhabricatorPolicyQuery
())
->
setViewer
(
$viewer
)
->
withPHIDs
(
array_keys
(
$policies
))
->
execute
();
}
return
$policy_objects
;
}
public
function
getPolicyIconName
(
array
$policy_objects
)
{
assert_instances_of
(
$policy_objects
,
'PhabricatorPolicy'
);
$icon
=
$policy_objects
[
$this
->
getViewPolicy
()]->
getIcon
();
return
$icon
;
}
/* -( PhabricatorApplicationTransactionInterface )------------------------- */
public
function
getApplicationTransactionEditor
()
{
return
new
ConpherenceEditor
();
}
public
function
getApplicationTransactionObject
()
{
return
$this
;
}
public
function
getApplicationTransactionTemplate
()
{
return
new
ConpherenceTransaction
();
}
public
function
willRenderTimeline
(
PhabricatorApplicationTransactionView
$timeline
,
AphrontRequest
$request
)
{
return
$timeline
;
}
/* -( PhabricatorDestructibleInterface )----------------------------------- */
public
function
destroyObjectPermanently
(
PhabricatorDestructionEngine
$engine
)
{
$this
->
openTransaction
();
$this
->
delete
();
$participants
=
id
(
new
ConpherenceParticipant
())
->
loadAllWhere
(
'conpherencePHID = %s'
,
$this
->
getPHID
());
foreach
(
$participants
as
$participant
)
{
$participant
->
delete
();
}
$this
->
saveTransaction
();
}
}
Event Timeline
Log In to Comment