forked from loadingdeck/Dial9Downloader
-
Notifications
You must be signed in to change notification settings - Fork 0
/
dial9.php
124 lines (114 loc) · 4.59 KB
/
dial9.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
<?php
/**
* Script to download recordings from Dial9, a VOIP service: http://www.dial9.co.uk/
* Simply change the 4 variables below and run: php /path/to/dial9.php
* @author James Hadley https://www.loadingdeck.com/labs/
* @license The MIT License
*/
// Dial9 username
define('USERNAME', '');
// Dial9 password
define('PASSWORD', '');
// Storage directory
define('DIRECTORY', '/backup/dial9');
// 0 = keep files at Dial9, 1 = remove them after downloading
define('REMOVE', 1);
class Dial9Downloader
{
public function run()
{
printf("Running at %s\n", (new \DateTime())->format('Y-m-d H:i:s'));
// Get list of calls
foreach(array('incoming', 'external') as $type)
{
printf("*** %s CALLS ***\n", strtoupper($type));
$page = 1;
unset($logs);
while(!isset($logs) || count($logs['data']))
{
$logs = $this->curlDial9('logs/historical', array('type' => $type, 'page' => $page));
if($logs === false)
{
// alert fail
printf("Could not get call logs:\n");
continue 2;
}
$logs = json_decode($logs, true);
if($logs['status'] != 'success')
{
// alert fail
printf("Call log return value was not success\n");
continue 2;
}
foreach($logs['data'] as $call)
{
printf("* CALL ID %d\n", $call['id']);
if($call['has_recording?'] !== false)
{
printf("* HAS RECORDING\n", $call['id']);
// Download the recording
$recording = $this->curlDial9('logs/recording', array('id' => $call['id']));
if($recording === false)
{
// alert fail
printf("Did not get a value for recording\n");
continue 3;
}
$recording = json_decode($recording, true);
if($recording['status'] != 'success')
{
// alert fail
printf("Could not download call %s\n", $call['id']);
continue;
}
$time = str_replace(':', '-', substr($call['timestamp'], 11, 8));
$file_name = sprintf('backups/%s.wav', $call['id']);
if(file_exists($file_name) && filesize($file_name) > 0) {
printf("Already downloaded %d\n", $call['id']);
if(REMOVE == 1){
printf("deleting call %d\n", $call['id']);
$res = $this->curlDial9('logs/delete_recording', array('id' => $call['id']));
}
} else {
printf("Downloading call %d\n", $call['id']);
file_put_contents(
$file_name,
base64_decode($recording['data']['file'])
);
}
} else {
printf("* NO RECORDING\n", $call['id']);
}
}
$page++;
}
}
}
private function curlDial9($function, array $params = array())
{
$json = sprintf('params=%s', json_encode($params));
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, sprintf('https://connect.dial9.co.uk/api/v2/%s', $function));
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 1);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
curl_setopt($ch, CURLOPT_TIMEOUT, 300);
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, $json);
curl_setopt($ch, CURLOPT_VERBOSE, 0);
curl_setopt($ch, CURLOPT_HTTPHEADER,
array(
sprintf('X-Auth-Token: %s', USERNAME),
sprintf('X-Auth-Secret: %s', PASSWORD)
)
);
$r = curl_exec($ch);
if(curl_errno($ch) !== 0) {
printf("Curl error: %d: %s\n", curl_errno($ch), curl_error($ch));
} else {
return $r;
}
}
}
(new Dial9Downloader())->run();