/* -*- Mode: Java; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
/* vim: set shiftwidth=4 tabstop=4 autoindent cindent expandtab: */

'use strict';

MIDP.lastSMSConnection = -1;
MIDP.lastSMSID = -1;
MIDP.smsConnections = {};
MIDP.j2meSMSMessages = [];
MIDP.j2meSMSWaiting = null;
MIDP.nokiaSMSMessages = [];

/**
 * Simulate a received SMS with the given text, sent to the specified addr.
 * (It appears the value of `addr` is unimportant for most apps.)
 */
function receiveSms(text, addr) {
    var sms = {
      text: text,
      addr: addr,
      id: ++MIDP.lastSMSID,
    };

    MIDP.nokiaSMSMessages.push(sms);
    MIDP.j2meSMSMessages.push(sms);

    MIDP.LocalMsgConnections["nokia.messaging"].receiveSMS(sms);

    if (MIDP.j2meSMSWaiting) {
      MIDP.j2meSMSWaiting();
    }
}

/**
 * This app is listening for SMS messages; for most apps, that means
 * they're looking for the content of a message the app's servers just
 * sent. Prompt the user to enter that code here, and forward it to
 * the app.
 */
function promptForMessageText() {
    var el = document.getElementById('sms-listener-prompt').cloneNode(true);
    el.style.display = 'block';
    el.classList.add('visible');

    var input = el.querySelector('input');
    var btnCancel = el.querySelector('button.cancel');
    var btnDone = el.querySelector('button.recommend');

    btnDone.disabled = true; // Wait for input before enabling.
    input.addEventListener('input', function() {
       btnDone.disabled = (input.value.length === 0);
    });

    btnCancel.addEventListener('click', function() {
       console.warn('SMS prompt canceled.');
       el.parentElement.removeChild(el);
    });

    btnDone.addEventListener('click', function() {
       el.parentElement.removeChild(el);
       console.log('SMS prompt filled out:', input.value);
       // We don't have easy access to our own phone number; use a
       // dummy unknown value instead.
       receiveSms(input.value, 'unknown');
    });

    document.body.appendChild(el);
    input.focus();
}

Native.create("com/sun/midp/io/j2me/sms/Protocol.open0.(Ljava/lang/String;II)I", function(host, msid, port) {
    MIDP.smsConnections[++MIDP.lastSMSConnection] = {
      port: port,
      msid: msid,
      host: util.fromJavaString(host),
    };

    promptForMessageText();

    return ++MIDP.lastSMSConnection;
});

Native.create("com/sun/midp/io/j2me/sms/Protocol.receive0.(IIILcom/sun/midp/io/j2me/sms/Protocol$SMSPacket;)I",
function(port, msid, handle, smsPacket) {
    return new Promise(function(resolve, reject) {
        function receiveSMS() {
            var sms = MIDP.j2meSMSMessages.shift();
            var text = sms.text;
            var addr = sms.addr;

            var message = util.newPrimitiveArray("B", text.length);
            for (var i = 0; i < text.length; i++) {
                message[i] = text.charCodeAt(i);
            }

            var address = util.newPrimitiveArray("B", addr.length);
            for (var i = 0; i < addr.length; i++) {
                address[i] = addr.charCodeAt(i);
            }

            smsPacket.class.getField("I.message.[B").set(smsPacket, message);
            smsPacket.class.getField("I.address.[B").set(smsPacket, address);
            smsPacket.class.getField("I.port.I").set(smsPacket, port);
            smsPacket.class.getField("I.sentAt.J").set(smsPacket, Long.fromNumber(Date.now()));
            smsPacket.class.getField("I.messageType.I").set(smsPacket, 0); // GSM_TEXT

            return text.length;
        }

        if (MIDP.j2meSMSMessages.length > 0) {
          resolve(receiveSMS());
        } else {
          MIDP.j2meSMSWaiting = function() {
            MIDP.j2meSMSWaiting = null;
            resolve(receiveSMS());
          }
        }
    });
}, true);

Native.create("com/sun/midp/io/j2me/sms/Protocol.close0.(III)I", function(port, handle, deRegister) {
    delete MIDP.smsConnections[handle];
    return 0;
});