/**

  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.

  *

  * Copyright 2013-2014 Oracle and/or its affiliates. All rights reserved.

  *

  * Oracle and Java are registered trademarks of Oracle and/or its affiliates.

  * Other names may be trademarks of their respective owners.

  *

  * The contents of this file are subject to the terms of either the GNU

  * General Public License Version 2 only ("GPL") or the Common

  * Development and Distribution License("CDDL") (collectively, the

  * "License"). You may not use this file except in compliance with the

  * License. You can obtain a copy of the License at

  * http://www.netbeans.org/cddl-gplv2.html

  * or nbbuild/licenses/CDDL-GPL-2-CP. See the License for the

  * specific language governing permissions and limitations under the

  * License.  When distributing the software, include this License Header

  * Notice in each file and include the License file at

  * nbbuild/licenses/CDDL-GPL-2-CP.  Oracle designates this

  * particular file as subject to the "Classpath" exception as provided

  * by Oracle in the GPL Version 2 section of the License file that

  * accompanied this code. If applicable, add the following below the

  * License Header, with the fields enclosed by brackets [] replaced by

  * your own identifying information:

  * "Portions Copyrighted [year] [name of copyright owner]"

  *

  * Contributor(s):

  *

  * The Original Software is NetBeans. The Initial Developer of the Original

  * Software is Oracle. Portions Copyright 2013-2014 Oracle. All Rights Reserved.

  *

  * If you wish your version of this file to be governed by only the CDDL

  * or only the GPL Version 2, indicate your decision by adding

  * "[Contributor] elects to include this software in this distribution

  * under the [CDDL or GPL Version 2] license." If you do not indicate a

  * single choice of license, a recipient has the option to distribute

  * your version of this file under either the CDDL, the GPL Version 2 or

  * to extend the choice of license to its licensees as provided above.

  * However, if you add GPL Version 2 code and therefore, elected the GPL

  * Version 2 license, then the option applies only if the new code is

  * made subject to such option by the copyright holder.

  */

 package org.netbeans.html.wstyrus;

 import java.io.IOException;

 import java.io.InputStream;

 import java.net.URI;

 import java.net.URISyntaxException;

 import java.util.Iterator;

 import javax.websocket.ClientEndpoint;

 import javax.websocket.ContainerProvider;

 import javax.websocket.OnClose;

 import javax.websocket.OnError;

 import javax.websocket.OnMessage;

 import javax.websocket.OnOpen;

 import javax.websocket.Session;

 import javax.websocket.WebSocketContainer;

 import net.java.html.json.OnReceive;

 import org.apidesign.html.context.spi.Contexts;

 import org.apidesign.html.json.spi.JSONCall;

 import org.apidesign.html.json.spi.Transfer;

 import org.apidesign.html.json.spi.WSTransfer;

 import org.netbeans.html.wstyrus.TyrusContext.Comm;

 import org.json.JSONArray;

 import org.json.JSONException;

 import org.json.JSONObject;

 import org.json.JSONTokener;

 import org.openide.util.lookup.ServiceProvider;

 /** This is an implementation module that provides support for

  * WebSocket protocol for {@link OnReceive} communication end point for

  * JDK7.

  * <p>

  * Don't deal with this module directly, rather use the 

  * {@link OnReceive @OnReceive(url="ws://...", ...)} API to establish your

  * WebSocket connection.

  * <p>

  * There is no need to include this module in your application if you are

  * running on JDK8. JDK8 WebView provides its own implementation of the

  * WebSocket API based on WebSocket object inside a browser. This is included

  * in the <code>org.apidesign.html:ko-fx:0.5</code> module.

  *

  * @author Jaroslav Tulach <jtulach@netbeans.org>

  */

 @ServiceProvider(service = Contexts.Provider.class)

 public final class TyrusContext 

 implements Contexts.Provider, WSTransfer<Comm>, Transfer {

     @Override

     public void fillContext(Contexts.Builder context, Class<?> requestor) {

         // default WebSocket transfer implementation is registered

         // in ko-fx module with 100, provide this one as a fallback only

         context.register(WSTransfer.class, this, 1000);

         context.register(Transfer.class, this, 1000);

     }

     @Override

     public Comm open(String url, JSONCall callback) {

         try {

             return new Comm(new URI(url), callback);

         } catch (URISyntaxException ex) {

             throw new IllegalStateException(ex);

         }

     }

     @Override

     public void send(Comm socket, JSONCall data) {

         socket.session.getAsyncRemote().sendText(data.getMessage());

     }

     @Override

     public void close(Comm socket) {

         try {

             final Session s = socket.session;

             if (s != null) {

                 s.close();

             }

         } catch (IOException ex) {

             socket.callback.notifyError(ex);

         }

     }

     @Override

     public void extract(Object obj, String[] props, Object[] values) {

         LoadJSON.extractJSON(obj, props, values);

     }

     @Override

     public Object toJSON(InputStream is) throws IOException {

         return LoadJSON.parse(is);

     }

     @Override

     public void loadJSON(JSONCall call) {

         LoadJSON.loadJSON(call);

     }

     /** Implementation class in an implementation. Represents a {@link ClientEndpoint} of the

      * WebSocket channel. You are unlikely to get on hold of it.

      */

     @ClientEndpoint

     public static final class Comm {

         private final JSONCall callback;

         private Session session;

         Comm(final URI url, JSONCall callback) {

             this.callback = callback;

             try {

                 final WebSocketContainer c = ContainerProvider.getWebSocketContainer();

                 c.connectToServer(Comm.this, url);

             } catch (Exception ex) {

                 wasAnError(ex);

             }

         }

         @OnOpen

         public synchronized void open(Session s) {

             this.session = s;

             callback.notifySuccess(null);

         }

         @OnClose

         public void close() {

             this.session = null;

             callback.notifyError(null);

         }

         @OnMessage

         public void message(final String orig, Session s) {

             Object json;

             String data = orig.trim();

             try {

                 JSONTokener tok = new JSONTokener(data);

                 Object obj = data.startsWith("[") ? new JSONArray(tok) : new JSONObject(tok);

                 json = convertToArray(obj);

             } catch (JSONException ex) {

                 json = data;

             }

             callback.notifySuccess(json);

         }

         @OnError

         public void wasAnError(Throwable t) {

             callback.notifyError(t);

         }

         static Object convertToArray(Object o) throws JSONException {

             if (o instanceof JSONArray) {

                 JSONArray ja = (JSONArray) o;

                 Object[] arr = new Object[ja.length()];

                 for (int i = 0; i < arr.length; i++) {

                     arr[i] = convertToArray(ja.get(i));

                 }

                 return arr;

             } else if (o instanceof JSONObject) {

                 JSONObject obj = (JSONObject) o;

                 Iterator it = obj.keys();

                 while (it.hasNext()) {

                     String key = (String) it.next();

                     obj.put(key, convertToArray(obj.get(key)));

                 }

                 return obj;

             } else {

                 return o;

             }

         }

     } // end of Comm

 }