packaging.in/murphy.lua

   1 with_system_controller = false
   2 with_amb = false
   3 verbose = 0
   4
   5 m = murphy.get()
   6
   7 -- try loading the various logging plugins
   8 m:try_load_plugin('systemd')
   9 m:try_load_plugin('dlog')
  10
  11 -- load the console plugin
  12 m:try_load_plugin('console')
  13
  14 m:try_load_plugin('console.disabled', 'webconsole', {
  15                   address = 'wsck:127.0.0.1:3000/murphy',
  16                   httpdir = '/usr/share/murphy/webconsole' });
  17
  18 -- load the dbus plugin
  19 if m:plugin_exists('dbus') then
  20     m:load_plugin('dbus')
  21 end
  22
  23 -- load the native resource plugin
  24 if m:plugin_exists('resource-native') then
  25     m:load_plugin('resource-native')
  26     m:info("native resource plugin loaded")
  27 else
  28     m:info("No native resource plugin found...")
  29 end
  30
  31 -- load the dbus resource plugin
  32 m:try_load_plugin('resource-dbus', {
  33     dbus_bus = "system",
  34     dbus_service = "org.Murphy",
  35     dbus_track = true,
  36     default_zone = "driver",
  37     default_class = "implicit"
  38 })
  39
  40 -- load the domain control plugin
  41 if m:plugin_exists('domain-control') then
  42     m:load_plugin('domain-control')
  43 else
  44     m:info("No domain-control plugin found...")
  45 end
  46
  47 if m:plugin_exists('glib') then
  48     m:load_plugin('glib')
  49 else
  50     m:info("No glib plugin found...")
  51 end
  52
  53 -- load the AMB plugin
  54 if m:plugin_exists('amb') then
  55     m:try_load_plugin('amb')
  56
  57     if builtin.method.amb_initiate and
  58        builtin.method.amb_update
  59     then
  60         with_amb = true
  61     end
  62 else
  63     m:info("No amb plugin found...")
  64 end
  65
  66 -- load the ASM resource plugin
  67 if m:plugin_exists('resource-asm') then
  68     m:try_load_plugin('resource-asm', {
  69         zone = "driver",
  70         share_mmplayer = "player:AVP,mandatory,exclusive,strict",
  71         ignored_argv0 = "WebProcess"
  72     })
  73 else
  74     m:info("No audio session manager plugin found...")
  75 end
  76
  77 if m:plugin_exists('system-controller') then
  78     with_system_controller = true
  79 elseif m:plugin_exists('ivi-resource-manager') then
  80     m:load_plugin('ivi-resource-manager')
  81     with_system_controller = false
  82 end
  83
  84 -- define application classes
  85 application_class {
  86     name     = "interrupt",
  87     priority = 99,
  88     modal    = true ,
  89     share    = false,
  90     order    = "fifo"
  91 }
  92
  93 application_class {
  94     name     = "emergency",
  95     priority = 80,
  96     modal    = false,
  97     share    = false,
  98     order    = "fifo"
  99 }
 100 application_class {
 101     name     = "system",
 102     priority = 52,
 103     modal    = false,
 104     share    = true,
 105     order    = "lifo"
 106 }
 107 application_class {
 108     name     = "alert",
 109     priority = 51,
 110     modal    = false,
 111     share    = false,
 112     order    = "fifo"
 113 }
 114
 115 application_class {
 116     name     = "navigator",
 117     priority = 50,
 118     modal    = false,
 119     share    = true,
 120     order    = "fifo"
 121 }
 122
 123 application_class {
 124     name     = "phone",
 125     priority = 6 ,
 126     modal    = false,
 127     share    = true ,
 128     order    = "lifo"
 129 }
 130 application_class {
 131     name     = "camera",
 132     priority = 5,
 133     modal    = false,
 134     share    = false,
 135     order    = "lifo"
 136 }
 137
 138 application_class { name="event"    , priority=4 , modal=false, share=true , order="fifo" }
 139 application_class { name="game"     , priority=3 , modal=false, share=false, order="lifo" }
 140 --# doesn't need to be created here, ivi-resource-manager creates it if loaded
 141 --#application_class { name="basic"    , priority=2 , modal=false, share=false, order="lifo" }
 142 application_class { name="player"   , priority=1 , modal=false, share=true , order="lifo" }
 143 application_class { name="implicit" , priority=0 , modal=false, share=false, order="lifo" }
 144
 145 -- define zone attributes
 146 zone.attributes {
 147     type = {mdb.string, "common", "rw"},
 148     location = {mdb.string, "anywhere", "rw"}
 149 }
 150
 151 -- define zones
 152 zone {
 153      name = "driver",
 154      attributes = {
 155          type = "common",
 156          location = "front-left"
 157      }
 158 }
 159
 160 zone {
 161      name = "passanger1",
 162      attributes = {
 163          type = "private",
 164          location = "front-right"
 165      }
 166 }
 167
 168 zone {
 169      name = "passanger2",
 170      attributes = {
 171          type = "private",
 172          location = "back-left"
 173      }
 174 }
 175
 176 zone {
 177      name = "passanger3",
 178      attributes = {
 179          type = "private",
 180          location = "back-right"
 181      }
 182 }
 183
 184 zone {
 185      name = "passanger4",
 186      attributes = {
 187          type = "private",
 188          location = "back-left"
 189      }
 190 }
 191
 192
 193 -- define resource classes
 194 if not m:plugin_exists('ivi-resource-manager') and
 195    not with_system_controller
 196 then
 197    resource.class {
 198         name = "audio_playback",
 199         shareable = true,
 200         attributes = {
 201             role = { mdb.string, "music", "rw" },
 202             pid = { mdb.string, "<unknown>", "rw" },
 203             policy = { mdb.string, "relaxed", "rw" }
 204         }
 205    }
 206 end
 207
 208 resource.class {
 209      name = "audio_recording",
 210      shareable = true,
 211      attributes = {
 212          role   = { mdb.string, "music"    , "rw" },
 213          pid    = { mdb.string, "<unknown>", "rw" },
 214          policy = { mdb.string, "relaxed"  , "rw" }
 215      }
 216 }
 217
 218 resource.class {
 219      name = "video_playback",
 220      shareable = false,
 221 }
 222
 223 resource.class {
 224      name = "video_recording",
 225      shareable = false
 226 }
 227
 228 resource.class {
 229      name = "speech_recognition",
 230      shareable = true
 231 }
 232
 233 resource.class {
 234      name = "speech_synthesis",
 235      shareable = true
 236 }
 237
 238 if not m:plugin_exists('ivi-resource-manager') and
 239    not with_system_controller
 240 then
 241     resource.method.veto = {
 242         function(zone, rset, grant, owners, req_set)
 243             return true
 244          end
 245     }
 246 end
 247
 248 -- test for creating selections
 249 mdb.select {
 250            name = "audio_owner",
 251            table = "audio_playback_owner",
 252            columns = {"application_class"},
 253            condition = "zone_name = 'driver'"
 254 }
 255
 256 mdb.select {
 257            name = "vehicle_speed",
 258            table = "amb_vehicle_speed",
 259            columns = {"value"},
 260            condition = "key = 'VehicleSpeed'"
 261 }
 262
 263 element.lua {
 264    name    = "speed2volume",
 265    inputs  = { speed = mdb.select.vehicle_speed, param = 9 },
 266    outputs = {  mdb.table { name = "speedvol",
 267                             index = {"zone", "device"},
 268                             columns = {{"zone", mdb.string, 16},
 269                                        {"device", mdb.string, 16},
 270                                        {"value", mdb.floating}},
 271                             create = true
 272                            }
 273              },
 274    oldvolume = 0.0,
 275    update  = function(self)
 276                 speed = self.inputs.speed.single_value
 277                 if (speed) then
 278                     volume = (speed - 144.0) / 7.0
 279                 else
 280                     volume = 0.0
 281                 end
 282                 diff = volume - self.oldvolume
 283                 if (diff*diff > self.inputs.param) then
 284                     print("*** element "..self.name.." update "..volume)
 285                     self.oldvolume = volume
 286                     mdb.table.speedvol:replace({zone = "driver", device = "speakers", value = volume})
 287                 end
 288              end
 289 }
 290
 291 mdb.select {
 292     name = "amb_state",
 293     table = "amb_state",
 294     columns = { "state" },
 295     condition = "id = 0"
 296 }
 297
 298 -- Night mode processing chain
 299
 300 mdb.select {
 301     name = "exterior_brightness",
 302     table = "amb_exterior_brightness",
 303     columns = { "value" },
 304     condition = "key = 'ExteriorBrightness'"
 305 }
 306
 307 element.lua {
 308     name    = "nightmode",
 309     inputs  = { brightness = mdb.select.exterior_brightness },
 310     oldmode = -1;
 311     outputs = {
 312         mdb.table {
 313             name = "amb_nightmode",
 314             index = { "id" },
 315             create = true,
 316             columns = {
 317                 { "id", mdb.unsigned },
 318                 { "night_mode", mdb.unsigned }
 319             }
 320         }
 321     },
 322     update = function(self)
 323         -- This is a trivial function to calculate night mode. Later, we will
 324         -- need a better threshold value and hysteresis to prevent oscillation.
 325
 326         brightness = self.inputs.brightness.single_value
 327
 328         if not brightness then
 329             return
 330         end
 331
 332         print("*** element "..self.name.." update brightness: "..brightness)
 333
 334         if brightness > 300 then
 335             mode = 0
 336         else
 337             mode = 1
 338         end
 339
 340         print("*** resulting mode: ".. mode)
 341
 342         if not (mode == self.oldmode) then
 343             mdb.table.amb_nightmode:replace({ id = 0, night_mode = mode })
 344         end
 345
 346         self.oldmode = mode
 347     end
 348 }
 349
 350 mdb.select {
 351     name = "select_night_mode",
 352     table = "amb_nightmode",
 353     columns = { "night_mode" },
 354     condition = "id = 0"
 355 }
 356
 357 if with_amb then
 358     sink.lua {
 359         name = "night_mode",
 360         inputs = { NightMode = mdb.select.select_night_mode,
 361                    amb_state = mdb.select.amb_state },
 362         property = "NightMode",
 363         type = "b",
 364         initiate = builtin.method.amb_initiate,
 365         update = builtin.method.amb_update
 366     }
 367 end
 368
 369 -- Night mode general handlers
 370
 371 sink.lua {
 372     name = "nightmode_homescreen",
 373     inputs = { owner = mdb.select.select_night_mode },
 374     initiate = function(self)
 375         -- data = mdb.select.select_night_mode.single_value
 376         return true
 377     end,
 378     update = function(self)
 379         data = mdb.select.select_night_mode.single_value
 380
 381         if verbose > 1 then
 382             print("Night mode updated: " .. tostring(data))
 383         end
 384
 385         if sc then
 386             -- tell homescreen that night mode was updated
 387             sc:send_message(homescreen, m:JSON({command=0x60001,arg=m:JSON({stateid=2,state=data})}))
 388         end
 389         return true
 390     end
 391 }
 392
 393 -- Driving mode processing chain
 394
 395 element.lua {
 396     name    = "drivingmode",
 397     inputs  = { speed = mdb.select.vehicle_speed },
 398     oldmode = -1;
 399     outputs = {
 400         mdb.table {
 401             name = "amb_drivingmode",
 402             index = { "id" },
 403             create = true,
 404             columns = {
 405                 { "id", mdb.unsigned },
 406                 { "driving_mode", mdb.unsigned }
 407             }
 408         }
 409     },
 410     update = function(self)
 411
 412         speed = self.inputs.speed.single_value
 413
 414         if not speed then
 415             return
 416         end
 417
 418         if speed == 0 then
 419             mode = 0
 420         else
 421             mode = 1
 422         end
 423
 424         if not (mode == self.oldmode) then
 425             mdb.table.amb_drivingmode:replace({ id = 0, driving_mode = mode })
 426         end
 427
 428         self.oldmode = mode
 429     end
 430 }
 431
 432 mdb.select {
 433     name = "select_driving_mode",
 434     table = "amb_drivingmode",
 435     columns = { "driving_mode" },
 436     condition = "id = 0"
 437 }
 438
 439 if with_amb then
 440     sink.lua {
 441         name = "driving_mode",
 442         inputs = { DrivingMode = mdb.select.select_driving_mode,
 443                    amb_state = mdb.select.amb_state },
 444         property = "DrivingMode",
 445         type = "u",
 446         initiate = builtin.method.amb_initiate,
 447         update = builtin.method.amb_update
 448     }
 449 end
 450
 451 -- turn signals (left, right)
 452
 453 mdb.select {
 454     name = "winker",
 455     table = "amb_turn_signal",
 456     columns = { "value" },
 457     condition = "key = 'TurnSignal'"
 458 }
 459
 460 -- define three categories
 461
 462 mdb.select {
 463     name = "undefined_applications",
 464     table = "aul_applications",
 465     columns = { "appid" },
 466     condition = "category = '<undefined>'"
 467 }
 468
 469 mdb.select {
 470     name = "basic_applications",
 471     table = "aul_applications",
 472     columns = { "appid" },
 473     condition = "category = 'basic'"
 474 }
 475
 476 mdb.select {
 477     name = "entertainment_applications",
 478     table = "aul_applications",
 479     columns = { "appid" },
 480     condition = "category = 'entertainment'"
 481 }
 482
 483 function ft(t)
 484     -- filter the object garbage out of the tables
 485     ret = {}
 486
 487     for k,v in pairs(t) do
 488         if k ~= "userdata" and k ~= "new" then
 489             ret[k] = v
 490         end
 491     end
 492
 493     return ret
 494 end
 495
 496 function getApplication(appid)
 497     local conf = nil
 498
 499     -- find the correct local application definition
 500
 501     for k,v in pairs(ft(application)) do
 502         if appid == v.appid then
 503             conf = v
 504             break
 505         end
 506     end
 507
 508     return conf
 509 end
 510
 511 function regulateApplications(t, regulation)
 512     for k,v in pairs(ft(t)) do
 513
 514         -- iterate through the undefined and entertainment apps, see if
 515         -- they have been overruled in local config
 516
 517         local conf = getApplication(v.appid)
 518
 519         if conf and conf.resource_class ~= "player" then
 520             -- override, don't disable
 521             resmgr:disable_screen_by_appid("*", "*", v.appid, false, false)
 522         else
 523             resmgr:disable_screen_by_appid("*", "*", v.appid, regulation == 1, false)
 524         end
 525     end
 526     resource.method.recalc("driver")
 527 end
 528
 529 -- regulation (on), use "select_driving_mode"
 530
 531 sink.lua {
 532     name = "driving_regulation",
 533     inputs = { owner = mdb.select.select_driving_mode },
 534     initiate = function(self)
 535         -- local data = mdb.select.select_driving_mode.single_value
 536         return true
 537     end,
 538     update = function(self)
 539         local data = mdb.select.select_driving_mode.single_value
 540
 541         if verbose > 1 then
 542             print("Driving mode updated: " .. tostring(data))
 543         end
 544
 545         if not sc then
 546             return true
 547         end
 548
 549         -- tell homescreen that driving mode was updated
 550         sc:send_message(homescreen, m:JSON({command=0x60001,arg=m:JSON({stateid=1,state=data})}))
 551
 552         --[[
 553         -- bulk handle the applications that need requisites
 554         r = requisite { driving = true }
 555         resmgr:disable_screen_by_requisite("*", "*", r, data == 1, true)
 556         --]]
 557
 558         regulateApplications(ft(mdb.select.entertainment_applications), data)
 559         regulateApplications(ft(mdb.select.undefined_applications), data)
 560
 561         return true
 562     end
 563 }
 564 --[[
 565 sink.lua {
 566     name = "regulated_app_change",
 567     inputs = { undef = mdb.select.undefined_applications,
 568                entertainment = mdb.select.entertainment_applications },
 569     initiate = function(self)
 570         return true
 571     end,
 572     update = function(self)
 573         local data = mdb.select.select_driving_mode.single_value
 574
 575         if not sc then
 576             return
 577         end
 578
 579         if verbose > 1 then
 580             print("regulated application list was changed")
 581         end
 582
 583         regulateApplications(ft(mdb.select.entertainment_applications), data)
 584         regulateApplications(ft(mdb.select.undefined_applications), data)
 585
 586         return true
 587     end
 588 }
 589 --]]
 590
 591 -- shift position (parking, reverse, other)
 592
 593 mdb.select {
 594     name = "gear_position",
 595     table = "amb_gear_position",
 596     columns = { "value" },
 597     condition = "key = 'GearPosition'"
 598 }
 599
 600 -- cameras (back, front, left, right)
 601
 602 element.lua {
 603     name    = "camera_state",
 604     inputs  = { winker = mdb.select.winker, gear = mdb.select.gear_position },
 605     oldmode = -1;
 606     outputs = {
 607         mdb.table {
 608             name = "target_camera_state",
 609             index = { "id" },
 610             create = true,
 611             columns = {
 612                 { "id", mdb.unsigned },
 613                 { "front_camera", mdb.unsigned },
 614                 { "back_camera", mdb.unsigned },
 615                 { "right_camera", mdb.unsigned },
 616                 { "left_camera", mdb.unsigned }
 617             }
 618         }
 619     },
 620     update = function(self)
 621
 622         front_camera = 0
 623         back_camera = 0
 624         right_camera = 0
 625         left_camera = 0
 626
 627         if self.inputs.gear == 128 then
 628             back_camera = 1
 629         elseif self.inputs.winker == 1 then
 630             right_camera = 1
 631         elseif self.inputs.winker == 2 then
 632             left_camera = 1
 633         end
 634
 635         mdb.table.target_camera_state:replace({ id = 0, front_camera = front_camera, back_camera = back_camera, right_camera = right_camera, left_camera = left_camera })
 636
 637     end
 638 }
 639
 640 -- system controller test setup
 641
 642 if not with_system_controller then
 643    -- ok, we should have 'audio_playback' defined by now
 644    m:try_load_plugin('telephony')
 645    return
 646 end
 647
 648 m:load_plugin('system-controller')
 649
 650 window_manager_operation_names = {
 651     [1] = "create",
 652     [2] = "destroy"
 653 }
 654
 655 function window_manager_operation_name(oper)
 656     local name = window_manager_operation_names[oper]
 657     if name then return name end
 658     return "<unknown " .. tostring(oper) .. ">"
 659 end
 660
 661 window_operation_names = {
 662     [1] = "create",
 663     [2] = "destroy",
 664     [3] = "name_change",
 665     [4] = "visible",
 666     [5] = "configure",
 667     [6] = "active"
 668 }
 669
 670 function window_operation_name(oper)
 671     local name = window_operation_names[oper]
 672     if name then return name end
 673     return "<unknown " .. tostring(oper) .. ">"
 674 end
 675
 676 layer_operation_names = {
 677     [1] = "create",
 678     [2] = "destroy",
 679     [3] = "visible"
 680 }
 681
 682 function layer_operation_name(oper)
 683     local name = layer_operation_names[oper]
 684     if name then return name end
 685     return "<unknown " .. tostring(oper) .. ">"
 686 end
 687
 688 input_manager_operation_names = {
 689     [1] = "create",
 690     [2] = "destroy",
 691     [3] = "ready"
 692 }
 693
 694 function input_manager_operation_name(oper)
 695     local name = input_manager_operation_names[oper]
 696     if name then return name end
 697     return "<unknown " .. tostring(oper) .. ">"
 698 end
 699
 700 input_operation_names = {
 701     [1] = "create",
 702     [2] = "destroy",
 703     [3] = "update"
 704 }
 705
 706 function input_operation_name(oper)
 707     local name = input_operation_names[oper]
 708     if name then return name end
 709     return "<unknown " .. tostring(oper) .. ">"
 710 end
 711
 712 code_operation_names = {
 713     [1] = "create",
 714     [2] = "destroy",
 715     [3] = "state_change"
 716 }
 717
 718 function code_operation_name(oper)
 719     local name = code_operation_names[oper]
 720     if name then return name end
 721     return "<unknown " .. tostring(oper) .. ">"
 722 end
 723
 724 command_names = {
 725     [0x00001] = "send_appid",
 726     [0x10001] = "create",
 727     [0x10002] = "destroy",
 728     [0x10003] = "show",
 729     [0x10004] = "hide",
 730     [0x10005] = "move",
 731     [0x10006] = "change_active",
 732     [0x10007] = "change_layer",
 733     [0x10008] = "change_attr",
 734     [0x10009] = "name",
 735     [0x10011] = "map_thumb",
 736     [0x10012] = "unmap_thumb",
 737     [0x10020] = "show layer",
 738     [0x10021] = "hide_layer",
 739     [0x10022] = "change_layer_attr",
 740     [0x20001] = "add_input",
 741     [0x20002] = "del_input",
 742     [0x20003] = "send_input",
 743     [0x40001] = "acquire_res",
 744     [0x40002] = "release_res",
 745     [0x40003] = "deprive_res",
 746     [0x40004] = "waiting_res",
 747     [0x40005] = "revert_res",
 748     [0x40011] = "create_res",
 749     [0x40012] = "destroy_res",
 750     [0x50001] = "set_region",
 751     [0x50002] = "unset_region",
 752     [0x60001] = "change_state"
 753 }
 754
 755 function command_name(command)
 756     local name = command_names[command]
 757     if name then return name end
 758     return "<unknown " .. tostring(command) .. ">"
 759 end
 760
 761 input_layer = {
 762    [3] = true, -- input
 763    [4] = true, -- touch
 764    [5] = true  -- cursor
 765 }
 766
 767 resmgr = resource_manager {
 768   screen_event_handler = function(self, ev)
 769                              local event = ev.event
 770                              local surface = ev.surface
 771
 772                              if event == "init" then
 773                                  if verbose > 0 then
 774                                      print("*** init screen resource allocation -- disable all 'player'")
 775                                  end
 776                                  resmgr:disable_audio_by_appid("*", "player", "*", true, false)
 777                              elseif event == "preallocate" then
 778                                  if verbose > 0 then
 779                                      print("*** preallocate screen resource "..
 780                                            "for '" .. ev.appid .. "' -- enable 'player', if any")
 781                                  end
 782                                  resmgr:disable_audio_by_appid("*", "player", ev.appid, false, false)
 783                              elseif event == "grant" then
 784                                  if verbose > 0 then
 785                                     print("*** make visible surface "..surface)
 786                                  end
 787                                  local a = animation({})
 788                                  local r = m:JSON({surface = surface,
 789                                                    visible = 1,
 790                                                    raise   = 1})
 791                                  wmgr:window_request(r,a,0)
 792                              elseif event == "revoke" then
 793                                  if verbose > 0 then
 794                                     print("*** hide surface "..surface)
 795                                  end
 796                                  local a = animation({})
 797                                  local r = m:JSON({surface = ev.surface,
 798                                                    visible = 0})
 799                                  wmgr:window_request(r,a,0)
 800
 801                              elseif event == "create" then
 802
 803                                 if verbose > 0 then
 804                                     print("*** screen resource event: " ..
 805                                           tostring(ev))
 806                                 end
 807
 808                                 local regulation = mdb.select.select_driving_mode.single_value
 809
 810                                 if regulation == 1 then
 811
 812                                     local blacklisted = false
 813
 814                                     -- applications which have their category set to "entertainment"
 815                                     -- or "undefined" are blacklisted, meaning they should be regulated
 816
 817                                     for i,v in pairs(ft(mdb.select.undefined_applications)) do
 818                                         if v.appid == ev.appid then
 819                                             if verbose > 0 then
 820                                                 print(ev.appid .. " was blacklisted (undefined)")
 821                                             end
 822                                             blacklisted = true
 823                                             break
 824                                         end
 825                                     end
 826
 827                                     if not blacklisted then
 828                                         for i,v in pairs(ft(mdb.select.entertainment_applications)) do
 829                                             if v.appid == ev.appid then
 830                                                 if verbose > 0 then
 831                                                     print(ev.appid .. " was blacklisted (entertainment)")
 832                                                 end
 833                                                 blacklisted = true
 834                                                 break
 835                                             end
 836                                         end
 837                                     end
 838
 839                                     -- our local application config, which takes precedence
 840                                     local conf = getApplication(ev.appid)
 841
 842                                     -- disable only non-whitelisted applications
 843                                     if not conf or conf.resource_class == "player" then
 844                                         if blacklisted then
 845                                             if verbose > 0 then
 846                                                 print("disabling screen for " .. ev.appid)
 847                                             end
 848                                             resmgr:disable_screen_by_appid("*", "*", ev.appid, true, true)
 849                                         end
 850                                     end
 851                                 end
 852
 853                              elseif event == "destroy" then
 854                                if verbose > 0 then
 855                                     print("*** screen resource event: " ..
 856                                           tostring(ev))
 857                                  end
 858                              else
 859                                  if verbose > 0 then
 860                                     print("*** screen resource event: " ..
 861                                           tostring(ev))
 862                                  end
 863                              end
 864                          end,
 865   audio_event_handler = function(self, ev)
 866                              local event = ev.event
 867                              local appid = ev.appid
 868                              local audioid = ev.audioid
 869
 870                              if event == "grant" then
 871                                  if verbose > 0 then
 872                                     print("*** grant audio to "..appid..
 873                                           " ("..audioid..") in '" ..
 874                                           ev.zone .. "' zone")
 875                                  end
 876                              elseif event == "revoke" then
 877                                  if verbose > 0 then
 878                                     print("*** revoke audio from "..appid..
 879                                           " ("..audioid..") in '" ..
 880                                           ev.zone .. "' zone")
 881                                  end
 882                              else
 883                                  if verbose > 0 then
 884                                     print("*** audio resource event: " ..
 885                                           tostring(ev))
 886                                  end
 887                              end
 888                         end
 889 }
 890
 891 resclnt = resource_client {}
 892
 893 wmgr = window_manager {
 894   geometry = function(self, w,h, v)
 895                   if type(v) == "function" then
 896                       return v(w,h)
 897                   end
 898                   return v
 899              end,
 900
 901   application = function(self, appid)
 902                      if appid then
 903                          local app = application_lookup(appid)
 904                          if not app then
 905                              app = application_lookup("default")
 906                          end
 907                          return app
 908                      end
 909                      return { privileges = {screen="none", audio="none"} }
 910                 end,
 911
 912   output_order = { 1, 0 },
 913
 914   outputs = { { name  = "Mid",
 915                 id    = 0,
 916                 zone  = "driver",
 917                 areas = { Full = {
 918                               id     = 20,
 919                               pos_x  = 0,
 920                               pos_y  = 0,
 921                               width  = function(w,h) return w end,
 922                               height = function(w,h) return h end
 923                           },
 924                           Left = {
 925                               id     = 21,
 926                               pos_x  = 0,
 927                               pos_y  = 0,
 928                               width  = 320,
 929                               height = function(w,h) return h end
 930                           },
 931                           Right = {
 932                               id     = 22,
 933                               pos_x  = function(w,h) return w-320 end,
 934                               pos_y  = 0,
 935                               width  = 320,
 936                               height = function(w,h) return h end
 937                           }
 938                         }
 939                },
 940                { name  = "Center",
 941                  id    = 1,
 942                  zone  = "driver",
 943                  areas = { Status = {
 944                               id     = 0,
 945                               pos_x  = 0,
 946                               pos_y  = 0,
 947                               width  = function(w,h) return w end,
 948                               height = 64
 949                            },
 950                            Full = {
 951                               id     = 1,
 952                               pos_x  = 0,
 953                               pos_y  = 64,
 954                               width  = function(w,h) return w end,
 955                               height = function(w,h) return h-64-128 end
 956                            },
 957                            Upper = {
 958                               id     = 2,
 959                               pos_x  = 0,
 960                               pos_y  = 64,
 961                               width  = function(w,h) return w end,
 962                               height = function(w,h) return (h-64-128)/2 end
 963                            },
 964                            Lower = {
 965                               id     = 3,
 966                               pos_x  = 0,
 967                               pos_y  = function(w,h) return (h-64-128)/2+64 end,
 968                               width  = function(w,h) return w end,
 969                               height = function(w,h) return (h-64-128)/2 end
 970                            },
 971                            UpperLeft = {
 972                               id     = 4,
 973                               pos_x  = 0,
 974                               pos_y  = 64,
 975                               width  = function(w,h) return w/2 end,
 976                               height = function(w,h) return (h-64-128)/2 end
 977                            },
 978                            UpperRight = {
 979                               id     = 5,
 980                               pos_x  = function(w,h) return w/2 end,
 981                               pos_y  = 64,
 982                               width  = function(w,h) return w/2 end,
 983                               height = function(w,h) return (h-64-128)/2 end
 984                            },
 985                            LowerLeft = {
 986                               id     = 6,
 987                               pos_x  = 0,
 988                               pos_y  = function(w,h) return (h-64-128/2)+64 end,
 989                               width  = function(w,h) return w/2 end,
 990                               height = function(w,h) return (h-64-128)/2 end
 991                            },
 992                            LowerRight = {
 993                               id     = 7,
 994                               pos_x  = function(w,h) return w/2 end,
 995                               pos_y  = function(w,h) return (h-64-128/2)+64 end,
 996                               width  = function(w,h) return w/2 end,
 997                               height = function(w,h) return (h-64-128)/2 end
 998                            },
 999                            SysApp = {
1000                               id     = 8,
1001                               pos_x  = 0,
1002                               pos_y  = 64,
1003                               width  = function(w,h) return w end,
1004                               height = function(w,h) return h-64-128 end
1005                            },
1006                            ["SysApp.Left"] = {
1007                               id     = 9,
1008                               pos_x  = 0,
1009                               pos_y  = 64,
1010                               width  = function(w,h) return w/2-181 end,
1011                               height = function(w,h) return h-64-128 end
1012                            },
1013                            ["SysApp.Right"] = {
1014                               id     = 10,
1015                               pos_x  = function(w,h) return w/2+181 end,
1016                               pos_y  = 64,
1017                               width  = function(w,h) return w/2-181 end,
1018                               height = function(w,h) return h-64-128 end
1019                            },
1020                            Control = {
1021                               id     = 11,
1022                               pos_x  = 0,
1023                               pos_y  = function(w,h) return h-128 end,
1024                               width  = function(w,h) return w end,
1025                               height = 128
1026                            },
1027                         }
1028               }
1029   },
1030   layers = { {      0, "Background"   , 1 },
1031              {      1, "Application"  , 2 },
1032              {      2, "Softkeyboard" , 4 },
1033              {      3, "HomeScreen"   , 2 },
1034              {      4, "ControlBar"   , 2 },
1035              {      5, "InterruptApp" , 2 },
1036              {      6, "OnScreen"     , 2 },
1037              {    101, "Input"        , 3 },
1038              {    102, "Cursor"       , 5 },
1039              {    103, "Startup"      , 6 },
1040              { 0x1000, "Background"   , 1 },
1041              { 0x2000, "Normal"       , 2 },
1042              { 0x3000, "Fullscreen"   , 2 },
1043              { 0x4000, "InputPanel"   , 3 },
1044              { 0xA000, "Touch"        , 4 },
1045              { 0xB000, "Cursor"       , 5 },
1046              { 0xC000, "Startup"      , 6 }
1047   },
1048
1049
1050   manager_update = function(self, oper)
1051                        if verbose > 0 then
1052                            print("### <== WINDOW MANAGER UPDATE:" ..
1053                                  window_manager_operation_name(oper))
1054                        end
1055                        if oper == 1 then
1056                            local wumask = window_mask { raise   = true,
1057                                                         visible = true,
1058                                                         active  = true }
1059                            local wrmask = window_mask { active  = true }
1060                            local lumask = layer_mask  { visible = true }
1061                            local lrmask = layer_mask  { visible = true }
1062                            local req = m:JSON({
1063                                passthrough_window_update  = wumask:tointeger(),
1064                                passthrough_window_request = wrmask:tointeger(),
1065                                passthrough_layer_update   = lumask:tointeger(),
1066                                passthrough_layer_request  = lrmask:tointeger()
1067                            })
1068                            self:manager_request(req)
1069                        end
1070                    end,
1071
1072   window_update = function(self, oper, win, mask)
1073                       if verbose > 0 then
1074                           print("### <== WINDOW UPDATE oper:" ..
1075                                 window_operation_name(oper) ..
1076                                 " mask: " .. tostring(mask))
1077                           if verbose > 1 then
1078                               print(win)
1079                           end
1080                       end
1081
1082                       local arg = m:JSON({ surface = win.surface,
1083                                            winname = win.name,
1084                       })
1085                       local command = 0
1086
1087                       if oper == 1 then -- create
1088                            local layertype = win.layertype
1089                            if layertype and input_layer[layertype] then
1090                                if verbose > 0 then
1091                                    print("ignoring input panel creation")
1092                                end
1093                                return
1094                            end
1095                            command     = 0x10001
1096                       elseif oper == 2 then -- destroy
1097                            command     = 0x10002
1098                       elseif oper == 3 then  -- namechange
1099                            command     = 0x10009
1100                       elseif oper == 4 or oper == 5 then --visible or configure
1101                            command     = 0x10008
1102                            arg.zone    = win.area
1103                            arg.node    = win.node
1104                            arg.layer   = win.layer
1105                            arg.pos_x   = win.pos_x
1106                            arg.pos_y   = win.pos_y
1107                            arg.width   = win.width
1108                            arg.height  = win.height
1109                            arg.raise   = win.raise
1110                            arg.visible = win.visible
1111                            arg.active  = win.active
1112                       elseif oper == 6 then -- active
1113                            command     = 0x10006
1114                            arg.active  = win.active
1115                       else
1116                            if verbose > 0 then
1117                                print("### nothing to do")
1118                            end
1119                            return
1120                       end
1121
1122                       local msg = m:JSON({ command = command,
1123                                            appid   = win.appid,
1124                                            pid     = win.pid,
1125                                            arg     = arg
1126                       })
1127                       if verbose > 0 then
1128                           print("### <== sending " ..
1129                                 command_name(msg.command) ..
1130                                 " window message to '" .. win.name .. "'")
1131                           if verbose > 1 then
1132                               print(msg)
1133                           end
1134                       end
1135                       sc:send_message(homescreen, msg)
1136
1137                       if oper == 1 then -- create
1138                           local i = input_layer[win.layertype]
1139                           local p = self:application(win.appid)
1140                           local s = p.privileges.screen
1141
1142                           if s == "system" then
1143                               local a = animation({})
1144                               local r = m:JSON({surface = win.surface,
1145                                                 visible = 1,
1146                                                 raise   = 1})
1147                               self:window_request(r,a,0)
1148                           else
1149                               if i then
1150                                   if verbose > 0 then
1151                                       print("do not make resource for " ..
1152                                             "input window")
1153                                   end
1154                               else
1155                                   resclnt:resource_set_create("screen",
1156                                                                "driver",
1157                                                                win.appid,
1158                                                                win.surface)
1159                               end
1160                           end
1161                       elseif oper == 2 then -- destroy
1162                           resclnt:resource_set_destroy("screen", win.surface)
1163                       elseif oper == 6 then -- active
1164                           if win.active then
1165                               local i = input_layer[win.layertype]
1166                               local p = self:application(win.appid)
1167                               local s = p.privileges.screen
1168                               local surface = win.surface
1169                               if not i and s ~= "system" then
1170                                  resclnt:resource_set_acquire("screen",surface)
1171                                  resmgr:window_raise(win.appid, surface, 1)
1172                               end
1173                           end
1174                       end
1175                   end,
1176
1177   layer_update = function(self, oper, layer, mask)
1178                       if verbose > 0 then
1179                           print("### LAYER UPDATE:" ..
1180                                 layer_operation_name(oper) ..
1181                                 " mask: " .. tostring(mask))
1182                           if verbose > 1 then
1183                               print(layer)
1184                           end
1185                       end
1186                       if oper == 3 then -- visible
1187                          local command = 0x10022
1188                          local msg = m:JSON({
1189                                          command = command,
1190                                          appid = "",
1191                                          arg = m:JSON({layer = layer.id,
1192                                                        visible = layer.visible
1193                                          })
1194                                 })
1195                          if verbose > 0 then
1196                             print("### <== sending "..command_name(command)..
1197                                   " layer message")
1198                             if verbose > 1 then
1199                                 print(msg)
1200                             end
1201                          end
1202                          sc:send_message(homescreen, msg)
1203                       else
1204                            if verbose > 0 then
1205                                print("### nothing to do")
1206                            end
1207                       end
1208                  end,
1209
1210   output_update = function(self, oper, out, mask)
1211                       local idx = out.index
1212                       local defidx = self.output_order[idx+1]
1213                       if verbose > 0 then
1214                           print("### OUTPUT UPDATE:" .. oper ..
1215                                 " mask: "..tostring(mask))
1216                       end
1217                       if not defidx then
1218                           return
1219                       end
1220                       print(out)
1221                       local outdef = self.outputs[defidx+1]
1222                       if (oper == 1) then -- create
1223                           if outdef then
1224                               self:output_request(m:JSON({index = idx,
1225                                                           id    = outdef.id,
1226                                                           name  = outdef.name
1227                                                           }))
1228                           end
1229                       elseif (oper == 5) then -- done
1230                           local ads = outdef.areas
1231                           local on = outdef.name
1232                           if ads then
1233                               for name,ad in pairs(ads) do
1234                                   local can = wmgr:canonical_name(on.."."..name)
1235                                   local a = m:JSON({name   = name,
1236                                                     output = out.index})
1237                                   for fld,val in pairs(ad) do
1238                                       a[fld] = self:geometry(out.width,
1239                                                              out.height,
1240                                                              val)
1241                                    end
1242                                    self:area_create(a)
1243                                    resmgr:area_create(area[can], outdef.zone)
1244                               end
1245                           end
1246                       end
1247                   end
1248 }
1249
1250
1251 imgr = input_manager {
1252   inputs = {{ name = "G27 Racing Wheel",
1253               id = 0,
1254               switch = { [2] = {appid="org.tizen.ico.app-soundsample"      },
1255                          [3] = {appid="org.tizen.ico.homescreen", keycode=1},
1256                          [4] = {appid="org.tizen.ico.app-soundsample"      },
1257                          [5] = {appid="org.tizen.ico.homescreen", keycode=2}
1258              }}
1259   },
1260
1261   manager_update = function(self, oper)
1262                        if verbose > 0 then
1263                            print("### <== INPUT MANAGER UPDATE:" ..
1264                                  input_manager_operation_name(oper))
1265                        end
1266                    end,
1267
1268   input_update = function(self, oper, inp, mask)
1269                      if verbose > 0 then
1270                          print("### INPUT UPDATE:" ..
1271                                 input_operation_name(oper) ..
1272                                 " mask: " .. tostring(mask))
1273                           if verbose > 1 then
1274                               print(inp)
1275                           end
1276                       end
1277                  end,
1278   code_update  = function(self, oper, code, mask)
1279                      if verbose > 0 then
1280                          print("### CODE UPDATE: mask: " .. tostring(mask))
1281                          if verbose > 1 then
1282                              print(code)
1283                          end
1284                      end
1285                      local msg = m:JSON({ command = 1,
1286                                           appid = "org.tizen.ico.homescreen",
1287                                           arg = m:JSON({ device = code.device,
1288                                                          time = code.time,
1289                                                          input = code.input,
1290                                                          code = code.id,
1291                                                          state = code.state
1292                                            })
1293                      })
1294                      if verbose > 0 then
1295                          print("### <== sending " ..
1296                                command_name(msg.command) ..
1297                                " input message")
1298                          if verbose > 1 then
1299                              print(msg)
1300                          end
1301                      end
1302                      sc:send_message(homescreen, msg)
1303                  end
1304 }
1305
1306 sc = m:get_system_controller()
1307
1308 -- resource sets
1309 sets = {}
1310
1311 -- user manager
1312 um = m:UserManager()
1313
1314 connected = false
1315 homescreen = ""
1316
1317 -- these shoud be before wmgr:connect() is called
1318 if verbose > 0 then
1319    print("====== creating applications ======")
1320 end
1321 application {
1322     appid          = "default",
1323     area           = "Center.Full",
1324     privileges     = { screen = "none", audio = "none" },
1325     resource_class = "player",
1326     screen_priority = 0
1327 }
1328
1329 application {
1330     appid           = "weston",
1331     area            = "Center.Full",
1332     privileges      = { screen = "system", audio = "none" },
1333     resource_class  = "implicit",
1334     screen_priority = 30
1335 }
1336
1337 application {
1338     appid           = "org.tizen.ico.homescreen",
1339     area            = "Center.Full",
1340     windows         = { {'ico_hs_controlbarwindow', 'Center.Control'} },
1341     privileges      = { screen = "system", audio = "system" },
1342     resource_class  = "player",
1343     screen_priority = 20
1344 }
1345
1346 application {
1347     appid           = "org.tizen.ico.statusbar",
1348     area            = "Center.Status",
1349     privileges      = { screen = "system", audio = "none" },
1350     resource_class  = "player",
1351     screen_priority = 20
1352 }
1353
1354 application {
1355     appid           = "org.tizen.ico.onscreen",
1356     area            = "Center.Full",
1357     privileges      = { screen = "system", audio = "system" },
1358     resource_class  = "player",
1359     screen_priority = 20
1360 }
1361
1362 application {
1363     appid           = "org.tizen.ico.login",
1364     area            = "Center.Full",
1365     privileges      = { screen = "system", audio = "system" },
1366     resource_class  = "player",
1367     screen_priority = 20
1368 }
1369
1370 application {
1371     appid           = "org.tizen.ico.camera_left",
1372     area            = "Center.SysApp.Left",
1373     privileges      = { screen = "system", audio = "none" },
1374     requisites      = { screen = "blinker_left", audio = "none" },
1375     resource_class  = "player",
1376     screen_priority = 30
1377 }
1378
1379 application {
1380     appid           = "org.tizen.ico.camera_right",
1381     area            = "Center.SysApp.Right",
1382     privileges      = { screen = "system", audio = "none" },
1383     requisites      = { screen = "blinker_right", audio = "none" },
1384     resource_class  = "player",
1385     screen_priority = 30
1386 }
1387
1388 application {
1389     appid           = "net.zmap.navi",
1390     area            = "Center.Full",
1391     privileges      = { screen = "none", audio = "none" },
1392     resource_class  = "navigator",
1393     screen_priority = 30
1394 }
1395
1396 application {
1397     appid           = "GV3ySIINq7.GhostCluster",
1398     area            = "Mid.Full",
1399     privileges      = { screen = "none", audio = "none" },
1400     resource_class  = "system",
1401     screen_priority = 30
1402 }
1403
1404 if sc then
1405     sc.client_handler = function (self, cid, msg)
1406         local command = msg.command
1407         if verbose > 0 then
1408             print('### ==> client handler:')
1409             if verbose > 1 then
1410                 print(msg)
1411             end
1412         end
1413
1414         -- known commands: 1 for SEND_APPID, synthetic command 0xFFFF for
1415         -- disconnection
1416
1417         if command == 0xFFFF then
1418             if verbose > 1 then
1419                 print('client ' .. cid .. ' disconnected')
1420             end
1421             if msg.appid == homescreen then
1422                 connected = false
1423                 homescreen = ""
1424             end
1425             return
1426         end
1427
1428         -- handle the connection
1429
1430         if not connected then
1431             print('Setting homescreen='..msg.appid)
1432             homescreen = msg.appid
1433             if command and command == 1 then
1434                 send_driving_mode_to_home_screen()
1435                 send_night_mode_to_home_screen()
1436             end
1437             print('Trying to connect to wayland...')
1438             connected = wmgr:connect()
1439         end
1440         if connected and command then
1441         end
1442     end
1443
1444     sc.generic_handler = function (self, cid, msg)
1445         if verbose > 0 then
1446             print('### ==> generic handler:')
1447             if verbose > 1 then
1448                print(msg)
1449             end
1450         end
1451     end
1452
1453     sc.window_handler = function (self, cid, msg)
1454         if verbose > 0 then
1455             print('### ==> received ' ..
1456                    command_name(msg.command) .. ' message')
1457             if verbose > 1 then
1458                 print(tostring(msg))
1459             end
1460         end
1461
1462         local a = animation({})
1463         local nores = false
1464         if msg.command == 0x10003 then       -- ico SHOW command
1465             local raise_mask = 0x01000000
1466             local lower_mask = 0x02000000
1467             local nores_mask = 0x40000000
1468             local time_mask  = 0x00ffffff
1469             msg.arg.visible = 1
1470             if msg.arg then
1471                 local time = 200
1472                 if  msg.arg.anim_time then
1473                     local t = msg.arg.anim_time
1474                     time = m:AND(t, time_mask)
1475                     nores = not m:AND(t, nores_mask)
1476                     if m:AND(t, raise_mask) then
1477                         msg.arg.raise = 1
1478                     elseif m:AND(t, lower_mask) then
1479                         msg.arg.raise = 0
1480                     end
1481                 end
1482                 if msg.arg.anim_name then
1483                     a.show = { msg.arg.anim_name, time }
1484                     print('time: ' .. tostring(a.show[2]))
1485                 end
1486             end
1487             if not nores then
1488                 local p = wmgr:application(msg.appid)
1489                 local s = p.privileges.screen
1490                 if s == "system" then
1491                     nores = true
1492                     if not msg.arg.raise then
1493                         msg.arg.raise = 1
1494                     end
1495                 end
1496             end
1497             if verbose > 2 then
1498                 print('### ==> SHOW')
1499                 print(tostring(msg.arg))
1500             end
1501             if nores then
1502                 wmgr:window_request(msg.arg, a, 0)
1503             else
1504                 local surface = msg.arg.surface
1505                 resclnt:resource_set_acquire("screen", surface)
1506                 resmgr:window_raise(msg.appid, surface, 1)
1507             end
1508         elseif msg.command == 0x10004 then   -- ico HIDE command
1509             local raise_mask = 0x01000000
1510             local lower_mask = 0x02000000
1511             local nores_mask = 0x40000000
1512             local time_mask  = 0x00ffffff
1513             msg.arg.visible = 0
1514             if msg.arg then
1515                 local time = 200
1516                 if msg.arg.anim_time then
1517                     local t = msg.arg.anim_time
1518                     time = m:AND(t, time_mask)
1519                     nores = not m:AND(t, nores_mask)
1520                 end
1521                 if msg.arg.anim_name then
1522                     a.hide = { msg.arg.anim_name, time }
1523                     print('hide animation time: ' .. tostring(a.hide[2]))
1524                 end
1525             end
1526             if not nores then
1527                 local p = wmgr:application(msg.appid)
1528                 local s = p.privileges.screen
1529                 if s == "system" then
1530                     nores = true
1531                     msg.arg.raise = 0
1532                 end
1533             end
1534             if verbose > 2 then
1535                 print('### ==> HIDE REQUEST')
1536                 print(tostring(msg.arg))
1537             end
1538             if nores then
1539                 wmgr:window_request(msg.arg, a, 0)
1540             else
1541                 resmgr:window_raise(msg.appid, msg.arg.surface, -1)
1542             end
1543         elseif msg.command == 0x10005 then   -- ico MOVE
1544             if verbose > 2 then
1545                 print('### ==> MOVE REQUEST')
1546                 print(tostring(msg.arg))
1547             end
1548             if msg.arg.zone then
1549                 msg.arg.area = msg.arg.zone
1550             end
1551             wmgr:window_request(msg.arg, a, 0)
1552             -- TODO: handle if area changed
1553         elseif msg.command == 0x10006 then   -- ico ACTIVE
1554             if not msg.arg.active then
1555                 msg.arg.active = 3 -- pointer + keyboard
1556             end
1557             if verbose > 2 then
1558                 print('### ==> ACTIVE REQUEST')
1559                 print(tostring(msg.arg))
1560             end
1561             wmgr:window_request(msg.arg, a, 0)
1562         elseif msg.command == 0x10007 then   -- ico CHANGE_LAYER
1563             if verbose > 2 then
1564                 print('### ==> CHANGE_LAYER REQUEST')
1565                 print(tostring(msg.arg))
1566             end
1567             --[[
1568             if msg.arg.layer ~= 4 or msg.arg.layer ~= 5 then
1569                 print("do not change layer for other than cursor or touch")
1570                 return
1571             end
1572             --]]
1573             wmgr:window_request(msg.arg, a, 0)
1574         elseif msg.command == 0x10011 then   -- ico MAP_THUMB
1575             local framerate = msg.arg.framerate
1576             if not framerate or framerate < 0 then
1577                 framerate = 0
1578             end
1579             msg.arg.map = 1
1580             if verbose > 2 then
1581                 print('### ==> MAP_THUMB REQUEST')
1582                 print(msg.arg)
1583                 print('framerate: '..framerate)
1584             end
1585             wmgr:window_request(msg.arg, a, framerate)
1586         elseif msg.command == 0x10012 then   -- ico UNMAP_THUMB
1587             msg.arg.map = 0
1588             if verbose > 2 then
1589                 print('### ==> UNMAP_THUMB REQUEST')
1590                 print(msg.arg)
1591             end
1592             wmgr:window_request(msg.arg, a, 0)
1593         elseif msg.command == 0x10020 then   -- ico SHOW_LAYER command
1594             msg.arg.visible = 1
1595             if verbose > 2 then
1596                 print('### ==> SHOW_LAYER REQUEST')
1597                 print(msg.arg)
1598             end
1599             wmgr:layer_request(msg.arg)
1600         elseif msg.command == 0x10021 then   -- ico HIDE_LAYER command
1601             msg.arg.visible = 0
1602             if verbose > 2 then
1603                 print('### ==> HIDE_LAYER REQUEST')
1604                 print(msg.arg)
1605             end
1606             wmgr:layer_request(msg.arg)
1607         end
1608     end
1609
1610     sc.input_handler = function (self, cid, msg)
1611         if verbose > 0 then
1612             print('### ==> input handler: ' .. command_name(msg.command))
1613             if verbose > 1 then
1614                 print(msg)
1615             end
1616         end
1617         if msg.command == 0x20001 then -- add_input
1618             msg.arg.appid = msg.appid
1619             if verbose > 2 then
1620                 print('### ==> ADD_INPUT REQUEST')
1621                 print(tostring(msg.arg))
1622             end
1623             imgr:input_request(msg.arg)
1624         elseif msg.command == 0x20002 then -- del_input
1625             msg.arg.appid = ''
1626             if verbose > 2 then
1627                 print('### ==> DEL_INPUT REQUEST')
1628                 print(tostring(msg.arg))
1629             end
1630             imgr:input_request(msg.arg)
1631         elseif msg.command == 0x20003 then -- send_input
1632         end
1633     end
1634
1635     sc.user_handler = function (self, cid, msg)
1636         if verbose > 0 then
1637             print('### ==> user handler: ' .. command_name(msg.command))
1638             if verbose > 1 then
1639                 print(msg)
1640             end
1641         end
1642
1643         if not um then
1644             print("User Manager not initialized")
1645             return
1646         end
1647
1648         if msg.command == 0x00030001 then -- MSG_CMD_CHANGE_USER
1649             print("command CHANGE_USER")
1650             if not msg.arg then
1651                 print("invalid message")
1652                 return
1653             end
1654
1655             username = msg.arg.user
1656             passwd = msg.arg.pass
1657
1658             if not username then
1659                 username = ""
1660             end
1661
1662             if not passwd then
1663                 passwd = ""
1664             end
1665
1666             success = um:changeUser(username, passwd)
1667
1668             if not success then
1669                 reply = m.JSON({
1670                     appid = msg.appid,
1671                     command = cmd
1672                 })
1673                 if sc:send_message(msg.appid, reply) then
1674                     print('*** sent authentication failed message')
1675                 else
1676                     print('*** failed to send authentication failed message')
1677                 end
1678             end
1679
1680         elseif msg.command == 0x00030002 then -- MSG_CMD_GET_USERLIST
1681             print("command GET_USERLIST")
1682             if not msg.appid then
1683                 print("invalid message")
1684                 return
1685             end
1686
1687             users, currentUser = um:getUserList()
1688
1689             if not users then
1690                 print("failed to get user list")
1691                 return
1692             end
1693
1694             nUsers = 0
1695
1696             for i,v in pairs(users) do
1697                 nUsers = nUsers + 1
1698             end
1699
1700             if not currentUser then
1701                 currentUser = ""
1702             end
1703
1704             if verbose > 1 then
1705                 print("current user: " .. currentUser)
1706                 print("user list:")
1707                 for i,v in pairs(users) do
1708                     print(v)
1709                 end
1710             end
1711
1712             reply = m.JSON({
1713                 appid = msg.appid,
1714                 command = cmd,
1715                 arg = m.JSON({
1716                     user_num = nUsers,
1717                     user_list = users,
1718                     user_login = currentUser
1719                 })
1720             })
1721
1722             if verbose > 1 then
1723                 print("### <== GetUserList reply: " .. tostring(reply))
1724             end
1725
1726             if sc:send_message(msg.appid, reply) then
1727                 print('*** reply OK')
1728             else
1729                 print('*** reply FAILED')
1730             end
1731
1732         elseif msg.command == 0x00030003 then -- MSG_CMD_GET_LASTINFO
1733             print("command GET_LASTINFO")
1734             if not msg.appid then
1735                 print("invalid message")
1736                 return
1737             end
1738
1739             lastInfo = um:getLastInfo(msg.appid)
1740
1741             if not lastInfo then
1742                 print("failed to get last info for app" .. msg.appid)
1743                 return
1744             end
1745
1746             reply = m.JSON({
1747                 appid = msg.appid,
1748                 command = cmd,
1749                 arg = m.JSON({
1750                     lastinfo = lastinfo
1751                 })
1752             })
1753
1754             if sc:send_message(msg.appid, reply) then
1755                 print('*** reply OK')
1756             else
1757                 print('*** reply FAILED')
1758             end
1759
1760         elseif msg.command == 0x00030004 then -- MSG_CMD_SET_LASTINFO
1761             print("command SET_LASTINFO")
1762             if not msg.arg or not msg.appid then
1763                 print("invalid message")
1764                 return
1765             end
1766
1767             lastInfo = um:setLastInfo(msg.appid, msg.arg.lastinfo)
1768         end
1769     end
1770
1771     sc.resource_handler = function (self, cid, msg)
1772         if verbose > 0 then
1773             print('### ==> resource handler: ' .. command_name(msg.command))
1774             if verbose > 1 then
1775                 print(msg)
1776             end
1777         end
1778
1779         createResourceSet = function (ctl, client, msg)
1780             cb = function(rset, data)
1781                 print("> resource callback")
1782
1783                 -- type is either basic (0) or interrupt (1)
1784                 requestType = 0
1785                 if msg.res.type then
1786                     requestType = msg.res.type
1787                 end
1788
1789                 if rset.acquired then
1790                     cmd = 0x00040001 -- acquire
1791                 else
1792                     cmd = 0x00040002 -- release
1793                 end
1794
1795                 reply = m.JSON({
1796                         appid = data.client,
1797                         command = cmd,
1798                         res = {
1799                             type = requestType
1800                         }
1801                     })
1802
1803                 if rset.resources.audio_playback then
1804                     reply.res.sound = {
1805                         zone = "driver",
1806                         name = msg.appid,
1807                         adjust = 0,
1808                         -- id = "0"
1809                     }
1810                 end
1811
1812                 if rset.resources.display then
1813                     reply.res.window = {
1814                         zone = "driver",
1815                         name = msg.appid,
1816                         -- id = "0"
1817                     }
1818                 end
1819
1820                 if rset.resources.input then
1821                     reply.res.input = {
1822                         name = msg.appid,
1823                         event = 0
1824                     }
1825                 end
1826                 print("sending message to client: " .. data.client)
1827
1828                 if sc:send_message(data.client, reply) then
1829                     print('*** reply OK')
1830                 else
1831                     print('*** reply FAILED')
1832                 end
1833             end
1834
1835             rset = m:ResourceSet({
1836                     application_class = "player",
1837                     zone = "driver", -- msg.zone ("full")
1838                     callback = cb
1839                 })
1840
1841             rset.data = {
1842                 cid = cid,
1843                 ctl = ctl
1844             }
1845
1846             if msg.res.sound then
1847                 rset:addResource({
1848                         resource_name = "audio_playback"
1849                     })
1850                 rset.resources.audio_playback.attributes.pid = tostring(msg.pid)
1851                 rset.resources.audio_playback.attributes.appid = msg.appid
1852                 print("sound name: " .. msg.res.sound.name)
1853                 print("sound zone:" .. msg.res.sound.zone)
1854                 print("sound adjust: " .. tostring(msg.res.sound.adjust))
1855                 if msg.res.sound.id then
1856                     print("sound id: " .. msg.res.sound.id)
1857                 end
1858             end
1859
1860             if msg.res.input then
1861                 rset:addResource({
1862                         resource_name = "input"
1863                     })
1864                 rset.resources.input.attributes.pid = tostring(msg.pid)
1865                 rset.resources.input.attributes.appid = msg.appid
1866                 print("input name: " .. msg.res.sound.name)
1867                 print("input event:" .. tostring(msg.res.input.event))
1868             end
1869
1870             if msg.res.window then
1871                 rset:addResource({
1872                         resource_name = "display"
1873                     })
1874                 rset.resources.display.attributes.pid = tostring(msg.pid)
1875                 rset.resources.display.attributes.appid = msg.appid
1876                 print("display name: " .. msg.res.display.name)
1877                 print("display zone:" .. msg.res.display.zone)
1878                 if msg.res.display.id then
1879                     print("display id: " .. msg.res.display.id)
1880                 end
1881             end
1882
1883             return rset
1884         end
1885
1886         -- parse the message
1887
1888         -- fields common to all messages:
1889         --      msg.command
1890         --      msg.appid
1891         --      msg.pid
1892
1893         if msg.command == 0x00040011 then -- MSG_CMD_CREATE_RES
1894             print("command CREATE")
1895
1896             if not sets.cid then
1897                 sets.cid = createResourceSet(self, cid, msg)
1898             end
1899
1900         elseif msg.command == 0x00040012 then -- MSG_CMD_DESTORY_RES
1901             print("command DESTROY")
1902
1903             if sets.cid then
1904                 sets.cid:release()
1905             end
1906
1907             sets.cid = nil -- garbage collecting
1908
1909         elseif msg.command == 0x00040001 then -- MSG_CMD_ACQUIRE_RES
1910             print("command ACQUIRE")
1911
1912             if not sets.cid then
1913                 sets.cid = createResourceSet(self, cid, msg)
1914             end
1915
1916             sets.cid:acquire()
1917
1918         elseif msg.command == 0x00040002 then -- MSG_CMD_RELEASE_RES
1919             print("command RELEASE")
1920
1921             if sets.cid then
1922                 sets.cid:release()
1923             end
1924
1925         elseif msg.command == 0x00040003 then -- MSG_CMD_DEPRIVE_RES
1926             print("command DEPRIVE")
1927
1928         elseif msg.command == 0x00040004 then -- MSG_CMD_WAITING_RES
1929             print("command WAITING")
1930
1931         elseif msg.command == 0x00040005 then -- MSG_CMD_REVERT_RES
1932             print("command REVERT")
1933         end
1934     end
1935
1936     sc.inputdev_handler = function (self, cid, msg)
1937         if verbose > 0 then
1938             print('*** inputdev handler: ' .. command_name(msg.command))
1939             if verbose > 1 then
1940                 print(msg)
1941             end
1942         end
1943     end
1944 end
1945
1946 function send_driving_mode_to_home_screen()
1947     local driving_mode = mdb.select.select_driving_mode.single_value
1948
1949     if not driving_mode then driving_mode = 0 end
1950
1951     local reply = m:JSON({ command = 0x60001,
1952                            arg     = m:JSON({ stateid = 1,
1953                                               state   = driving_mode
1954                                      })
1955                   })
1956
1957     if verbose > 0 then
1958         print("### <== sending " .. command_name(reply.command) .. " message")
1959         if verbose > 1 then
1960             print(reply)
1961         end
1962     end
1963
1964     sc:send_message(homescreen, reply)
1965 end
1966
1967 function send_night_mode_to_home_screen()
1968     local night_mode = mdb.select.select_night_mode.single_value
1969
1970     if not night_mode then night_mode = 0 end
1971
1972     local reply = m:JSON({ command = 0x60001,
1973                            arg     = m:JSON({ stateid = 2,
1974                                               state   = night_mode
1975                                      })
1976                   })
1977
1978     if verbose > 0 then
1979         print("### <== sending " .. command_name(reply.command) .. " message")
1980         if verbose > 1 then
1981             print(reply)
1982         end
1983      end
1984
1985      sc:send_message(homescreen, reply)
1986 end
1987
1988 -- we should have 'audio_playback' defined by now
1989 m:try_load_plugin('telephony')