diff options
Diffstat (limited to 'rhnop-client')
-rw-r--r-- | rhnop-client/conf.lua | 33 | ||||
-rwxr-xr-x | rhnop-client/nopcollect | 54 | ||||
-rw-r--r-- | rhnop-client/nopcollect.conf | 8 |
3 files changed, 95 insertions, 0 deletions
diff --git a/rhnop-client/conf.lua b/rhnop-client/conf.lua new file mode 100644 index 0000000..eb1cd29 --- /dev/null +++ b/rhnop-client/conf.lua @@ -0,0 +1,33 @@ +-- +-- rhnop +-- +-- Copyright (C) 2011 Christian Pointner <equinox@helsinki.at> +-- +-- This file is part of rhnop. +-- +-- rhnop is free software: you can redistribute it and/or modify +-- it under the terms of the GNU General Public License as published by +-- the Free Software Foundation, either version 3 of the License, or +-- any later version. +-- +-- rhnop 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 General Public License for more details. +-- +-- You should have received a copy of the GNU General Public License +-- along with rhnop. If not, see <http://www.gnu.org/licenses/>. +-- + +local conf = {} + +local file = assert(io.open("nopcollect.conf", "r")) +for line in file:lines() do + local k,v = string.match(line, "^([^=#]+)=(.*)$") + if k and v and v ~= "" then + conf[k] = v + end +end +file:close() + +return conf diff --git a/rhnop-client/nopcollect b/rhnop-client/nopcollect new file mode 100755 index 0000000..04560e2 --- /dev/null +++ b/rhnop-client/nopcollect @@ -0,0 +1,54 @@ +#!/usr/bin/lua +-- +-- rhnop +-- +-- Copyright (C) 2011 Christian Pointner <equinox@helsinki.at> +-- +-- This file is part of rhnop. +-- +-- rhnop is free software: you can redistribute it and/or modify +-- it under the terms of the GNU General Public License as published by +-- the Free Software Foundation, either version 3 of the License, or +-- any later version. +-- +-- rhnop 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 General Public License for more details. +-- +-- You should have received a copy of the GNU General Public License +-- along with rhnop. If not, see <http://www.gnu.org/licenses/>. +-- +-- +-- send now and next cart# and length to nopsyncd +-- this script should be called by the now/next macro cart +-- the arguments should be: now# nowlen next# nextlen +-- + +require "socket" + +conf = require "conf" + +-- connect to server (reconnect after error) +local sock = assert(socket.tcp()) + +local ret, err = sock:connect(conf.host, conf.port) +if ret == nil then + print(err) + return 1 +end + +print "connection established" + +-- TODO: load all info we don't have yet + +while true do + local timestamp = sock:receive('*l') + -- TODO: check if connection is closed + print("received: '" .. timestamp .. "'") + + -- TODO: check if we already fetched that timestamp + -- TODO: fetch info for the timestamp and insert it into local db +end +sock:close() +return 0 diff --git a/rhnop-client/nopcollect.conf b/rhnop-client/nopcollect.conf new file mode 100644 index 0000000..18316fb --- /dev/null +++ b/rhnop-client/nopcollect.conf @@ -0,0 +1,8 @@ +host=127.0.0.1 +port=2345 + +db=nop +#db_host=127.0.0.1 +#db_port=3306 +db_user= +db_pwd= |