mirror of
https://github.com/lxsang/antos-frontend.git
synced 2024-11-15 09:18:22 +01:00
130 lines
4.3 KiB
CoffeeScript
130 lines
4.3 KiB
CoffeeScript
'use strict'
|
|
#define the OS object
|
|
self = this
|
|
self.OS or=
|
|
|
|
API: {}
|
|
GUI: {}
|
|
APP: {}
|
|
setting:
|
|
user: {}
|
|
applications: {}
|
|
desktop: {}
|
|
appearance: {}
|
|
VFS: {}
|
|
system: {}
|
|
courrier:
|
|
observable: riot.observable()
|
|
quota: 0
|
|
listeners: new Object
|
|
on: (e, f, a) ->
|
|
_courrier.listeners[a.pid] = [] unless _courrier.listeners[a.pid]
|
|
_courrier.listeners[a.pid].push { e: e, f: f }
|
|
_courrier.observable.on e, f
|
|
trigger: (e, d) -> _courrier.observable.trigger e, d
|
|
osfail: (m, e, s) ->
|
|
_courrier.ostrigger "fail", { m: m, e: e, s: s }
|
|
oserror: (m, e, s) ->
|
|
_courrier.ostrigger "error", { m: m, e: e, s: s }
|
|
osinfo: (m) ->
|
|
_courrier.ostrigger "info", { m: m, e: null, s: null }
|
|
ostrigger: (e, d) ->
|
|
_courrier.trigger e, { id: 0, data: d, name: "OS" }
|
|
unregister: (app) ->
|
|
return unless _courrier.listeners[app.pid] and _courrier.listeners[app.pid].length > 0
|
|
_courrier.observable.off i.e, i.f for i in _courrier.listeners[app.pid]
|
|
delete _courrier.listeners[app.pid]
|
|
_courrier.listeners[app.pid] = []
|
|
getMID: () ->
|
|
_courrier.quota += 1
|
|
_courrier.quota
|
|
register: (name, x) ->
|
|
if x.type is 3 then self.OS.GUI.subwindows[name] = x else _OS.APP[name] = x
|
|
|
|
PM:
|
|
pidalloc: 0
|
|
processes: {}
|
|
createProcess: (app, cls, args) ->
|
|
f = () ->
|
|
#if it is single ton
|
|
# and a process is existing
|
|
# just return it
|
|
if cls.singleton and _PM.processes[app] and _PM.processes[app].length == 1
|
|
_PM.processes[app][0].show()
|
|
else
|
|
_PM.processes[app] = [] if not _PM.processes[app]
|
|
obj = new cls(args)
|
|
obj.birth = (new Date).getTime()
|
|
_PM.pidalloc++
|
|
obj.pid = _PM.pidalloc
|
|
_PM.processes[app].push obj
|
|
if cls.type is 1 then _GUI.dock obj, cls.meta else _GUI.attachservice obj
|
|
if cls.type is 2
|
|
_courrier.trigger "srvroutineready", app
|
|
if cls.dependencies
|
|
libs = (v for v in cls.dependencies)
|
|
_API.requires libs, f
|
|
else
|
|
f()
|
|
appByPid: (pid) ->
|
|
app = undefined
|
|
find = (l) ->
|
|
return a for a in l when a.pid is pid
|
|
for k, v of _PM.processes
|
|
app = find v
|
|
break if app
|
|
app
|
|
|
|
kill: (app) ->
|
|
return if not app.name or not _PM.processes[app.name]
|
|
|
|
i = _PM.processes[app.name].indexOf app
|
|
if i >= 0
|
|
if _OS.APP[app.name].type == 1 then _GUI.undock app else _GUI.detachservice app
|
|
_courrier.unregister app
|
|
delete _PM.processes[app.name][i]
|
|
_PM.processes[app.name].splice i, 1
|
|
|
|
killAll: (app) ->
|
|
return unless _PM.processes[app]
|
|
tmp = []
|
|
tmp.push a for a in _PM.processes[app]
|
|
a.quit() for a in tmp
|
|
|
|
cleanup: ->
|
|
console.log "Clean up system"
|
|
($ "#wrapper").empty()
|
|
_GUI.clearTheme()
|
|
_courrier.observable = riot.observable()
|
|
_courrier.quota = 0
|
|
_OS.APP = {}
|
|
_OS.setting =
|
|
user: {}
|
|
applications: {}
|
|
desktop: {}
|
|
appearance: {}
|
|
VFS: {}
|
|
system: {}
|
|
_PM.processes = {}
|
|
_PM.pidalloc = 0
|
|
|
|
boot: ->
|
|
#first login
|
|
console.log "Booting sytem"
|
|
_API.handler.auth (d) ->
|
|
# in case someone call it more than once :)
|
|
if d.error
|
|
# show login screen
|
|
_GUI.login()
|
|
else
|
|
# startX :)
|
|
_GUI.startAntOS d.result
|
|
|
|
cleanupHandlers: {}
|
|
exit: ->
|
|
#do clean up first
|
|
f() for n, f of _OS.cleanupHandlers
|
|
_API.handler.setting () ->
|
|
_API.handler.logout()
|
|
onexit: (n, f) ->
|
|
self.OS.cleanupHandlers[n] = f unless self.OS.cleanupHandlers[n] |