Function startTrackingServer

test/unit-ci/session-ssh-password-first.spec.js:100–165

* Start an SSH server that tracks which auth methods are attempted. * @param {string} publicKey - The public key to accept for publickey auth * @returns {{ port: number, authAttempts: string[], close: () => Promise }}

(publicKey)

 * @returns {{ port: number, authAttempts: string[], close: () => Promise<void> }}
 */
async function startTrackingServer (publicKey) {
  const clients = new Set()
  const authAttempts = []

  const server = new Server({
    hostKeys: [HOST_KEY.private]
  }, (client) => {
    clients.add(client)
    const cleanup = () => clients.delete(client)

    client.on('close', cleanup)
    client.on('end', cleanup)
    client.on('authentication', (ctx) => {
      authAttempts.push(ctx.method)

      if (ctx.method === 'none') {
        return ctx.reject(['publickey', 'password'])
      }

      // Accept password auth
      if (ctx.method === 'password' && ctx.username === USERNAME && ctx.password === PASSWORD) {
        return ctx.accept()
      }

      // Accept publickey auth
      if (ctx.method === 'publickey' && ctx.username === USERNAME && matchesPublicKey(ctx, publicKey)) {
        return ctx.accept()
      }

      ctx.reject(['publickey', 'password'])
    })
    client.on('ready', () => {
      client.on('session', (accept) => {
        const sshSession = accept()
        sshSession.on('env', (accept) => accept())
        sshSession.on('pty', (accept) => accept())
        sshSession.on('shell', (accept) => {
          const stream = accept()
          stream.write('electerm ready\n')
        })
      })
    })
  })

  server.listen(0, '127.0.0.1')
  await once(server, 'listening')

  return {
    port: server.address().port,
    authAttempts,
    async close () {
      for (const client of clients) {
        client.end()
      }
      await new Promise((resolve, reject) => {
        server.close((err) => {
          if (err) {
            reject(err)