-
Notifications
You must be signed in to change notification settings - Fork 14
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* add calling.collect api * changeset * rename continue with continuous * better log * handle start_of_input * doc line * fix prompt types * ignore done on start_of_input
- Loading branch information
Edoardo Gallo
authored
Dec 27, 2022
1 parent
45536d5
commit a937768
Showing
11 changed files
with
733 additions
and
5 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,5 @@ | ||
| --- | ||
| '@signalwire/core': patch | ||
| --- | ||
|
|
||
| Add types for `calling.collect` API |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,6 @@ | ||
| --- | ||
| '@signalwire/realtime-api': minor | ||
| '@sw-internal/e2e-realtime-api': patch | ||
| --- | ||
|
|
||
| Expose calling.collect API |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,118 @@ | ||
| import tap from 'tap' | ||
| import { Voice } from '@signalwire/realtime-api' | ||
| import { createTestRunner } from './utils' | ||
|
|
||
| const sleep = (ms = 3000) => { | ||
| return new Promise((r) => { | ||
| setTimeout(r, ms) | ||
| }) | ||
| } | ||
|
|
||
| const handler = () => { | ||
| return new Promise<number>(async (resolve, reject) => { | ||
| const client = new Voice.Client({ | ||
| host: process.env.RELAY_HOST || 'relay.swire.io', | ||
| project: process.env.RELAY_PROJECT as string, | ||
| token: process.env.RELAY_TOKEN as string, | ||
| contexts: [process.env.VOICE_CONTEXT as string], | ||
| // logLevel: "trace", | ||
| debug: { | ||
| logWsTraffic: true, | ||
| }, | ||
| }) | ||
|
|
||
| client.on('call.received', async (call) => { | ||
| console.log('Got call', call.id, call.from, call.to, call.direction) | ||
|
|
||
| try { | ||
| const resultAnswer = await call.answer() | ||
| tap.ok(resultAnswer.id, 'Inboud call answered') | ||
| tap.equal( | ||
| call.id, | ||
| resultAnswer.id, | ||
| 'Call answered gets the same instance' | ||
| ) | ||
|
|
||
| call.on('collect.started', (collect) => { | ||
| console.log('>>> collect.started', collect) | ||
| }) | ||
| call.on('collect.updated', (collect) => { | ||
| console.log('>>> collect.updated', collect.digits) | ||
| }) | ||
| call.on('collect.ended', (collect) => { | ||
| console.log('>>> collect.ended', collect.digits) | ||
| }) | ||
| call.on('collect.failed', (collect) => { | ||
| console.log('>>> collect.failed', collect.reason) | ||
| }) | ||
| // call.on('collect.startOfSpeech', (collect) => {}) | ||
|
|
||
| const callCollect = await call.collect({ | ||
| initialTimeout: 4.0, | ||
| digits: { | ||
| max: 4, | ||
| digitTimeout: 10, | ||
| terminators: '#', | ||
| }, | ||
| partialResults: true, | ||
| continuous: false, | ||
| sendStartOfInput: true, | ||
| startInputTimers: false, | ||
| }) | ||
|
|
||
| await callCollect.ended() // block the script until the collect ended | ||
|
|
||
| tap.equal(callCollect.digits, '123', 'Collect the correct digits') | ||
| // await callCollect.stop() | ||
| // await callCollect.startInputTimers() | ||
|
|
||
| await call.hangup() | ||
| } catch (error) { | ||
| console.error('Error', error) | ||
| reject(4) | ||
| } | ||
| }) | ||
|
|
||
| const call = await client.dialPhone({ | ||
| // make an outbound call to an `office` context to trigger the `call.received` event above | ||
| to: process.env.VOICE_DIAL_TO_NUMBER as string, | ||
| from: process.env.VOICE_DIAL_FROM_NUMBER as string, | ||
| timeout: 30, | ||
| }) | ||
| tap.ok(call.id, 'Call resolved') | ||
|
|
||
| await sleep(3000) | ||
|
|
||
| const sendDigitResult = await call.sendDigits('1w2w3w#') | ||
| tap.equal( | ||
| call.id, | ||
| sendDigitResult.id, | ||
| 'sendDigit returns the same instance' | ||
| ) | ||
|
|
||
| const waitForParams = ['ended', 'ending', ['ending', 'ended']] as const | ||
| const results = await Promise.all( | ||
| waitForParams.map((params) => call.waitFor(params as any)) | ||
| ) | ||
| waitForParams.forEach((value, i) => { | ||
| if (typeof value === 'string') { | ||
| tap.ok(results[i], `"${value}": completed successfully.`) | ||
| } else { | ||
| tap.ok(results[i], `${JSON.stringify(value)}: completed successfully.`) | ||
| } | ||
| }) | ||
| resolve(0) | ||
| }) | ||
| } | ||
|
|
||
| async function main() { | ||
| const runner = createTestRunner({ | ||
| name: 'Voice Collect E2E', | ||
| testHandler: handler, | ||
| executionTime: 60_000, | ||
| }) | ||
|
|
||
| await runner.run() | ||
| } | ||
|
|
||
| main() |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.