Skip to content

Commit

Permalink
import
Browse files Browse the repository at this point in the history
  • Loading branch information
@markkimsal
markkimsal committed Feb 17, 2017
1 parent 899a450 commit 0284dd8
Show file tree
Hide file tree
Showing 197 changed files with 24,718 additions and 0 deletions.
218 changes: 218 additions & 0 deletions bin/beanstalk_listener.php
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,218 @@
<?php

$argDefs = [
[
'name' => 'refreshTokenFile',
'keys' => [
'r',
'refresh-token',
],
'default' => '',
],
[
'name' => 'watch',
'keys' => [
'w',
'watch',
],
'default' => 'hangouts',
],
[
'name' => 'conversationId',
'keys' => [
'conversation-id',
'conversationid',
'convid',
'cid'
],
'default' => '',
],
[
'name' => 'email',
'keys' => [
'email',
'e'
],
'default' => ''
],
[
'name' => 'password',
'keys' => [
'password',
'p'
],
'default' => ''
]
];
$h = getenv('HOME');
if ($h) {
$argDefs[0]['default'] = $h.'/.cache/hwp/refresh-token.txt';
}

$defaults = [
'OAUTH2_LOGIN_URL' => 'https://accounts.google.com/o/oauth2/programmatic_auth',
'OAUTH2_TOKEN_REQUEST_URL' => 'https://accounts.google.com/o/oauth2/token',
'OAUTH2_CLIENT_SECRET' => 'KWsJlkaMn1jGLxQpWxMnOox-',
//'OAUTH2_LOGIN_URL' => 'https://accounts.google.com/o/oauth2/v2/auth',
'OAUTH2_SCOPES' => [
'https://www.googleapis.com/auth/userinfo.email',
'https://www.google.com/accounts/OAuthLogin',
],
'OAUTH2_CLIENT_ID' => '936475272427.apps.googleusercontent.com',

];
$o = [
'conversation-id:',
'convid:',
'refresh-token:',
'watch:',
];

$options = getopt('c:w:r:', $o);
$config = array_merge($defaults);

foreach ($argDefs as $arg) {
foreach ($options as $k => $v) {
if (array_key_exists('default', $arg)) {
$config[ $arg['name'] ] = $arg['default'];
} else {
$config[ $arg['name'] ] = NULL;
}
if (in_array($k, $arg['keys'])) {
$config[ $arg['name'] ] = $v;
continue 2;
}
}
}

include(dirname(__DIR__).'/vendor/autoload.php');
$session = new Requests_Session();

include('src/Client.php');
try {
$hwpclient = new HWP\Client($session, $config);


//try connecting over and over, if there's an authorization
// error, wait increasing time and try again
Amp\repeat(function() use ($hwpclient){

if ($hwpclient->isConnected) {
return;
}

if (!$hwpclient->getRefreshToken()) {
echo "W/Hangouts: Cannot read refresh token. Will try again later.\n";
return;
}

try {
$hwpclient->connect();
} catch (\Exception $e) {
$hwpclient->isConnected = FALSE;
echo "E/Hangouts: Exception in Hangouts connection. ".$e->getMessage()."\n";
}

}, $msInterval=5000);

} catch (Exception $e) {
echo "Error: ".$e->getMessage()."\n";
die(1);
}


Amp\run(function () use ($config, $hwpclient) {
try {
$client = new Amp\Beanstalk\BeanstalkClient('127.0.0.1:11300');

$client->watch($config['watch']);

Amp\repeat(function() use ($client, $config, $hwpclient){

try {
//echo "I/Job: waiting for reserve ...\n";
$promise = $client->reserve(0);
//echo "I/Job: got promise\n";
} catch (Exception $e) {
if ($e instanceOf Amp\Beanstalk\DeadlineSoonException) {
var_dump($e->getJob());
}
}
$promise->when( function($error, $result, $cbData) use ($client, $config, $hwpclient) {
if ($error instanceOf Amp\Beanstalk\TimedOutException) {
return;
}
if ($error instanceOf Amp\Beanstalk\DeadlineSoonException) {
echo "E/Job: DeadLineSoon: ".$e->getMessage()."\n";
return;
}
if ($result) {
echo "I/Job: RESERVED JOB: ".$result[0]."\n";
}

if (!$result) {
return;
}

try {
$id = $result[0];

//var_dump($result);
$params = json_decode($result[1], TRUE);
//var_dump($params, TRUE);
$convId = $config['conversationId'];
if (array_key_exists('convid', $params)) {
$convId = $params['convid'];
}
if (array_key_exists('text', $params)) {
$convText = $params['text'];
$hwpclient->sendChatMessage($convId, $convText);
}

$k = $client->delete($id);
$k->when( function($err, $res) use ($client, $id) {
echo "I/Job: DELETING JOB: " . $id."\n";
});
} catch (Exception $e) {
echo "E/Job: Exception: ".$e->getMessage()."\n";
}
});
}, $msInterval=50);


} catch (Exception $e) {
var_dump($e->getMessage());
}

});















function helpText() {
echo "php ./bin/cli_send_message.php [-c|--convid 123456] [-t|--text \"Your Text\"] \n";
echo "Parmeters:\n";
echo " -w --watch: Tube to watch for messages\n";
echo " (defaults to 'hangouts')\n";
echo " -c --convid: The unique conversation ID\n";
echo " -r --refresh-token: The filename to use as refresh token cache.\n";
echo " -e --email: Email for sign-in.\n";
echo " (only required one time if --refresh-token is used)\n";
echo " (Using email and password is strongly discouraged\n";
echo " use cli_auth_once.php and set --refresh-token file location)\n";
echo " -p --password: Password for sign-in.\n";
echo " (only required one time if --refresh-token is used)\n";
echo " (Using email and password is strongly discouraged,\n";
echo " use cli_auth_once.php and set --refresh-token file location)\n";
}
126 changes: 126 additions & 0 deletions bin/cli_send_message.php
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,126 @@
<?php

$argDefs = [
[
'name' => 'refreshTokenFile',
'keys' => [
'r',
'refresh-token',
],
'default' => '',
],
[
'name' => 'conversationId',
'keys' => [
'conversation-id',
'conversationid',
'convid',
'cid'
],
'default' => '',
],
[
'name' => 'convText',
'keys' => [
'text',
't'
],
'default' => ''
],
[
'name' => 'email',
'keys' => [
'email',
'e'
],
'default' => ''
],
[
'name' => 'password',
'keys' => [
'password',
'p'
],
'default' => ''
]
];
$h = getenv('HOME');
if ($h) {
$argDefs[0]['default'] = $h.'/.cache/hwp/refresh-token.txt';
}

$defaults = [
'OAUTH2_LOGIN_URL' => 'https://accounts.google.com/o/oauth2/programmatic_auth',
'OAUTH2_TOKEN_REQUEST_URL' => 'https://accounts.google.com/o/oauth2/token',
'OAUTH2_CLIENT_SECRET' => 'KWsJlkaMn1jGLxQpWxMnOox-',
//'OAUTH2_LOGIN_URL' => 'https://accounts.google.com/o/oauth2/v2/auth',
'OAUTH2_SCOPES' => [
'https://www.googleapis.com/auth/userinfo.email',
'https://www.google.com/accounts/OAuthLogin',
],
'OAUTH2_CLIENT_ID' => '936475272427.apps.googleusercontent.com',

];
$o = [
'conversation-id:',
'convid:',
'convtext:',
'text:',
'refresh-token:',
];
$options = getopt('c:t:r:', $o);
$config = array_merge($defaults);

foreach ($argDefs as $arg) {
foreach ($options as $k => $v) {
if (array_key_exists('default', $arg)) {
$config[ $arg['name'] ] = $arg['default'];
} else {
$config[ $arg['name'] ] = NULL;
}
if (in_array($k, $arg['keys'])) {
$config[ $arg['name'] ] = $v;
continue 2;
}
}
}

$convText = $config['convText'];
if (!$convText) {
echo "You must include some text to send.\n";
helpText();
die(1);
}

if (empty ($config['conversationId']) ) {
echo "You must supply a conversation ID.\n";
helpText();
die(1);
}

include('vendor/autoload.php');
$session = new Requests_Session();

include('src/Client.php');
try {
$client = new HWP\Client($session, $config);
$client->connect();
$client->sendChatMessage($config['conversationId'], $convText);
} catch (Exception $e) {
echo "Error: ".$e->getMessage()."\n";
die(1);
}



function helpText() {
echo "php ./bin/cli_send_message.php [-c|--convid 123456] [-t|--text \"Your Text\"] \n";
echo "Parmeters:\n";
echo " -t --text: The content of your message\n";
echo " -c --convid: The unique conversation ID\n";
echo " -r --refresh-token: The filename to use as refresh token cache.\n";
echo " -e --email: Email for sign-in.\n";
echo " (only required one time if --refresh-token is used)\n";
echo " -p --password: Password for sign-in.\n";
echo " (only required one time if --refresh-token is used)\n";
}
12 changes: 12 additions & 0 deletions composer.json
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{
"repositories": [
{
"type": "vcs",
"url": "https://github.com/markkimsal/beanstalk.git"
}],

"require": {
"markkimsal/beanstalk": "^0.2.0",
"rmccue/requests": "^1.7"
}
}
Loading

0 comments on commit 0284dd8

Please sign in to comment.