summaryrefslogtreecommitdiff
path: root/xmake/modules/private/service/server/remote_build_server.lua
blob: a323132a6a5f0ace6d6427b0751bd7d23b3be85d (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
--!A cross-platform build utility based on Lua
--
-- Licensed under the Apache License, Version 2.0 (the "License");
-- you may not use this file except in compliance with the License.
-- You may obtain a copy of the License at
--
--     http://www.apache.org/licenses/LICENSE-2.0
--
-- Unless required by applicable law or agreed to in writing, software
-- distributed under the License is distributed on an "AS IS" BASIS,
-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- See the License for the specific language governing permissions and
-- limitations under the License.
--
-- Copyright (C) 2015-present, TBOOX Open Source Group.
--
-- @author      ruki
-- @file        remote_build_server.lua
--

-- imports
import("private.service.config")
import("private.service.socket_stream")
import("private.service.message")
import("private.service.server.server")

-- define module
local remote_build_server = remote_build_server or server()
local super = remote_build_server:class()

-- init server
function remote_build_server:init(daemon)
    super.init(self, daemon)
    if self:daemon() then
        config.load()
    end
    local listen = assert(config.get("remote_build.server.listen"), "config(remote_build.server.listen): not found!")
    super.listen_set(self, listen)
    super.handler_set(self, self.on_handle)
end

-- handle ping message
function remote_build_server:handle_ping(sock, msg)
    local stream = socket_stream(sock)
    if stream:send_msg(message.new_ping()) and stream:flush() then
        print("send ok")
    end
end

-- on handle message
function remote_build_server:on_handle(sock, msg)
    if msg:is_ping() then
        self:handle_ping(sock, msg)
    end
end

-- get class
function remote_build_server:class()
    return remote_build_server
end

function remote_build_server:__tostring()
    return "<remote_build_server>"
end

function main(daemon)
    local instance = remote_build_server()
    instance:init(daemon ~= nil)
    return instance
end