-
Notifications
You must be signed in to change notification settings - Fork 2
/
Bencode.php
141 lines (114 loc) · 3.51 KB
/
Bencode.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
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
<?php
namespace PureBencode;
class Bencode {
/**
* @param int|string|array $value
* @throws Exception
* @return string
*/
static function encode($value) {
if (is_array($value)) {
if (self::isAssoc($value)) {
ksort($value, SORT_STRING);
$result = '';
foreach ($value as $k => $v)
$result .= self::encode("$k") . self::encode($v);
return "d{$result}e";
} else {
$result = '';
foreach ($value as $v)
$result .= self::encode($v);
return "l{$result}e";
}
} else if (is_int($value)) {
return "i{$value}e";
} else if (is_string($value)) {
return strlen($value) . ":$value";
} else {
$type = gettype($value);
throw new Exception("Bencode supports only integers, strings and arrays. $type given.");
}
}
private static function isAssoc(array $array) {
$i = 0;
foreach ($array as $k => $v)
if ($k !== $i++)
return true;
return false;
}
/**
* @param string $string Bencode string
* @throws Exception
* @return int|string|array
*/
static function decode($string) {
$parser = new BencodeParser($string);
return $parser->decode();
}
}
class BencodeParser {
private $string, $pos = 0;
function __construct($string) {
$this->string = $string;
}
function decode() {
switch ($this->read()) {
case 'i':
$this->seek();
return $this->readInt('e');
case 'l':
$this->seek();
$result = array();
while ($this->read() !== 'e')
$result[] = $this->decode();
$this->seek();
return $result;
case 'd':
$this->seek();
$result = array();
while ($this->read() !== 'e')
$result[$this->parseString()] = $this->decode();
$this->seek();
return $result;
default:
return $this->parseString();
}
}
private function read($len = 1) {
$result = (string)substr($this->string, $this->pos, $len);
$len2 = strlen($result);
if ($len !== $len2)
throw new Exception("$len bytes expected but only $len2 bytes remain");
return $result;
}
private function seek($len = 1) {
$this->pos += $len;
}
private function readInt($delimiter) {
$result = $this->remove($this->find($delimiter));
$this->seek(strlen($delimiter));
$int = (int)$result;
if ("$int" !== $result)
throw new Exception("Invalid integer: $result");
return $int;
}
private function remove($len) {
$string = $this->read($len);
$this->seek($len);
return $string;
}
private function find($needle) {
$pos = strpos($this->string, $needle, $this->pos);
if ($pos === false)
throw new Exception("'$needle' not found");
return $pos - $this->pos;
}
private function parseString() {
$len = $this->readInt(':');
if ($len < 0)
throw new Exception("Length of string ($len) must not be negative");
return $this->remove($len);
}
}
class Exception extends \Exception {
}