//*********************************************************************
// Simple RSS reader for FOX board
// Read RSS news and show them on a 20x2 PLED display
// with standard Hitachi HD44780 4 bits interfaces
//
// More info on: http://www.acmesystems.it/?id=15
// Author: Sergio Tanzilli 
// Web site: http://www.acmesystems.it
//*********************************************************************

#include "stdio.h"     
#include "stdlib.h"     
#include "unistd.h"    
#include "sys/ioctl.h"
#include "fcntl.h"     
#include "asm/etraxgpio.h"
#include "stdarg.h"
#include "string.h"

// Software delay in ms

void msDelay(int ms) {
  int i,a;
  int delayvar=10;
  
  for (a=0;a<ms;a++) {
    for (i=0;i<33084;i++) {
      delayvar*=2;        
      delayvar/=2;
    } 
  }
}   

// Software delay in us

void usDelay(int us) {
  int i,a;
  int delayvar=10;
  
  for (a=0;a<us;a++) {
    for (i=0;i<33;i++) {
      delayvar*=2;        
      delayvar/=2;
    } 
  }
}   

//*********************************************************************
// LCD functions
//*********************************************************************

// Set RS line
void lcd_rs_hi(int fd) {
  ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, IO_SETBITS), 1 << 12);
}

// Reset RS line
void lcd_rs_lo(int fd) {
  ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, IO_CLRBITS), 1 << 12);
}

// Set E line
void lcd_e_hi(int fd) {
  ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, IO_SETBITS), 1 << 13);
}

// Reset E line
void lcd_e_lo(int fd) {
  ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, IO_CLRBITS), 1 << 13);
}

// Send an hi pulse to E line
void lcd_e_strobe(int fd) {
	lcd_e_hi(fd);
	lcd_e_lo(fd);
}

// Send a nibble (4 bit) to LCD
void lcd_put_nibble(int fd, int value) {
	if (value&0x01) ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, IO_SETBITS), 1 << 8);
	else ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, IO_CLRBITS), 1 << 8);
	if (value&0x02) ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, IO_SETBITS), 1 << 9);
	else ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, IO_CLRBITS), 1 << 9);
	if (value&0x04) ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, IO_SETBITS), 1 << 10);
	else ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, IO_CLRBITS), 1 << 10);
	if (value&0x08) ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, IO_SETBITS), 1 << 11);
	else ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, IO_CLRBITS), 1 << 11);
}

// Send a char to LCD
// data: Ascii char or instruction to send
// mode: 0 = Instruction, 1 = Data
void lcd_putc(int fd,unsigned char data, int mode) {
	int a;
	
	if (mode==0) lcd_rs_lo(fd);
	else lcd_rs_hi(fd);
	
	a=(data>>4)&0x000F;
	lcd_put_nibble(fd,a);
	lcd_e_strobe(fd);
	a=data&0x000F;
	lcd_put_nibble(fd,a);
	lcd_e_strobe(fd);
} 

// Lcd initialization
void lcd_init(int fd) {
 	unsigned long data, mask;

  data = mask = 0xFF << 8;
  ioctl(fd, _IO(ETRAXGPIO_IOCTYPE, 0x13), &mask);
  if ((mask & data) != data)  printf("Check your kernel config\n");

	lcd_rs_lo(fd);
	lcd_e_lo(fd);
	msDelay(15);
	
	lcd_put_nibble(fd,0x03);
	lcd_e_strobe(fd);
	msDelay(4);
	lcd_e_strobe(fd);
	msDelay(2);
	lcd_e_strobe(fd);
	msDelay(2);
	lcd_put_nibble(fd,0x02);
	lcd_e_strobe(fd);
	msDelay(1);

  lcd_putc(fd,0x28,0);
	msDelay(1);
  lcd_putc(fd,0x06,0);
	msDelay(1);
  lcd_putc(fd,0x0C,0);
	msDelay(1);
  lcd_putc(fd,0x01,0);
	msDelay(2);
} 

// Locate cursor on LCD
// row (0-2)
// col (1-39)
void lcd_locate(int fd, int row, int col) {
  lcd_putc(fd,0x80+row*0x40+col,0);
  usDelay(35);
} 

// Clear LCD
void lcd_clear(int fd) {
  lcd_putc(fd,0x01,0);
  msDelay(2);
} 

// Lcd version of printf
void lcd_printf(int fd,char *format, ...) {
  int i;
  
  va_list argptr;
  char buffer[1024];
  
  va_start(argptr,format);
  vsprintf(buffer,format,argptr);
  va_end(argptr);
  
  for (i=0;i<strlen(buffer);i++) {
    lcd_putc(fd,buffer[i],1);
  }
}

#define RX_NULL     0
#define RX_TAG 		  1
#define RX_CONTENTS 2

int main(void) {
  int fd;
  int ch;
  int i;
  int p=0;
  int rss_fd;
  int rxstate=RX_NULL;
  char tagbuffer[256];
  char contentsbuffer[4096];
  char lcdbuffer[4096+20+20];
  
  if ((fd = open("/dev/gpiog", O_RDWR)) < 0) {
    printf("/dev/gpiog error");
    exit(1);
  }

	// Show a banner

  lcd_init(fd);
  lcd_locate(fd,0,0);
  lcd_printf(fd,"FOX RSS READER");
  
  // Get the RSS page
  while(1) {
  
  	// Get new from CNN top stories RSS feed
//	  system("cd /var; wget http://rss.cnn.com/rss/cnn_topstories.rss -O out.rss");
    system("cd /var; wget http://newsrss.bbc.co.uk/rss/newsonline_uk_edition/front_page/rss.xml  -O out.rss");
  	// Get new from ANSA italian news
	//  system("cd /var; wget http://194.244.5.202/main/notizie/awnplus/italia/synd/ansait_awnplus_italia_medsynd_Today_Idx.xml -O out.rss");
	  
	  // Read the RSS result
	
	  if ((rss_fd = open("/var/out.rss", O_RDONLY)) < 0) {
	    printf("Open file /var/out.rss error");
	    exit(1);
	  }
	  
	  while (1) {
	  	if (read(rss_fd,&ch,1)<1) break;
	  	
	  	if (ch==0x0A) continue;
	  	
	  	if (ch=='<') {
		  	if (rxstate==RX_CONTENTS && p>0) {
			  	contentsbuffer[p]=0;
			  	if (strcmp(tagbuffer,"title")==0) {
			  	  printf("%s\n",contentsbuffer);
				  	sprintf(lcdbuffer,"%20.20s%s%20.20s"," ",contentsbuffer," ");
			  		for (i=0;i<(strlen(lcdbuffer)-20+1);i++) {
				  		lcd_locate(fd,1,0);
			  			lcd_printf(fd,"%-20.20s",lcdbuffer+i);
			  			msDelay(90);
			  			msDelay(90);
			  			msDelay(90);
			  		}
			  	}	
		  	}	
	  		rxstate=RX_TAG;
	  		p=0;
	  		continue;
	  	}
	  	
	  	if (rxstate==RX_TAG) {
		  	tagbuffer[p]=ch;
		  	if (ch=='>') {
		  		tagbuffer[p]=0;
		  		rxstate=RX_CONTENTS;
		  		p=0;
		  		//printf("<%s>\n",tagbuffer);
		  		continue;
		  	}
		  	p++;
	  		continue;
	  	}
	  	
	  	if (rxstate==RX_CONTENTS) {
		  	contentsbuffer[p]=ch;
		  	p++;
	  		continue;
	  	}
	  }
	  
	  close(rss_fd);
	}  
  close(fd);
  exit(0);
}