server.js

const environment = process.env.NODE_ENV ?? 'development'
const autobahn = require('autobahn')
const Fastify = require('fastify')
const { ak } = require('./waapi.js')
const { wwiseRequest } = require('./wwise.api.js')

const envToLogger = {
  development: {
    transport: {
      target: 'pino-pretty',
      options: {
        translateTime: 'HH:MM:ss Z',
        ignore: 'pid,hostname',
      },
    },
  },
  production: true,
  test: false,
}
const fastify = require('fastify')({
  logger: envToLogger[environment] ?? true, // defaults to true if no entry matches in the map
})

const PORT = 3000

/** @typedef {import('autobahn').Connection} Connection */
/** @typedef {import('autobahn').Session} Session */
/** @type {Connection} */
let connection = null

// Middleware to register session in the Fastify instance
fastify.decorate('wwiseSession', null)

// CORS configuration
fastify.register(require('@fastify/cors'), {})

// Establish a connection to Wwise WAAPI
const connectToWwise = (url) => {
  connection = new autobahn.Connection({
    url: `${url}/waapi`,
    realm: 'realm1',
    protocols: ['wamp.2.json'],
  })

  connection.onopen = (session) => {
    fastify.log.debug('Connected to Wwise WAAPI')
    fastify.wwiseSession = session
    session.call(ak.wwise.core.getInfo, [], {}).then(
      function (res) {
        fastify.log.debug(
          `Hello ${res.kwargs.displayName} ${res.kwargs.version.displayName}!`
        )
      },
      function (error) {
        fastify.log.error(`Error getInfo: `, error)
      }
    )
  }

  connection.onclose = (reason) => {
    fastify.log.error('Connection to Wwise closed:', reason)

    fastify.wwiseSession = null
  }

  connection.open()
}

// API Endpoint: Fetch Wwise objects
fastify.get('/event', async (request, reply) => {
  /** @type {Session} */
  const session = fastify.wwiseSession
  if (!session) {
    reply.status(500).send({ error: 'Not connected to Wwise' })
    return
  }

  try {
    const result = await wwiseRequest(
      ak.wwise.core.object.get,
      {
        // waql: "$ from type sound",
        // from: { ofType: ["Sound"] }, // Fetch Sound object
        from: { ofType: ['Event'] },
      },
      session
    )
    reply.send(result.return)
  } catch (error) {
    reply.status(500).send({ error: error.message })
  }
})

fastify.get('/gameobjs', async (request, reply) => {
  const session = fastify.wwiseSession
  if (!session) {
    reply.status(500).send({ error: 'Not connected to Wwise' })
    return
  }

  try {
    // https://www.audiokinetic.com/en/library/edge/?source=SDK&id=ak_wwise_core_profiler_getgameobjects_example_query_game_objects_registered_at_or_before_1_minute.html
    const result = await wwiseRequest(
      ak.wwise.core.profiler.getGameObjects,
      {
        time: 'capture',
      },
      session
    )

    reply.send(result.return)
  } catch (error) {
    reply.status(500).send({ error: error.message })
  }
})

fastify.get('/play', async (request, reply) => {
  const session = fastify.wwiseSession
  if (!session) {
    reply.status(500).send({ error: 'Not connected to Wwise' })
    return
  }

  try {
    // https://www.audiokinetic.com/en/library/edge/?source=SDK&id=ak_soundengine_registergameobj.html
    await wwiseRequest(
      ak.soundengine.registerGameObj,
      {
        gameObject: 1122334,
        name: 'MyGameObjectName',
      },
      session
    )

    await wwiseRequest(
      ak.soundengine.setListeners,
      {
        emitter: 1122334,
        listeners: [18446744073709552000n],
      },
      session
    )

    // https://www.audiokinetic.com/en/library/edge/?source=SDK&id=ak_soundengine_postevent_example_posting_an_event_by_name.html
    await wwiseRequest(
      ak.soundengine.postEvent,
      {
        event: 'Istanbul_Amb_Test',
        gameObject: 1122334,
      },
      session
    )

    reply.send(result.return)
  } catch (error) {
    reply.status(500).send({ error: error.message })
  }
})

fastify.get('/playtrasnp', async (request, reply) => {
  const session = fastify.wwiseSession
  if (!session) {
    reply.status(500).send({ error: 'Not connected to Wwise' })
    return
  }

  try {
    //https://www.audiokinetic.com/en/library/edge/?source=SDK&id=ak_wwise_ui_commands_execute.html
    // https://www.audiokinetic.com/en/library/edge/?source=SDK&id=globalcommandsids.html
    const result = await wwiseRequest(
      ak.wwise.ui.commands.execute,
      {
        command: 'TransportPlayStop',
      },
      session
    )

    reply.send(result.return)
  } catch (error) {
    reply.status(500).send({ error: error.message })
  }
})

fastify.get('/stop', async (request, reply) => {
  const session = fastify.wwiseSession
  if (!session) {
    reply.status(500).send({ error: 'Not connected to Wwise' })
    return
  }

  try {
    const result = await wwiseRequest(
      ak.soundengine.stopAll,
      {
        gameObject: 1122334,
      },
      session
    )

    reply.send(result.return)
  } catch (error) {
    reply.status(500).send({ error: error.message })
  }
})
// Start the Fastify server and connect to Wwise
const startServer = async () => {
  try {
    await fastify.listen({ port: PORT })
    fastify.log.info(`Server running at http://localhost:${PORT}`)
    connectToWwise('ws://localhost:8080')
  } catch (err) {
    fastify.log.error(err)
    process.exit(1)
  }
}

startServer()