debugging network protocol

client.c

@@ -40,7 +40,7 @@ int client_connect(conn_handler handler, char *servip, int16_t port) {
         if(0 != ret)
             break;
 
-        if (0 >= write(connfd, buffer, sizeof(buffer))) {
+        if (0 >= write(connfd, buffer, strlen(buffer))) {
             printf("client_connect: cannot write to socket\n");
             ret = -1;
         }

issuer.c

@@ -95,6 +95,7 @@ int process_issuer(char *buffer) {
                 }
                 break;
             default:
+                issuer.state = READY;
                 bzero(buffer, MAX_BUFSIZE);
                 strncpy(buffer, "ERR\n", 4);
                 break;
@@ -107,6 +108,7 @@ int process_issuer(char *buffer) {
                 }
                 break;
             default:
+                issuer.state = READY;
                 bzero(buffer, MAX_BUFSIZE);
                 strncpy(buffer, "ERR\n", 4);
                 break;
@@ -135,6 +137,7 @@ int process_issuer(char *buffer) {
         printf("error()\n");
         bzero(buffer, MAX_BUFSIZE);
         strncpy(buffer, "ERR\n", 4);
+        issuer.state = READY;
         ret = 0;
     }
 

member.c

@@ -205,23 +205,23 @@ int member_verifymsg(char *buffer) {
 }
 
 //"PUBLISH" > "PUBLISH <member.mpk>"
-int member_publish(char *buffer) {
-    char *current;
-    int ret = 0;
-    uint8_t binbuf[MAX_BUFSIZE];
-    bzero(buffer, MAX_BUFSIZE);
+/* int member_publish(char *buffer) { */
+/*     char *current; */
+/*     int ret = 0; */
+/*     uint8_t binbuf[MAX_BUFSIZE]; */
+/*     bzero(buffer, MAX_BUFSIZE); */
 
-    strncpy(buffer, "PUBLISH ", 8);
+/*     strncpy(buffer, "PUBLISH ", 8); */
 
-    current = &buffer[8];
-    bzero(binbuf, MAX_BUFSIZE);
-    ecdaa_member_public_key_FP256BN_serialize(binbuf, &member.mpk);
-    ret = ecdaa_encode(binbuf, current, ECDAA_MEMBER_PUBLIC_KEY_FP256BN_LENGTH);
+/*     current = &buffer[8]; */
+/*     bzero(binbuf, MAX_BUFSIZE); */
+/*     ecdaa_member_public_key_FP256BN_serialize(binbuf, &member.mpk); */
+/*     ret = ecdaa_encode(binbuf, current, ECDAA_MEMBER_PUBLIC_KEY_FP256BN_LENGTH); */
 
-    current[ret] = '\n';
+/*     current[ret] = '\n'; */
 
-    return 0;
-}
+/*     return 0; */
+/* } */
 
 //"JOINSTART <issuer.nonce>" > "APPEND <member.mpk>"
 int member_joinappend(char *buffer) {