/**
 * @author Ian Johnson
 * @version 1.0
 */


#include <netdb.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>



struct sockaddr_in eiger_socket_addr;
int  eiger_max_message_length = 1024;
char eiger_message[1024];
int  eiger_message_length = 0;
int  eiger_ret_val=0;

const int   ndacs         = 16;
const char* dac_names[16] = {"SvP","Vtr","Vrf","Vrs","SvN","Vtgstv","Vcmp_ll","Vcmp_lr","cal","Vcmp_rl","rxb_rb","rxb_lb","Vcmp_rr","Vcp","Vcn","Vis"};




unsigned int EigerGetNumberOfExposures(){return 1;};
float EigerGetExposureTime(){return 1;};
float EigerGetExposurePeriod(){return 1;};
int EigerGetDynamicRange(){return 1;};
int EigerGetPhotonEnergy(){return 1;};
/* for later */
unsigned int EigerGetNumberOfExposureSeries(){return 1;};
unsigned int EigerSetNumberOfExposureSeries(unsigned int i){return 1;};



int EigerInit(){
  static int passed = 0;

  if(!passed){
    struct hostent *dst_host;
    if((dst_host = gethostbyname("localhost")) == NULL){  //or look into getaddrinfo(3)
      fprintf(stderr,"ERROR, no such host\n");
      return 0;
    }else{
      //struct sockaddr_in eiger_socket_addr;
      int port = 43210;
      bzero((char *) &eiger_socket_addr, sizeof(eiger_socket_addr));
      eiger_socket_addr.sin_family = AF_INET;
      bcopy((char *)dst_host->h_addr,(char *)&eiger_socket_addr.sin_addr.s_addr,dst_host->h_length);
      eiger_socket_addr.sin_port = htons(port);
      passed = 1;
    }
  }

  return passed;
}


int EigerSendCMD(){
  if(!EigerInit()||eiger_message_length<=0) return 0;

  int sockfd = socket(AF_INET,SOCK_STREAM,0);
  if(sockfd<0){
    fprintf(stderr,"ERROR opening socket\n");
    return 0;
  }

  if(connect(sockfd,(struct sockaddr *) &eiger_socket_addr,sizeof(eiger_socket_addr))<0){
    fprintf(stderr,"ERROR connecting\n");
    return 0;
  }

  int n = write(sockfd,eiger_message,eiger_message_length);
  int ret_length = read(sockfd,eiger_message,eiger_max_message_length);

  close(sockfd);

  if(n<0||ret_length<0) return 0;


  //fprintf(stdout,"%s\n",eiger_message);
  if(eiger_ret_val>0){
    int i=0;
    eiger_message[1]='\0';
    if(atoi(eiger_message)!=0) return 0;

    for(i=2;i<ret_length;i++){
      if(eiger_message[i] == ' '){
	//fprintf(stdout," in : %d \n",i);
	eiger_message[i]='\0';
	break;
      }
    }
    eiger_ret_val = atoi(&eiger_message[2]);
    //fprintf(stdout," the \"%s\" %d\n",&eiger_message[2],eiger_ret_val);
  }

  eiger_message_length = 0;

  return 1;
}

const char* EigerGetDACName(int i){
  if(i>0&&i<ndacs) return dac_names[i];
  return dac_names[0];
}


int EigerSetDAC(const char* iname,int v){
  eiger_ret_val=0;
  eiger_message_length = sprintf(eiger_message,"setdacvalue %s %d",iname,v);
  return EigerSendCMD();
}

int EigerGetDAC(const char* iname){
  eiger_ret_val=1;
  eiger_message_length = sprintf(eiger_message,"getdacvalue %s",iname);
  if(!EigerSendCMD()) return -1;
  return eiger_ret_val;
}

int EigerSetNumberOfExposures(unsigned int n){
  eiger_ret_val=0;
  eiger_message_length = sprintf(eiger_message,"setnumberofexposures %u",n);
  return EigerSendCMD();
}

/*
int EigerGetNumberOfExposures(unsigned int n){
  eiger_ret_val=1;
  eiger_message_length = sprintf(eiger_message,"getnumberofexposures %s",iname);
  if(!EigerSendCMD()) return -1;
  return eiger_ret_val;
}
*/

int EigerSetExposureTime(float v){
  eiger_ret_val=0;
  eiger_message_length = sprintf(eiger_message,"setexposuretime %f",v);
  return EigerSendCMD();
}

/*
int EigerGetExposureTime(float v){
  eiger_ret_val=1;
  eiger_message_length = sprintf(eiger_message,"getexposuretime");
  if(!EigerSendCMD()) return 0;
  return eiger_ret_val;
}
*/

int EigerSetExposurePeriod(float v){
  eiger_ret_val=0;
  eiger_message_length = sprintf(eiger_message,"setexposureperiod %f",v);
  return EigerSendCMD();
}

/*
int EigerGetExposurePeriod(float v){
  eiger_ret_val=1;
  eiger_message_length = sprintf(eiger_message,"getexposuretime");
  if(!EigerSendCMD()) return 0;
  return eiger_ret_val;
}
*/

int EigerSetDynamicRange(unsigned int i){
  eiger_ret_val=0;
  eiger_message_length = sprintf(eiger_message,"setbitmode %u",i);
  return EigerSendCMD();
}

/*
int EigerGetDynamicRange(){
}
*/


int EigerSetPhotonEnergy(int in_eV){
  eiger_ret_val=0;
  eiger_message_length = sprintf(eiger_message,"setphotonenergy %d",in_eV);
  return EigerSendCMD();
}

/*
int EigerGetPhotonEnergy(int in_eV){
  eiger_ret_val=1;
  eiger_message_length = sprintf(eiger_message,"the %s",iname);
  if(!EigerSendCMD()) return -1;
  return eiger_ret_val;
}
*/

/*
int EigerSetGainMode(int i){
  eiger_ret_val=0;
  eiger_message_length = sprintf(eiger_message,"setphotonenergy %f",v);
  return EigerSendCMD();
}
get function too....
*/

int EigerStartAcquisition(){
  eiger_ret_val=0;
  eiger_message_length = sprintf(eiger_message,"startacquisition");
  return EigerSendCMD();
}


int EigerRunStatus(){
  eiger_ret_val=1;
  eiger_message_length = sprintf(eiger_message,"isdaqstillrunning");
  if(!EigerSendCMD()) return -1;
  return eiger_ret_val;
}

int EigerStopAcquisition(){
  eiger_ret_val=0;
  eiger_message_length = sprintf(eiger_message,"stopacquisition");
  return EigerSendCMD();
}



#ifdef TESTEIGERFUNCTIONS
int main(){

  int v=220;
  char n[2000] = "Vcmp_lr";

  fprintf(stdout," ret : %d\n",EigerSetDAC(EigerGetDACName(7),2200));
  int t = EigerGetDAC(EigerGetDACName(7));
  fprintf(stdout," v : %d\n",t);

  fprintf(stdout," ret : %d\n",EigerSetDAC(n,v));
  t = EigerGetDAC(n);
  fprintf(stdout," ret : %d\n",t);
  
  float f=0.12; 
  fprintf(stdout," ret : %d\n",EigerSetNumberOfExposures(120));
  fprintf(stdout," ret : %d\n",EigerSetExposureTime(0.12));
  fprintf(stdout," ret : %d\n",EigerSetExposurePeriod(0.22));
  fprintf(stdout," ret : %d\n",EigerSetPhotonEnergy(9200));
  fprintf(stdout," ret : %d\n",EigerSetDynamicRange(16));
  fprintf(stdout," ret : %d\n",EigerStartAcquisition());
  fprintf(stdout," aret : %d\n",EigerRunStatus());
  sleep(1);
  fprintf(stdout," ret : %d\n",EigerStopAcquisition());
  fprintf(stdout," bret : %d\n",EigerRunStatus());
  
  return 0;
}
#endif