Subversion Repositories NedoOS

#include <math.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <oscalls.h>
#include <osfs.h>
#include <intrz80.h>
#include <ctype.h>
#include <tcp.h>
#include <graphic.h>
#include <terminal.c>
unsigned char netbuf[1452];
unsigned char picture[16384];
unsigned char piclist[1024];
unsigned char picId[16];
unsigned char picType[32];
unsigned char picName[255];
unsigned char picYear[8];
unsigned char picRating[8];
unsigned char crlf[2] = {13, 10};
unsigned int bytecount;
unsigned char status, key;
struct sockaddr_in   targetadr;
struct readstructure   readStruct;
unsigned long contLen;


void errorPrint(unsigned int error)
{
  switch (error)
  {
    case 2:
      printf ("02 SHUT_RDWR\n\r");
      break;
    case 4:
      printf ("04 ERR_INTR\n\r");
      break;
    case 23:
      printf ("23 ERR_NFILE\n\r");
      break;
    case 35:
      printf ("35 ERR_EAGAIN or ERR_EWOULDBLOCK\n\r");
      break;
    case 37:
      printf ("37 ERR_ALREADY\n\r");
      break;
    case 38:
      printf ("38 ERR_NOTSOCK\n\r");
      break;
    case 40:
      printf ("40 ERR_EMSGSIZE\n\r");
      break;
    case 41:
      printf ("41 ERR_PROTOTYPE\n\r");
      break;
    case 47:
      printf ("47 ERR_AFNOSUPPORT\n\r");
      break;
    case 53:
      printf ("53 ERR_ECONNABORTED\n\r");
      break;
    case 54:
      printf ("54 ERR_CONNRESET\n\r");
      break;
    case 57:
      printf ("57 ERR_NOTCONN\n\r");
      break;
    case 65:
      printf ("65 ERR_HOSTUNREACH\n\r");
      break;
    default:
      printf ("%u UNKNOWN ERROR\n\r", error);
      break;
  }
  YIELD();
  //    do {key = _low_level_get();} while (key == 0);
}

unsigned char OpenSock(unsigned char family, unsigned char protocol)
{
  unsigned char socket, retry = 100;
  unsigned int todo;
  todo = OS_NETSOCKET ((family << 8) + protocol);
  if (todo > 32767) {
    printf("OS_NETSOCKET: ");
    errorPrint(todo & 255);
    exit(0);

  }
  else {
    socket = ( (todo & 65280) >> 8);
    //printf ("OS_NETSOCKET: Socket #%d created\n\r", socket);
  }
  return socket;
}

unsigned char netConnect (unsigned char socket)
{
  unsigned int todo;

  targetadr.family  = AF_INET;
  targetadr.porth   = 00;
  targetadr.portl   = 80;
  targetadr.b1      = 217;
  targetadr.b2      = 146;
  targetadr.b3      = 69;
  targetadr.b4      = 13;

  todo = OS_NETCONNECT (socket, &targetadr);
  if (todo > 32767)
  {
    printf("OS_NETCONNECT: ");
    errorPrint(todo & 255);
    exit(0);
  } else {
   // printf("OS_NETCONNECT: connection successful, %u\n\r", (todo & 255));
  }
  return 0;
}  


unsigned int tcpSend (unsigned char socket, unsigned int messageadr, unsigned int size)
{
  unsigned char retry = 100;
  unsigned int todo;
  readStruct.socket  = socket;
  readStruct.BufAdr  = messageadr;
  readStruct.bufsize = size;
  readStruct.protocol = SOCK_STREAM;



wizwrite:
  todo = OS_WIZNETWRITE (&readStruct);
  if (todo > 32767)
  {
    printf("OS_WIZNETWRITE: ");
    errorPrint(todo & 255);
    if (retry == 0) {
      exit(0);
    }
    retry--;
    goto wizwrite;
  }
  else
  {
  //  printf("OS_WIZNETWRITE: %u bytes written. \n\r", todo);
  }
  return todo;
}

unsigned int tcpRead (unsigned char socket)
{
  unsigned char retry = 50;
  unsigned int err, todo;

  readStruct.socket  = socket;
  readStruct.BufAdr  = (unsigned int)&netbuf;
  readStruct.bufsize = sizeof (netbuf);
  readStruct.protocol = SOCK_STREAM;

wizread:
  todo = OS_WIZNETREAD (&readStruct);
  err = todo & 255;
  if (todo > 32767)
  {
        YIELD();
        retry--;
    if (retry == 0)
        {
        if (err == ERR_EAGAIN) {todo = 0; return todo;}
    printf("OS_WIZNETREAD: ");
    errorPrint(err);
        exit(0);
    }
    goto wizread;
  }
 // printf("OS_WIZNETREAD: %u bytes read. \n\r", todo);
 return todo;
}

unsigned int cutHeader(unsigned int todo)
{
        unsigned int q, headlng;
        unsigned char *count;
        count = strstr (netbuf, "Content-Length:");
        if ( count == NULL)
  {
    printf ("contLen  not found \r\n");
        contLen = 0;
  }
        else
        {
       
        contLen = atol (count + 15);                    // 1.1
        //printf ("Found at count %u   Dlinna  soderzhimogo = %lu \n\r", count, contLen);
        }
       
       
  count = strstr (netbuf, "\r\n\r\n");
  if ( count == NULL)
  {
    printf ("header not found\r\n");
  }
  else
  {
    headlng = ((unsigned int)count - (unsigned int)netbuf + 4);
    q = todo - headlng;
    memcpy (&netbuf, count + 4, q);
   // printf ("header removed. %u bytes\r\n", headlng);
  }
 

  return q;
}

unsigned int netShutDown(unsigned char socket)
{
  unsigned int todo;
  todo = OS_NETSHUTDOWN (socket);
  if (todo > 32767) {
    printf("OS_NETSHUTDOWN: ");
    errorPrint(todo & 255);
    return 255;
  }  else {
   // printf ("Socket #%u closed.\n\r", socket);
  }
  return 0;
}

void fillPicture(unsigned char socket)
{
  unsigned int todo, w, pPos, q, headskip;
 
          headskip = 0;
  pPos = 0;
   while (1)
   {
        todo =  tcpRead (socket);
        if (todo == 0) {break;}
    q = todo;
    if (headskip == 0)
    {
      headskip = 1;
      q = cutHeader(todo);
    }
    for (w = 0; w < q; w++)
    {
      picture [w + pPos]  = netbuf[w];
    }
    if (pPos > sizeof(picture)) {printf ("Picture overrun... \n\r"); break;} // 1.1
        pPos = pPos + q;
       
  }
    netShutDown(socket);
}



unsigned char getPic(unsigned long fileId)
{
  unsigned int todo;
  unsigned char cmdlist1[] = "GET \/file\/id:";
  unsigned char cmdlist2[] = " HTTP/1.1\r\nHost: zxart.ee\r\nUser-Agent: User-Agent: Mozilla/4.0 (compatible; MSIE5.01; NedoOS)\r\n\r\n\0";
  unsigned char buffer  [] = "0000000000";
  unsigned char socket;
  socket = OpenSock(AF_INET, SOCK_STREAM);
    todo = netConnect (socket);
                netbuf[0] = '\0';
                sprintf(buffer, "%lu", fileId);
                strcat (netbuf, cmdlist1);
                strcat (netbuf, buffer);
                strcat (netbuf, cmdlist2);
  todo = tcpSend (socket, (unsigned int)&netbuf, strlen(netbuf));
  fillPicture(socket);
  return 0;
}
unsigned char savePic(unsigned long fileId)
{
  FILE *fp2;
  unsigned char fileName[32];
  unsigned char buffer  [] = "0000000000";
  strcpy(fileName, "zxart_");
  sprintf(buffer, "%lu", fileId);
  strcat (fileName, buffer);
  strcat (fileName, ".scr");

 fp2 = OS_CREATEHANDLE(fileName, 0x80);
  if (((int)fp2) & 0xff)
  {
    printf (fileName);
    printf(" creating error\r\n");
    exit(0);
  }
  OS_WRITEHANDLE(picture, fp2, 6912);
  OS_CLOSEHANDLE(fp2);
  return 0;
}

int pos(unsigned char *s, unsigned char *c, unsigned int n, unsigned int startPos)
{
        unsigned int i, j;             
        unsigned int lenC, lenS;       
       
        for (lenC = 0; c[lenC]; lenC++);
        for (lenS = 0; s[lenS]; lenS++);
         
        for (i = startPos; i <= lenS - lenC; i++)
        {
                for (j = 0; s[i + j] == c[j]; j++);
       
                if (j - lenC == 1 && i == lenS - lenC  && !(n - 1)) return i;
                if (j == lenC)
                if (n - 1) n--;
                else return i;
        }
        return -1;
}



const char* parseJson(unsigned char *property)
{
unsigned int w, lng, lngp1, findEnd, listPos;
unsigned char terminator;
int n;
        n = -1;
        netbuf[0] = '\0';
        n = pos(picture, property, 1 , 0);
        if ( n == -1)  {strcpy(netbuf, "0\0"); return netbuf;}
        lng = n - 1 + strlen(property);
        if (picture[lng] == ':')  {terminator = '\0';}
        if (picture[lng] == '\"') {terminator = '\"';}
        if (picture[lng] == '[')  {terminator = ']';}
               
        findEnd = 1;
        lngp1 = lng + 1;
 
  while (42)
  {
               
        if ((picture [lngp1 + findEnd] == ','))
        {
                if (terminator == '\0'){break;}
                if ((picture [lng + findEnd] == terminator)) { findEnd--; break;}
        }
        findEnd++;
  }
        listPos = 0;
        for (w = lngp1; w < findEnd + lngp1 ;w++)
        {
        netbuf [listPos] = picture[w];
                listPos++;
        }
netbuf[listPos] = '\0';
return netbuf;
}
void convert866(void)
{
  unsigned int lng, targetPos, w, q = 0;
  unsigned char buffer[8], one, two;
  unsigned int decVal;
  lng = strlen(netbuf);
  targetPos = lng + 1;

 while (q < lng)
  {
        one = netbuf [q];
        two = netbuf [q + 1];
        if ( one == 92 && two == 117)
        {
        q = q + 2;
        for (w = 0; w < 4; w++)  {buffer [w] = netbuf [q + w];}
        q = q + 4;
        buffer[4] = '\0';
        decVal= (unsigned int)strtol(buffer, NULL, 16);
                                                                                                               
          if (decVal < 1088) {decVal = decVal - 912;}
          if (decVal > 1087) {decVal = decVal - 864;}
          if (decVal == 1025) {decVal = 240;}
          if (decVal == 1105) {decVal = 241;}
          netbuf [targetPos] = decVal;
        }
                else {netbuf [targetPos] = netbuf [q]; q++;}
        targetPos++;
        }
        netbuf [targetPos] = '\0';

  for (w = lng + 1; w < targetPos + 1; w++)
  {
  netbuf [w - lng -1] = netbuf [w];
   }
}      





unsigned long processJson(unsigned long startPos, unsigned char limit)
{
  unsigned int todo, pPos, headskip;
  unsigned char cmdlist1[] = "GET /api/export:zxPicture\/filter:zxPicture\/limit:";
  unsigned char cmdlist2[] = "\/start:";
  unsigned char cmdlist3[] = "\/order:date,desc HTTP/1.1\r\nHost: zxart.ee\r\nUser-Agent: User-Agent: Mozilla/4.0 (compatible; MSIE5.01; NedoOS)\r\n\r\n\0";
  unsigned char buffer  [] = "000000000";
  unsigned char *count, socket;
  unsigned long idpic, bytecount;
 
  socket = OpenSock(AF_INET, SOCK_STREAM);
  netConnect (socket);
   
          netbuf[0] = '\0';
      strcat (netbuf, cmdlist1);
          sprintf(buffer, "%u", limit);
          strcat (netbuf, buffer);
          strcat (netbuf, cmdlist2);
          sprintf(buffer, "%lu", startPos);
          strcat (netbuf, buffer);
          strcat (netbuf, cmdlist3);
             
          todo = tcpSend (socket, (unsigned int)&netbuf, strlen(netbuf));
         
         
  headskip = 0;
  pPos = 0;
  fillPicture(socket);
  count = strstr (picture, "responseStatus\":\"success");
  if ( count == NULL)
  {
    printf ("BAD JSON no(responseStatus"":""success)\r\n");

        exit(0);
  }
 
  count = strstr (picture, "\"id\":");
  if ( count == NULL)
  {
    printf ("BAD JSON: ID not found \r\n");
        exit(0);
  }

 
       
  netbuf        [0] = '\0';
  picName       [0] = '\0';
  picId         [0] = '\0';
  picType       [0] = '\0';
  picRating [0] = '\0';
  picYear       [0] = '\0';
  strcat (picId, parseJson("\"id\":"));
  idpic = atol (netbuf);
  parseJson(",\"title\":\"");
  convert866();
  strcat (picName, netbuf);
  parseJson(",\"type\":\"");
  strcat (picType, netbuf) ;
  parseJson("\"rating\":\"");
  strcat (picRating, netbuf) ;
  parseJson("\"year\":\"");
  strcat (picYear, netbuf) ;

  /*
  "type":"standard",
  strcat (piclist, netbuf) ;
  strcat (piclist, "\n\r");
  strcat (piclist, parseJson ("\"dateCreated\":"));
  strcat (piclist, "\n\r");
  strcat (piclist, parseJson("\"authorIds\":["));
  strcat (piclist, "\n\r");
  strcat (piclist, parseJson("\"rating\":\""));
  strcat (piclist, "\n\r");
  strcat (piclist, parseJson("\"views\":\""));
  strcat (piclist, "\n\r");
  strcat (piclist, parseJson("\"year\":\""));
  strcat (piclist, "\n\r");
*/

return idpic;
}

C_task main (void)
{
  unsigned char errno,keypress;
  unsigned long iddqd, count;
  os_initstdio();
  piclist[0] = '\0';

        BOX(1, 1, 80, 8, 40);
        BOX(1, 9, 80, 17, 47);
       
        AT(1,1);
       
        ATRIB(33);
        ATRIB(40);
        count = 0;
                printf(" Управление:\n\r");
        printf(" Управление:\n\r");
        printf("        'ESC' - выход из программы;\n\r");
        printf("        '<-' или 'B' к последним картинкам;\n\r");
        printf("        '->' или 'Пробел' к более старым картинкам\n\r");
        printf("        'J' Прыжок на  указанную по счету картинку,<15000\n\r");
        printf("        'I' Просмотр экрана информации о картинках\n\r");
        printf("        'S' Сохранить картинку на диск в текущую папку\n\r");
        do {key = _low_level_get();} while (key == 0);
        ATRIB(30);
        ATRIB(47);
        AT(1,8);
start:

        piclist[0] = '\0';
        iddqd = processJson(count, 1);
        printf(" ID:%s  TITLE:%s\r\n",picId, picName);
        printf(" RATING:%s      YEAR:%s \r\n", picRating, picYear);

        if(!strcmp(picType, "standard"))
       
        {
                errno = getPic(iddqd);
                keypress = viewScreen6912((unsigned int)&picture);
        }
        else {printf("  >>Format %s not supported, skipped \n\r", picType);count++; goto start;}

if (keypress == 's' || keypress == 'S')  
{  
        savePic(iddqd);
        printf("        ID:%s    TITLE:%s  SAVED\r\n",picId, picName);
}

if (keypress == 27)  
{  
       
        printf("Good bye...\r\n");
        ATRIB(37);
        ATRIB(40);
        exit(0);
}
if (keypress == 248 || keypress == 'b' || keypress == 'B')  
{  
        if (count > 0) {count--;}
}

if (keypress == 251|| keypress == 32)  
{  
        count++;
}

if (keypress == 'j' || keypress == 'J')  
{  
printf("Jump to picture:");
scanf ("%lu", &count);
}

if (keypress == 'i' || keypress == 'I')  
{  
do {key = _low_level_get();} while (key == 0);
}


goto start;

}