src/stapibas/Cli.php

   1 <?php
   2 namespace stapibas;
   3
   4 class Cli
   5 {
   6     protected $cliParser;
   7
   8     public function __construct()
   9     {
  10         $this->setupCli();
  11     }
  12
  13     public function run()
  14     {
  15         try {
  16             $result = $this->cliParser->parse();
  17         } catch (\Exception $exc) {
  18             $this->cliParser->displayError($exc->getMessage());
  19         }
  20
  21         $log = new Logger();
  22         if ($result->options['debug']) {
  23             $log->debug = true;
  24         }
  25
  26         try {
  27             $deps = new Dependencies();
  28             $deps->db = new PDO(
  29                 $GLOBALS['dbdsn'], $GLOBALS['dbuser'], $GLOBALS['dbpass']
  30             );
  31             $deps->log = $log;
  32             $deps->options = array_merge(
  33                 $result->options,
  34                 $result->command ? $result->command->options : array(),
  35                 ($result->command && $result->command->command)
  36                     ? $result->command->command->options
  37                     : array()
  38             );
  39
  40             if ($result->command_name == 'feed') {
  41                 $this->runFeed($result->command, $deps);
  42             } else if ($result->command_name == 'handle') {
  43                 $this->runPingbackHandler($result->command, $deps);
  44             } else {
  45                 $this->cliParser->displayUsage(1);
  46             }
  47         } catch (\Exception $e) {
  48             $msg = 'stapibas exception!' . "\n"
  49                 . 'Code: ' . $e->getCode() . "\n"
  50                 . 'Message: ' . $e->getMessage() . "\n";
  51             file_put_contents('php://stderr', $msg);
  52             exit(1);
  53         }
  54     }
  55
  56     protected function runFeed(
  57         \Console_CommandLine_Result $command, Dependencies $deps
  58     ) {
  59         if ($command->command_name == 'update') {
  60             return $this->runFeedUpdate($command, $deps);
  61         }
  62
  63         $mg = new Feed_Manage($deps);
  64         if ($command->command_name == 'add') {
  65             $mg->addFeed($command->command->args['feed']);
  66         } else if ($command->command_name ==  'remove') {
  67             $mg->removeFeed($command->command->args['feed']);
  68         } else {
  69             $mg->listAll();
  70         }
  71     }
  72
  73     protected function runFeedUpdate(
  74         \Console_CommandLine_Result $result, Dependencies $deps
  75     ) {
  76         $tasks = array_flip(explode(',', $result->command->options['tasks']));
  77
  78         if (isset($tasks['feeds'])) {
  79             $this->runFeedUpdateFeeds($deps);
  80         }
  81         if (isset($tasks['entries'])) {
  82             $this->runFeedUpdateEntries($deps);
  83         }
  84         if (isset($tasks['urls'])) {
  85             $this->runFeedUpdatePingUrls($deps);
  86         }
  87     }
  88
  89
  90     protected function runFeedUpdateFeeds($deps)
  91     {
  92         $uf = new Feed_UpdateFeeds($deps);
  93         if ($deps->options['feed'] === null) {
  94             $uf->updateAll();
  95         } else {
  96             $urlOrIds = explode(',', $deps->options['feed']);
  97             $uf->updateSome($urlOrIds);
  98         }
  99     }
 100
 101     protected function runFeedUpdateEntries($deps)
 102     {
 103         $ue = new Feed_UpdateEntries($deps);
 104         if ($deps->options['entry'] === null) {
 105             $ue->updateAll();
 106         } else {
 107             $urlOrIds = explode(',', $deps->options['entry']);
 108             $ue->updateSome($urlOrIds);
 109         }
 110     }
 111
 112     protected function runFeedUpdatePingUrls($deps)
 113     {
 114         $uf = new Feed_PingUrls($deps);
 115         if ($deps->options['entryurl'] === null) {
 116             $uf->pingAll();
 117         } else {
 118             $urls = explode(',', $deps->options['entryurl']);
 119             $uf->pingSome($urls);
 120         }
 121     }
 122
 123
 124     protected function runPingbackHandler(
 125         \Console_CommandLine_Result $command, Dependencies $deps
 126     ) {
 127         //fetch content of pingback source pages
 128         $cf = new Content_Fetcher($deps);
 129         $cf->updateAll();
 130
 131         $cx = new Content_Extractor($deps);
 132         $cx->updateAll();
 133     }
 134
 135
 136     public function setupCli()
 137     {
 138         $p = new \Console_CommandLine();
 139         $p->description = 'Sends pingbacks to URLs linked in Atom feed entries';
 140         $p->version = '0.0.1';
 141
 142         $p->addOption(
 143             'debug',
 144             array(
 145                 'short_name'  => '-d',
 146                 'long_name'   => '--debug',
 147                 'description' => "Output debug messages",
 148                 'action'      => 'StoreTrue'
 149             )
 150         );
 151         $p->addOption(
 152             'force',
 153             array(
 154                 'short_name'  => '-f',
 155                 'long_name'   => '--force',
 156                 'description' => "Update even when resource did not change",
 157                 'action'      => 'StoreTrue'
 158             )
 159         );
 160
 161         $this->setupCliFeed($p);
 162         $this->setupCliPingback($p);
 163
 164         $this->cliParser = $p;
 165     }
 166
 167     protected function setupCliFeed($p)
 168     {
 169         $feed = $p->addCommand(
 170             'feed',
 171             array(
 172                 'description' => 'Edit, list or delete feeds'
 173             )
 174         );
 175
 176         $add = $feed->addCommand(
 177             'add',
 178             array(
 179                 'description' => 'Add the feed',
 180             )
 181         );
 182         $add->addArgument('feed', array('description' => 'URL of feed'));
 183
 184         $remove = $feed->addCommand(
 185             'remove',
 186             array(
 187                 'description' => 'Remove the feed',
 188             )
 189         );
 190         $remove->addArgument('feed', array('description' => 'URL or ID of feed'));
 191
 192
 193         $update = $feed->addCommand(
 194             'update',
 195             array(
 196                 'description' => 'Update feed data and send out pings'
 197             )
 198         );
 199         $update->addOption(
 200             'feed',
 201             array(
 202                 'short_name'  => '-i',
 203                 'long_name'   => '--feed',
 204                 'description' => 'Update this feed URL or ID',
 205                 'help_name'   => 'URL|ID',
 206                 'action'      => 'StoreString'
 207             )
 208         );
 209         $update->addOption(
 210             'entry',
 211             array(
 212                 'short_name'  => '-e',
 213                 'long_name'   => '--entry',
 214                 'description' => 'Update this feed entry URL or ID',
 215                 'help_name'   => 'URL|ID',
 216                 'action'      => 'StoreString'
 217             )
 218         );
 219         $update->addOption(
 220             'tasks',
 221             array(
 222                 'short_name'  => '-t',
 223                 'long_name'   => '--tasks',
 224                 'description' => 'Execute the given tasks (comma-separated: feeds,entries,urls)',
 225                 'help_name'   => 'tasks',
 226                 'action'      => 'StoreString',
 227                 'default'     => 'feeds,entries,urls',
 228             )
 229         );
 230         $update->addOption(
 231             'list_tasks',
 232             array(
 233                 'long_name'     => '--list-tasks',
 234                 'description'   => 'Show all possible tasks',
 235                 'action'        => 'List',
 236                 'action_params' => array(
 237                     'list' => array('feeds', 'entries', 'urls')
 238                 )
 239             )
 240         );
 241         $update->addOption(
 242             'entryurl',
 243             array(
 244                 'short_name'  => '-u',
 245                 'long_name'   => '--url',
 246                 'description' => 'Ping this URL or ID',
 247                 'help_name'   => 'URL|ID',
 248                 'action'      => 'StoreString'
 249             )
 250         );
 251     }
 252
 253     protected function setupCliPingback($p)
 254     {
 255         $handle = $p->addCommand(
 256             'handle',
 257             array(
 258                 'description' => 'Handle pingbacks: Fetch content, extract data'
 259             )
 260         );
 261     }
 262 }
 263 ?>