blockclient.c

#include "Lista.h"
#include "wrapper.h"

int main(int argc, char* argv[])
{
    int sock;
    struct sockaddr_in serv_add;

    int scelta = 0;
    int n,cont;
    struct temp t;
    char ip[16];
    int porta;
    int i;
    int check;
    int enable = 1;

    if(argc <2)
    {
        printf("Input error: add an address\n");
        exit(1);
    }

    sock = Socket(AF_INET, SOCK_STREAM, 0);

    setsockopt(sock, SOL_SOCKET, SO_REUSEPORT, &enable, sizeof(int));
    setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &enable, sizeof(int));

    serv_add.sin_family = AF_INET;
    serv_add.sin_port = htons(2000);

    if ( (inet_pton(PF_INET, argv[1], &serv_add.sin_addr)) <= 0) {
		printf("Address creation error\n");
		return 1;
    }

    if( Connect(sock, (struct sockaddr *) &serv_add, sizeof(serv_add)) == -1)
        exit(-1);

    do
    {
        printf("\n+--------------------------------------------------------------------------------------------+\n| BLOCK CLIENT: Scegli un operazione da effettuare sull'attuale blockchain:                  |\n");
        printf("| [1] Visualizzare le ultime n transazioni                                                   |\n| [2] Visualizzare i dettagli di una specifica transazione                                   |\n");
        printf("| [3] Visualizzare la somma dei valori di tutta la blockchain                                |\n| [4] Cercare il numero di transazioni in cui e' coinvolto un indirizzo specifico            |\n");
        printf("| [5] Cercare tutte le transazioni in cui e' coinvolto un indirizzo specifico                |\n| [6] Visualizzare il bilancio delle transazioni in cui e' coinvolto un indirizzo specifico  |\n");
        printf("| [0] Esci                                                                                   |\n+--------------------------------------------------------------------------------------------+\n");
        printf("Scelta: ");
        scanf("%d", &scelta);
        printf("\n");

        FullWrite(sock, &scelta, sizeof(int));

        switch (scelta)
        {
            case 1:
                printf("Inserire il valore di n: ");
                scanf("%d", &n);
                printf("\n");

                FullWrite(sock, &n, sizeof(int));

                if ( FullRead(sock, &n, sizeof(int)) == -1)
                {
                    printf("Connessione persa\n");
                    close (sock);
					exit(1);
                }

                if( n == -1 )
                    printf("I blocchi richiesti non sono presenti nella blockchain\n");
            
                for(i = 0; i<n; i++)
                {
                    if( FullRead(sock, &t, sizeof(struct temp)) == -1)
                    {
                        printf("Connessione persa\n");
                        close (sock);
                        exit(1);
                    }

                    printf("n = %d\ntempo = %d\nIp Destinatario: %s\t Porta: %d\n", t.n,t.tempo, t.ts.ipDestinatario, t.ts.portaDestinatario);
                    printf("Ip Mittente: %s\t Porta Mittente: %d\nCredito: %d\nNumero Randomico: %d\n\n\n\n", t.ts.ipMittente, t.ts.portaMittente, t.ts.credito, t.ts.numRandom);
                }

                break;
            case 2:
                printf("Inserisci l'identificativo del blocco di cui vuoi visualizzare la transazione\n");
                printf("Scelta: ");
                scanf("%d", &n);
                printf("\n");

                FullWrite(sock, &n, sizeof(int));

                if( FullRead(sock, &n, sizeof(int)) == -1)
                {
                    printf("Connessione persa");
                    close (sock);
                    exit(1);
                }

                if( n == -1)
                {
                    printf("Blocco non presente nella BlockChain\n");
                    break;
                }
                else
                {
                    if( FullRead(sock, &t, sizeof(struct temp)) == -1)
                    {
                        printf("Connessione persa\n");
                        close (sock);
                        exit(1);
                    }            
                }

                printf("n = %d\ntempo = %d\nIp Destinatario: %s\t Porta: %d\n", t.n,t.tempo, t.ts.ipDestinatario, t.ts.portaDestinatario);
                printf("Ip Mittente: %s\t Porta Mittente: %d\nCredito: %d\nNumero Randomico: %d\n\n\n\n", t.ts.ipMittente, t.ts.portaMittente, t.ts.credito, t.ts.numRandom);
                break;
            case 3:
                if( FullRead(sock, &n, sizeof(int)) == -1)
                {
                    printf("Connessione persa\n");
                    close (sock); 
                    exit(1);
                }
        
                if(n == 0)
                    printf("La somma e' 0 perche' la BlockChain e' vuota e non ci sono transazioni\n");       
                else
                    printf("La somma dei valori di tutte le attuali transazioni = %d\n", n);  
            
                     
                break;
            case 4:
                printf("Inserisci indirizzo IP: ");
                scanf("%s", ip);
                printf("\nInserisci la porta: ");
                scanf("%d", &porta);
                printf("\n");

                FullWrite(sock, &ip, sizeof(ip));

                FullWrite(sock, &porta, sizeof(int));

                if( FullRead(sock, &n, sizeof(int)) == -1)
                {
                    printf("Connessione persa\n");
                    close (sock);
                    exit(1);
                }

                printf("L'indirizzo %s: %d e' coinvolto in %d transazioni\n", ip, porta, n);

                break;
            case 5:
		        printf("Inserire l'indirizzo IP: ");
                scanf("%s", ip);
                printf("\nInserire la porta: ");
                scanf("%d", &porta);
                printf("\n");
                FullWrite(sock, &ip, sizeof(ip));
	 	        FullWrite(sock, &porta, sizeof(int));
                if( FullRead(sock, &n, sizeof(int)) == -1)
                {
                    printf("Connessione persa\n");
                            close (sock);
                            exit(1);
                }
                for(i=0;i<n;i++)
                {
                    if ( FullRead(sock,&t,sizeof(struct temp)) == -1)
                    {
                        printf("Connessione con il Blockserver interrotta\n");
                        break;
                    }
                        printf("\nTransazione numero= %d\nIp Mittente= %s\t\tporta Mittente= %d\nIp Destinatario= %s\t\tporta Destinatario= %d\nAmmontare= %d\nNumero random= %d\n",t.n,t.ts.ipMittente,t.ts.portaMittente,t.ts.ipDestinatario,t.ts.portaDestinatario,t.ts.credito,t.ts.numRandom);
                }
		        if(n==0)
                    printf("L'ndirizzo Ip: %s\tporta: %d  non e' coinvolto in nessuna transazione.\n",ip,porta);
                printf("\nRichiesta conclusa.\n");	
                break;

            case 6:
		        printf("Inserire l'indirizzo IP: ");
                scanf("%s", ip);

                printf("\nInserire la porta: ");
                scanf("%d", &porta);
                printf("\n");

                FullWrite(sock, &ip, sizeof(ip));

	 	        FullWrite(sock, &porta, sizeof(int));

                if( FullRead(sock, &n, sizeof(int)) == -1)
		        {
		            printf("Connessione persa\n");
                            close (sock);
                            exit(1);
		        }
                if( n > 0)
                {
                    if( FullRead(sock, &n, sizeof(int)) == -1)
                    {
                        printf("Connessione persa\n");
                        close (sock);
                        exit(1);
                    }

                    printf("Bilancio delle transazioni dell'indirizzo desiderato: %d\n",n);
                }
                else
                    printf("Non e' stato possibile calcolare il bilancio perche' non e' presente nessuna transazione in cui compare quell'indirizzo\n");
                
		        break;

            case 0:
                printf("Disconnessione dal BlockServer...\n");
				close (sock);
				printf("Terminazione\nArrivederci e grazie per aver utilizzato i nostri servizi.\n");
                return 0;
				break;
            default:
                printf("Opzione non prevista\n");
                break;
        }

    }while (scelta != 0);
}