Page Menu
Home
c4science
Search
Configure Global Search
Log In
Files
F93072524
HeraldPreCommitContentAdapter.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, Nov 26, 00:09
Size
6 KB
Mime Type
text/x-php
Expires
Thu, Nov 28, 00:09 (1 d, 23 h)
Engine
blob
Format
Raw Data
Handle
22569988
Attached To
rPH Phabricator
HeraldPreCommitContentAdapter.php
View Options
<?php
final
class
HeraldPreCommitContentAdapter
extends
HeraldPreCommitAdapter
{
private
$changesets
;
private
$commitRef
;
private
$fields
;
private
$revision
=
false
;
public
function
getAdapterContentName
()
{
return
pht
(
'Commit Hook: Commit Content'
);
}
public
function
getAdapterSortOrder
()
{
return
2500
;
}
public
function
getAdapterContentDescription
()
{
return
pht
(
"React to commits being pushed to hosted repositories.
\n
"
.
"Hook rules can block changes and send push summary mail."
);
}
public
function
isPreCommitRefAdapter
()
{
return
false
;
}
public
function
getHeraldName
()
{
return
pht
(
'Push Log (Content)'
);
}
public
function
isDiffEnormous
()
{
$this
->
getDiffContent
(
'*'
);
return
(
$this
->
changesets
instanceof
Exception
);
}
public
function
getDiffContent
(
$type
)
{
if
(
$this
->
changesets
===
null
)
{
try
{
$this
->
changesets
=
$this
->
getHookEngine
()->
getChangesetsForCommit
(
$this
->
getObject
()->
getRefNew
());
}
catch
(
Exception
$ex
)
{
$this
->
changesets
=
$ex
;
}
}
if
(
$this
->
changesets
instanceof
Exception
)
{
$ex_class
=
get_class
(
$this
->
changesets
);
$ex_message
=
$this
->
changesets
->
getMessage
();
if
(
$type
===
'name'
)
{
return
array
(
"<{$ex_class}: {$ex_message}>"
);
}
else
{
return
array
(
"<{$ex_class}>"
=>
$ex_message
);
}
}
$result
=
array
();
if
(
$type
===
'name'
)
{
foreach
(
$this
->
changesets
as
$change
)
{
$result
[]
=
$change
->
getFilename
();
}
}
else
{
foreach
(
$this
->
changesets
as
$change
)
{
$lines
=
array
();
foreach
(
$change
->
getHunks
()
as
$hunk
)
{
switch
(
$type
)
{
case
'-'
:
$lines
[]
=
$hunk
->
makeOldFile
();
break
;
case
'+'
:
$lines
[]
=
$hunk
->
makeNewFile
();
break
;
case
'*'
:
default
:
$lines
[]
=
$hunk
->
makeChanges
();
break
;
}
}
$result
[
$change
->
getFilename
()]
=
implode
(
''
,
$lines
);
}
}
return
$result
;
}
public
function
getCommitRef
()
{
if
(
$this
->
commitRef
===
null
)
{
$this
->
commitRef
=
$this
->
getHookEngine
()->
loadCommitRefForCommit
(
$this
->
getObject
()->
getRefNew
());
}
return
$this
->
commitRef
;
}
public
function
getAuthorPHID
()
{
$repository
=
$this
->
getHookEngine
()->
getRepository
();
$vcs
=
$repository
->
getVersionControlSystem
();
switch
(
$vcs
)
{
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_GIT
:
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_MERCURIAL
:
$ref
=
$this
->
getCommitRef
();
$author
=
$ref
->
getAuthor
();
if
(!
strlen
(
$author
))
{
return
null
;
}
return
$this
->
lookupUser
(
$author
);
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_SVN
:
// In Subversion, the pusher is always the author.
return
$this
->
getHookEngine
()->
getViewer
()->
getPHID
();
}
}
public
function
getCommitterPHID
()
{
$repository
=
$this
->
getHookEngine
()->
getRepository
();
$vcs
=
$repository
->
getVersionControlSystem
();
switch
(
$vcs
)
{
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_GIT
:
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_MERCURIAL
:
// If there's no committer information, we're going to return the
// author instead. However, if there's committer information and we
// can't resolve it, return `null`.
$ref
=
$this
->
getCommitRef
();
$committer
=
$ref
->
getCommitter
();
if
(!
strlen
(
$committer
))
{
return
$this
->
getAuthorPHID
();
}
return
$this
->
lookupUser
(
$committer
);
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_SVN
:
// In Subversion, the pusher is always the committer.
return
$this
->
getHookEngine
()->
getViewer
()->
getPHID
();
}
}
public
function
getAuthorRaw
()
{
$repository
=
$this
->
getHookEngine
()->
getRepository
();
$vcs
=
$repository
->
getVersionControlSystem
();
switch
(
$vcs
)
{
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_GIT
:
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_MERCURIAL
:
$ref
=
$this
->
getCommitRef
();
return
$ref
->
getAuthor
();
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_SVN
:
// In Subversion, the pusher is always the author.
return
$this
->
getHookEngine
()->
getViewer
()->
getUsername
();
}
}
public
function
getCommitterRaw
()
{
$repository
=
$this
->
getHookEngine
()->
getRepository
();
$vcs
=
$repository
->
getVersionControlSystem
();
switch
(
$vcs
)
{
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_GIT
:
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_MERCURIAL
:
// Here, if there's no committer, we're going to return the author
// instead.
$ref
=
$this
->
getCommitRef
();
$committer
=
$ref
->
getCommitter
();
if
(
strlen
(
$committer
))
{
return
$committer
;
}
return
$ref
->
getAuthor
();
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_SVN
:
// In Subversion, the pusher is always the committer.
return
$this
->
getHookEngine
()->
getViewer
()->
getUsername
();
}
}
private
function
lookupUser
(
$author
)
{
return
id
(
new
DiffusionResolveUserQuery
())
->
withName
(
$author
)
->
execute
();
}
private
function
getCommitFields
()
{
if
(
$this
->
fields
===
null
)
{
$this
->
fields
=
id
(
new
DiffusionLowLevelCommitFieldsQuery
())
->
setRepository
(
$this
->
getHookEngine
()->
getRepository
())
->
withCommitRef
(
$this
->
getCommitRef
())
->
execute
();
}
return
$this
->
fields
;
}
public
function
getRevision
()
{
if
(
$this
->
revision
===
false
)
{
$fields
=
$this
->
getCommitFields
();
$revision_id
=
idx
(
$fields
,
'revisionID'
);
if
(!
$revision_id
)
{
$this
->
revision
=
null
;
}
else
{
$this
->
revision
=
id
(
new
DifferentialRevisionQuery
())
->
setViewer
(
PhabricatorUser
::
getOmnipotentUser
())
->
withIDs
(
array
(
$revision_id
))
->
needReviewers
(
true
)
->
executeOne
();
}
}
return
$this
->
revision
;
}
public
function
getIsMergeCommit
()
{
$repository
=
$this
->
getHookEngine
()->
getRepository
();
$vcs
=
$repository
->
getVersionControlSystem
();
switch
(
$vcs
)
{
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_GIT
:
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_MERCURIAL
:
$parents
=
id
(
new
DiffusionLowLevelParentsQuery
())
->
setRepository
(
$repository
)
->
withIdentifier
(
$this
->
getObject
()->
getRefNew
())
->
execute
();
return
(
count
(
$parents
)
>
1
);
case
PhabricatorRepositoryType
::
REPOSITORY_TYPE_SVN
:
// NOTE: For now, we ignore "svn:mergeinfo" at all levels. We might
// change this some day, but it's not nearly as clear a signal as
// ancestry is in Git/Mercurial.
return
false
;
}
}
public
function
getBranches
()
{
return
$this
->
getHookEngine
()->
loadBranches
(
$this
->
getObject
()->
getRefNew
());
}
}
Event Timeline
Log In to Comment