60 lines
2.1 KiB
PHP
60 lines
2.1 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
if (php_sapi_name() != 'cli') {
|
||
|
|
die('no');
|
||
|
|
}
|
||
|
|
|
||
|
|
define('INSTALLDIR', dirname(dirname(dirname(__FILE__))));
|
||
|
|
|
||
|
|
require INSTALLDIR . "/scripts/commandline.inc";
|
||
|
|
|
||
|
|
// temp stuff
|
||
|
|
require 'yam-config.php';
|
||
|
|
$yam = new SN_YammerClient($consumerKey, $consumerSecret, $token, $tokenSecret);
|
||
|
|
$imp = new YammerImporter();
|
||
|
|
|
||
|
|
$data = $yam->messages();
|
||
|
|
/*
|
||
|
|
["messages"]=>
|
||
|
|
["meta"]=> // followed_user_ids, current_user_id, etc
|
||
|
|
["threaded_extended"]=> // empty!
|
||
|
|
["references"]=> // lists the users, threads, replied messages, tags
|
||
|
|
*/
|
||
|
|
|
||
|
|
// 1) we're getting messages in descending order, but we'll want to process ascending
|
||
|
|
// 2) we'll need to pull out all those referenced items too?
|
||
|
|
// 3) do we need to page over or anything?
|
||
|
|
|
||
|
|
// 20 qualifying messages per hit...
|
||
|
|
// use older_than to grab more
|
||
|
|
// (better if we can go in reverse though!)
|
||
|
|
// meta: The older-available element indicates whether messages older than those shown are available to be fetched. See the older_than parameter mentioned above.
|
||
|
|
foreach ($data['references'] as $item) {
|
||
|
|
if ($item['type'] == 'user') {
|
||
|
|
$user = $imp->importUser($item);
|
||
|
|
echo "Imported Yammer user " . $item['id'] . " as $user->nickname ($user->id)\n";
|
||
|
|
} else if ($item['type'] == 'group') {
|
||
|
|
$group = $imp->importGroup($item);
|
||
|
|
echo "Imported Yammer group " . $item['id'] . " as $group->nickname ($group->id)\n";
|
||
|
|
} else if ($item['type'] == 'tag') {
|
||
|
|
// could need these if we work from the parsed message text
|
||
|
|
// otherwise, the #blarf in orig text is fine.
|
||
|
|
} else if ($item['type'] == 'thread') {
|
||
|
|
// Shouldn't need thread info; we'll reconstruct conversations
|
||
|
|
// from the reply-to chains.
|
||
|
|
} else if ($item['type'] == 'message') {
|
||
|
|
// If we're processing everything, then we don't need the refs here.
|
||
|
|
} else {
|
||
|
|
echo "(skipping unknown ref: " . $item['type'] . ")\n";
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// Process in reverse chron order...
|
||
|
|
// @fixme follow paging
|
||
|
|
$messages = $data['messages'];
|
||
|
|
$messages = array_reverse($messages);
|
||
|
|
foreach ($messages as $item) {
|
||
|
|
$notice = $imp->importNotice($item);
|
||
|
|
echo "Imported Yammer notice " . $item['id'] . " as $notice->id\n";
|
||
|
|
}
|