//const transit = require('transit-js');

const MatrixWhisperBridge = require('./app/MatrixWhisperBridge');
const { decodeStatusPayload } = require('./utils/statusUtils');

const CHANNEL = 'noman-test';

const bridge = new MatrixWhisperBridge();

bridge.init().then(([whisperUtils]) => {
  whisperUtils.getPublicKey().then(publicKey => {
    whisperUtils.send(CHANNEL, 'Bot is alive');

    whisperUtils.listen(CHANNEL).then(
      subscription => {
        subscription.on('data', ({ payload, sig, timestamp, topic }) => {
          const [, [message]] = decodeStatusPayload(payload);
          const isMe = publicKey === sig;
          const name = isMe ? 'Bot' : sig.slice(0, 10);

          console.log('From:', name, 'at', timestamp);
          console.log('Topic:', topic);
          console.log('Message:', message, '\n');

          if (!isMe) {
            whisperUtils.send(CHANNEL, `${message} back`);
          }
        });
      },
    );
  },
  error => console.error(error));
});