 
     public func blob (fetch digest: String, from table: String) throws -> Data {
 
+      let socket = nextSocket()
 
       let headers: Headers = [
           "User-Agent": HeaderValues("Swift-CrateIO")


public class CrateIO {

    let socket : TCPClientSocket
    let host: String
    let port: Int

  	public init(withHost host: String, onPort port: Int) throws {
      self.host = host
      self.port = port
      socket = try TCPClientSocket(ip: IP(remoteAddress: host, port: port))
  	}

    public func sql (statement: String) throws -> JSON? {

      let post = "{\"stmt\": \"\(statement)\"}\r\n"
      let postBytes = [UInt8](post.utf8)


    public func blob (insert data: Data, into table: String) throws -> String? {

      let socket = nextSocket()

      let digest = Digest.sha1(try String(data: data))

      let headers: Headers = [
