/usr/bin/archipel-vmrequestnode is in archipel-agent-hypervisor-platformrequest 0.6.0-1.
This file is owned by root:root, with mode 0o755.
The actual contents of the file can be viewed below.
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 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 | #! /usr/bin/python -W ignore::DeprecationWarning
#
# archipel-vmrequestnode
#
# Copyright (C) 2010 Antoine Mercadal <antoine.mercadal@inframonde.eu>
# 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/>.archipel-vmrequestnode
import os
import sys
from optparse import OptionParser
import xmpp
import archipelcore.pubsub
from archipelcore.scriptutils import *
NODENAME_REQIN = "/archipel/platform/requests/in"
NODENAME_REQOUT = "/archipel/platform/requests/out"
def create(xmppclient, pubsubserver):
"""
Create the pubsub node
"""
configIn = {
archipelcore.pubsub.XMPP_PUBSUB_VAR_ACCESS_MODEL: archipelcore.pubsub.XMPP_PUBSUB_VAR_ACCESS_MODEL_OPEN,
archipelcore.pubsub.XMPP_PUBSUB_VAR_PUBLISH_MODEL: archipelcore.pubsub.XMPP_PUBSUB_VAR_ACCESS_MODEL_OPEN,
archipelcore.pubsub.XMPP_PUBSUB_VAR_DELIVER_NOTIFICATION: 1,
archipelcore.pubsub.XMPP_PUBSUB_VAR_MAX_ITEMS: 1,
archipelcore.pubsub.XMPP_PUBSUB_VAR_PERSIST_ITEMS: 0,
archipelcore.pubsub.XMPP_PUBSUB_VAR_NOTIFY_RECTRACT: 0,
archipelcore.pubsub.XMPP_PUBSUB_VAR_DELIVER_PAYLOADS: 1,
archipelcore.pubsub.XMPP_PUBSUB_VAR_SEND_LAST_PUBLISHED_ITEM: archipelcore.pubsub.XMPP_PUBSUB_VAR_SEND_LAST_PUBLISHED_ITEM_NEVER,
archipelcore.pubsub.XMPP_PUBSUB_VAR_ITEM_REPLY: archipelcore.pubsub.XMPP_PUBSUB_VAR_ITEM_REPLY_PUBLISHER
}
configOut = {
archipelcore.pubsub.XMPP_PUBSUB_VAR_ACCESS_MODEL: archipelcore.pubsub.XMPP_PUBSUB_VAR_ACCESS_MODEL_OPEN,
archipelcore.pubsub.XMPP_PUBSUB_VAR_PUBLISH_MODEL: archipelcore.pubsub.XMPP_PUBSUB_VAR_ACCESS_MODEL_OPEN,
archipelcore.pubsub.XMPP_PUBSUB_VAR_DELIVER_NOTIFICATION: 1,
archipelcore.pubsub.XMPP_PUBSUB_VAR_MAX_ITEMS: 1,
archipelcore.pubsub.XMPP_PUBSUB_VAR_PERSIST_ITEMS: 0,
archipelcore.pubsub.XMPP_PUBSUB_VAR_NOTIFY_RECTRACT: 0,
archipelcore.pubsub.XMPP_PUBSUB_VAR_DELIVER_PAYLOADS: 1,
archipelcore.pubsub.XMPP_PUBSUB_VAR_SEND_LAST_PUBLISHED_ITEM: archipelcore.pubsub.XMPP_PUBSUB_VAR_SEND_LAST_PUBLISHED_ITEM_NEVER,
archipelcore.pubsub.XMPP_PUBSUB_VAR_ITEM_REPLY: archipelcore.pubsub.XMPP_PUBSUB_VAR_ITEM_REPLY_PUBLISHER
}
create_pubsub(xmppclient, pubsubserver, NODENAME_REQIN, configIn)
create_pubsub(xmppclient, pubsubserver, NODENAME_REQOUT, configOut)
def delete(xmppclient, pubsubserver):
"""
Delete the pubsub node
"""
delete_pubsub(xmppclient, pubsubserver, NODENAME_REQIN)
delete_pubsub(xmppclient, pubsubserver, NODENAME_REQOUT)
if __name__ == "__main__":
parser = OptionParser()
parser.add_option("-j", "--jid",
dest="jid",
help="set the JID to use",
metavar="user@domain")
parser.add_option("-p", "--password",
dest="password",
help="set the password associated to the JID",
metavar="123456")
parser.add_option("-P", "--pubsubserver",
dest="pubsubserver",
help="set the pubsubserver to use. if not given it will be pubsub.[jid.getDomain()]",
metavar="pubsub.domain",
default=None)
parser.add_option("-c", "--create",
action="store_true",
dest="create",
help="create the node")
parser.add_option("-d", "--delete",
action="store_true",
dest="delete",
help="delete the node")
options, args = parser.parse_args()
xmppclient = initialize(options)
if options.create:
create(xmppclient, options.pubsubserver)
elif options.delete:
delete(xmppclient, options.pubsubserver)
|