SocketWrapper.java

package com.renomad.minum.web;

import com.renomad.minum.logging.ILogger;

import java.io.*;
import java.net.Socket;
import java.net.SocketAddress;
import java.nio.charset.Charset;

/**
 * This wraps Sockets to make them more particular to our use case
 */
public final class SocketWrapper implements ISocketWrapper {

    private final Socket socket;
    private final String hostName;
    private final BufferedOutputStream bufferedOutputStream;
    private final ILogger logger;
    private final IServer server;
    private final BufferedInputStream bufferedInputStream;

    /**
     * Constructor
     * @param socket a socket we intend to wrap with methods applicable to our use cases
     * @param logger not much more to say on this param
     * @param timeoutMillis we'll configure the socket to timeout after this many milliseconds.
     */
    public SocketWrapper(Socket socket, IServer server, ILogger logger, int timeoutMillis, String hostName) throws IOException {
        this.socket = socket;
        this.hostName = hostName;
        logger.logTrace(() -> String.format("Setting timeout of %d milliseconds on socket %s", timeoutMillis, socket));

        this.socket.setSoTimeout(timeoutMillis);
        this.bufferedInputStream = new BufferedInputStream(socket.getInputStream());
        this.bufferedOutputStream = new BufferedOutputStream(socket.getOutputStream());

        this.logger = logger;
        this.server = server;
    }

    @Override
    public void send(String msg) throws IOException {
        bufferedOutputStream.write(msg.getBytes(Charset.defaultCharset()));
    }

    @Override
    public void send(byte[] bodyContents) throws IOException {
        bufferedOutputStream.write(bodyContents);
    }

    @Override
    public void send(byte[] bodyContents, int off, int len) throws IOException {
        bufferedOutputStream.write(bodyContents, off, len);
    }

    @Override
    public void send(int b) throws IOException {
        bufferedOutputStream.write(b);
    }

    @Override
    public void sendHttpLine(String msg) throws IOException {
        logger.logTrace(() -> String.format("%s sending: \"%s\"", this, msg));
        send(msg + WebEngine.HTTP_CRLF);
    }

    @Override
    public int getLocalPort() {
        return socket.getLocalPort();
    }

    @Override
    public SocketAddress getRemoteAddrWithPort() {
        return socket.getRemoteSocketAddress();
    }

    @Override
    public String getRemoteAddr() {
        return socket.getInetAddress().getHostAddress();
    }

    @Override
    public HttpServerType getServerType() {
        return server.getServerType();
    }

    @Override
    public void close() throws IOException {
        logger.logTrace(() -> "close called on " + this);
        socket.close();
        if (server != null) server.removeMyRecord(this);
    }

    @Override
    public InputStream getInputStream() {
        return bufferedInputStream;
    }

    /**
     * Note that since we are indicating just the remote address
     * as the unique value, in cases like tests where we are operating as
     * sometimes server or client, you might see the server as the remote.
     */
    @Override
    public String toString() {
        return "(SocketWrapper for remote address: " + this.getRemoteAddrWithPort().toString() + ")";
    }

    @Override
    public String getHostName() {
        return hostName;
    }

    @Override
    public void flush() throws IOException {
        this.bufferedOutputStream.flush();
    }
}


















Active mutators

CONDITIONALS_BOUNDARY
EMPTY_RETURNS
FALSE_RETURNS
INCREMENTS
INVERT_NEGS
MATH
NEGATE_CONDITIONALS
NULL_RETURNS
PRIMITIVE_RETURNS
TRUE_RETURNS
VOID_METHOD_CALLS

Tests examined

com.renomad.minum.FunctionalTests.testEndToEnd_Functional(com.renomad.minum.FunctionalTests) (2358 ms)
com.renomad.minum.web.WebPerformanceTests.test3(com.renomad.minum.web.WebPerformanceTests) (651 ms)
com.renomad.minum.web.WebPerformanceTests.test2(com.renomad.minum.web.WebPerformanceTests) (658 ms)
com.renomad.minum.FunctionalTests.test_EdgeCase_IOExceptionThrown_WebFramework(com.renomad.minum.FunctionalTests) (678 ms)
com.renomad.minum.FunctionalTests.test_PathFunction_Response(com.renomad.minum.FunctionalTests) (625 ms)
com.renomad.minum.FunctionalTests.test_EdgeCase_Response_MultiCookies(com.renomad.minum.FunctionalTests) (640 ms)
com.renomad.minum.FunctionalTests.test_EdgeCase_BadRequest(com.renomad.minum.FunctionalTests) (667 ms)
com.renomad.minum.FunctionalTests.test_EdgeCase_PostHandler_IgnoreBody(com.renomad.minum.FunctionalTests) (640 ms)
com.renomad.minum.FunctionalTests.test_PathFunction_Response_Range(com.renomad.minum.FunctionalTests) (641 ms)
com.renomad.minum.FunctionalTests.test_EdgeCase_BadRequest2(com.renomad.minum.FunctionalTests) (691 ms)
com.renomad.minum.web.WebPerformanceTests.test1(com.renomad.minum.web.WebPerformanceTests) (784 ms)
com.renomad.minum.web.WebTests (698 ms)
com.renomad.minum.web.ServerTests (181 ms)
com.renomad.minum.web.SocketWrapperTests (30 ms)

Report generated by PIT 1.17.0

1		package com.renomad.minum.web;
2
3		import com.renomad.minum.logging.ILogger;
4
5		import java.io.*;
6		import java.net.Socket;
7		import java.net.SocketAddress;
8		import java.nio.charset.Charset;
9
10		/**
11		* This wraps Sockets to make them more particular to our use case
12		*/
13		public final class SocketWrapper implements ISocketWrapper {
14
15		private final Socket socket;
16		private final String hostName;
17		private final BufferedOutputStream bufferedOutputStream;
18		private final ILogger logger;
19		private final IServer server;
20		private final BufferedInputStream bufferedInputStream;
21
22		/**
23		* Constructor
24		* @param socket a socket we intend to wrap with methods applicable to our use cases
25		* @param logger not much more to say on this param
26		* @param timeoutMillis we'll configure the socket to timeout after this many milliseconds.
27		*/
28		public SocketWrapper(Socket socket, IServer server, ILogger logger, int timeoutMillis, String hostName) throws IOException {
29		this.socket = socket;
30		this.hostName = hostName;
31		logger.logTrace(() -> String.format("Setting timeout of %d milliseconds on socket %s", timeoutMillis, socket));
32
33	1 1. <init> : removed call to java/net/Socket::setSoTimeout → KILLED	this.socket.setSoTimeout(timeoutMillis);
34		this.bufferedInputStream = new BufferedInputStream(socket.getInputStream());
35		this.bufferedOutputStream = new BufferedOutputStream(socket.getOutputStream());
36
37		this.logger = logger;
38		this.server = server;
39		}
40
41		@Override
42		public void send(String msg) throws IOException {
43	1 1. send : removed call to java/io/BufferedOutputStream::write → TIMED_OUT	bufferedOutputStream.write(msg.getBytes(Charset.defaultCharset()));
44		}
45
46		@Override
47		public void send(byte[] bodyContents) throws IOException {
48	1 1. send : removed call to java/io/BufferedOutputStream::write → KILLED	bufferedOutputStream.write(bodyContents);
49		}
50
51		@Override
52		public void send(byte[] bodyContents, int off, int len) throws IOException {
53	1 1. send : removed call to java/io/BufferedOutputStream::write → KILLED	bufferedOutputStream.write(bodyContents, off, len);
54		}
55
56		@Override
57		public void send(int b) throws IOException {
58	1 1. send : removed call to java/io/BufferedOutputStream::write → KILLED	bufferedOutputStream.write(b);
59		}
60
61		@Override
62		public void sendHttpLine(String msg) throws IOException {
63		logger.logTrace(() -> String.format("%s sending: \"%s\"", this, msg));
64	1 1. sendHttpLine : removed call to com/renomad/minum/web/SocketWrapper::send → KILLED	send(msg + WebEngine.HTTP_CRLF);
65		}
66
67		@Override
68		public int getLocalPort() {
69	1 1. getLocalPort : replaced int return with 0 for com/renomad/minum/web/SocketWrapper::getLocalPort → KILLED	return socket.getLocalPort();
70		}
71
72		@Override
73		public SocketAddress getRemoteAddrWithPort() {
74	1 1. getRemoteAddrWithPort : replaced return value with null for com/renomad/minum/web/SocketWrapper::getRemoteAddrWithPort → KILLED	return socket.getRemoteSocketAddress();
75		}
76
77		@Override
78		public String getRemoteAddr() {
79	1 1. getRemoteAddr : replaced return value with "" for com/renomad/minum/web/SocketWrapper::getRemoteAddr → TIMED_OUT	return socket.getInetAddress().getHostAddress();
80		}
81
82		@Override
83		public HttpServerType getServerType() {
84	1 1. getServerType : replaced return value with null for com/renomad/minum/web/SocketWrapper::getServerType → KILLED	return server.getServerType();
85		}
86
87		@Override
88		public void close() throws IOException {
89		logger.logTrace(() -> "close called on " + this);
90	1 1. close : removed call to java/net/Socket::close → TIMED_OUT	socket.close();
91	2 1. close : negated conditional → TIMED_OUT 2. close : removed call to com/renomad/minum/web/IServer::removeMyRecord → TIMED_OUT	if (server != null) server.removeMyRecord(this);
92		}
93
94		@Override
95		public InputStream getInputStream() {
96	1 1. getInputStream : replaced return value with null for com/renomad/minum/web/SocketWrapper::getInputStream → KILLED	return bufferedInputStream;
97		}
98
99		/**
100		* Note that since we are indicating just the remote address
101		* as the unique value, in cases like tests where we are operating as
102		* sometimes server or client, you might see the server as the remote.
103		*/
104		@Override
105		public String toString() {
106	1 1. toString : replaced return value with "" for com/renomad/minum/web/SocketWrapper::toString → KILLED	return "(SocketWrapper for remote address: " + this.getRemoteAddrWithPort().toString() + ")";
107		}
108
109		@Override
110		public String getHostName() {
111	1 1. getHostName : replaced return value with "" for com/renomad/minum/web/SocketWrapper::getHostName → KILLED	return hostName;
112		}
113
114		@Override
115		public void flush() throws IOException {
116	1 1. flush : removed call to java/io/BufferedOutputStream::flush → KILLED	this.bufferedOutputStream.flush();
117		}
118		}
		Mutations
33		1.1 Location : <init> Killed by : com.renomad.minum.web.SocketWrapperTests removed call to java/net/Socket::setSoTimeout → KILLED
43		1.1 Location : send Killed by : none removed call to java/io/BufferedOutputStream::write → TIMED_OUT
48		1.1 Location : send Killed by : com.renomad.minum.web.WebPerformanceTests.test3(com.renomad.minum.web.WebPerformanceTests) removed call to java/io/BufferedOutputStream::write → KILLED
53		1.1 Location : send Killed by : com.renomad.minum.FunctionalTests.testEndToEnd_Functional(com.renomad.minum.FunctionalTests) removed call to java/io/BufferedOutputStream::write → KILLED
58		1.1 Location : send Killed by : com.renomad.minum.web.SocketWrapperTests removed call to java/io/BufferedOutputStream::write → KILLED
64		1.1 Location : sendHttpLine Killed by : com.renomad.minum.web.WebPerformanceTests.test2(com.renomad.minum.web.WebPerformanceTests) removed call to com/renomad/minum/web/SocketWrapper::send → KILLED
69		1.1 Location : getLocalPort Killed by : com.renomad.minum.FunctionalTests.testEndToEnd_Functional(com.renomad.minum.FunctionalTests) replaced int return with 0 for com/renomad/minum/web/SocketWrapper::getLocalPort → KILLED
74		1.1 Location : getRemoteAddrWithPort Killed by : com.renomad.minum.web.ServerTests replaced return value with null for com/renomad/minum/web/SocketWrapper::getRemoteAddrWithPort → KILLED
79		1.1 Location : getRemoteAddr Killed by : none replaced return value with "" for com/renomad/minum/web/SocketWrapper::getRemoteAddr → TIMED_OUT
84		1.1 Location : getServerType Killed by : com.renomad.minum.FunctionalTests.testEndToEnd_Functional(com.renomad.minum.FunctionalTests) replaced return value with null for com/renomad/minum/web/SocketWrapper::getServerType → KILLED
90		1.1 Location : close Killed by : none removed call to java/net/Socket::close → TIMED_OUT
91		1.1 Location : close Killed by : none negated conditional → TIMED_OUT 2.2 Location : close Killed by : none removed call to com/renomad/minum/web/IServer::removeMyRecord → TIMED_OUT
96		1.1 Location : getInputStream Killed by : com.renomad.minum.web.WebPerformanceTests.test3(com.renomad.minum.web.WebPerformanceTests) replaced return value with null for com/renomad/minum/web/SocketWrapper::getInputStream → KILLED
106		1.1 Location : toString Killed by : com.renomad.minum.FunctionalTests.test_EdgeCase_IOExceptionThrown_WebFramework(com.renomad.minum.FunctionalTests) replaced return value with "" for com/renomad/minum/web/SocketWrapper::toString → KILLED
111		1.1 Location : getHostName Killed by : com.renomad.minum.FunctionalTests.testEndToEnd_Functional(com.renomad.minum.FunctionalTests) replaced return value with "" for com/renomad/minum/web/SocketWrapper::getHostName → KILLED
116		1.1 Location : flush Killed by : com.renomad.minum.web.WebPerformanceTests.test3(com.renomad.minum.web.WebPerformanceTests) removed call to java/io/BufferedOutputStream::flush → KILLED

SocketWrapper.java

Mutations

Active mutators

Tests examined