use strict;
use LWP;
use threads;
use threads::shared;
use Socket;
use bytes;

my $ua = LWP::UserAgent->new;
our $current :shared;
our $get :shared = 1212121;
# our $get :shared = 999777;

sub post {
    my $postnum = shift;

    print $postnum,"\n";
######################### КО-КО-КОНФИГ############################################

    my $data = qq%email=&homeboard=anonymous&category=&title=Хуй вам&link=&text=а не гет %.(chr(65279) x 100).q/&text_full=/;
#####################################################################


    return if $postnum != ($get-1);


    my $socket;
    socket($socket, PF_INET, SOCK_STREAM, getprotobyname('tcp')) or die;
    connect($socket, sockaddr_in(80,inet_aton('1chan.ru'))) or die;


# Да, быдлокод, но мне лень сделать нормально через HTTP::Request
# окончания строк в файле должны быть Win (\r\n)
send ($socket, 'POST /news/add/ HTTP/1.1
User-Agent: Opera/9.80 (Windows NT 6.1; U; ru) Presto/2.10.229 Version/11.60
Host: 1chan.ru
Accept: text/html, application/xml;q=0.9, application/xhtml+xml, image/png, image/webp, image/jpeg, image/gif, image/x-xbitmap, */*;q=0.1
Accept-Language: ru-RU,ru;q=0.9,en;q=0.8
Referer: http://1chan.ru/news/add/'.
#Cookie: PHPSESSID=sis1vcssu3v981jbam8g497ln2; key=c8ce55483bc36886a1ed310580c8d66c4ef5c260e4a7c
'
Connection: close
Content-Length: '.length($data).'
Content-Type: application/x-www-form-urlencoded

'.$data, 0) or die;

    while(<$socket>){print $_,"\n"};
    close $socket;


}



threads->new( sub {while(1){

        $ua->get('http://pipe.1chan.ru/?identifier=1chan_post_last_comments')->decoded_content =~m/,"id":([0-9]+)}}/;
        post($current = $1);

}} );

threads->new( sub {while(1){

    if(
        $ua->get('http://pipe.1chan.ru/?identifier=1chan_posts')
        ->decoded_content =~ m/"event":"add_post"/
        ){
            post(++$current);
    }

}} );

sleep;