Page Menu
Home
c4science
Search
Configure Global Search
Log In
Files
F62624090
PhabricatorOwnersPackage.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
Tue, May 14, 10:24
Size
7 KB
Mime Type
text/x-php
Expires
Thu, May 16, 10:24 (1 d, 23 h)
Engine
blob
Format
Raw Data
Handle
17669432
Attached To
rPH Phabricator
PhabricatorOwnersPackage.php
View Options
<?php
final
class
PhabricatorOwnersPackage
extends
PhabricatorOwnersDAO
implements
PhabricatorPolicyInterface
,
PhabricatorApplicationTransactionInterface
{
protected
$name
;
protected
$originalName
;
protected
$auditingEnabled
;
protected
$description
;
protected
$primaryOwnerPHID
;
protected
$mailKey
;
private
$unsavedOwners
=
self
::
ATTACHABLE
;
private
$unsavedPaths
=
self
::
ATTACHABLE
;
private
$actorPHID
;
private
$oldPrimaryOwnerPHID
;
private
$oldAuditingEnabled
;
public
static
function
initializeNewPackage
(
PhabricatorUser
$actor
)
{
return
id
(
new
PhabricatorOwnersPackage
())
->
setAuditingEnabled
(
0
)
->
setPrimaryOwnerPHID
(
$actor
->
getPHID
());
}
public
function
getCapabilities
()
{
return
array
(
PhabricatorPolicyCapability
::
CAN_VIEW
,
);
}
public
function
getPolicy
(
$capability
)
{
return
PhabricatorPolicies
::
POLICY_USER
;
}
public
function
hasAutomaticCapability
(
$capability
,
PhabricatorUser
$viewer
)
{
return
false
;
}
public
function
describeAutomaticCapability
(
$capability
)
{
return
null
;
}
protected
function
getConfiguration
()
{
return
array
(
// This information is better available from the history table.
self
::
CONFIG_TIMESTAMPS
=>
false
,
self
::
CONFIG_AUX_PHID
=>
true
,
self
::
CONFIG_COLUMN_SCHEMA
=>
array
(
'name'
=>
'text128'
,
'originalName'
=>
'text255'
,
'description'
=>
'text'
,
'primaryOwnerPHID'
=>
'phid?'
,
'auditingEnabled'
=>
'bool'
,
'mailKey'
=>
'bytes20'
,
),
self
::
CONFIG_KEY_SCHEMA
=>
array
(
'key_phid'
=>
null
,
'phid'
=>
array
(
'columns'
=>
array
(
'phid'
),
'unique'
=>
true
,
),
'name'
=>
array
(
'columns'
=>
array
(
'name'
),
'unique'
=>
true
,
),
),
)
+
parent
::
getConfiguration
();
}
public
function
generatePHID
()
{
return
PhabricatorPHID
::
generateNewPHID
(
PhabricatorOwnersPackagePHIDType
::
TYPECONST
);
}
public
function
save
()
{
if
(!
$this
->
getMailKey
())
{
$this
->
setMailKey
(
Filesystem
::
readRandomCharacters
(
20
));
}
return
parent
::
save
();
}
public
function
attachUnsavedOwners
(
array
$owners
)
{
$this
->
unsavedOwners
=
$owners
;
return
$this
;
}
public
function
getUnsavedOwners
()
{
return
$this
->
assertAttached
(
$this
->
unsavedOwners
);
}
public
function
attachUnsavedPaths
(
array
$paths
)
{
$this
->
unsavedPaths
=
$paths
;
return
$this
;
}
public
function
getUnsavedPaths
()
{
return
$this
->
assertAttached
(
$this
->
unsavedPaths
);
}
public
function
attachActorPHID
(
$actor_phid
)
{
$this
->
actorPHID
=
$actor_phid
;
return
$this
;
}
public
function
getActorPHID
()
{
return
$this
->
actorPHID
;
}
public
function
attachOldPrimaryOwnerPHID
(
$old_primary
)
{
$this
->
oldPrimaryOwnerPHID
=
$old_primary
;
return
$this
;
}
public
function
getOldPrimaryOwnerPHID
()
{
return
$this
->
oldPrimaryOwnerPHID
;
}
public
function
attachOldAuditingEnabled
(
$auditing_enabled
)
{
$this
->
oldAuditingEnabled
=
$auditing_enabled
;
return
$this
;
}
public
function
getOldAuditingEnabled
()
{
return
$this
->
oldAuditingEnabled
;
}
public
function
setName
(
$name
)
{
$this
->
name
=
$name
;
if
(!
$this
->
getID
())
{
$this
->
originalName
=
$name
;
}
return
$this
;
}
public
function
loadOwners
()
{
if
(!
$this
->
getID
())
{
return
array
();
}
return
id
(
new
PhabricatorOwnersOwner
())->
loadAllWhere
(
'packageID = %d'
,
$this
->
getID
());
}
public
function
loadPaths
()
{
if
(!
$this
->
getID
())
{
return
array
();
}
return
id
(
new
PhabricatorOwnersPath
())->
loadAllWhere
(
'packageID = %d'
,
$this
->
getID
());
}
public
static
function
loadAffectedPackages
(
PhabricatorRepository
$repository
,
array
$paths
)
{
if
(!
$paths
)
{
return
array
();
}
return
self
::
loadPackagesForPaths
(
$repository
,
$paths
);
}
public
static
function
loadOwningPackages
(
$repository
,
$path
)
{
if
(
empty
(
$path
))
{
return
array
();
}
return
self
::
loadPackagesForPaths
(
$repository
,
array
(
$path
),
1
);
}
private
static
function
loadPackagesForPaths
(
PhabricatorRepository
$repository
,
array
$paths
,
$limit
=
0
)
{
$fragments
=
array
();
foreach
(
$paths
as
$path
)
{
foreach
(
self
::
splitPath
(
$path
)
as
$fragment
)
{
$fragments
[
$fragment
][
$path
]
=
true
;
}
}
$package
=
new
PhabricatorOwnersPackage
();
$path
=
new
PhabricatorOwnersPath
();
$conn
=
$package
->
establishConnection
(
'r'
);
$repository_clause
=
qsprintf
(
$conn
,
'AND p.repositoryPHID = %s'
,
$repository
->
getPHID
());
// NOTE: The list of $paths may be very large if we're coming from
// the OwnersWorker and processing, e.g., an SVN commit which created a new
// branch. Break it apart so that it will fit within 'max_allowed_packet',
// and then merge results in PHP.
$rows
=
array
();
foreach
(
array_chunk
(
array_keys
(
$fragments
),
128
)
as
$chunk
)
{
$rows
[]
=
queryfx_all
(
$conn
,
'SELECT pkg.id, p.excluded, p.path
FROM %T pkg JOIN %T p ON p.packageID = pkg.id
WHERE p.path IN (%Ls) %Q'
,
$package
->
getTableName
(),
$path
->
getTableName
(),
$chunk
,
$repository_clause
);
}
$rows
=
array_mergev
(
$rows
);
$ids
=
self
::
findLongestPathsPerPackage
(
$rows
,
$fragments
);
if
(!
$ids
)
{
return
array
();
}
arsort
(
$ids
);
if
(
$limit
)
{
$ids
=
array_slice
(
$ids
,
0
,
$limit
,
$preserve_keys
=
true
);
}
$ids
=
array_keys
(
$ids
);
$packages
=
$package
->
loadAllWhere
(
'id in (%Ld)'
,
$ids
);
$packages
=
array_select_keys
(
$packages
,
$ids
);
return
$packages
;
}
public
static
function
loadPackagesForRepository
(
$repository
)
{
$package
=
new
PhabricatorOwnersPackage
();
$ids
=
ipull
(
queryfx_all
(
$package
->
establishConnection
(
'r'
),
'SELECT DISTINCT packageID FROM %T WHERE repositoryPHID = %s'
,
id
(
new
PhabricatorOwnersPath
())->
getTableName
(),
$repository
->
getPHID
()),
'packageID'
);
return
$package
->
loadAllWhere
(
'id in (%Ld)'
,
$ids
);
}
public
static
function
findLongestPathsPerPackage
(
array
$rows
,
array
$paths
)
{
$ids
=
array
();
foreach
(
igroup
(
$rows
,
'id'
)
as
$id
=>
$package_paths
)
{
$relevant_paths
=
array_select_keys
(
$paths
,
ipull
(
$package_paths
,
'path'
));
// For every package, remove all excluded paths.
$remove
=
array
();
foreach
(
$package_paths
as
$package_path
)
{
if
(
$package_path
[
'excluded'
])
{
$remove
+=
idx
(
$relevant_paths
,
$package_path
[
'path'
],
array
());
unset
(
$relevant_paths
[
$package_path
[
'path'
]]);
}
}
if
(
$remove
)
{
foreach
(
$relevant_paths
as
$fragment
=>
$fragment_paths
)
{
$relevant_paths
[
$fragment
]
=
array_diff_key
(
$fragment_paths
,
$remove
);
}
}
$relevant_paths
=
array_filter
(
$relevant_paths
);
if
(
$relevant_paths
)
{
$ids
[
$id
]
=
max
(
array_map
(
'strlen'
,
array_keys
(
$relevant_paths
)));
}
}
return
$ids
;
}
private
static
function
splitPath
(
$path
)
{
$result
=
array
(
'/'
);
$trailing_slash
=
preg_match
(
'@/$@'
,
$path
)
?
'/'
:
''
;
$path
=
trim
(
$path
,
'/'
);
$parts
=
explode
(
'/'
,
$path
);
while
(
count
(
$parts
))
{
$result
[]
=
'/'
.
implode
(
'/'
,
$parts
).
$trailing_slash
;
$trailing_slash
=
'/'
;
array_pop
(
$parts
);
}
return
$result
;
}
/* -( PhabricatorApplicationTransactionInterface )------------------------- */
public
function
getApplicationTransactionEditor
()
{
return
new
PhabricatorOwnersPackageTransactionEditor
();
}
public
function
getApplicationTransactionObject
()
{
return
$this
;
}
public
function
getApplicationTransactionTemplate
()
{
return
new
PhabricatorOwnersPackageTransaction
();
}
public
function
willRenderTimeline
(
PhabricatorApplicationTransactionView
$timeline
,
AphrontRequest
$request
)
{
return
$timeline
;
}
}
Event Timeline
Log In to Comment