import { Client, convertFromSNOauth2KeyFile, OAuth } from 'pulsar-client-typescript'

const brokerUrl = 'pulsar+ssl://pulsar.end.point:6651'
const audience = 'urn:sn:pulsar:organization:instance'
const snKeyFile = '/Users/someone/Downloads/service-account-oauth2-key-file.json'

// #1 to connect to pulsar without any auth configured
const clientWithNoAuth = new Client({ url: brokerUrl })

// #2 to connect to pulsar with oauth2 parameters directly
const clientFromOauth = new Client({
  url: brokerUrl,
  auth: new OAuth({
    clientId: 'CLIENT_ID',          // client ID
    clientSecret: 'CLIENT_SECRET',  // replace to client secret
    baseSite: 'ISSUER_URL',         // replace to issuer url
    accessTokenPath: 'oauth/token',
    customParams: {
      audience,
      grant_type: 'client_credentials'
    }
  })
})

// #3 If pulsar cluster is hosted by [StreamNative.io](https://streamnative.io/), 
// then there is a helper function that will be more easily used for initializing the client.
// {
//  "type": "sn_service_account",
//  "client_id": "{CLIENT ID}",
//  "client_secret": "{CLIENT SECRET}",
//  "client_email": "{CLIENT EMAIL}",
//   "issuer_url": "{ISSUER URL}"
// }
const clientFromOauthKeyFile = new Client({
  url: brokerUrl,
  auth: new OAuth(convertFromSNOauth2KeyFile(audience, snKeyFile))
})

const persistentProducer = client.createProducer({ topic: 'persistent://public/default/my-first-topic' })

// awaiting for producer.send(...) ensures messages are sent and received sent receipt from the pulsar server.
await persistentProducer.send('Mr. Watson – Come here – I want to see you')

// to implment...