Page Menu
Home
c4science
Search
Configure Global Search
Log In
Files
F67300546
PhabricatorRepositoryManagementParentsWorkflow.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, Jun 21, 15:21
Size
3 KB
Mime Type
text/x-php
Expires
Sun, Jun 23, 15:21 (2 d)
Engine
blob
Format
Raw Data
Handle
18364332
Attached To
rPH Phabricator
PhabricatorRepositoryManagementParentsWorkflow.php
View Options
<?php
final
class
PhabricatorRepositoryManagementParentsWorkflow
extends
PhabricatorRepositoryManagementWorkflow
{
public
function
didConstruct
()
{
$this
->
setName
(
'parents'
)
->
setExamples
(
'**parents** [options] [__repository__] ...'
)
->
setSynopsis
(
pht
(
'Build parent caches in repositories that are missing the data, '
.
'or rebuild them in a specific __repository__.'
))
->
setArguments
(
array
(
array
(
'name'
=>
'repos'
,
'wildcard'
=>
true
,
),
));
}
public
function
execute
(
PhutilArgumentParser
$args
)
{
$repos
=
$this
->
loadRepositories
(
$args
,
'repos'
);
if
(!
$repos
)
{
$repos
=
id
(
new
PhabricatorRepositoryQuery
())
->
setViewer
(
$this
->
getViewer
())
->
execute
();
}
$console
=
PhutilConsole
::
getConsole
();
foreach
(
$repos
as
$repo
)
{
$monogram
=
$repo
->
getMonogram
();
if
(
$repo
->
isSVN
())
{
$console
->
writeOut
(
"%s
\n
"
,
pht
(
'Skipping "%s": Subversion repositories do not require this '
.
'cache to be built.'
,
$monogram
));
continue
;
}
$this
->
rebuildRepository
(
$repo
);
}
return
0
;
}
private
function
rebuildRepository
(
PhabricatorRepository
$repo
)
{
$console
=
PhutilConsole
::
getConsole
();
$console
->
writeOut
(
"%s
\n
"
,
pht
(
'Rebuilding "%s"...'
,
$repo
->
getMonogram
()));
$refs
=
id
(
new
PhabricatorRepositoryRefCursorQuery
())
->
setViewer
(
$this
->
getViewer
())
->
withRefTypes
(
array
(
PhabricatorRepositoryRefCursor
::
TYPE_BRANCH
))
->
withRepositoryPHIDs
(
array
(
$repo
->
getPHID
()))
->
execute
();
$graph
=
array
();
foreach
(
$refs
as
$ref
)
{
$console
->
writeOut
(
"%s
\n
"
,
pht
(
'Rebuilding branch "%s"...'
,
$ref
->
getRefName
()));
$commit
=
$ref
->
getCommitIdentifier
();
if
(
$repo
->
isGit
())
{
$stream
=
new
PhabricatorGitGraphStream
(
$repo
,
$commit
);
}
else
{
$stream
=
new
PhabricatorMercurialGraphStream
(
$repo
,
$commit
);
}
$discover
=
array
(
$commit
);
while
(
$discover
)
{
$target
=
array_pop
(
$discover
);
if
(
isset
(
$graph
[
$target
]))
{
continue
;
}
$graph
[
$target
]
=
$stream
->
getParents
(
$target
);
foreach
(
$graph
[
$target
]
as
$parent
)
{
$discover
[]
=
$parent
;
}
}
}
$console
->
writeOut
(
"%s
\n
"
,
pht
(
'Found %s total commit(s); updating...'
,
new
PhutilNumber
(
count
(
$graph
))));
$commit_table
=
id
(
new
PhabricatorRepositoryCommit
());
$commit_table_name
=
$commit_table
->
getTableName
();
$conn_w
=
$commit_table
->
establishConnection
(
'w'
);
$bar
=
id
(
new
PhutilConsoleProgressBar
())
->
setTotal
(
count
(
$graph
));
foreach
(
$graph
as
$child
=>
$parents
)
{
$names
=
$parents
;
$names
[]
=
$child
;
$rows
=
queryfx_all
(
$conn_w
,
'SELECT id, commitIdentifier FROM %T
WHERE commitIdentifier IN (%Ls) AND repositoryID = %d'
,
$commit_table_name
,
$names
,
$repo
->
getID
());
$map
=
ipull
(
$rows
,
'id'
,
'commitIdentifier'
);
foreach
(
$names
as
$name
)
{
if
(
empty
(
$map
[
$name
]))
{
throw
new
Exception
(
pht
(
'Unknown commit "%s"!'
,
$name
));
}
}
$sql
=
array
();
foreach
(
$parents
as
$parent
)
{
$sql
[]
=
qsprintf
(
$conn_w
,
'(%d, %d)'
,
$map
[
$child
],
$map
[
$parent
]);
}
$commit_table
->
openTransaction
();
queryfx
(
$conn_w
,
'DELETE FROM %T WHERE childCommitID = %d'
,
PhabricatorRepository
::
TABLE_PARENTS
,
$map
[
$child
]);
if
(
$sql
)
{
queryfx
(
$conn_w
,
'INSERT INTO %T (childCommitID, parentCommitID) VALUES %Q'
,
PhabricatorRepository
::
TABLE_PARENTS
,
implode
(
', '
,
$sql
));
}
$commit_table
->
saveTransaction
();
$bar
->
update
(
1
);
}
$bar
->
done
();
}
}
Event Timeline
Log In to Comment