initial commit

Author: Sorunome

Diff for: lib/libtoxav.so

@@ -0,0 +1,23 @@
+{
+  "name": "matrix-puppet-tox",
+  "version": "0.0.0",
+  "main": "./dist/index.js",
+  "types": "./dist/index.d.ts",
+  "scripts": {
+    "prepare": "tsc",
+    "start": "DEBUG=matrix-puppet:* node index.js",
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "bluebird": "^3.4.7",
+    "matrix-puppet-bridge": "^2.0.0",
+    "node-ffi": "https://github.com/node-ffi/node-ffi",
+    "toxcore": "https://github.com/TokTok/js-toxcore-c"
+  },
+  "devDependencies": {
+    "typescript": "^2.3.4"
+  }
+}

Diff for: lib/libtoxcore.so

@@ -0,0 +1,69 @@
+import * as toxcore from 'toxcore';
+import * as Promise from 'bluebird';
+const debug = require('debug')('matrix-puppet:tox:client');
+export const EventEmitter = require('events').EventEmitter;
+
+Promise.promisifyAll(toxcore);
+
+const nodes = [
+  { maintainer: 'saneki',
+    address: '96.31.85.154',
+    port: 33445,
+    key: '674153CF49616CD1C4ADF44B004686FC1F6C9DCDD048EF89B117B3F02AA0B778' },
+  { maintainer: 'Impyy',
+    address: '178.62.250.138',
+    port: 33445,
+    key: '788236D34978D1D5BD822F0A5BEBD2C53C64CC31CD3149350EE27D4D9A2F9B6B' },
+  { maintainer: 'sonOfRa',
+    address: '144.76.60.215',
+    port: 33445,
+    key: '04119E835DF3E78BACF0F84235B300546AF8B936F035185E2A8E9E0A67C8924F' }
+];
+
+export class ToxClient extends (EventEmitter as { new(): any; }) {
+  constructor() {
+    super();
+    this.tox = new toxcore.Tox({
+      data: '/home/sorunome/.config/tox/tox_save_test.tox',
+      path: '/home/sorunome/repos/matrix-puppet-tox/lib/libtoxcore.so',
+      crypto: '/home/sorunome/repos/matrix-puppet-tox/lib/libtoxencryptsave.so',
+    });
+  }
+  connect() {
+    return Promise.map(nodes, (node) => {
+      return this.tox.bootstrapAsync(node.address, node.port, node.key);
+    }).then(this.tox.setNameAsync('Soruteeeest'))
+    .then(this.tox.setStatusMessageAsync('testing tox'))
+    .then(() => {
+      // init callbacks
+      
+      // Listen for friend requests
+      this.tox.on('friendRequest', (e) => {
+        console.log('Friend request from: ' + e.publicKeyHex());
+      });
+
+      // Print received friend messages to console
+      this.tox.on('friendMessage', (e) => {
+        var friendName = this.getNameById(e.friend());
+        this.emit('message', {
+          name: friendName,
+          id: this.tox.getFriendPublicKeyHexSync(e.friend()),
+          message: e.message(),
+          action: e._messageType == 1
+        });
+      });
+    })
+    .then(() => {
+      this.tox.start();
+    });
+  }
+  sendMessage(text, channel, action) {
+    return this.tox.sendFriendMessageAsync(channel, text, action);
+  }
+  getSelfUserId() {
+    return this.tox.getAddressHexAsync();
+  }
+  getNameById(id) {
+    return this.tox.getFriendNameSync(id).replace(/\0/g, '');
+  }
+}

Diff for: lib/libtoxencryptsave.so

@@ -0,0 +1,61 @@
+import {
+  ThirdPartyAdapter,
+  
+  download, entities,
+  
+  ThirdPartyPayload, ThirdPartyMessagePayload, ThirdPartyImageMessagePayload,
+  UserData, RoomData
+} from 'matrix-puppet-bridge';
+
+const debug = require('debug')('matrix-puppet:tox');
+import { ToxClient } from './client'
+
+export class Adapter extends ThirdPartyAdapter {
+  public serviceName = 'Tox';
+  private client: ToxClient;
+  startClient(): Promise<void> {
+    this.client = new ToxClient();
+    return this.client.connect().then(() => {
+      debug('waiting a little bit for initial self-messages to fire before listening for messages');
+      setTimeout(()=>this.registerMessageListener(), 5000);
+    });
+  }
+  registerMessageListener() {
+    this.client.on('message', (data) => {
+      this.puppetBridge.sendMessage({
+        roomId: data.id,
+        senderId: data.id,
+        senderName: data.name,
+        text: data.message,
+      });
+    })
+  }
+  getUserData(id): Promise<UserData>{
+    return Promise.resolve(() => {
+      let payload = <UserData>{
+        name: this.client.getNameById(id),
+      };
+      return payload;
+    });
+  }
+  getRoomData(id: string): Promise<RoomData> {
+    return new Promise<RoomData>((resolve, reject) => {
+      const name = this.client.getNameById(id);
+      if (!name) {
+        return reject();
+      }
+      let payload = <RoomData>{
+        name: name,
+        topic: 'Tox Chat ('+name+')',
+        isDirect: true,
+      };
+      return resolve(payload);
+    });
+  }
+  sendMessage(id, text) {
+    return this.client.sendMessage(text, id, false);
+  }
+  sendImageMessage(id, data) {
+    return this.client.sendMessage('['+data.text+'] '+data.url, id, false);
+  }
+};

Diff for: package.json

@@ -0,0 +1,9 @@
+{
+  "compilerOptions": {
+    "sourceMap": true,
+    "declaration": true,
+    "module": "commonjs",
+    "target": "es2015",
+    "outDir": "./dist"
+  }
+}