Page Menu
Home
c4science
Search
Configure Global Search
Log In
Files
F96154621
LegalpadDocumentQuery.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
Mon, Dec 23, 06:07
Size
6 KB
Mime Type
text/x-php
Expires
Wed, Dec 25, 06:07 (2 d)
Engine
blob
Format
Raw Data
Handle
23134980
Attached To
rPH Phabricator
LegalpadDocumentQuery.php
View Options
<?php
final
class
LegalpadDocumentQuery
extends
PhabricatorCursorPagedPolicyAwareQuery
{
private
$ids
;
private
$phids
;
private
$creatorPHIDs
;
private
$contributorPHIDs
;
private
$signerPHIDs
;
private
$dateCreatedAfter
;
private
$dateCreatedBefore
;
private
$needDocumentBodies
;
private
$needContributors
;
private
$needSignatures
;
private
$needViewerSignatures
;
public
function
withIDs
(
array
$ids
)
{
$this
->
ids
=
$ids
;
return
$this
;
}
public
function
withPHIDs
(
array
$phids
)
{
$this
->
phids
=
$phids
;
return
$this
;
}
public
function
withCreatorPHIDs
(
array
$phids
)
{
$this
->
creatorPHIDs
=
$phids
;
return
$this
;
}
public
function
withContributorPHIDs
(
array
$phids
)
{
$this
->
contributorPHIDs
=
$phids
;
return
$this
;
}
public
function
withSignerPHIDs
(
array
$phids
)
{
$this
->
signerPHIDs
=
$phids
;
return
$this
;
}
public
function
needDocumentBodies
(
$need_bodies
)
{
$this
->
needDocumentBodies
=
$need_bodies
;
return
$this
;
}
public
function
needContributors
(
$need_contributors
)
{
$this
->
needContributors
=
$need_contributors
;
return
$this
;
}
public
function
needSignatures
(
$need_signatures
)
{
$this
->
needSignatures
=
$need_signatures
;
return
$this
;
}
public
function
withDateCreatedBefore
(
$date_created_before
)
{
$this
->
dateCreatedBefore
=
$date_created_before
;
return
$this
;
}
public
function
withDateCreatedAfter
(
$date_created_after
)
{
$this
->
dateCreatedAfter
=
$date_created_after
;
return
$this
;
}
public
function
needViewerSignatures
(
$need
)
{
$this
->
needViewerSignatures
=
$need
;
return
$this
;
}
protected
function
loadPage
()
{
$table
=
new
LegalpadDocument
();
$conn_r
=
$table
->
establishConnection
(
'r'
);
$data
=
queryfx_all
(
$conn_r
,
'SELECT d.* FROM %T d %Q %Q %Q %Q %Q'
,
$table
->
getTableName
(),
$this
->
buildJoinClause
(
$conn_r
),
$this
->
buildWhereClause
(
$conn_r
),
$this
->
buildGroupClause
(
$conn_r
),
$this
->
buildOrderClause
(
$conn_r
),
$this
->
buildLimitClause
(
$conn_r
));
$documents
=
$table
->
loadAllFromArray
(
$data
);
return
$documents
;
}
protected
function
willFilterPage
(
array
$documents
)
{
if
(
$this
->
needDocumentBodies
)
{
$documents
=
$this
->
loadDocumentBodies
(
$documents
);
}
if
(
$this
->
needContributors
)
{
$documents
=
$this
->
loadContributors
(
$documents
);
}
if
(
$this
->
needSignatures
)
{
$documents
=
$this
->
loadSignatures
(
$documents
);
}
if
(
$this
->
needViewerSignatures
)
{
if
(
$documents
)
{
if
(
$this
->
getViewer
()->
getPHID
())
{
$signatures
=
id
(
new
LegalpadDocumentSignatureQuery
())
->
setViewer
(
$this
->
getViewer
())
->
withSignerPHIDs
(
array
(
$this
->
getViewer
()->
getPHID
()))
->
withDocumentPHIDs
(
mpull
(
$documents
,
'getPHID'
))
->
execute
();
$signatures
=
mpull
(
$signatures
,
null
,
'getDocumentPHID'
);
}
else
{
$signatures
=
array
();
}
foreach
(
$documents
as
$document
)
{
$signature
=
idx
(
$signatures
,
$document
->
getPHID
());
$document
->
attachUserSignature
(
$this
->
getViewer
()->
getPHID
(),
$signature
);
}
}
}
return
$documents
;
}
private
function
buildJoinClause
(
$conn_r
)
{
$joins
=
array
();
if
(
$this
->
contributorPHIDs
!==
null
)
{
$joins
[]
=
qsprintf
(
$conn_r
,
'JOIN edge contributor ON contributor.src = d.phid
AND contributor.type = %d'
,
PhabricatorEdgeConfig
::
TYPE_OBJECT_HAS_CONTRIBUTOR
);
}
if
(
$this
->
signerPHIDs
!==
null
)
{
$joins
[]
=
qsprintf
(
$conn_r
,
'JOIN %T signer ON signer.documentPHID = d.phid
AND signer.signerPHID IN (%Ls)'
,
id
(
new
LegalpadDocumentSignature
())->
getTableName
(),
$this
->
signerPHIDs
);
}
return
implode
(
' '
,
$joins
);
}
private
function
buildGroupClause
(
AphrontDatabaseConnection
$conn_r
)
{
if
(
$this
->
contributorPHIDs
||
$this
->
signerPHIDs
)
{
return
'GROUP BY d.id'
;
}
else
{
return
''
;
}
}
protected
function
buildWhereClause
(
$conn_r
)
{
$where
=
array
();
if
(
$this
->
ids
!==
null
)
{
$where
[]
=
qsprintf
(
$conn_r
,
'd.id IN (%Ld)'
,
$this
->
ids
);
}
if
(
$this
->
phids
!==
null
)
{
$where
[]
=
qsprintf
(
$conn_r
,
'd.phid IN (%Ls)'
,
$this
->
phids
);
}
if
(
$this
->
creatorPHIDs
!==
null
)
{
$where
[]
=
qsprintf
(
$conn_r
,
'd.creatorPHID IN (%Ls)'
,
$this
->
creatorPHIDs
);
}
if
(
$this
->
dateCreatedAfter
!==
null
)
{
$where
[]
=
qsprintf
(
$conn_r
,
'd.dateCreated >= %d'
,
$this
->
dateCreatedAfter
);
}
if
(
$this
->
dateCreatedBefore
!==
null
)
{
$where
[]
=
qsprintf
(
$conn_r
,
'd.dateCreated <= %d'
,
$this
->
dateCreatedBefore
);
}
if
(
$this
->
contributorPHIDs
!==
null
)
{
$where
[]
=
qsprintf
(
$conn_r
,
'contributor.dst IN (%Ls)'
,
$this
->
contributorPHIDs
);
}
$where
[]
=
$this
->
buildPagingClause
(
$conn_r
);
return
$this
->
formatWhereClause
(
$where
);
}
private
function
loadDocumentBodies
(
array
$documents
)
{
$body_phids
=
mpull
(
$documents
,
'getDocumentBodyPHID'
);
$bodies
=
id
(
new
LegalpadDocumentBody
())->
loadAllWhere
(
'phid IN (%Ls)'
,
$body_phids
);
$bodies
=
mpull
(
$bodies
,
null
,
'getPHID'
);
foreach
(
$documents
as
$document
)
{
$body
=
idx
(
$bodies
,
$document
->
getDocumentBodyPHID
());
$document
->
attachDocumentBody
(
$body
);
}
return
$documents
;
}
private
function
loadContributors
(
array
$documents
)
{
$document_map
=
mpull
(
$documents
,
null
,
'getPHID'
);
$edge_type
=
PhabricatorEdgeConfig
::
TYPE_OBJECT_HAS_CONTRIBUTOR
;
$contributor_data
=
id
(
new
PhabricatorEdgeQuery
())
->
withSourcePHIDs
(
array_keys
(
$document_map
))
->
withEdgeTypes
(
array
(
$edge_type
))
->
execute
();
foreach
(
$document_map
as
$document_phid
=>
$document
)
{
$data
=
$contributor_data
[
$document_phid
];
$contributors
=
array_keys
(
idx
(
$data
,
$edge_type
,
array
()));
$document
->
attachContributors
(
$contributors
);
}
return
$documents
;
}
private
function
loadSignatures
(
array
$documents
)
{
$document_map
=
mpull
(
$documents
,
null
,
'getPHID'
);
$signatures
=
id
(
new
LegalpadDocumentSignatureQuery
())
->
setViewer
(
$this
->
getViewer
())
->
withDocumentPHIDs
(
array_keys
(
$document_map
))
->
execute
();
$signatures
=
mgroup
(
$signatures
,
'getDocumentPHID'
);
foreach
(
$documents
as
$document
)
{
$sigs
=
idx
(
$signatures
,
$document
->
getPHID
(),
array
());
$document
->
attachSignatures
(
$sigs
);
}
return
$documents
;
}
public
function
getQueryApplicationClass
()
{
return
'PhabricatorApplicationLegalpad'
;
}
}
Event Timeline
Log In to Comment