/**

  * Back 2 Browser Bytecode Translator

  * Copyright (C) 2012 Jaroslav Tulach <jaroslav.tulach@apidesign.org>

  *

  * This program is free software: you can redistribute it and/or modify

  * it under the terms of the GNU General Public License as published by

  * the Free Software Foundation, version 2 of the License.

  *

  * This program is distributed in the hope that it will be useful,

  * but WITHOUT ANY WARRANTY; without even the implied warranty of

  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

  * GNU General Public License for more details.

  *

  * You should have received a copy of the GNU General Public License

  * along with this program. Look for COPYING file in the top folder.

  * If not, see http://opensource.org/licenses/GPL-2.0.

  */

 package org.apidesign.bck2brwsr.ko2brwsr;

 import java.io.ByteArrayOutputStream;

 import java.io.IOException;

 import java.io.InputStream;

 import java.io.InputStreamReader;

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

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

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

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

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

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

 /**

  *

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

  */

 final class BrwsrCtxImpl implements Technology<Object>, Transfer, WSTransfer<LoadWS> {

     private BrwsrCtxImpl() {}

     public static final BrwsrCtxImpl DEFAULT = new BrwsrCtxImpl();

     @Override

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

         ConvertTypes.extractJSON(obj, props, values);

     }

     @Override

     public void loadJSON(final JSONCall call) {

         class R implements Runnable {

             final boolean success;

             public R(boolean success) {

                 this.success = success;

             }

             Object[] arr = { null };

             @Override

             public void run() {

                 if (success) {

                     call.notifySuccess(arr[0]);

                 } else {

                     Throwable t;

                     if (arr[0] instanceof Throwable) {

                         t = (Throwable) arr[0];

                     } else {

                         if (arr[0] == null) {

                             t = new IOException();

                         } else {

                             t = new IOException(arr[0].toString());

                         }

                     }

                     call.notifyError(t);

                 }

             }

         }

         R success = new R(true);

         R failure = new R(false);

         if (call.isJSONP()) {

             String me = ConvertTypes.createJSONP(success.arr, success);

             ConvertTypes.loadJSONP(call.composeURL(me), me);

         } else {

             String data = null;

             if (call.isDoOutput()) {

                 try {

                     ByteArrayOutputStream bos = new ByteArrayOutputStream();

                     call.writeData(bos);

                     data = new String(bos.toByteArray(), "UTF-8");

                 } catch (IOException ex) {

                     call.notifyError(ex);

                 }

             }

             ConvertTypes.loadJSON(call.composeURL(null), success.arr, success, failure, call.getMethod(), data);

         }

     }

     @Override

     public Object wrapModel(Object model) {

         return model;

     }

     @Override

     public void bind(PropertyBinding b, Object model, Object data) {

         Knockout.bind(data, b, b.getPropertyName(), 

             "getValue__Ljava_lang_Object_2", 

             b.isReadOnly() ? null : "setValue__VLjava_lang_Object_2", 

             false, false

         );

     }

     @Override

     public void valueHasMutated(Object data, String propertyName) {

         Knockout.valueHasMutated(data, propertyName);

     }

     @Override

     public void expose(FunctionBinding fb, Object model, Object d) {

         Knockout.expose(d, fb, fb.getFunctionName(), "call__VLjava_lang_Object_2Ljava_lang_Object_2");

     }

     @Override

     public void applyBindings(Object data) {

         Knockout.applyBindings(data);

     }

     @Override

     public Object wrapArray(Object[] arr) {

         return arr;

     }

     @Override

     public <M> M toModel(Class<M> modelClass, Object data) {

         return modelClass.cast(data);

     }

     @Override

     public Object toJSON(InputStream is) throws IOException {

         StringBuilder sb = new StringBuilder();

         InputStreamReader r = new InputStreamReader(is);

         for (;;) {

             int ch = r.read();

             if (ch == -1) {

                 break;

             }

             sb.append((char)ch);

         }

         return ConvertTypes.parse(sb.toString());

     }

     @Override

     public void runSafe(Runnable r) {

         r.run();

     }

     @Override

     public LoadWS open(String url, JSONCall callback) {

         return new LoadWS(callback, url);

     }

     @Override

     public void send(LoadWS socket, JSONCall data) {

         socket.send(data);

     }

     @Override

     public void close(LoadWS socket) {

         socket.close();

     }

 }