Page Menu
Home
c4science
Search
Configure Global Search
Log In
Files
F79711921
PhabricatorRepositoryMirrorEngine.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, Aug 27, 21:10
Size
2 KB
Mime Type
text/x-php
Expires
Thu, Aug 29, 21:10 (1 d, 21 h)
Engine
blob
Format
Raw Data
Handle
20224067
Attached To
rPH Phabricator
PhabricatorRepositoryMirrorEngine.php
View Options
<?php
/**
* Pushes a repository to its mirrors.
*/
final
class
PhabricatorRepositoryMirrorEngine
extends
PhabricatorRepositoryEngine
{
public
function
pushToMirrors
()
{
$repository
=
$this
->
getRepository
();
if
(!
$repository
->
canMirror
())
{
return
;
}
$mirrors
=
id
(
new
PhabricatorRepositoryMirrorQuery
())
->
setViewer
(
$this
->
getViewer
())
->
withRepositoryPHIDs
(
array
(
$repository
->
getPHID
()))
->
execute
();
$exceptions
=
array
();
foreach
(
$mirrors
as
$mirror
)
{
try
{
$this
->
pushRepositoryToMirror
(
$repository
,
$mirror
);
}
catch
(
Exception
$ex
)
{
$exceptions
[]
=
$ex
;
}
}
if
(
$exceptions
)
{
throw
new
PhutilAggregateException
(
pht
(
'Exceptions occurred while mirroring the "%s" repository.'
,
$repository
->
getCallsign
()),
$exceptions
);
}
}
private
function
pushRepositoryToMirror
(
PhabricatorRepository
$repository
,
PhabricatorRepositoryMirror
$mirror
)
{
// TODO: This is a little bit janky, but we don't have first-class
// infrastructure for running remote commands against an arbitrary remote
// right now. Just make an emphemeral copy of the repository and muck with
// it a little bit. In the medium term, we should pull this command stuff
// out and use it here and for "Land to ...".
$proxy
=
clone
$repository
;
$proxy
->
makeEphemeral
();
$proxy
->
setDetail
(
'hosting-enabled'
,
false
);
$proxy
->
setDetail
(
'remote-uri'
,
$mirror
->
getRemoteURI
());
$proxy
->
setCredentialPHID
(
$mirror
->
getCredentialPHID
());
$this
->
log
(
pht
(
'Pushing to remote "%s"...'
,
$mirror
->
getRemoteURI
()));
if
(
$proxy
->
isGit
())
{
$this
->
pushToGitRepository
(
$proxy
);
}
else
if
(
$proxy
->
isHg
())
{
$this
->
pushToHgRepository
(
$proxy
);
}
else
{
throw
new
Exception
(
pht
(
'Unsupported VCS!'
));
}
}
private
function
pushToGitRepository
(
PhabricatorRepository
$proxy
)
{
$future
=
$proxy
->
getRemoteCommandFuture
(
'push --verbose --mirror -- %P'
,
$proxy
->
getRemoteURIEnvelope
());
$future
->
setCWD
(
$proxy
->
getLocalPath
())
->
resolvex
();
}
private
function
pushToHgRepository
(
PhabricatorRepository
$proxy
)
{
$future
=
$proxy
->
getRemoteCommandFuture
(
'push --verbose --rev tip -- %P'
,
$proxy
->
getRemoteURIEnvelope
());
try
{
$future
->
setCWD
(
$proxy
->
getLocalPath
())
->
resolvex
();
}
catch
(
CommandException
$ex
)
{
if
(
preg_match
(
'/no changes found/'
,
$ex
->
getStdOut
()))
{
// mercurial says nothing changed, but that's good
}
else
{
throw
$ex
;
}
}
}
}
Event Timeline
Log In to Comment