Test

iguana/exchanges/LP_commands.c

@@ -543,19 +543,19 @@ bot_resume(botid)\n\
         return(LP_uitem_recv(argjson));
     else if ( strcmp(method,"notify") == 0 )
         return(LP_notify_recv(argjson));
-    else if ( strcmp(method,"getpeers") == 0 )
+    /*else if ( strcmp(method,"getpeers") == 0 )
     {
         char *tmpstr;
         if ( (tmpstr= jstr(argjson,"LPnode")) != 0 )
             LP_addpeer(LP_mypeer,LP_mypubsock,tmpstr,RPC_port,RPC_port+10,RPC_port+20,1,G.LP_sessionid);
         if ( IAMLP != 0 )
         {
-            printf("send peers list\n");
+            printf("send peers list %s\n",LP_peers());
             bits256 zero; memset(zero.bytes,0,sizeof(zero));
             LP_reserved_msg(0,"","",zero,LP_peers());
         }
         retstr = clonestr("{\"result\":\"success\"}");
-    }
+    }*/
     // end received response
     
     else if ( strcmp(method,"tradestatus") == 0 )

iguana/exchanges/LP_nativeDEX.c

@@ -1093,11 +1093,11 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,uint16_t mybu
         printf("error launching LP_swapsloop for port.%u\n",myport);
         exit(-1);
     }
-    char request[128];
+    /*char request[128];
     if ( IAMLP == 0 )
         sprintf(request,"{\"method\":\"getpeers\",\"timestamp\":%u}",(uint32_t)time(NULL));
     else sprintf(request,"{\"method\":\"getpeers\",\"LPnode\":\"%s\",\"timestamp\":%u}",myipaddr,(uint32_t)time(NULL));
-    LP_reserved_msg(0,"","",G.LP_mypub25519,clonestr(request));    
+    LP_reserved_msg(0,"","",G.LP_mypub25519,clonestr(request));    */
     int32_t nonz; //uint32_t lasthello = 0;
     while ( 1 )
     {

iguana/exchanges/LP_signatures.c

@@ -569,17 +569,22 @@ void LP_notify_pubkeys(void *ctx,int32_t pubsock)
     timestamp = (uint32_t)time(NULL);
     jaddnum(reqjson,"timestamp",timestamp);
     LP_pubkey_sigadd(reqjson,timestamp,G.LP_privkey,G.LP_mypub25519,G.LP_myrmd160,G.LP_pubsecp);
+    if ( IAMLP != 0 )
+        jaddstr(reqjson,"isLP",LP_myipaddr);
+    jaddnum(reqjson,"session",G.LP_sessionid);
     LP_reserved_msg(0,"","",zero,jprint(reqjson,1));
 }
 
 char *LP_notify_recv(cJSON *argjson)
 {
-    bits256 pub; struct LP_pubkeyinfo *pubp;
+    bits256 pub; struct LP_pubkeyinfo *pubp; char *ipaddr;
     pub = jbits256(argjson,"pub");
     if ( bits256_nonz(pub) != 0 )
     {
         if ( (pubp= LP_pubkeyadd(pub)) != 0 )
             LP_pubkey_sigcheck(pubp,argjson);
+        if ( (ipaddr= jstr(argjson,"isLP")) != 0 )
+            LP_addpeer(LP_mypeer,LP_mypubsock,ipaddr,RPC_port,RPC_port+10,RPC_port+20,1,juint(argjson,"session"));
         //char str[65]; printf("%.3f NOTIFIED pub %s rmd160 %s\n",OS_milliseconds()-millis,bits256_str(str,pub),rmd160str);
     }
     return(clonestr("{\"result\":\"success\",\"notify\":\"received\"}"));