package ca.uhn.hl7v2.examples.hoh;
   
   import java.io.IOException;
   
   import ca.uhn.hl7v2.HL7Exception;
   import ca.uhn.hl7v2.hoh.api.DecodeException;
   import ca.uhn.hl7v2.hoh.api.EncodeException;
   import ca.uhn.hl7v2.hoh.api.IAuthorizationClientCallback;
   import ca.uhn.hl7v2.hoh.api.IReceivable;
  import ca.uhn.hl7v2.hoh.api.ISendable;
  import ca.uhn.hl7v2.hoh.api.MessageMetadataKeys;
  import ca.uhn.hl7v2.hoh.auth.SingleCredentialClientCallback;
  import ca.uhn.hl7v2.hoh.hapi.api.MessageSendable;
  import ca.uhn.hl7v2.hoh.hapi.client.HohClientSimple;
  import ca.uhn.hl7v2.hoh.sockets.TlsSocketFactory;
  import ca.uhn.hl7v2.model.Message;
  import ca.uhn.hl7v2.model.v25.message.ADT_A01;
  import ca.uhn.hl7v2.parser.Parser;
  import ca.uhn.hl7v2.parser.PipeParser;
  
  public class HohClientSimpleExample {
  
  	/**
  	 * Example of an HL7-over-HTTP client for sending messages 
  	 */
  	public static void main(String[] args) throws HL7Exception, IOException {
  		
  		/*
  		 * http://localhost:8080/AppContext
  		 */
  		String host = "localhost";
  		int port = 8080;
  		String uri = "/AppContext";
  		
  		// Create a parser
  		Parser parser = PipeParser.getInstanceWithNoValidation();
  		
  		// Create a client
  		HohClientSimple client = new HohClientSimple(host, port, uri, parser);
  
  		// Set the socket factory to use TLS (if this is desired)
  		client.setSocketFactory(new TlsSocketFactory());
  		
  		// Optionally, if credentials should be sent, they 
  		// can be provided using a credential callback
  		IAuthorizationClientCallback authCalback = new SingleCredentialClientCallback("ausername", "somepassword");
  		client.setAuthorizationCallback(authCalback);
  		
  		// The ISendable defines the object that provides the actual
  		// message to send
  		ADT_A01 adt = new ADT_A01();
  		adt.initQuickstart("ADT", "A01", "T");
  		// .. set other values on the message ..
  		
  		// The MessageSendable provides the message to send 
  		ISendable<Message> sendable = new MessageSendable(adt);
  		
  		try {
  			// sendAndReceive actually sends the message
  			IReceivable<Message> receivable = client.sendAndReceiveMessage(sendable);
  			
  			// receivavle.getRawMessage() provides the response
  			Message message = receivable.getMessage();
  			System.out.println("Response was:\n" + message.encode());
  			
  			// IReceivable also stores metadata about the message
  			String remoteHostIp = (String) receivable.getMetadata().get(MessageMetadataKeys.REMOTE_HOST_ADDRESS);
  			System.out.println("From:\n" + remoteHostIp);
  			
  			/*
  			 * Note that the client may be reused as many times as you like,
  			 * by calling sendAndReceiveMessage repeatedly
  			 */
  			
  		} catch (DecodeException | EncodeException | IOException e) {
  			// Thrown if the response can't be read
  			e.printStackTrace();
  		} // Thrown if communication fails
          // Thrown if the message can't be encoded (generally a programming bug)
  
  
      }
  
  }