Merge pull request #23 from libp2p/feat/disconnect-peer

Add API endpoint to disconnect peers

conn.go

@@ -122,6 +122,14 @@ func (d *Daemon) handleConn(c net.Conn) {
 				return
 			}
 
+		case pb.Request_DISCONNECT:
+			res := d.doDisconnect(&req)
+			err := w.WriteMsg(res)
+			if err != nil {
+				log.Debugf("Error writing response: %s", err.Error())
+				return
+			}
+
 		default:
 			log.Debugf("Unexpected request type: %d", *req.Type)
 			return
@@ -179,6 +187,24 @@ func (d *Daemon) doConnect(req *pb.Request) *pb.Response {
 	return okResponse()
 }
 
+func (d *Daemon) doDisconnect(req *pb.Request) *pb.Response {
+	if req.Disconnect == nil {
+		return errorResponseString("Malformed request; missing parameters")
+	}
+
+	p, err := peer.IDFromBytes(req.Disconnect.GetPeer())
+	if err != nil {
+		return errorResponse(err)
+	}
+
+	err = d.host.Network().ClosePeer(p)
+	if err != nil {
+		return errorResponse(err)
+	}
+
+	return okResponse()
+}
+
 func (d *Daemon) doStreamOpen(req *pb.Request) (*pb.Response, inet.Stream) {
 	ctx, cancel := context.WithTimeout(d.ctx, DefaultTimeout)
 	defer cancel()