Method connect

packages/serverless/lib/plugins/aws/dev/index.js:852–1117

* Connects to the IoT endpoint over websockets and listens for lambda events. * The method subscribes to all function invocation topics and listens for incoming events. * When an event is received, the method invokes the corresponding function locally, waits for the result, * and publishes

()

   * @returns {Promise<void>} This is a long-running method, so it does not return a value.
   */
  async connect() {
    const mainProgress = progress.get('main')
    logger.debug('Connecting to IoT endpoint')

    const endpoint = await this.getIotEndpoint()

    const {
      accessKeyId,
      secretAccessKey: secretKey,
      sessionToken,
    } = await this.provider.getCredentials()

    const device = new iot.device({
      protocol: 'wss',
      host: endpoint,
      accessKeyId,
      secretKey,
      sessionToken,
      autoResubscribe: true,
      offlineQueueing: true,
      baseReconnectTimeMs: 1000,
      maximumReconnectTimeMs: 1000,
      minimumConnectionTimeMs: 1000,
      keepalive: 1,
    })

    device.on('error', (e) => {
      logger.debug('IoT connection error', e)
    })

    device.on('offline', (e) => {
      mainProgress.notice('Reconnecting')
    })

    device.on('connect', (e) => {
      if (!this.heartbeatInterval) {
        this.heartbeatInterval = setInterval(() => {
          device.publish(
            this.getTopicId('_heartbeat'),
            JSON.stringify({ connected: true }),
            {
              qos: 1,
            },
          )
        }, 1000)
      }

      logger.success(`Connected (Ctrl+C to cancel)`)
      mainProgress.remove()
    })

    // Each function has a seperate topic we need to subscribe to
    const functionNames = this.serverless.service.getAllFunctions()

    for (const functionName of functionNames) {
      device.subscribe(this.getTopicId(`${functionName}/request`), {
        qos: 1,
      })