serverfunctions.liq

#
# Aura Engine (https://gitlab.servus.at/aura/engine)
#
# Copyright (C) 2017-2020 - The Aura Engine Team.
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU Affero General Public License for more details.
#
# You should have received a copy of the GNU Affero General Public License
# along with this program.  If not, see <http://www.gnu.org/licenses/>.

#
# Namespace: aura_engine
#

# Get state of the inputs/outputs as JSON
server.register(
  namespace="aura_engine",
  description=
    "Get status info (uptime and fallback state)",
  usage="status",
  "status",
  fun (s) ->
    begin
      ignore(s)
      uptime = list.nth(server.execute("uptime"), 0)
      json_data = json()
      json_data.add("uptime", uptime)
      json_data.add("is_fallback", engine_state.is_fallback())
      json.stringify(json_data)
    end
)

# Updates engine config
server.register(
  namespace="aura_engine",
  description=
    "Update the engine configuration",
  usage=
    "update_config { \"fallback_show_id\": \"-1\", \"fallback_show_name\": \
     \"Station Fallback\" }",
  "update_config",
  fun (s) ->
    begin
      log(
        "Received JSON to update config: #{s}"
      )
      let json.parse (data :
        {fallback_show_id: int, fallback_show_name: string}
      ) = s

      fallback_show_id := "#{data.fallback_show_id}"
      log(
        "Set Fallback Show ID to '#{fallback_show_id()}'"
      )
      fallback_show_name := data.fallback_show_name
      log(
        "Set Fallback Show Name to '#{fallback_show_name()}'"
      )
      "OK"
    end
)

# Get version
server.register(
  namespace="aura_engine",
  description=
    "Return the version of Engine Core and Liquidsoap",
  usage="version",
  "version",
  fun (s) ->
    begin
      ignore(s)
      json_data = json()
      json_data.add("core", engine_version)
      json_data.add("liquidsoap", liquidsoap.version)
      json.stringify(json_data)
    end
)

# Shutdown server
server.register(
  namespace="aura_engine",
  description=
    "Shutdown play-out server",
  usage="stop",
  "stop",
  fun (s) ->
    begin
      ignore(s)
      shutdown(code=0)
      "OK"
    end
)

#
# Namespace: mixer
#

# Get connection state of outgoing streams #TODO refactor
server.register(
  namespace="mixer",
  description=
    "Return all active outputs",
  usage="outputs",
  "outputs",
  fun (s) ->
    begin
      ignore(s)
      log(
        "executing: mixer.outputs"
      )

      so = []
      so =
        s0_enable
        ? list.add(("out_line_0", ("connected", "#{s0_connected()}")), so) : so
      # so =
      #   s1_enable
      #   ? list.add(("out_line_1", ("connected", "#{s1_connected()}")), so) : so
      # so =
      #   s2_enable
      #   ? list.add(("out_line_2", ("connected", "#{s2_connected()}")), so) : so
      # so =
      #   s3_enable
      #   ? list.add(("out_line_3", ("connected", "#{s3_connected()}")), so) : so
      # so =
      #   s4_enable
      #   ? list.add(("out_line_4", ("connected", "#{s4_connected()}")), so) : so

      lo = []
      lo = a0_out != '' ? list.add("out_line_0", lo) : lo
      lo = a1_out != '' ? list.add("out_line_1", lo) : lo
      lo = a2_out != '' ? list.add("out_line_2", lo) : lo
      lo = a3_out != '' ? list.add("out_line_3", lo) : lo
      lo = a4_out != '' ? list.add("out_line_4", lo) : lo

      json_data = json()
      json_data.add("line", lo)
      json_data.add("stream", so)
      json.stringify(json_data)
    end
)

# Activate a source by selecting it and setting the volume to 100 (or vice versa)
server.register(
  namespace="mixer",
  description=
    "Select a source and set the volume to 100",
  usage=
    "activate <source number> <true|false>",
  "activate",
  fun (p) ->
    begin
      params =
        string.split(
          separator=
            " ",
          p
        )
      if
        list.length(params) < 2
      then
        print(p)
        "Usage: mixer.activate <source nb> <true|false>"
      else
        source_number = list.nth(default="0", params, 0)
        source_enable = list.nth(default="false", params, 1)

        if
          source_enable == "true"
        then
          r =
            server.execute(
              "mixer.select #{source_number} true"
            )
          print(r)
          r =
            server.execute(
              "mixer.volume #{source_number} 1"
            )
          print(r)
        else
          r =
            server.execute(
              "mixer.volume #{source_number} 0"
            )
          print(r)
          r =
            server.execute(
              "mixer.select #{source_number} false"
            )
          print(r)
        end
        "OK"
      end
    end
)

#
# Namespace: misc #TODO: refactor
#

def fadeTo(source_number) =
  if
    source_number == ""
  then
    print(source_number)
    "Usage: mixer.fadeto <source nb> #{source_number}"
  else
    r =
      server.execute(
        "mixer.select #{source_number} true"
      )
    print(r)
    "OK"
  end
end

# enable fadeTo for the mixer
server.register(
  namespace="mixer",
  description=
    "is fading from one mixer input to another",
  usage=
    "fadeto <source number>",
  "fadeto",
  fadeTo
)

def icy_update(v) =
  # Parse the argument
  l = string.split(separator=",", v)
  def split(l, v) =
    v = string.split(separator="=", v)
    if
      list.length(v) >= 2
    then
      list.append(l, [(list.nth(v, 0, default=""), list.nth(v, 1, default=""))])
    else
      l
    end
  end
  meta = list.fold(split, [], l)

  # Update metadata
  if
    s0_enable == true
  then
    icy.update_metadata(
      mount=s0_mount,
      user=s0_user,
      password=s0_pass,
      host=s0_host,
      port=s0_port,
      meta
    )
  end

  #   if
  #     s1_enable == true
  #   then
  #     icy.update_metadata(
  #       mount=s1_mount,
  #       user=s1_user,
  #       password=s1_pass,
  #       host=s1_host,
  #       port=s1_port,
  #       meta
  #     )
  #   end

  #   if
  #     s2_enable == true
  #   then
  #     icy.update_metadata(
  #       mount=s2_mount,
  #       user=s2_user,
  #       password=s2_pass,
  #       host=s2_host,
  #       port=s2_port,
  #       meta
  #     )
  #   end

  #   if
  #     s3_enable == true
  #   then
  #     icy.update_metadata(
  #       mount=s3_mount,
  #       user=s3_user,
  #       password=s3_pass,
  #       host=s3_host,
  #       port=s3_port,
  #       meta
  #     )
  #   end

  #   if
  #     s4_enable == true
  #   then
  #     icy.update_metadata(
  #       mount=s4_mount,
  #       user=s4_user,
  #       password=s4_pass,
  #       host=s4_host,
  #       port=s4_port,
  #       meta
  #     )
  #   end

  "OK"
end

server.register(
  "update",
  namespace="metadata",
  description=
    "Update metadata",
  usage=
    "update title=foo,album=bar, ...",
  icy_update
)