eisen-dev/eisen_engine

# (c) 2015, Alice Ferrazzi <alice.ferrazzi@gmail.com>
#
# This file is part of Eisen
#
# Eisen 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
# (at your option) any later version.
#
# Eisen 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 Eisen.  If not, see <http://www.gnu.org/licenses/>.
 
from flask import Flask, jsonify, abort, make_response
from flask_restful import Api, Resource, reqparse, fields, marshal
from flask_httpauth import HTTPBasicAuth
from core import PackageListUpdate, dispatcher
 
auth = HTTPBasicAuth()
 
#TODO make password auth to be same for all resource
@auth.get_password
def get_password(username):
    if username == 'ansible':
        return 'default'
    return None
 
pack_fields = {
    'target_host': fields.String,
    'command': fields.String,
    'uri': fields.Url('host')
}
 
packs = dispatcher.PackageUpdate()
 
class PackageAPI(Resource):
    decorators = [auth.login_required]
 
    def __init__(self):
        self.reqparse = reqparse.RequestParser()
        self.reqparse.add_argument('target_host', type=str, required=True,
                                   help='No task title provided',
                                   location='json')
        self.reqparse.add_argument('target_os', type=str, required=True,
                                   help='No task title provided',
                                   location='json')
        self.reqparse.add_argument('command', type=str, required=True,
                                   help='No task title provided',
                                   location='json')
        super(PackageAPI, self).__init__()
 
    def get(self):
        return {'agent': [marshal(host, pack_fields) for host in packs]}
 
    def post(self):
        args = self.reqparse.parse_args()
Similar blocks of code found in 2 locations. Consider refactoring.
        pack = {
            'id': packs[-1]['id'] + 1,
            'target_host': args['target_host'],
            'target_os': args['target_os'],
            'command': args['command'],
        }
        PackageListUpdate.package_update(pack['target_host'], pack['target_os'],
                                         pack['command'])
        return {'agent': marshal(pack, pack_fields)}, 201
 
class OsCheckAPI(Resource):
    decorators = [auth.login_required]
 
Similar blocks of code found in 2 locations. Consider refactoring.
    def __init__(self):
        self.reqparse = reqparse.RequestParser()
        self.reqparse.add_argument('module', type=str, required=True,
                                   help='No task title provided',
                                   location='json')
        self.reqparse.add_argument('version', type=str, required=True,
                                   help='No task title provided',
                                   location='json')
        super(OsCheckAPI, self).__init__()
 
    def get(self):
        PackageListUpdate.get_os()
        return {'agent': [marshal(host, pack_fields) for host in packs]}
 
Similar blocks of code found in 3 locations. Consider refactoring.
    def post(self):
        args = self.reqparse.parse_args()
        host = {
            'id': packs[-1]['id'] + 1,
            'module': args['module'],
            'version': args['version'],
        }
        packs.append(host)
        return {'agent': marshal(host, pack_fields)}, 201