diff --git a/iguana/exchanges/LP_commands.c b/iguana/exchanges/LP_commands.c index 43c41e08d..cf47309d6 100644 --- a/iguana/exchanges/LP_commands.c +++ b/iguana/exchanges/LP_commands.c @@ -441,7 +441,14 @@ dividends(coin, height, )\n\ memset(zero.bytes,0,sizeof(zero)); if ( strcmp("connect",method) == 0 ) printf("broadcast.(%s)\n",jprint(reqjson,0)); - LP_broadcast_message(LP_mypubsock,base!=0?base:jstr(argjson,"coin"),rel,zero,jprint(reqjson,0)); + if ( LP_mypubsock >= 0 ) + { + char *msg; + msg = jprint(reqjson,0); + nn_send(pubsock,(void *)msg,(int32_t)strlen(msg)+1,0); + free(msg); + } + //LP_broadcast_message(LP_mypubsock,base!=0?base:jstr(argjson,"coin"),rel,zero,jprint(reqjson,0)); } retstr = clonestr("{\"result\":\"success\"}"); } else retstr = clonestr("{\"error\":\"couldnt dereference sendmessage\"}"); diff --git a/iguana/exchanges/LP_nativeDEX.c b/iguana/exchanges/LP_nativeDEX.c index 44f5714c9..1c82749c5 100644 --- a/iguana/exchanges/LP_nativeDEX.c +++ b/iguana/exchanges/LP_nativeDEX.c @@ -202,7 +202,8 @@ char *LP_process_message(void *ctx,char *typestr,char *myipaddr,int32_t pubsock, if ( jsonstr != 0 && argjson != 0 ) { len = (int32_t)strlen(jsonstr) + 1; - fprintf(stderr,"%s ",jstr(argjson,"method")); + if ( strcmp(method,"postprice") != 0 ) + fprintf(stderr,"%s ",jstr(argjson,"method")); if ( (retstr= LP_command_process(ctx,myipaddr,pubsock,argjson,&((uint8_t *)ptr)[len],recvlen - len)) != 0 ) { } diff --git a/iguana/exchanges/LP_network.c b/iguana/exchanges/LP_network.c index f3c6c1355..2262efcd8 100644 --- a/iguana/exchanges/LP_network.c +++ b/iguana/exchanges/LP_network.c @@ -214,7 +214,7 @@ void _LP_queuesend(uint32_t crc32,int32_t sock0,int32_t sock1,uint8_t *msg,int32 printf("_LP_queuesend0 sent %d instead of %d\n",sentbytes,msglen); else { - printf("Q sent %u\n",crc32); + printf("Q sent %u msglen.%d\n",crc32,msglen); sock0 = -1; } } diff --git a/iguana/exchanges/LP_ordermatch.c b/iguana/exchanges/LP_ordermatch.c index 458a264f8..2a3776542 100644 --- a/iguana/exchanges/LP_ordermatch.c +++ b/iguana/exchanges/LP_ordermatch.c @@ -594,7 +594,9 @@ int32_t LP_connectstartbob(void *ctx,int32_t pubsock,struct LP_utxoinfo *utxo,cJ if ( (pair= LP_nanobind(ctx,pairstr)) >= 0 ) { LP_requestinit(&qp->R,qp->srchash,qp->desthash,base,qp->satoshis-qp->txfee,rel,qp->destsatoshis-qp->desttxfee,qp->timestamp,qp->quotetime,DEXselector); + printf("call swapinit\n"); swap = LP_swapinit(1,0,privkey,&qp->R,qp); + printf("swapinit.%p\n",swap); swap->N.pair = pair; utxo->S.swap = swap; swap->utxo = utxo; @@ -764,6 +766,8 @@ int32_t LP_tradecommand(void *ctx,char *myipaddr,int32_t pubsock,cJSON *argjson, { bits256 zero; memset(&zero,0,sizeof(zero)); + if ( pubsock >= 0 ) + nn_send(pubsock,msg,(int32_t)strlen(msg)+1,0); LP_broadcast_message(pubsock,Q.srccoin,Q.destcoin,zero,msg); //butxo->S.otherpubkey } butxo->T.lasttime = (uint32_t)time(NULL);