@recaptime-dev's working patches + fork for Phorge, a community fork of Phabricator. (Upstream dev and stable branches are at upstream/main and upstream/stable respectively.)
hq.recaptime.dev/wiki/Phorge
phorge
phabricator
1<?php
2
3final class PhabricatorDaemonManagementLogWorkflow
4 extends PhabricatorDaemonManagementWorkflow {
5
6 protected function didConstruct() {
7 $this
8 ->setName('log')
9 ->setExamples('**log** [__options__]')
10 ->setSynopsis(
11 pht(
12 'Print the logs for all daemons, or some daemon(s) identified by '.
13 'ID. You can get the ID for a daemon from the Daemon Console in '.
14 'the web interface.'))
15 ->setArguments(
16 array(
17 array(
18 'name' => 'id',
19 'param' => 'id',
20 'help' => pht('Show logs for daemon(s) with given ID(s).'),
21 'repeat' => true,
22 ),
23 array(
24 'name' => 'limit',
25 'param' => 'N',
26 'default' => 100,
27 'help' => pht(
28 'Show a specific number of log messages (default 100).'),
29 ),
30 ));
31 }
32
33 public function execute(PhutilArgumentParser $args) {
34
35 $query = id(new PhabricatorDaemonLogQuery())
36 ->setViewer($this->getViewer())
37 ->setAllowStatusWrites(true);
38 $ids = $args->getArg('id');
39 if ($ids) {
40 $query->withIDs($ids);
41 }
42 $daemons = $query->execute();
43 $daemons = mpull($daemons, null, 'getID');
44
45 if ($ids) {
46 foreach ($ids as $id) {
47 if (!isset($daemons[$id])) {
48 throw new PhutilArgumentUsageException(
49 pht(
50 'No log record exists for a daemon with ID "%s".',
51 $id));
52 }
53 }
54 } else if (!$daemons) {
55 throw new PhutilArgumentUsageException(
56 pht('No log records exist for any daemons.'));
57 }
58
59 $console = PhutilConsole::getConsole();
60
61 $limit = $args->getArg('limit');
62
63 $logs = id(new PhabricatorDaemonLogEvent())->loadAllWhere(
64 'logID IN (%Ld) ORDER BY id DESC LIMIT %d',
65 mpull($daemons, 'getID'),
66 $limit);
67 $logs = array_reverse($logs);
68
69 $lines = array();
70 foreach ($logs as $log) {
71 $text_lines = phutil_split_lines($log->getMessage(), $retain = false);
72 foreach ($text_lines as $line) {
73 $lines[] = array(
74 'id' => $log->getLogID(),
75 'type' => $log->getLogType(),
76 'date' => $log->getEpoch(),
77 'data' => $line,
78 );
79 }
80 }
81
82 // Each log message may be several lines. Limit the number of lines we
83 // output so that `--limit 123` means "show 123 lines", which is the most
84 // easily understandable behavior.
85 $lines = array_slice($lines, -$limit);
86
87 foreach ($lines as $line) {
88 $id = $line['id'];
89 $type = $line['type'];
90 $data = $line['data'];
91 $date = date('r', $line['date']);
92
93 $console->writeOut(
94 "%s\n",
95 pht(
96 'Daemon %d %s [%s] %s',
97 $id,
98 $type,
99 $date,
100 $data));
101 }
102
103 return 0;
104 }
105
106
107}