import { RpcProvider } from "worker-rpc";
import * as jsonMap from "json-source-map";

const rpcProvider = new RpcProvider((message: any, transfer: any) => postMessage(message, transfer));

onmessage = e => rpcProvider.dispatch(e.data);

rpcProvider.registerRpcHandler("generateSourceMap", ({ obj }: any) => jsonMap.stringify(obj, null, 2));

 *
 *   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; if not, write to the Free Software Foundation, Inc.,
 *   51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */

declare function postMessage(message: any, transfer?: any): void;

import { RpcProviderInterface, RpcProvider } from 'worker-rpc';

let rpcProvider: RpcProvider = null,
    port: MessagePort = null,
    portPending: MessagePort = null;

function send(message: any, transfer?: any): void {
    if (port) {
        port.postMessage(message, transfer);
    } else {
        postMessage(message, transfer);
    }

    if (portPending) {
        port = portPending;
        port.onmessage = (e: MessageEvent) => rpcProvider.dispatch(e.data);
    }

onmessage = e => rpcProvider.dispatch(e.data);

onmessage = (e: MessageEvent) => port || rpcProvider.dispatch(e.data);

onmessage = messageEvent => rpcProvider.dispatch(messageEvent.data);