app_interactive.c

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

#define BOLDWHITE "\033[1m\033[37m" /* Bold White */

#include "KVS-lib.h"

// exemple of function to be executed whenever a key's value is updated
void keyALterada(char *key) {
	printf("\n\t %s was altered. This is the callback function.\n", key);

	// put_value(key, "some new key");

	return;
}

int main() {
	char group_id[1024];
	char secret[1024];

	char key[128];

	// the value is defined for demonstration purposes, but the system can handle bigger sized files
	char value[5000];

	char option[20];
	char *result;
	int a;
	char *line;
	size_t n;

	while (1) {
		while (1) {
			printf(BOLDWHITE "Enter GroupId: ");
			scanf("%s", group_id);
			printf("Enter Secret: ");
			scanf("%s", secret);

			// establishes connection with the local server
			a = establish_connection(group_id, secret);
			if (a == 0) {
				printf("Established conNEECtion ✔️\n");
				break;
			} else if (a == WRONG_SECRET) {
				printf("Correct Group, wrong password ❌\n");
			} else if (a == WRONG_GROUP) {
				printf("No Group with same GroupId ❌\n");
			} else if (a == ERROR_CONNECTION) {
				printf("Error in connection to server ❌\n");
			} else if (a == FULL_SERVER) {
				printf("Full server, try again later 👥\n");
			} else if (a == TIMED_OUT) {
				printf("Timed out ⌛️\n");
			}
		}
		// the app reaches this point whenever there is a successfull connection with one of the groups
		while (1) {
			printf("\nEnter option (put/get/delete/register/close) (key associated to the operation): ");
			// we need this sleep for the callback function results not to overlap and destroy the app UI
			usleep(100);
			scanf("%s %s", option, group_id);
			getchar();

			// Put value on the local server
			if (strcmp(option, "put") == 0) {
				printf("Value to store: ");
				int x = getline(&line, &n, stdin);
				a = put_value(group_id, line);
				if (a == NO_ERROR) {
					printf("Value Stored ✔️\n");
				} else if (a == GROUP_DELETED) {
					printf("Group was deleted ❌\n");
					break;
				} else {
					printf("Error ❌\n");
				}
			}  // get value from the local server
			else if (strcmp(option, "get") == 0) {
				a = get_value(group_id, &result);
				if (a == NO_ERROR) {
					printf("Value retrieved ✔️\n");
					printf("Value: %s\n", result);
				} else if (a == GROUP_DELETED) {
					printf("Group was deleted ❌\n");
					break;
				} else if (a == NO_KEY) {
					printf("Key doesn't exist ❌\n");
				} else if (a == ERROR_CONNECTION) {
					printf("Error comunicating with the server ❌\n");
					break;
				} else {
					printf("Error ❌\n");
				}
			}  // Delete value from the local server
			else if (strcmp(option, "delete") == 0) {
				a = delete_value(group_id);
				if (a == NO_ERROR) {
					printf("Value deleted ✔️\n");
				} else if (a == GROUP_DELETED) {
					printf("Group was deleted ❌\n");
					break;
				} else {
					printf("Error ❌\n");
				}
			}  // Close the connection with the local server
			else if (strcmp(option, "close") == 0) {
				a = close_connection();
				if (a == NO_ERROR) {
					printf("Connection closed ✔️\n");
				} else {
					printf("Error ❌\n");
				}
				break;
			}  // Register a callback on a key
			else if (strcmp(option, "register") == 0) {
				a = register_callback(group_id, &keyALterada);
				if (a == NO_ERROR) {
					printf("Callback registered ✔️\n");
				} else {
					printf("Error ❌\n");
				}
			}
		}
	}
	return 0;
}