diff --git a/app/assets/javascripts/signaling-server.js b/app/assets/javascripts/signaling-server.js index 55f59d1..0a674b9 100644 --- a/app/assets/javascripts/signaling-server.js +++ b/app/assets/javascripts/signaling-server.js @@ -194,3 +194,153 @@ const exchange = data => { }; const logError = error => console.warn("Whoops! Error:", error); + + + + + +// Google Cloud Speech Playground with node.js and socket.io +// Created by Vinzenz Aubry for sansho 24.01.17 +// Feel esee to improve! +// Contact: vinzenz@sansho.studio + +const express = require('express'); // const bodyParser = require('body-parser'); // const path = require('path'); +const fs = require('fs'); +const environmentVars = require('dotenv').config(); + +// Google Cloud +const speech = require('@google-cloud/speech'); +const speechClient = new speech.SpeechClient(); // Creates a client + +const Translate = require('@google-cloud/translate'); +const projectId = 'booming-banner-212315'; +const translate = new Translate({ + projectId: projectId, +}); +const target = 'en'; + + +const app = express(); +const port = process.env.PORT || 1337; +const server = require('http').createServer(app); + +const io = require('socket.io')(server); + +app.use('/assets', express.static(__dirname + '/public')); +app.use('/session/assets', express.static(__dirname + '/public')); +app.set('view engine', 'ejs'); + + +// =========================== ROUTERS ================================ // + +app.get('/', function (req, res) { + res.render('index', {}); +}); + +app.use('/', function (req, res, next) { + next(); // console.log(`Request Url: ${req.url}`); +}); + + +// =========================== SOCKET.IO ================================ // + +io.on('connection', function (client) { + console.log('Client Connected to server'); + let recognizeStream = null; + + client.on('join', function (data) { + client.emit('messages', 'Socket Connected to Server'); + }); + + client.on('messages', function (data) { + client.emit('broad', data); + }); + + client.on('startGoogleCloudStream', function (data) { + startRecognitionStream(this, data); + }); + + client.on('endGoogleCloudStream', function (data) { + stopRecognitionStream(); + }); + + client.on('binaryData', function (data) { + // console.log(data); //log binary data + if (recognizeStream !== null) { + recognizeStream.write(data); + } + }); + + function startRecognitionStream(client, data) { + recognizeStream = speechClient.streamingRecognize(request) + .on('error', console.error) + .on('data', (data) => { + process.stdout.write( + (data.results[0] && data.results[0].alternatives[0]) + ? `Transcription: ${data.results[0].alternatives[0].transcript}\n` + : `\n\nReached transcription time limit, press Ctrl+C\n`); + client.emit('speechData', data); + + if (data.results[0].alternatives[0] !== undefined) { + let text = data.results[0].alternatives[0].transcript + translate + .translate(text, target) + .then(results => { + const translation = results[0]; + client.emit('translateData', translation) + + console.log(`Text: ${text}`); + console.log(`Translation: ${translation}`); + }) + .catch(err => { + console.error('ERROR:', err); + }); + } + + // if end of utterance, let's restart stream + // this is a small hack. After 65 seconds of silence, the stream will still throw an error for speech length limit + if (data.results[0] && data.results[0].isFinal) { + stopRecognitionStream(); + startRecognitionStream(client); + // console.log('restarted stream serverside'); + } + }); + } + + function stopRecognitionStream() { + if (recognizeStream) { + recognizeStream.end(); + } + recognizeStream = null; + } +}); + + +// =========================== GOOGLE CLOUD SETTINGS ================================ // + +// The encoding of the audio file, e.g. 'LINEAR16' +// The sample rate of the audio file in hertz, e.g. 16000 +// The BCP-47 language code to use, e.g. 'en-US' +const encoding = 'LINEAR16'; +const sampleRateHertz = 16000; +const languageCode = 'fr-FR'; //en-US + +const request = { + config: { + encoding: encoding, + sampleRateHertz: sampleRateHertz, + languageCode: languageCode, + profanityFilter: false, + enableWordTimeOffsets: true + }, + interimResults: true // If you want interim results, set this to true +}; + + +// =========================== START SERVER ================================ // + +server.listen(port, "127.0.0.1", function () { //http listen, to make socket work + // app.address = "127.0.0.1"; + console.log('Server started on port:' + port) +}); + diff --git a/app/assets/stylesheets/config/_colors.scss b/app/assets/stylesheets/config/_colors.scss index 40bd4cc..fa1108e 100644 --- a/app/assets/stylesheets/config/_colors.scss +++ b/app/assets/stylesheets/config/_colors.scss @@ -12,5 +12,5 @@ $light-gray: #F4F4F4; $primary: #F55E4F; $secondary: #5ED17E; $background: #33333D; -$card-backround: #464650; +$card-background: #464650; $navbar-background: #1F1F29; diff --git a/app/assets/stylesheets/layouts/_contacts.scss b/app/assets/stylesheets/layouts/_contacts.scss new file mode 100644 index 0000000..2ede27e --- /dev/null +++ b/app/assets/stylesheets/layouts/_contacts.scss @@ -0,0 +1,17 @@ +.card { + display: flex; + justify-content: space-between; + + background-color: $card-background; + .profile { + + } + .call { + transform: scaleX(-1); + -moz-transform: scaleX(-1); + -webkit-transform: scaleX(-1); + -ms-transform: scaleX(-1); + } + +} + diff --git a/app/controllers/pages_controller.rb b/app/controllers/pages_controller.rb index e039f5e..4e227c9 100644 --- a/app/controllers/pages_controller.rb +++ b/app/controllers/pages_controller.rb @@ -1,6 +1,6 @@ class PagesController < ApplicationController - skip_before_action :authenticate_user!, only: [:home] + skip_before_action :authenticate_user!, only: [:call] - def home + def call end end diff --git a/app/views/layouts/_contact.html.erb b/app/views/layouts/_contact.html.erb new file mode 100644 index 0000000..7d5f068 --- /dev/null +++ b/app/views/layouts/_contact.html.erb @@ -0,0 +1,12 @@ +
Last call: <%= Date.now %>
+