use std::borrow::IntoCow;
use util::StrCharIndex;
use index_simpchinese as index;
use types::*;
#[derive(Clone, Copy)]
pub struct GB18030Encoding;
impl Encoding for GB18030Encoding {
fn name(&self) -> &'static str { "gb18030" }
fn whatwg_name(&self) -> Option<&'static str> { Some("gb18030") }
fn raw_encoder(&self) -> Box<RawEncoder> { GB18030Encoder::new() }
fn raw_decoder(&self) -> Box<RawDecoder> { GB18030Decoder::new() }
}
#[derive(Clone, Copy)]
pub struct GB18030Encoder;
impl GB18030Encoder {
pub fn new() -> Box<RawEncoder> { box GB18030Encoder as Box<RawEncoder> }
}
impl RawEncoder for GB18030Encoder {
fn from_self(&self) -> Box<RawEncoder> { GB18030Encoder::new() }
fn is_ascii_compatible(&self) -> bool { true }
fn raw_feed(&mut self, input: &str, output: &mut ByteWriter) -> (uint, Option<CodecError>) {
output.writer_hint(input.len());
for ch in input.chars() {
if ch < '\u{80}' {
output.write_byte(ch as u8);
} else {
let ptr = index::gb18030::backward(ch as u32);
if ptr == 0xffff {
let ptr = index::gb18030_ranges::backward(ch as u32);
assert!(ptr != 0xffffffff);
let (ptr, byte4) = (ptr / 10, ptr % 10);
let (ptr, byte3) = (ptr / 126, ptr % 126);
let (byte1, byte2) = (ptr / 10, ptr % 10);
output.write_byte((byte1 + 0x81) as u8);
output.write_byte((byte2 + 0x30) as u8);
output.write_byte((byte3 + 0x81) as u8);
output.write_byte((byte4 + 0x30) as u8);
} else {
let lead = ptr / 190 + 0x81;
let trail = ptr % 190;
let trailoffset = if trail < 0x3f {0x40} else {0x41};
output.write_byte(lead as u8);
output.write_byte((trail + trailoffset) as u8);
}
}
}
(input.len(), None)
}
fn raw_finish(&mut self, _output: &mut ByteWriter) -> Option<CodecError> {
None
}
}
ascii_compatible_stateful_decoder! {
#[doc="A decoder for GB 18030."]
#[derive(Clone, Copy)]
struct GB18030Decoder;
module gb18030;
internal pub fn map_two_bytes(lead: u8, trail: u8) -> u32 {
use index_simpchinese as index;
let lead = lead as uint;
let trail = trail as uint;
let index = match (lead, trail) {
(0x81...0xfe, 0x40...0x7e) | (0x81...0xfe, 0x80...0xfe) => {
let trailoffset = if trail < 0x7f {0x40} else {0x41};
(lead - 0x81) * 190 + trail - trailoffset
}
_ => 0xffff,
};
index::gb18030::forward(index as u16)
}
internal pub fn map_four_bytes(b1: u8, b2: u8, b3: u8, b4: u8) -> u32 {
use index_simpchinese as index;
let index = (b1 as uint - 0x81) * 12600 + (b2 as uint - 0x30) * 1260 +
(b3 as uint - 0x81) * 10 + (b4 as uint - 0x30);
index::gb18030_ranges::forward(index as u32)
}
initial state S0(ctx) {
case b @ 0x00...0x7f => ctx.emit(b as u32);
case 0x80 => ctx.emit(0x20ac);
case b @ 0x81...0xfe => S1(ctx, b);
case _ => ctx.err("invalid sequence");
}
state S1(ctx, first: u8) {
case b @ 0x30...0x39 => S2(ctx, first, b);
case b => match map_two_bytes(first, b) {
0xffff => ctx.backup_and_err(1, "invalid sequence"), ch => ctx.emit(ch)
};
}
state S2(ctx, first: u8, second: u8) {
case b @ 0x81...0xfe => S3(ctx, first, second, b);
case _ => ctx.backup_and_err(2, "invalid sequence");
}
state S3(ctx, first: u8, second: u8, third: u8) {
case b @ 0x30...0x39 => match map_four_bytes(first, second, third, b) {
0xffffffff => ctx.backup_and_err(3, "invalid sequence"), ch => ctx.emit(ch)
};
case _ => ctx.backup_and_err(3, "invalid sequence");
}
}
#[cfg(test)]
mod gb18030_tests {
extern crate test;
use super::GB18030Encoding;
use testutils;
use types::*;
#[test]
fn test_encoder_valid() {
let mut e = GB18030Encoding.raw_encoder();
assert_feed_ok!(e, "A", "", [0x41]);
assert_feed_ok!(e, "BC", "", [0x42, 0x43]);
assert_feed_ok!(e, "", "", []);
assert_feed_ok!(e, "\u{4e2d}\u{534e}\u{4eba}\u{6c11}\u{5171}\u{548c}\u{56fd}", "",
[0xd6, 0xd0, 0xbb, 0xaa, 0xc8, 0xcb, 0xc3, 0xf1,
0xb9, 0xb2, 0xba, 0xcd, 0xb9, 0xfa]);
assert_feed_ok!(e, "1\u{20ac}/m", "", [0x31, 0xa2, 0xe3, 0x2f, 0x6d]);
assert_feed_ok!(e, "\u{ff21}\u{ff22}\u{ff23}", "", [0xa3, 0xc1, 0xa3, 0xc2, 0xa3, 0xc3]);
assert_feed_ok!(e, "\u{80}", "", [0x81, 0x30, 0x81, 0x30]);
assert_feed_ok!(e, "\u{81}", "", [0x81, 0x30, 0x81, 0x31]);
assert_feed_ok!(e, "\u{a3}", "", [0x81, 0x30, 0x84, 0x35]);
assert_feed_ok!(e, "\u{a4}", "", [0xa1, 0xe8]);
assert_feed_ok!(e, "\u{a5}", "", [0x81, 0x30, 0x84, 0x36]);
assert_feed_ok!(e, "\u{10ffff}", "", [0xe3, 0x32, 0x9a, 0x35]);
assert_feed_ok!(e, "\u{2a6a5}\u{3007}", "", [0x98, 0x35, 0xee, 0x37, 0xa9, 0x96]);
assert_finish_ok!(e, []);
}
#[test]
fn test_decoder_valid() {
let mut d = GB18030Encoding.raw_decoder();
assert_feed_ok!(d, [0x41], [], "A");
assert_feed_ok!(d, [0x42, 0x43], [], "BC");
assert_feed_ok!(d, [], [], "");
assert_feed_ok!(d, [0xd6, 0xd0, 0xbb, 0xaa, 0xc8, 0xcb, 0xc3, 0xf1,
0xb9, 0xb2, 0xba, 0xcd, 0xb9, 0xfa], [],
"\u{4e2d}\u{534e}\u{4eba}\u{6c11}\u{5171}\u{548c}\u{56fd}");
assert_feed_ok!(d, [0x31, 0x80, 0x2f, 0x6d], [], "1\u{20ac}/m");
assert_feed_ok!(d, [0xa3, 0xc1, 0xa3, 0xc2, 0xa3, 0xc3], [], "\u{ff21}\u{ff22}\u{ff23}");
assert_feed_ok!(d, [0x81, 0x30, 0x81, 0x30], [], "\u{80}");
assert_feed_ok!(d, [0x81, 0x30, 0x81, 0x31], [], "\u{81}");
assert_feed_ok!(d, [0x81, 0x30, 0x84, 0x35], [], "\u{a3}");
assert_feed_ok!(d, [0xa1, 0xe8], [], "\u{a4}" );
assert_feed_ok!(d, [0x81, 0x30, 0x84, 0x36], [], "\u{a5}");
assert_feed_ok!(d, [0xe3, 0x32, 0x9a, 0x35], [], "\u{10ffff}");
assert_feed_ok!(d, [0x98, 0x35, 0xee, 0x37, 0xa9, 0x96], [], "\u{2a6a5}\u{3007}");
assert_finish_ok!(d, "");
}
#[test]
fn test_decoder_valid_partial() {
let mut d = GB18030Encoding.raw_decoder();
assert_feed_ok!(d, [], [0xa1], "");
assert_feed_ok!(d, [0xa1], [], "\u{3000}");
assert_feed_ok!(d, [], [0x81], "");
assert_feed_ok!(d, [], [0x30], "");
assert_feed_ok!(d, [], [0x81], "");
assert_feed_ok!(d, [0x30], [], "\u{80}");
assert_feed_ok!(d, [], [0x81], "");
assert_feed_ok!(d, [], [0x30], "");
assert_feed_ok!(d, [0x81, 0x31], [], "\u{81}");
assert_feed_ok!(d, [], [0x81], "");
assert_feed_ok!(d, [0x30, 0x81, 0x32], [], "\u{82}");
assert_feed_ok!(d, [], [0x81], "");
assert_feed_ok!(d, [], [0x30, 0x81], "");
assert_feed_ok!(d, [0x33], [], "\u{83}");
assert_feed_ok!(d, [], [0x81, 0x30], "");
assert_feed_ok!(d, [], [0x81], "");
assert_feed_ok!(d, [0x34], [], "\u{84}");
assert_feed_ok!(d, [], [0x81, 0x30], "");
assert_feed_ok!(d, [0x81, 0x35], [], "\u{85}");
assert_feed_ok!(d, [], [0x81, 0x30, 0x81], "");
assert_feed_ok!(d, [0x36], [], "\u{86}");
assert_finish_ok!(d, "");
}
#[test]
fn test_decoder_invalid_partial() {
let mut d = GB18030Encoding.raw_decoder();
assert_feed_ok!(d, [], [0xa1], "");
assert_finish_err!(d, "");
let mut d = GB18030Encoding.raw_decoder();
assert_feed_ok!(d, [], [0x81], "");
assert_finish_err!(d, "");
let mut d = GB18030Encoding.raw_decoder();
assert_feed_ok!(d, [], [0x81, 0x30], "");
assert_finish_err!(d, "");
let mut d = GB18030Encoding.raw_decoder();
assert_feed_ok!(d, [], [0x81, 0x30, 0x81], "");
assert_finish_err!(d, "");
}
#[test]
fn test_decoder_invalid_out_of_range() {
let mut d = GB18030Encoding.raw_decoder();
assert_feed_err!(d, [], [0xff], [], "");
assert_feed_err!(d, [], [0x81], [0x00], "");
assert_feed_err!(d, [], [0x81], [0x7f], "");
assert_feed_err!(d, [], [0x81], [0xff], "");
assert_feed_err!(d, [], [0x81], [0x31, 0x00], "");
assert_feed_err!(d, [], [0x81], [0x31, 0x80], "");
assert_feed_err!(d, [], [0x81], [0x31, 0xff], "");
assert_feed_err!(d, [], [0x81], [0x31, 0x81, 0x00], "");
assert_feed_err!(d, [], [0x81], [0x31, 0x81, 0x2f], "");
assert_feed_err!(d, [], [0x81], [0x31, 0x81, 0x3a], "");
assert_feed_err!(d, [], [0x81], [0x31, 0x81, 0xff], "");
assert_finish_ok!(d, "");
}
#[test]
fn test_decoder_invalid_boundary() {
let mut d = GB18030Encoding.raw_decoder();
assert_feed_ok!(d, [], [0xe3], "");
assert_feed_err!(d, [], [], [0x32, 0x9a, 0x36], "");
assert_finish_ok!(d, "");
let mut d = GB18030Encoding.raw_decoder();
assert_feed_ok!(d, [], [0xe3], "");
assert_feed_ok!(d, [], [0x32, 0x9a], "");
assert_feed_err!(d, -2, [], [], [0x32, 0x9a, 0x36], "");
assert_finish_ok!(d, "");
}
#[test]
fn test_decoder_feed_after_finish() {
let mut d = GB18030Encoding.raw_decoder();
assert_feed_ok!(d, [0xd2, 0xbb], [0xd2], "\u{4e00}");
assert_finish_err!(d, "");
assert_feed_ok!(d, [0xd2, 0xbb], [], "\u{4e00}");
assert_finish_ok!(d, "");
let mut d = GB18030Encoding.raw_decoder();
assert_feed_ok!(d, [0x98, 0x35, 0xee, 0x37], [0x98, 0x35, 0xee], "\u{2a6a5}");
assert_finish_err!(d, "");
assert_feed_ok!(d, [0x98, 0x35, 0xee, 0x37], [0x98, 0x35], "\u{2a6a5}");
assert_finish_err!(d, "");
assert_feed_ok!(d, [0x98, 0x35, 0xee, 0x37], [0x98], "\u{2a6a5}");
assert_finish_err!(d, "");
assert_feed_ok!(d, [0x98, 0x35, 0xee, 0x37], [], "\u{2a6a5}");
assert_finish_ok!(d, "");
}
#[bench]
fn bench_encode_short_text(bencher: &mut test::Bencher) {
let s = testutils::SIMPLIFIED_CHINESE_TEXT;
bencher.bytes = s.len() as u64;
bencher.iter(|| test::black_box({
GB18030Encoding.encode(s[], EncoderTrap::Strict)
}))
}
#[bench]
fn bench_decode_short_text(bencher: &mut test::Bencher) {
let s = GB18030Encoding.encode(testutils::SIMPLIFIED_CHINESE_TEXT,
EncoderTrap::Strict).ok().unwrap();
bencher.bytes = s.len() as u64;
bencher.iter(|| test::black_box({
GB18030Encoding.decode(s[], DecoderTrap::Strict)
}))
}
}
#[derive(Clone, Copy)]
pub struct HZEncoding;
impl Encoding for HZEncoding {
fn name(&self) -> &'static str { "hz" }
fn whatwg_name(&self) -> Option<&'static str> { Some("hz-gb-2312") }
fn raw_encoder(&self) -> Box<RawEncoder> { HZEncoder::new() }
fn raw_decoder(&self) -> Box<RawDecoder> { HZDecoder::new() }
}
#[derive(Clone, Copy)]
pub struct HZEncoder {
escaped: bool,
}
impl HZEncoder {
pub fn new() -> Box<RawEncoder> { box HZEncoder { escaped: false } as Box<RawEncoder> }
}
impl RawEncoder for HZEncoder {
fn from_self(&self) -> Box<RawEncoder> { HZEncoder::new() }
fn is_ascii_compatible(&self) -> bool { false }
fn raw_feed(&mut self, input: &str, output: &mut ByteWriter) -> (uint, Option<CodecError>) {
output.writer_hint(input.len());
let mut escaped = self.escaped;
macro_rules! ensure_escaped(
() => (if !escaped { output.write_bytes(b"~{"); escaped = true; })
);
macro_rules! ensure_unescaped(
() => (if escaped { output.write_bytes(b"~}"); escaped = false; })
);
for ((i,j), ch) in input.index_iter() {
if ch < '\u{80}' {
ensure_unescaped!();
output.write_byte(ch as u8);
if ch == '~' { output.write_byte('~' as u8); }
} else {
let ptr = index::gb18030::backward(ch as u32);
if ptr == 0xffff {
self.escaped = escaped; return (i, Some(CodecError {
upto: j as int, cause: "unrepresentable character".into_cow()
}));
} else {
let lead = ptr / 190;
let trail = ptr % 190;
if lead < 0x21 - 1 || trail < 0x21 + 0x3f { self.escaped = escaped; return (i, Some(CodecError {
upto: j as int, cause: "unrepresentable character".into_cow()
}));
} else {
ensure_escaped!();
output.write_byte((lead + 1) as u8);
output.write_byte((trail - 0x3f) as u8);
}
}
}
}
self.escaped = escaped;
(input.len(), None)
}
fn raw_finish(&mut self, _output: &mut ByteWriter) -> Option<CodecError> {
None
}
}
stateful_decoder! {
#[doc="A decoder for HZ."]
#[derive(Clone, Copy)]
struct HZDecoder;
module hz;
ascii_compatible false;
internal pub fn map_two_bytes(lead: u8, trail: u8) -> u32 {
use index_simpchinese as index;
let lead = lead as uint;
let trail = trail as uint;
let index = match (lead, trail) {
(0x20...0x7f, 0x21...0x7e) => (lead - 1) * 190 + (trail + 0x3f),
_ => 0xffff,
};
index::gb18030::forward(index as u16)
}
initial state A0(ctx) {
case 0x7e => A1(ctx);
case b @ 0x00...0x7f => ctx.emit(b as u32);
case _ => ctx.err("invalid sequence");
final => ctx.reset();
}
checkpoint state B0(ctx) {
case 0x7e => B1(ctx);
case b @ 0x20...0x7f => B2(ctx, b);
case 0x0a => ctx.err("invalid sequence"); case _ => ctx.err("invalid sequence"), B0(ctx);
final => ctx.reset();
}
state A1(ctx) {
case 0x7b => B0(ctx);
case 0x7d => A0(ctx);
case 0x7e => ctx.emit(0x7e), A0(ctx);
case 0x0a => A0(ctx);
case _ => ctx.backup_and_err(1, "invalid sequence");
final => ctx.err("incomplete sequence");
}
state B1(ctx) {
case 0x7b => B0(ctx);
case 0x7d => A0(ctx);
case 0x7e => ctx.emit(0x7e), B0(ctx);
case 0x0a => A0(ctx);
case _ => ctx.backup_and_err(1, "invalid sequence"), B0(ctx);
final => ctx.err("incomplete sequence");
}
state B2(ctx, lead: u8) {
case 0x0a => ctx.err("invalid sequence"); case b =>
match map_two_bytes(lead, b) {
0xffff => ctx.err("invalid sequence"),
ch => ctx.emit(ch)
},
B0(ctx);
final => ctx.err("incomplete sequence");
}
}
#[cfg(test)]
mod hz_tests {
extern crate test;
use super::HZEncoding;
use testutils;
use types::*;
#[test]
fn test_encoder_valid() {
let mut e = HZEncoding.raw_encoder();
assert_feed_ok!(e, "A", "", b"A");
assert_feed_ok!(e, "BC", "", b"BC");
assert_feed_ok!(e, "", "", b"");
assert_feed_ok!(e, "\u{4e2d}\u{534e}\u{4eba}\u{6c11}\u{5171}\u{548c}\u{56fd}", "",
b"~{VP;*HKCq92:M9z");
assert_feed_ok!(e, "\u{ff21}\u{ff22}\u{ff23}", "", b"#A#B#C");
assert_feed_ok!(e, "1\u{20ac}/m", "", b"~}1~{\"c~}/m");
assert_feed_ok!(e, "~<\u{a4}~\u{0a4}>~", "", b"~~<~{!h~}~~~{!h~}>~~");
assert_finish_ok!(e, []);
}
#[test]
fn test_encoder_invalid() {
let mut e = HZEncoding.raw_encoder();
assert_feed_err!(e, "", "\u{ffff}", "", []);
assert_feed_err!(e, "?", "\u{ffff}", "!", [0x3f]);
assert_feed_err!(e, "", "\u{3007}", "", []);
assert_finish_ok!(e, []);
}
#[test]
fn test_decoder_valid() {
let mut d = HZEncoding.raw_decoder();
assert_feed_ok!(d, b"A", b"", "A");
assert_feed_ok!(d, b"BC", b"", "BC");
assert_feed_ok!(d, b"D~~E", b"~", "D~E");
assert_feed_ok!(d, b"~F~\nG", b"~", "~FG");
assert_feed_ok!(d, b"", b"", "");
assert_feed_ok!(d, b"\nH", b"~", "H");
assert_feed_ok!(d, b"{VP~}~{;*~{HKCq92:M9z", b"",
"\u{4e2d}\u{534e}\u{4eba}\u{6c11}\u{5171}\u{548c}\u{56fd}");
assert_feed_ok!(d, b"", b"#", "");
assert_feed_ok!(d, b"A", b"~", "\u{ff21}");
assert_feed_ok!(d, b"~#B~~#C", b"~", "~\u{ff22}~\u{ff23}");
assert_feed_ok!(d, b"", b"", "");
assert_feed_ok!(d, b"\n#D~{#E~\n#F~{#G", b"~", "#D\u{ff25}#F\u{ff27}");
assert_feed_ok!(d, b"}X~}YZ", b"", "XYZ");
assert_finish_ok!(d, "");
}
#[test]
fn test_decoder_invalid_out_or_range() {
let mut d = HZEncoding.raw_decoder();
assert_feed_ok!(d, b"~{", b"", "");
assert_feed_err!(d, b"", b"\x20\x20", b"", "");
assert_feed_err!(d, b"", b"\x20\x7f", b"", ""); assert_feed_err!(d, b"", b"\x21\x7f", b"", "");
assert_feed_err!(d, b"", b"\x7f\x20", b"", "");
assert_feed_err!(d, b"", b"\x7f\x21", b"", "");
assert_feed_err!(d, b"", b"\x7f\x7f", b"", "");
assert_finish_ok!(d, "");
}
#[test]
fn test_decoder_invalid_carriage_return() {
let mut d = HZEncoding.raw_decoder();
assert_feed_ok!(d, b"~{#A", b"", "\u{ff21}");
assert_feed_err!(d, b"", b"\n", b"", "");
assert_feed_ok!(d, b"#B~{#C", b"", "#B\u{ff23}");
assert_feed_err!(d, b"", b"#\n", b"", "");
assert_feed_ok!(d, b"#D", b"", "#D");
assert_finish_ok!(d, "");
}
#[test]
fn test_decoder_invalid_partial() {
let mut d = HZEncoding.raw_decoder();
assert_feed_ok!(d, b"", b"~", "");
assert_finish_err!(d, "");
let mut d = HZEncoding.raw_decoder();
assert_feed_ok!(d, b"~{", b"#", "");
assert_finish_err!(d, "");
let mut d = HZEncoding.raw_decoder();
assert_feed_ok!(d, b"~{#A", b"~", "\u{ff21}");
assert_finish_err!(d, "");
}
#[test]
fn test_decoder_invalid_escape() {
let mut d = HZEncoding.raw_decoder();
assert_feed_ok!(d, b"#A", b"", "#A");
assert_feed_err!(d, b"", b"~", b"xy", "");
assert_feed_ok!(d, b"#B", b"", "#B");
assert_feed_ok!(d, b"", b"~", "");
assert_feed_err!(d, b"", b"", b"xy", "");
assert_feed_ok!(d, b"#C~{#D", b"", "#C\u{ff24}");
assert_feed_err!(d, b"", b"~", b"xy", "");
assert_feed_ok!(d, b"#E", b"", "\u{ff25}"); assert_feed_ok!(d, b"", b"~", "");
assert_feed_err!(d, b"", b"", b"xy", "");
assert_feed_ok!(d, b"#F~}#G", b"", "\u{ff26}#G");
assert_finish_ok!(d, "");
}
#[test]
fn test_decoder_feed_after_finish() {
let mut d = HZEncoding.raw_decoder();
assert_feed_ok!(d, b"R;~{R;", b"R", "R;\u{4e00}");
assert_finish_err!(d, "");
assert_feed_ok!(d, b"R;~{R;", b"", "R;\u{4e00}");
assert_finish_ok!(d, "");
}
#[bench]
fn bench_encode_short_text(bencher: &mut test::Bencher) {
let s = testutils::SIMPLIFIED_CHINESE_TEXT;
bencher.bytes = s.len() as u64;
bencher.iter(|| test::black_box({
HZEncoding.encode(s[], EncoderTrap::Strict)
}))
}
#[bench]
fn bench_decode_short_text(bencher: &mut test::Bencher) {
let s = HZEncoding.encode(testutils::SIMPLIFIED_CHINESE_TEXT,
EncoderTrap::Strict).ok().unwrap();
bencher.bytes = s.len() as u64;
bencher.iter(|| test::black_box({
HZEncoding.decode(s[], DecoderTrap::Strict)
}))
}
}