Blame src/Bencode.cc

Packit 8f70b4
/*
Packit 8f70b4
 * lftp - file transfer program
Packit 8f70b4
 *
Packit 8f70b4
 * Copyright (c) 1996-2012 by Alexander V. Lukyanov (lav@yars.free.net)
Packit 8f70b4
 *
Packit 8f70b4
 * This program is free software; you can redistribute it and/or modify
Packit 8f70b4
 * it under the terms of the GNU General Public License as published by
Packit 8f70b4
 * the Free Software Foundation; either version 3 of the License, or
Packit 8f70b4
 * (at your option) any later version.
Packit 8f70b4
 *
Packit 8f70b4
 * This program is distributed in the hope that it will be useful,
Packit 8f70b4
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
Packit 8f70b4
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
Packit 8f70b4
 * GNU General Public License for more details.
Packit 8f70b4
 *
Packit 8f70b4
 * You should have received a copy of the GNU General Public License
Packit 8f70b4
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
Packit 8f70b4
 */
Packit 8f70b4
Packit 8f70b4
#include <config.h>
Packit 8f70b4
#include <stdio.h>
Packit 8f70b4
#include "Bencode.h"
Packit 8f70b4
#include "c-ctype.h"
Packit 8f70b4
Packit 8f70b4
BeNode::BeNode(long long n)
Packit 8f70b4
   : type(BE_INT),num(n)
Packit 8f70b4
{}
Packit 8f70b4
BeNode::BeNode(const xstring& s)
Packit 8f70b4
   : type(BE_STR),str(s.get(),s.length())
Packit 8f70b4
{}
Packit 8f70b4
BeNode::BeNode(const char *s,int len)
Packit 8f70b4
   : type(BE_STR),str(s,len)
Packit 8f70b4
{}
Packit 8f70b4
BeNode::BeNode(const char *s)
Packit 8f70b4
   : type(BE_STR),str(s)
Packit 8f70b4
{}
Packit 8f70b4
BeNode::BeNode(xarray_p<BeNode> *a)
Packit 8f70b4
   : type(BE_LIST)
Packit 8f70b4
{
Packit 8f70b4
   list.move_here(*a);
Packit 8f70b4
}
Packit 8f70b4
BeNode::BeNode(xmap_p<BeNode> *m)
Packit 8f70b4
   : type(BE_DICT)
Packit 8f70b4
{
Packit 8f70b4
   dict.move_here(*m);
Packit 8f70b4
}
Packit 8f70b4
Packit 8f70b4
BeNode *BeNode::Parse(const char *s,int s_len,int *rest)
Packit 8f70b4
{
Packit 8f70b4
   if(s_len<2) {
Packit 8f70b4
      *rest=0;
Packit 8f70b4
      return 0;
Packit 8f70b4
   }
Packit 8f70b4
   switch(*s)
Packit 8f70b4
   {
Packit 8f70b4
   case 'i':
Packit 8f70b4
   {
Packit 8f70b4
      s++;
Packit 8f70b4
      s_len--;
Packit 8f70b4
      bool neg=false;
Packit 8f70b4
      if(*s=='-') {
Packit 8f70b4
	 neg=true;
Packit 8f70b4
	 s++;
Packit 8f70b4
	 s_len--;
Packit 8f70b4
      }
Packit 8f70b4
      if(s_len<2) {
Packit 8f70b4
	 *rest=0;
Packit 8f70b4
	 return 0;
Packit 8f70b4
      }
Packit 8f70b4
      if(c_isdigit(*s))
Packit 8f70b4
      {
Packit 8f70b4
	 if(*s=='0' && s[1]!='e') {
Packit 8f70b4
	    *rest=s_len;
Packit 8f70b4
	    return 0;
Packit 8f70b4
	 }
Packit 8f70b4
	 long long n=*s++-'0';
Packit 8f70b4
	 s_len--;
Packit 8f70b4
	 while(s_len>1 && c_isdigit(*s)) {
Packit 8f70b4
	    n=n*10+*s++-'0';
Packit 8f70b4
	    s_len--;
Packit 8f70b4
	 }
Packit 8f70b4
	 if(s_len<1 || *s!='e') {
Packit 8f70b4
	    *rest=s_len;
Packit 8f70b4
	    return 0;
Packit 8f70b4
	 }
Packit 8f70b4
	 *rest=s_len-1;
Packit 8f70b4
	 return new BeNode(neg?-n:n);
Packit 8f70b4
      }
Packit 8f70b4
      *rest=s_len;
Packit 8f70b4
      return 0;
Packit 8f70b4
   }
Packit 8f70b4
   case 'l':
Packit 8f70b4
   {
Packit 8f70b4
      s++;
Packit 8f70b4
      s_len--;
Packit 8f70b4
      xarray_p<BeNode> a;
Packit 8f70b4
      while(s_len>1 && *s!='e')
Packit 8f70b4
      {
Packit 8f70b4
	 int rest1;
Packit 8f70b4
	 BeNode *n=Parse(s,s_len,&rest1);
Packit 8f70b4
	 if(!n) {
Packit 8f70b4
	    *rest=rest1;
Packit 8f70b4
	    return 0;
Packit 8f70b4
	 }
Packit 8f70b4
	 a.append(n);
Packit 8f70b4
	 s+=(s_len-rest1);
Packit 8f70b4
	 s_len=rest1;
Packit 8f70b4
      }
Packit 8f70b4
      if(s_len<1 || *s!='e') {
Packit 8f70b4
	 *rest=s_len;
Packit 8f70b4
	 return 0;
Packit 8f70b4
      }
Packit 8f70b4
      *rest=s_len-1;
Packit 8f70b4
      return new BeNode(&a);
Packit 8f70b4
   }
Packit 8f70b4
   case 'd':
Packit 8f70b4
   {
Packit 8f70b4
      const char *d_begin=s;
Packit 8f70b4
      s++;
Packit 8f70b4
      s_len--;
Packit 8f70b4
      xmap_p<BeNode> map;
Packit 8f70b4
      while(s_len>1 && *s!='e')
Packit 8f70b4
      {
Packit 8f70b4
	 int rest1;
Packit 8f70b4
	 Ref<BeNode> n(Parse(s,s_len,&rest1));
Packit 8f70b4
	 if(!n) {
Packit 8f70b4
	    *rest=rest1;
Packit 8f70b4
	    return 0;
Packit 8f70b4
	 }
Packit 8f70b4
	 if(n->type!=BE_STR) {
Packit 8f70b4
	    *rest=s_len;
Packit 8f70b4
	    return 0;
Packit 8f70b4
	 }
Packit 8f70b4
	 s+=(s_len-rest1);
Packit 8f70b4
	 s_len=rest1;
Packit 8f70b4
	 BeNode *v=Parse(s,s_len,&rest1);
Packit 8f70b4
	 if(!v) {
Packit 8f70b4
	    *rest=rest1;
Packit 8f70b4
	    return 0;
Packit 8f70b4
	 }
Packit 8f70b4
	 map.add(n->str,v);
Packit 8f70b4
	 s+=(s_len-rest1);
Packit 8f70b4
	 s_len=rest1;
Packit 8f70b4
      }
Packit 8f70b4
      if(s_len<1 || *s!='e') {
Packit 8f70b4
	 *rest=s_len;
Packit 8f70b4
	 return 0;
Packit 8f70b4
      }
Packit 8f70b4
      s++;
Packit 8f70b4
      s_len--;
Packit 8f70b4
      *rest=s_len;
Packit 8f70b4
      BeNode *node=new BeNode(&map);
Packit 8f70b4
      node->str.nset(d_begin,s-d_begin);
Packit 8f70b4
      return node;
Packit 8f70b4
   }
Packit 8f70b4
   default:
Packit 8f70b4
      if(c_isdigit(*s))
Packit 8f70b4
      {
Packit 8f70b4
	 int n=*s++-'0';
Packit 8f70b4
	 s_len--;
Packit 8f70b4
	 while(s_len>0 && c_isdigit(*s)) {
Packit 8f70b4
	    if(n>=s_len) {
Packit 8f70b4
	       *rest=0;
Packit 8f70b4
	       return 0;
Packit 8f70b4
	    }
Packit 8f70b4
	    n=n*10+*s++-'0';
Packit 8f70b4
	    s_len--;
Packit 8f70b4
	 }
Packit 8f70b4
	 if(s_len<1 || *s!=':') {
Packit 8f70b4
	    *rest=s_len;
Packit 8f70b4
	    return 0;
Packit 8f70b4
	 }
Packit 8f70b4
	 s++;
Packit 8f70b4
	 s_len--;
Packit 8f70b4
	 if(s_len
Packit 8f70b4
	    *rest=0;
Packit 8f70b4
	    return 0;
Packit 8f70b4
	 }
Packit 8f70b4
	 *rest=s_len-n;
Packit 8f70b4
	 return new BeNode(s,n);
Packit 8f70b4
      }
Packit 8f70b4
      *rest=s_len;
Packit 8f70b4
      return 0;
Packit 8f70b4
   }
Packit 8f70b4
}
Packit 8f70b4
Packit 8f70b4
BeNode::~BeNode()
Packit 8f70b4
{
Packit 8f70b4
   for(int i=0; i
Packit 8f70b4
      delete list[i];
Packit 8f70b4
      list[i]=0;
Packit 8f70b4
   }
Packit 8f70b4
   for(BeNode *e=dict.each_begin(); e; e=dict.each_next())
Packit 8f70b4
   {
Packit 8f70b4
      delete e;
Packit 8f70b4
      dict.each_set(0);
Packit 8f70b4
   }
Packit 8f70b4
}
Packit 8f70b4
Packit 8f70b4
void BeNode::Format(xstring &buf,int level)
Packit 8f70b4
{
Packit 8f70b4
   int i;
Packit 8f70b4
   for(i=0; i
Packit 8f70b4
      buf.append('\t');
Packit 8f70b4
   switch(type)
Packit 8f70b4
   {
Packit 8f70b4
   case BE_STR:
Packit 8f70b4
      buf.append("STR: ");
Packit 8f70b4
      (str_lc?str_lc:str).dump_to(buf);
Packit 8f70b4
      buf.append("\n");
Packit 8f70b4
      break;
Packit 8f70b4
   case BE_INT:
Packit 8f70b4
      buf.appendf("INT: %lld\n",num);
Packit 8f70b4
      break;
Packit 8f70b4
   case BE_LIST:
Packit 8f70b4
      buf.appendf("LIST: %d items\n",list.count());
Packit 8f70b4
      for(i=0; i
Packit 8f70b4
	 list[i]->Format(buf,level+1);
Packit 8f70b4
      break;
Packit 8f70b4
   case BE_DICT:
Packit 8f70b4
      buf.appendf("DICT: %d items\n",dict.count());
Packit 8f70b4
      for(BeNode *e=dict.each_begin(); e; e=dict.each_next())
Packit 8f70b4
      {
Packit 8f70b4
	 for(i=0; i
Packit 8f70b4
	    buf.append('\t');
Packit 8f70b4
	 buf.appendf("KEY=%s:\n",dict.each_key().get());
Packit 8f70b4
	 e->Format(buf,level+2);
Packit 8f70b4
      }
Packit 8f70b4
      break;
Packit 8f70b4
   }
Packit 8f70b4
}
Packit 8f70b4
Packit 8f70b4
const char *BeNode::Format()
Packit 8f70b4
{
Packit 8f70b4
   static xstring buf;
Packit 8f70b4
   buf.set("");
Packit 8f70b4
   Format(buf,0);
Packit 8f70b4
   return buf;
Packit 8f70b4
}
Packit 8f70b4
Packit 8f70b4
#include <sys/socket.h>
Packit 8f70b4
#include <arpa/inet.h>
Packit 8f70b4
Packit 8f70b4
void BeNode::Format1(xstring &buf)
Packit 8f70b4
{
Packit 8f70b4
   int i;
Packit 8f70b4
   switch(type)
Packit 8f70b4
   {
Packit 8f70b4
   case BE_STR:
Packit 8f70b4
      buf.append('"');
Packit 8f70b4
      (str_lc?str_lc:str).dump_to(buf);
Packit 8f70b4
      buf.append('"');
Packit 8f70b4
      break;
Packit 8f70b4
   case BE_INT:
Packit 8f70b4
      buf.appendf("%lld",num);
Packit 8f70b4
      break;
Packit 8f70b4
   case BE_LIST:
Packit 8f70b4
      buf.append('[');
Packit 8f70b4
      for(i=0; i
Packit 8f70b4
	 if(i>0)
Packit 8f70b4
	    buf.append(", ");
Packit 8f70b4
	 list[i]->Format1(buf);
Packit 8f70b4
      }
Packit 8f70b4
      buf.append(']');
Packit 8f70b4
      break;
Packit 8f70b4
   case BE_DICT:
Packit 8f70b4
      buf.append('{');
Packit 8f70b4
      i=0;
Packit 8f70b4
      for(BeNode *e=dict.each_begin(); e; e=dict.each_next(), i++)
Packit 8f70b4
      {
Packit 8f70b4
	 if(i>0)
Packit 8f70b4
	    buf.append(", ");
Packit 8f70b4
	 const xstring& key=dict.each_key();
Packit 8f70b4
	 buf.appendf("\"%s\":",key.get());
Packit 8f70b4
	 if(e->type==BE_STR) {
Packit 8f70b4
	    char tmp[40];
Packit 8f70b4
	    if(e->str.length()==4 && (key.eq("ip",2) || key.eq("ipv4",4) || key.eq("yourip",6))) {
Packit 8f70b4
	       inet_ntop(AF_INET,e->str.get(),tmp,sizeof(tmp));
Packit 8f70b4
	       buf.append(tmp);
Packit 8f70b4
	       continue;
Packit 8f70b4
	    }
Packit 8f70b4
#if INET6
Packit 8f70b4
	    else if(e->str.length()==16 && (key.eq("ip",2) || key.eq("ipv6",4) || key.eq("yourip",6))) {
Packit 8f70b4
	       inet_ntop(AF_INET6,e->str.get(),tmp,sizeof(tmp));
Packit 8f70b4
	       buf.append(tmp);
Packit 8f70b4
	       continue;
Packit 8f70b4
	    }
Packit 8f70b4
#endif//INET6
Packit 8f70b4
	 }
Packit 8f70b4
	 e->Format1(buf);
Packit 8f70b4
      }
Packit 8f70b4
      buf.append('}');
Packit 8f70b4
      break;
Packit 8f70b4
   }
Packit 8f70b4
}
Packit 8f70b4
const char *BeNode::Format1()
Packit 8f70b4
{
Packit 8f70b4
   static xstring buf;
Packit 8f70b4
   buf.set("");
Packit 8f70b4
   Format1(buf);
Packit 8f70b4
   return buf;
Packit 8f70b4
}
Packit 8f70b4
Packit 8f70b4
const char *BeNode::TypeName(be_type_t t)
Packit 8f70b4
{
Packit 8f70b4
   static const char *table[]={
Packit 8f70b4
      "STR",
Packit 8f70b4
      "INT",
Packit 8f70b4
      "LIST",
Packit 8f70b4
      "DICT"
Packit 8f70b4
   };
Packit 8f70b4
   return table[t];
Packit 8f70b4
}
Packit 8f70b4
Packit 8f70b4
int BeNode::ComputeLength()
Packit 8f70b4
{
Packit 8f70b4
   int len=0;
Packit 8f70b4
   int i;
Packit 8f70b4
   switch(type)
Packit 8f70b4
   {
Packit 8f70b4
   case BE_STR:
Packit 8f70b4
      i=str.length();
Packit 8f70b4
      len+=1+i; // ':' + string
Packit 8f70b4
      while(i>=10) {
Packit 8f70b4
	 len++;
Packit 8f70b4
	 i/=10;
Packit 8f70b4
      }
Packit 8f70b4
      len++; // last digit
Packit 8f70b4
      break;
Packit 8f70b4
   case BE_INT:
Packit 8f70b4
      len+=1+xstring::format("%lld",num).length()+1; // 'i' + number + 'e'
Packit 8f70b4
      break;
Packit 8f70b4
   case BE_LIST:
Packit 8f70b4
      len++; // 'l'
Packit 8f70b4
      for(i=0; i
Packit 8f70b4
	 len+=list[i]->ComputeLength();
Packit 8f70b4
      len++; // 'e'
Packit 8f70b4
      break;
Packit 8f70b4
   case BE_DICT:
Packit 8f70b4
      len++; // 'd'
Packit 8f70b4
      for(BeNode *e=dict.each_begin(); e; e=dict.each_next())
Packit 8f70b4
      {
Packit 8f70b4
	 const xstring &key=dict.each_key();
Packit 8f70b4
	 i=key.length();
Packit 8f70b4
	 len+=1+i; // ':' + string
Packit 8f70b4
	 while(i>=10) {
Packit 8f70b4
	    len++;
Packit 8f70b4
	    i/=10;
Packit 8f70b4
	 }
Packit 8f70b4
	 len++; // last digit
Packit 8f70b4
	 len+=e->ComputeLength();
Packit 8f70b4
      }
Packit 8f70b4
      len++; // 'e'
Packit 8f70b4
      break;
Packit 8f70b4
   }
Packit 8f70b4
   return len;
Packit 8f70b4
}
Packit 8f70b4
Packit 8f70b4
void BeNode::Pack(const SMTaskRef<IOBuffer> &buf)
Packit 8f70b4
{
Packit 8f70b4
   xstring &tmp=xstring::get_tmp("");
Packit 8f70b4
   Pack(tmp);
Packit 8f70b4
   buf->Put(tmp);
Packit 8f70b4
}
Packit 8f70b4
static int xstring_ptr_cmp(const xstring*const*a,const xstring*const*b)
Packit 8f70b4
{
Packit 8f70b4
   return (*a)->cmp(**b);
Packit 8f70b4
}
Packit 8f70b4
void BeNode::PackDict(xstring &buf)
Packit 8f70b4
{
Packit 8f70b4
   xarray<const xstring*> keys;
Packit 8f70b4
   for(BeNode *e=dict.each_begin(); e; e=dict.each_next())
Packit 8f70b4
      keys.append(&dict.each_key());
Packit 8f70b4
   keys.qsort(xstring_ptr_cmp);
Packit 8f70b4
   for(int i=0; i
Packit 8f70b4
   {
Packit 8f70b4
      const xstring &key=*keys[i];
Packit 8f70b4
      buf.appendf("%d:",(int)key.length());
Packit 8f70b4
      buf.append(key);
Packit 8f70b4
      dict.lookup(key)->Pack(buf);
Packit 8f70b4
   }
Packit 8f70b4
}
Packit 8f70b4
void BeNode::Pack(xstring &buf)
Packit 8f70b4
{
Packit 8f70b4
   int i;
Packit 8f70b4
   switch(type)
Packit 8f70b4
   {
Packit 8f70b4
   case BE_STR:
Packit 8f70b4
      i=str.length();
Packit 8f70b4
      buf.appendf("%d:",i);
Packit 8f70b4
      buf.append(str);
Packit 8f70b4
      break;
Packit 8f70b4
   case BE_INT:
Packit 8f70b4
      buf.appendf("i%llde",num);
Packit 8f70b4
      break;
Packit 8f70b4
   case BE_LIST:
Packit 8f70b4
      buf.append('l');
Packit 8f70b4
      for(i=0; i
Packit 8f70b4
	 list[i]->Pack(buf);
Packit 8f70b4
      buf.append('e');
Packit 8f70b4
      break;
Packit 8f70b4
   case BE_DICT:
Packit 8f70b4
      buf.append('d');
Packit 8f70b4
      PackDict(buf);
Packit 8f70b4
      buf.append('e');
Packit 8f70b4
      break;
Packit 8f70b4
   }
Packit 8f70b4
}
Packit 8f70b4
const xstring& BeNode::Pack()
Packit 8f70b4
{
Packit 8f70b4
   xstring& tmp=xstring::get_tmp("");
Packit 8f70b4
   Pack(tmp);
Packit 8f70b4
   return tmp;
Packit 8f70b4
}