packages:
  - channel

importers:
  content:
    dependencies:
      uuid: 8.3.0
      ws: 6.2.1
    specifiers:
      uuid: ^8.0.0
      ws: ^6.0.0
lockfileVersion: 5.1
packages:
  /async-limiter/1.0.1:
    dev: false
    resolution:
      integrity: sha512-csOlWGAcRFJaI6m+F2WKdnMKr4HhdhFVBk0H/QbJFMCr+uO2kwohwXQPxw/9OCxp05r5ghVBFSyioixx3gfkNQ==
  /uuid/8.3.0:
    dev: false
    hasBin: true
    resolution:
      integrity: sha512-fX6Z5o4m6XsXBdli9g7DtWgAx+osMsRRZFKma1mIUsLCz6vRvv+pz5VNbyu9UEDzpMWulZfvpgb/cmDXVulYFQ==
  /ws/6.2.1:
    dependencies:
      async-limiter: 1.0.1
    dev: false
    resolution:
      integrity: sha512-GIyAXC2cB7LjvpgMt9EKS2ldqr0MTrORaleiOno6TweZ6r3TKtoFQWay/2PceJ3RuBasOHzXNn5Lrw1X0bEjqA==

import crypto from "crypto"
class Session {
  constructor() {
    this.cleaner = setInterval(this.clean.bind(this), 1000 * 60 * 60)
    this.key = '2390fbad9157e1f8de9ecb5a494feeb988dfe2ba31c39ca1ba91ba2fa9d30d20'
  }
  clean() {
    const timeouts = datastore.read('/session/connections/+/tokens/+')
    _.forEach(timeouts, (timeout, path) => {
      if (+ new Date < timeout) { return }
      const pointer = Pointer.create(path)
      pointer.replace('/timeout', '')
      datastore.destroy(pointer)
    })
  }
  fetchSession(cookie, ws, channels) {
    console.log(`fetchSession\n\ntoken:\n${cookie}`)
    const response = {
      o: 'a',
      c: 5,
      v: false
    }
    // {
    //   tokens: ,
    //   topics: []
    // }
    const [user, token, mac] = cookie.split(':')
    const verify = crypto.createHmac(
      'sha256',
      user + ':' + token,
      this.key
    ).digest('hex')
    const session = datastore.read(`/session/connections/${user}`)
    if (!session) return
    let topics = []
    if (crypto.timingSafeEqual(Buffer.from(verify, 'utf8'), Buffer.from(mac, 'utf8')) &&
        session && session.tokens) {
      _.find(session.tokens, (timestamp, stored_token) => {
        if (crypto.timingSafeEqual(Buffer.from(stored_token, 'utf8'), Buffer.from(token, 'utf8')) &&
            timestamp > + new Date) {
          response.v = { u: user, s: session.topics || [] }
        return true
        }
      })
    }
    _.forEach((session.topics || []), topic => {
      console.log(topic)
      const pointer = Pointer.create(topic)
      const channel = channels[pointer.trunk_steps[0]]
      channel.resume(pointer, ws)
    })
    ws.send(JSON.stringify(response))
  }
  requestSession(user, ws, users) {
    console.log("FFFFFFFFFFFFFFFFF")
    if (!users.isAuthorized(Pointer.create(`state/users/${user}/#`), ws)) {
      return
    }
    const token = crypto.randomBytes(256).toString('hex')
    const cookie = user + ':' + token
    console.log(`postSession for ${user} \n\ntoken:\n${token}`)
    const mac = crypto.createHmac(
      'sha256',
      user + ':' + token,
      this.key
    ).digest('hex')
    console.log('L')
    console.log(mac)
    datastore.write(`/session/connections/${user}/tokens/${token}`, + new Date + 60 * 60 * 24 * 7 * 1000)
    const response = {
      o: 'a',
      c: 6,
      v: cookie + ':' + mac
    }
    ws.send(JSON.stringify(response))
  }
  addSubscription(user, pointer) {
    console.log(`#addSubscription ${user}, ${pointer.topic}`)
    const topics = new Set(datastore.read(`/session/connections/${user}/topics`) || [])
    topics.add(pointer.topic)
    datastore.write(`/session/connections/${user}/topics`, Array.from(topics))
  }
  toString() {
    return 'Channel-Connections'
  }
}
const session = new Session()
export { session }

import WebSocket from 'ws'
import { v4 as uuid } from 'uuid'
import './models/item'
import './models/event'
import './models/user'
import './models/admin'
import './models/stash'
import './models/spotify'
import { events } from './channels/event.js'
import { users } from './channels/user.js'
import { items } from './channels/item.js'
import { admin } from './channels/admin.js'
import { session } from './session.js'
let main = () => {
  /* Models */
  const channels = {
    events: events,
    users: users,
    items: items,
    admin: admin
  }
  console.log(channels)
  /* IPC Sockets */
  const port = 25706
  const wss = new WebSocket.Server({ port })
  console.log(`Listenning on ${port}`)
  wss.on('connection', function connection(ws, request) {
    const ip = request.socket.remoteAddress
    ws.uuid = uuid()
    ws.toString = () => ws.uuid
    console.log(`Connection from ${ip}`)
    datastore.push('/session/connections', ip)
    const node_id = datastore.read('/session/node_id')
    const hello = {}
    hello.o = 'w'
    hello.v = node_id
    hello.p = '/session/node_id'
    ws.send(JSON.stringify(hello))
    const publish = (topic, pointer, value) => {
      const message = {}
      message.o = 'p'
      message.p = pointer.path
      message.v = value
      //console.log(`sending: ${JSON.stringify(message)}`)
      ws.send(JSON.stringify(message))
    }
    ws.on('message', (message) => {
      console.log(message)
      message = JSON.parse(message)
      if (!message.o) {
        return
      }
      let pointer, channel
      switch (message.o) {
        case 'a':
          console.dir(message)
          switch (message.c) {
            case 0:
              // createAccount
              pointer = Pointer.create(message.t)
              channel = channels[pointer.trunk_steps[0]]
              channel.createAuthorization(pointer, message.v, ws)
              break
            case 1:
              // startSession
              pointer = Pointer.create(message.t)
              channel = channels[pointer.trunk_steps[0]]
              channel.authorize(pointer, message.v, ws)
              break
            case 4:
              // verifySession
              pointer = Pointer.create(message.t)
              channel = channels[pointer.trunk_steps[0]]
              if (channel.prove(pointer, message.v, ws)) {
                session.addSubscription(message.v.u, pointer)
              }
              break
            case 5:
              // post session
              session.fetchSession(message.v, ws, channels)
              break
            case 6:
              // fetch session
              session.requestSession(message.v, ws, users)
            default:
              break
          }
          break
        case 'm':
          pointer = Pointer.create(message.p)
          channel = channels[pointer.trunk_steps[0]]
          channel.merge(pointer, message.v, ws)
          break
        case 'w':
          pointer = Pointer.create(message.p)
          channel = channels[pointer.trunk_steps[0]]
          channel.write(pointer, message.v, ws)
          break
        case 'd':
          pointer = Pointer.create(message.p)
          channel = channels[pointer.trunk_steps[0]]
          channel.delete(pointer, ws)
          break
        case 's':
          pointer = Pointer.create(message.p)
          channel = channels[pointer.trunk_steps[0]]
          channel.subscribe(pointer, ws, publish)
          if (!message.i) break
        case 'r':
          pointer = Pointer.create(message.p)
          channel = channels[pointer.trunk_steps[0]]
          _.forEach(channel.read(pointer, ws), (value, path) => {
            const response = { o: 'r' }
            response.p = path
            response.v = value
            ws.send(JSON.stringify(response))
          })
          break
      }
    })
    ws.on('close', () => {
      datastore.pull('/session/connections', ip)
      _.forEach(channels, channel => {
        channel.unsubscribe(ws)
      })
      console.log('disconnected')
    })
  })
  const cleanup = () => {
    console.log('\rShutting down server') // eslint-disable-line no-console
    process.removeListener('SIGINT', cleanup)
    process.removeListener('SIGTERM', cleanup)
    wss.close(() => {
      datastore.destroy('')
      process.exit()
    })
  }
  process.on('SIGINT', cleanup)
  process.on('SIGTERM', cleanup)
}
// TODO: Figure out a better way to prevent jsdoctest from executing this.
if (!process.env.TEST) {
  main()
}

class User {
  constructor() {
    console.log(`${this.toString()} #constructor`)
    datastore.subscribe('q/state/users/+/#', this, this.onStateQueued.bind(this))
  }
  toString() {
    return 'Model-Users'
  }
  onStateQueued(topic, pointer, value) {
    console.log(`${this.toString()} #onStateQueued: ${pointer.path}, ${JSON.stringify(value)}`)
    if (!value) { return }
    if (pointer.leaf == 'vote') {
      const event_id = datastore.read(`/state${pointer.trunk_path}/event_id`)
      console.log('event_id', pointer.branch_path, `/state${pointer.trunk_path}/event_id`, event_id)
      if (!event_id) { return }
      datastore.set(`/q/state/events/${event_id}${pointer.branch_path}`, value)
      datastore.set(pointer, null, { silent: true })
      console.log(`Transfer vote to /q/state/${pointer.branch_steps.slice(2,4).join('/')}${pointer.trunk_path}/${pointer.branch_steps.slice(-3).join('/')}`)
      datastore.set(`/q/state/${pointer.branch_steps.slice(2,4).join('/')}${pointer.trunk_path}/${pointer.branch_steps.slice(-3).join('/')}`, value)
      datastore.set(pointer, null, { silent: true })
    } else if (pointer.leaf == 'pin') {
      this.accept(pointer, value)
      pointer.leaf = 'srp'
      datastore.set(pointer.path, 'authenticated')
    } else {
      this.accept(pointer, value)
    }
  }
  accept(pointer, value, { force = false } = {}) {
    datastore.set(pointer, null, { silent: true })
    const dequeued_pointer = pointer.dequeue()
    console.log(dequeued_pointer.path)
    datastore.set(dequeued_pointer, value, { force })
  }
  destroy() {}
}
const users = new User()
const cleanup = () => {users.destroy()}
process.on('SIGINT', cleanup)
process.on('SIGTERM', cleanup)
export { users }

import fs from 'fs'
class Stash {
  constructor() {
    console.log(`${this.toString()} #constructor`)
    setInterval(this.stash.bind(this), 5000)
  }
  toString() {
    return 'Model-Stash'
  }
  stash() {
    console.log(`${this.toString()} #stash`)
    const tree = {}
    if (datastore.has('/state')) Object.assign(tree, { state: datastore.read('/state') })
    if (datastore.has('/setup')) Object.assign(tree, { setup: datastore.read('/setup') })
    fs.writeFile(
      './.stash.json',
      JSON.stringify(tree, null, 2),
      (error) => {
        if (!error) return
        console.log("Error Writing to Stash")
        console.log(error)
      }
    )
  }
  destroy() {
    clearInterval(this.interval)
  }
}
const stash = new Stash()
const cleanup = () => {stash.destroy()}
process.on('SIGINT', cleanup)
process.on('SIGTERM', cleanup)
export { stash }

import https from 'https'
class Driver {
  constructor() {
    this.chain = datastore.chain()
    this.chain.link('start', 'action/events/+/start', this.initializePlaylist.bind(this))
    this.debouncePushPlaylistDetails = _.debounce(this.pushPlaylistDetails, 1000)
    this.chain.link('name', 'action/events/+/name', this.debouncePushPlaylistDetails.bind(this))
    this.chain.link('description', 'action/events/+/description', this.debouncePushPlaylistDetails.bind(this))
    this.chain.link('queue_playlist', 'q/state/events/+/playlist', this.onPlaylistItemsQueued.bind(this))
  }
  toString() {
    return 'Driver-Spotify-Database'
  }
  token() {
    return datastore.read('/setup/admin/token')
  }
  initializePlaylist(value, pointer) {
    console.log(`#initialize_playlist ${pointer.path}`)
    const eventId = pointer.branch_path.split('/').slice(-1)[0]
    const name = eventId
    const admin_id = datastore.read("/setup/admin/id")
    const body = {
      name,
      public: true,
      collaborative: false
    }
    const request = https.request({
        method: 'POST',
        hostname: 'api.spotify.com',
        path: `/v1/users/${admin_id}/playlists`,
        headers: {
          'Authorization': `Bearer ${this.token()}`,
          'Content-Type': 'application/json'
        }
      },
      response => {
        console.log(response.statusCode)
        if (![200, 201].includes(response.statusCode)) { return }
        let body = ''
        response.on('data', chunk => {
          console.log(body)
          body += chunk.toString()
        })
        response.on('end', () => {
          this.decodeInitializePlaylist(JSON.parse(body))
        })
      })
    request.on('error', e => {
      console.error(`problem with request ${e.message}`)
    })
    request.write(JSON.stringify(body))
    request.end()
  }
  decodeInitializePlaylist(response) {
    console.log(`#decodeInitializePlaylist`)
    console.log(response)
    const control_id = response['id']
    const djin_id = response['name']
    const externalUrl = response['external_urls']['spotify']
    const branch_path = `/events/${djin_id}`
    datastore.write(`/setup${branch_path}/spotify_id`, control_id)
    this.updateInitializedPlaylist(branch_path)
  }
  updateInitializedPlaylist(branch_path) {
    const name = datastore.read(`/setup${branch_path}/name`)
    const description = datastore.read(`/setup${branch_path}/description`)
    const options = {
      name,
      description: description + `\nCreated with Djinlist (www.djinlist.ca).`
    }
    this.changePlaylistDetails(branch_path, options, branch_path => {
      datastore.write(`/setup${branch_path}/initialized`, true)
    })
  }
  onPushPlaylistDetails(topic, pointer, value) {
    datastore.write(`/setup${pointer.branch_path}/details_synced`, false)
    this.debouncePushPlaylistDetails(value, pointer)
  }
  pushPlaylistDetails(value, pointer) {
    const name = datastore.read(`/setup${pointer.branch_path}/name`)
    const description = datastore.read(`/setup${pointer.branch_path}/description`)
    const options = {}
    if (name) { Object.assign(options, { name }) }
    if (description) { Object.assign(options, { description }) }
    this.changePlaylistDetails(pointer.branch_path, options, branch_path => {
      datastore.write(`/setup${branch_path}/details_synced`, true)
    })
  }
  changePlaylistDetails(branch_path, options, callback) {
    const spotify_id = datastore.read(`/setup${branch_path}/spotify_id`)
    console.log(`#changePlaylistDetails ${branch_path}, ${spotify_id}`)
    console.log('options:', options)
    const request = https.request({
        method: 'PUT',
        hostname: 'api.spotify.com',
        path: `/v1/playlists/${spotify_id}`,
        headers: {
          'Authorization': `Bearer ${this.token()}`,
          'Content-Type': 'application/json'
        }
      },
      response => {
        response.on('end', () => callback(branch_path))
      })
    request.on('error', e => {
      console.error(`problem with request ${e.message}`)
    })
    request.write(JSON.stringify(options))
    request.end()
  }
  onTokenExpiry(topic, pointer, value) {
    const time = value - (+ new Date())
    console.log('#onTokenExpiry #{time}')
    if (this.refreshTokenInterval) {
      clearInterval(this.refreshTokenInterval)
    }
    if (time > 0) {
      this.refreshTokenInterval = setInterval(
        this.refreshToken.bind(this), time * 1000
      )
    } else {
      this.refreshToken()
    }
  }
  refreshToken() {
    const refreshToken = datastore.read(`/setup/admin/refresh_id`)
    console.log(`#refreshToken ${refresh_id}`)
    if (!refreshToken) { return }
    const body = {
      grant_type: 'refresh_token',
      refresh_token: refreshToken
    }
    request = https.request({
        method: 'POST',
        hostname: 'accounts.spotify.com',
        path: '/api/token',
        headers: {
          'Authorization': `Basic ZmUwMDk5M2ZmOTNlNDgyNzgwNGFmMTZlMWRlMzEyZGU6ODQ1NzQzNzhkMDg2NDQwZGI2MDczNmRiN2MxNzc1Mzg=`,
          'Content-Type': 'application/json'
        }
      },
      response => {
        if (![200, 201].includes(response.statusCode)) { return }
        let body = ''
        response.on('data', chunk => {
          body += chunk.toString()
        })
        response.on('end', () => {
          this.decodeTokenRefresh(JSON.parse(body))
        })
      })
    request.on('error', e => {
      console.log(`problem with request ${e.message}`)
    })
    request.write(JSON.stringify(body))
    request.end()
  }
  decodeRefreshToken(message) {
    console.log(`#decodeRefreshToken ${JSON.stringify(message)}`)
    const new_expiry = (+ new Date()) + message.expires_in
    datastore.write('/setup/admin/token', message.access_token)
    datastore.write('/setup/admin/expiry', new_expiry)
  }
  onPlaylistItemsQueued(value, pointer) {
    if (!value) return
    console.log(`#onPlaylistItemsQueued ${value.length}`)
    const spotify_id = datastore.read(`/setup${pointer.branch_path}/spotify_id`)
    // const length = datastore.read(`/setup${pointer.branch_path}/spotify_id`)
    const request = https.request({
      method: 'PUT',
      hostname: 'api.spotify.com',
      path: `/v1/playlists/${spotify_id}/tracks`,
      headers: {
        'Authorization': `Bearer ${this.token()}`,
        'Content-Type': 'application/json'
      }
    })
    request.on('error', e => {
      console.log(`problem with request ${e.message}`)
    })
    const tracks = _.reduce(value || [], (acc, track) => {
      return _.concat(acc, [track[0]])
    }, [])
    request.write(JSON.stringify({uris: tracks}))
    request.end()
  }
  destroy() {}
}
const spotify = new Driver
const cleanup = () => {spotify.destroy()}
process.on('SIGINT', cleanup)
process.on('SIGTERM', cleanup)
export { spotify }

class Item {
  constructor() {
    console.log(`${this.toString()} #constructor`)
    datastore.subscribe('q/state/items/+/#', this, this.onStateQueued.bind(this))
  }
  toString() {
    return 'Model-Items'
  }
  onStateQueued(topic, pointer, value) {
    console.log(`${this.toString()} #onStateQueued: ${pointer.path}, ${JSON.stringify(value)}`)
    this.accept(pointer, value)
  }
  accept(pointer, value, { force = false } = {}) {
    datastore.set(pointer, null, { silent: true })
    const dequeued_pointer = pointer.dequeue()
    datastore.set(dequeued_pointer, value, { force })
  }
  destroy() {}
}
const items = new Item()
const cleanup = () => {items.destroy()}
process.on('SIGINT', cleanup)
process.on('SIGTERM', cleanup)
export { items }

class Event {
  constructor() {
    console.log(`${this.toString()} #constructor`)
    datastore.subscribe('q/state/events/+/#', this, this.onStateQueued.bind(this))
    datastore.subscribe('q/setup/events/+/#', this, this.onSetupQueued.bind(this))
    this.ticker = setInterval(this.publishPlaylists.bind(this), 60 * 1000)
  }
  toString() {
    return 'Model-Events'
  }
  onStateQueued(topic, pointer, value) {
    console.log(`${this.toString()} #onStateQueued: ${pointer.path}, ${JSON.stringify(value)}`)
    switch (pointer.branch_path.length) {
      case 4:
        if (pointer.branch_steps[2] == 'users') {
          this.onUserQueued(topic, pointer, value)
        }
        break
      default:
        this.accept(pointer, value)
        break
    }
  }
  onSetupQueued(topic, pointer, value) {
    console.log(`${this.toString()} #onSetupQueued: ${pointer.path}, ${JSON.stringify(value)}`)
    this.accept(pointer, value)
  }
  onUserQueued(topic, pointer, value) {
    switch (pointer.leaf) {
      case 'vote':
        this.accept(pointer, value)
    }
  }
  publishPlaylist(name, pointer) {
    const issueAt = datastore.read(pointer.path + '/issue_at')
    const currentTime = + new Date()
    console.log(`#publishPlaylist ${name} ${issueAt && (issueAt < currentTime)}`)
    if (
      !issueAt  // &&
      // currentTime.getDay() == 5 ||
      // currentTime.getHours() == 20 ||
      // currentTime.getMinutes() == 0
    ) {
      this.issuePlaylist(name, pointer)
    } else if (issueAt < currentTime) {
      this.issuePlaylist(name, pointer)
      // Determine the next time we need to update the playlist
      const intervalDays = datastore.read(pointer.path + '/interval')
      const intervalSeconds = intervalDays * 24 * 60 * 60
      datastore.write(pointer.path + '/issue_at', issueAt + intervalSeconds)
    }
  }
  publishPlaylists() {
    const playlists = datastore.read('setup/events/+/name')
    _.forEach(playlists, (playlist, path) => {
      const pointer = Pointer.create(path)
      this.publishPlaylist(playlist, pointer.slice(0, -1))
    })
  }
  tally(pointer) {
    const items = datastore.read(`/state${pointer.trunk_path}/users/+/items/+/vote`)
    const length = datastore.read(`/state${pointer.trunk_path}/users/+/items/+/vote`)
    const tally = {}
    _.forEach(items, (value, path) => {
      const id = path.split('/').slice(-2, -1)[0]
      if (tally[id]) {
        tally[id] += 1
      } else {
        tally[id] = 1
      }
    })
    const sorted_list = _.reverse(_.sortBy(_.entries(tally), entry => entry[1]))
    const current_list = datastore.read(`/state${pointer.trunk_path}/playlist`)
    let match = true
    if (current_list) {
      for (var idx in current_list) {
        if (current_list[idx] != sorted_list[idx]) { match = false }
      }
    } else {
      match = false
    }
    if (match) return
    datastore.write(`/q/state${pointer.trunk_path}/playlist`, sorted_list)
  }
  issuePlaylist(name, pointer) {
    console.log(`#issuePlaylist ${name} at ${pointer.path}`)
    const exists = datastore.read(`/setup${pointer.trunk_path}/spotify_id`)
    if (exists) {
      this.tally(pointer)
    } else {
      datastore.write(`/action${pointer.trunk_path}/start`, +new Date())
    }
  }
  accept(pointer, value, { force = false } = {}) {
    datastore.set(pointer, null, { silent: true })
    const dequeued_pointer = pointer.dequeue()
    datastore.set(dequeued_pointer, value, { force })
  }
  destroy() {
    clearInterval(this.ticker)
  }
}
const events = new Event()
const cleanup = () => {events.destroy()}
process.on('SIGINT', cleanup)
process.on('SIGTERM', cleanup)
export { events }

class Admin {
  constructor() {
    console.log(`${this.toString()} #constructor`)
    datastore.subscribe('q/setup/admin/#', this, this.onSetupQueued.bind(this))
  }
  toString() {
    return 'Model-Admin'
  }
  onSetupQueued(topic, pointer, value) {
    console.log(`${this.toString()} #onSetupQueued: ${pointer.path}, ${JSON.stringify(value)}`)
    this.accept(pointer, value)
  }
  accept(pointer, value, { force = false } = {}) {
    datastore.set(pointer, null, { silent: true })
    const dequeued_pointer = pointer.dequeue()
    datastore.set(dequeued_pointer, value, { force })
  }
  destroy() {}
}
const admin = new Admin()
const cleanup = () => {admin.destroy()}
process.on('SIGINT', cleanup)
process.on('SIGTERM', cleanup)
export { admin }

import _ from 'lodash'
if (!global._) global._ = _
import { Datastore, Pointer} from '@djinlist/datastore'
if (!global.datastore) global.datastore = new Datastore()
if (!global.Pointer) global.Pointer = Pointer
import fs from 'fs'
const loadConfig = async () => {
  // configuration information goes here
  datastore.set('/session/node_id', '952ede89-4c91-4df7-bdab-c6dda4257abb')
  let filePath
  fs.access('.stash.json', fs.constants.F_OK, (err) => {
    filePath = `.${err ? 'preconfig' : 'stash'}.json`
  })
  const onFileFound = (file, data) => {
    if (!data) { return false }
    const _root = JSON.parse(data)
    if (Object.keys(_root).length === 0) { return false }
    console.log(`index.js Parsing root found at ${file}`)
    datastore.set('/state', _root.state)
    datastore.set('/setup', _root.setup)
    main()
    return true
  }
  ['.stash.json', '.preconfig.json'].find(filePath => {
    try {
      return onFileFound(filePath, fs.readFileSync(filePath))
    } catch (e) {
      console.log(`Error reading config at ${filePath}`)
      console.log(e)
      return false
    }
  })
}
const main = () => {
  import('./server')
}
loadConfig()

import { Base } from './base.js'
class User extends Base {
  constructor() {
    super()
    datastore.subscribe('state/users/+/#', this, this.publish.bind(this))
    this.blacklist('state/users/+/auth/#')
    this.blacklist('state/users/+/auth/*')
  }
  toString() {
    return 'Channel-Users'
  }
}
const users = new User()
export { users }

import { Base } from './base.js'
class Item extends Base {
  constructor() {
    super()
    this.whitelist('state/items/+/#')
  }
  toString() {
    return 'Channel-Items'
  }
}
const items = new Item()
export { items }

import { Base } from './base.js'
class Event extends Base {
  constructor() {
    super()
    this.whitelist('setup/events/+/name')
    this.whitelist('setup/events/+/items/#')
    this.whitelist('setup/events/+/private')
    this.blacklist('state/events/+/pin')
    datastore.subscribe('state/events/+/pin', this, this.syndicate.bind(this))
    datastore.subscribe('state/events/+/#', this, this.publish.bind(this))
    this.initialize('/state/events', '/pin', this.syndicate.bind(this))
  }
  toString() {
    return 'Channel-Events'
  }
}
const events = new Event()
export { events }

import { TopicTree, coppice } from '@djinlist/datastore'
import { authorization } from '../authorization.js'
class Base {
  constructor() {
    Object.defineProperties(this, {
      _permissions: {
        value: new TopicTree
      },
      _subscribers: {
        value: new TopicTree
      }
    })
  }
  toString() {
    return 'Channel-Base'
  }
  whitelist(topic) {
    console.log(`${this.toString()} #whitelist ${topic}`)
    this.list(topic, 'whitelist')
  }
  blacklist(topic) {
    console.log(`${this.toString()} #blacklist ${topic}`)
    this.list(topic, 'blacklist')
  }
  dewhitelist(topic) {
    console.log(`${this.toString()} #dewhitelist ${topic}`)
    this.delist(topic, 'whitelist')
  }
  deblacklist(topic) {
    console.log(`${this.toString()} #deblacklist ${topic}`)
    this.delist(topic, 'blacklist')
  }
  list(topic, type) {
    const permissions = this._permissions.getWithDefault(topic, [])
    permissions._topic = topic
    permissions._value.push(type)
  }
  initialize(prefix, postfix, callback) {
    console.log(`${this.toString()} #initialize ${prefix}/+/${postfix}`)
    const keys = datastore.keys(prefix)
    const callback_topic = `${prefix}/+${postfix}`
    _.forEach(keys, key => {
      const pointer = Pointer.create(`${prefix}/${key}${postfix}`)
      const value = datastore.read(pointer)
      callback(callback_topic, pointer, value)
    })
  }
  delist(topic, type) {
    const permissions = this._permissions.get(topic)
    if (permissions == null || Object.keys(permissions).length === 0) { return }
    permissions.delete(type)
  }
  syndicate(topic, pointer, value) {
    const syndicated_path = pointer.steps.slice(0, -1).concat('#').join('/')
    const private_path = '/' + pointer.steps.slice(0, -1).concat('private').join('/')
    console.log(`${this.toString()} #syndicate ${syndicated_path} ${value}`)
    if (!value) {
      this.whitelist(syndicated_path)
      datastore.destroy(private_path)
    } else {
      this.dewhitelist(syndicated_path)
      datastore.write(private_path, true)
    }
  }
  publish(topic, pointer, value) {
    console.log(`${this.toString()} #publish ${topic} @ ${pointer.path}`)
    const permissions = this._permissions.entries(pointer.topic)
    let whitelisted = false
    for (var idx in permissions) {
      const _permitted = permissions[idx][1]
      if (_permitted.includes('blacklist')) { return }
      if (_permitted.includes('whitelist')) {
        whitelisted = true
      }
    }
    const permitted = _.concat(...Object.values(_.fromPairs(permissions)))
    _.remove(
      permitted,
      subscriber => ['whitelist', 'blacklist'].includes(subscriber)
    )
    const subscribers = this._subscribers.entries(pointer.path.slice(1))
    if (subscribers.length == 0) { return }
    let parse
    if (whitelisted) {
      parse = ([_topic, subscribed]) => {
        console.log(_topic, subscribed)
        _.forEach(subscribed, callbacks => {
          callbacks.forEach(callback => callback(_topic, pointer, value))
        })
      }
    } else {
      parse = ([_topic, subscribed]) => {
        _.forEach(subscribed, (callbacks, subscriber) => {
          if (permitted.includes(subscriber)) {
            callbacks.forEach(callback => callback(_topic, pointer, value))
          }
        })
      }
    }
    _.forEach(subscribers, parse)
  }
  createAuthorization(pointer, packet, subscriber) {
    const response = authorization.createAuthorization(pointer, packet)
    subscriber.send(JSON.stringify(response))
  }
  authorize(pointer, packet, subscriber) {
    const response = authorization.authorize(pointer, packet)
    subscriber.send(JSON.stringify(response))
  }
  prove(pointer, packet, subscriber) {
    const response = authorization.prove(pointer, packet)
    if (response.v.p === false) {
      console.log(`#prove FAIL ${pointer.topic} ${subscriber}`)
      return false
    }
    pointer.root = '+'
    console.log('test', pointer.topic)
    const permissions = this._permissions.getWithDefault(pointer.topic, [])
    permissions._value.push(subscriber.toString())
    console.log(`${this.toString()} #prove SUCCEED ${pointer.topic} ${subscriber}`)
    subscriber.send(JSON.stringify(response))
    return true
  }
  resume(pointer, subscriber) {
    console.log(`${this.toString()} #resume ${pointer.topic} ${subscriber}`)
    const permissions = this._permissions.getWithDefault(pointer.topic, [])
    permissions._value.push(subscriber.toString())
  }
  isAuthorized(pointer, subscriber) {
    const entries = this._permissions.entries(pointer.dequeue().topic)
    if (!entries) {
      console.log(`${this.toString()} #isAuthorized FAIL ${pointer.path}`)
      return false
    }
    let authorized = false
    for (var idx in entries) {
      const callbacks = entries[idx][1]
      if (callbacks.includes('blacklist')) {
        console.log(`${this.toString()} #isAuthorized BLACKLIST ${entries[idx][0]} ${pointer.path}`)
        return false
      }
      if (callbacks.includes('whitelist')) {
        console.log(`${this.toString()} #isAuthorized WHITELIST ${entries[idx][0]}`)
        authorized = true
      } else if (callbacks.includes(subscriber.toString())) {
        console.log(`${this.toString()} #isAuthorized APPROVED ${entries[idx][0]}`)
        authorized = true
      }
    }
    console.log(`${this.toString()} #isAuthorized SUCCEED ${pointer.path}`)
    return authorized
  }
  read(pointer, subscriber) {
    if (!this.isAuthorized(pointer, subscriber)) { return }
    console.log(`#read ${pointer.path}`)
    console.dir(datastore.read(pointer.path))
    const authorizeCoppice = (path, subscriber) => {
      return _.reduce(datastore.read(pointer.path), (result, value, path) => {
        if (this.isAuthorized(Pointer.create(path), subscriber)) {
          result[path] = value
        }
        return result
      }, {})
    }
    const data_coppice = {}
    if (pointer.is_wildcard) {
      Object.assign(
        data_coppice,
        authorizeCoppice(pointer.path, subscriber)
      )
    } else {
      const found = datastore.read(pointer.path)
      if (_.isPlainObject(found)) {
        coppice(found, pointer.path, data_coppice)
      } else {
        data_coppice[path] = found
      }
    }
    return data_coppice
  }
  write(pointer, value, subscriber) {
    if (!this.isAuthorized(pointer, subscriber)) { return }
    console.log(`${this.toString()} #write`, pointer.path, value)
    return datastore.write(pointer.path, value)
  }
  merge(pointer, value, subscriber) {
    if (!this.isAuthorized(pointer, subscriber)) { return }
    console.log(`${this.toString()} #merge`, pointer.path, value)
    return datastore.merge(pointer.path, value)
  }
  delete(pointer, subscriber) {
    if (!this.isAuthorized(pointer, subscriber)) { return }
    return datastore.delete(pointer.path)
  }
  subscribe(pointer, subscriber, callback) {
    const subscribers = this._subscribers.getWithDefault(pointer.topic, {})._value
    if (_.isArray(subscribers[subscriber])) {
      subscribers[subscriber].push(callback)
    } else {
      subscribers[subscriber] = [callback]
    }
  }
  unsubscribe(subscriber) {
    console.log(`#unsubscribe ${subscriber}`)
    const removeSubscriber = ({ _value }) => {
      if (!_value) return
      delete _value[subscriber]
    }
    this._subscribers.apply(removeSubscriber)
    const removePermission = ({ _value }) => {
      if (!_value) return
      _.remove(_value, subscriber.toString())
    }
    this._permissions.apply(removePermission)
  }
}
export { Base }

import { Base } from './base.js'
class Admin extends Base {
  constructor() {
    super()
    this.blacklist('state/admin/auth/#')
    this.blacklist('state/admin/auth/*')
  }
  toString() {
    return 'Channel-Admin'
  }
}
const admin = new Admin()
export { admin }

import srp from "secure-remote-password/server"
import crypto from "crypto"
class serverAuthorization {
  createAuthorization(pointer, packet) {
    // 0
    const salt = packet.s
    const verifier = packet.v
    const salt_pointer = pointer.replace('/#', '/auth/salt')
    const verifier_pointer = pointer.replace('/#', '/auth/verifier')
    const response = {
      o: 'a',
      c: 0,
      t: pointer.topic,
      v: true
    }
    response.v = !datastore.has(salt_pointer)
    if (response.v) {
      datastore.write(salt_pointer, salt)
      datastore.write(verifier_pointer, verifier)
    }
    return response // reject
  }
  authorize(pointer, packet) {
    // 1
    const salt_pointer = pointer.replace('/#', '/auth/salt')
    const verifier_pointer = pointer.replace('/#', '/auth/verifier')
    const client_public_key_pointer = pointer.replace('/#', '/auth/client_public_key')
    const server_secret_key_pointer = pointer.replace('/#', '/auth/server_secret_key')
    datastore.write(client_public_key_pointer, packet.k)
    const response = {
      o: 'a',
      c: 2,
      t: pointer.topic,
      v: {
        u: packet.u
      }
    }
    let salt = datastore.read(salt_pointer)
    let verifier = datastore.read(verifier_pointer)
    let ephemeral
    if (salt && verifier) {
      console.log(`#authorize() ${packet.u} found`)
      ephemeral = srp.generateEphemeral(verifier)
      datastore.write(server_secret_key_pointer, ephemeral.secret)
      response.v.k = ephemeral.public
      response.v.s = salt
    } else {
      console.log(`#authorize() ${packet.u} not found`)
      salt = crypto.randomBytes(32).toString('hex')
      ephemeral = crypto.randomBytes(256).toString('hex')
      response.v.k = ephemeral
      response.v.s = salt
    }
    return response
  }
  prove(pointer, packet) {
    // 3
    const salt_pointer = pointer.replace('/#', '/auth/salt')
    const verifier_pointer = pointer.replace('/#', '/auth/verifier')
    const client_public_key_pointer = pointer.replace('/#', '/auth/client_public_key')
    const server_secret_key_pointer = pointer.replace('/#', '/auth/server_secret_key')
    const session_key_pointer = pointer.replace('/#', '/auth/session_key')
    const server_secret_key = datastore.read(server_secret_key_pointer)
    const client_public_key = datastore.read(client_public_key_pointer)
    const salt = datastore.read(salt_pointer)
    const username = packet.u
    const verifier = datastore.read(verifier_pointer)
    const proof = packet.p
    var session, response
    try {
      session = srp.deriveSession(
      server_secret_key,
        client_public_key,
        salt,
        username,
        verifier,
        proof
      )
      datastore.write(session_key_pointer, session.key)
      response = {
        o: 'a',
        c: 4,
        t: pointer.topic,
        v: {
          u: packet.u,
          p: session.proof
        }
      }
      return response
    } catch (error) {
      response = {
        o: 'a',
        c: 4,
        t: pointer.topic,
        v: {
          u: packet.u,
          p: false
        }
      }
      return response
    }
  }
}
const authorization = new serverAuthorization()
export { authorization }

{
  "name": "@djinlist/content",
  "version": "1.0.0",
  "type": "module",
  "license": "UNLICENSED",
  "private": true,
  "main": "src/index.js",
  "dependencies": {
    "ws": "^6.0.0",
    "uuid": "^8.0.0"
  },
  "exports": {
    ".": "./src/index.js"
  }
}

{
  "state": {
    "events": {
      "75c6cfd0-139a-4a33-8826-9c284645f1ae": {
        "users": {
          "8e97bb55-8b08-5eea-b6d8-3456ec25d301": {
            "items": {
              "spotify:track:7nDYw1nNAW4dAqgmW2W3tq": {
                "vote": 1599514588577
              },
              "spotify:track:6JqYhSdTE4WbQrMXxPH5cD": {
                "vote": 1599514590773
              },
              "spotify:track:3QpkbrYXtlU3LRJu3sTK6V": {
                "vote": 1599514593054
              },
              "spotify:track:1yTTMcUhL7rtz08Dsgb7Qb": {
                "vote": 1599514595941
              },
              "spotify:track:6S1IgeHxxOT9qVWnmsdGxe": {
                "vote": 1599514599534
              },
              "spotify:track:3VXvKTOQoY0kWvpjU67uq2": {
                "vote": 1599514649778
              },
              "spotify:track:2P0FH5jSRu8cctdYfTXtje": {
                "vote": 1599514650996
              },
              "spotify:track:6As34Fmjj7dtReKB51NOVc": {
                "vote": 1600015121994
              },
              "spotify:track:5t9KYe0Fhd5cW6UYT4qP8f": {
                "vote": 1600015123841
              },
              "spotify:track:17jEoYoOfRD6dvNCMmC9n4": {
                "vote": 1600015125507
              },
              "spotify:track:1tkg4EHVoqnhR6iFEXb60y": {
                "vote": 1602363580571
              },
              "spotify:track:5u1n1kITHCxxp8twBcZxWy": {
                "vote": 1602363581598
              },
              "spotify:track:5KCbr5ndeby4y4ggthdiAb": {
                "vote": 1602363582535
              },
              "spotify:track:0sNOPYInjylsM8ZnQozPjt": {
                "vote": 1608595195694
              },
              "spotify:track:4U1c58fpDgbjkb6sVQg26L": {
                "vote": 1608595196665
              },
              "spotify:track:5ryZK3msA04LNcnMaMtm6p": {
                "vote": 1608595197424
              },
              "spotify:track:00deiAYxr1qQx4km9ftnPK": {
                "vote": 1608595199560
              },
              "spotify:track:7lQ8MOhq6IN2w8EYcFNSUk": {
                "vote": 1608595299092
              }
            }
          },
          "f9666a8a-4df1-5d14-9b66-8d08d8d3df58": {
            "items": {
              "spotify:track:5t9KYe0Fhd5cW6UYT4qP8f": {
                "vote": 1600015220987
              },
              "spotify:track:6As34Fmjj7dtReKB51NOVc": {
                "vote": 1600015223023
              },
              "spotify:track:1zXpHPdBAUxnOCQqFMFLk3": {
                "vote": 1600015224884
              },
              "spotify:track:2kXeAEpGBN874ZKJPV24fr": {
                "vote": 1600016939990
              },
              "spotify:track:03ITeFvMvTRpTC92WsQWw5": {
                "vote": 1600016941050
              },
              "spotify:track:3eCwKRKjGT0EIJe3FKOjIo": {
                "vote": 1600016942825
              },
              "spotify:track:3HVRywtkhSjhpmkaeaYTgh": {
                "vote": 1600028103232
              },
              "spotify:track:0YedjUOqafibhe8htcD6Gz": {
                "vote": 1600028946840
              },
              "spotify:track:4G3DWijMhNkWZwLcxnDI0H": {
                "vote": 1600028954864
              },
              "spotify:track:54WIS7qug0Gnt65eD9gg8g": {
                "vote": 1600035577353
              },
              "spotify:track:4kK14radw0XfwxJDPt9tnP": {
                "vote": 1600036253132
              }
            }
          }
        },
        "playlist": [
          [
            "spotify:track:5t9KYe0Fhd5cW6UYT4qP8f",
            2
          ],
          [
            "spotify:track:6As34Fmjj7dtReKB51NOVc",
            2
          ],
          [
            "spotify:track:4kK14radw0XfwxJDPt9tnP",
            1
          ],
          [
            "spotify:track:54WIS7qug0Gnt65eD9gg8g",
            1
          ],
          [
            "spotify:track:4G3DWijMhNkWZwLcxnDI0H",
            1
          ],
          [
            "spotify:track:0YedjUOqafibhe8htcD6Gz",
            1
          ],
          [
            "spotify:track:3HVRywtkhSjhpmkaeaYTgh",
            1
          ],
          [
            "spotify:track:3eCwKRKjGT0EIJe3FKOjIo",
            1
          ],
          [
            "spotify:track:03ITeFvMvTRpTC92WsQWw5",
            1
          ],
          [
            "spotify:track:2kXeAEpGBN874ZKJPV24fr",
            1
          ],
          [
            "spotify:track:1zXpHPdBAUxnOCQqFMFLk3",
            1
          ],
          [
            "spotify:track:7lQ8MOhq6IN2w8EYcFNSUk",
            1
          ],
          [
            "spotify:track:00deiAYxr1qQx4km9ftnPK",
            1
          ],
          [
            "spotify:track:5ryZK3msA04LNcnMaMtm6p",
            1
          ],
          [
            "spotify:track:4U1c58fpDgbjkb6sVQg26L",
            1
          ],
          [
            "spotify:track:0sNOPYInjylsM8ZnQozPjt",
            1
          ],
          [
            "spotify:track:5KCbr5ndeby4y4ggthdiAb",
            1
          ],
          [
            "spotify:track:5u1n1kITHCxxp8twBcZxWy",
            1
          ],
          [
            "spotify:track:1tkg4EHVoqnhR6iFEXb60y",
            1
          ],
          [
            "spotify:track:17jEoYoOfRD6dvNCMmC9n4",
            1
          ],
          [
            "spotify:track:2P0FH5jSRu8cctdYfTXtje",
            1
          ],
          [
            "spotify:track:3VXvKTOQoY0kWvpjU67uq2",
            1
          ],
          [
            "spotify:track:6S1IgeHxxOT9qVWnmsdGxe",
            1
          ],
          [
            "spotify:track:1yTTMcUhL7rtz08Dsgb7Qb",
            1
          ],
          [
            "spotify:track:3QpkbrYXtlU3LRJu3sTK6V",
            1
          ],
          [
            "spotify:track:6JqYhSdTE4WbQrMXxPH5cD",
            1
          ],
          [
            "spotify:track:7nDYw1nNAW4dAqgmW2W3tq",
            1
          ]
        ]
      },
      "62854dc2-7d97-45d3-be03-f0bac69119f8": {
        "users": {
          "8e97bb55-8b08-5eea-b6d8-3456ec25d301": {
            "items": {
              "spotify:track:45bE4HXI0AwGZXfZtMp8JR": {
                "vote": 1600015005150
              },
              "spotify:track:4wosxLl0mAqhneDzya2MfY": {
                "vote": 1600015008029
              },
              "spotify:track:2J4P46vCFm1rPkNkp9pZWX": {
                "vote": 1600015009080
              },
              "spotify:track:5nLNuK7OoJt36gY9gWgnbo": {
                "vote": 1607307765906
              },
              "spotify:track:5vk6nP3fXbz9FoFmsu5coD": {
                "vote": 1607307767167
              },
              "spotify:track:7ytR5pFWmSjzHJIeQkgog4": {
                "vote": 1608594919265
              },
              "spotify:track:4CNzuSQoL5jgCxzYmuMvcz": {
                "vote": 1612729873750
              },
              "spotify:track:4VSyH8AkIt3kaR5xIPFVVi": {
                "vote": 1612730821011
              },
              "spotify:track:1XXimziG1uhM0eDNCZCrUl": {
                "vote": 1613256471284
              },
              "spotify:track:7lPN2DXiMsVn7XUKtOW1CS": {
                "vote": 1612733220849
              },
              "spotify:track:463CkQjx2Zk1yXoBuierM9": {
                "vote": 1612733222218
              },
              "spotify:track:5QO79kh1waicV47BqGRL3g": {
                "vote": 1613256469721
              },
              "spotify:track:3YJJjQPAbDT7mGpX3WtQ9A": {
                "vote": 1612733333737
              },
              "spotify:track:6Im9k8u9iIzKMrmV7BWtlF": {
                "vote": 1612733577976
              },
              "spotify:track:1FkIrCoa9Lkd8rgZ4VhNP9": {
                "vote": 1612757417811
              },
              "spotify:track:4WPaFfZYr290KKtbc0rEO7": {
                "vote": 1612757423526
              },
              "spotify:track:0izUjTuDrUy2FgQOSRALSU": {
                "vote": 1612757442106
              },
              "spotify:track:4fWK7zJp17fuhDfQ9YnAei": {
                "vote": 1612757443252
              },
              "spotify:track:3CeCwYWvdfXbZLXFhBrbnf": {
                "vote": 1613258089402
              },
              "spotify:track:5Kskr9LcNYa0tpt5f0ZEJx": {
                "vote": 1613258320712
              },
              "spotify:track:7Ei7kZxjEw9d76cEDxoxua": {
                "vote": 1613259636644
              },
              "spotify:track:2NeyJbL3ROKCjRkAjs77ya": {
                "vote": 1613259033247
              },
              "spotify:track:7L6G0wpIUiPXuvoo7qhb06": {
                "vote": 1613259037259
              },
              "spotify:track:5srKMwXoeyrRnyTnNbpgIW": {
                "vote": 1613259038382
              },
              "spotify:track:4Iedi94TIaB2GGb1nMB68v": {
                "vote": 1613259638535
              },
              "spotify:track:26UxwWl9xCb83OynXELJcL": {
                "vote": 1613259640344
              },
              "spotify:track:2oI1Avedp7KK4Wytv2Dx0O": {
                "vote": 1615669778570
              },
              "spotify:track:3hbi5zXAgQt0Z9V5JSOnCe": {
                "vote": 1625408125835
              },
              "USRW29600011": {
                "vote": 1625614042071
              },
              "USRW30900002": {
                "vote": 1625521507643
              },
              "USA2P2125949": {
                "vote": 1625710090088
              },
              "CAUM72100222": {
                "vote": 1625710098134
              },
              "QZES82074435": {
                "vote": 1625741218535
              },
              "USUM72021500": {
                "vote": 1625741219686
              },
              "GBAHS2100318": {
                "vote": 1626494269063
              },
              "FRX202125956": {
                "vote": 1626743462791
              }
            },
            "events": {
              "62854dc2-7d97-45d3-be03-f0bac69119f8": {
                "items": {
                  "spotify:track:2NeyJbL3ROKCjRkAjs77ya": {
                    "vote": 1613259033247
                  },
                  "spotify:track:1FkIrCoa9Lkd8rgZ4VhNP9": {
                    "vote": 1612757417811
                  },
                  "spotify:track:4WPaFfZYr290KKtbc0rEO7": {
                    "vote": 1612757423526
                  },
                  "spotify:track:0izUjTuDrUy2FgQOSRALSU": {
                    "vote": 1612757442106
                  },
                  "spotify:track:4fWK7zJp17fuhDfQ9YnAei": {
                    "vote": 1612757443252
                  },
                  "spotify:track:5QO79kh1waicV47BqGRL3g": {
                    "vote": 1613256469721
                  },
                  "spotify:track:1XXimziG1uhM0eDNCZCrUl": {
                    "vote": 1613256471284
                  },
                  "spotify:track:3CeCwYWvdfXbZLXFhBrbnf": {
                    "vote": 1613258089402
                  },
                  "spotify:track:5Kskr9LcNYa0tpt5f0ZEJx": {
                    "vote": 1613258320712
                  },
                  "spotify:track:7Ei7kZxjEw9d76cEDxoxua": {
                    "vote": 1613259636644
                  },
                  "spotify:track:7L6G0wpIUiPXuvoo7qhb06": {
                    "vote": 1613259037259
                  },
                  "spotify:track:5srKMwXoeyrRnyTnNbpgIW": {
                    "vote": 1613259038382
                  },
                  "spotify:track:4Iedi94TIaB2GGb1nMB68v": {
                    "vote": 1613259638535
                  },
                  "spotify:track:26UxwWl9xCb83OynXELJcL": {
                    "vote": 1613259640344
                  },
                  "spotify:track:2oI1Avedp7KK4Wytv2Dx0O": {
                    "vote": 1615669778570
                  },
                  "spotify:track:3hbi5zXAgQt0Z9V5JSOnCe": {
                    "vote": 1625408125835
                  },
                  "USRW29600011": {
                    "vote": 1625614042071
                  },
                  "USRW30900002": {
                    "vote": 1625521507643
                  },
                  "USA2P2125949": {
                    "vote": 1625710090088
                  },
                  "CAUM72100222": {
                    "vote": 1625710098134
                  },
                  "QZES82074435": {
                    "vote": 1625741218535
                  },
                  "USUM72021500": {
                    "vote": 1625741219686
                  },
                  "GBAHS2100318": {
                    "vote": 1626494269063
                  },
                  "FRX202125956": {
                    "vote": 1626743462791
                  }
                }
              }
            }
          }
        },
        "playlist": [
          [
            "FRX202125956",
            1
          ],
          [
            "GBAHS2100318",
            1
          ],
          [
            "USUM72021500",
            1
          ],
          [
            "QZES82074435",
            1
          ],
          [
            "CAUM72100222",
            1
          ],
          [
            "USA2P2125949",
            1
          ],
          [
            "USRW30900002",
            1
          ],
          [
            "USRW29600011",
            1
          ],
          [
            "spotify:track:3hbi5zXAgQt0Z9V5JSOnCe",
            1
          ],
          [
            "spotify:track:2oI1Avedp7KK4Wytv2Dx0O",
            1
          ],
          [
            "spotify:track:26UxwWl9xCb83OynXELJcL",
            1
          ],
          [
            "spotify:track:4Iedi94TIaB2GGb1nMB68v",
            1
          ],
          [
            "spotify:track:5srKMwXoeyrRnyTnNbpgIW",
            1
          ],
          [
            "spotify:track:7L6G0wpIUiPXuvoo7qhb06",
            1
          ],
          [
            "spotify:track:2NeyJbL3ROKCjRkAjs77ya",
            1
          ],
          [
            "spotify:track:7Ei7kZxjEw9d76cEDxoxua",
            1
          ],
          [
            "spotify:track:5Kskr9LcNYa0tpt5f0ZEJx",
            1
          ],
          [
            "spotify:track:3CeCwYWvdfXbZLXFhBrbnf",
            1
          ],
          [
            "spotify:track:4fWK7zJp17fuhDfQ9YnAei",
            1
          ],
          [
            "spotify:track:0izUjTuDrUy2FgQOSRALSU",
            1
          ],
          [
            "spotify:track:4WPaFfZYr290KKtbc0rEO7",
            1
          ],
          [
            "spotify:track:1FkIrCoa9Lkd8rgZ4VhNP9",
            1
          ],
          [
            "spotify:track:6Im9k8u9iIzKMrmV7BWtlF",
            1
          ],
          [
            "spotify:track:3YJJjQPAbDT7mGpX3WtQ9A",
            1
          ],
          [
            "spotify:track:5QO79kh1waicV47BqGRL3g",
            1
          ],
          [
            "spotify:track:463CkQjx2Zk1yXoBuierM9",
            1
          ],
          [
            "spotify:track:7lPN2DXiMsVn7XUKtOW1CS",
            1
          ],
          [
            "spotify:track:1XXimziG1uhM0eDNCZCrUl",
            1
          ],
          [
            "spotify:track:4VSyH8AkIt3kaR5xIPFVVi",
            1
          ],
          [
            "spotify:track:4CNzuSQoL5jgCxzYmuMvcz",
            1
          ],
          [
            "spotify:track:7ytR5pFWmSjzHJIeQkgog4",
            1
          ],
          [
            "spotify:track:5vk6nP3fXbz9FoFmsu5coD",
            1
          ],
          [
            "spotify:track:5nLNuK7OoJt36gY9gWgnbo",
            1
          ],
          [
            "spotify:track:2J4P46vCFm1rPkNkp9pZWX",
            1
          ],
          [
            "spotify:track:4wosxLl0mAqhneDzya2MfY",
            1
          ],
          [
            "spotify:track:45bE4HXI0AwGZXfZtMp8JR",
            1
          ]
        ],
        "items": {
          "spotify:track:1FkIrCoa9Lkd8rgZ4VhNP9": {
            "name": "My People",
            "artists": [
              "Erykah Badu"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0213066c8c5df466c8a3e57ca4"
          },
          "spotify:track:08zt4rqVjqahvXaWAuEBbP": {
            "name": "Cold Feet",
            "artists": [
              "Loud Luxury"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0294805d9c6cd1f558d0b0a8ef"
          },
          "spotify:track:2plLJpUcYPFrl1sW2pMG63": {
            "name": "Lights Up",
            "artists": [
              "Harry Styles"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02766ba00b287429d0b13e1e5f"
          },
          "spotify:track:0gmgCD6OoJMcoK5af0exA2": {
            "name": "The Lake (with Wrabel)",
            "artists": [
              "Galantis",
              "Wrabel"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02816cee08cb1ed2c881416a24"
          },
          "spotify:track:5QO79kh1waicV47BqGRL3g": {
            "name": "Save Your Tears",
            "artists": [
              "The Weeknd"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e028863bc11d2aa12b54f5aeb36"
          },
          "spotify:track:4pBhTGnL5N5KqsyqU58jee": {
            "name": "I'm not Pretty",
            "artists": [
              "JESSIA"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02fb006ce1d7c3f263c521f01e"
          },
          "spotify:track:4wcOBczfEVjEgsF4aKhKbL": {
            "name": "When You're Home",
            "artists": [
              "Tyler Shaw"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02b16d438b180bdec4ef771c19"
          },
          "spotify:track:6Im9k8u9iIzKMrmV7BWtlF": {
            "name": "34+35",
            "artists": [
              "Ariana Grande"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e025ef878a782c987d38d82b605"
          },
          "spotify:track:54bFM56PmE4YLRnqpW6Tha": {
            "name": "Therefore I Am",
            "artists": [
              "Billie Eilish"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02fec5ef9f3133aff71c525acc"
          },
          "spotify:track:3USxtqRwSYz57Ewm6wWRMp": {
            "name": "Heat Waves",
            "artists": [
              "Glass Animals"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02712701c5e263efc8726b1464"
          },
          "spotify:track:6IE47jpPeatF2Iay7GZtEc": {
            "name": "Feel It All Around",
            "artists": [
              "Washed Out"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e020f2e0c616a2eb4e00d4c51c3"
          },
          "spotify:track:2EH1ZVZx2wPGtQb5V2hNih": {
            "name": "Good To Sea",
            "artists": [
              "Pinback"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02a3708b5baa5ec5f353324f81"
          },
          "spotify:track:24HPkbkXJsIFC4eyg63zgQ": {
            "name": "Wraith Pinned to the Mist and Other Games",
            "artists": [
              "of Montreal"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0238a6cc0b38036949ed001f9a"
          },
          "spotify:track:3qUqucPIPqlSnzq5MacjxQ": {
            "name": "Goût cerise",
            "artists": [
              "Ragers"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02be8727b798d326c3c164b359"
          },
          "spotify:track:6HyUeilH0GYtSWRYBtRm3l": {
            "name": "À qui j'dois ressembler ?",
            "artists": [
              "Matthieu Lévesque"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0242ce05b61d23754a0204a4d2"
          },
          "spotify:track:4ycyOBm9iFoiNVkafhb1WW": {
            "name": "Nouveaux parrains",
            "artists": [
              "Sofiane",
              "Soolking"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e028b6fb0dffb290ef4f27e56e7"
          },
          "spotify:track:6iUlUzSGZzKtlCvQ3wCVZD": {
            "name": "Breakdown (feat. Krayzie Bone & Wish Bone)",
            "artists": [
              "Mariah Carey",
              "Krayzie Bone",
              "Wishbone"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0298ed501c6a838b2244ebaf75"
          },
          "spotify:track:58r4JuwHhXLAkttkaUZfLw": {
            "name": "Got to Be Real",
            "artists": [
              "Cheryl Lynn"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02c0e98d7c48b548f1a3833368"
          },
          "spotify:track:4CNzuSQoL5jgCxzYmuMvcz": {
            "name": "Like It (with 6LACK)",
            "artists": [
              "Summer Walker",
              "6LACK"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02b5ed9187ac7f8aa281a547e3"
          },
          "spotify:track:7vxLj7MREliG5i5vSnqSVr": {
            "name": "Body",
            "artists": [
              "Summer Walker"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02b5ed9187ac7f8aa281a547e3"
          },
          "spotify:track:4VSyH8AkIt3kaR5xIPFVVi": {
            "name": "Where My Girls At",
            "artists": [
              "702"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e020100a4e7e46b63b46e03b158"
          },
          "spotify:track:2NeyJbL3ROKCjRkAjs77ya": {
            "name": "Ashes",
            "artists": [
              "Stellar"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e023286f23a94f357cdbbb4d718"
          },
          "spotify:track:4WPaFfZYr290KKtbc0rEO7": {
            "name": "Life's Gone Down Low",
            "artists": [
              "Lijadu Sisters"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02236de7aa0dab13d4c9b02eba"
          },
          "spotify:track:0izUjTuDrUy2FgQOSRALSU": {
            "name": "Lockdown",
            "artists": [
              "Koffee"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02cdbcabc170ce557ae4919753"
          },
          "spotify:track:4fWK7zJp17fuhDfQ9YnAei": {
            "name": "Gettaway (feat. Space & Nicole)",
            "artists": [
              "Missy Elliott",
              "Nicole Wray",
              "Space"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02f27571e59cac2e7a4624c9c4"
          },
          "spotify:track:1XXimziG1uhM0eDNCZCrUl": {
            "name": "Up",
            "artists": [
              "Cardi B"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02d619b8baab0619516bb53804"
          },
          "spotify:track:3CeCwYWvdfXbZLXFhBrbnf": {
            "name": "Love Story (Taylor’s Version)",
            "artists": [
              "Taylor Swift"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02877ea8fa223c26f19aaef92d"
          },
          "spotify:track:5Kskr9LcNYa0tpt5f0ZEJx": {
            "name": "Calling My Phone",
            "artists": [
              "Lil Tjay",
              "6LACK"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e021b36f91abf80aedb7c88f460"
          },
          "spotify:track:7Ei7kZxjEw9d76cEDxoxua": {
            "name": "What It Feels Like",
            "artists": [
              "Nipsey Hussle",
              "JAY-Z"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02b02a3380a69bd2418a1f68f1"
          },
          "spotify:track:7L6G0wpIUiPXuvoo7qhb06": {
            "name": "oops!",
            "artists": [
              "Yung Gravy"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02c5e844c860c9717785b7aaa2"
          },
          "spotify:track:5srKMwXoeyrRnyTnNbpgIW": {
            "name": "People I Don't Like",
            "artists": [
              "UPSAHL"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02de3975b105bc6d216359ffe6"
          },
          "spotify:track:4Iedi94TIaB2GGb1nMB68v": {
            "name": "On Me",
            "artists": [
              "Lil Baby"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e028de3ce24866dcc8ffddbebac"
          },
          "spotify:track:26UxwWl9xCb83OynXELJcL": {
            "name": "Masterpiece",
            "artists": [
              "DaBaby"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e027b41da110df7023757e8f8fa"
          },
          "spotify:track:2oI1Avedp7KK4Wytv2Dx0O": {
            "name": "Love is a losing game",
            "artists": [
              "THEHONESTGUY",
              "Malaika Khadijaa"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e025f27cac740de78fddbab7bfe"
          },
          "spotify:track:3hbi5zXAgQt0Z9V5JSOnCe": {
            "name": "Everybody Wants To Party",
            "artists": [
              "Dubdogz",
              "JØRD"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0286271a532aa6196b056f369f"
          }
        }
      },
      "fe71a1ee-6e64-4d4f-8a03-7b091d93c823": {
        "playlist": []
      },
      "null": {
        "users": {
          "8e97bb55-8b08-5eea-b6d8-3456ec25d301": {
            "items": {
              "spotify:track:0k7wmahjkn389wAZdz19Cv": {
                "vote": 1607306677700
              }
            }
          }
        }
      },
      "": {
        "users": {
          "8e97bb55-8b08-5eea-b6d8-3456ec25d301": {
            "spotify:track:1FkIrCoa9Lkd8rgZ4VhNP9": {
              "vote": 1612735281874
            },
            "spotify:track:08zt4rqVjqahvXaWAuEBbP": {
              "vote": 1612750262848
            },
            "spotify:track:2plLJpUcYPFrl1sW2pMG63": {
              "vote": 1612750264080
            },
            "spotify:track:0gmgCD6OoJMcoK5af0exA2": {
              "vote": 1612750266245
            }
          }
        }
      },
      "users": {
        "8e97bb55-8b08-5eea-b6d8-3456ec25d301": {
          "spotify:track:5QO79kh1waicV47BqGRL3g": {
            "vote": 1612751939386
          },
          "spotify:track:4pBhTGnL5N5KqsyqU58jee": {
            "vote": 1612751940395
          },
          "spotify:track:4wcOBczfEVjEgsF4aKhKbL": {
            "vote": 1612751941208
          },
          "spotify:track:6Im9k8u9iIzKMrmV7BWtlF": {
            "vote": 1612752104792
          },
          "spotify:track:54bFM56PmE4YLRnqpW6Tha": {
            "vote": 1612752106934
          },
          "spotify:track:3USxtqRwSYz57Ewm6wWRMp": {
            "vote": 1612752110688
          },
          "spotify:track:6IE47jpPeatF2Iay7GZtEc": {
            "vote": 1612752137501
          },
          "spotify:track:2EH1ZVZx2wPGtQb5V2hNih": {
            "vote": 1612752146666
          },
          "spotify:track:24HPkbkXJsIFC4eyg63zgQ": {
            "vote": 1612752149757
          },
          "spotify:track:3qUqucPIPqlSnzq5MacjxQ": {
            "vote": 1612752423687
          },
          "spotify:track:6HyUeilH0GYtSWRYBtRm3l": {
            "vote": 1612752429315
          },
          "spotify:track:4ycyOBm9iFoiNVkafhb1WW": {
            "vote": 1612752433894
          },
          "spotify:track:6iUlUzSGZzKtlCvQ3wCVZD": {
            "vote": 1612753413416
          },
          "spotify:track:58r4JuwHhXLAkttkaUZfLw": {
            "vote": 1612753415873
          },
          "spotify:track:4CNzuSQoL5jgCxzYmuMvcz": {
            "vote": 1612753423847
          },
          "items": {
            "spotify:track:2NeyJbL3ROKCjRkAjs77ya": {
              "vote": 1612756744096
            }
          }
        }
      }
    },
    "users": {
      "8e97bb55-8b08-5eea-b6d8-3456ec25d301": {
        "auth": {
          "salt": "27e869c626c79ebc8b0d4e59887f3bb66a8031a5e01a0e5faedbdcaa4a7748ab",
          "verifier": "ab2acfc79f5bb1cad3f16276bed6089c626c6e8bb870486a687d5c41b1f0e9534e096e1657c4baee38b805a6ab8c2c38ec38d29048eb8f1f1a28f2a7668f0c2f8983ea6514a00f26f2bc42530946d11f9f304882d0bd4ce240272fe5fc46ada47c22917d630cb2c65f08f2a76438c9d08bfa458d5e1b67ebf43a829027365d1a2d8794b08132796c32d9d9492cc42ca5147eff60304a5b38496b0326f92dfbde167b722834657b45db7a2f51398128fb32753f6deba8a5f474bc58d6d34a1c5a5f75e84860cfba95ad4742017053b464e924bfd10aeceb0169b5c88ddb0bddaee59b198ecdae658a3211eeaf5590c2315459cc7ab78a2114d6e0a162845b386e",
          "client_public_key": "8b119bd7b590235ed80827763e385af341e31e69743cab56500ea1dbe59a2703c38111c3a21751e018de0bf38237a313bc6ad52ac1ce816605e3c11b931822a1c0726715171576450bcd34c3b7a262cc0755fce9afd918e8e60f6e7b3ec8c55a12cd399a5940638113a00735971fbd4a19ed9b0821a6f625d9ac7a3c2d9590e89c4c2692ded40c8b442c477404b54a4aaae2ba0f226d800a1e4a6b5469ac50f5e48e466b82319728bc37839a88ad96c302f4eae80eb7d834cbf0e9b1554cec4b6c9a0749cb843257287f834785ce39d1ef06f71ecd2c19a5143e34f4ccf7d7ece7be83f8129ade15e678c02c9c7bbfafd69c68b26c4787de006c7fccb3f49dd5",
          "server_secret_key": "357ea32f5d17bb517b882d150955d810eccf1dcc0cc3c9a99262897ea15e83ae",
          "session_key": "34b1ae3709db4bcb9948ab8769b130a8a1c5954dc8d551432b0c93316bf13e2d"
        },
        "email": "thomas.p.cowan@gmail.com",
        "name": "tpcowan",
        "created_at": 1599514138874,
        "services": {
          "spotify": {
            "expiry": 1627916615,
            "token": "BQBW0F54C5aapo5-1Lq3B3nF3MUSM7j19a7CRrfKnjeg9xdN-y3Ix3zOP3ggRdarU5WtWZYyOYAAM-owFrEdXcT-cXkHYH_WI3p7Dtm4JRPnVGGLsZeVeA15N7bYzFRvPxFBooHoGehc2ILFlEYUyHUJ60odagrpOGyUsW3oCeZBO_7-3FrvEzgtDxkIrg"
          }
        },
        "drivers": {
          "spotify": {
            "token": "BQBW0F54C5aapo5-1Lq3B3nF3MUSM7j19a7CRrfKnjeg9xdN-y3Ix3zOP3ggRdarU5WtWZYyOYAAM-owFrEdXcT-cXkHYH_WI3p7Dtm4JRPnVGGLsZeVeA15N7bYzFRvPxFBooHoGehc2ILFlEYUyHUJ60odagrpOGyUsW3oCeZBO_7-3FrvEzgtDxkIrg"
          }
        },
        "event_id": "62854dc2-7d97-45d3-be03-f0bac69119f8",
        "items": {
          "1tkg4EHVoqnhR6iFEXb60y": {
            "artists": [
              "Pop Smoke"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0277ada0863603903f57b34369"
          },
          "5u1n1kITHCxxp8twBcZxWy": {
            "artists": [
              "Justin Bieber",
              "Chance the Rapper"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02572c68f79b356c21202e248c"
          },
          "5KCbr5ndeby4y4ggthdiAb": {
            "artists": [
              "Shawn Mendes"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e023d9621bb2904dc57a60a6b36"
          },
          "spotify:track:0k7wmahjkn389wAZdz19Cv": {
            "artists": [
              "Future",
              "Lil Uzi Vert"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0257928e0363878a71692e6a1f"
          },
          "spotify:track:5nLNuK7OoJt36gY9gWgnbo": {
            "artists": [
              "YSN Fab"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02dea56579b16b977c620ac267"
          },
          "spotify:track:5vk6nP3fXbz9FoFmsu5coD": {
            "artists": [
              "Tizzy Stackz"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e020b20ee77457a3f4df0dcc63e"
          },
          "spotify:track:7ytR5pFWmSjzHJIeQkgog4": {
            "artists": [
              "DaBaby",
              "Roddy Ricch"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0220e08c8cc23f404d723b5647"
          },
          "spotify:track:0sNOPYInjylsM8ZnQozPjt": {
            "artists": [
              "Ramin Djawadi"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02239a1395e4d595efc28af924"
          },
          "spotify:track:4U1c58fpDgbjkb6sVQg26L": {
            "artists": [
              "Ramin Djawadi"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02239a1395e4d595efc28af924"
          },
          "spotify:track:5ryZK3msA04LNcnMaMtm6p": {
            "artists": [
              "Ramin Djawadi"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02239a1395e4d595efc28af924"
          },
          "spotify:track:00deiAYxr1qQx4km9ftnPK": {
            "artists": [
              "Ramin Djawadi"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0262be9b16adb2e32aed9bda26"
          },
          "spotify:track:7lQ8MOhq6IN2w8EYcFNSUk": {
            "artists": [
              "Eminem"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e026ca5c90113b30c3c43ffb8f4"
          },
          "spotify:track:4CNzuSQoL5jgCxzYmuMvcz": {
            "artists": [
              "Summer Walker",
              "6LACK"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02b5ed9187ac7f8aa281a547e3"
          },
          "spotify:track:4VSyH8AkIt3kaR5xIPFVVi": {
            "artists": [
              "702"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e020100a4e7e46b63b46e03b158"
          },
          "spotify:track:1XXimziG1uhM0eDNCZCrUl": {
            "artists": [
              "Cardi B"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e02d619b8baab0619516bb53804"
          },
          "spotify:track:7lPN2DXiMsVn7XUKtOW1CS": {
            "artists": [
              "Olivia Rodrigo"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0259779689e1d9c15ca2f76b84"
          },
          "spotify:track:463CkQjx2Zk1yXoBuierM9": {
            "artists": [
              "Dua Lipa",
              "DaBaby"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0249caa4fc6f962057ba65576a"
          },
          "spotify:track:5QO79kh1waicV47BqGRL3g": {
            "artists": [
              "The Weeknd"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e028863bc11d2aa12b54f5aeb36"
          },
          "spotify:track:3YJJjQPAbDT7mGpX3WtQ9A": {
            "artists": [
              "SZA"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e023097b1375ab17ae5bf302a0a"
          },
          "spotify:track:6Im9k8u9iIzKMrmV7BWtlF": {
            "artists": [
              "Ariana Grande"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e025ef878a782c987d38d82b605"
          }
        }
      },
      "f9666a8a-4df1-5d14-9b66-8d08d8d3df58": {
        "auth": {
          "salt": "311ac5713fe41aa6ddb172325967c2ec73f93c5d52e4db1603ce5e209eb55a65",
          "verifier": "39722ca76312f45013194c033279fdcac4470bcf8b001d64ad8d75896b372567b787775ea2d49b886e52cbde406f7977c1ac6201143801c00ddf2804262ab7dbe6b78f2d110d5addb5715ce485070f1736bae20e302ce809368b19b5bcb16e4ac785744a71824edc69847729d3d0e68559b640fa842ff1cf77520c83a2f67f84d72e1de89240c82c145c2b88452cbd5f7403998c554a20296fa017e0419698f289c8eb5a79dc9c8bb9184201c7d27a795658fba76a1114ccb2d0f3e71538af86d60ab2dbcf8b1ce0321ff84d6799352e9a0b11d26c2c4152a1c9d38d98988e6d87318f223f33f5c5e970a796186981338569fd97713b7f93825f30cb42311e2f",
          "client_public_key": "365c94c8676042a17ceac7ff56d03be4c8565e086ccbe43eae362d5c2fe4eb9d22cc5d1ee460b96b30c91bb40d50cb6cf3b93dd6319bc2a9dc6a2a403da9d6f44a77f0478f33f6d09fbb8ccb43576889d437f07f189dc407781a6a65ca44738bffe20e51198a92b990143c4f4a3e5811d60c8202a87720176b564b66ed5ae5b58d833709a6c299517387da112f11363f9b429baf593bca9891adec15fa27685ad0040a8dc788c15e07fa1905360827e4f5ad59fbdeede252334d1b3213d5b74297412622f31065d9c9907eadede277e72d3ed4aa6fd5167947d56ac211bed8d6a1913119a7b876d8247b60966e4fb3c842f0a586757866e84c52e89cafa79fb4",
          "server_secret_key": "53a123ed0d4fde5bb266ecf1e1d065ef0fa97c38d78069cfe16fb883f3ec12b3",
          "session_key": "a5ad681112cf8a6c1e057b7f3697110dfbec110921861d0b9566a0238064ce76"
        },
        "email": "telcowan@gmail.com",
        "name": "tec",
        "created_at": 1600015188562,
        "drivers": {
          "spotify": {
            "token": "BQBYmk6K2LAFwuhn0zdk_6TgjMlc3N1Zz9-KZBHxvMI695au6QlMpSmPQvxqPcjeznJXSJbJiWT6gOmEy84XyZ0S9UCYNR6MK14Nth4D5tbHeLHushL2NJltos_Si2N_VDDKDV82m1vgj83_KvdaJhPF8_6jJOGk"
          }
        },
        "services": {
          "spotify": {
            "expiry": 1600825145,
            "token": "BQBYmk6K2LAFwuhn0zdk_6TgjMlc3N1Zz9-KZBHxvMI695au6QlMpSmPQvxqPcjeznJXSJbJiWT6gOmEy84XyZ0S9UCYNR6MK14Nth4D5tbHeLHushL2NJltos_Si2N_VDDKDV82m1vgj83_KvdaJhPF8_6jJOGk"
          }
        },
        "event_id": "75c6cfd0-139a-4a33-8826-9c284645f1ae",
        "items": {
          "54WIS7qug0Gnt65eD9gg8g": {
            "artists": [
              "Morgan Delt"
            ]
          },
          "4kK14radw0XfwxJDPt9tnP": {
            "artists": [
              "Lewis Del Mar"
            ],
            "image_url": "https://i.scdn.co/image/ab67616d00001e0211555ed45c4377e101d7979d"
          }
        }
      },
      "59c40275-d764-5f53-907d-c9ccc7b097d7": {
        "auth": {
          "salt": "1f3f6715b48937796e62ea7725e02ec3be2edf681298a5d345b61bc75486739d",
          "verifier": "5f2c9aaab598abfd6bc47ffc772061aa67c735d5ddc27d192f6a05b98c994ef151f27b67e9d059c46e05200eebed9cc905ec12a7f38fa30ab7778bebe0796572ef7f7d14eda52a938e65fc577c6e686e98f5f7ca4f2cc9b49747493bc266c6b0e62c90349dc3311bd310e0523d27fb404f3df4ad6fc7d50d2d48d5b9f23eb49456a8cef6642acbef2bf0c914f1d2f2801ae7de6d24d89b9698410dd2cfc91f592befcef89513ef8755ff11473ac8cdcb5ce3d99f970621403fd44f5b1aa177f9f33171de5f57b0a6eb16e24a96302acf7bf6443803b77efb35d8e956885c00836c142eb2fd4f4a3006311f513dc0554530b1691464b0a3c85304c8b96ec26cec",
          "client_public_key": "a5f078c9d7c9e334a9d1c86328af91753e963f2f2633e04f8c6734e4ede048bdd4a4736c3f7309b0c7322fd1a9c23a8610ab34337b35cc773142cef80b0f7dbe16c745355981c9db7f578c263c64bf42c31eb9f34a9df9029790549bb0d0a4baa8e4005a47815ae29b97b902e887ed5d7019a3715ec456059b3465c8bdae10f7d14760e304ee61f94951b13e3589c1078f8f1853257ccc2b4b85da198462316e95cb8cb5d82df321de6955c0e406ae1964c403fd6bded40cbd1af7958a56af52ba0d609d2428788c3e75a85280f552890c608830c55ee58abcac686e0fccbacd46ceb4e227e5600c3091236ceddb5ee58ba16a3784c2b0e8b9c22ee209cf6bbf",
          "server_secret_key": "edfeee05c987ab609e43f5b5ab6e8affd3a34249db192fdf9978cc664c591b99",
          "session_key": "ce6589a816fb281814bca9fe6ae1d6e3d48c865d02673fe48982f6324a130bfc"
        },
        "created_at": 1607305069408
      }
    },
    "items": {
      "spotify:track:7nDYw1nNAW4dAqgmW2W3tq": {
        "name": "Almost (Sweet Music)"
      },
      "spotify:track:6JqYhSdTE4WbQrMXxPH5cD": {
        "name": "Honeypie"
      },
      "spotify:track:3QpkbrYXtlU3LRJu3sTK6V": {
        "name": "Joy"
      },
      "spotify:track:1yTTMcUhL7rtz08Dsgb7Qb": {
        "name": "The Bones - with Hozier"
      },
      "spotify:track:6S1IgeHxxOT9qVWnmsdGxe": {
        "name": "Treehouse (feat. Shotty Horroh)"
      },
      "spotify:track:3VXvKTOQoY0kWvpjU67uq2": {
        "name": "Daydreaming"
      },
      "spotify:track:2P0FH5jSRu8cctdYfTXtje": {
        "name": "Space and Time"
      },
      "spotify:track:45bE4HXI0AwGZXfZtMp8JR": {
        "name": "you broke me first"
      },
      "spotify:track:4wosxLl0mAqhneDzya2MfY": {
        "name": "Head & Heart (feat. MNEK)"
      },
      "spotify:track:2J4P46vCFm1rPkNkp9pZWX": {
        "name": "Ice Cream (with Selena Gomez)"
      },
      "spotify:track:6As34Fmjj7dtReKB51NOVc": {
        "name": "Super Natural"
      },
      "spotify:track:5t9KYe0Fhd5cW6UYT4qP8f": {
        "name": "Good Vibrations - Remastered"
      },
      "spotify:track:17jEoYoOfRD6dvNCMmC9n4": {
        "name": "City Club"
      },
      "spotify:track:1zXpHPdBAUxnOCQqFMFLk3": {
        "name": "Saltwater"
      },
      "spotify:track:2kXeAEpGBN874ZKJPV24fr": {
        "name": "Acaríñame"
      },
      "spotify:track:03ITeFvMvTRpTC92WsQWw5": {
        "name": "La Cumbia de los Monjes"
      },
      "spotify:track:3eCwKRKjGT0EIJe3FKOjIo": {
        "name": "La Sirenita"
      },
      "spotify:track:3HVRywtkhSjhpmkaeaYTgh": {
        "name": "Life Itself"
      },
      "spotify:track:0YedjUOqafibhe8htcD6Gz": {
        "name": "Bounce (feat. N.O.R.E.) - Radio Version"
      },
      "spotify:track:4G3DWijMhNkWZwLcxnDI0H": {
        "name": "Freeze Me"
      },
      "spotify:track:54WIS7qug0Gnt65eD9gg8g": {
        "name": "Some Sunsick Day"
      },
      "spotify:track:4kK14radw0XfwxJDPt9tnP": {
        "name": "Painting (Masterpiece)"
      },
      "spotify:track:1tkg4EHVoqnhR6iFEXb60y": {
        "name": "What You Know Bout Love"
      },
      "spotify:track:5u1n1kITHCxxp8twBcZxWy": {
        "name": "Holy (feat. Chance The Rapper)"
      },
      "spotify:track:5KCbr5ndeby4y4ggthdiAb": {
        "name": "Wonder"
      },
      "spotify:track:0k7wmahjkn389wAZdz19Cv": {
        "name": "Drankin N Smokin"
      },
      "spotify:track:5nLNuK7OoJt36gY9gWgnbo": {
        "name": "Get Rich or Die Tryin"
      },
      "spotify:track:5vk6nP3fXbz9FoFmsu5coD": {
        "name": "Boujee"
      },
      "spotify:track:7ytR5pFWmSjzHJIeQkgog4": {
        "name": "ROCKSTAR (feat. Roddy Ricch)"
      },
      "spotify:track:0sNOPYInjylsM8ZnQozPjt": {
        "name": "Winter Is Coming - From The \"Game Of Thrones\" Soundtrack"
      },
      "spotify:track:4U1c58fpDgbjkb6sVQg26L": {
        "name": "Jon's Honor - From The \"Game Of Thrones\" Soundtrack"
      },
      "spotify:track:5ryZK3msA04LNcnMaMtm6p": {
        "name": "The Night's Watch - From The \"Game Of Thrones\" Soundtrack"
      },
      "spotify:track:00deiAYxr1qQx4km9ftnPK": {
        "name": "White Walkers"
      },
      "spotify:track:7lQ8MOhq6IN2w8EYcFNSUk": {
        "name": "Without Me"
      },
      "spotify:track:4CNzuSQoL5jgCxzYmuMvcz": {
        "name": "Like It (with 6LACK)"
      },
      "spotify:track:4VSyH8AkIt3kaR5xIPFVVi": {
        "name": "Where My Girls At"
      },
      "spotify:track:2h9TDNEXRhcDIV3fsoEVq9": {
        "name": "What Other People Say"
      },
      "spotify:track:1A8990rtwHQ417l3yADe5t": {
        "name": "GNF (OKOKOK)"
      },
      "spotify:track:0tQmgwFKw9069z1BXniOiA": {
        "name": "Provide (feat. Chris Brown & Mark Morrison)"
      },
      "spotify:track:2u8NmvhYX6wiviyxJTOhEi": {
        "name": "Making A Fire"
      },
      "spotify:track:2Y0wPrPQBrGhoLn14xRYCG": {
        "name": "Come & Go (with Marshmello)"
      },
      "spotify:track:5SWnsxjhdcEDc7LJjq9UHk": {
        "name": "Runnin"
      },
      "spotify:track:3SYO8wU4bEgIYt7AeGRIwG": {
        "name": "Nightwhisper"
      },
      "spotify:track:73X9X7kDgsm4YeHpc8prf6": {
        "name": "Apricots"
      },
      "spotify:track:1XXimziG1uhM0eDNCZCrUl": {
        "name": "Up"
      },
      "spotify:track:7lPN2DXiMsVn7XUKtOW1CS": {
        "name": "drivers license"
      },
      "spotify:track:463CkQjx2Zk1yXoBuierM9": {
        "name": "Levitating (feat. DaBaby)"
      },
      "spotify:track:5QO79kh1waicV47BqGRL3g": {
        "name": "Save Your Tears"
      },
      "spotify:track:3YJJjQPAbDT7mGpX3WtQ9A": {
        "name": "Good Days"
      },
      "spotify:track:6Im9k8u9iIzKMrmV7BWtlF": {
        "name": "34+35"
      },
      "USRW29600011": {
        "name": "Everlong",
        "spotfiy_id": "spotify:track:5UWwZ5lm5PKu6eKsHAGxOk",
        "isrc": "USRW29600011"
      },
      "USRW30900002": {
        "name": "Everlong - Acoustic Version",
        "spotfiy_id": "spotify:track:3QmesrvdbPjwf7i40nht1D",
        "isrc": "USRW30900002"
      },
      "USA2P2125949": {
        "name": "All Eyes On Me - Song Only",
        "spotfiy_id": "spotify:track:47emsK4Cj4dMqctYq18U03",
        "isrc": "USA2P2125949"
      },
      "CAUM72100222": {
        "name": "Therapy",
        "spotfiy_id": "spotify:track:3rsJVGczbI4PRb9YdyoZms",
        "isrc": "CAUM72100222"
      },
      "QZES82074435": {
        "name": "Stunnin' (feat. Harm Franklin)",
        "spotfiy_id": "spotify:track:2D0dj3hVkRQJCp63cxCPEx",
        "isrc": "QZES82074435"
      },
      "USUM72021500": {
        "name": "Therefore I Am",
        "spotfiy_id": "spotify:track:54bFM56PmE4YLRnqpW6Tha",
        "isrc": "USUM72021500"
      },
      "GBAHS2100318": {
        "name": "Bad Habits",
        "spotfiy_id": "spotify:track:6PQ88X9TkUIAUIZJHW2upE",
        "isrc": "GBAHS2100318"
      },
      "FRX202125956": {
        "name": "Tonight",
        "spotfiy_id": "spotify:track:3YoiHH3Myq1fo19pNCTmkW",
        "isrc": "FRX202125956"
      }
    },
    "admin": {
      "auth": {
        "salt": "f0c7b75bc552729b75de85c221238275a665b2608204dc2def1bec3657c22946",
        "verifier": "1a058c680c16bb0f09e2a69d92ca79ee4bdd24f28645fe5e5fed5b1ca8edd8d46760b5b469653923d1876695a4246fd603dd6045c81f10ed69d8b515ceb6e1784a4e0041ee7e9f716cc374519d258fbc08c14f9b82db7e2187a3693fa15e32f9bbb4c3a718ee7e8a30e9fec8bcf57ad592922206b84ca0af2480b4e98016600496a8873278745f2ec53306ea9e7dddfa3277faac8aa00f6091337fdaf66cb2e61fc45cca130b43dedeb3db2f3f3d9c1a8cdcdc17ec3c0892c621478afb22f6060e3e0195ea8527a07c6e0bc01b7304baad7a22a3e6162eec6c5adc8f78a1a4704430d7bba6d4f7c0a90960d98703a82d4e8069487cb35fe295fdb6b1b4e4eb51",
        "client_public_key": "725fce92074dd0b06b3dea7858ddc2f12cd9a40f3091019c3ab743222783986d20924babef5904ae5acc976998b8186e846187feb1f98026060966619fba3c414546fdcca95b357eae4446b942fdfb79ad8c540f3e715a6a1162db8bd17edffc9596563f0757b70475b77017310861dfe1b504893fc50fb15e334a366f3a919eebb2c9996f27779f470a70b07f0a0f6db553de0f2d1f49fc778b44e897f13c96eac82b3004f428b8dbb966d01c36c85c50bcc262965f54af4e622d5ec8bbd9b4d2e4bc645d6b9784fa156ed081566f29cdcaad190bdca02d7026cb0d6b6c764ed5881d4a65ac9a5b0ae896beb9c1fb5b89811d90b596206a65ee9fded3889764",
        "server_secret_key": "d5c862d34de2c18b3c162be538cfb59e5957224452b6c9733a37ff27f580480f",
        "session_key": "bc444d93d7efa3010bdbe36e3762af63850147fd2f13df7c31ca3696348b591c"
      }
    }
  },
  "setup": {
    "admin": {
      "token": "BQAICrqhcCVqGJ5C73OVEuvJ-AHiyU9Fsa44yB6aBu1WC1q7Ig0-_QeGLkk7ZCCE_gX6_zU_ncwnL7Ot8JxeQFPBdsspZ3ZlK4hMyEmmOYHgnANFf48BOeuADuFjRogM-dXqpyTMWyQGVW6ShftOllU1ljsmWvBKPkbLuj4Afx4Fs3So15BOC4KQJsdyOsH_",
      "code": "AQBkIHzrU8B3Kd5qmmcXdea-iyF60OaPk0zK6oS40zv4q2-RD2H9SQr1KHiinx8fx_IxO2VNgF1WOZp_ahnq6pPoQ42MgL7i8-ou1jxgMJyzD7Gc64cPc17EK64FWHW8__ugxPTN-Cl_BMp00zBzc80M3PxVb67oPCW3KALp1rNollD2Z2JPQhlikaHr3Zzj8otGbhVSvZfTbUY4eA0Sh6lrwWj8UtXwGlSBszBufNlgjh6--g3PtkrR5g",
      "refresh_token": "AQDxl71M2uyxcKw-1j-oxKYpcnQvsKcRLra8i43aYJTqPgZkh5P4QgOiRZwIuiXKuUG3ebEomKtudJ_NDBw5_NXnwZk1seXqXSOIa5reZyZ3LTW5RG30WEA9KOOgi4DVQ8k",
      "id": "12166793664",
      "expiry": 1607203962
    },
    "events": {
      "75c6cfd0-139a-4a33-8826-9c284645f1ae": {
        "name": "Calgary Weekly List",
        "playlist": [
          [
            "spotify:track:5t9KYe0Fhd5cW6UYT4qP8f",
            2
          ],
          [
            "spotify:track:6As34Fmjj7dtReKB51NOVc",
            2
          ],
          [
            "spotify:track:4kK14radw0XfwxJDPt9tnP",
            1
          ],
          [
            "spotify:track:54WIS7qug0Gnt65eD9gg8g",
            1
          ],
          [
            "spotify:track:4G3DWijMhNkWZwLcxnDI0H",
            1
          ],
          [
            "spotify:track:0YedjUOqafibhe8htcD6Gz",
            1
          ],
          [
            "spotify:track:3HVRywtkhSjhpmkaeaYTgh",
            1
          ],
          [
            "spotify:track:3eCwKRKjGT0EIJe3FKOjIo",
            1
          ],
          [
            "spotify:track:03ITeFvMvTRpTC92WsQWw5",
            1
          ],
          [
            "spotify:track:2kXeAEpGBN874ZKJPV24fr",
            1
          ],
          [
            "spotify:track:1zXpHPdBAUxnOCQqFMFLk3",
            1
          ],
          [
            "spotify:track:5KCbr5ndeby4y4ggthdiAb",
            1
          ],
          [
            "spotify:track:5u1n1kITHCxxp8twBcZxWy",
            1
          ],
          [
            "spotify:track:1tkg4EHVoqnhR6iFEXb60y",
            1
          ],
          [
            "spotify:track:17jEoYoOfRD6dvNCMmC9n4",
            1
          ],
          [
            "spotify:track:2P0FH5jSRu8cctdYfTXtje",
            1
          ],
          [
            "spotify:track:3VXvKTOQoY0kWvpjU67uq2",
            1
          ],
          [
            "spotify:track:6S1IgeHxxOT9qVWnmsdGxe",
            1
          ],
          [
            "spotify:track:1yTTMcUhL7rtz08Dsgb7Qb",
            1
          ],
          [
            "spotify:track:3QpkbrYXtlU3LRJu3sTK6V",
            1
          ],
          [
            "spotify:track:6JqYhSdTE4WbQrMXxPH5cD",
            1
          ],
          [
            "spotify:track:7nDYw1nNAW4dAqgmW2W3tq",
            1
          ]
        ],
        "spotify_id": "1UxyXZ4YuKdbPHNkFYXpyZ"
      },
      "62854dc2-7d97-45d3-be03-f0bac69119f8": {
        "name": "Toronto Weekly List",
        "playlist": [
          [
            "spotify:track:2J4P46vCFm1rPkNkp9pZWX",
            1
          ],
          [
            "spotify:track:4wosxLl0mAqhneDzya2MfY",
            1
          ],
          [
            "spotify:track:45bE4HXI0AwGZXfZtMp8JR",
            1
          ]
        ],
        "spotify_id": "3Do3cXEkmdHao31jX0B1oo"
      },
      "fe71a1ee-6e64-4d4f-8a03-7b091d93c823": {
        "name": "Belgium Weekly List",
        "playlist": [],
        "spotify_id": "6vXyy0FUbzWgrPuNB9xY88"
      }
    }
  }
}

{
  "state": {
    "events": {
      "75c6cfd0-139a-4a33-8826-9c284645f1ae": {
        "name": "Calgary Weekly List"
      },
      "62854dc2-7d97-45d3-be03-f0bac69119f8": {
        "name": "Toronto Weekly List"
      },
      "fe71a1ee-6e64-4d4f-8a03-7b091d93c823": {
        "name": "Belgium Weekly List"
      }
    }
  }
}

#!/usr/bin/env bash
. $BIN_DIR/_lib.sh
node --experimental-modules --experimental-json-modules --es-module-specifier-resolution=node src/index.js

.git
*.log
node_modules
app/
nginx.conf

#!/usr/bin/env bash
. $BIN_DIR/_lib.sh
rsync --progress -Pavuz --exclude-from="$WORKING_BIN_DIR/rsync-deploy.ignore" -e "ssh -i $HOME/.ssh/id_rsa_corda_digital_ocean" "${MONO_DIR}/." "tpcowan@processor.djinmusic.ca:/home/tpcowan/djinmusic"
rsync --progress -Pavuz -e "ssh -i $HOME/.ssh/id_rsa_corda_digital_ocean" $WORKING_BIN_DIR/deploy-remote.sh "tpcowan@processor.djinmusic.ca:/home/tpcowan/deploy-remote.sh"
ssh -F $HOME/.ssh/id_rsa_corda_digital_ocean tpcowan@processor.djinmusic.ca "sh /home/tpcowan/deploy-remote.sh"

#!/usr/bin/env bash
if [[ "$(uname -s)" == "Darwin" ]]; then
  echo "Don't run this on your local computer!"
  exit 1
fi
echo "[remote] Updating processor"
cd djinmusic
pnpm install -r
cd ..
echo "[remote] Installed"

#!/bin/zsh
autoenv_source_parent
autostash WORKING_DIR=$(dirname ${0})
autostash WORKING_BIN_DIR="${WORKING_DIR}/.bin"
autostash alias start="${WORKING_BIN_DIR}/start.sh"

import crypto from "crypto"
class Session {
  constructor() {
    this.cleaner = setInterval(this.clean.bind(this), 1000 * 60 * 60)
    this.key = '2390fbad9157e1f8de9ecb5a494feeb988dfe2ba31c39ca1ba91ba2fa9d30d20'
  }
  clean() {
    const timeouts = datastore.read('/session/connections/+/tokens/+')
    _.forEach(timeouts, (timeout, path) => {
      if (+ new Date < timeout) { return }
      const pointer = new Pointer(path.replace('/timeout', ''))
      datastore.destroy(pointer.path)
    })
  }
  fetchSession(cookie, ws, channels) {
    console.log(`fetchSession\n\ntoken:\n${cookie}`)
    const response = {
      o: 'a',
      c: 5,
      v: false
    }
    // {
    //   tokens: ,
    //   topics: []
    // }
    const [user, token, mac] = cookie.split(':')
    const verify = crypto.createHmac(
      'sha256',
      user + ':' + token,
      this.key
    ).digest('hex')
    const session = datastore.read(`/session/connections/${user}`)
    if (!session) return
    if (crypto.timingSafeEqual(Buffer.from(verify, 'utf8'), Buffer.from(mac, 'utf8')) &&
        session && session.tokens) {
      _.find(session.tokens, (timestamp, stored_token) => {
        if (crypto.timingSafeEqual(Buffer.from(stored_token, 'utf8'), Buffer.from(token, 'utf8')) &&
            timestamp > + new Date) {
          response.v = { u: user, s: session.topics || [] }
        return true
        }
      })
    }
    _.forEach((session.topics || []), pattern => {
      console.log(pattern)
      const topic = new Topic(pattern)
      const channel = channels[topic.trunk[0]]
      channel.resume(topic, ws)
    })
    ws.send(JSON.stringify(response))
  }
  requestSession(user, ws, users) {
    if (!users.isAuthorized(new Topic(`state/users/${user}/#`), ws)) {
      return
    }
    const token = crypto.randomBytes(256).toString('hex')
    const cookie = user + ':' + token
    console.log(`postSession for ${user} \n\ntoken:\n${token}`)
    const mac = crypto.createHmac(
      'sha256',
      user + ':' + token,
      this.key
    ).digest('hex')
    console.log('L')
    console.log(mac)
    datastore.write(`/session/connections/${user}/tokens/${token}`, + new Date + 60 * 60 * 24 * 7 * 1000)
    const response = {
      o: 'a',
      c: 6,
      v: cookie + ':' + mac
    }
    ws.send(JSON.stringify(response))
  }
  addSubscription(user, topic) {
    console.log(`#addSubscription ${user}, ${topic.pattern}`)
    const topics = new Set(datastore.read(`/session/connections/${user}/topics`) || [])
    topics.add(topic.pattern)
    datastore.write(`/session/connections/${user}/topics`, Array.from(topics))
  }
  toString() {
    return 'Channel-Connections'
  }
}
const session = new Session()
export { session }

import WebSocket from 'ws'
import { v4 as uuid } from 'uuid'
import './models/item'
import './models/event'
import './models/user'
import './models/admin'
import './models/stash'
import './models/spotify'
import { events } from './channels/event.js'
import { users } from './channels/user.js'
import { items } from './channels/item.js'
import { admin } from './channels/admin.js'
import { session } from './session.js'
let main = () => {
  /* Models */
  const channels = {
    events: events,
    users: users,
    items: items,
    admin: admin
  }
  console.log(channels)
  /* IPC Sockets */
  const port = 25706
  const wss = new WebSocket.Server({ port })
  console.log(`Listenning on ${port}`)
  wss.on('connection', function connection(ws, request) {
    const ip = request.socket.remoteAddress
    ws.uuid = uuid()
    ws.toString = () => ws.uuid
    console.log(`Connection from ${ip}`)
    datastore.push('/session/connections', ip)
    const node_id = datastore.read('/session/node_id')
    const hello = {}
    hello.o = 'w'
    hello.v = node_id
    hello.p = '/session/node_id'
    ws.send(JSON.stringify(hello))
    const publish = (topic, pointer) => {
      const message = {}
      const { tree, path } = pointer
      const { value } = tree
      message.o = 'p'
      message.t = topic
      message.p = path
      message.v = value
      console.log(`sending: ${JSON.stringify(message)}`)
      ws.send(JSON.stringify(message))
    }
    ws.on('message', (message) => {
      console.log(message)
      message = JSON.parse(message)
      if (!message.o) {
        return
      }
      let pointer, topic, channel
      switch (message.o) {
        case 'a': {
          switch (message.c) {
            case 0: {
              // createAccount
              topic = new Topic(message.t)
              channel = channels[topic.trunk[0]]
              channel.createAuthorization(topic, message.v, ws)
            } break
            case 1: {
              // startSession
              topic = new Topic(message.t)
              channel = channels[topic.trunk[0]]
              channel.authorize(topic, message.v, ws)
            } break
            case 4: {
              // verifySession
              topic = new Topic(message.t)
              channel = channels[topic.trunk[0]]
              if (channel.prove(topic, message.v, ws)) {
                session.addSubscription(message.v.u, topic)
              }
            } break
            case 5: {
              // post session
              session.fetchSession(message.v, ws, channels)
            } break
            case 6: {
              // fetch session
              session.requestSession(message.v, ws, users)
            } break
            default:
              break
          }
        } break
        case 'm': {
          pointer = new Pointer(message.p)
          channel = channels[pointer.trunk[0]]
          channel.merge(pointer, message.v, ws)
        } break
        case 'w': {
          pointer = new Pointer(message.p)
          channel = channels[pointer.trunk[0]]
          channel.write(pointer, message.v, ws)
        } break
        case 'd': {
          pointer = new Pointer(message.p)
          channel = channels[pointer.trunk[0]]
          channel.delete(pointer, ws)
        } break
        case 's': {
          topic = new Topic(message.t)
          console.log({topic})
          channel = channels[topic.trunk[0]]
          channel.subscribe(topic, ws, publish)
          if (!message.i) { break }
          console.log('IMMEDIATE')
          message.p = `/${message.t}`
        }
        case 'r': {
          pointer = new Pointer(message.p)
          channel = channels[pointer.trunk[0]]
          _.forEach(channel.read(pointer, ws), (value, path) => {
            const response = { o: 'r' }
            response.p = path
            response.v = value
            ws.send(JSON.stringify(response))
          })
        } break
        case 'u': {
            topic = new Topic(message.t)
            channel = channels[topic.trunk[0]]
  
            channel.unsubscribe(topic, ws, publish)
  
            if (!message.i) break
        }
      }
    })
    ws.on('close', () => {
      datastore.pull('/session/connections', ip)
      _.forEach(channels, channel => {
        channel.unsubscribe(ws)
      })
      console.log('disconnected')
    })
  })
  const cleanup = () => {
    console.log('\rShutting down server') // eslint-disable-line no-console
    process.removeListener('SIGINT', cleanup)
    process.removeListener('SIGTERM', cleanup)
    wss.close(() => {
      datastore.destroy('')
      process.exit()
    })
  }
  process.on('SIGINT', cleanup)
  process.on('SIGTERM', cleanup)
}
// TODO: Figure out a better way to prevent jsdoctest from executing this.
if (!process.env.TEST) {
  main()
}

import { v4 as uuid } from 'uuid'
class User {
  constructor() {
    console.log(`${this.toString()} #constructor`)
    datastore.subscribe('q/state/users/+/#', this.onStateQueued.bind(this))
    datastore.subscribe('q/action/users/+/events/new', this.onEventCreate.bind(this))
    datastore.subscribe('q/setup/users/+/events/+/+', this.onEventSetup.bind(this))
  }
  toString() {
    return 'Model-Users'
  }
  onStateQueued(topic, event) {
    if (event.type !== '=') return
    const { pointer } = event
    const value = pointer?.tree?.value
    console.log(`${this.toString()} #onStateQueued: ${pointer.path}, ${JSON.stringify(value)}`)
    if (!value || event.type !== '=') { return }
    if (pointer.leaf == 'pin') {
      // FIXME: @thomascowan what purpose does this serve? 09/20/2021
      this.accept(pointer, value)
      pointer.leaf = 'srp'
      datastore.set(pointer.path, 'authenticated')
    } else if (pointer.steps[4] === 'events') {
      switch (pointer.leaf) {
        case 'vote': {
          // NOTE: if the leaf is 'vote', then transfer the vote to the event
          const event_id = datastore.read(`/state${pointer.trunk_path}/event_id`)
          console.log('event_id', pointer.branch_path, `/state${pointer.trunk_path}/event_id`, event_id)
    
          if (!event_id) { return }
    
          datastore.set(pointer, null, { silent: true })
          console.log(`Transfer vote to /q/state/${pointer.branch.slice(2,4).join('/')}${pointer.trunk_path}/${pointer.branch.slice(-2).join('/')}`)
    
          datastore.set(`/q/state/${pointer.branch.slice(2,4).join('/')}${pointer.trunk_path}/${pointer.branch.slice(-2).join('/')}`, value)
          datastore.set(pointer, null, { silent: true })
        } break
        case 'pin': {
          datastore.read(`/setup/${pointer.branch.slice(2,4).join('/')}/owner`)
        } break
      }
    } else {
      this.accept(pointer, value)
    }
  }
  // What are the basic actions that can be taken on an event? Assuming there are three levels
  // of permissions that are consistent across all event types.
  // (These event types can be elaborated and parse out by reading a 'type' leaf later)
  //   1. Owner
  //   2. Admin
  //      - add admin (action) v
  //      - change name (setup) v
  //      - splice
  //      - insert
  //      - blacklist (setup) v
  //      - whitelist (setup) v
  //      - ban user (setup) v
  //      - unban user (setup) v
  //      - change date (setup)
  //      - description (setup) v
  //   3. Participant
  //      - vote
  //
  // 'q/setup/users/+/events/+/+'
  onEventSetup(topic, event) {
    if (event.type !== '=') return
    const { pointer } = event
    switch(pointer.leaf) {
      // leafs that don't require validation
      case 'name':
      case 'description':
      case 'private': {
        if (this.permissionFor('admin', pointer.steps[3], pointer.steps[5])) {
          this.accept(event.pointer.sliceBranch(2), event.pointer.value)
        }
      } break
      // leafs that require some validation
      case 'pin': {
        this.accept(pointer, pointer.value)
      } break
      case 'time': {
        this.accept(pointer, pointer.value)
      } break
      case 'type': {
        if (!['recurring', 'one_time'].includes(pointer.value)) return
        this.accept(pointer, pointer.value)
      } break
      // special cases
      case 'blacklist': {
        if (this.permissionFor('admin', pointer.steps[3], pointer.steps[5])) {
          datastore.push(`/setup/events/${pointer.setps[5]}/blacklist`, pointer.value)
        }
      } break
      case 'whitelist': {
        if (this.permissionFor('admin', pointer.steps[3], pointer.steps[5])) {
          datastore.pull(`/setup/events/${pointer.setps[5]}/blacklist`, pointer.value)
        }
      } break
      case 'ban': {
        if (this.permissionFor('admin', pointer.steps[3], pointer.steps[5])) {
          const admins = datastore.read(`/setup/events/${pointer.steps[5]}/admin`)
          if (admins.includes(event.pointer.value)) {
            if (this.permissionFor('user', pointer.steps[3], pointer.steps[5])) {
              datastore.pull(`/setup/events/${pointer.setps[5]}/admin`, pointer.value)
              datastore.push(`/setup/events/${pointer.setps[5]}/banned`, pointer.value)
            }
          } else {
            datastore.pull(`/setup/events/${pointer.setps[5]}/banned`, pointer.value)
          }
        }
      } break
      case 'unban': {
        if (this.permissionFor('admin', pointer.steps[3], pointer.steps[5])) {
          datastore.pull(`/setup/events/${pointer.setps[5]}/banned`, pointer.value)
        }
      } break
    }
  }
  permissionFor(level, user, event) {
    if (level === 'owner') {
      return datastore.read(`/setup/events/${event}/owner`) === user
    } else if (level === 'admin') {
      (datastore.read(`/setup/events/${event}/admin`) || []).includes(user)
    } else {
      (datastore.read(`/setup/events/${event}/users`) || []).includes(user)
    }
  }
  onEventCreate(topic, event) {
    if (event.type !== '=') return
    const { pointer } = event
    const value = pointer?.tree?.value
    if (!value) return
    // NOTE: check the account type and the number of owned events
    // TODO: @thomascowan add support for accoun types
    const account_type = datastore.read(`/setup${pointer.trunk_path}/type`) || 'free'
    const owned = datastore.read(`/setup${pointer.trunk_path}/events/owned`) || []
    // NOTE: check that the user meets the criteria required to create a new event
    switch (account_type) {
      case 'business': {
        // NOTE: Placeholder do nothing for now
      } break
      case 'basic': {
        if (owned.length >= 5) return
      } break
      case 'free': {
        if (owned.length >= 3) return
      }
    }
    // NOTE: create an event with the user_id
    const user_id = pointer.steps[3] 
    const new_event_id = uuid()
    datastore.write(`/setup/events/${new_event_id}/private`, true)
    datastore.write(`/setup/events/${new_event_id}/owner`, user_id)
    datastore.write(`/setup/events/${new_event_id}/admin`, [user_id])
    datastore.write(`/setup/events/${new_event_id}/users`, [user_id])
  }
  onEventPin(topic, event) {
    if (event.type !== '=') {
      return
    }
    const { pointer } = event
    const value = pointer?.tree?.value
    if (!this.validatePin(value)) {
      return
    }
    const owners = datastore.read(`/state/${pointer.branch.slice(2,4).join('/')}/owners`)
    const user_id = pointer.steps[3] 
    if (!owners.includes(user_id)) {
      return
    }
    datastore.write(`/state${pointer.branch.slice(2,4).join('/')}/pin`, value)
  }
  validatePin(pin) {
    /\d{4}/.test(pin) // FIXME: @thomascowan Improve available logic for pins
  }
  accept(pointer, value, { force = false } = {}) {
    datastore.set(pointer.path, null, { silent: true })
    const dequeued_pointer = pointer.dequeue()
    datastore.set(dequeued_pointer.path, value, { force })
  }
  destroy() {}
}
const users = new User()
const cleanup = () => {users.destroy()}
process.on('SIGINT', cleanup)
process.on('SIGTERM', cleanup)
export { users }

import fs from 'fs'
class Stash {
  constructor() {
    console.log(`${this.toString()} #constructor`)
    setInterval(this.stash.bind(this), 5000)
  }
  toString() {
    return 'Model-Stash'
  }
  stash() {
    console.log(`${this.toString()} #stash`)
    const tree = {}
    const state = datastore.read('/state')
    const setup = datastore.read('/setup')
    if (state) Object.assign(tree, { state })
    if (setup) Object.assign(tree, { setup })
    fs.writeFile(
      './.stash.json',
      JSON.stringify(tree, null, 2),
      (error) => {
        if (!error) return
        console.log("Error Writing to Stash")
        console.log(error)
      }
    )
  }
  destroy() {
    clearInterval(this.interval)
  }
}
const stash = new Stash()
const cleanup = () => {stash.destroy()}
process.on('SIGINT', cleanup)
process.on('SIGTERM', cleanup)
export { stash }

import https from 'https'
class Driver {
  constructor() {
    datastore.subscribe('action/events/+/start', this.initializePlaylist.bind(this))
    this.debouncePushPlaylistDetails = _.debounce(this.pushPlaylistDetails, 1000)
    datastore.subscribe('action/events/+/name', this.debouncePushPlaylistDetails.bind(this))
    datastore.subscribe('action/events/+/description', this.debouncePushPlaylistDetails.bind(this))
    datastore.subscribe('q/state/events/+/playlist', this.onPlaylistItemsQueued.bind(this))
  }
  toString() {
    return 'Driver-Spotify-Database'
  }
  token() {
    return datastore.read('/setup/admin/token')
  }
  initializePlaylist(topic, event) {
    const { pointer } = event
    console.log(`#initialize_playlist ${pointer.path}`)
    const eventId = pointer.branch.slice(-1)[0]
    const name = eventId
    const admin_id = datastore.read("/setup/admin/id")
    const body = {
      name,
      public: true,
      collaborative: false
    }
    const request = https.request({
        method: 'POST',
        hostname: 'api.spotify.com',
        path: `/v1/users/${admin_id}/playlists`,
        headers: {
          'Authorization': `Bearer ${this.token()}`,
          'Content-Type': 'application/json'
        }
      },
      response => {
        console.log(response.statusCode)
        if (![200, 201].includes(response.statusCode)) { return }
        let body = ''
        response.on('data', chunk => {
          console.log(body)
          body += chunk.toString()
        })
        response.on('end', () => {
          this.decodeInitializePlaylist(JSON.parse(body))
        })
      })
    request.on('error', e => {
      console.error(`problem with request ${e.message}`)
    })
    request.write(JSON.stringify(body))
    request.end()
  }
  decodeInitializePlaylist(response) {
    console.log(`#decodeInitializePlaylist`)
    console.log(response)
    const control_id = response['id']
    const djin_id = response['name']
    const externalUrl = response['external_urls']['spotify']
    const branch_path = `/events/${djin_id}`
    datastore.write(`/setup${branch_path}/spotify_id`, control_id)
    this.updateInitializedPlaylist(branch_path)
  }
  updateInitializedPlaylist(branch_path) {
    const name = datastore.read(`/setup${branch_path}/name`)
    const description = datastore.read(`/setup${branch_path}/description`)
    const options = {
      name,
      description: description + `\nCreated with Djinlist (www.djinlist.ca).`
    }
    this.changePlaylistDetails(branch_path, options, branch_path => {
      datastore.write(`/setup${branch_path}/initialized`, true)
    })
  }
  onPushPlaylistDetails(topic, event) {
    if (event.type !== '=') return
    const { pointer } = event
    const value = pointer?.tree?.value
    datastore.write(`/setup${pointer.branch_path}/details_synced`, false)
    this.debouncePushPlaylistDetails(value, pointer)
  }
  pushPlaylistDetails(value, pointer) {
    if (event.type !== '=') return
    const name = datastore.read(`/setup${pointer.branch_path}/name`)
    const description = datastore.read(`/setup${pointer.branch_path}/description`)
    const options = {}
    if (name) { Object.assign(options, { name }) }
    if (description) { Object.assign(options, { description }) }
    this.changePlaylistDetails(pointer.branch_path, options, branch_path => {
      datastore.write(`/setup${branch_path}/details_synced`, true)
    })
  }
  changePlaylistDetails(branch_path, options, callback) {
    const spotify_id = datastore.read(`/setup${branch_path}/spotify_id`)
    console.log(`#changePlaylistDetails ${branch_path}, ${spotify_id}`)
    console.log('options:', options)
    const request = https.request({
        method: 'PUT',
        hostname: 'api.spotify.com',
        path: `/v1/playlists/${spotify_id}`,
        headers: {
          'Authorization': `Bearer ${this.token()}`,
          'Content-Type': 'application/json'
        }
      },
      response => {
        response.on('end', () => callback(branch_path))
      })
    request.on('error', e => {
      console.error(`problem with request ${e.message}`)
    })
    request.write(JSON.stringify(options))
    request.end()
  }
  onTokenExpiry(topic, event) {
    if (event.type !== '=') return
    
    const { pointer } = event
    const value = pointer?.tree?.value
    const time = value - (+ new Date())
    console.log('#onTokenExpiry #{time}')
    if (this.refreshTokenInterval) {
      clearInterval(this.refreshTokenInterval)
    }
    if (time > 0) {
      this.refreshTokenInterval = setInterval(
        this.refreshToken.bind(this), time * 1000
      )
    } else {
      this.refreshToken()
    }
  }
  refreshToken() {
    const refreshToken = datastore.read(`/setup/admin/refresh_id`)
    console.log(`#refreshToken ${refresh_id}`)
    if (!refreshToken) { return }
    const body = {
      grant_type: 'refresh_token',
      refresh_token: refreshToken
    }
    request = https.request({
        method: 'POST',
        hostname: 'accounts.spotify.com',
        path: '/api/token',
        headers: {
          'Authorization': `Basic ZmUwMDk5M2ZmOTNlNDgyNzgwNGFmMTZlMWRlMzEyZGU6ODQ1NzQzNzhkMDg2NDQwZGI2MDczNmRiN2MxNzc1Mzg=`,
          'Content-Type': 'application/json'
        }
      },
      response => {
        if (![200, 201].includes(response.statusCode)) { return }
        let body = ''
        response.on('data', chunk => {
          body += chunk.toString()
        })
        response.on('end', () => {
          this.decodeTokenRefresh(JSON.parse(body))
        })
      })
    request.on('error', e => {
      console.log(`problem with request ${e.message}`)
    })
    request.write(JSON.stringify(body))
    request.end()
  }
  decodeRefreshToken(message) {
    console.log(`#decodeRefreshToken ${JSON.stringify(message)}`)
    const new_expiry = (+ new Date()) + message.expires_in
    datastore.write('/setup/admin/token', message.access_token)
    datastore.write('/setup/admin/expiry', new_expiry)
  }
  onPlaylistItemsQueued(value, pointer) {
    if (!value) return
    console.log(`#onPlaylistItemsQueued ${value.length}`)
    const spotify_id = datastore.read(`/setup${pointer.branch_path}/spotify_id`)
    // const length = datastore.read(`/setup${pointer.branch_path}/spotify_id`)
    const request = https.request({
      method: 'PUT',
      hostname: 'api.spotify.com',
      path: `/v1/playlists/${spotify_id}/tracks`,
      headers: {
        'Authorization': `Bearer ${this.token()}`,
        'Content-Type': 'application/json'
      }
    })
    request.on('error', e => {
      console.log(`problem with request ${e.message}`)
    })
    const tracks = _.reduce(value || [], (acc, track) => {
      return _.concat(acc, [track[0]])
    }, [])
    request.write(JSON.stringify({uris: tracks}))
    request.end()
  }
  destroy() {}
}
const spotify = new Driver
const cleanup = () => {spotify.destroy()}
process.on('SIGINT', cleanup)
process.on('SIGTERM', cleanup)
export { spotify }

class Item {
  constructor() {
    console.log(`${this.toString()} #constructor`)
    datastore.subscribe('q/state/items/+/#', this.onStateQueued.bind(this))
  }
  toString() {
    return 'Model-Items'
  }
  onStateQueued(topic, event) {
    if (event.type !== '=') return
    const { pointer } = event
    const value = pointer?.tree?.value
    console.log(`${this.toString()} #onStateQueued: ${pointer.path}, ${JSON.stringify(value)}`)
    this.accept(pointer, value)
  }
  accept(pointer, value, { force = false } = {}) {
    datastore.set(pointer, null, { silent: true })
    const dequeued_pointer = pointer.dequeue()
    datastore.set(dequeued_pointer.path, value, { force })
  }
  destroy() {}
}
const items = new Item()
const cleanup = () => {items.destroy()}
process.on('SIGINT', cleanup)
process.on('SIGTERM', cleanup)
export { items }

class Event {
  constructor() {
    console.log(`${this.toString()} #constructor`)
    datastore.subscribe('q/state/events/+/#', this.onStateQueued.bind(this))
    datastore.subscribe('q/setup/events/+/#', this.onSetupQueued.bind(this))
    this.ticker = setInterval(this.publishPlaylists.bind(this), 60 * 1000)
  }
  toString() {
    return 'Model-Events'
  }
  onStateQueued(topic, event) {
    if (event.type !== '=') return
    const { pointer } = event
    const value = pointer?.tree?.value
    console.log(`${this.toString()} #onStateQueued: ${pointer.path}, ${JSON.stringify(value)}`)
    switch (pointer.branch_path.length) {
      case 4:
        if (pointer.branch_steps[2] == 'users') {
          this.onUserQueued(topic, pointer, value)
        }
        break
      default:
        this.accept(pointer, value)
        break
    }
  }
  onSetupQueued(topic, event) {
    if (event.type !== '=') return
    const { pointer } = event
    const value = pointer?.tree?.value
    console.log(`${this.toString()} #onSetupQueued: ${pointer.path}, ${JSON.stringify(value)}`)
    this.accept(pointer, value)
  }
  onUserQueued(topic, event) {
    if (event.type !== '=') return
    const { pointer } = event
    const value = pointer?.tree?.value
    switch (pointer.leaf) {
      case 'vote':
        this.accept(pointer, value)
    }
  }
  publishPlaylist(name, pointer) {
    const issueAt = datastore.read(pointer.path + '/issue_at')
    const currentTime = + new Date()
    console.log(`#publishPlaylist ${name} ${issueAt && (issueAt < currentTime)}`)
    if (
      !issueAt  // &&
      // currentTime.getDay() == 5 ||
      // currentTime.getHours() == 20 ||
      // currentTime.getMinutes() == 0
    ) {
      this.issuePlaylist(name, pointer)
    } else if (issueAt < currentTime) {
      this.issuePlaylist(name, pointer)
      // Determine the next time we need to update the playlist
      const intervalDays = datastore.read(pointer.path + '/interval')
      const intervalSeconds = intervalDays * 24 * 60 * 60
      datastore.write(pointer.path + '/issue_at', issueAt + intervalSeconds)
    }
  }
  publishPlaylists() {
    const playlists = datastore.read('/setup/events/+/name')
    console.log(`#publishPlaylists`, playlists)
    _.forEach(playlists, (playlist, path) => {
      const pointer = new Pointer(path)
      this.publishPlaylist(playlist, pointer.slice(0, -1))
    })
  }
  tally(pointer) {
    const items = datastore.read(`/state${pointer.trunk_path}/users/+/items/+/vote`)
    const length = datastore.read(`/state${pointer.trunk_path}/users/+/items/+/vote`)
    const tally = {}
    _.forEach(items, (value, path) => {
      const id = path.split('/').slice(-2, -1)[0]
      if (tally[id]) {
        tally[id] += 1
      } else {
        tally[id] = 1
      }
    })
    const sorted_list = _.reverse(_.sortBy(_.entries(tally), entry => entry[1]))
    const current_list = datastore.read(`/state${pointer.trunk_path}/playlist`)
    let match = true
    if (current_list) {
      for (var idx in current_list) {
        if (current_list[idx] != sorted_list[idx]) { match = false }
      }
    } else {
      match = false
    }
    if (match) return
    datastore.write(`/q/state${pointer.trunk_path}/playlist`, sorted_list)
  }
  issuePlaylist(name, pointer) {
    console.log(`#issuePlaylist ${name} at ${pointer.path}`)
    const exists = datastore.read(`/setup${pointer.trunk_path}/spotify_id`)
    if (exists) {
      this.tally(pointer)
    } else {
      datastore.write(`/action${pointer.trunk_path}/start`, +new Date())
    }
  }
  accept(pointer, value, { force = false } = {}) {
    datastore.set(pointer, null, { silent: true })
    const dequeued_pointer = pointer.dequeue()
    datastore.set(dequeued_pointer.path, value, { force })
  }
  destroy() {
    console.log(`${this.toString()} #destroy`)
    clearInterval(this.ticker)
  }
}
const events = new Event()
const cleanup = () => {events.destroy()}
process.on('SIGINT', cleanup)
process.on('SIGTERM', cleanup)
export { events }

class Admin {
  constructor() {
    console.log(`${this.toString()} #constructor`)
    datastore.subscribe('q/setup/admin/#', this.onSetupQueued.bind(this))
  }
  toString() {
    return 'Model-Admin'
  }
  onSetupQueued(topic, event) {
    if (event.type !== '=') return
    const { pointer } = event
    const value = pointer?.tree?.value
    console.log(`${this.toString()} #onSetupQueued: ${pointer.path}, ${JSON.stringify(value)}`)
    this.accept(pointer, value)
  }
  accept(pointer, value, { force = false } = {}) {
    datastore.set(pointer, null, { silent: true })
    const dequeued_pointer = pointer.dequeue()
    datastore.set(dequeued_pointer.path, value, { force })
  }
  destroy() {}
}
const admin = new Admin()
const cleanup = () => {admin.destroy()}
process.on('SIGINT', cleanup)
process.on('SIGTERM', cleanup)
export { admin }

import _ from 'lodash'
if (!global._) global._ = _
import { Datastore, Pointer, Topic } from '@controlenvy/datastore'
if (!global.datastore) global.datastore = new Datastore()
if (!global.Pointer) global.Pointer = Pointer
if (!global.Topic) global.Topic = Topic
import fs from 'fs'
const loadConfig = async () => {
  // configuration information goes here
  datastore.set('/session/node_id', '952ede89-4c91-4df7-bdab-c6dda4257abb')
  let filePath
  fs.access('.stash.json', fs.constants.F_OK, (err) => {
    filePath = `.${err ? 'preconfig' : 'stash'}.json`
  })
  const onFileFound = (file, data) => {
    if (!data) { return false }
    const _root = JSON.parse(data)
    if (Object.keys(_root).length === 0) { return false }
    console.log(`index.js Parsing root found at ${file}`)
    datastore.merge('/state', _root.state)
    datastore.merge('/setup', _root.setup)
    main()
    return true
  }
  ['.stash.json', '.preconfig.json'].find(filePath => {
    try {
      return onFileFound(filePath, fs.readFileSync(filePath))
    } catch (e) {
      console.log(`Error reading config at ${filePath}`)
      console.log(e)
      return false
    }
  })
}
const main = () => {
  import('./server')
}
loadConfig()

import { Base } from './base.js'
class User extends Base {
  constructor() {
    super()
    datastore.subscribe('state/users/+/#', this.publish.bind(this))
    this.blacklist(new Topic('state/users/+/auth/#'))
    this.blacklist(new Topic('state/users/+/auth/*'))
  }
  toString() {
    return 'Channel-Users'
  }
}
const users = new User()
export { users }

class TopicTree {
  constructor() {
    Object.defineProperties(this, {
      _root: {
        value: this.createTreeNode()
      }
    })
  }
  createTreeNode() {
    const node = Object.create(null)
    Object.defineProperties(node, {
      _value: {
        writable: true
      }
    })
    return node
  }
  // expensive, call rarely
  all(func = null, output = [], node = this._root) {
    if (node._topic && node._value && (!func || func(node))) {
      output.push([node._topic, node._value])
    }
    _.forEach(node, (child, key) => {
      if (!['_value', '_topic'].includes(key)) {
        this.all(func, output, child)
      }
    })
    return output
  }
  apply(func, node = this._root) {
    func(node)
    return _.forEach(node, (child, key) => {
      if (!['_value', '_topic'].includes(key)) {
        this.apply(func, child)
      }
    })
  }
  get(topic) {
    const steps = topic.split('/')
    let left = this._root
    for (const step of steps) {
      left = left[step]
      if (left == null) {
        left = this.createTreeNode()
        break
      }
    }
    return left
  }
  getWithDefault(topic, value) {
    const steps = topic.split('/')
    let node = this._root
    for (const step of steps) {
      if (node[step] == null) {
        node[step] = this.createTreeNode()
      }
      node = node[step]
    }
    if (node._value == null) {
      node._topic = topic
      node._value = value
    }
    return node
  }
  add(topic, value) {
    const node = this.getWithDefault(topic)
    node._topic = topic
    node._value = value
  }
  values(topic) {
    const steps = topic.split('/')
    return this._values(this._root, steps, 0, []).reverse()
  }
  _values(node, steps, pivot, values) {
    if (steps.length == pivot) {
      if (node._value != null) {
        values.push(node._value)
      }
      return values
    }
    const step = steps[pivot]
    if (node['#'] != null) {
      values.push(node['#']._value)
    }
    if (node['+'] != null) {
      values = this._values(node['+'], steps, pivot + 1, values)
    }
    if (node[step] != null) {
      values = this._values(node[step], steps, pivot + 1, values)
    }
    return values
  }
  entries(topic) {
    const steps = topic.split('/')
    return this._entries(this._root, steps, 0, []).reverse()
  }
  _entries(node, steps, pivot, entries) {
    if (steps.length == pivot) {
      if (node._value != null) {
        entries.push([node._topic, node._value])
      }
      if (node['*'] != null) {
        entries.push([node['*']._topic, node['*']._value])
      }
      return entries
    }
    const step = steps[pivot]
    if (node['#'] != null) {
      entries.push([node['#']._topic, node['#']._value])
    }
    if (node['+'] != null) {
      entries = this._entries(node['+'], steps, pivot + 1, entries)
    }
    if (node[step] != null) {
      entries = this._entries(node[step], steps, pivot + 1, entries)
    }
    return entries
  }
}
export { TopicTree }